Kaynağa Gözat

数据库修改

yumeng 1 ay önce
ebeveyn
işleme
de0c8c007e

+ 8 - 8
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/JiaoYangFenXiaoJob.java

@@ -153,7 +153,7 @@ public class JiaoYangFenXiaoJob {
                 for (int p = 0; p < cookies.size(); p++) {
                     JSONObject cookieJson = cookies.get(p);
                     String cookie = cookieJson.getString("cookie");
-                    jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                    jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                 }
             }
         }
@@ -192,7 +192,7 @@ public class JiaoYangFenXiaoJob {
                 for (int p = 0; p < cookies.size(); p++) {
                     JSONObject cookieJson = cookies.get(p);
                     String cookie = cookieJson.getString("cookie");
-                    jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                    jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                 }
             }
         }
@@ -235,7 +235,7 @@ public class JiaoYangFenXiaoJob {
                     for (int p = 0; p < cookies.size(); p++) {
                         JSONObject cookieJson = cookies.get(p);
                         String cookie = cookieJson.getString("cookie");
-                        jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                        jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                     }
                 }
             }
@@ -276,7 +276,7 @@ public class JiaoYangFenXiaoJob {
                 for (int p = 0; p < cookies.size(); p++) {
                     JSONObject cookieJson = cookies.get(p);
                     String cookie = cookieJson.getString("cookie");
-                    jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                    jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                 }
             }
         }
@@ -314,7 +314,7 @@ public class JiaoYangFenXiaoJob {
                 for (int p = 0; p < cookies.size(); p++) {
                     JSONObject cookieJson = cookies.get(p);
                     String cookie = cookieJson.getString("cookie");
-                    jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                    jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                 }
 
             }
@@ -356,7 +356,7 @@ public class JiaoYangFenXiaoJob {
                     for (int p = 0; p < cookies.size(); p++) {
                         JSONObject cookieJson = cookies.get(p);
                         String cookie = cookieJson.getString("cookie");
-                        jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                        jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                     }
                 }
             }
@@ -403,7 +403,7 @@ public class JiaoYangFenXiaoJob {
                     for (int p = 0; p < cookies.size(); p++) {
                         JSONObject cookieJson = cookies.get(p);
                         String cookie = cookieJson.getString("cookie");
-                        jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                        jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                     }
                 }
             }
@@ -451,7 +451,7 @@ public class JiaoYangFenXiaoJob {
                     for (int p = 0; p < cookies.size(); p++) {
                         JSONObject cookieJson = cookies.get(p);
                         String cookie = cookieJson.getString("cookie");
-                        jiaoYangFenXiaoService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+                        jiaoYangFenXiaoService.getOrderList(cookie, 1, 0, orderCreateTimeStart, orderCreateTimeEnd);
                     }
                 }
             }

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IJiaoYangFenXiaoService.java

@@ -7,7 +7,7 @@ import java.util.List;
 public interface IJiaoYangFenXiaoService {
     List<JSONObject> getCookie();
 
-    void getOrderList(String cookie, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd) throws Exception;
+    void getOrderList(String cookie, Integer current,Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd) throws Exception;
 
     void getClipCooperation(String cookie, Integer offset, Long statDate,Integer status) throws Exception;
 

+ 7 - 6
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/JiaoYangFenXiaoServiceImpl.java

@@ -42,7 +42,7 @@ public class JiaoYangFenXiaoServiceImpl implements IJiaoYangFenXiaoService {
     }
 
     @Override
-    public void getOrderList(String cookie, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd) throws Exception {
+    public void getOrderList(String cookie, Integer current, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd) throws Exception {
         Thread.sleep(4000L);
         log.info("骄阳订单数据入参,开始时间:{},结束时间:{},数据:{}", DateUtils.tempToLongDateStr(orderCreateTimeStart), DateUtils.tempToLongDateStr(orderCreateTimeEnd), offset);
         Map<String, Object> params = new HashMap<>();
@@ -52,20 +52,21 @@ public class JiaoYangFenXiaoServiceImpl implements IJiaoYangFenXiaoService {
         if (!Check.isNull(orderCreateTimeEnd)) {
             params.put("orderCreateTimeEnd", orderCreateTimeEnd);
         }
-        //  params.put("fundType", 1);
-        params.put("limit", 100);
+        params.put("pageSize", 100);
+        params.put("current", current);
         params.put("offset", offset);
+        params.put("limit", 100);
         params.put("timeType", 1);
         Map<String, String> headers = new HashMap<>();
         headers.put("Cookie", cookie);
-        headers.put("Accept", "application/json");
+      /*  headers.put("Accept", "application/json");
         headers.put("Accept-Encoding", "gzip, deflate, br");
         headers.put("Accept-Language", "gzip, deflate, br");
         headers.put("Connection", "keep-alive");
         headers.put("Host", "cps.kwaixiaodian.com");
         headers.put("kpf", "PC_WEB");
         headers.put("Referer", "https://cps.kwaixiaodian.com/pc/leader/base/order-manage");
-        headers.put("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:122.0) Gecko/20100101 Firefox/122.0");
+        headers.put("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:122.0) Gecko/20100101 Firefox/122.0");*/
         String resultStr = HttpUtils.KuaiShouttpGetRequest(url, params, headers);
         log.info("爬虫数据返回:{}", resultStr);
         JSONObject result = JSONObject.parseObject(resultStr);
@@ -137,7 +138,7 @@ public class JiaoYangFenXiaoServiceImpl implements IJiaoYangFenXiaoService {
             e.printStackTrace();
         }
         if (list.size() >= 100) {
-            getOrderList(cookie, offset + 100, orderCreateTimeStart, orderCreateTimeEnd);
+            getOrderList(cookie, current + 1, offset + 100, orderCreateTimeStart, orderCreateTimeEnd);
         }
 
     }