楼长单元长=》楼栋表

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CommunityBuildingManagerServiceImpl.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.constant.StrConstant;
 import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.EpmetException;
@@ -14,17 +15,20 @@ import com.epmet.commons.tools.utils.EpmetRequestHolder;
 import com.epmet.commons.tools.utils.PidUtils;
 import com.epmet.commons.tools.utils.SpringContextUtils;
 import com.epmet.dao.CommunityBuildingManagerDao;
+import com.epmet.dao.IcBuildingDao;
 import com.epmet.dto.CustomerGridDTO;
 import com.epmet.dto.form.yt.CommunityBuildingManagerPageFormDTO;
 import com.epmet.dto.result.CommunityBuildingManagerDTO;
 import com.epmet.dto.result.yt.CommunityBuildingManagerResultDTO;
 import com.epmet.entity.CommunityBuildingManagerEntity;
+import com.epmet.entity.IcBuildingEntity;
 import com.epmet.service.CommunityBuildingManagerService;
 import com.epmet.service.CustomerGridService;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -43,6 +47,8 @@ import java.util.List;
 @Slf4j
 @Service
 public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<CommunityBuildingManagerDao, CommunityBuildingManagerEntity> implements CommunityBuildingManagerService {
+    @Autowired
+    private IcBuildingDao icBuildingDao;
 
     /**
      * 列表分页查询
@@ -105,7 +111,7 @@ public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<Communi
 
     /**
      * 新增楼长/单元长
-     * todo: 同步到具体的楼栋表
+     * 同步到具体的楼栋表
      *
      * @param addFormDto
      * @return
@@ -119,6 +125,16 @@ public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<Communi
         CustomerGridDTO gridDTO = SpringContextUtils.getBean(CustomerGridService.class).get(addFormDto.getGridId());
         entity.setOrgIdPath(PidUtils.convertPid2OrgIdPath(gridDTO.getId(), gridDTO.getPids()));
         insert(entity);
+        // 清空楼栋表的楼长4列信息
+        LambdaUpdateWrapper<IcBuildingEntity> buildingUpdate = new LambdaUpdateWrapper<>();
+        buildingUpdate.eq(IcBuildingEntity::getId, entity.getBuildingId())
+                .set(IcBuildingEntity::getBuildingLeaderName, entity.getName())
+                .set(IcBuildingEntity::getBuildingLeaderMobile, entity.getPhone())
+                .set(IcBuildingEntity::getBuildingLeaderIdCard, entity.getIdCard())
+                .set(IcBuildingEntity::getBuildingLeaderType, entity.getType())
+                .set(IcBuildingEntity::getUpdatedBy, EpmetRequestHolder.getLoginUserId())
+                .set(IcBuildingEntity::getUpdatedTime, new Date());
+        icBuildingDao.update(null, buildingUpdate);
     }
 
     private void checkUnqiue(String type, String buildingId, String unitId, String id) {
@@ -136,7 +152,7 @@ public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<Communi
 
     /**
      * 编辑楼长/单元长
-     * todo: 同步到具体的楼栋
+     * 同步到具体的楼栋
      *
      * @param updateFormDto
      * @return
@@ -149,11 +165,21 @@ public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<Communi
         CustomerGridDTO gridDTO = SpringContextUtils.getBean(CustomerGridService.class).get(updateFormDto.getGridId());
         entity.setOrgIdPath(PidUtils.convertPid2OrgIdPath(gridDTO.getId(), gridDTO.getPids()));
         updateById(entity);
+        // 清空楼栋表的楼长4列信息
+        LambdaUpdateWrapper<IcBuildingEntity> buildingUpdate = new LambdaUpdateWrapper<>();
+        buildingUpdate.eq(IcBuildingEntity::getId, updateFormDto.getBuildingId())
+                .set(IcBuildingEntity::getBuildingLeaderName, updateFormDto.getName())
+                .set(IcBuildingEntity::getBuildingLeaderMobile, updateFormDto.getPhone())
+                .set(IcBuildingEntity::getBuildingLeaderIdCard, updateFormDto.getIdCard())
+                .set(IcBuildingEntity::getBuildingLeaderType, updateFormDto.getType())
+                .set(IcBuildingEntity::getUpdatedBy, EpmetRequestHolder.getLoginUserId())
+                .set(IcBuildingEntity::getUpdatedTime, new Date());
+        icBuildingDao.update(null, buildingUpdate);
     }
 
     /**
      * 批量删除楼长/单元长
-     * todo: 同时清空楼栋表里的信息
+     * 同时清空楼栋表里的信息
      *
      * @param ids
      * @return
@@ -163,13 +189,27 @@ public class CommunityBuildingManagerServiceImpl extends BaseServiceImpl<Communi
     public void delete(List<String> ids) {
         Date now = new Date();
         ids.forEach(id -> {
+            CommunityBuildingManagerEntity origin = baseDao.selectById(id);
+            if (null != origin) {
                 LambdaUpdateWrapper<CommunityBuildingManagerEntity> updateWrapper = new LambdaUpdateWrapper<>();
                 updateWrapper.eq(CommunityBuildingManagerEntity::getId, id)
                         .set(CommunityBuildingManagerEntity::getDelFlag, NumConstant.ONE_STR)
                         .set(CommunityBuildingManagerEntity::getUpdatedBy, EpmetRequestHolder.getLoginUserId())
                         .set(CommunityBuildingManagerEntity::getUpdatedTime, now);
                 baseDao.update(null, updateWrapper);
-            // todo
+                if (StringUtils.isNotBlank(origin.getBuildingId())) {
+                    // 清空楼栋表的楼长4列信息
+                    LambdaUpdateWrapper<IcBuildingEntity> buildingUpdate = new LambdaUpdateWrapper<>();
+                    buildingUpdate.eq(IcBuildingEntity::getId, origin.getBuildingId())
+                            .set(IcBuildingEntity::getBuildingLeaderName, StrConstant.EPMETY_STR)
+                            .set(IcBuildingEntity::getBuildingLeaderMobile, StrConstant.EPMETY_STR)
+                            .set(IcBuildingEntity::getBuildingLeaderIdCard, StrConstant.EPMETY_STR)
+                            .set(IcBuildingEntity::getBuildingLeaderType, StrConstant.EPMETY_STR)
+                            .set(IcBuildingEntity::getUpdatedBy, EpmetRequestHolder.getLoginUserId())
+                            .set(IcBuildingEntity::getUpdatedTime, now);
+                    icBuildingDao.update(null, buildingUpdate);
+                }
+            }
         });
     }