2022年6月30日20:22:48 防止快手账号登录失效, 无限循环获取sig3信息

王明元
1 parent a989441e
Showing 1 changed file with 4 additions and 0 deletions
src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java
@@ -15,6 +15,7 @@ import cn.fw.freya.model.data.pool.VideoPool;
 import cn.fw.freya.model.dto.rpc.ReportAccountDto;
 import cn.fw.freya.service.crawl.CrawlStrategy;
 import cn.fw.freya.service.data.AccountService;
+import cn.fw.freya.service.rpc.AccountRpcService;
 import cn.fw.freya.utils.DateUtil;
 import cn.fw.freya.utils.JsonUtils;
 import cn.fw.freya.utils.PublicUtil;
@@ -83,6 +84,7 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
     private final AccountService accountService;
     private final String playbackBaseUrl = "https://live.kuaishou.com/playback/";
     private final ConcurrentHashMap<String, String> sig3Map = new ConcurrentHashMap<>();
+    private final AccountRpcService accountRpcService;
     @Resource(name = "wmyThreadPool")
     private ThreadPoolExecutor threadPoolExecutor;
@@ -117,6 +119,8 @@ public class KuaiShouCrawl implements CrawlStrategy, SmartLifecycle {
         final String ns_sig3 = this.getNS_sig3(accountNo, dataType, true);
         if (Objects.nonNull(ns_sig3))
             sig3Map.put(key, ns_sig3);
+        else
+            accountRpcService.pushExpireAccount(accountNo, this.getType().getValue());
     }
     /**