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 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()); } /**