From 560db6a1036201e7e2ac50f34ad4a418f17eaba6 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期一, 06 六月 2022 11:01:11 +0800
Subject: [PATCH] bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngVillageServiceImpl.java |   51 ++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 38 insertions(+), 13 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngVillageServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngVillageServiceImpl.java
index 392e510..edd0d31 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngVillageServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngVillageServiceImpl.java
@@ -6,6 +6,8 @@
 
 import javax.annotation.Resource;
 
+import com.panzhihua.service_community.dao.*;
+import com.panzhihua.service_community.model.dos.*;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 
@@ -25,14 +27,6 @@
 import com.panzhihua.common.model.vos.grid.ComMngVillageBuildingVO;
 import com.panzhihua.common.utlis.Snowflake;
 import com.panzhihua.common.utlis.StringUtils;
-import com.panzhihua.service_community.dao.ComActDAO;
-import com.panzhihua.service_community.dao.ComActVillageDAO;
-import com.panzhihua.service_community.dao.ComMngPopulationDAO;
-import com.panzhihua.service_community.dao.ComMngPopulationHouseDAO;
-import com.panzhihua.service_community.model.dos.ComActDO;
-import com.panzhihua.service_community.model.dos.ComMngPopulationDO;
-import com.panzhihua.service_community.model.dos.ComMngPopulationHouseDO;
-import com.panzhihua.service_community.model.dos.ComMngVillageDO;
 import com.panzhihua.service_community.service.ComMngVillageService;
 
 /**
@@ -50,6 +44,8 @@
     ComMngPopulationDAO populationDAO;
     @Resource
     private ComMngPopulationHouseDAO comMngPopulationHouseDAO;
+    @Resource
+    private ComMngBuildingDAO comMngBuildingDAO;
 
     @Override
     public R addComActVillage(ComMngVillageVO comMngVillageVO) {
@@ -85,11 +81,13 @@
     public R listComActVillage(ComMngVillageVO comMngVillageVO) {
         List<ComMngVillageDO> vos = Lists.newArrayList();
         LambdaQueryWrapper<ComMngVillageDO> param = new QueryWrapper<ComMngVillageDO>().lambda();
-        param.eq(ComMngVillageDO::getAlley, comMngVillageVO.getAlley());
+        if(StringUtils.isNotEmpty(comMngVillageVO.getName())){
+            param.like(ComMngVillageDO::getName, comMngVillageVO.getName());
+        }
         param.eq(ComMngVillageDO::getCommunityId, comMngVillageVO.getCommunityId());
         List<ComMngVillageDO> comMngVillageDOS = comActVillageDAO.selectList(param);
-        BeanUtils.copyProperties(vos, comMngVillageDOS);
-        return R.ok(vos);
+        BeanUtils.copyProperties(comMngVillageDOS, vos);
+        return R.ok(comMngVillageDOS);
     }
 
     @Override
@@ -218,6 +216,7 @@
             path.append(vo.getAlley()).append(">").append(vo.getHouseNum()).append(">").append(vo.getGroupAt());
             comMngVillageDO.setPath(path.toString());
             comMngVillageDO.setUpdateAt(new Date());
+            comMngVillageDO.setName(comMngVillageDO.getGroupAt());
             comMngVillageDOS.add(comMngVillageDO);
         });
         this.saveBatch(comMngVillageDOS);
@@ -230,12 +229,38 @@
         if (comMngVillageDO == null) {
             return R.fail("id有误!");
         }
-        BeanUtils.copyProperties(comMngVillageVO, comMngVillageDO);
-        comMngVillageDO.setName(comMngVillageVO.getGroupAt());
+        if(!comMngVillageVO.getAlley().equals(comMngVillageDO.getAlley())&&!comMngVillageVO.getHouseNum().equals(comMngVillageDO.getHouseNum())){
+            Integer count= this.baseMapper.selectCount(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getAlley,comMngVillageVO.getAlley()).eq(ComMngVillageDO::getHouseNum,comMngVillageVO.getHouseNum()));
+            if(count>0){
+                return R.fail("街路巷已存在");
+            }
+            //历史人口数据处理
+            List<ComMngPopulationDO> populationDOS=this.populationDAO.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getVillageId,villageId));
+            if(!populationDOS.isEmpty()){
+                populationDOS.forEach(comMngPopulationDO -> {
+                    comMngPopulationDO.setRoad(comMngVillageVO.getAlley());
+                    comMngPopulationDO.setDoorNo(comMngVillageVO.getHouseNum());
+                    comMngPopulationDO.setAddress(comMngPopulationDO.getAddress().replace(comMngVillageDO.getAlley()+comMngVillageDO.getHouseNum(),comMngVillageVO.getAlley()+comMngVillageVO.getHouseNum()));
+                    this.populationDAO.updateById(comMngPopulationDO);
+                });
+            }
+            //历史房屋数据处理
+            List<ComMngPopulationHouseDO> comMngPopulationHouseDOS=this.comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getVillageId,comMngVillageVO.getVillageId()));
+            if(!comMngPopulationHouseDOS.isEmpty()){
+                comMngPopulationHouseDOS.forEach(comMngPopulationHouseDO -> {
+                    comMngPopulationHouseDO.setAlley(comMngVillageVO.getAlley());
+                    comMngPopulationHouseDO.setHouseNum(comMngVillageVO.getHouseNum());
+                    comMngPopulationHouseDO.setAddress(comMngPopulationHouseDO.getAddress().replace(comMngVillageDO.getAlley()+comMngVillageDO.getHouseNum(),comMngVillageVO.getAlley()+comMngVillageVO.getHouseNum()));
+                    this.comMngPopulationHouseDAO.updateById(comMngPopulationHouseDO);
+                });
+            }
+        }
         ComActDO comActDO = comActDAO.selectById(comMngVillageDO.getCommunityId());
         if (comActDO == null || comActDO.getStreetId() == null) {
             return R.fail("社区没有绑定街道,请绑定后操作!");
         }
+        BeanUtils.copyProperties(comMngVillageVO, comMngVillageDO);
+        comMngVillageDO.setName(comMngVillageVO.getGroupAt());
         comMngVillageDO.setStreetId(comActDO.getStreetId());
         int update = this.baseMapper.update(comMngVillageDO,
             new LambdaQueryWrapper<ComMngVillageDO>().eq(ComMngVillageDO::getVillageId, villageId));

--
Gitblit v1.7.1