话题 网格为空时 继续下次

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/IssueExtractServiceImpl.java

@@ -121,7 +121,7 @@ public class IssueExtractServiceImpl implements IssueExtractService {
             });
         });
         // 5. 查询pid
-        List<String> agencyIds = result.stream().map(r -> r.getAgencyId()).distinct().collect(Collectors.toList());
+        List<String> agencyIds = result.stream().map(IssueMainDailyFormDTO::getAgencyId).distinct().collect(Collectors.toList());
         List<AgencyInfoResultDTO> agencyInfoList = dimAgencyDao.selectAgencyInfo(agencyIds);
         if (CollectionUtils.isEmpty(agencyInfoList)){
             throw new RenException(ExtractConstant.PARENT_AGENCY_ID_LIST);
@@ -138,7 +138,9 @@ public class IssueExtractServiceImpl implements IssueExtractService {
                 }
             });
         });
-        delAndInsertMain(customerId,dateId,result);
+        //过滤掉pids为空的数据
+        List<IssueMainDailyFormDTO> collect = result.stream().filter(o -> StringUtils.isNotBlank(o.getPids())).collect(Collectors.toList());
+        delAndInsertMain(customerId,dateId,collect);
         return true;
     }