From 4f6c4b291dfe70cf8f65b082d7bbdfa5e0eccb3f Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Fri, 23 Sep 2022 10:28:59 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java | 33 +++++++++++++++++++++++++++++++-- 1 files changed, 31 insertions(+), 2 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java b/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java index 57f42b8..a464e2f 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java @@ -1,9 +1,11 @@ package cc.mrbird.febs.mall.quartz; import cc.mrbird.febs.common.enumerates.OrderStatusEnum; +import cc.mrbird.febs.mall.entity.MallGoods; +import cc.mrbird.febs.mall.entity.MallGoodsSku; import cc.mrbird.febs.mall.entity.MallOrderInfo; -import cc.mrbird.febs.mall.mapper.MallMemberMapper; -import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper; +import cc.mrbird.febs.mall.entity.MallOrderItem; +import cc.mrbird.febs.mall.mapper.*; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; @@ -29,6 +31,15 @@ @Autowired private MallMemberMapper mallMemberMapper; + @Autowired + private MallOrderItemMapper mallOrderItemMapper; + + @Autowired + private MallGoodsMapper mallGoodsMapper; + + @Autowired + private MallGoodsSkuMapper mallGoodsSkuMapper; + @Scheduled(cron = "0 0/5 * * * ? ") public void overtimeJob() { log.info("订单超时任务执行"); @@ -41,6 +52,24 @@ orderInfo.setStatus(OrderStatusEnum.CANCEL.getValue()); orderInfo.setCancelType(MallOrderInfo.CANCEL_OVERTIME_NO_PAY); orderInfoMapper.updateById(orderInfo); + + List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfo.getId()); + if (CollUtil.isNotEmpty(mallOrderItemList)) { + for (MallOrderItem mallOrderItem : mallOrderItemList) { + Long goodsId = mallOrderItem.getGoodsId(); + Long skuId = mallOrderItem.getSkuId(); + Integer cnt = mallOrderItem.getCnt(); + MallGoods mallGoods = mallGoodsMapper.selectById(goodsId); + mallGoods.setVolume(mallGoods.getVolume() - cnt); + mallGoods.setStock(mallGoods.getStock() + cnt); + mallGoodsMapper.updateById(mallGoods); + + MallGoodsSku mallGoodsSku = mallGoodsSkuMapper.selectById(skuId); + mallGoodsSku.setSkuVolume(mallGoodsSku.getSkuVolume() - cnt); + mallGoodsSku.setStock(mallGoodsSku.getStock() + cnt); + mallGoodsSkuMapper.updateById(mallGoodsSku); + } + } } } } -- Gitblit v1.9.1