fix(tcm):生产问题处理

amos-boot-system-tzs/amos-boot-module-tcm/amos-boot-module-tcm-biz/src/main/java/com/yeejoin/amos/boot/module/tcm/biz/service/impl/EnterpriseManageServiceImpl.java

 package com.yeejoin.amos.boot.module.tcm.biz.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.yeejoin.amos.boot.biz.common.dto.CountDto;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import com.yeejoin.amos.boot.module.common.api.dao.EsBaseEnterpriseInfoDao;
+import com.yeejoin.amos.boot.module.common.api.dao.EsUserInfoDao;
+import com.yeejoin.amos.boot.module.common.api.entity.BaseEnterpriseCert;
 import com.yeejoin.amos.boot.module.common.api.entity.EsBaseEnterpriseInfo;
 import com.yeejoin.amos.boot.module.common.api.entity.TzsDataRefreshMessage;
+import com.yeejoin.amos.boot.module.common.api.mapper.BaseEnterpriseCertMapper;
 import com.yeejoin.amos.boot.module.common.biz.refresh.DataRefreshEvent;
+import com.yeejoin.amos.boot.module.tcm.api.entity.BaseUnitLicence;
 import com.yeejoin.amos.boot.module.tcm.api.entity.TzBaseEnterpriseInfo;
+import com.yeejoin.amos.boot.module.tcm.api.entity.TzsBaseIndividuality;
+import com.yeejoin.amos.boot.module.tcm.api.entity.TzsBaseInstitution;
+import com.yeejoin.amos.boot.module.tcm.api.mapper.BaseUnitLicenceMapper;
+import com.yeejoin.amos.boot.module.tcm.api.mapper.TzsBaseIndividualityMapper;
+import com.yeejoin.amos.boot.module.tcm.api.mapper.TzsBaseInstitutionMapper;
 import com.yeejoin.amos.boot.module.tcm.biz.refresh.handler.EnterpriseRefreshHandler;
+import com.yeejoin.amos.boot.module.tcm.flc.api.entity.RegUnitInfo;
+import com.yeejoin.amos.boot.module.tcm.flc.api.mapper.RegUnitInfoMapper;
 import com.yeejoin.amos.component.feign.utils.FeignUtil;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
@@ -46,6 +58,21 @@ public class EnterpriseManageServiceImpl {
 
     private final EnterpriseRefreshHandler refreshHandler;
 
+    private final EsUserInfoDao esUserInfoDao;
+
+    private final TzsBaseInstitutionMapper tzsBaseInstitutionMapper;
+
+    private final TzsBaseIndividualityMapper tzsBaseIndividualityMapper;
+
+    private final BaseEnterpriseCertMapper enterpriseCertMapper;
+
+    private final BaseUnitLicenceMapper unitLicenceMapper;
+
+    private final RegUnitInfoMapper regUnitInfoMapper;
+
+
+
+
     /**
      * 批量删除企业
      *
@@ -65,10 +92,19 @@ public class EnterpriseManageServiceImpl {
             this.deleteAmosUser(e);
             this.deleteAmosCompany(e);
             this.deleteEsEnterpriseInfo(e);
+            this.deleteEsUser(e);
         });
         return enterpriseInfos;
     }
 
+    /**
+     *  冗余删除es的人员（已经前置校验数据库没人、没设备才能删除，目的防止人员的数据库和es人员索引的人员不一致）
+     * @param e 企业
+     */
+    private void deleteEsUser(TzBaseEnterpriseInfo e) {
+        esUserInfoDao.deleteAllByUnitCode(e.getUseCode());
+    }
+
     private void deleteEsEnterpriseInfo(TzBaseEnterpriseInfo e) {
         Optional<EsBaseEnterpriseInfo> op = esBaseEnterpriseInfoDao.findById(e.getSequenceNbr() + "");
         op.ifPresent(v -> {
@@ -215,6 +251,18 @@ public class EnterpriseManageServiceImpl {
     }
 
     private void deleteEnterprise(TzBaseEnterpriseInfo e) {
+        // 删除关系表
+        tzsBaseInstitutionMapper.delete(new LambdaQueryWrapper<TzsBaseInstitution>().eq(TzsBaseInstitution::getEnterpriseId, e.getSequenceNbr()));
+
+        tzsBaseIndividualityMapper.delete(new LambdaQueryWrapper<TzsBaseIndividuality>().eq(TzsBaseIndividuality::getEnterpriseId, e.getSequenceNbr()));
+
+        enterpriseCertMapper.delete(new LambdaQueryWrapper<BaseEnterpriseCert>().eq(BaseEnterpriseCert::getUnitCode, e.getUseUnitCode()));
+
+        unitLicenceMapper.delete(new LambdaQueryWrapper<BaseUnitLicence>().eq(BaseUnitLicence::getUnitCode, e.getUseUnitCode()));
+
+        regUnitInfoMapper.delete(new LambdaQueryWrapper<RegUnitInfo>().eq(RegUnitInfo::getUnitCode, e.getUseUnitCode()));
+
+        // 删除主表
         enterpriseInfoService.removeById(e.getSequenceNbr());
     }