修改

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/FeishuPushJob.java

@@ -7,6 +7,9 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 @Slf4j
 @Component
 public class FeishuPushJob {
@@ -33,84 +36,118 @@ public class FeishuPushJob {
     @Autowired
     IFeishuService feishuService;
 
+    private static ExecutorService sendExecutor = Executors.newFixedThreadPool(2);
+    private static ExecutorService reportsAdPushExecutor = Executors.newFixedThreadPool(2);
+    private static ExecutorService totalRankPushExecutor = Executors.newFixedThreadPool(2);
+    private static ExecutorService movieRankExecutor = Executors.newFixedThreadPool(2);
+
+
     @XxlJob("unbindWarnPush")
-    public void unbindWarnPush(){
+    public void unbindWarnPush() {
         unbindWarnPushService.send();
     }
+
     @XxlJob("bindAppErrorWarnPush")
-    public void bindAppErrorWarnPush(){
+    public void bindAppErrorWarnPush() {
         bindAppErrorWarnService.send();
     }
 
     //投放战报
     @XxlJob("reportsAdPush")
-    public void reportsAdPush(){
-        reportsAdPushService.send();
+    public void reportsAdPush() {
+        reportsAdPushExecutor.submit(new Runnable() {
+            @Override
+            public void run() {
+                reportsAdPushService.send();
+            }
+        });
+
+
     }
 
     //优化师实时战报（小组排行榜）
     @XxlJob("optimizerRankPush")
-    public void optimizerRankPush(){
-        optimizerRankPushService.send();
+    public void optimizerRankPush() {
+        sendExecutor.submit(new Runnable() {
+            @Override
+            public void run() {
+                optimizerRankPushService.send();
+            }
+        });
+
     }
 
     //优化师实时战绩
     @XxlJob("totalRankPush")
-    public void totalRankPush(){
-        totalRankPushService.send();
+    public void totalRankPush() {
+        totalRankPushExecutor.submit(new Runnable() {
+            @Override
+            public void run() {
+                totalRankPushService.send();
+            }
+        });
+
+
     }
 
     //短剧业务概况（投放）
     @XxlJob("dateReportsPush")
-    public void dateReportsPush(){
+    public void dateReportsPush() {
         dateReportsPushService.send();
     }
 
     @XxlJob("reportsByBusinessPush")
-    public void reportByBusinessPush(){
+    public void reportByBusinessPush() {
         reportsByBusinessPushService.send();
     }
 
     //短剧业务概况预投放（12点）
     @XxlJob("preDateReportsPush")
-    public void preDataReportsPush(){
+    public void preDataReportsPush() {
         dateReportsPushService.send12hour();
     }
 
     //短剧业务概况预投放-给开发
     @XxlJob("dataReportsToDeveloper")
-    public void dataReportsToDeveloper(){
+    public void dataReportsToDeveloper() {
         dateReportsPushService.preSend();
     }
 
     //剪辑排行榜
     @XxlJob("cutGroupRankPush")
-    public void cutGroupRankPush(){
+    public void cutGroupRankPush() {
         cutGroupRankPushService.send();
     }
 
     @XxlJob("loginRecordPush")
-    public void loginRecordPush(){
+    public void loginRecordPush() {
         userLoginRecordService.queryUserLoginRecord();
     }
 
     @XxlJob("pullFeishuAvatar")
-    public void pullFeishuAvatar(){
+    public void pullFeishuAvatar() {
         try {
             feishuService.uploadAvatar();
-        }catch (Exception e){
-            log.error("pullFeishuAvatar error: "+e.getMessage(), e);
+        } catch (Exception e) {
+            log.error("pullFeishuAvatar error: " + e.getMessage(), e);
         }
     }
 
     @XxlJob("distributionPush")
-    public void distributionPush(){
+    public void distributionPush() {
 
 
     }
 
     @XxlJob("movieTopPush")
-    public void movieTopPush(){
-        movieRankPushService.send();
+    public void movieTopPush() {
+
+        movieRankExecutor.submit(new Runnable() {
+            @Override
+            public void run() {
+                movieRankPushService.send();
+            }
+        });
+
     }
 }