yumeng 9 months ago
parent
commit
aa9c8bb1a9
26 changed files with 1460 additions and 60 deletions
  1. 45 30
      jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/TestController.java
  2. 1 1
      jeecg-boot-module-system/src/main/resources/application-dev.yml
  3. 161 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/YuXiuOrderLIstGetJob.java
  4. 11 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/settlementJob.java
  5. 1 1
      module-job-kuaishou/src/main/resources/application-dev.yml
  6. 2 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/KuaiShouActivityItemListMapper.java
  7. 18 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/KuaishouSupplyChainMapper.java
  8. 2 7
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/MgsSupplyChainMapper.java
  9. 2 7
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/RocketSupplyChainMapper.java
  10. 21 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/YuXiuSupplyChainMapper.java
  11. 2 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/YufuSupplyChainMapper.java
  12. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaiShouActivityItemListMapper.xml
  13. 366 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaishouSupplyChainMapper.xml
  14. 63 5
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/MgsSupplyChainMapper.xml
  15. 64 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/RocketSupplyChainMapper.xml
  16. 339 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/YuXiuSupplyChainMapper.xml
  17. 64 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/YufuSupplyChainMapper.xml
  18. 2 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaiShouActivityItemListService.java
  19. 8 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouSupplyChainService.java
  20. 12 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IYuXiuSupplyChainService.java
  21. 14 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouActivityItemListServiceImpl.java
  22. 36 8
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouSupplyChainServiceImpl.java
  23. 7 1
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/MgsSupplyChainServiceImpl.java
  24. 8 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/RocketSupplyChainServiceImpl.java
  25. 198 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/YuXiuSupplyChainServiceImpl.java
  26. 8 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/YufuSupplyChainServiceImpl.java

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

@@ -166,49 +166,64 @@ public class TestController {
 
     @Autowired
     private IMgsSupplyChainService mgsSupplyChainService;
+
+    @Autowired
+    private IYuXiuSupplyChainService yuXiuSupplyChainService;
+
     @Autowired
     private IKuaishouSupplyChainService ikuaishouSupplyChainService;
 
     @Autowired
     private YufuSupplyChainService yufuSupplyChainService;
 
+    static ExecutorService fxNowService = Executors.newFixedThreadPool(3);
 
     @GetMapping(value = "/getData")
     public void getDate() throws Exception {
-
-        List<JSONObject> cookies = ikuaishouSupplyChainService.getCookie();
+        log.info("-------------------------获取快分销订单当前月数据开始数据开始--------------------------");
+        List<JSONObject> cookies = yuXiuSupplyChainService.getCookie();
         if (Check.isNull(cookies)) {
+            log.error("cookie数据为空");
             return;
         }
-
-        String date = DateUtils.getNowDate("yyyy-MM-dd");
-        String yesDate = DateUtils.getAnotherDay("yyyy-MM-dd", date, -1);
-        for (int i = 0; i < cookies.size(); i++) {
-            JSONObject jsonObject = cookies.get(i);
-            String cookie = jsonObject.getString("cookie");
-            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "ruixuan", yesDate);
-        }
-        Thread.sleep(5 * 1000);
-        List<JSONObject> mgsCookies = ikuaishouSupplyChainService.getMgsCookie();
-        for (int i = 0; i < mgsCookies.size(); i++) {
-            JSONObject jsonObject = mgsCookies.get(i);
-            String cookie = jsonObject.getString("cookie");
-            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "miaogousi", yesDate);
-        }
-        Thread.sleep(5 * 1000);
-        List<JSONObject> rocketCookies = ikuaishouSupplyChainService.getRocketCookie();
-        for (int i = 0; i < rocketCookies.size(); i++) {
-            JSONObject jsonObject = rocketCookies.get(i);
-            String cookie = jsonObject.getString("cookie");
-            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "rocket", yesDate);
-        }
-        Thread.sleep(5 * 1000);
-        List<JSONObject> yufuCookies = ikuaishouSupplyChainService.getYuFuCiikie();
-        for (int i = 0; i < yufuCookies.size(); i++) {
-            JSONObject jsonObject = yufuCookies.get(i);
-            String cookie = jsonObject.getString("cookie");
-            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "yufu", yesDate);
+        String nowDate = "2024-09-23";
+        String endDate = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -10);
+
+        List<String> days = DateUtils.getDays("2024-08-19", nowDate);
+        JSONArray hourList = KuaishouHourEnum.getHourList();
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        Map<Long, Long> itemMap = activityItemListService.getYufuItemList();
+        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;
+                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                    Long orderCreateTimeStart = sdf.parse(start).getTime();
+                    Long orderCreateTimeEnd = sdf.parse(end).getTime();
+                    for (int p = 0; p < cookies.size(); p++) {
+                        JSONObject cookieJson = cookies.get(p);
+                        String cookie = cookieJson.getString("cookie");
+                        fxNowService.submit(new Runnable() {
+                            @Override
+                            public void run() {
+                                try {
+                                    yuXiuSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                                } catch (Exception e) {
+                                    e.printStackTrace();
+                                }
+                            }
+                        });
+                    }
+                }
+            }
         }
+
     }
 
 

+ 1 - 1
jeecg-boot-module-system/src/main/resources/application-dev.yml

@@ -161,7 +161,7 @@ spring:
   # mongodb 配置
   data:
     mongodb:
-      host: 192.168.0.99
+      host: 114.117.193.186
       port: 27017
       #root:只在admin数据库中可用。超级账号,超级权限
       username: root

+ 161 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/YuXiuOrderLIstGetJob.java

@@ -0,0 +1,161 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.common.module.utils.Check;
+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.IKuaiShouActivityItemListService;
+import cn.com.ctop.kuaishou.modules.batch.service.IYuXiuSupplyChainService;
+import cn.com.ctop.kuaishou.modules.batch.service.YufuSupplyChainService;
+import cn.com.ctop.kuaishou.modules.batch.service.impl.YuXiuSupplyChainServiceImpl;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Slf4j
+@Component
+public class YuXiuOrderLIstGetJob {
+
+    @Autowired
+    private IYuXiuSupplyChainService yuXiuSupplyChainService;
+
+    @Autowired
+    private IKuaiShouActivityItemListService yufuActivityItemListService;
+
+    static ExecutorService fxService = Executors.newFixedThreadPool(3);
+
+    /**
+     * 昨日快分销数据获取
+     **/
+    @XxlJob("yuxiuYesterdayOrderGet")
+    public void yufuYesterdayOrderGet() throws Exception {
+        List<JSONObject> cookies = yuXiuSupplyChainService.getCookie();
+        if (Check.isNull(cookies)) {
+            log.error("cookie数据为空");
+            return;
+        }
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String date = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+        JSONArray hourList = KuaishouHourEnum.getHourList();
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        Map<Long, Long> itemMap = yufuActivityItemListService.getYuXiuItemList();
+        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();
+                for (int p = 0; p < cookies.size(); p++) {
+                    JSONObject cookieJson = cookies.get(p);
+                    String cookie = cookieJson.getString("cookie");
+                    yuXiuSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                }
+            }
+        }
+    }
+
+
+    /**
+     * 当前小时数据获取
+     **/
+    @XxlJob("yuxiuNowHourOrderGet")
+    public void yufuNowHourOrderGet() throws Exception {
+        List<JSONObject> cookies = yuXiuSupplyChainService.getCookie();
+        if (Check.isNull(cookies)) {
+            log.error("cookie数据为空");
+            return;
+        }
+        String date = DateUtils.getNowDate("yyyy-MM-dd");
+        Integer nowHour = DateUtils.getNowHour();
+        JSONArray hours = new JSONArray();
+        hours.add(nowHour);
+        if (nowHour >= 1) {
+            hours.add(nowHour - 1);
+        }
+
+
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        Map<Long, Long> itemMap = yufuActivityItemListService.getYuXiuItemList();
+        for (int i = 0; i < hours.size(); i++) {
+            Integer hour = hours.getInteger(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();
+                for (int p = 0; p < cookies.size(); p++) {
+                    JSONObject cookieJson = cookies.get(p);
+                    String cookie = cookieJson.getString("cookie");
+                    yuXiuSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                }
+            }
+        }
+    }
+
+    /**
+     * 当天所有数据获取
+     **/
+    /**
+     * 当天数据获取
+     **/
+    @XxlJob("yuxiuFrontHourOrderGet")
+    public void yufuFrontHourOrderGet() throws Exception {
+        List<JSONObject> cookies = yuXiuSupplyChainService.getCookie();
+        if (Check.isNull(cookies)) {
+            log.error("cookie数据为空");
+            return;
+        }
+        String date = DateUtils.getNowDate("yyyy-MM-dd");
+        JSONArray hourList = KuaishouHourEnum.getHourList();
+        JSONArray minSecList = KuaishouMinSecEnum.getMinSecList();
+        Map<Long, Long> itemMap = yufuActivityItemListService.getYuXiuItemList();
+        Integer nowHour = DateUtils.getNowHour();
+        for (int i = 0; i < hourList.size(); i++) {
+            String hour = hourList.getString(i);
+            Integer integer = Integer.valueOf(hour.replace(":", "").replace(" ", ""));
+            if (integer <= nowHour) {
+                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();
+                    for (int p = 0; p < cookies.size(); p++) {
+                        JSONObject cookieJson = cookies.get(p);
+                        String cookie = cookieJson.getString("cookie");
+                        yuXiuSupplyChainService.getOrderList(cookie, 0, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+                    }
+                }
+            }
+        }
+    }
+
+
+}

+ 11 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/settlementJob.java

@@ -187,6 +187,14 @@ public class settlementJob {
         ikuaishouSupplyChainService.deleteYufuPromoterBindChannelByDate(date);
         ikuaishouSupplyChainService.cleanYufuKuaiShouPromoterBindChannel(date);
 
+        ikuaishouSupplyChainService.deleteYuXiuPromoterBindChannelByDate(date);
+        ikuaishouSupplyChainService.cleanYuXiuKuaiShouPromoterBindChannel(date);
+
+
+
+
+
+        // 招商
 
         ikuaishouSupplyChainService.deleteItemBindCourtshipByDate(date);
         ikuaishouSupplyChainService.cleanKuaiShouItemBindCourtship(date);
@@ -204,6 +212,9 @@ public class settlementJob {
         ikuaishouSupplyChainService.deleteYufuItemBindCourtshipByDate(date);
         ikuaishouSupplyChainService.cleanYufuItemBindCourtship(date);
 
+        ikuaishouSupplyChainService.deleteYuXiuItemBindCourtshipByDate(date);
+        ikuaishouSupplyChainService.cleanYuXiuItemBindCourtship(date);
+
 
     }
 

+ 1 - 1
module-job-kuaishou/src/main/resources/application-dev.yml

@@ -91,7 +91,7 @@ spring:
   # mongodb 配置
   data:
     mongodb:
-      host: 192.168.0.99
+      host: 114.117.193.186
       port: 27017
       #root:只在admin数据库中可用。超级账号,超级权限
       username: root

+ 2 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/KuaiShouActivityItemListMapper.java

@@ -28,4 +28,6 @@ public interface KuaiShouActivityItemListMapper extends BaseMapper<KuaiShouActiv
     void updateItemStatusByItem(@Param("itemId") Long itemId, @Param("itemStatus") Integer itemStatus);
 
     List<JSONObject> getYufuItemList();
+
+    List<JSONObject> getYuXiuItemList();
 }

+ 18 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/KuaishouSupplyChainMapper.java

@@ -91,4 +91,22 @@ public interface KuaishouSupplyChainMapper extends BaseMapper<KuaishouSupplyChai
     void deleteYufuItemBindCourtshipByDate(@Param("date") Long date);
 
     void cleanYufuItemBindCourtship(@Param("date") Long date);
+
+    void replaceRuixuanSupplyChains(@Param("adds") List<KuaishouSupplyChain> ruixuanSupplyChains);
+
+    void replaceMgsSupplyChains(@Param("adds") List<KuaishouSupplyChain> mgsSupplyChains);
+
+    void replaceRocketSupplyChains(@Param("adds") List<KuaishouSupplyChain> rocketSupplyChains);
+
+    void replaceYufuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yufuSupplyChains);
+
+    void replaceYuXiuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yuxiuSupplyChains);
+
+    void deleteYuXiuPromoterBindChannelByDate(@Param("date") Long date);
+
+    void cleanYuXiuKuaiShouPromoterBindChannel(@Param("date") Long date);
+
+    void deleteYuXiuItemBindCourtshipByDate(@Param("date") Long date);
+
+    void cleanYuXiuItemBindCourtship(@Param("date") Long date);
 }

+ 2 - 7
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/MgsSupplyChainMapper.java

@@ -20,13 +20,6 @@ public interface MgsSupplyChainMapper extends BaseMapper<KuaishouSupplyChain> {
 
     List<JSONObject>  getCookie();
 
-
-
-
-
-
-
-
     void replaceRuixuanSupplyChains(@Param("adds") List<KuaishouSupplyChain> ruixuanSupplyChains);
 
     void replaceMgsSupplyChains(@Param("adds") List<KuaishouSupplyChain> mgsSupplyChains);
@@ -34,4 +27,6 @@ public interface MgsSupplyChainMapper extends BaseMapper<KuaishouSupplyChain> {
     void replaceRocketSupplyChains(@Param("adds") List<KuaishouSupplyChain> rocketSupplyChains);
 
     void replaceYufuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yufuSupplyChains);
+
+    void replaceYuXiuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yuxiuSupplyChains);
 }

+ 2 - 7
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/RocketSupplyChainMapper.java

@@ -17,13 +17,6 @@ public interface RocketSupplyChainMapper extends BaseMapper<KuaishouSupplyChain>
 
     List<JSONObject> getCookie();
 
-
-
-
-
-
-
-
     void replaceRuixuanSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> ruixuanSupplyChains);
 
     void replaceMgsSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> mgsSupplyChains);
@@ -31,4 +24,6 @@ public interface RocketSupplyChainMapper extends BaseMapper<KuaishouSupplyChain>
     void replaceRocketSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> rocketSupplyChains);
 
     void replaceYufuSupplyChains(@Param(value = "adds")  List<KuaishouSupplyChain> yufuSupplyChains);
+
+    void replaceYuXiuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yuxiuSupplyChains);
 }

+ 21 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/YuXiuSupplyChainMapper.java

@@ -0,0 +1,21 @@
+package cn.com.ctop.kuaishou.modules.batch.mapper;
+
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaishouSupplyChain;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface YuXiuSupplyChainMapper {
+    List<JSONObject> getCookie();
+
+    void replaceRuixuanSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> ruixuanSupplyChains);
+
+    void replaceMgsSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> mgsSupplyChains);
+
+    void replaceRocketSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> rocketSupplyChains);
+
+    void replaceYufuSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> yufuSupplyChains);
+
+    void replaceYuXiuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yuxiuSupplyChains);
+}

+ 2 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/YufuSupplyChainMapper.java

@@ -30,4 +30,6 @@ public interface YufuSupplyChainMapper extends BaseMapper<KuaishouSupplyChain> {
     void replaceRocketSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> rocketSupplyChains);
 
     void replaceYufuSupplyChains(@Param(value = "adds") List<KuaishouSupplyChain> yufuSupplyChains);
+
+    void replaceYuXiuSupplyChains(@Param("adds") List<KuaishouSupplyChain> yuxiuSupplyChains);
 }

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaiShouActivityItemListMapper.xml

@@ -112,4 +112,9 @@
         FROM yufu.kuaishou_activity_open_item_list
 
     </select>
+    <select id="getYuXiuItemList" resultType="com.alibaba.fastjson.JSONObject">
+        SELECT item_id AS 'itemId', item_commission_rate AS 'itemCommissionRate'
+        FROM yuxiu.kuaishou_activity_open_item_list
+
+    </select>
 </mapper>

+ 366 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaishouSupplyChainMapper.xml

@@ -2,6 +2,335 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="cn.com.ctop.kuaishou.modules.batch.mapper.KuaishouSupplyChainMapper">
 
+
+    <insert id="replaceRuixuanSupplyChains">
+        replace into ruixuan.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+
+
+    </insert>
+    <insert id="replaceMgsSupplyChains">
+        replace into miaogousi.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+    </insert>
+    <insert id="replaceRocketSupplyChains">
+        replace into rocket.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+
+    </insert>
+    <insert id="replaceYufuSupplyChains">
+        replace into yufu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+        </foreach>
+    </insert>
+    <insert id="replaceYuXiuSupplyChains">
+        replace into yuxiu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+        </foreach>
+    </insert>
+
+
+
+
+
+
+
     <insert id="cleanKuaiShouPromoterBindChannel" parameterType="java.lang.Long">
         insert into ruixuan.promoter_bind_channel_date (promoter_id, promoter_name,promoter_url, user_id, user_name, stat_date,media_id)
         select t1.promoter_id, t1.promoter_nick_name, t1.promoter_url,t1.user_id, t1.user_name, #{date},media_id
@@ -203,6 +532,32 @@
           AND t1.media_id = 2
         GROUP BY t1.item_id
     </insert>
+    <insert id="cleanYuXiuKuaiShouPromoterBindChannel" parameterType="java.lang.Long">
+        INSERT INTO yuxiu.promoter_bind_channel_date (promoter_id, promoter_name, promoter_url, user_id, user_name,
+                                                       stat_date, media_id)
+        SELECT t1.promoter_id, t1.promoter_nick_name, t1.promoter_url, t1.user_id, t1.user_name, #{date}, media_id
+        FROM yuxiu.kuaishou_promoter t1
+                 LEFT JOIN yuxiu.sys_user_role t2
+                           ON t1.user_id = t2.user_id
+                 LEFT JOIN yuxiu.sys_role t3
+                           ON t2.role_id = t3.role_id
+        WHERE 1 = 1
+          AND t1.media_id = '2'
+          AND t3.role_key IN ('bdManager', 'bd')
+          AND date_format(t1.create_time, '%Y%m%d') &lt; #{date}
+        GROUP BY t1.promoter_id
+
+
+    </insert>
+    <insert id="cleanYuXiuItemBindCourtship" parameterType="java.lang.Long">
+        INSERT INTO yuxiu.item_bind_courtship_date (item_id, item_name, item_url, user_id, user_name, stat_date,
+                                                    media_id)
+        SELECT t1.item_id, t1.item_title, t1.item_img_url, t1.user_id, t1.user_name, #{date}, media_id
+        FROM yuxiu.kuaishou_item_list t1
+        WHERE date_format(t1.create_time, '%Y%m%d') &lt; #{date}
+          AND t1.media_id = 2
+        GROUP BY t1.item_id
+    </insert>
     <delete id="deletePromoterBindChannelByDate" parameterType="java.lang.Long">
         delete from ruixuan.promoter_bind_channel_date where stat_date = #{date}
     </delete>
@@ -240,6 +595,17 @@
         FROM yufu.item_bind_courtship_date
         WHERE stat_date = #{date}
     </delete>
+    <delete id="deleteYuXiuPromoterBindChannelByDate" parameterType="java.lang.Long">
+        DELETE
+        FROM yuxiu.promoter_bind_channel_date
+        WHERE stat_date = #{date}
+    </delete>
+    <delete id="deleteYuXiuItemBindCourtshipByDate" parameterType="java.lang.Long">
+        DELETE
+        FROM yuxiu.item_bind_courtship_date
+        WHERE stat_date = #{date}
+
+    </delete>
     <select id="getCookie" resultType="com.alibaba.fastjson.JSONObject">
 
         select  id ,cookie  from ruixuan.kuaishou_supply_chain_cookie

+ 63 - 5
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/MgsSupplyChainMapper.xml

@@ -260,11 +260,69 @@
             )
         </foreach>
     </insert>
-
-
-
-
-
+    <insert id="replaceYuXiuSupplyChains">
+        replace into yuxiu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+        </foreach>
+    </insert>
 
 
     <select id="getCookie" resultType="com.alibaba.fastjson.JSONObject">

+ 64 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/RocketSupplyChainMapper.xml

@@ -259,6 +259,70 @@
             )
         </foreach>
     </insert>
+    <insert id="replaceYuXiuSupplyChains">
+        replace into yuxiu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+        </foreach>
+
+    </insert>
 
     <select id="getCookie" resultType="com.alibaba.fastjson.JSONObject">
 

+ 339 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/YuXiuSupplyChainMapper.xml

@@ -0,0 +1,339 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.com.ctop.kuaishou.modules.batch.mapper.YuXiuSupplyChainMapper">
+
+
+
+
+    <insert id="replaceRuixuanSupplyChains">
+        replace into ruixuan.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+
+
+    </insert>
+    <insert id="replaceMgsSupplyChains">
+        replace into miaogousi.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+    </insert>
+    <insert id="replaceRocketSupplyChains">
+        replace into rocket.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+
+    </insert>
+    <insert id="replaceYufuSupplyChains">
+        replace into yufu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+    </insert>
+    <insert id="replaceYuXiuSupplyChains">
+        replace into yuxiu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+        </foreach>
+    </insert>
+
+    <select id="getCookie" resultType="com.alibaba.fastjson.JSONObject">
+        SELECT id, cookie
+        FROM yuxiu.kuaishou_supply_chain_cookie
+    </select>
+
+
+
+
+</mapper>

+ 64 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/YufuSupplyChainMapper.xml

@@ -264,6 +264,70 @@
 
         </foreach>
     </insert>
+    <insert id="replaceYuXiuSupplyChains">
+        replace into yuxiu.kuaishou_supply_chain(
+        oid,
+        item_id,
+        item_title,
+        reserve_price,
+        image_url,
+        order_status,
+        order_create_time,
+        send_status,
+        settlement_biz_type,
+        settlement_biz_type_desc,
+        send_time,
+        recv_time,
+        seller_id,
+        promoter_id,
+        promoter_nick_name,
+        activity_id,
+        order_amount,
+        pay_amount,
+        regimental_promotion_rate,
+        share_rate,
+        base_amount,
+        service_amount,
+        regimental_promotion_amount,
+        total_regimental_settle_amount,
+        stat_date,
+        stat_hour,
+        item_commission_rate
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.oid},
+            #{add.itemId},
+            #{add.itemTitle},
+            #{add.reservePrice},
+            #{add.imageUrl},
+            #{add.orderStatus},
+            #{add.orderCreateTime},
+            #{add.sendStatus},
+            #{add.settlementBizType},
+            #{add.settlementBizTypeDesc},
+            #{add.sendTime},
+            #{add.recvTime},
+            #{add.sellerId},
+            #{add.promoterId},
+            #{add.promoterNickName},
+            #{add.activityId},
+            #{add.orderAmount},
+            #{add.payAmount},
+            #{add.regimentalPromotionRate},
+            #{add.shareRate},
+            #{add.baseAmount},
+            #{add.serviceAmount},
+            #{add.regimentalPromotionAmount},
+            #{add.totalRegimentalSettleAmount},
+            #{add.statDate},
+            #{add.statHour},
+            #{add.itemCommissionRate}
+            )
+
+        </foreach>
+    </insert>
 
     <select id="getCookie" resultType="com.alibaba.fastjson.JSONObject">
 

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

@@ -23,4 +23,6 @@ public interface IKuaiShouActivityItemListService extends IService<KuaiShouActiv
     Map<Long, Long> getRocketItemList();
 
     Map<Long, Long> getYufuItemList();
+
+    Map<Long, Long> getYuXiuItemList();
 }

+ 8 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouSupplyChainService.java

@@ -80,4 +80,12 @@ public interface IKuaishouSupplyChainService extends IService<KuaishouSupplyChai
     void deleteYufuItemBindCourtshipByDate(Long date);
 
     void cleanYufuItemBindCourtship(Long date);
+
+    void deleteYuXiuPromoterBindChannelByDate(Long date);
+
+    void cleanYuXiuKuaiShouPromoterBindChannel(Long date);
+
+    void deleteYuXiuItemBindCourtshipByDate(Long date);
+
+    void cleanYuXiuItemBindCourtship(Long date);
 }

+ 12 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IYuXiuSupplyChainService.java

@@ -0,0 +1,12 @@
+package cn.com.ctop.kuaishou.modules.batch.service;
+
+import com.alibaba.fastjson.JSONObject;
+
+import java.util.List;
+import java.util.Map;
+
+public interface IYuXiuSupplyChainService {
+    void getOrderList(String cookie, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd, Map<Long,Long> itemMap) throws Exception;
+
+    List<JSONObject> getCookie();
+}

+ 14 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouActivityItemListServiceImpl.java

@@ -203,6 +203,20 @@ public class KuaiShouActivityItemListServiceImpl extends ServiceImpl<KuaiShouAct
         return returnMap;
     }
 
+    @Override
+    public Map<Long, Long> getYuXiuItemList() {
+        Map<Long, Long> returnMap = new HashMap<>();
+        List<JSONObject> list = activityItemListMapper.getYuXiuItemList();
+        if (!Check.isNull(list)) {
+            for (int i = 0; i < list.size(); i++) {
+                JSONObject jsonObject = list.get(i);
+                returnMap.put(jsonObject.getLong("itemId"), jsonObject.getLong("itemCommissionRate"));
+            }
+        }
+
+        return returnMap;
+    }
+
     public static String filterSupplement(String content) {
         StringBuilder sb = new StringBuilder();
         for (char ch : content.toCharArray()) {

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

@@ -56,7 +56,7 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
     @Transactional
     @Override
     public void getOrderList(String cookie, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd, Map<Long, Long> itemMap) throws Exception {
-        Thread.sleep(1000);
+        Thread.sleep(1500);
         log.info("567团长抓取订单数据入参,开始时间:{},结束时间:{},数据:{}", DateUtils.tempToLongDateStr(orderCreateTimeStart), DateUtils.tempToLongDateStr(orderCreateTimeEnd), offset);
         Map<String, Object> params = new HashMap<>();
         if (!Check.isNull(orderCreateTimeStart)) {
@@ -100,6 +100,7 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
         List<KuaishouSupplyChain> mgsSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> rocketSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> yufuSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yuxiuSupplyChains = new ArrayList<>();
         for (int i = 0; i < list.size(); i++) {
             JSONObject jsonObject = list.getJSONObject(i);
             KuaishouSupplyChain supplyChain = new KuaishouSupplyChain();
@@ -150,31 +151,38 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
                 if ("miaogousi".equals(ownership)) {
                     mgsSupplyChains.add(supplyChain);
                 }
-
                 if ("rocket".equals(ownership)) {
                     rocketSupplyChains.add(supplyChain);
                 }
                 if ("yufu".equals(ownership)) {
                     yufuSupplyChains.add(supplyChain);
                 }
+                if ("yuxiu".equals(ownership)) {
+                    yuxiuSupplyChains.add(supplyChain);
+                }
+
             }
 
         }
         try {
             if (!Check.isNull(ruixuanSupplyChains)) {
-                rocketSupplyChainMapper.replaceRuixuanSupplyChains(ruixuanSupplyChains);
+                supplyChainMapper.replaceRuixuanSupplyChains(ruixuanSupplyChains);
             }
 
             if (!Check.isNull(mgsSupplyChains)) {
-                rocketSupplyChainMapper.replaceMgsSupplyChains(mgsSupplyChains);
+                supplyChainMapper.replaceMgsSupplyChains(mgsSupplyChains);
             }
 
             if (!Check.isNull(rocketSupplyChains)) {
-                rocketSupplyChainMapper.replaceRocketSupplyChains(rocketSupplyChains);
+                supplyChainMapper.replaceRocketSupplyChains(rocketSupplyChains);
             }
 
             if (!Check.isNull(yufuSupplyChains)) {
-                rocketSupplyChainMapper.replaceYufuSupplyChains(yufuSupplyChains);
+                supplyChainMapper.replaceYufuSupplyChains(yufuSupplyChains);
+            }
+
+            if (!Check.isNull(yuxiuSupplyChains)) {
+                supplyChainMapper.replaceYuXiuSupplyChains(yuxiuSupplyChains);
             }
 
         } catch (Exception e) {
@@ -297,8 +305,8 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
     public void getSellerInfo(String cookie, Integer offset, String db, String date) throws InterruptedException {
         Thread.sleep(2000);
         Map<String, Object> params = new HashMap<>();
-        params.put("startDate", "2024-07-01");
-        params.put("endDate", "2024-08-20");
+        params.put("startDate",date);
+        params.put("endDate", date);
         params.put("limit", 20);
         params.put("offset", offset);
         Map<String, String> headers = new HashMap<>();
@@ -400,6 +408,26 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
         supplyChainMapper.cleanYufuItemBindCourtship(date);
     }
 
+    @Override
+    public void deleteYuXiuPromoterBindChannelByDate(Long date) {
+        supplyChainMapper.deleteYuXiuPromoterBindChannelByDate(date);
+    }
+
+    @Override
+    public void cleanYuXiuKuaiShouPromoterBindChannel(Long date) {
+        supplyChainMapper.cleanYuXiuKuaiShouPromoterBindChannel(date);
+    }
+
+    @Override
+    public void deleteYuXiuItemBindCourtshipByDate(Long date) {
+        supplyChainMapper.deleteYuXiuItemBindCourtshipByDate(date);
+    }
+
+    @Override
+    public void cleanYuXiuItemBindCourtship(Long date) {
+        supplyChainMapper.cleanYuXiuItemBindCourtship(date);
+    }
+
 
     @Override
     public List<JSONObject> getCookie() {

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

@@ -100,6 +100,7 @@ public class MgsSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChainMa
         List<KuaishouSupplyChain> mgsSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> rocketSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> yufuSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yuxiuSupplyChains = new ArrayList<>();
         for (int i = 0; i < list.size(); i++) {
             JSONObject jsonObject = list.getJSONObject(i);
             KuaishouSupplyChain supplyChain = new KuaishouSupplyChain();
@@ -157,6 +158,9 @@ public class MgsSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChainMa
                 if ("yufu".equals(ownership)) {
                     yufuSupplyChains.add(supplyChain);
                 }
+                if ("yuxiu".equals(ownership)) {
+                    yuxiuSupplyChains.add(supplyChain);
+                }
 
             }
         }
@@ -176,7 +180,9 @@ public class MgsSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChainMa
             if (!Check.isNull(yufuSupplyChains)) {
                 mgsSupplyChainMapper.replaceYufuSupplyChains(yufuSupplyChains);
             }
-
+            if (!Check.isNull(yuxiuSupplyChains)) {
+                mgsSupplyChainMapper.replaceYuXiuSupplyChains(yuxiuSupplyChains);
+            }
 
         } catch (Exception e) {
             e.printStackTrace();

+ 8 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/RocketSupplyChainServiceImpl.java

@@ -97,6 +97,7 @@ public class RocketSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChai
         List<KuaishouSupplyChain> mgsSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> rocketSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> yufuSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yuxiuSupplyChains = new ArrayList<>();
         for (int i = 0; i < list.size(); i++) {
             JSONObject jsonObject = list.getJSONObject(i);
             KuaishouSupplyChain supplyChain = new KuaishouSupplyChain();
@@ -153,6 +154,10 @@ public class RocketSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChai
                 if ("yufu".equals(ownership)) {
                     yufuSupplyChains.add(supplyChain);
                 }
+                if ("yuxiu".equals(ownership)) {
+                    yuxiuSupplyChains.add(supplyChain);
+                }
+
 
             }
 
@@ -174,6 +179,9 @@ public class RocketSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyChai
                 rocketSupplyChainMapper.replaceYufuSupplyChains(yufuSupplyChains);
             }
 
+            if (!Check.isNull(yuxiuSupplyChains)) {
+                rocketSupplyChainMapper.replaceYuXiuSupplyChains(yuxiuSupplyChains);
+            }
 
         } catch (Exception e) {
             e.printStackTrace();

+ 198 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/YuXiuSupplyChainServiceImpl.java

@@ -0,0 +1,198 @@
+package cn.com.ctop.kuaishou.modules.batch.service.impl;
+
+import cn.com.ctop.common.module.service.ISendMessageService;
+import cn.com.ctop.common.module.utils.Check;
+import cn.com.ctop.common.module.utils.HttpUtils;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaishouSupplyChain;
+import cn.com.ctop.kuaishou.modules.batch.entity.vo.ItemCheck;
+import cn.com.ctop.kuaishou.modules.batch.mapper.YuXiuSupplyChainMapper;
+import cn.com.ctop.kuaishou.modules.batch.service.IYuXiuSupplyChainService;
+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.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+@Slf4j
+public class YuXiuSupplyChainServiceImpl implements IYuXiuSupplyChainService {
+
+    private static String url = "https://cps.kwaixiaodian.com/distribute/pc/investment/order/list";
+    @Autowired
+    private ISendMessageService sendMessageService;
+    @Autowired
+    private YuXiuSupplyChainMapper yuXiuSupplyChainMapper;
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    public static void main(String[] args) {
+        System.err.println(DateUtils.tempToLongDateStr(1706112000000L));
+    }
+
+
+    @Transactional
+    @Override
+    public void getOrderList(String cookie, Integer offset, Long orderCreateTimeStart, Long orderCreateTimeEnd, Map<Long, Long> itemMap) throws Exception {
+        Thread.sleep(1000);
+        log.info("yuxiu团长抓取订单数据入参,开始时间:{},结束时间:{},数据:{}", DateUtils.tempToLongDateStr(orderCreateTimeStart), DateUtils.tempToLongDateStr(orderCreateTimeEnd), offset);
+        Map<String, Object> params = new HashMap<>();
+        if (!Check.isNull(orderCreateTimeStart)) {
+            params.put("orderCreateTimeStart", orderCreateTimeStart);
+        }
+        if (!Check.isNull(orderCreateTimeEnd)) {
+            params.put("orderCreateTimeEnd", orderCreateTimeEnd);
+        }
+        params.put("fundType", 1);
+        params.put("timeType", 1);
+        params.put("limit", 100);
+        params.put("offset", offset);
+
+        Map<String, String> headers = new HashMap<>();
+        headers.put("Cookie", cookie);
+
+        String resultStr = HttpUtils.KuaiShouttpGetRequest(url, params, headers);
+        JSONObject result = JSONObject.parseObject(resultStr);
+        if (Check.isNull(result)) {
+            log.error("快分销数据返回为空");
+            return;
+        }
+        Integer code = result.getInteger("result");
+        if (code != 1) {
+            log.info("yuxiu快分销数据返回异常:", resultStr);
+            sendMessageService.sendMessage("113dee46c7df464da78c07a985e92cd1", "yuxiucookie失效,请及时更新。媒体返回信息:" + resultStr);
+            return;
+        }
+        JSONObject dataJson = result.getJSONObject("data");
+        if (Check.isNull(dataJson)) {
+            log.error("yuxiu数据返回为data数据为空");
+            return;
+        }
+        JSONArray list = dataJson.getJSONArray("list");
+        if (Check.isNull(list)) {
+            log.error("yuxiu数据返回为list数据为空");
+            return;
+        }
+        log.info("yuxiu当前数据条数:{}", list.size());
+        List<KuaishouSupplyChain> ruixuanSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> mgsSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> rocketSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yufuSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yuxiuSupplyChains = new ArrayList<>();
+        for (int i = 0; i < list.size(); i++) {
+            JSONObject jsonObject = list.getJSONObject(i);
+            KuaishouSupplyChain supplyChain = new KuaishouSupplyChain();
+            supplyChain.setOid(jsonObject.getLong("oid"));
+            JSONObject item = jsonObject.getJSONArray("itemList").getJSONObject(0);
+            Long itemId = null;
+            if (!Check.isNull(item)) {
+                itemId = item.getLong("itemId");
+                supplyChain.setItemId(itemId);
+                supplyChain.setItemTitle(item.getString("itemTitle"));
+                supplyChain.setReservePrice(item.getLong("reservePrice"));
+                supplyChain.setImageUrl(item.getString("imageUrl"));
+            }
+            supplyChain.setOrderStatus(jsonObject.getInteger("orderStatus"));
+            supplyChain.setOrderCreateTime(jsonObject.getLong("orderCreateTime"));
+            supplyChain.setSendStatus(jsonObject.getInteger("sendStatus"));
+            supplyChain.setSettlementBizType(jsonObject.getInteger("settlementBizType"));
+            supplyChain.setSettlementBizTypeDesc(jsonObject.getString("settlementBizTypeDesc"));
+            supplyChain.setSendTime(jsonObject.getLong("sendTime"));
+            supplyChain.setRecvTime(jsonObject.getLong("recvTime"));
+            supplyChain.setSellerId(jsonObject.getLong("sellerId"));
+            supplyChain.setPromoterId(jsonObject.getLong("promoterId"));
+            supplyChain.setPromoterNickName(filterSupplement(jsonObject.getString("promoterNickName")));
+            supplyChain.setActivityId(jsonObject.getLong("activityId"));
+            supplyChain.setOrderAmount(jsonObject.getLong("orderAmount"));
+            supplyChain.setPayAmount(jsonObject.getLong("payAmount"));
+            supplyChain.setRegimentalPromotionRate(jsonObject.getLong("regimentalPromotionRate"));
+            supplyChain.setShareRate(jsonObject.getLong("shareRate"));
+            supplyChain.setBaseAmount(jsonObject.getLong("baseAmount"));
+            supplyChain.setServiceAmount(jsonObject.getLong("serviceAmount"));
+            supplyChain.setRegimentalPromotionAmount(jsonObject.getLong("regimentalPromotionAmount"));
+            supplyChain.setTotalRegimentalSettleAmount(jsonObject.getLong("totalRegimentalSettleAmount"));
+            supplyChain.setStatDate(DateUtils.tempToDateLong(jsonObject.getLong("orderCreateTime")));
+            supplyChain.setStatHour(DateUtils.getHour(jsonObject.getLong("orderCreateTime")));
+            supplyChain.setItemCommissionRate(itemMap.get(item.getLong("itemId")));
+            Criteria criteria = new Criteria();
+            criteria = Criteria.where("_id").is(itemId);
+            Query query = new Query(criteria);
+            ItemCheck itemCheck = mongoTemplate.findOne(query, ItemCheck.class);
+            if (Check.isNull(itemCheck)) {
+                yuxiuSupplyChains.add(supplyChain);
+            }
+            if (!Check.isNull(itemCheck)) {
+                String ownership = itemCheck.getOwnership();
+                if ("yuxiu".equals(ownership)) {
+                    yuxiuSupplyChains.add(supplyChain);
+                }
+                if ("ruixuan".equals(ownership)) {
+                    ruixuanSupplyChains.add(supplyChain);
+                }
+                if ("miaogousi".equals(ownership)) {
+                    mgsSupplyChains.add(supplyChain);
+                }
+                if ("rocket".equals(ownership)) {
+                    rocketSupplyChains.add(supplyChain);
+                }
+                if ("yufu".equals(ownership)) {
+                    yufuSupplyChains.add(supplyChain);
+                }
+            }
+
+        }
+        try {
+
+            if (!Check.isNull(yuxiuSupplyChains)) {
+                yuXiuSupplyChainMapper.replaceYuXiuSupplyChains(yuxiuSupplyChains);
+            }
+
+            if (!Check.isNull(yufuSupplyChains)) {
+                yuXiuSupplyChainMapper.replaceYufuSupplyChains(yufuSupplyChains);
+            }
+
+            if (!Check.isNull(ruixuanSupplyChains)) {
+                yuXiuSupplyChainMapper.replaceRuixuanSupplyChains(ruixuanSupplyChains);
+            }
+
+            if (!Check.isNull(mgsSupplyChains)) {
+                yuXiuSupplyChainMapper.replaceMgsSupplyChains(mgsSupplyChains);
+            }
+
+            if (!Check.isNull(rocketSupplyChains)) {
+                yuXiuSupplyChainMapper.replaceRocketSupplyChains(rocketSupplyChains);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        if (list.size() >= 100) {
+            getOrderList(cookie, offset + 100, orderCreateTimeStart, orderCreateTimeEnd, itemMap);
+        }
+
+    }
+
+    @Override
+    public List<JSONObject> getCookie() {
+        return yuXiuSupplyChainMapper.getCookie();
+    }
+
+
+    public static String filterSupplement(String content) {
+        StringBuilder sb = new StringBuilder();
+        for (char ch : content.toCharArray()) {
+            if (!Character.isHighSurrogate(ch) && !Character.isLowSurrogate(ch)) {
+                sb.append(ch);
+            }
+        }
+        return sb.toString();
+    }
+}

+ 8 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/YufuSupplyChainServiceImpl.java

@@ -95,6 +95,8 @@ public class YufuSupplyChainServiceImpl extends ServiceImpl<YufuSupplyChainMappe
         List<KuaishouSupplyChain> mgsSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> rocketSupplyChains = new ArrayList<>();
         List<KuaishouSupplyChain> yufuSupplyChains = new ArrayList<>();
+        List<KuaishouSupplyChain> yuxiuSupplyChains = new ArrayList<>();
+
         for (int i = 0; i < list.size(); i++) {
             JSONObject jsonObject = list.getJSONObject(i);
             KuaishouSupplyChain supplyChain = new KuaishouSupplyChain();
@@ -151,6 +153,9 @@ public class YufuSupplyChainServiceImpl extends ServiceImpl<YufuSupplyChainMappe
                 if ("rocket".equals(ownership)) {
                     rocketSupplyChains.add(supplyChain);
                 }
+                if ("yuxiu".equals(ownership)) {
+                    yuxiuSupplyChains.add(supplyChain);
+                }
             }
 
         }
@@ -170,6 +175,9 @@ public class YufuSupplyChainServiceImpl extends ServiceImpl<YufuSupplyChainMappe
             if (!Check.isNull(rocketSupplyChains)) {
                 yufuSupplyChainMapper.replaceRocketSupplyChains(rocketSupplyChains);
             }
+            if (!Check.isNull(yuxiuSupplyChains)) {
+                yufuSupplyChainMapper.replaceYuXiuSupplyChains(yuxiuSupplyChains);
+            }
         } catch (Exception e) {
             e.printStackTrace();
         }