2023年9月15日16:36:13 解决并发上报直播数据问题导致旧数据覆盖新数据

王明元
1 parent 31609a68
Showing 1 changed file with 1 additions and 0 deletions
src/main/java/cn/fw/freya/service/CrawlBizService.java
@@ -275,6 +275,7 @@ public class CrawlBizService {
         String accountNo = account.getAccountNo();
         AccountTypeEnum typeEnum = AccountTypeEnum.getEnumByValue(type);
         CrawlStrategy crawlStrategy = crawlStrategyMap.get(typeEnum);
+        LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(10));// 线程挂起10秒, 防止并发上报, 旧数据覆盖新数据
         List<LivePool> yesterdayLiveMsg = crawlStrategy.getYesterdayLiveMsg(accountNo);// 获取昨日直播信息
         boolean reportLive = this.doReportLive(account, yesterdayLiveMsg);
         if (!reportLive) {