Browse Source

活动自动改变状态定时任务

yubin 2 weeks ago
parent
commit
d60af17aa6

+ 11 - 3
cif-service/src/main/java/com/txz/cif/dubbo/client/OrderDubboServiceClient.java

@@ -23,7 +23,7 @@ public class OrderDubboServiceClient {
         log.info("cif:scheduledTaskStorePinkSummaryClose end");
     }
 
-    ;
+
 
     /**
      * 自动签收定时任务
@@ -34,7 +34,7 @@ public class OrderDubboServiceClient {
         log.info("cif:scheduledTaskBatchSigning end");
     }
 
-    ;
+
 
 
     public void orderTimeoutAutomaticCancel() {
@@ -43,6 +43,14 @@ public class OrderDubboServiceClient {
         log.info("cif:orderTimeoutAutomaticCancel end");
     }
 
-    ;
+
+
+
+    public void activityStatusJudgmentTimedTask() {
+        log.info("cif:activityStatusJudgmentTimedTask start");
+        orderDubboService.activityStatusJudgmentTimedTask();
+        log.info("cif:activityStatusJudgmentTimedTask end");
+    }
+
 
 }

+ 15 - 1
cif-service/src/main/java/com/txz/cif/task/GeneralJob.java

@@ -156,7 +156,21 @@ public class GeneralJob {
         }
         return ReturnT.SUCCESS;
     }
-    
+
+    @XxlJob("activityStatusJudgmentTimedTask")
+    public ReturnT<String> activityStatusJudgmentTimedTask(String param) throws Exception {
+        try {
+            logger.info("【活动定时改变状态任务】开始");
+            orderDubboServiceClient.activityStatusJudgmentTimedTask();
+            logger.info("【活动定时改变状态任务】完成");
+        } catch (Exception e) {
+            logger.error("【活动定时改变状态任务】异常:e{}", e);
+            return ReturnT.FAIL;
+        }
+        return ReturnT.SUCCESS;
+    }
+
+
     @XxlJob("closeRecharge")
     public ReturnT<String> closeRecharge() throws Exception {
         try {

+ 10 - 0
cif-service/src/main/java/com/txz/cif/web/mng/OrderApiController.java

@@ -46,4 +46,14 @@ public class OrderApiController {
         return ResultGenerator.genSuccessResult();
     }
 
+
+    @PostMapping("/activityStatusJudgmentTimedTask")
+    @ApiOperation(value = "活动状态修改定时任务",httpMethod = "POST")
+    public Result activityStatusJudgmentTimedTask() {
+        orderDubboServiceClient.activityStatusJudgmentTimedTask();
+        return ResultGenerator.genSuccessResult();
+    }
+
+
+
 }