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