|
@@ -27,22 +27,22 @@ public class OrderJob {
|
|
|
@Autowired
|
|
|
private OrderService orderService;
|
|
|
|
|
|
-// @Scheduled(cron = "0 */1 * * * ?")
|
|
|
-// public void execute(){
|
|
|
-// LambdaQueryWrapper<Order> queryWrapper = Wrappers.lambdaQuery();
|
|
|
-// queryWrapper
|
|
|
-// .ne(Order::getPayType, OrderPayType.XJ.getPayCode())
|
|
|
-// .and(wrapper -> wrapper.eq(Order::getOrderFlag, OrderStatus.NO_PAYMENT.getCode())
|
|
|
-// .or()
|
|
|
-// .eq(Order::getOrderFlag, OrderStatus.AWAIT_PAY.getCode()));
|
|
|
-// List<Order> list = orderService.list(queryWrapper);
|
|
|
-// for (Order order:list) {
|
|
|
-// try {
|
|
|
-// orderService.callTopFindOrderInfoApi(order.getOrderNumber());
|
|
|
-// }catch (Exception e){
|
|
|
-// log.error("---orderJob---异常"+e.getMessage());
|
|
|
-// }
|
|
|
-// }
|
|
|
-// log.info("---orderJob---处理完成");
|
|
|
-// }
|
|
|
+ @Scheduled(cron = "0 */1 * * * ?")
|
|
|
+ public void execute(){
|
|
|
+ LambdaQueryWrapper<Order> queryWrapper = Wrappers.lambdaQuery();
|
|
|
+ queryWrapper
|
|
|
+ .ne(Order::getPayType, OrderPayType.XJ.getPayCode())
|
|
|
+ .and(wrapper -> wrapper.eq(Order::getOrderFlag, OrderStatus.NO_PAYMENT.getCode())
|
|
|
+ .or()
|
|
|
+ .eq(Order::getOrderFlag, OrderStatus.AWAIT_PAY.getCode()));
|
|
|
+ List<Order> list = orderService.list(queryWrapper);
|
|
|
+ for (Order order:list) {
|
|
|
+ try {
|
|
|
+ orderService.callTopFindOrderInfoApi(order.getOrderNumber());
|
|
|
+ }catch (Exception e){
|
|
|
+ log.error("---orderJob---异常"+e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ log.info("---orderJob---处理完成");
|
|
|
+ }
|
|
|
}
|