-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1354 from bakaphp/hotfix-shopify-sync-price-stock
fix: shopify sync
- Loading branch information
Showing
6 changed files
with
155 additions
and
51 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
107 changes: 107 additions & 0 deletions
107
src/Domains/Connectors/Shopify/Services/ShopifyImageService.php
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,107 @@ | ||
| <?php | ||
|
|
||
| declare(strict_types=1); | ||
|
|
||
| namespace Kanvas\Connectors\Shopify\Services; | ||
|
|
||
| use Baka\Contracts\AppInterface; | ||
| use Baka\Contracts\CompanyInterface; | ||
| use Exception; | ||
| use Kanvas\Connectors\Shopify\Client; | ||
| use Kanvas\Inventory\Products\Models\Products; | ||
| use Kanvas\Inventory\Regions\Models\Regions; | ||
| use Kanvas\Inventory\Variants\Models\Variants; | ||
| use PHPShopify\ShopifySDK; | ||
|
|
||
| class ShopifyImageService | ||
| { | ||
| protected ShopifySDK $shopifySdk; | ||
|
|
||
| public function __construct( | ||
| protected AppInterface $app, | ||
| protected CompanyInterface $company, | ||
| protected Regions $region, | ||
| ) { | ||
| $this->shopifySdk = Client::getInstance($app, $company, $region); | ||
| } | ||
|
|
||
| public function processEntityImage(Products|Variants $entity): int | ||
| { | ||
| $totalUploaded = 0; | ||
| if (! $entity->files->count()) { | ||
| return $totalUploaded; | ||
| } | ||
|
|
||
| foreach ($entity->files as $file) { | ||
| if ($entity instanceof Products) { | ||
| if ($this->addImage($entity, $file->url)) { | ||
| $totalUploaded++; | ||
| } | ||
| } else { | ||
| if ($this->addVariantImage($entity, $file->url)) { | ||
| $totalUploaded++; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return $totalUploaded; | ||
| } | ||
|
|
||
| public function addImage(Products $product, string $imageUrl): ?array | ||
| { | ||
| try { | ||
| $shopifyProduct = $this->shopifySdk->Product($product->getShopifyId($this->region)); | ||
|
|
||
| $fileName = pathinfo($imageUrl, PATHINFO_BASENAME); | ||
| // Check if the image already exists | ||
| $existingImages = $shopifyProduct->Image->get(); | ||
| foreach ($existingImages as $image) { | ||
| if ($image['alt'] === $fileName) { | ||
| return null; // Image already exists, no need to upload | ||
| } | ||
| } | ||
|
|
||
| // Add the image if it does not exist | ||
| $response = $shopifyProduct->Image->post(['src' => $imageUrl, 'alt' => $fileName]); | ||
| return $response; | ||
| } catch (Exception $e) { | ||
| throw new Exception('Failed to add image to Shopify product: ' . $e->getMessage()); | ||
| } | ||
| } | ||
|
|
||
| public function addVariantImage(Variants $variant, string $imageUrl): bool | ||
| { | ||
| try { | ||
| $shopifyProduct = $this->shopifySdk->Product($variant->product->getShopifyId($this->region)); | ||
| $shopifyVariant = $shopifyProduct->Variant($variant->getShopifyId($this->region)); | ||
|
|
||
| // Check if the image already exists | ||
| $existingImages = $shopifyProduct->Image->get(); | ||
| $fileName = pathinfo($imageUrl, PATHINFO_BASENAME); | ||
|
|
||
| foreach ($existingImages as $image) { | ||
| if ($image['alt'] === $fileName) { | ||
| return false; // Image already exists, no need to upload | ||
| } | ||
| } | ||
|
|
||
| // Add the image if it does not exist | ||
| $image = $this->addImage($variant->product, $imageUrl); | ||
|
|
||
| if ($image) { | ||
| $shopifyVariantData = $shopifyVariant->get(); | ||
| $shopifyVariant->put(['image_id' => $image['id']]); | ||
|
|
||
| if ($shopifyVariantData['image_id'] !== null) { | ||
| $shopifyProduct->Image($shopifyVariantData['image_id'])->delete(); | ||
| } | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| return false; | ||
| } catch (Exception $e) { | ||
| throw new Exception('Failed to add image to Shopify variant: ' . $e->getMessage()); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters