广告账号CDC

src/main/java/com/qucheng/game/data/oldsystem/ods/AdAccountCDC.java

@@ -39,6 +39,7 @@ import javax.sql.DataSource;
 import java.time.LocalDateTime;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 /**
  * 广告账号、广告渠道、投手的 CDC
@@ -246,6 +247,9 @@ public class AdAccountCDC {
                         queryParams.put("account_id", accountId);
                         List<Map<String, Object>> agentList = mapper.queryList("t_pitcher_agent", queryParams);
                         queryParams.clear();
+                        if(agentList != null) {
+                            agentList = agentList.stream().filter(map -> StringUtils.isNotBlank(ObjectUtil.objToString(map.get("agent_key")))).collect(Collectors.toList());
+                        }
                         if (agentList == null || agentList.isEmpty()) {
                             return;
                         }