| | |
| | | @Autowired |
| | | private MallGoodsSkuMapper mallGoodsSkuMapper; |
| | | |
| | | @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()) { |
| | | // @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() + "库存不足"); |
| | | // } |
| | | |
| | | 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() { |