订单状态查询

lhb-basic/lhb-basic-biz/src/main/java/com/kxs/lhb/basic/biz/controller/admin/SysOrderController.java

@@ -113,7 +113,7 @@ public class SysOrderController {
     /**
      * 更新订单状态
      */
-    @Inner
+    @Inner(value = false)
     @GetMapping("/orderStatusTask")
     public void orderStatusTask() {
 

lhb-basic/lhb-basic-biz/src/main/java/com/kxs/lhb/basic/biz/service/impl/LhbOrderServiceImpl.java

@@ -353,11 +353,18 @@ public class LhbOrderServiceImpl extends MPJBaseServiceImpl<LhbOrderMapper, LhbO
     @Async
     public void orderStatusTask() {
         List<LhbOrder> orders = list(Wrappers.lambdaQuery(LhbOrder.class)
+                .isNotNull(LhbOrder::getOutOrderSn)
                 .eq(LhbOrder::getIsAct, CommonConstants.FAIL)
                 .notIn(LhbOrder::getOutStatus, 2, 3)
                 .eq(LhbOrder::getStatus, OrderStatusEnum.PAY.getCode()));
 
-        orders.forEach(order -> channelFactory.getChannel(order.getIfCode()).queryStatus(order));
+        for (LhbOrder order : orders) {
+            try {
+                channelFactory.getChannel(order.getIfCode()).queryStatus(order);
+            } catch (Exception e) {
+                log.error("查询订单状态失败", e);
+            }
+        }
     }
 
     @Override
@@ -368,9 +375,13 @@ public class LhbOrderServiceImpl extends MPJBaseServiceImpl<LhbOrderMapper, LhbO
                 .eq(LhbOrder::getIsAct, CommonConstants.FAIL)
                 .eq(LhbOrder::getStatus, OrderStatusEnum.PAY.getCode()));
 
-        orders.forEach(order -> {
-            channelFactory.getChannel(order.getIfCode()).queryFirstCharge(order);
-        });
+        for (LhbOrder order : orders) {
+            try {
+                channelFactory.getChannel(order.getIfCode()).queryFirstCharge(order);
+            } catch (Exception e) {
+                log.error("查询订单首充失败", e);
+            }
+        }
     }