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

修改商品上架的错误

Browse Source
This commit is contained in:
luofei 2023-06-08 14:48:16 +08:00
parent a78270cc20
commit 031f66da22
3 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/common/model/store/product/CloudProduct.php
View File

@ -17,6 +17,8 @@ use app\common\model\BaseModel;
class CloudProduct extends BaseModel class CloudProduct extends BaseModel
{ {
const CacheKey = 'CloudMerchantSpu_%s';
public static function tablePk(): string public static function tablePk(): string
{ {
return 'product_id'; return 'product_id';

7
app/common/repositories/store/product/SpuRepository.php
View File

@ -10,6 +10,7 @@
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
namespace app\common\repositories\store\product; namespace app\common\repositories\store\product;
use app\common\model\store\product\CloudProduct;
use app\common\repositories\store\coupon\StoreCouponProductRepository; use app\common\repositories\store\coupon\StoreCouponProductRepository;
use app\common\repositories\store\coupon\StoreCouponRepository; use app\common\repositories\store\coupon\StoreCouponRepository;
use app\common\repositories\store\StoreActivityRepository; use app\common\repositories\store\StoreActivityRepository;
@ -179,7 +180,7 @@ class SpuRepository extends BaseRepository
} }
if ($rand) { if ($rand) {
$dataKey = 'CloudMerchantSpu_' . $where['mer_id']; $dataKey = sprintf(CloudProduct::CacheKey, $where['mer_id']);
$RedisCacheService = app()->make(RedisCacheService::class); $RedisCacheService = app()->make(RedisCacheService::class);
$exists = $RedisCacheService->exists($dataKey); $exists = $RedisCacheService->exists($dataKey);
if (!$exists) { if (!$exists) {
@ -224,8 +225,8 @@ class SpuRepository extends BaseRepository
*/ */
public function getSpuFromCache($merId, $page): array public function getSpuFromCache($merId, $page): array
{ {
$dataKey = 'CloudMerchantSpu_' . $merId; $dataKey = sprintf(CloudProduct::CacheKey, $merId);
$takenKey = 'CloudMerchantSpu_' . $merId . '_page_'. $page; $takenKey = $dataKey . '_page_'. $page;
$remainKey = 'CloudMerchantSpuRemain_' . $merId; $remainKey = 'CloudMerchantSpuRemain_' . $merId;
/** @var RedisCacheService $RedisCacheService */ /** @var RedisCacheService $RedisCacheService */
$RedisCacheService = app()->make(RedisCacheService::class); $RedisCacheService = app()->make(RedisCacheService::class);

8
app/listener/CloudProduct.php
View File

@ -13,6 +13,9 @@ class CloudProduct
public function handle($event) public function handle($event)
{ {
if (!$event['source_mer_id']) {
return true;
}
$sourceMerchant = Merchant::getDB()->where('mer_id', $event['source_mer_id'])->field('category_id,type_id')->find(); $sourceMerchant = Merchant::getDB()->where('mer_id', $event['source_mer_id'])->field('category_id,type_id')->find();
if ($sourceMerchant['type_id'] != Merchant::TypeStore) { if ($sourceMerchant['type_id'] != Merchant::TypeStore) {
return true; return true;
@ -36,12 +39,13 @@ class CloudProduct
$repo->update((int)$productId, $values); $repo->update((int)$productId, $values);
} }
} }
$cacheKey = sprintf(\app\common\model\store\product\CloudProduct::CacheKey, $cloudMerchant);
$RedisCacheService = app()->make(RedisCacheService::class); $RedisCacheService = app()->make(RedisCacheService::class);
foreach ($event['product_id'] as $productId) { foreach ($event['product_id'] as $productId) {
if ($event['status'] == 1) { if ($event['status'] == 1) {
$RedisCacheService->SADD('CloudMerchantSpu_' . $cloudMerchant, $productId); $RedisCacheService->SADD($cacheKey, $productId);
} else { } else {
$RedisCacheService->SREM('CloudMerchantSpu_' . $cloudMerchant, $productId); $RedisCacheService->SREM($cacheKey, $productId);
} }
} }
} }