From 47655cdeba92cc4414e41a806093af2cbdaa1ec4 Mon Sep 17 00:00:00 2001
From: tangxiaobao <303826152@qq.com>
Date: 星期五, 16 七月 2021 19:35:21 +0800
Subject: [PATCH] 社区后台基础数据库修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java |   30 ++++++++++++++++++++++++++++--
 1 files changed, 28 insertions(+), 2 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
index c520a90..2f71757 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
@@ -180,7 +180,11 @@
 //        if (!comMngFamilyInfoVOS.isEmpty()) {
 //            comMngPopulationVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS);
 //        }
-
+        //设置户主关系
+        ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = comMngPopulationHouseUserDAO.selectOne((new QueryWrapper<ComMngPopulationHouseUserDO>().lambda().eq(ComMngPopulationHouseUserDO::getPopulId, populationId)));
+        if (comMngPopulationHouseUserDO != null) {
+            comMngPopulationVO.setRelation(comMngPopulationHouseUserDO.getRelation());
+        }
         //设置年龄
         if (StringUtils.isNotEmpty(comMngPopulationVO.getBirthday())) {
             comMngPopulationVO.setAge(AgeUtils.getAgeFromBirthTimes(comMngPopulationVO.getBirthday()));
@@ -403,6 +407,7 @@
             if (populationDO == null) {
                 //不存在实有人口,则新增
                 populationDO = savePopulationDO(vo, comActDO, comMngVillageDO);
+                ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = savePopulationHouseUser(vo, populationDO, populationHouseDO);
             } else {
                 //如果存在人口信息,且是自用房,则更新人口默认的房屋信息
                 if (vo.getIsRent() != null && vo.getIsRent().equals(PopulHouseUseEnum.SELF.getCode())) {
@@ -519,6 +524,19 @@
         }
         comMngPopulationHouseDAO.insert(populationHouseDO);
         return populationHouseDO;
+    }
+
+    private ComMngPopulationHouseUserDO savePopulationHouseUser(ComMngPopulationServeExcelVO vo, ComMngPopulationDO comMngPopulationDO, ComMngPopulationHouseDO comMngPopulationHouseDO) {
+        //查询该房屋未建立,执行建立房屋信息
+        ComMngPopulationHouseUserDO populationHouseUserDO = new ComMngPopulationHouseUserDO();
+        populationHouseUserDO.setId(Snowflake.getId());
+        populationHouseUserDO.setPopulId(comMngPopulationDO.getId());
+        populationHouseUserDO.setHouseId(comMngPopulationHouseDO.getId());
+        populationHouseUserDO.setRelationId(comMngPopulationHouseDO.getStatus());
+        populationHouseUserDO.setRelation(vo.getRelation());
+        populationHouseUserDO.setCreateAt(new Date());
+        comMngPopulationHouseUserDAO.insert(populationHouseUserDO);
+        return populationHouseUserDO;
     }
 
     /**
@@ -751,7 +769,15 @@
                 }
             }
         }
-        populationDO.setUpdateAt(new Date());
+
+        //查询当前用户所有戶主关系
+        List<Integer> relations = comMngPopulationHouseUserDAO.getPopulationRelationByUserId(vo.getId());
+        if (!relations.isEmpty()) {
+            ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = comMngPopulationHouseUserDAO.selectOne(new QueryWrapper<ComMngPopulationHouseUserDO>().lambda()
+                    .eq(ComMngPopulationHouseUserDO::getPopulId, vo.getId()));
+            comMngPopulationHouseUserDO.setRelation(relations.get(relations.size() - 1));
+            comMngPopulationHouseUserDAO.updateById(comMngPopulationHouseUserDO);
+        }
         if (populationDAO.updateById(populationDO) > 0) {
             return R.ok();
         } else {

--
Gitblit v1.7.1