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

库存校验改为共享库存校验

Browse Source
This commit is contained in:
SongZhang
2024-10-10 15:11:35 +08:00
parent 4425812590
commit 1aa729dc91
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
View File

@@ -895,16 +895,15 @@ public class CartService {
log.info("下单,开始校验库存预警,购物车id:{}", cart.getId()); log.info("下单,开始校验库存预警,购物车id:{}", cart.getId());
CompletableFuture.runAsync(() -> checkWarnLineAndSendMsg(tbProduct, tbProduct1, cart.getNumber())); CompletableFuture.runAsync(() -> checkWarnLineAndSendMsg(tbProduct, tbProduct1, cart.getNumber()));
log.info("开始修改库存，商品id：{}，商品名：{}", tbProduct1.getId(), tbProduct1.getName()); log.info("开始修改库存，商品id：{}，商品名：{}", tbProduct1.getId(), tbProduct1.getName());
// 修改库存 // 修改库存
try { try {
// 首次下单扣除库存 // 首次下单扣除库存
if (StrUtil.isBlank(cart.getOrderId())) { if (StrUtil.isBlank(cart.getOrderId())) {
if (tbProduct1.getIsStock() == 1) { if (tbProduct1.getIsStock() == 1) {
productService.updateStock(tbProduct.getProductId(), tbProduct.getId(), cart.getNumber(), tbProduct1.getIsDistribute() == 1); productService.updateStock(tbProduct.getProductId(), tbProduct.getId(), cart.getNumber(), true);
} else { } else {
productService.updateStockAndNoCheck(tbProduct.getProductId(), tbProduct.getId(), cart.getNumber(), tbProduct1.getIsDistribute() == 1); productService.updateStockAndNoCheck(tbProduct.getProductId(), tbProduct.getId(), cart.getNumber(), true);
} }
} }
@@ -914,7 +913,7 @@ public class CartService {
jsonObject1.put("msg", tbProduct1.getName() + "库存不足"); jsonObject1.put("msg", tbProduct1.getName() + "库存不足");
jsonObject1.put("data", new ArrayList<>()); jsonObject1.put("data", new ArrayList<>());
PushToAppChannelHandlerAdapter.getInstance().AppSendInfo(jsonObject1.toString(), tableCartKey, jsonObject.getString("userId"), true); PushToAppChannelHandlerAdapter.getInstance().AppSendInfo(jsonObject1.toString(), tableCartKey, jsonObject.getString("userId"), true);
continue; throw new MsgException((String) jsonObject1.get("msg"));
} }
saleAmount = saleAmount.add(tbProduct.getSalePrice()); saleAmount = saleAmount.add(tbProduct.getSalePrice());
} else { } else {