|
|
@@ -141,17 +141,17 @@ public class OrderScheduler {
|
|
|
List<TbOrder> orders = orderService.list(queryWrapper);
|
|
|
|
|
|
for (TbOrder order: orders) {
|
|
|
- LocalDateTime updateTime = LocalDateTime.parse(order.getUpdateTime(), df);
|
|
|
- // 计算当前订单什么时候超时完成
|
|
|
- LocalDateTime overDateTime = updateTime.plusHours(Integer.parseInt(one.getValue()));
|
|
|
- if (LocalDateTime.now().isAfter(overDateTime)) {
|
|
|
- log.info("订单id:{},开始自动完成", order.getOrderId());
|
|
|
- try {
|
|
|
+ try {
|
|
|
+ LocalDateTime updateTime = LocalDateTime.parse(order.getUpdateTime(), df);
|
|
|
+ // 计算当前订单什么时候超时完成
|
|
|
+ LocalDateTime overDateTime = updateTime.plusHours(Integer.parseInt(one.getValue()));
|
|
|
+ if (LocalDateTime.now().isAfter(overDateTime)) {
|
|
|
+ log.info("订单id:{},开始自动完成", order.getOrderId());
|
|
|
orderService.accomplishOrders(order.getOrderId(),2);
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("订单id:{},开始自动完成失败,失败原因【{}】", order.getOrderId(), e);
|
|
|
+ log.info("订单id:{},完成自动完成", order.getOrderId());
|
|
|
}
|
|
|
- log.info("订单id:{},完成自动完成", order.getOrderId());
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("订单id:{},开始自动完成失败,失败原因【{}】", order.getOrderId(), e);
|
|
|
}
|
|
|
}
|
|
|
log.info("自动完成订单任务运行成功");
|