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

Merge remote-tracking branch 'origin/main'

Browse Source
This commit is contained in:
Jack 2025-11-06 16:58:59 +08:00
commit 30bf1446d4
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -979,6 +979,9 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
logger.info("key:{},Product_number:{}",key,itemId);
if(array_item_spec.isEmpty()){
BigDecimal saleAmount=new BigDecimal(unitPrice).multiply(new BigDecimal(delta));
if(saleAmount.compareTo(BigDecimal.ZERO)<0){
saleAmount=saleAmount.multiply(new BigDecimal("-1"));
}
redisTemplate.opsForHash().increment(key, itemId+"-"+orderId+"-"+unitPrice+"-"+saleAmount.toPlainString(), delta.doubleValue());
logger.info("存储无规格库存成功");
continue;
@ -996,6 +999,9 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
itemReturnAmount=unitPriceBg.multiply(itemQuaryty);
}
logger.info("unitWeight-{};itemQuaryty-{};unitPriceBg-{}",unitWeight,itemQuaryty,unitPriceBg);
if(itemReturnAmount.compareTo(BigDecimal.ZERO)<0){
itemReturnAmount=itemReturnAmount.multiply(new BigDecimal("-1"));
}
// 使用 Redis 的 HINCRBY 保证原子性和高性能
redisTemplate.opsForHash().increment(key, itemId+"-"+orderId+"-"+unitPriceBg.toPlainString()+"-"+itemReturnAmount.toPlainString(), itemQuaryty.doubleValue());
logger.info("存储有规格库存成功",itemId+"-"+orderId+"-"+unitPriceBg.toPlainString());