定时任务 接口调用成功

待测 job传参调用

liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/task/FeignPlatformTaskClient.java

@@ -21,5 +21,5 @@ public interface FeignPlatformTaskClient {
     ResponseDto<String> checkPerformanceTime();
 
     @PostMapping("platform/performance/checkTransferOrder")
-    ResponseDto<Boolean> checkTransferOrder();
+    ResponseDto<Boolean> checkTransferOrder(Integer minute);
 }

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/KylinTaskHandler.java

@@ -8,6 +8,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.RequestParam;
 
 /**
  * XxlJob开发示例（Bean模式）
@@ -47,9 +48,9 @@ public class KylinTaskHandler {
     }
 
     @XxlJob(value = "sev-platform:checkTransferOrderHandler")
-    public ReturnT<String> checkTransferOrderHandler() {
+    public ReturnT<String> checkTransferOrderHandler(@RequestParam Integer minute) {
         try {
-            boolean result = feignPlatformTaskClient.checkTransferOrder().getData();
+            boolean result = feignPlatformTaskClient.checkTransferOrder(minute).getData();
             log.info("checkTransferOrderHandler：结果："+result);
             return ReturnT.SUCCESS;
         } catch (Exception e) {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/KylinOrderTicketsController.java

@@ -10,6 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -39,7 +40,7 @@ public class KylinOrderTicketsController {
     @PostMapping("checkTransferOrder")
     @ApiOperation("转赠订单失效脚本")
     @ApiResponse(code = 200, message = "接口返回对象参数")
-    public ResponseDto<Boolean> checkTransferOrder() {
-        return ResponseDto.success(kylinCheckOrderTime.checkTransferOrder());
+    public ResponseDto<Boolean> checkTransferOrder(@RequestParam Integer minute) {
+        return ResponseDto.success(kylinCheckOrderTime.checkTransferOrder(minute));
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DMCheckOrderTimeImpl.java

@@ -146,16 +146,20 @@ public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, K
         return true;
     }
 
-    public boolean checkTransferOrder() {
+    public boolean checkTransferOrder(Integer minute) {
         LocalDateTime now = LocalDateTime.now();
         List<KylinOrderTask> task = orderTaskMapper.selectList(
-                Wrappers.lambdaQuery(KylinOrderTask.class).eq(KylinOrderTask::getStatus, 10).ge(KylinOrderTask::getCreatedAt,now.plusHours(2))
+                Wrappers.lambdaQuery(KylinOrderTask.class).eq(KylinOrderTask::getStatus, 10).last("and NOW() > DATE_SUB(created_at,INTERVAL -("+minute+") MINUTE)")
         );
         ArrayList<String> orderIdList = CollectionUtil.arrayListString();
         for (KylinOrderTask item : task) {
             orderIdList.add(item.getOrderId());
         }
 
+        if (orderIdList.size() == 0) {
+            return true;
+        }
+
         //处理原订单mongo
         HashMap<String, Object> mapMongo = new HashMap<>();
         mapMongo.put("transferStatus", 0);
@@ -176,7 +180,7 @@ public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, K
         orderTicketRelations.setUpdatedAt(now);
         orderTicketRelationsMapper.update(orderTicketRelations, new UpdateWrapper<KylinOrderTicketRelations>().in("order_id", orderIdList));
         //mysql 删除持久化数据
-        orderTaskMapper.delete(Wrappers.lambdaQuery(KylinOrderTask.class).eq(KylinOrderTask::getStatus, 10).ge(KylinOrderTask::getCreatedAt,now.plusHours(2)));
+        orderTaskMapper.delete(Wrappers.lambdaQuery(KylinOrderTask.class).eq(KylinOrderTask::getStatus, 10).ge(KylinOrderTask::getCreatedAt, now.plusHours(2)));
         //处理原订单redis
         int forSize = 500;
         int forCount = orderIdList.size() % forSize == 0 ? orderIdList.size() / forSize : (orderIdList.size() / forSize) + 1;