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 11:20:27 +08:00
parent dffed92a76
commit 5b7be1a41c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -780,7 +780,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
} }
//持久化保存数据到数据库队列 //持久化保存数据到数据库队列
String key=RedisKey.STOREDATARELEASE+":"+syncAppO.getStore_id(); String key=RedisKey.STOREDATARELEASE+":"+syncAppO.getStore_id();
Map<String, Double> redisHash = redisTemplate.opsForHash().entries(key); Map redisHash = redisTemplate.opsForHash().entries(key);
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()) {
@ -884,7 +884,7 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
@Override @Override
public List<ProductQuantityConsumption> getProductStockFromRedis(String storeId,Map<String, Double> redisHash) { public List<ProductQuantityConsumption> getProductStockFromRedis(String storeId,Map redisHash) {
try { try {
// 从 Redis 获取 hash 结构的所有键值对 // 从 Redis 获取 hash 结构的所有键值对
if (redisHash.isEmpty()) { if (redisHash.isEmpty()) {
@ -894,7 +894,8 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
List<ProductQuantityConsumption> productQuantityConsumptionList=new ArrayList<>(); List<ProductQuantityConsumption> productQuantityConsumptionList=new ArrayList<>();
redisHash.forEach((k, v)->{ redisHash.forEach((k, v)->{
ProductQuantityConsumption productQuantityConsumption=new ProductQuantityConsumption(); ProductQuantityConsumption productQuantityConsumption=new ProductQuantityConsumption();
String[] productKeyArrys=k.split("-"); String productKey= (String) k;
String[] productKeyArrys=productKey.split("-");
if(productKeyArrys.length!=2){ if(productKeyArrys.length!=2){
return; return;
} }