mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新云仓上下架

Browse Source
This commit is contained in:
mkm 2024-01-25 15:23:47 +08:00
parent 9405922d72
commit 8c308fd431
2 changed files with 4 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/common/repositories/store/product/ProductRepository.php
View File

@ -1698,7 +1698,7 @@ class ProductRepository extends BaseRepository
throw new ValidateException('商品spu更新出错');
} else {
if ($product->product_type == 0) {
event('product.sell', ['product_id' => [$id]]);
event('product.sell', ['product_id' => [$id],'status'=>$status]);
}
}
Db::commit();

48
app/listener/CloudProduct.php
View File

@ -17,52 +17,10 @@ class CloudProduct
public function handle($event)
{
$productIds = $event['product_id'];
$typeStoreId = Db::name('MerchantType')->where('type_code', Merchant::TypeCode['TypeStore'])->value('mer_type_id');
$typeCloudWarehouseId = Db::name('MerchantType')->where('type_code', Merchant::TypeCode['TypeCloudWarehouse'])->value('mer_type_id');
$products = Product::withTrashed()->whereIn('product_id', $productIds)->field('product_id,mer_id,status,is_del,is_show,mer_status,is_used')->select();
/** @var CloudProductDao $repo */
$repo = app()->make(CloudProductDao::class);
/** @var RedisCacheService $RedisCacheService */
$RedisCacheService = app()->make(RedisCacheService::class);
$clearCache = [];
foreach ($products as $product) {
$categoryId = Merchant::getDB()->where('mer_id', $product['mer_id'])->where('type_id', $typeStoreId)->value('category_id');
if (!$categoryId) {
continue;
}
$cloudMerchant = Merchant::getDB()->where(['type_id' => $typeCloudWarehouseId, 'category_id' => $categoryId, 'status' => 1, 'mer_state' => 1])->value('mer_id');
if (empty($cloudMerchant)) {
continue;
}
$status = $product->isEnable() ? 1 : 0;
$exist = $repo->get($product['product_id']);
if (!$exist) {
$values = [
'mer_id' => $cloudMerchant,
'source_mer_id' => $product['mer_id'],
'product_id' => $product['product_id'],
'status' => $status,
'create_time' => date('Y-m-d H:i:s'),
];
$repo->create($values);
} else {
$repo->update((int)$product['product_id'], ['status' => $status]);
}
$status = $event['status'];
Db::name('cloud_product')->whereIn('product_id',$productIds)->update(['status' => $status]);
$cacheKey = sprintf(CloudProductModel::CacheKey, $cloudMerchant);
$exist = $RedisCacheService->SISMEMBER($cacheKey, $product['product_id']);
if ($status == 1 && !$exist) {
$RedisCacheService->SADD($cacheKey, $product['product_id']);
$clearCache[] = $cloudMerchant;
} elseif ($status == 0) {
$RedisCacheService->SREM($cacheKey, $product['product_id']);
$clearCache[] = $cloudMerchant;
}
}
foreach ($clearCache as $item) {
$takenKey = sprintf(CloudProductModel::TakenKey, $item);
$RedisCacheService->del($takenKey);
}
}
}