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

Complexity

Conditions	18
Paths	436

Size

Total Lines	96
Code Lines	60

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

        if ($consumer) {
            $query['modifiedSince'] = substr(
                $consumer->dbObject('ExternalLastEdited')->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((string) $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((string) $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()->get('admin_email')) {
                $data = $results->getData();
                $email = Email::create(
                    ShopConfigExtension::config()->get('email_from') ?: Email::config()->get('admin_email'),
                    Email::config()->get('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();
            }