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-05 16:35:36 +08:00
parent 12fbd15a66
commit 3a4a8d7772
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -107,7 +107,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import java.util.stream.Collectors;
import static com.suisung.mall.common.utils.I18nUtil._; import static com.suisung.mall.common.utils.I18nUtil._;
@ -987,9 +986,10 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
BigDecimal unitWeight = itemQuarytys[0]; BigDecimal unitWeight = itemQuarytys[0];
BigDecimal itemQuaryty = itemQuarytys[1]; BigDecimal itemQuaryty = itemQuarytys[1];
BigDecimal unitPriceBg=new BigDecimal(unitPrice).divide(unitWeight,4, RoundingMode.HALF_UP); BigDecimal unitPriceBg=new BigDecimal(unitPrice).divide(unitWeight,4, RoundingMode.HALF_UP);
logger.info("unitWeight-{};itemQuaryty-{};unitPriceBg-{}",unitWeight,itemQuaryty,unitPriceBg);
// 使用 Redis 的 HINCRBY 保证原子性和高性能 // 使用 Redis 的 HINCRBY 保证原子性和高性能
redisTemplate.opsForHash().increment(key, itemId+"-"+orderId+"-"+unitPriceBg.toPlainString(), itemQuaryty.doubleValue()); redisTemplate.opsForHash().increment(key, itemId+"-"+orderId+"-"+unitPriceBg.toPlainString(), itemQuaryty.doubleValue());
logger.info("存储有规格库存成功"); logger.info("存储有规格库存成功",itemId+"-"+orderId+"-"+unitPriceBg.toPlainString());
} catch (Exception e) { } catch (Exception e) {
logger.error("库存累计失败，productKey={}, delta={}, error={}", productKey, delta, e.getMessage(), e); logger.error("库存累计失败，productKey={}, delta={}, error={}", productKey, delta, e.getMessage(), e);
} }