yumeng 1 년 전
부모
커밋
bdd42fe134
1개의 변경된 파일16개의 추가작업 그리고 0개의 파일을 삭제
  1. 16 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouOrderLIstGetJob.java

+ 16 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouOrderLIstGetJob.java

@@ -20,6 +20,8 @@ import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 @Slf4j
 @Component
@@ -31,6 +33,8 @@ public class KuaishouOrderLIstGetJob {
     private IKuaiShouActivityInfoService activityInfoService;
     @Autowired
     private IKuaiShouActivityItemListService activityItemListService;
+    static ExecutorService fxService = Executors.newFixedThreadPool(3);
+
 
 
     /**
@@ -132,6 +136,18 @@ public class KuaishouOrderLIstGetJob {
                         JSONObject cookieJson = cookies.get(p);
                         String cookie = cookieJson.getString("cookie");
                         ikuaishouSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                        fxService.submit(new Runnable() {
+                            @Override
+                            public void run() {
+                                try {
+                                    ikuaishouSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                                } catch (Exception e) {
+                                    e.printStackTrace();
+                                }
+                            }
+                        });
+
+
                     }
                 }
             }