AntonyThorpe\SilverShopUnleashed\Task\UnleashedUpdateOrderTask::run()

Complexity

Conditions	17
Paths	148

Size

Total Lines	84
Code Lines	53

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function run($request)
    {
        // Definitions
        $default_source_id = Defaults::config()->source_id;
        $query = [];
        $consumer = Consumer::get()->find('Title', 'OrderUpdate');  // to get modifiedSince

        if ($consumer) {

$consumer is of type SilverStripe\ORM\DataObject, thus it always evaluated to true.

            $date = new DateTime($consumer->ExternalLastEdited);
            $query['modifiedSince'] = substr($date->format('Y-m-d\TH:i:s.u'), 0, 23);
        }

        if ($default_source_id) {
            $query['sourceId'] = $default_source_id;
        }

        $response = UnleashedAPI::sendCall(
            'GET',
            'https://api.unleashedsoftware.com/SalesOrders',
            ['query' => $query]
        );

        if ($response->getStatusCode() == '200') {
            $apidata_array = json_decode($response->getBody()->getContents(), true);
            $apidata = $apidata_array['Items'];
            $pagination = $apidata_array['Pagination'];
            $numberofpages = (int) $pagination['NumberOfPages'];

            if ($numberofpages > 1) {
                for ($i = 2; $i <= $numberofpages; $i++) {
                    $response = UnleashedAPI::sendCall(
                        'GET',
                        'https://api.unleashedsoftware.com/SalesOrders/' . $i,
                        ['query' => $query]
                    );
                    if ($response->getStatusCode() == '200') {
                        $apidata_array = json_decode($response->getBody()->getContents(), true);
                        $apidata = array_merge($apidata, $apidata_array['Items']);
                    }
                }
            }

            $this->log('<h3>Update the OrderStatus in Silvershop</h3>');
            $loader = OrderBulkLoader::create('SilverShop\Model\Order');
            $loader->transforms = [
                'Status' => [
                    'callback' => function ($value) {
                        // convert from Unleashed Sales Order status to Silvershop
                        return $this->order_status_map[$value];
                    }
                ]
            ];
            $results = $loader->updateRecords($apidata, $this->preview);

            if ($results->UpdatedCount()) {
                $this->log(Debug::text($results->getData()));
            }
            $this->log("Done");

            // Send email
            if ($results->Count() && $this->email_subject && !$this->preview && Email::config()->admin_email) {
                $data = $results->getData();
                $email = Email::create(
                    ShopConfigExtension::config()->email_from ? ShopConfigExtension::config()->email_from : Email::config()->admin_email,
                    Email::config()->admin_email,
                    $this->email_subject,
                    Debug::text($data)
                );
                $dispatched = $email->send();
                if ($dispatched) {
                    $this->log("Email sent");
                }
            }

            // Create/update Consumer
            if (!$this->preview && $apidata) {
                if (!$consumer) {

$consumer is of type SilverStripe\ORM\DataObject, thus it always evaluated to true.

                    $consumer = Consumer::create([
                        'Title' => 'OrderUpdate',
                        'ExternalLastEditedKey' => 'LastModifiedOn'
                    ]);
                }
                $consumer->setMaxExternalLastEdited($apidata);
                $consumer->write();
            }