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

Complexity

Conditions	18
Paths	436

Size

Total Lines	91
Code Lines	59

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) {
            $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 = (array) json_decode($response->getBody(), true);
            $apidata = $apidata_array['Items'];
            $pagination = $apidata_array['Pagination'];
            $numberofpages = intval($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 = (array) json_decode($response->getBody(), true);
                        $apidata = array_merge($apidata, $apidata_array['Items']);
                    }
                }
            }

            $this->log('<h3>Update the OrderStatus in Silvershop</h3>');
            $loader = OrderBulkLoader::create(Order::class);
            $loader->transforms = [
                'Status' => [
                    'callback' => fn($value) =>
                        // convert from Unleashed Sales Order status to Silvershop
                        $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 ?: Email::config()->admin_email,
                    Email::config()->admin_email,
                    $this->email_subject,
                    Debug::text($data)
                );

                $dispatched = true;
                try {
                    $email->send();
                } catch (TransportExceptionInterface $e) {
                    $dispatched = false;
                    $this->log("Email not sent: " . $e->getDebug());
                } finally {
                    if ($dispatched) {
                        $this->log("Email sent");
                    }
                }
            }

            // Create/update Consumer
            if (!$this->preview && $apidata) {
                if (!$consumer) {
                    $consumer = Consumer::create([
                        'Title' => 'OrderUpdate',
                        'ExternalLastEditedKey' => 'LastModifiedOn'
                    ]);
                }
                $consumer->setMaxExternalLastEdited($apidata);
                $consumer->write();
            }