From 343edc2d3c193c49f3f99f3abb1e351162da00ae Mon Sep 17 00:00:00 2001
From: 王明元 <97082371@qq.com>
Date: Thu, 30 Jun 2022 20:24:16 +0800
Subject: [PATCH] 2022年6月30日20:22:48 防止快手账号登录失效, 无限循环获取sig3信息

---
 src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java | 4 ++++
 1 file changed, 4 insertions(+), 0 deletions(-)

diff --git a/src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java b/src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java
index 8376f0f..5569a01 100644
--- a/src/main/java/cn/fw/freya/service/crawl/impl/KuaiShouCrawl.java
+++ b/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());
     }
 
     /**
--
libgit2 0.22.2