yumeng 7 місяців тому
батько
коміт
87c8911d5f

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

@@ -328,6 +328,28 @@ public class settlementJob {
             String cookie = jsonObject.getString("cookie");
             ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "yufu", date);
         }
+
+
+
+        Thread.sleep(5 * 1000);
+        List<JSONObject> yuxiuCookies = ikuaishouSupplyChainService.getyuxiuCiikie();
+        for (int i = 0; i < yuxiuCookies.size(); i++) {
+            JSONObject jsonObject = yuxiuCookies.get(i);
+            String cookie = jsonObject.getString("cookie");
+            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "yuxiu", date);
+        }
+
+
+        Thread.sleep(5 * 1000);
+        List<JSONObject> zhishuiCookies = ikuaishouSupplyChainService.getZhiShuiCiikie();
+        for (int i = 0; i < zhishuiCookies.size(); i++) {
+            JSONObject jsonObject = zhishuiCookies.get(i);
+            String cookie = jsonObject.getString("cookie");
+            ikuaishouSupplyChainService.getSellerInfo(cookie, 0, "zhishui", date);
+        }
+
+
+
     }
 
 

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

@@ -119,4 +119,12 @@ public interface KuaishouSupplyChainMapper extends BaseMapper<KuaishouSupplyChai
     void deleteZhiShuiItemBindCourtshipByDate(@Param("date") Long date);
 
     void cleanZhiShuiItemBindCourtship(@Param("date") Long date);
+
+    void replaceYuXiuSellerInfo(@Param("adds") List<JSONObject> adds);
+
+    void replaceZhishuiSellerInfo(@Param("adds") List<JSONObject> adds);
+
+    List<JSONObject> getZhiShuiCiikie();
+
+    List<JSONObject> getyuxiuCiikie();
 }

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

@@ -663,6 +663,34 @@
           AND t1.media_id = 2
         GROUP BY t1.item_id
     </insert>
+    <insert id="replaceYuXiuSellerInfo" >
+        replace into yuxiu.kuaishou_seller_info(
+        seller_id,
+        seller_name
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.sellerId},
+            #{add.sellerName}
+            )
+        </foreach>
+
+
+    </insert>
+    <insert id="replaceZhishuiSellerInfo">
+        replace into zhishui.kuaishou_seller_info(
+        seller_id,
+        seller_name
+        )
+        values
+        <foreach collection="adds" item="add" separator=",">
+            (
+            #{add.sellerId},
+            #{add.sellerName}
+            )
+        </foreach>
+    </insert>
     <delete id="deletePromoterBindChannelByDate" parameterType="java.lang.Long">
         delete from ruixuan.promoter_bind_channel_date where stat_date = #{date}
     </delete>
@@ -934,5 +962,14 @@ group by t1.promoter_id;
         WHERE stat_date = #{date}
         GROUP BY activity_id;
     </select>
+    <select id="getZhiShuiCiikie" resultType="com.alibaba.fastjson.JSONObject">
+        select id, cookie
+        from zhishui.kuaishou_supply_chain_cookie
+    </select>
+    <select id="getyuxiuCiikie" resultType="com.alibaba.fastjson.JSONObject">
+        SELECT id, cookie
+        FROM yuxiu.kuaishou_supply_chain_cookie
+
+    </select>
 
 </mapper>

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

@@ -96,4 +96,8 @@ public interface IKuaishouSupplyChainService extends IService<KuaishouSupplyChai
     void deleteZhiShuiItemBindCourtshipByDate(Long date);
 
     void cleanZhiShuiItemBindCourtship(Long date);
+
+    List<JSONObject> getZhiShuiCiikie();
+
+    List<JSONObject> getyuxiuCiikie();
 }

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

@@ -364,6 +364,14 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
                     supplyChainMapper.replaceYUfuSellerInfo(adds);
                 }
 
+                if ("yuxiu".equals(db)) {
+                    supplyChainMapper.replaceYuXiuSellerInfo(adds);
+                }
+                if ("zhishui".equals(db)) {
+                    supplyChainMapper.replaceZhishuiSellerInfo(adds);
+                }
+
+
                 if (adds.size() >= 20) {
                     getSellerInfo(cookie, offset + 20, db, date);
                 }
@@ -459,6 +467,16 @@ public class KuaishouSupplyChainServiceImpl extends ServiceImpl<KuaishouSupplyCh
         supplyChainMapper.cleanZhiShuiItemBindCourtship(date);
     }
 
+    @Override
+    public List<JSONObject> getZhiShuiCiikie() {
+        return supplyChainMapper.getZhiShuiCiikie();
+    }
+
+    @Override
+    public List<JSONObject> getyuxiuCiikie() {
+        return supplyChainMapper.getyuxiuCiikie();
+    }
+
 
     @Override
     public List<JSONObject> getCookie() {