czg_team/cashier-client
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

回滚库存

Browse Source
This commit is contained in:
GYJ
2024-06-25 15:31:50 +08:00
parent b66a89b143
commit 2310a0164b
1 changed files with 20 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/main/java/com/chaozhanggui/system/cashierservice/service/DutyService.java
View File

@@ -45,6 +45,8 @@ public class DutyService {
@Autowired @Autowired
private TbProductSkuMapper productSkuMapper; private TbProductSkuMapper productSkuMapper;
@Autowired @Autowired
private TbProductMapper productMapper;
@Autowired
private CloudPrinterService cloudPrinterService; private CloudPrinterService cloudPrinterService;
@Autowired @Autowired
private RedisUtils redisUtil; private RedisUtils redisUtil;
@@ -372,12 +374,25 @@ public class DutyService {
} }
private void subInventory(Integer shopId, Integer skuId, Integer num) { private void subInventory(Integer shopId, Integer skuId, Integer num) {
String result = redisUtil.seckill(RedisCst.PRODUCT + shopId.toString() + ":" + skuId.toString(), num.toString());
TbProductSku tbProductSku = productSkuMapper.selectByPrimaryKey(skuId); TbProductSku tbProductSku = productSkuMapper.selectByPrimaryKey(skuId);
if (num > tbProductSku.getStockNumber()) { TbProductWithBLOBs product = productMapper.selectByPrimaryKey(Integer.valueOf(tbProductSku.getProductId()));
productSkuMapper.updateStockNum(skuId,num);
} else {
productSkuMapper.updateByskuIdSub(skuId, num); if (ObjectUtil.isNotEmpty(product)) {
if (product.getIsDistribute() == 1) {
redisUtil.seckill(RedisCst.PRODUCT + shopId.toString() + ":product" + product.getId().toString(), num.toString());
productMapper.updateStockById(skuId, num);
} else {
redisUtil.seckill(RedisCst.PRODUCT + shopId.toString() + ":" + skuId.toString(), num.toString());
if (ObjectUtil.isNotEmpty(tbProductSku)) {
if (num > tbProductSku.getStockNumber()) {
productSkuMapper.updateStockNum(skuId,num);
} else {
productSkuMapper.updateByskuIdSub(skuId, num);
}
}
}
} }
} }
} }