程序调整优化

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/DataReportingServiceImpl.java

@@ -100,6 +100,9 @@ public class DataReportingServiceImpl implements DataReportingService {
 	public List<GridUserInfoDTO> getStaffBaseInfo(StaffBaseInfoFormDTO formDTO) {
 		//1.查询工作人员所属网格信息
 		List<GridUserInfoDTO> resultList = customerGridService.getStaffGrid(formDTO);
+		if (CollectionUtils.isEmpty(resultList)) {
+			return new ArrayList<>();
+		}
 
 		//2.查询工作人员基础信息
 		List<CustomerStaffDTO> staffDTOList = userService.getStaffBaseInfo(formDTO);

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/org/CustomerGridDao.xml

@@ -181,7 +181,7 @@
             cg.`code` code
         FROM
             customer_staff_grid csg
-        INNER JOIN customer_grid cg ON csg.grid_id = cg.id
+        INNER JOIN customer_grid cg ON csg.grid_id = cg.id AND cg.`CODE` != '' AND cg.`CODE` is not null
         WHERE
             csg.del_flag = '0'
         AND csg.customer_id = #{customerId}

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/GridstaffInfoPingyinServiceImpl.java

@@ -111,6 +111,9 @@ public class GridstaffInfoPingyinServiceImpl extends BaseServiceImpl<GridstaffIn
         if (!result.success()) {
             throw new RenException(result.getInternalMsg());
         }
+        if (CollectionUtils.isEmpty(result.getData())) {
+            return;
+        }
 
         //2.中间库新增/修改数据【基本一个人一条数据，程序按批量处理】
         result.getData().forEach(r -> {