From 55cac2c369fb78547067d7b9b3bf3f40b68e72c7 Mon Sep 17 00:00:00 2001
From: lzxry <39932950+lzxry@users.noreply.github.com>
Date: Wed, 12 May 2021 10:19:59 +0800
Subject: [PATCH] bugfix

---
 src/main/java/track/task/TrackingFlowTask.java |  9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/main/java/track/task/TrackingFlowTask.java b/src/main/java/track/task/TrackingFlowTask.java
index e9bd77e..1f05290 100644
--- a/src/main/java/track/task/TrackingFlowTask.java
+++ b/src/main/java/track/task/TrackingFlowTask.java
@@ -7,6 +7,7 @@ import common.repository.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
 import tkio.model.Account;
 import tkio.repository.AccountRepository;
 import tkio.repository.AppRepository;
@@ -208,7 +209,8 @@ public class TrackingFlowTask {
             //查询用户下所有appkey
             Account account = accountRepository.findByEmail(email);
             if(account==null||account.getRootParent()==null){
-                logger.info("【单日流量同步】用户不存在:{}",email);
+                logger.warn("【单日流量同步】用户不存在:{}",email);
+                continue;
             }
             List<Account> accountList = accountRepository.findByRootParent(account.getRootParent());
             List<Long> idList = new ArrayList<>();
@@ -218,7 +220,10 @@ public class TrackingFlowTask {
             List<String> appkeys = appRepository.findAppkeysNotDebug(idList);
             String appkeyStr = String.join("','", appkeys);
             appkeyStr = "'" + appkeyStr + "'";
-
+            if(CollectionUtils.isEmpty(appkeys)){
+                logger.warn("【单日流量同步】该用户没有appkey:{}",email);
+                continue;
+            }
             //BigInteger clickNum = accountFlowRestrictService.getTotalNum(yesterday, yesterday, appkeyStr, "account_track_flow_restrict", "click_sum");
             BigInteger clickNum = flowService.getFlowByAccount(yesterday,yesterday,appkeys);
             if (clickNum != null && clickNum.longValue() > 0) {
--
libgit2 0.27.1