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

Complexity

Conditions	24
Paths	240

Size

Total Lines	174
Code Lines	113

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
    public function run($request): void
    {
        // Definitions
        $silvershopInternalItemIDMustBeUnique = Product::get()->column('InternalItemID');
        $silvershopTitleMustBeUnique = Product::get()->column('Title');
        $consumer = Consumer::get()->find('Title', 'ProductUpdate');

        // Get Products from Unleashed
        if (!$consumer) {
            $response = UnleashedAPI::sendCall(
                'GET',
                'https://api.unleashedsoftware.com/Products'
            );

            $apidata_array = (array) json_decode((string) $response->getBody(), 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/Products/' . $i
                    );
                    $apidata_array = (array) json_decode((string) $response->getBody(), true);
                    $apidata = array_merge($apidata, $apidata_array['Items']);
                }
            }
        } else {
            $query = [];
            $dateTime = new DateTime($consumer->getField('ExternalLastEdited'));
            $dateTime->setTimezone(new DateTimeZone("UTC"));  // required only for Unleashed Products (not for other endpoints)
            $query['modifiedSince'] = substr($dateTime->format('Y-m-d\TH:i:s.u'), 0, 23);

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

            $apidata_array = (array) json_decode((string) $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/Products/' . $i,
                        ['query' => $query]
                    );
                    $apidata_array = (array) json_decode((string) $response->getBody()->getContents(), true);
                    $apidata = array_merge($apidata, $apidata_array['Items']);
                }
            }
        }

        $this->log('<h2>Preliminary Checks</h2>');
        // Check for duplicates in DataList before proceeding further
        $duplicates = Utilities::getDuplicates($silvershopInternalItemIDMustBeUnique);
        if ($duplicates !== []) {
            echo "<h2>Duplicate check of Product InternalItemID within Silvershop</h2>";
            foreach ($duplicates as $duplicate) {
                $this->log($duplicate);
            }

            $this->log('Please remove duplicates from Silvershop before running this Build Task');
            $this->log('Exit');
            die();

Using exit here is not recommended.

        }

        $this->log('No duplicate found');

        $duplicates = Utilities::getDuplicates($silvershopTitleMustBeUnique);
        if ($duplicates !== []) {
            echo "<h2>Duplicate check of Product Titles within Silvershop</h2>";
            foreach ($duplicates as $duplicate) {
                $this->log($duplicate);
            }

            $this->log('Please remove duplicates from Silvershop before running this Build Task');
            $this->log('Exit');
            die();

Using exit here is not recommended.

        }

        $this->log('No duplicate found');

        // Check for duplicates in apidata before proceeding further
        $duplicates = Utilities::getDuplicates(array_column($apidata, 'ProductCode'));
        if ($duplicates !== []) {
            echo "<h2>Duplicate check of ProductCode within Unleashed</h2>";
            foreach ($duplicates as $duplicate) {
                $this->log(htmlspecialchars((string) $duplicate, ENT_QUOTES, 'utf-8'));
            }

            $this->log(
                'Please remove duplicates from Unleashed before running this Build Task'
            );
            $this->log('Exit');
            die();

Using exit here is not recommended.

        }

        $this->log('No duplicate found');

        // Update
        $this->log('<h3>Update Product records in Silvershop</h3>');
        $productBulkLoader = ProductBulkLoader::create(Product::class);
        $productBulkLoader->transforms = [
            'Parent' => [
                'callback' => function (array $value) {
                    $obj = ProductCategory::get()->find('Guid', $value['Guid']);
                    if ($obj) {
                        return $obj;
                    }

                    return ProductCategory::get()->find('Title', $value['GroupName']);
                }
            ],
            'BasePrice' => [
                'callback' => fn($value): float => (float)$value
            ],
            'Title' => [
                'callback' => function ($value, &$placeholder) {
                    $placeholder->URLSegment = Convert::raw2url($value);
                    return $value;
                }
            ]
        ];
        $bulkLoaderResult = $productBulkLoader->updateRecords($apidata, $this->preview);

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

        $this->log("Done");
        Debug::show($bulkLoaderResult->Count());
        Debug::show(!$this->preview);
        Debug::show(Email::config()->get('admin_email'));
        Debug::show($this->email_subject);
        // Send email
        if ($bulkLoaderResult->Count() && !$this->preview && Email::config()->get('admin_email') && $this->email_subject) {
            // send email
            $email = Email::create(
                ShopConfigExtension::config()->get('email_from') ?: Email::config()->get('admin_email'),
                Email::config()->get('admin_email'),
                $this->email_subject,
                Debug::text($bulkLoaderResult->getData())
            );

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

        if (!$this->preview && $apidata) {
            if (!$consumer) {
                $consumer = Consumer::create([
                    'Title' => 'ProductUpdate',
                    'ExternalLastEditedKey' => 'LastModifiedOn'
                ]);
            }

            $consumer->setMaxExternalLastEdited($apidata);
            $consumer->write();
        }