EcommerceTaskCartCleanup

Complexity

Total Complexity

59

Size/Duplication

Total Lines	379
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	run_on_demand()	0	6	1
A	runSilently()	0	6	1
F	run()	0	314	54
A	flush()	0	9	2
A	deleteObject()	0	5	1

<?php


/**
 * @description: cleans up old (abandonned) carts...
 *
 *
 * @authors: Nicolaas [at] Sunny Side Up .co.nz
 * @package: ecommerce
 * @sub-package: tasks
 * @inspiration: Silverstripe Ltd, Jeremy
 **/
class EcommerceTaskCartCleanup extends BuildTask
{
    /**
     * Standard SS Variable
     * TODO: either remove or add to all tasks.
     */
    private static $allowed_actions = array(
        '*' => 'SHOPADMIN',
    );

    protected $title = 'Clear old carts';

    protected $description = 'Deletes abandonned carts (add ?limit=xxxx to the end of the URL to set the number of records (xxx = number of records) to be deleted in one load).';

    /**
     * Output feedback about task?
     *
     * @var bool
     */
    public $verbose = false;

    /**
     * run in verbose mode.
     */
    public static function run_on_demand()
    {
        $obj = new self();
        $obj->verbose = true;
        $obj->run(null);

null is of type null, but the function expects a object<SS_HTTPRequest>.

    }

    /**
     * runs the task without output.
     */
    public function runSilently()
    {
        $this->verbose = false;

        return $this->run(null);

null is of type null, but the function expects a object<SS_HTTPRequest>.

    }
    /**
     *@return int - number of carts destroyed

Should the return type not be integer|null?

     **/
    public function run($request)
    {
        if ($this->verbose || (isset($_GET['verbose']) && Permission::check('ADMIN'))) {
            $this->verbose = true;
            $this->flush();
            $countAll = DB::query('SELECT COUNT("ID") FROM "Order"')->value();
            DB::alteration_message("<h2>deleting empty and abandonned carts (total cart count = $countAll)</h2>.");
        }

        $neverDeleteIfLinkedToMember = EcommerceConfig::get('EcommerceTaskCartCleanup', 'never_delete_if_linked_to_member');
        $maximumNumberOfObjectsDeleted = EcommerceConfig::get('EcommerceTaskCartCleanup', 'maximum_number_of_objects_deleted');

        //LIMITS ...
        if ($request) {
            $limitFromGetVar = $request->getVar('limit');
            if ($limitFromGetVar && Permission::check('ADMIN')) {
                $maximumNumberOfObjectsDeleted = intval($limitFromGetVar);
            }
        }
        $limit = '0, '.$maximumNumberOfObjectsDeleted;

$limit is not used, you could remove the assignment.

        //sort
        $sort = '"Order"."Created" ASC';

        //join
        $leftMemberJoin = 'LEFT JOIN Member ON "Member"."ID" = "Order"."MemberID"';
        $joinShort = '"Member"."ID" = "Order"."MemberID"';

        //ABANDONNED CARTS
        $clearMinutes = EcommerceConfig::get('EcommerceTaskCartCleanup', 'clear_minutes');
        $createdStepID = OrderStep::get_status_id_from_code('CREATED');
        $time = strtotime('-'.$clearMinutes.' minutes');
        $where = '"StatusID" = '.$createdStepID." AND UNIX_TIMESTAMP(\"Order\".\"LastEdited\") < $time ";
        if ($neverDeleteIfLinkedToMember) {
            $userStatement = 'or have a user associated with it';
            $withoutMemberWhere = ' AND "Member"."ID" IS NULL ';
            $withMemberWhere = ' OR "Member"."ID" IS NOT NULL ';
            $memberDeleteNote = '(Carts linked to a member will NEVER be deleted)';
        } else {
            $userStatement = '';
            $withoutMemberWhere = '  ';
            $withMemberWhere = '';
            $memberDeleteNote = '(We will also delete carts in this category that are linked to a member)';
        }
        $oldCarts = Order::get()
            ->where($where.$withoutMemberWhere)
            ->sort($sort)
            ->limit($maximumNumberOfObjectsDeleted);
        $oldCarts = $oldCarts->leftJoin('Member', $joinShort);
        if ($oldCarts->count()) {
            $count = 0;
            if ($this->verbose) {
                $this->flush();
                $totalToDeleteSQLObject = DB::query(
                    '
                    SELECT COUNT(*)
                    FROM "Order"
                        '.$leftMemberJoin.'
                    WHERE '
                        .$where
                        .$withoutMemberWhere
                    .';'
                );
                $totalToDelete = $totalToDeleteSQLObject->value();
                DB::alteration_message('
                        <h2>Total number of abandonned carts: '.$totalToDelete.'</h2>
                        <br /><b>number of records deleted at one time:</b> '.$maximumNumberOfObjectsDeleted.'
                        <br /><b>Criteria:</b> last edited '.$clearMinutes.' (~'.round($clearMinutes / 60 / 24, 2)." days)
                        minutes ago or more $memberDeleteNote", 'created');
            }
            foreach ($oldCarts as $oldCart) {
                $count++;
                if ($this->verbose) {
                    $this->flush();
                    DB::alteration_message("$count ... deleting abandonned order #".$oldCart->ID, 'deleted');
                }
                $this->deleteObject($oldCart);
            }
        } else {
            if ($this->verbose) {
                $this->flush();
                DB::alteration_message('There are no old carts', 'created');
            }
        }
        if ($this->verbose) {
            $this->flush();
            $timeLegible = date('Y-m-d H:i:s', $time);
            $countCart = DB::query('SELECT COUNT("ID") FROM "Order" WHERE "StatusID" = '.$createdStepID.' ')->value();
            $countCartWithinTimeLimit = DB::query('
                SELECT COUNT("Order"."ID")
                FROM "Order"
                    '.$leftMemberJoin.'
                WHERE "StatusID" = '.$createdStepID.'
                AND
                (
                    UNIX_TIMESTAMP("Order"."LastEdited") >= '.$time .'
                    '.$withMemberWhere.'
                );
            ')->value();
            DB::alteration_message(
                "
                    $countCart Orders are still in the CREATED cart state (not submitted),
                    $countCartWithinTimeLimit of them are within the time limit (last edited after $timeLegible)
                    ".$userStatement." so they are not deleted.",
                'created'
            );
        }

        //EMPTY ORDERS
        $clearMinutes = EcommerceConfig::get('EcommerceTaskCartCleanup', 'clear_minutes_empty_carts');
        $time = strtotime('-'.$clearMinutes.' minutes');
        $where = "\"StatusID\" = 0 AND UNIX_TIMESTAMP(\"Order\".\"LastEdited\") < $time ";
        $oldCarts = Order::get()
            ->where($where)
            ->sort($sort)
            ->limit($maximumNumberOfObjectsDeleted);
        $oldCarts = $oldCarts->leftJoin('Member', $joinShort);
        if ($oldCarts->count()) {
            $count = 0;
            if ($this->verbose) {
                $this->flush();
                $totalToDelete = DB::query(
                    '
                    SELECT COUNT(*)
                    FROM "Order"
                        '.$leftMemberJoin.'
                    WHERE '
                        .$where
                        .$withoutMemberWhere
                    .';'
                )->value();
                DB::alteration_message('
                        <h2>Total number of empty carts: '.$totalToDelete.'</h2>
                        <br /><b>number of records deleted at one time:</b> '.$maximumNumberOfObjectsDeleted."
                        <br /><b>Criteria:</b> there are no order items and
                        the order was last edited $clearMinutes minutes ago $memberDeleteNote", 'created');
            }
            foreach ($oldCarts as $oldCart) {
                ++$count;
                if ($this->verbose) {
                    $this->flush();
                    DB::alteration_message("$count ... deleting empty order #".$oldCart->ID, 'deleted');
                }
                $this->deleteObject($oldCart);
            }
        }
        if ($this->verbose) {
            $this->flush();
            $timeLegible = date('Y-m-d H:i:s', $time);
            $countCart = DB::query(
                '
                SELECT COUNT("Order"."ID")
                FROM "Order"
                    '.$leftMemberJoin.'
                WHERE "StatusID" = 0 '
            )->value();
            $countCartWithinTimeLimit = DB::query(
                '
                SELECT COUNT("Order"."ID")
                FROM "Order"
                    '.$leftMemberJoin.'
                WHERE "StatusID" = 0 AND
                (
                    UNIX_TIMESTAMP("Order"."LastEdited") >= '.$time.'
                    '.$withMemberWhere.'
                )'
            )->value();
            DB::alteration_message(
                "
                    $countCart Orders are without status at all,
                    $countCartWithinTimeLimit are within the time limit (last edited after $timeLegible)
                    ".$userStatement."so they are not deleted yet.",
                'created'
            );
        }

        $oneToMany = EcommerceConfig::get('EcommerceTaskCartCleanup', 'one_to_many_classes');
        $oneToOne = EcommerceConfig::get('EcommerceTaskCartCleanup', 'one_to_one_classes');
        $manyToMany = EcommerceConfig::get('EcommerceTaskCartCleanup', 'many_to_many_classes');
        if (!is_array($oneToOne)) {
            $oneToOne = array();
        }
        if (!is_array($oneToMany)) {
            $oneToMany = array();
        }
        if (!is_array($manyToMany)) {
            $manyToMany = array();
        }

        /***********************************************
        //CLEANING ONE-TO-ONES
        ************************************************/
        if ($this->verbose) {
            $this->flush();
            DB::alteration_message('<h2>Checking one-to-one relationships</h2>.');
        }
        if (count($oneToOne)) {
            foreach ($oneToOne as $orderFieldName => $className) {
                if (!in_array($className, $oneToMany) && !in_array($className, $manyToMany)) {
                    if ($this->verbose) {
                        $this->flush();
                        DB::alteration_message("looking for $className objects without link to order.");
                    }
                    $rows = DB::query("
                        SELECT \"$className\".\"ID\"
                        FROM \"$className\"
                            LEFT JOIN \"Order\"
                                ON \"Order\".\"$orderFieldName\" = \"$className\".\"ID\"
                        WHERE \"Order\".\"ID\" IS NULL
                        LIMIT 0, ".$maximumNumberOfObjectsDeleted);
                    //the code below is a bit of a hack, but because of the one-to-one relationship we
                    //want to check both sides....
                    $oneToOneIDArray = array();
                    if ($rows) {
                        foreach ($rows as $row) {
                            $oneToOneIDArray[$row['ID']] = $row['ID'];
                        }
                    }
                    if (count($oneToOneIDArray)) {
                        $unlinkedObjects = $className::get()
                            ->filter(array('ID' => $oneToOneIDArray));
                        if ($unlinkedObjects->count()) {
                            foreach ($unlinkedObjects as $unlinkedObject) {
                                if ($this->verbose) {
                                    $this->flush();
                                    DB::alteration_message('Deleting '.$unlinkedObject->ClassName.' with ID #'.$unlinkedObject->ID.' because it does not appear to link to an order.', 'deleted');
                                }
                                $this->deleteObject($unlinkedObject);
                            }
                        } else {
                            if ($this->verbose) {
                                $this->flush();
                                DB::alteration_message("No objects where found for $className even though there appear to be missing links.", 'created');
                            }
                        }
                    } elseif ($this->verbose) {
                        $this->flush();
                        DB::alteration_message("All references in Order to $className are valid.", 'created');
                    }
                    if ($this->verbose) {
                        $this->flush();
                        $countAll = DB::query("SELECT COUNT(\"ID\") FROM \"$className\"")->value();
                        $countUnlinkedOnes = DB::query("SELECT COUNT(\"$className\".\"ID\") FROM \"$className\" LEFT JOIN \"Order\" ON \"$className\".\"ID\" = \"Order\".\"$orderFieldName\" WHERE \"Order\".\"ID\" IS NULL")->value();
                        DB::alteration_message("In total there are $countAll $className ($orderFieldName), of which there are $countUnlinkedOnes not linked to an order. ", 'created');
                        if ($countUnlinkedOnes) {
                            DB::alteration_message("There should be NO $orderFieldName ($className) without link to Order - un error is suspected", 'deleted');
                        }
                    }
                }
            }
        }

        /***********************************************
        //CLEANING ONE-TO-MANY
        *************************************************/

        //one order has many other things so we increase the ability to delete stuff
        $maximumNumberOfObjectsDeleted = $maximumNumberOfObjectsDeleted * 25;
        if ($this->verbose) {
            $this->flush();
            DB::alteration_message('<h2>Checking one-to-many relationships</h2>.');
        }
        if (count($oneToMany)) {
            foreach ($oneToMany as $classWithOrderID => $classWithLastEdited) {
                if (!in_array($classWithLastEdited, $oneToOne) && !in_array($classWithLastEdited, $manyToMany)) {
                    if ($this->verbose) {
                        $this->flush();
                        DB::alteration_message("looking for $classWithOrderID objects without link to order.");
                    }
                    $rows = DB::query("
                        SELECT \"$classWithOrderID\".\"ID\"
                        FROM \"$classWithOrderID\"
                            LEFT JOIN \"Order\"
                                ON \"Order\".\"ID\" = \"$classWithOrderID\".\"OrderID\"
                        WHERE \"Order\".\"ID\" IS NULL
                        LIMIT 0, ".$maximumNumberOfObjectsDeleted);
                    $oneToManyIDArray = array();
                    if ($rows) {
                        foreach ($rows as $row) {
                            $oneToManyIDArray[$row['ID']] = $row['ID'];
                        }
                    }
                    if (count($oneToManyIDArray)) {
                        $unlinkedObjects = $classWithLastEdited::get()
                            ->filter(array('ID' => $oneToManyIDArray));
                        if ($unlinkedObjects->count()) {
                            foreach ($unlinkedObjects as $unlinkedObject) {
                                if ($this->verbose) {
                                    DB::alteration_message('Deleting '.$unlinkedObject->ClassName.' with ID #'.$unlinkedObject->ID.' because it does not appear to link to an order.', 'deleted');
                                }
                                $this->deleteObject($unlinkedObject);
                            }
                        } elseif ($this->verbose) {
                            $this->flush();
                            DB::alteration_message("$classWithLastEdited objects could not be found even though they were referenced.", 'deleted');
                        }
                    } elseif ($this->verbose) {
                        $this->flush();
                        DB::alteration_message("All $classWithLastEdited objects have a reference to a valid order.", 'created');
                    }
                    if ($this->verbose) {
                        $this->flush();
                        $countAll = DB::query("SELECT COUNT(\"ID\") FROM \"$classWithLastEdited\"")->value();
                        $countUnlinkedOnes = DB::query("SELECT COUNT(\"$classWithOrderID\".\"ID\") FROM \"$classWithOrderID\" LEFT JOIN \"Order\" ON \"$classWithOrderID\".\"OrderID\" = \"Order\".\"ID\" WHERE \"Order\".\"ID\" IS NULL")->value();
                        DB::alteration_message("In total there are $countAll $classWithOrderID ($classWithLastEdited), of which there are $countUnlinkedOnes not linked to an order. ", 'created');
                    }
                }
            }
        }
        if ($this->verbose) {
            $this->flush();
            DB::alteration_message('---------------- DONE --------------------');
        }
    }

    private function flush()
    {
        if ((php_sapi_name() === 'cli')) {
            echo "\n";
        } else {
            ob_flush();
            flush();
        }
    }

    /**
     * delete an object
     * @param  DataObject
     * @return null
     */
    private function deleteObject($objectToDelete)
    {
        $objectToDelete->delete();
        $objectToDelete->destroy();
    }
}