报错修改

src/main/java/com/ydtech/utils/sendCollectUtils/SendCollectUtils.java

@@ -29,7 +29,7 @@ import java.util.UUID;
 
 @Slf4j
 @Service
-public class SendCollectUtils implements Runnable {
+public class SendCollectUtils{
 
     @Autowired
     private SendCollectMapper sendCollectMapper;
@@ -99,9 +99,9 @@ public class SendCollectUtils implements Runnable {
             }
 
         } catch (Exception e) {
-            SendCollectUtils sendCollectUtils = new SendCollectUtils();
-            scheduledFutureUtil.startJob(sendCollectUtils, CORN);
-            e.printStackTrace();
+//            SendCollectUtils sendCollectUtils = new SendCollectUtils();
+//            scheduledFutureUtil.startJob(sendCollectUtils, CORN);
+//            e.printStackTrace();
         } finally {
             try {
                 // 释放资源
@@ -183,14 +183,14 @@ public class SendCollectUtils implements Runnable {
         }
     }
 
-    @Override
-    public void run() {
-        num++;
-        log.info("第{}次重新推送提现记录消息", num);
-        this.sendCollectRetry();
-        if (num == 3) {
-            //停止定时任务
-            scheduledFutureUtil.endJob("com.ydtech.utils.scheduledFutureUtil");
-        }
-    }
+//    @Override
+//    public void run() {
+//        num++;
+//        log.info("第{}次重新推送提现记录消息", num);
+//        this.sendCollectRetry();
+//        if (num == 3) {
+//            //停止定时任务
+//            scheduledFutureUtil.endJob("com.ydtech.utils.scheduledFutureUtil");
+//        }
+//    }
 }

src/main/java/com/ydtech/utils/sendProjectUtils/SendProjrctUtils.java

@@ -27,7 +27,7 @@ import java.util.*;
 
 @Slf4j
 @Component
-public class SendProjrctUtils implements Runnable {
+public class SendProjrctUtils{
 
     @Autowired
     private SendProjectMapper sendProjectMapper;
@@ -87,8 +87,8 @@ public class SendProjrctUtils implements Runnable {
             sendProjectInfo.setHttpResponse(e.getMessage());
             sendProjectInfo.setSendState(STRING_9);
             updateSendProjectInfo(sendProjectInfo);
-            SendProjrctUtils sendProjrctUtils = new SendProjrctUtils();
-            scheduledFutureUtil.startJob(sendProjrctUtils, CORN);
+//            SendProjrctUtils sendProjrctUtils = new SendProjrctUtils();
+//            scheduledFutureUtil.startJob(sendProjrctUtils, CORN);
             e.printStackTrace();
         } finally {
             try {
@@ -190,14 +190,14 @@ public class SendProjrctUtils implements Runnable {
         }
     }
 
-    @Override
-    public void run() {
-        num++;
-        log.info("第{}次重新推送服务消息", num);
-        this.sendProjectRetry();
-        if (num == 3) {
-            //停止定时任务
-            scheduledFutureUtil.endJob("com.ydtech.utils.sendProjectUtils");
-        }
-    }
+//    @Override
+//    public void run() {
+//        num++;
+//        log.info("第{}次重新推送服务消息", num);
+//        this.sendProjectRetry();
+//        if (num == 3) {
+//            //停止定时任务
+//            scheduledFutureUtil.endJob("com.ydtech.utils.sendProjectUtils");
+//        }
+//    }
 }