Browse Source

补全骄阳数据

zhaoxian 1 year ago
parent
commit
0d5cc5c3ef

+ 2 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/mapper/KuaishouPromoterMapper.java

@@ -123,4 +123,6 @@ public interface KuaishouPromoterMapper {
     JYKuaishouPromoter selectKuaishouPromoterById3(Long id);
 
     void deleteKuaishouPromoterById3(Long id);
+
+    List<JYKuaishouPromoter> getFailInfo3();
 }

+ 22 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouPromoterServiceImpl.java

@@ -452,9 +452,31 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
         thread.start();
         List<String> promoters = new ArrayList<>();
         list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId() + "【" + kuaishouPromoter.getMediaId() + "】"));
+        String jyMsg = supplementInfo3();
+        promoters.add("\n" + jyMsg);
         return Result.success("共计" + list.size() + "条,数据补充中...", promoters);
     }
 
+    //骄阳补全
+    public String supplementInfo3() {
+        List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo3();
+        Thread thread = new Thread() {
+            @Override
+            public void run() {
+                try {
+                    list.forEach(kuaishouPromoter -> editPromoter3(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        };
+        thread.start();
+        List<String> promoters = new ArrayList<>();
+        list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId() + "【" + kuaishouPromoter.getMediaId() + "】"));
+        return "骄阳共计" + list.size() + "条,达人IDS: " + promoters.toString();
+    }
+
+
     @Override
     public int addFollowUpRecords(JSONObject result) {
         return kuaishouPromoterMapper.addFollowUpRecords(result);

+ 27 - 0
ruixuan-live/src/main/resources/mapper/isc/KuaishouPromoterMapper.xml

@@ -305,6 +305,33 @@
         AND state =1
     </select>
 
+
+    <select id="getFailInfo3" resultMap="KuaishouPromoterResult">
+        select id,
+               media_id,
+               user_id,
+               user_name,
+               promoter_id,
+               promoter_nick_name,
+               `state`,
+               province,
+               commission_requirement,
+               category_requirement,
+               promoter_url,
+               phone,
+               consignee,
+               promoter_address,
+               total_sale,
+               fans_number,
+               avg_video_sales,
+               video_sales,
+               create_time,
+               update_time
+        from jy_kuaishou_promoter
+        where (promoter_nick_name = '' or promoter_nick_name is null)
+          AND state = 1
+    </select>
+
     <select id="getBoundPromoterRoleKey" resultType="com.alibaba.fastjson.JSONObject">
         SELECT t1.user_id,
                t3.role_key,