AntonyThorpe\SilverShopUnleashed\Task\UnleashedUpdateProductTask

Complexity

Total Complexity

24

Size/Duplication

Total Lines	182
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
F	run()	0	174	24

<?php

namespace AntonyThorpe\SilverShopUnleashed\Task;

use AntonyThorpe\Consumer\Consumer;

The type AntonyThorpe\Consumer\Consumer was not found. Maybe you did not declare it correctly or list all dependencies?

use AntonyThorpe\Consumer\Utilities;

The type AntonyThorpe\Consumer\Utilities was not found. Maybe you did not declare it correctly or list all dependencies?

use AntonyThorpe\SilverShopUnleashed\BulkLoader\ProductBulkLoader;
use AntonyThorpe\SilverShopUnleashed\Task\UnleashedBuildTask;
use AntonyThorpe\SilverShopUnleashed\UnleashedAPI;
use DateTime;
use DateTimeZone;
use SilverShop\Extension\ShopConfigExtension;

The type SilverShop\Extension\ShopConfigExtension was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverShop\Page\Product;

The type SilverShop\Page\Product was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverShop\Page\ProductCategory;

The type SilverShop\Page\ProductCategory was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverStripe\Control\Email\Email;

The type SilverStripe\Control\Email\Email was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverStripe\Core\Convert;

The type SilverStripe\Core\Convert was not found. Maybe you did not declare it correctly or list all dependencies?

use SilverStripe\Dev\Debug;

The type SilverStripe\Dev\Debug was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Mailer\Exception\TransportExceptionInterface;

The type Symfony\Component\Mailer\Exception\TransportExceptionInterface was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * Update Products with fresh data from Unleashed Inventory Management Software
 */
abstract class UnleashedUpdateProductTask extends UnleashedBuildTask
{
    protected $title = "Unleashed: Update Products";

    protected $description = "Update the Products in Silvershop with data from Unleashed.  Will not automatically bring over new items but will update Titles, Base Price, etc.";

    protected string $email_subject = "API Unleashed Software - Update Product Results";

    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();
        }
    }
}