解决业务库的数据del_flag=1之后，统计库的维度表del_flag无法同步改字段的问题

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

@@ -106,6 +106,10 @@ public class StatsDimServiceImpl implements StatsDimService {
                     dimGrid.setGridName(updatedGrid.getGridName());
                     dimGrid.setUpdatedTime(now);
                     dimGrid.setUpdatedBy(RobotConstant.DIMENSION_ROBOT);
+                    dimGrid.setDelFlag(updatedGrid.getDelFlag());
+                    dimGrid.setAgencyId(updatedGrid.getPid());
+                    dimGrid.setAreaCode(updatedGrid.getAreaCode());
+                    dimGrid.setCustomerId(updatedGrid.getCustomerId());
                     dimGrids.add(dimGrid);
                 }
             }

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

@@ -139,9 +139,18 @@ public class DimAgencyServiceImpl extends BaseServiceImpl<DimAgencyDao, DimAgenc
             if (existsDimAgency != null) {
                 //说明是已存在的，不是新增的
                 existsDimAgency.setAgencyName(agency.getOrganizationName());
+                existsDimAgency.setAllParentName(agency.getAllParentName());
+                existsDimAgency.setCustomerId(agency.getCustomerId());
+                existsDimAgency.setLevel(agency.getLevel());
+                existsDimAgency.setPid(agency.getPid());
+                existsDimAgency.setPids(agency.getPids());
                 existsDimAgency.setUpdatedTime(initTime);
                 existsDimAgency.setUpdatedBy(RobotConstant.DIMENSION_ROBOT);
                 baseDao.updateById(existsDimAgency);
+
+                if ("1".equals(agency.getDelFlag())) {
+                    baseDao.deleteById(agency.getId());
+                }
             }
         }
 

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

@@ -146,6 +146,10 @@ public class DimCustomerServiceImpl extends BaseServiceImpl<DimCustomerDao, DimC
                 existsCustomerDim.setUpdatedTime(initTime);
                 existsCustomerDim.setAreaCode(updatedCustomer.getAreaCode());
                 baseDao.updateById(existsCustomerDim);
+
+                if ("1".equals(updatedCustomer.getDelFlag())) {
+                    baseDao.deleteById(updatedCustomer.getId());
+                }
             }
         }
 

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

@@ -132,9 +132,15 @@ public class DimDepartmentServiceImpl extends BaseServiceImpl<DimDepartmentDao,
             DimDepartmentEntity dimDepartment = baseDao.selectById(updatedDepartment.getId());
             if (dimDepartment != null) {
                 dimDepartment.setDepartmentName(updatedDepartment.getDepartmentName());
+                dimDepartment.setAgencyId(updatedDepartment.getAgencyId());
+                dimDepartment.setCustomerId(updatedDepartment.getCustomerId());
                 dimDepartment.setUpdatedBy(RobotConstant.DIMENSION_ROBOT);
                 dimDepartment.setUpdatedTime(initTime);
                 baseDao.updateById(dimDepartment);
+
+                if ("1".equals(updatedDepartment.getDelFlag())) {
+                    baseDao.deleteById(updatedDepartment.getId());
+                }
             }
         }
 

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

@@ -128,6 +128,10 @@ public class DimGridServiceImpl extends BaseServiceImpl<DimGridDao, DimGridEntit
 
         for (DimGridEntity updatedGridDim : changedGrids) {
             baseDao.updateById(updatedGridDim);
+            if ("1".equals(updatedGridDim.getDelFlag())) {
+                // 如果已经被删除了，那么这里也做删除操作
+                baseDao.deleteById(updatedGridDim.getId());
+            }
         }
 
         lastExecRecordDao.updateExecTimeBySubject(new Date(), StatsSubject.DIM_GRID);