From c0e5c1f671f928161c28e93d00be40aa2a74ebc0 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 28 Jul 2023 10:23:33 +0800 Subject: [PATCH] 赠送积分更新状态 --- src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java | 75 ++++++++++++++++++++----------------- 1 files changed, 40 insertions(+), 35 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 4064e7c..108967a 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/OrderOvertimeJob.java @@ -1,6 +1,7 @@ package cc.mrbird.febs.mall.quartz; import cc.mrbird.febs.common.enumerates.OrderStatusEnum; +import cc.mrbird.febs.common.exception.FebsException; import cc.mrbird.febs.mall.entity.MallGoods; import cc.mrbird.febs.mall.entity.MallGoodsSku; import cc.mrbird.febs.mall.entity.MallOrderInfo; @@ -42,41 +43,45 @@ @Autowired private MallGoodsSkuMapper mallGoodsSkuMapper; - @Scheduled(cron = "0 0/5 * * * ? ") - public void overtimeJob() { - log.info("订单超时任务执行"); - List<MallOrderInfo> orderList = orderInfoMapper.selectOrderInfoByStatus(OrderStatusEnum.WAIT_PAY.getValue()); - if (CollUtil.isNotEmpty(orderList)) { - for (MallOrderInfo orderInfo : orderList) { - long subTime = DateUtil.between(orderInfo.getOrderTime(), new Date(), DateUnit.MINUTE, false); - - if (subTime > 15) { - 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); - } - } - } - } - } - - } +// @Scheduled(cron = "0 0/5 * * * ? ") +// public void overtimeJob() { +// log.info("订单超时任务执行"); +// List<MallOrderInfo> orderList = orderInfoMapper.selectOrderInfoUpTime(OrderStatusEnum.WAIT_PAY.getValue()); +// if (CollUtil.isNotEmpty(orderList)) { +// for (MallOrderInfo orderInfo : orderList) { +// //更新订单状态 +// 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){ +// MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(mallOrderItem.getSkuId()); +// if (sku == null) { +// throw new FebsException("购买商品或sku不存在"); +// } +// +//// if (sku.getStock() < mallOrderItem.getCnt()) { +//// throw new FebsException(sku.getSkuName() + "库存不足"); +//// } +// +// MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId()); +// Integer goodsResult = mallGoodsMapper.updateStockAndVolumeByGoodsId(mallGoods.getId(), mallOrderItem.getCnt()); +// if(1 != goodsResult){ +// throw new FebsException(mallGoods.getGoodsName() + "库存不足"); +// } +// +// Integer skuResult = mallGoodsSkuMapper.updateStockAndVolumeBySkuId(sku.getId(),mallOrderItem.getCnt()); +// if(1 != skuResult){ +// throw new FebsException(sku.getSkuName() + "库存不足"); +// } +// } +// } +// } +// } +// +// } // @Scheduled(cron = "0/5 * * * * ? ") // public void wakeup() { -- Gitblit v1.9.1