896 lines
34 KiB
PHP
896 lines
34 KiB
PHP
<?php
|
|
namespace App\Services\Catalog;
|
|
|
|
use App\Models\Fornitore;
|
|
use App\Models\Product;
|
|
use App\Models\ProductIdentifier;
|
|
use App\Models\ProductMedia;
|
|
use App\Models\ProductOffer;
|
|
use Illuminate\Support\Arr;
|
|
use Illuminate\Support\Collection;
|
|
use Illuminate\Support\Str;
|
|
use RuntimeException;
|
|
|
|
class AmazonCreatorsCatalogSyncService
|
|
{
|
|
public function __construct(
|
|
private readonly AmazonCreatorsApiService $apiService,
|
|
private readonly ProductOfferService $productOfferService,
|
|
) {
|
|
}
|
|
|
|
/** @return array<string, mixed> */
|
|
public function syncProduct(Product $product, array $options = []): array
|
|
{
|
|
$dryRun = (bool) ($options['dry_run'] ?? false);
|
|
$item = $this->resolveItemPayload($product, $options);
|
|
if (! is_array($item) || $item === []) {
|
|
throw new RuntimeException('Nessun item Amazon trovato per il prodotto selezionato.');
|
|
}
|
|
|
|
$asin = $this->extractAsin($item);
|
|
if ($asin === null) {
|
|
throw new RuntimeException('La risposta Amazon non contiene un ASIN utilizzabile.');
|
|
}
|
|
|
|
$title = $this->extractTitle($item) ?: (string) ($product->name ?? 'Prodotto Amazon');
|
|
$marketplace = trim((string) ($options['marketplace'] ?? $this->apiService->getMarketplace())) ?: $this->apiService->getMarketplace();
|
|
$associateTag = trim((string) ($options['associate_tag'] ?? $this->apiService->getAssociateTag() ?? '')) ?: null;
|
|
$detailUrl = $this->extractDetailPageUrl($item);
|
|
$referralUrl = $detailUrl !== null ? $this->appendAssociateTag($detailUrl, $associateTag) : $this->productOfferService->buildAmazonReferralUrl($product, $associateTag, $this->mapMarketplaceToLocale($marketplace));
|
|
$price = $this->extractPriceAmount($item);
|
|
$compareAt = $this->extractCompareAtAmount($item);
|
|
$currency = $this->extractCurrency($item) ?? 'EUR';
|
|
$availability = $this->extractAvailability($item) ?? 'catalog_synced';
|
|
$externalId = $asin;
|
|
$ean = $this->extractEan($item);
|
|
$upc = $this->extractUpc($item);
|
|
$manufacturerCode = $this->extractManufacturerPartNumber($item);
|
|
$imageUrls = $this->extractImageUrls($item);
|
|
$imageUrl = $imageUrls[0] ?? null;
|
|
$payloadSummary = $this->buildAmazonSnapshot($item, [
|
|
'asin' => $asin,
|
|
'ean' => $ean,
|
|
'upc' => $upc,
|
|
'manufacturer_code' => $manufacturerCode,
|
|
'title' => $title,
|
|
'marketplace' => $marketplace,
|
|
'associate_tag' => $associateTag,
|
|
'detail_url' => $detailUrl,
|
|
'referral_url' => $referralUrl,
|
|
'image_url' => $imageUrl,
|
|
'image_urls' => $imageUrls,
|
|
'price_amount' => $price,
|
|
'price_compare_at' => $compareAt,
|
|
'currency' => $currency,
|
|
'availability' => $availability,
|
|
'search_query' => trim((string) ($options['search_query'] ?? '')),
|
|
]);
|
|
|
|
$identifiersCreated = 0;
|
|
$mediaCreated = 0;
|
|
$offer = null;
|
|
|
|
if (! $dryRun) {
|
|
$identifiersCreated += $this->upsertIdentifier($product, 'asin', $asin, 'amazon_creators_api', true) ? 1 : 0;
|
|
if ($ean !== null) {
|
|
$identifiersCreated += $this->upsertIdentifier($product, 'ean', $ean, 'amazon_creators_api', false) ? 1 : 0;
|
|
}
|
|
if ($upc !== null) {
|
|
$identifiersCreated += $this->upsertIdentifier($product, 'upc', $upc, 'amazon_creators_api', false) ? 1 : 0;
|
|
}
|
|
if ($manufacturerCode !== null) {
|
|
$identifiersCreated += $this->upsertIdentifier($product, 'mpn', $manufacturerCode, 'amazon_creators_api', false) ? 1 : 0;
|
|
}
|
|
|
|
foreach (array_values(array_slice($imageUrls, 0, 12)) as $index => $remoteUrl) {
|
|
$mediaCreated += $this->upsertRemoteMedia(
|
|
$product,
|
|
$remoteUrl,
|
|
$title,
|
|
$index,
|
|
[
|
|
'provider' => 'amazon_creators_api',
|
|
'role' => $index === 0 ? 'primary' : 'gallery',
|
|
]
|
|
) ? 1 : 0;
|
|
}
|
|
|
|
$offer = $this->productOfferService->syncOffer($product, [
|
|
'source_type' => 'amazon_creators_api',
|
|
'source_name' => 'Amazon Creators API',
|
|
'external_product_id' => $externalId,
|
|
'title' => $title,
|
|
'currency' => $currency,
|
|
'price_amount' => $price,
|
|
'price_compare_at' => $compareAt,
|
|
'availability' => $availability,
|
|
'external_url' => $detailUrl,
|
|
'referral_url' => $referralUrl,
|
|
'referral_code' => $associateTag,
|
|
'is_internal' => false,
|
|
'is_active' => true,
|
|
'meta' => [
|
|
'marketplace' => $marketplace,
|
|
'sync_source' => (string) ($options['source'] ?? 'api'),
|
|
'payload' => $payloadSummary,
|
|
],
|
|
]);
|
|
}
|
|
|
|
return [
|
|
'asin' => $asin,
|
|
'title' => $title,
|
|
'detail_url' => $detailUrl,
|
|
'referral_url' => $referralUrl,
|
|
'image_url' => $imageUrl,
|
|
'image_urls' => $imageUrls,
|
|
'price_amount' => $price,
|
|
'price_compare_at' => $compareAt,
|
|
'currency' => $currency,
|
|
'availability' => $availability,
|
|
'ean' => $ean,
|
|
'upc' => $upc,
|
|
'manufacturer_code' => $manufacturerCode,
|
|
'identifiers_created' => $identifiersCreated,
|
|
'media_created' => $mediaCreated,
|
|
'offer_id' => $offer instanceof ProductOffer ? (int) $offer->id : null,
|
|
'source' => (string) ($options['source'] ?? 'api'),
|
|
'dry_run' => $dryRun,
|
|
];
|
|
}
|
|
|
|
/** @return array<int, array<string, mixed>> */
|
|
public function searchCatalog(string $query, int $limit = 8, array $options = []): array
|
|
{
|
|
$query = trim($query);
|
|
if ($query === '') {
|
|
throw new RuntimeException('Inserisci una query Amazon da cercare.');
|
|
}
|
|
|
|
$response = $this->apiService->searchItems($query, [
|
|
'marketplace' => (string) ($options['marketplace'] ?? $this->apiService->getMarketplace()),
|
|
]);
|
|
|
|
return $this->extractItems($response)
|
|
->take(max(1, $limit))
|
|
->map(function (array $item): array {
|
|
$asin = $this->extractAsin($item);
|
|
$ean = $this->extractEan($item);
|
|
$upc = $this->extractUpc($item);
|
|
$manufacturerCode = $this->extractManufacturerPartNumber($item);
|
|
$existingProduct = $this->findExistingProduct($asin, $ean, $upc, $manufacturerCode);
|
|
$detailUrl = $this->extractDetailPageUrl($item);
|
|
$associateTag = $this->apiService->getAssociateTag();
|
|
|
|
return [
|
|
'asin' => $asin,
|
|
'ean' => $ean,
|
|
'upc' => $upc,
|
|
'manufacturer_code' => $manufacturerCode,
|
|
'title' => $this->extractTitle($item) ?: 'Prodotto Amazon',
|
|
'brand' => $this->extractBrand($item),
|
|
'price_amount' => $this->extractPriceAmount($item),
|
|
'price_compare_at' => $this->extractCompareAtAmount($item),
|
|
'currency' => $this->extractCurrency($item) ?? 'EUR',
|
|
'availability' => $this->extractAvailability($item) ?? '',
|
|
'detail_url' => $detailUrl,
|
|
'referral_url' => $detailUrl !== null ? $this->appendAssociateTag($detailUrl, $associateTag) : null,
|
|
'image_url' => $this->extractPrimaryImageUrl($item),
|
|
'existing_product_id' => $existingProduct?->id,
|
|
'existing_label' => $existingProduct instanceof Product
|
|
? trim((string) ($existingProduct->internal_code ?? '') . ' · ' . (string) ($existingProduct->name ?? ''))
|
|
: '',
|
|
'item_payload' => $item,
|
|
];
|
|
})
|
|
->values()
|
|
->all();
|
|
}
|
|
|
|
/** @return array{product: Product, sync: array<string,mixed>, created: bool} */
|
|
public function importItemForSupplier(Fornitore $fornitore, array $item, array $options = []): array
|
|
{
|
|
$item = $this->enrichItem($item, $options);
|
|
|
|
$asin = $this->extractAsin($item);
|
|
if ($asin === null) {
|
|
throw new RuntimeException('Il risultato Amazon selezionato non contiene un ASIN valido.');
|
|
}
|
|
|
|
$ean = $this->extractEan($item);
|
|
$upc = $this->extractUpc($item);
|
|
$manufacturerCode = $this->extractManufacturerPartNumber($item);
|
|
$title = $this->extractTitle($item) ?: 'Prodotto Amazon';
|
|
$brand = $this->extractBrand($item);
|
|
$model = $this->extractModel($item);
|
|
$description = $this->buildDescriptionFromAmazon($item);
|
|
$product = $this->findExistingProduct($asin, $ean, $upc, $manufacturerCode);
|
|
$created = false;
|
|
|
|
$marketplace = trim((string) ($options['marketplace'] ?? $this->apiService->getMarketplace())) ?: $this->apiService->getMarketplace();
|
|
$associateTag = trim((string) ($options['associate_tag'] ?? ($this->apiService->getAssociateTag() ?? ''))) ?: null;
|
|
$detailUrl = $this->extractDetailPageUrl($item);
|
|
$referralUrl = $detailUrl !== null ? $this->appendAssociateTag($detailUrl, $associateTag) : null;
|
|
$snapshot = $this->buildAmazonSnapshot($item, [
|
|
'asin' => $asin,
|
|
'ean' => $ean,
|
|
'upc' => $upc,
|
|
'manufacturer_code' => $manufacturerCode,
|
|
'title' => $title,
|
|
'brand' => $brand,
|
|
'model' => $model,
|
|
'marketplace' => $marketplace,
|
|
'associate_tag' => $associateTag,
|
|
'detail_url' => $detailUrl,
|
|
'referral_url' => $referralUrl,
|
|
'search_query' => trim((string) ($options['search_query'] ?? '')),
|
|
'sync_source' => (string) ($options['source'] ?? 'amazon_catalog_search_ui'),
|
|
]);
|
|
|
|
if (! $product instanceof Product) {
|
|
$product = Product::query()->create([
|
|
'default_fornitore_id' => (int) $fornitore->id,
|
|
'type' => 'product',
|
|
'canonical_key' => $this->buildCanonicalKey($title, $asin, $ean),
|
|
'name' => $title,
|
|
'brand' => $brand,
|
|
'model' => $model,
|
|
'description' => $description,
|
|
'track_serials' => false,
|
|
'is_active' => true,
|
|
'meta' => [
|
|
'source' => 'amazon_creators_api',
|
|
'catalog' => [
|
|
'publication_mode' => 'internal_only',
|
|
'public_showcase' => false,
|
|
],
|
|
'verification' => [
|
|
'status' => 'pending_review',
|
|
'channel' => 'amazon_catalog_search_ui',
|
|
'updated_at' => now()->toIso8601String(),
|
|
],
|
|
'amazon' => $snapshot,
|
|
],
|
|
]);
|
|
$created = true;
|
|
} else {
|
|
$meta = is_array($product->meta ?? null) ? $product->meta : [];
|
|
$meta['source'] = $meta['source'] ?? 'amazon_creators_api';
|
|
$meta['catalog'] = array_replace([
|
|
'publication_mode' => 'internal_only',
|
|
'public_showcase' => false,
|
|
], is_array($meta['catalog'] ?? null) ? $meta['catalog'] : []);
|
|
$meta['verification'] = [
|
|
'status' => 'pending_review',
|
|
'channel' => 'amazon_catalog_search_ui',
|
|
'updated_at' => now()->toIso8601String(),
|
|
];
|
|
$meta['amazon'] = array_filter(array_replace(
|
|
is_array($meta['amazon'] ?? null) ? $meta['amazon'] : [],
|
|
$snapshot
|
|
), static fn(mixed $value): bool => $value !== null && $value !== '');
|
|
|
|
$product->fill([
|
|
'default_fornitore_id' => $product->default_fornitore_id ?: (int) $fornitore->id,
|
|
'name' => trim((string) $product->name) !== '' ? $product->name : $title,
|
|
'brand' => trim((string) ($product->brand ?? '')) !== '' ? $product->brand : $brand,
|
|
'model' => trim((string) ($product->model ?? '')) !== '' ? $product->model : $model,
|
|
'description' => trim((string) ($product->description ?? '')) !== '' ? $product->description : $description,
|
|
'meta' => $meta,
|
|
]);
|
|
$product->save();
|
|
}
|
|
|
|
$sync = $this->syncProduct($product, [
|
|
'item' => $item,
|
|
'source' => (string) ($options['source'] ?? 'amazon_catalog_search_ui'),
|
|
'marketplace' => $marketplace,
|
|
'associate_tag' => (string) ($associateTag ?? ''),
|
|
'search_query' => trim((string) ($options['search_query'] ?? '')),
|
|
]);
|
|
|
|
return [
|
|
'product' => $product->fresh(),
|
|
'sync' => $sync,
|
|
'created' => $created,
|
|
];
|
|
}
|
|
|
|
/** @param array<int, array<string, mixed>> $rows
|
|
* @return array<string, mixed>
|
|
*/
|
|
public function importSearchResultsForSupplier(Fornitore $fornitore, array $rows, array $options = []): array
|
|
{
|
|
$created = 0;
|
|
$updated = 0;
|
|
$skipped = 0;
|
|
$errors = [];
|
|
|
|
foreach ($rows as $row) {
|
|
$item = is_array($row['item_payload'] ?? null) ? $row['item_payload'] : null;
|
|
if (! is_array($item) || $item === []) {
|
|
$skipped++;
|
|
continue;
|
|
}
|
|
|
|
try {
|
|
$result = $this->importItemForSupplier($fornitore, $item, [
|
|
'source' => (string) ($options['source'] ?? 'amazon_catalog_search_bulk_ui'),
|
|
'marketplace' => (string) ($options['marketplace'] ?? $this->apiService->getMarketplace()),
|
|
'associate_tag' => (string) ($options['associate_tag'] ?? ($this->apiService->getAssociateTag() ?? '')),
|
|
'search_query' => trim((string) ($options['search_query'] ?? '')),
|
|
]);
|
|
|
|
if (! empty($result['created'])) {
|
|
$created++;
|
|
} else {
|
|
$updated++;
|
|
}
|
|
} catch (RuntimeException $e) {
|
|
$errors[] = $e->getMessage();
|
|
}
|
|
}
|
|
|
|
return [
|
|
'created' => $created,
|
|
'updated' => $updated,
|
|
'skipped' => $skipped,
|
|
'errors' => array_values(array_unique($errors)),
|
|
'processed' => $created + $updated,
|
|
];
|
|
}
|
|
|
|
/** @return array<string, mixed> */
|
|
private function resolveItemPayload(Product $product, array $options): array
|
|
{
|
|
if (is_array($options['item'] ?? null)) {
|
|
return $options['item'];
|
|
}
|
|
|
|
if (is_array($options['response'] ?? null)) {
|
|
$candidate = $this->pickFirstItem((array) $options['response']);
|
|
|
|
return is_array($candidate) ? $candidate : [];
|
|
}
|
|
|
|
$asin = trim((string) ($options['asin'] ?? $this->findIdentifierValue($product, ['asin']) ?? ''));
|
|
if ($asin !== '') {
|
|
$response = $this->apiService->getItems([$asin], [
|
|
'marketplace' => (string) ($options['marketplace'] ?? $this->apiService->getMarketplace()),
|
|
]);
|
|
|
|
return $this->pickFirstItem($response) ?? [];
|
|
}
|
|
|
|
$query = trim((string) ($options['query'] ?? $this->findIdentifierValue($product, ['ean']) ?? $this->buildSearchQuery($product)));
|
|
if ($query === '') {
|
|
return [];
|
|
}
|
|
|
|
$response = $this->apiService->searchItems($query, [
|
|
'marketplace' => (string) ($options['marketplace'] ?? $this->apiService->getMarketplace()),
|
|
]);
|
|
|
|
return $this->pickFirstItem($response) ?? [];
|
|
}
|
|
|
|
/** @return Collection<int, array<string, mixed>> */
|
|
private function extractItems(array $payload): Collection
|
|
{
|
|
foreach ([
|
|
'items',
|
|
'itemsResult.items',
|
|
'searchResult.items',
|
|
'getItemsResult.items',
|
|
'ItemsResult.Items',
|
|
'SearchResult.Items',
|
|
'GetItemsResult.Items',
|
|
'data.items',
|
|
'data.searchItems.items',
|
|
'data.getItems.items',
|
|
] as $path) {
|
|
$items = data_get($payload, $path);
|
|
if (is_array($items)) {
|
|
return collect($items)->filter(static fn(mixed $item): bool => is_array($item))->values();
|
|
}
|
|
}
|
|
|
|
return collect(isset($payload['asin']) || isset($payload['ASIN']) ? [$payload] : []);
|
|
}
|
|
|
|
/** @return array<string, mixed>|null */
|
|
private function pickFirstItem(array $payload): ?array
|
|
{
|
|
foreach ([
|
|
'items',
|
|
'itemsResult.items',
|
|
'searchResult.items',
|
|
'getItemsResult.items',
|
|
'ItemsResult.Items',
|
|
'SearchResult.Items',
|
|
'GetItemsResult.Items',
|
|
'data.items',
|
|
'data.searchItems.items',
|
|
'data.getItems.items',
|
|
] as $path) {
|
|
$items = data_get($payload, $path);
|
|
if (is_array($items) && isset($items[0]) && is_array($items[0])) {
|
|
return $items[0];
|
|
}
|
|
}
|
|
|
|
return isset($payload['asin']) || isset($payload['ASIN']) ? $payload : null;
|
|
}
|
|
|
|
private function extractAsin(array $item): ?string
|
|
{
|
|
foreach (['asin', 'ASIN', 'itemId', 'ItemId'] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractEan(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'ean',
|
|
'EAN',
|
|
'ExternalIds.EANs.DisplayValues.0',
|
|
'externalIds.eans.0',
|
|
'itemInfo.externalIds.eans.displayValues.0',
|
|
'identifiers.ean',
|
|
] as $path) {
|
|
$value = preg_replace('/\s+/', '', trim((string) data_get($item, $path, '')));
|
|
if (is_string($value) && $value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractUpc(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'UPC',
|
|
'upc',
|
|
'ExternalIds.UPCs.DisplayValues.0',
|
|
'externalIds.upcs.0',
|
|
'itemInfo.externalIds.upcs.displayValues.0',
|
|
] as $path) {
|
|
$value = preg_replace('/\s+/', '', trim((string) data_get($item, $path, '')));
|
|
if (is_string($value) && $value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractTitle(array $item): ?string
|
|
{
|
|
foreach (['title', 'Title', 'ItemInfo.Title.DisplayValue', 'itemInfo.title.displayValue'] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractBrand(array $item): ?string
|
|
{
|
|
foreach (['brand', 'Brand', 'ItemInfo.ByLineInfo.Brand.DisplayValue', 'itemInfo.byLineInfo.brand.displayValue'] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractModel(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'model',
|
|
'Model',
|
|
'ItemInfo.ManufactureInfo.Model.DisplayValue',
|
|
'itemInfo.manufactureInfo.model.displayValue',
|
|
'ItemInfo.Classifications.ProductGroup.DisplayValue',
|
|
'itemInfo.classifications.productGroup.displayValue',
|
|
] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractManufacturerPartNumber(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'manufacturer_code',
|
|
'mpn',
|
|
'MPN',
|
|
'ItemInfo.ManufactureInfo.ItemPartNumber.DisplayValue',
|
|
'itemInfo.manufactureInfo.itemPartNumber.displayValue',
|
|
] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractDetailPageUrl(array $item): ?string
|
|
{
|
|
foreach (['detailPageURL', 'DetailPageURL', 'detailPageUrl', 'url'] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractPrimaryImageUrl(array $item): ?string
|
|
{
|
|
return $this->extractImageUrls($item)[0] ?? null;
|
|
}
|
|
|
|
/** @return array<int, string> */
|
|
private function extractImageUrls(array $item): array
|
|
{
|
|
$urls = [];
|
|
|
|
foreach ([
|
|
'Images.Primary.Large.URL',
|
|
'Images.Primary.Medium.URL',
|
|
'Images.Primary.Small.URL',
|
|
'Images.Variants.*.Large.URL',
|
|
'Images.Variants.*.Medium.URL',
|
|
'Images.Variants.*.Small.URL',
|
|
'images.primary.large.url',
|
|
'images.primary.medium.url',
|
|
'images.primary.small.url',
|
|
'images.variants.*.large.url',
|
|
'images.variants.*.medium.url',
|
|
'images.variants.*.small.url',
|
|
'images.*.url',
|
|
'image',
|
|
] as $path) {
|
|
$value = data_get($item, $path);
|
|
foreach (Arr::wrap($value) as $candidate) {
|
|
$url = trim((string) $candidate);
|
|
if ($url !== '' && str_starts_with($url, 'http')) {
|
|
$urls[] = $url;
|
|
}
|
|
}
|
|
}
|
|
|
|
return array_values(array_unique($urls));
|
|
}
|
|
|
|
private function extractPriceAmount(array $item): ?float
|
|
{
|
|
foreach ([
|
|
'Offers.Listings.0.Price.Amount',
|
|
'Offers.Summaries.0.LowestPrice.Amount',
|
|
'offersV2.listings.0.price.money.amount',
|
|
'offers.listings.0.price.amount',
|
|
'offers.summaries.0.lowestPrice.amount',
|
|
'price.amount',
|
|
] as $path) {
|
|
$value = data_get($item, $path);
|
|
if (is_numeric($value)) {
|
|
return round((float) $value, 2);
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractCompareAtAmount(array $item): ?float
|
|
{
|
|
foreach ([
|
|
'Offers.Listings.0.SavingBasis.Amount',
|
|
'offersV2.listings.0.price.savingBasis.money.amount',
|
|
'offers.listings.0.savingBasis.amount',
|
|
'price.compareAt.amount',
|
|
] as $path) {
|
|
$value = data_get($item, $path);
|
|
if (is_numeric($value)) {
|
|
return round((float) $value, 2);
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractCurrency(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'Offers.Listings.0.Price.Currency',
|
|
'Offers.Summaries.0.LowestPrice.Currency',
|
|
'offersV2.listings.0.price.money.currency',
|
|
'offers.listings.0.price.currency',
|
|
'offers.summaries.0.lowestPrice.currency',
|
|
'price.currency',
|
|
] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return strtoupper($value);
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function extractAvailability(array $item): ?string
|
|
{
|
|
foreach ([
|
|
'Offers.Listings.0.Availability.Message',
|
|
'offers.listings.0.availability.message',
|
|
'availability',
|
|
] as $path) {
|
|
$value = trim((string) data_get($item, $path, ''));
|
|
if ($value !== '') {
|
|
return $value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/** @return array<int, string> */
|
|
private function extractFeaturePoints(array $item): array
|
|
{
|
|
$features = [];
|
|
|
|
foreach ([
|
|
'ItemInfo.Features.DisplayValues',
|
|
'itemInfo.features.displayValues',
|
|
'features',
|
|
'featureBullets',
|
|
] as $path) {
|
|
$value = data_get($item, $path);
|
|
foreach (Arr::wrap($value) as $candidate) {
|
|
$text = trim((string) $candidate);
|
|
if ($text !== '') {
|
|
$features[] = $text;
|
|
}
|
|
}
|
|
}
|
|
|
|
return array_values(array_unique($features));
|
|
}
|
|
|
|
private function buildDescriptionFromAmazon(array $item): ?string
|
|
{
|
|
$features = array_slice($this->extractFeaturePoints($item), 0, 8);
|
|
|
|
return $features !== [] ? implode(PHP_EOL, $features) : null;
|
|
}
|
|
|
|
/** @param array<string, mixed> $overrides
|
|
* @return array<string, mixed>
|
|
*/
|
|
private function buildAmazonSnapshot(array $item, array $overrides = []): array
|
|
{
|
|
$snapshot = array_filter([
|
|
'asin' => $this->extractAsin($item),
|
|
'ean' => $this->extractEan($item),
|
|
'upc' => $this->extractUpc($item),
|
|
'title' => $this->extractTitle($item),
|
|
'brand' => $this->extractBrand($item),
|
|
'model' => $this->extractModel($item),
|
|
'manufacturer_code' => $this->extractManufacturerPartNumber($item),
|
|
'detail_url' => $this->extractDetailPageUrl($item),
|
|
'image_url' => $this->extractPrimaryImageUrl($item),
|
|
'image_urls' => $this->extractImageUrls($item),
|
|
'price_amount' => $this->extractPriceAmount($item),
|
|
'price_compare_at' => $this->extractCompareAtAmount($item),
|
|
'currency' => $this->extractCurrency($item),
|
|
'availability' => $this->extractAvailability($item),
|
|
'feature_points' => array_slice($this->extractFeaturePoints($item), 0, 8),
|
|
'synced_at' => now()->toIso8601String(),
|
|
], static fn(mixed $value): bool => $value !== null && $value !== '' && $value !== []);
|
|
|
|
return array_filter(array_replace($snapshot, $overrides), static fn(mixed $value): bool => $value !== null && $value !== '' && $value !== []);
|
|
}
|
|
|
|
private function appendAssociateTag(string $url, ?string $associateTag): string
|
|
{
|
|
$associateTag = $associateTag !== null ? trim($associateTag) : '';
|
|
if ($associateTag === '') {
|
|
return $url;
|
|
}
|
|
|
|
$separator = str_contains($url, '?') ? '&' : '?';
|
|
|
|
return str_contains($url, 'tag=') ? $url : ($url . $separator . 'tag=' . rawurlencode($associateTag));
|
|
}
|
|
|
|
private function mapMarketplaceToLocale(string $marketplace): string
|
|
{
|
|
return match (Str::lower(trim($marketplace))) {
|
|
'www.amazon.de' => 'de',
|
|
'www.amazon.fr' => 'fr',
|
|
'www.amazon.es' => 'es',
|
|
'www.amazon.co.uk' => 'uk',
|
|
default => 'it',
|
|
};
|
|
}
|
|
|
|
/** @param array<int, string> $types */
|
|
private function findIdentifierValue(Product $product, array $types): ?string
|
|
{
|
|
$value = ProductIdentifier::query()
|
|
->where('product_id', (int) $product->id)
|
|
->whereIn('code_type', $types)
|
|
->orderByDesc('is_primary')
|
|
->orderBy('id')
|
|
->value('code_value');
|
|
|
|
$value = trim((string) $value);
|
|
|
|
return $value !== '' ? $value : null;
|
|
}
|
|
|
|
private function buildSearchQuery(Product $product): string
|
|
{
|
|
$parts = array_values(array_unique(array_filter([
|
|
trim((string) ($product->brand ?? '')),
|
|
trim((string) ($product->model ?? '')),
|
|
trim((string) ($product->name ?? '')),
|
|
], static fn(string $value): bool => $value !== '')));
|
|
|
|
return Str::limit(implode(' ', $parts), 120, '');
|
|
}
|
|
|
|
private function findExistingProduct(?string $asin, ?string $ean, ?string $upc = null, ?string $manufacturerCode = null): ?Product
|
|
{
|
|
$codes = array_values(array_filter([
|
|
$this->normalizeCode($asin),
|
|
$this->normalizeCode($ean),
|
|
$this->normalizeCode($upc),
|
|
$this->normalizeCode($manufacturerCode),
|
|
]));
|
|
|
|
if ($codes === []) {
|
|
return null;
|
|
}
|
|
|
|
$productId = ProductIdentifier::query()
|
|
->whereIn('normalized_code', $codes)
|
|
->orderByDesc('is_primary')
|
|
->value('product_id');
|
|
|
|
return $productId ? Product::query()->find((int) $productId) : null;
|
|
}
|
|
|
|
/** @param array<string, mixed> $options */
|
|
private function enrichItem(array $item, array $options = []): array
|
|
{
|
|
$asin = $this->extractAsin($item);
|
|
if ($asin === null) {
|
|
return $item;
|
|
}
|
|
|
|
$needsEnrichment = $this->extractManufacturerPartNumber($item) === null
|
|
|| $this->extractEan($item) === null
|
|
|| $this->extractPrimaryImageUrl($item) === null
|
|
|| $this->extractBrand($item) === null
|
|
|| $this->extractPriceAmount($item) === null;
|
|
|
|
if (! $needsEnrichment) {
|
|
return $item;
|
|
}
|
|
|
|
try {
|
|
$response = $this->apiService->getItems([$asin], [
|
|
'marketplace' => (string) ($options['marketplace'] ?? $this->apiService->getMarketplace()),
|
|
]);
|
|
} catch (RuntimeException) {
|
|
return $item;
|
|
}
|
|
|
|
$richItem = $this->pickFirstItem($response);
|
|
|
|
return is_array($richItem) ? $richItem : $item;
|
|
}
|
|
|
|
private function buildCanonicalKey(string $title, ?string $asin, ?string $ean): string
|
|
{
|
|
$base = Str::slug(Str::limit($title, 80, ''));
|
|
$seed = $this->normalizeCode($asin) ?: $this->normalizeCode($ean) ?: Str::upper(Str::random(8));
|
|
$key = Str::limit(($base !== '' ? $base : 'amazon-item') . '-' . Str::lower($seed), 190, '');
|
|
|
|
if (! Product::query()->where('canonical_key', $key)->exists()) {
|
|
return $key;
|
|
}
|
|
|
|
return Str::limit($key . '-' . Str::lower(Str::random(4)), 190, '');
|
|
}
|
|
|
|
private function normalizeCode(?string $value): ?string
|
|
{
|
|
$value = trim((string) $value);
|
|
if ($value === '') {
|
|
return null;
|
|
}
|
|
|
|
$normalized = strtoupper(preg_replace('/[^A-Z0-9]+/', '', $value) ?? '');
|
|
|
|
return $normalized !== '' ? $normalized : null;
|
|
}
|
|
|
|
private function upsertIdentifier(Product $product, string $type, string $value, string $source, bool $isPrimary): bool
|
|
{
|
|
$value = trim($value);
|
|
if ($value === '') {
|
|
return false;
|
|
}
|
|
|
|
$normalized = strtoupper(preg_replace('/[^A-Z0-9]+/', '', $value) ?? '');
|
|
if ($normalized === '') {
|
|
return false;
|
|
}
|
|
|
|
$identifier = ProductIdentifier::query()->firstOrNew([
|
|
'product_id' => (int) $product->id,
|
|
'code_type' => $type,
|
|
'normalized_code' => $normalized,
|
|
]);
|
|
|
|
$created = ! $identifier->exists;
|
|
$identifier->code_role = $type;
|
|
$identifier->code_value = $value;
|
|
$identifier->source = $source;
|
|
$identifier->source_reference = $value;
|
|
$identifier->is_primary = $isPrimary;
|
|
$identifier->payload = ['provider' => 'amazon'];
|
|
$identifier->save();
|
|
|
|
return $created;
|
|
}
|
|
|
|
private function upsertRemoteMedia(Product $product, string $url, string $title, int $sortOrder = 0, array $meta = []): bool
|
|
{
|
|
$url = trim($url);
|
|
if ($url === '' || ! str_starts_with($url, 'http')) {
|
|
return false;
|
|
}
|
|
|
|
$media = ProductMedia::query()->firstOrNew([
|
|
'product_id' => (int) $product->id,
|
|
'media_type' => 'image',
|
|
'disk' => 'remote-url',
|
|
'path' => $url,
|
|
]);
|
|
|
|
$created = ! $media->exists;
|
|
$media->title = $title;
|
|
$media->sort_order = max(0, $sortOrder);
|
|
$media->meta = array_replace([
|
|
'provider' => 'amazon_creators_api',
|
|
'remote' => true,
|
|
], $meta);
|
|
$media->save();
|
|
|
|
return $created;
|
|
}
|
|
}
|