فهرست منبع

快分销数据修改

yumeng 2 سال پیش
والد
کامیت
375c078de7

+ 13 - 0
jeecg-boot-base-common/src/main/java/org/jeecg/common/util/DateUtils.java

@@ -1324,6 +1324,19 @@ public class DateUtils extends PropertyEditorSupport {
     }
 
     /**
+     * 获取当前月份第一天
+     *
+     * @return
+     */
+    public static String getMonthFirstDay() {
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.DAY_OF_MONTH, 1);
+        calendar.add(Calendar.MONTH, 0);
+        String format = new SimpleDateFormat("yyyy-MM-dd").format(calendar.getTime());
+        return format;
+    }
+
+    /**
      * 计算季度开始、结束时间
      * 原则:周五为本周的第一天,下一周的周四为本周的最后一天
      *

+ 83 - 0
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/TestController.java

@@ -8,13 +8,18 @@ import cn.com.ctop.common.module.utils.Check;
 import cn.com.ctop.common.module.utils.CorpWexinUtils;
 import cn.com.ctop.crawler.modules.core.service.CrawlerDouyinMusicTaskService;
 import cn.com.ctop.crawler.modules.douyin.service.DouyinMusicService;
+import cn.com.ctop.kuaishou.modules.batch.Enums.KuaishouHourEnum;
+import cn.com.ctop.kuaishou.modules.batch.Enums.KuaishouMinSecEnum;
 import cn.com.ctop.kuaishou.modules.batch.service.*;
 import cn.com.ctop.kuaishou.modules.graphql.service.IKuaishouWebInterfaceService;
 import cn.com.ctop.kuaishou.modules.report.service.IKuaiShouDailyAgentService;
 import cn.com.ctop.kuaishou.modules.report.service.IKuaiShouProjectDataService;
 import cn.com.ctop.manage.modules.material.service.IMaterialUploadService;
 import cn.com.ctop.toutiao.modules.report.service.IBytedanceReportService;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -22,6 +27,10 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -111,11 +120,85 @@ public class TestController {
     private IKuaishouProgramCreativeService kuaishouProgramCreativeService;
     @Autowired
     private IRefreshTokenService refreshTokenService;
+    @Autowired
+    private IKuaishouSupplyChainService ikuaishouSupplyChainService;
 
     @Value("${xxl-job.requestUrl}")
     private String jobUrl;
 
 
+    @GetMapping(value = "/getData")
+    public void getDate() throws Exception {
+        log.info("-------------------------获取快分销订单昨日数据开始数据开始--------------------------");
+        String cookie = ikuaishouSupplyChainService.getCookie();
+        if (Check.isNull(cookie)) {
+            log.error("cookie数据为空");
+            return;
+        }
+
+
+        List<String> dateList = new ArrayList<>();
+        dateList.add("2022-11-01");
+        dateList.add("2022-11-02");
+        dateList.add("2022-11-03");
+        dateList.add("2022-11-04");
+        dateList.add("2022-11-05");
+        dateList.add("2022-11-06");
+        dateList.add("2022-11-07");
+        dateList.add("2022-11-08");
+        dateList.add("2022-11-09");
+        dateList.add("2022-11-10");
+        dateList.add("2022-11-11");
+        dateList.add("2022-11-12");
+        dateList.add("2022-11-13");
+        dateList.add("2022-11-14");
+        dateList.add("2022-11-15");
+        dateList.add("2022-11-16");
+        dateList.add("2022-11-17");
+        dateList.add("2022-11-18");
+        dateList.add("2022-11-19");
+        dateList.add("2022-11-20");
+        dateList.add("2022-11-21");
+        dateList.add("2022-11-22");
+        dateList.add("2022-11-23");
+        dateList.add("2022-11-24");
+        dateList.add("2022-11-25");
+        dateList.add("2022-11-26");
+        dateList.add("2022-11-27");
+        dateList.add("2022-11-28");
+        dateList.add("2022-11-29");
+        dateList.add("2022-11-30");
+
+        JSONArray hourList = KuaishouHourEnum.getHourList();
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        for (int z = 0; z < dateList.size(); z++) {
+            String date = dateList.get(z);
+            for (int i = 0; i < hourList.size(); i++) {
+                String hour = hourList.getString(i);
+                for (int j = 0; j < minSecList.size(); j++) {
+                    JSONObject minSecJson = minSecList.getJSONObject(j);
+                    String startTime = minSecJson.getString("startTime");
+                    String endTime = minSecJson.getString("endTime");
+                    String start = date + hour + startTime;
+                    String end = date + hour + endTime;
+                    System.err.println("开始时间:" + start);
+                    System.err.println("结束时间:" + end);
+                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                    Long orderCreateTimeStart = sdf.parse(start).getTime();
+                    Long orderCreateTimeEnd = sdf.parse(end).getTime();
+                    ikuaishouSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+
+                }
+            }
+        }
+
+
+    }
+
+
+
+
+
  /*   @GetMapping(value = "/updateMaterial")
     public void updateMaterial() {
 

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

@@ -15,6 +15,7 @@ import org.springframework.stereotype.Component;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
+import java.util.List;
 
 @Slf4j
 @Component
@@ -23,6 +24,49 @@ public class KuaishouOrderLIstGetJob {
     @Autowired
     private IKuaishouSupplyChainService ikuaishouSupplyChainService;
 
+
+    /**
+     * 快分销-当前月说有数据
+     **/
+    @XxlJob("nowMonthyOrderGet")
+    public void nowMonthyOrderGet() throws Exception {
+        log.info("-------------------------获取快分销订单当前月数据开始数据开始--------------------------");
+        String cookie = ikuaishouSupplyChainService.getCookie();
+        if (Check.isNull(cookie)) {
+            log.error("cookie数据为空");
+            return;
+        }
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String endDate = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -3);
+        String monthFirstDay = DateUtils.getMonthFirstDay();
+        List<String> days = DateUtils.getDays(monthFirstDay, endDate);
+        JSONArray hourList = KuaishouHourEnum.getHourList();
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        for (int z = 0; z < days.size() ; z++) {
+            String date = days.get(z);
+            for (int i = 0; i < hourList.size(); i++) {
+                String hour = hourList.getString(i);
+                for (int j = 0; j < minSecList.size(); j++) {
+                    JSONObject minSecJson = minSecList.getJSONObject(j);
+                    String startTime = minSecJson.getString("startTime");
+                    String endTime = minSecJson.getString("endTime");
+                    String start = date + hour + startTime;
+                    String end = date + hour + endTime;
+                    System.err.println("开始时间:" + start);
+                    System.err.println("结束时间:" + end);
+                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                    Long orderCreateTimeStart = sdf.parse(start).getTime();
+                    Long orderCreateTimeEnd = sdf.parse(end).getTime();
+                    ikuaishouSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd);
+
+                }
+            }
+        }
+        
+        
+    }
+
+
     /**
      * 昨日快分销数据获取
      **/

+ 3 - 6
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/Enums/KuaishouMinSecEnum.java

@@ -8,12 +8,9 @@ import java.util.ArrayList;
 import java.util.List;
 
 public enum KuaishouMinSecEnum {
-    MIN_SEC_1("00:00", "10:00"),
-    MIN_SEC_2("10:00", "20:00"),
-    MIN_SEC_3("20:00", "30:00"),
-    MIN_SEC_4("30:00", "40:00"),
-    MIN_SEC_5("40:00", "50:00"),
-    MIN_SEC_6("50:00", "60:00");
+    MIN_SEC_1("00:00", "60:00");
+    // MIN_SEC_2("30:00", "60:00");
+
 
 
     /**

+ 2 - 2
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouSupplyChainServiceImpl.java

@@ -46,7 +46,7 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
             params.put("orderCreateTimeEnd", orderCreateTimeEnd);
         }
         params.put("fundType", 1);
-        params.put("limit", 2000);
+        params.put("limit", 5000);
         params.put("offset", offset);
 
         Map<String, String> headers = new HashMap<>();
@@ -110,7 +110,7 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
         }
         supplyChainMapper.replace(supplyChains);
         Thread.sleep(2000L);
-        getOrderList(cookie, offset + 2000, orderCreateTimeStart, orderCreateTimeEnd);
+        getOrderList(cookie, offset + 5000, orderCreateTimeStart, orderCreateTimeEnd);
     }
 
     @Override