Gm product expiration renew

.gitignore

@@ -10,3 +10,5 @@ node_modules
 .php-cs-fixer.cache
 .vscode
 tests.txt
+composer-local.json
+composer-local.lock

src/Console/GoogleMerchant/ProductsExprirationRenewCommand.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace DescomMarket\Feeds\Console\GoogleMerchant;
+
+use Illuminate\Console\Command;
+use DescomMarket\Feeds\Google\Merchant\Services\Products\ProductsExpirationRenewService;
+
+class ProductsExprirationRenewCommand extends Command
+{
+    protected $signature = 'dm360:google-merchant:products:expiration:renew {--min-expiration-days=14}';
+
+    protected $description = 'Renew Google Merchant products expiration';
+
+    public function handle()
+    {
+        $minExpirationDays = $this->option('min-expiration-days');
+
+        $success = ProductsExpirationRenewService::run($minExpirationDays);
+
+        if ($success) {
+            $this->info('Renewing Google Merchant products expiration completed.');
+        } else {
+            $this->error('Renewing Google Merchant products expiration failed.');
+        }
+    }
+}

src/DescomMarketFeedsServiceProvider.php

@@ -2,6 +2,7 @@
 
 namespace DescomMarket\Feeds;
 
+use DescomMarket\Feeds\Console\GoogleMerchant\ProductsExprirationRenewCommand;
 use DescomMarket\Feeds\Console\IndexUrlCommand;
 use DescomMarket\Feeds\Providers\EventServiceProvider;
 use Illuminate\Console\Scheduling\Schedule;
@@ -26,6 +27,7 @@ public function boot()
 
             $this->commands([
                 IndexUrlCommand::class,
+                ProductsExprirationRenewCommand::class,
             ]);
 
             $this->registerScheduler();
@@ -34,7 +36,7 @@ public function boot()
 
     private function registerScheduler()
     {
-        if (! config('feeds-google.index.enabled')) {
+        if (!config('feeds-google.index.enabled')) {
             return;
         }
 

src/Google/GoogleServiceBuilder.php

@@ -24,20 +24,18 @@ private static function service(string $serviceClassName, string|array $scopes)
     {
         $credentials = config('feeds-google.api.credentials.path');
 
-        if (! $credentials) {
+        if (!$credentials) {
             throw new \Exception('No can connect to Google without credentials json file');
         }
 
-        if (! self::$client) {
+        if (!self::$client) {
             self::$client = new Client();
 
             self::$client->setAuthConfig($credentials);
 
             self::$client->addScope($scopes);
-
         }
 
-
         return new $serviceClassName(self::$client);
     }
 }

src/Google/Merchant/Jobs/InsertProductInGoogleMerchantJob.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace DescomMarket\Feeds\Google\Merchant\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use DescomMarket\Common\Repositories\Catalog\Products\ProductRepository;
+use DescomMarket\Feeds\Google\Merchant\Services\Products\ProductInsertService;
+
+
+class InsertProductInGoogleMerchantJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public $delay;
+    public $tries;
+
+    public function __construct(private int $productId)
+    {
+        $this->delay = config('feeds-google.merchant.queue.delay', 60);
+        $this->tries = config('feeds-google.merchant.queue.tries', 10);
+        $this->queue = config('feeds-google.merchant.queue.name', 'google_merchant');
+        $this->connection = config('feeds-google.merchant.queue.connection', 'sync');
+    }
+
+    public function handle()
+    {
+        $product = ProductRepository::get($this->productId);
+
+        if (!$product) {
+            return;
+        }
+
+        $command = new ProductInsertService();
+
+        $command->run($product);
+    }
+}

src/Google/Merchant/Services/Products/ProductsExpirationRenewService.php

@@ -0,0 +1,71 @@
+<?php
+
+namespace DescomMarket\Feeds\Google\Merchant\Services\Products;
+
+use Carbon\Carbon;
+use DescomMarket\Feeds\Google\GoogleServiceBuilder;
+use DescomMarket\Feeds\Google\Merchant\Jobs\InsertProductInGoogleMerchantJob;
+
+class ProductsExpirationRenewService
+{
+    private string $merchantId;
+    private int $maxResults;
+    private ?string $pageToken;
+    private ?int $minExpirationDays;
+
+    public function __construct()
+    {
+        $this->merchantId = config('feeds-google.merchant.id') ?? '';
+        $this->maxResults = 250;
+        $this->pageToken = null;
+    }
+
+    public static function run($minExpirationDays = null): bool
+    {
+        $self = new self();
+        $self->minExpirationDays = $minExpirationDays;
+
+        if (!$self->merchantId || !$self->minExpirationDays) {
+            return false;
+        }
+
+        do {
+            $productsStatuses = $self->getProductsStatuses();
+            $self->renewProductExpiration($productsStatuses);
+        } while ($self->pageToken !== null);
+
+        return true;
+    }
+
+    private function getProductsStatuses()
+    {
+        $productsStatuses = GoogleServiceBuilder::googleMerchant()
+            ->productstatuses
+            ->listProductstatuses($this->merchantId, [
+                'maxResults' => $this->maxResults,
+                'pageToken' => $this->pageToken,
+            ]);
+
+        $this->pageToken = $productsStatuses->getNextPageToken() ?? null;
+
+        return $productsStatuses->getResources();
+    }
+
+    private function renewProductExpiration($productsStatuses = [])
+    {
+        foreach ($productsStatuses as $productStatus) {
+
+            $googleExpirationDate = Carbon::parse($productStatus->getGoogleExpirationDate());
+
+            if (Carbon::now()->diffInDays($googleExpirationDate) < $this->minExpirationDays) {
+                $productId = $this->cleanProductId($productStatus->getProductId());
+                InsertProductInGoogleMerchantJob::dispatch($productId);
+            }
+        }
+    }
+
+    private function cleanProductId(string $productId): int
+    {
+        return str_replace('online:es:ES:', '', $productId);
+    }
+}

src/Google/Merchant/Services/Products/Transformer/ProductTransformer.php

@@ -56,7 +56,7 @@ public static function transform(array $productData): Product
 
         $offer = self::offer($productData);
 
-        if (! is_null($offer)) {
+        if (!is_null($offer)) {
             $price = new Price();
             $price->setValue($offer);
             $price->setCurrency('EUR');