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-10-20 15:19:19 +08:00
parent 71a2b5acb8
commit e252475a34
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -766,7 +766,9 @@ 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<>()); // Map<String,Integer> map=new HashMap<>();
// map.put("33638-DD_20251020_3",-1);
// incrProductStockToRedis(map);
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._("缺少必要参数！"));
} }
@ -781,6 +783,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
//持久化保存数据到数据库队列 //持久化保存数据到数据库队列
String key=RedisKey.STOREDATARELEASE+":"+syncAppO.getStore_id(); String key=RedisKey.STOREDATARELEASE+":"+syncAppO.getStore_id();
Map redisHash = redisTemplate.opsForHash().entries(key); Map redisHash = redisTemplate.opsForHash().entries(key);
logger.info("获取扣减库存数据redisHash：{}",redisHash);
List<ProductQuantityConsumption> productQuantityConsumptionList=getProductStockFromRedis(syncAppO.getStore_id(),redisHash); List<ProductQuantityConsumption> productQuantityConsumptionList=getProductStockFromRedis(syncAppO.getStore_id(),redisHash);
List<ProductQuantityConsumption> productQuantityConsumptions=new ArrayList<>(); List<ProductQuantityConsumption> productQuantityConsumptions=new ArrayList<>();
if (!productQuantityConsumptionList.isEmpty()) { if (!productQuantityConsumptionList.isEmpty()) {
@ -886,6 +889,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
@Override @Override
public List<ProductQuantityConsumption> getProductStockFromRedis(String storeId,Map redisHash) { public List<ProductQuantityConsumption> getProductStockFromRedis(String storeId,Map redisHash) {
try { try {
logger.info("获取redis的库存扣减redisHash:{}",redisHash);
// 从 Redis 获取 hash 结构的所有键值对 // 从 Redis 获取 hash 结构的所有键值对
if (redisHash.isEmpty()) { if (redisHash.isEmpty()) {
return Collections.emptyList(); return Collections.emptyList();
@ -896,6 +900,8 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
ProductQuantityConsumption productQuantityConsumption=new ProductQuantityConsumption(); ProductQuantityConsumption productQuantityConsumption=new ProductQuantityConsumption();
String productKey= (String) k; String productKey= (String) k;
String[] productKeyArrys=productKey.split("-"); String[] productKeyArrys=productKey.split("-");
logger.info("productNumber:{}",productKeyArrys[0]);
logger.info("orderId:{}",productKeyArrys[0]);
if(productKeyArrys.length!=2){ if(productKeyArrys.length!=2){
return; return;
} }
@ -918,7 +924,6 @@ 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;