diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java index 77eeffa1..6812c641 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java @@ -4220,7 +4220,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl stockDeltaMap = new HashMap<>(); stockDeltaMap.put(Convert.toStr(shopProductItem.getItem_src_id()), order_item_quantity); @@ -7234,6 +7234,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl stockDeltaMap = new HashMap<>(); stockDeltaMap.put(Convert.toStr(item_src_id), -cart_quantity); syncThirdDataService.incrProductStockToRedis(stockDeltaMap); diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java index 5bd32952..28d94b10 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java @@ -768,6 +768,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements @Override public ThirdApiRes getStoreDataRelease(String appKey, String sign) { + // incrProductStockToRedis(new HashMap<>()); if (StrUtil.isBlank(appKey) || StrUtil.isBlank(sign)) { return new ThirdApiRes().fail(1003, I18nUtil._("缺少必要参数!")); } @@ -817,7 +818,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements // 从 Redis 获取 hash 结构的所有键值对 String key=RedisKey.STOREDATARELEASE+":"+storeId; Map redisHash = redisTemplate.opsForHash().entries(key); - if (redisHash == null || redisHash.isEmpty()) { + if (redisHash.isEmpty()) { return Collections.emptyMap(); } // 转换为 Map @@ -834,11 +835,12 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements @Override public void incrProductStockToRedis(Map stockDeltaMap) { + // stockDeltaMap.put("5458", 1); // 校验参数,避免空指针 if (CollectionUtil.isEmpty(stockDeltaMap)) { return; } - + logger.debug("扣减库存的map:{}", JSONUtil.toJsonStr(stockDeltaMap)); for (Map.Entry entry : stockDeltaMap.entrySet()) { String productKey = entry.getKey(); Integer delta = entry.getValue(); @@ -862,7 +864,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements String itemId=productBase.getProduct_number(); cn.hutool.json.JSONArray array_item_spec= JSONUtil.parseArray(spuItem.getItem_spec()); if(array_item_spec.isEmpty()){ - redisTemplate.opsForHash().increment(key, spuItem.getItem_id(), delta.doubleValue()); + redisTemplate.opsForHash().increment(key, itemId, delta.doubleValue()); continue; } cn.hutool.json.JSONObject item = (cn.hutool.json.JSONObject) ((cn.hutool.json.JSONObject) array_item_spec.get(0)).get("item");