backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

同步思迅库存扣减问题修复

Browse Source
This commit is contained in:
liyj 2025-09-24 18:32:14 +08:00
parent 12fbc5a16f
commit 52eead2229
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java
View File

@ -4220,7 +4220,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl<ShopOrderBaseMappe
if (!shopProductItemService.edit(shopProductItem)) { if (!shopProductItemService.edit(shopProductItem)) {
throw new ApiException(String.format(I18nUtil._("释放: %s 冻结库存失败!"), order_item_row.getItem_id())); throw new ApiException(String.format(I18nUtil._("释放: %s 冻结库存失败!"), order_item_row.getItem_id()));
} }
log.debug("释放库存Item_src_id:{},数量：{}",shopProductItem.getItem_src_id(),order_item_quantity);
// RMK 第三方数据同步相关：redis 给这个商品加上对应的库存 // RMK 第三方数据同步相关：redis 给这个商品加上对应的库存
Map<String, Integer> stockDeltaMap = new HashMap<>(); Map<String, Integer> stockDeltaMap = new HashMap<>();
stockDeltaMap.put(Convert.toStr(shopProductItem.getItem_src_id()), order_item_quantity); stockDeltaMap.put(Convert.toStr(shopProductItem.getItem_src_id()), order_item_quantity);
@ -7234,6 +7234,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl<ShopOrderBaseMappe
} }
// RMK 第三方数据同步相关：redis 给这个商品减去上对应的库存 // RMK 第三方数据同步相关：redis 给这个商品减去上对应的库存
log.debug("减库存Item_src_id:{},数量：{}",item_src_id,cart_quantity);
Map<String, Integer> stockDeltaMap = new HashMap<>(); Map<String, Integer> stockDeltaMap = new HashMap<>();
stockDeltaMap.put(Convert.toStr(item_src_id), -cart_quantity); stockDeltaMap.put(Convert.toStr(item_src_id), -cart_quantity);
syncThirdDataService.incrProductStockToRedis(stockDeltaMap); syncThirdDataService.incrProductStockToRedis(stockDeltaMap);

8
mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
View File

@ -768,6 +768,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
@Override @Override
public ThirdApiRes getStoreDataRelease(String appKey, String sign) { public ThirdApiRes getStoreDataRelease(String appKey, String sign) {
// incrProductStockToRedis(new HashMap<>());
if (StrUtil.isBlank(appKey) || StrUtil.isBlank(sign)) { if (StrUtil.isBlank(appKey) || StrUtil.isBlank(sign)) {
return new ThirdApiRes().fail(1003, I18nUtil._("缺少必要参数！")); return new ThirdApiRes().fail(1003, I18nUtil._("缺少必要参数！"));
} }
@ -817,7 +818,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
// 从 Redis 获取 hash 结构的所有键值对 // 从 Redis 获取 hash 结构的所有键值对
String key=RedisKey.STOREDATARELEASE+":"+storeId; String key=RedisKey.STOREDATARELEASE+":"+storeId;
Map<Object, Object> redisHash = redisTemplate.opsForHash().entries(key); Map<Object, Object> redisHash = redisTemplate.opsForHash().entries(key);
if (redisHash == null || redisHash.isEmpty()) { if (redisHash.isEmpty()) {
return Collections.emptyMap(); return Collections.emptyMap();
} }
// 转换为 Map<String, Integer> // 转换为 Map<String, Integer>
@ -834,11 +835,12 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
@Override @Override
public void incrProductStockToRedis(Map<String, Integer> stockDeltaMap) { public void incrProductStockToRedis(Map<String, Integer> stockDeltaMap) {
// stockDeltaMap.put("5458", 1);
// 校验参数，避免空指针 // 校验参数，避免空指针
if (CollectionUtil.isEmpty(stockDeltaMap)) { if (CollectionUtil.isEmpty(stockDeltaMap)) {
return; return;
} }
logger.debug("扣减库存的map:{}", JSONUtil.toJsonStr(stockDeltaMap));
for (Map.Entry<String, Integer> entry : stockDeltaMap.entrySet()) { for (Map.Entry<String, Integer> entry : stockDeltaMap.entrySet()) {
String productKey = entry.getKey(); String productKey = entry.getKey();
Integer delta = entry.getValue(); Integer delta = entry.getValue();
@ -862,7 +864,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
String itemId=productBase.getProduct_number(); String itemId=productBase.getProduct_number();
cn.hutool.json.JSONArray array_item_spec= JSONUtil.parseArray(spuItem.getItem_spec()); cn.hutool.json.JSONArray array_item_spec= JSONUtil.parseArray(spuItem.getItem_spec());
if(array_item_spec.isEmpty()){ if(array_item_spec.isEmpty()){
redisTemplate.opsForHash().increment(key, spuItem.getItem_id(), delta.doubleValue()); redisTemplate.opsForHash().increment(key, itemId, delta.doubleValue());
continue; continue;
} }
cn.hutool.json.JSONObject item = (cn.hutool.json.JSONObject) ((cn.hutool.json.JSONObject) array_item_spec.get(0)).get("item"); cn.hutool.json.JSONObject item = (cn.hutool.json.JSONObject) ((cn.hutool.json.JSONObject) array_item_spec.get(0)).get("item");