瀏覽代碼

达人数据更新

zhaoxian 1 年之前
父節點
當前提交
8f6b1bda6d
共有 1 個文件被更改,包括 64 次插入68 次删除
  1. 64 68
      ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouPromoterServiceImpl.java

+ 64 - 68
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouPromoterServiceImpl.java

@@ -328,7 +328,6 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
         return result;
     }
 
-
     /**
      * 同步更新数据
      */
@@ -352,7 +351,8 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
             String content = "";
             if ("2".equals(mediaId)) {
                 content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-                Thread.sleep(3000);
+                //睡眠: 随机数 3~25s
+                Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
             } else {
                 content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
                 Thread.sleep(60000);
@@ -413,13 +413,15 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                 redisUtil.set(key, "1", 60 * 60 * 24);
             }
 
+            //睡眠: 随机数 3~30s
+            Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
+
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
             param.put("promoterId", promoterId);
             param.put("mediaId", mediaId);
             Long startTime = System.currentTimeMillis();
             String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-            Thread.sleep(3000);
 
             JSONObject result = JSONObject.parseObject(content);
             if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
@@ -465,13 +467,15 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                 redisUtil.set(key, "1", 60 * 60 * 24);
             }
 
+            //睡眠: 随机数 3~30s
+            Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
+
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
             param.put("promoterId", promoterId);
             param.put("mediaId", mediaId);
             Long startTime = System.currentTimeMillis();
             String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-            Thread.sleep(3000);
 
             JSONObject result = JSONObject.parseObject(content);
             if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
@@ -518,14 +522,15 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                 redisUtil.set(key, "1", 60 * 60 * 24);
             }
 
+            //睡眠: 随机数 3~30s
+            Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
+
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
             param.put("promoterId", promoterId);
             param.put("mediaId", mediaId);
             Long startTime = System.currentTimeMillis();
             String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-            Thread.sleep(3000);
-
             JSONObject result = JSONObject.parseObject(content);
             if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
                 log.info("--------------------Rocket达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
@@ -570,14 +575,15 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                 redisUtil.set(key, "1", 60 * 60 * 24);
             }
 
+            //睡眠: 随机数 3~30s
+            Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
+
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
             param.put("promoterId", promoterId);
             param.put("mediaId", mediaId);
             Long startTime = System.currentTimeMillis();
             String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-            Thread.sleep(3000);
-
             JSONObject result = JSONObject.parseObject(content);
             if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
                 log.info("--------------------Yufu达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
@@ -621,14 +627,15 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
                 redisUtil.set(key, "1", 60 * 60 * 24);
             }
 
+            //睡眠: 随机数 3~30s
+            Thread.sleep(1000 * ((int) (3 + Math.random() * 27)));
+
             /*更新达人数据*/
             Map<String, Object> param = new HashMap<>();
             param.put("promoterId", promoterId);
             param.put("mediaId", mediaId);
             Long startTime = System.currentTimeMillis();
             String content = HttpUtil.httpPostRequest(startIpPath + "promoterInfo/getPromoterId", param, null);
-            Thread.sleep(3000);
-
             JSONObject result = JSONObject.parseObject(content);
             if (Check.isNotNull(result) && Check.isNotNull(result.getString("promoterNickName"))) {
                 log.info("--------------------Yuxiu达人更新\n【入参】:{}\n【返回结果】:{}", param, result.toJSONString());
@@ -697,7 +704,6 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
 
     @Override
     public JSONObject addAuth(Long promoterId) {
-
         String cookie = kuaishouPromoterMapper.getAuthCookie();
         Map<String, Object> param = new HashMap<>();
         param.put("userId", promoterId);
@@ -712,125 +718,115 @@ public class KuaishouPromoterServiceImpl implements IKuaishouPromoterService {
         return jsonObject;
     }
 
+    static ExecutorService editPromoterService = Executors.newFixedThreadPool(10);
+
     @Override
     public Result supplementInfo() {
+        List<String> promoters = new ArrayList<>();
         List<KuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    editPromoter(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() + "】"));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId() + "[" + ("2".equals(kuaishouPromoter.getMediaId()) ? "快手" : "头条") + "]"));
+        }
         promoters.add(supplementInfo3());
         promoters.add(miaogousiInfo());
         promoters.add(rocketInfo());
         promoters.add(yufuInfo());
-        return Result.success("共计" + list.size() + "条,数据补充中...", promoters);
+        promoters.add(yuxiuInfo());
+        return Result.success("达人数据更新 -------------<睿选>共计:" + list.size() + "条", promoters);
     }
 
     //骄阳补全
     public String supplementInfo3() {
+        List<String> promoters = new ArrayList<>();
         List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getFailInfo3();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editPromoter3(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    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()));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
+        }
         return "-------------骄阳共计" + list.size() + "条,达人id: " + promoters.toString();
     }
 
     //miaogousi
     public String miaogousiInfo() {
+        List<String> promoters = new ArrayList<>();
         List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getMiaogousiInfoFailInfo();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editMiaogousiPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    editMiaogousiPromoter(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()));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
+        }
         return "-------------miaogousi共计" + list.size() + "条,达人id: " + promoters.toString();
     }
 
     //rocket
     public String rocketInfo() {
+        List<String> promoters = new ArrayList<>();
         List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getRocketFailInfo();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editRocketPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    editRocketPromoter(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()));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
+        }
         return "-------------rocket共计" + list.size() + "条,达人id: " + promoters.toString();
     }
 
     //yufu
     public String yufuInfo() {
+        List<String> promoters = new ArrayList<>();
         List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getYufuFailInfo();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editYufuPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    editYufuPromoter(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()));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
+        }
         return "-------------yufu共计" + list.size() + "条,达人id: " + promoters.toString();
     }
 
-      //yuxiu
+    //yuxiu
     public String yuxiuInfo() {
+        List<String> promoters = new ArrayList<>();
         List<JYKuaishouPromoter> list = kuaishouPromoterMapper.getYuxiuFailInfo();
-        Thread thread = new Thread() {
-            @Override
-            public void run() {
+        if (!Check.isNull(list)) {
+            list.forEach(kuaishouPromoter -> editPromoterService.submit(() -> {
                 try {
-                    list.forEach(kuaishouPromoter -> editYuxiuPromoter(kuaishouPromoter.getId(), kuaishouPromoter.getMediaId(), kuaishouPromoter.getPromoterId(), false));
+                    editYuxiuPromoter(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()));
+            }));
+            list.forEach(kuaishouPromoter -> promoters.add(kuaishouPromoter.getPromoterId()));
+        }
         return "-------------yuxiu共计" + list.size() + "条,达人id: " + promoters.toString();
     }
 
-
     @Override
     public int addFollowUpRecords(JSONObject result) {
         return kuaishouPromoterMapper.addFollowUpRecords(result);