From 2e64c232ab6b51b2cecf1ee96e1e9b709234f326 Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期六, 21 八月 2021 16:35:14 +0800 Subject: [PATCH] 随手拍改版接口开发 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java | 297 ++++++++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 221 insertions(+), 76 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 0eab426..60f59a4 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 @@ -244,84 +244,120 @@ } //吸毒信息 - ComDrugPopulationVO comDrugPopulationVO = new ComDrugPopulationVO(); - ComDrugPopulationDO comDrugPopulationDO = comDrugPopulationDAO.selectOne(new QueryWrapper<ComDrugPopulationDO>(). + List<ComDrugPopulationVO> comDrugPopulationVOs = new ArrayList<>(); + List<ComDrugPopulationDO> comDrugPopulationDOs = comDrugPopulationDAO.selectList(new QueryWrapper<ComDrugPopulationDO>(). lambda().eq(ComDrugPopulationDO::getPopulationId, populationId)); - if (null != comDrugPopulationDO) { - BeanUtils.copyProperties(comDrugPopulationDO, comDrugPopulationVO); - comMngPopulationVO.setComDrugPopulationVO(comDrugPopulationVO); + if (!comDrugPopulationDOs.isEmpty()) { + comDrugPopulationDOs.forEach(comDrugPopulationDO -> { + ComDrugPopulationVO comDrugPopulationVO = new ComDrugPopulationVO(); + BeanUtils.copyProperties(comDrugPopulationDO, comDrugPopulationVO); + comDrugPopulationVOs.add(comDrugPopulationVO); + comMngPopulationVO.setComDrugPopulationVOs(comDrugPopulationVOs); + }); } //社区矫正信息 - ComCorrectPopulationVO comCorrectPopulationVO = new ComCorrectPopulationVO(); - ComCorrectPopulationDO comCorrectPopulationDO = comCorrectPopulationDAO.selectOne(new QueryWrapper<ComCorrectPopulationDO>(). + List<ComCorrectPopulationVO> comCorrectPopulationVOS = new ArrayList<>(); + List<ComCorrectPopulationDO> comCorrectPopulationDOS = comCorrectPopulationDAO.selectList(new QueryWrapper<ComCorrectPopulationDO>(). lambda().eq(ComCorrectPopulationDO::getPopulationId, populationId)); - if (null != comCorrectPopulationDO) { - BeanUtils.copyProperties(comCorrectPopulationDO, comCorrectPopulationVO); - comMngPopulationVO.setComCorrectPopulationVO(comCorrectPopulationVO); + if (!comCorrectPopulationDOS.isEmpty()) { + comCorrectPopulationDOS.forEach(comCorrectPopulationDO -> { + ComCorrectPopulationVO comCorrectPopulationVO = new ComCorrectPopulationVO(); + BeanUtils.copyProperties(comCorrectPopulationDO, comCorrectPopulationVO); + comCorrectPopulationVOS.add(comCorrectPopulationVO); + comMngPopulationVO.setComCorrectPopulationVOs(comCorrectPopulationVOS); + }); } //精神障碍信息 - ComMajorPopulationVO comMajorPopulationVO = new ComMajorPopulationVO(); - ComMajorPopulationDO comMajorPopulationDO = comMajorPopulationDAO.selectOne(new QueryWrapper<ComMajorPopulationDO>(). + List<ComMajorPopulationVO> comMajorPopulationVOS = new ArrayList<>(); + List<ComMajorPopulationDO> comMajorPopulationDOs = comMajorPopulationDAO.selectList(new QueryWrapper<ComMajorPopulationDO>(). lambda().eq(ComMajorPopulationDO::getPopulationId, populationId)); - if (null != comMajorPopulationDO) { - BeanUtils.copyProperties(comMajorPopulationDO, comMajorPopulationVO); - comMngPopulationVO.setComMajorPopulationVO(comMajorPopulationVO); + if (!comMajorPopulationDOs.isEmpty()) { + comMajorPopulationDOs.forEach(comMajorPopulationDO -> { + ComMajorPopulationVO comMajorPopulationVO = new ComMajorPopulationVO(); + BeanUtils.copyProperties(comMajorPopulationDO, comMajorPopulationVO); + comMajorPopulationVOS.add(comMajorPopulationVO); + comMngPopulationVO.setComMajorPopulationVOs(comMajorPopulationVOS); + }); } //邪教信息 - ComCultPopulationVO comCultPopulationVO = new ComCultPopulationVO(); - ComCultPopulationDO comCultPopulationDO = comCultPopulationDAO.selectOne(new QueryWrapper<ComCultPopulationDO>(). + List<ComCultPopulationVO> comCultPopulationVOS = new ArrayList<>(); + List<ComCultPopulationDO> comCultPopulationDOS = comCultPopulationDAO.selectList(new QueryWrapper<ComCultPopulationDO>(). lambda().eq(ComCultPopulationDO::getPopulationId, populationId)); - if (null != comCultPopulationDO) { - BeanUtils.copyProperties(comCultPopulationDO, comCultPopulationVO); - comMngPopulationVO.setComCultPopulationVO(comCultPopulationVO); + if (!comCultPopulationDOS.isEmpty()) { + comCultPopulationDOS.forEach(comCultPopulationDO -> { + ComCultPopulationVO comCultPopulationVO = new ComCultPopulationVO(); + BeanUtils.copyProperties(comCultPopulationDO, comCultPopulationVO); + comCultPopulationVOS.add(comCultPopulationVO); + comMngPopulationVO.setComCultPopulationVOs(comCultPopulationVOS); + }); } //刑释信息 - ComRehabilitationPopulationVO comRehabilitationPopulationVO = new ComRehabilitationPopulationVO(); - ComRehabilitationPopulationDO comRehabilitationPopulationDO = comRehabilitationPopulationDAO.selectOne(new QueryWrapper<ComRehabilitationPopulationDO>(). + List<ComRehabilitationPopulationVO> comRehabilitationPopulationVOS = new ArrayList<>(); + List<ComRehabilitationPopulationDO> comRehabilitationPopulationDOS = comRehabilitationPopulationDAO.selectList(new QueryWrapper<ComRehabilitationPopulationDO>(). lambda().eq(ComRehabilitationPopulationDO::getPopulationId, populationId)); - if (null != comRehabilitationPopulationDO) { - BeanUtils.copyProperties(comRehabilitationPopulationDO, comRehabilitationPopulationVO); - comMngPopulationVO.setComRehabilitationPopulationVO(comRehabilitationPopulationVO); + if (!comRehabilitationPopulationDOS.isEmpty()) { + comRehabilitationPopulationDOS.forEach(comRehabilitationPopulationDO -> { + ComRehabilitationPopulationVO comRehabilitationPopulationVO = new ComRehabilitationPopulationVO(); + BeanUtils.copyProperties(comRehabilitationPopulationDO, comRehabilitationPopulationVO); + comRehabilitationPopulationVOS.add(comRehabilitationPopulationVO); + comMngPopulationVO.setComRehabilitationPopulationVOs(comRehabilitationPopulationVOS); + }); } //上访信息 - ComKeyPopulationVO comKeyPopulationVO = new ComKeyPopulationVO(); - ComKeyPopulationDO comKeyPopulationDO = comKeyPopulationDAO.selectOne(new QueryWrapper<ComKeyPopulationDO>(). + List<ComKeyPopulationVO> comKeyPopulationVOS = new ArrayList<>(); + List<ComKeyPopulationDO> comKeyPopulationDOS = comKeyPopulationDAO.selectList(new QueryWrapper<ComKeyPopulationDO>(). lambda().eq(ComKeyPopulationDO::getPopulationId, populationId)); - if (null != comKeyPopulationDO) { - BeanUtils.copyProperties(comKeyPopulationDO, comKeyPopulationVO); - comMngPopulationVO.setComKeyPopulationVO(comKeyPopulationVO); + if (!comKeyPopulationDOS.isEmpty()) { + comKeyPopulationDOS.forEach(comKeyPopulationDO -> { + ComKeyPopulationVO comKeyPopulationVO = new ComKeyPopulationVO(); + BeanUtils.copyProperties(comKeyPopulationDO, comKeyPopulationVO); + comKeyPopulationVOS.add(comKeyPopulationVO); + comMngPopulationVO.setComKeyPopulationVOs(comKeyPopulationVOS); + }); } //退役军人信息 - ComVeteransPopulationVO comVeteransPopulationVO = new ComVeteransPopulationVO(); - ComVeteransPopulationDO comVeteransPopulationDO = comVeteransPopulationDAO.selectOne(new QueryWrapper<ComVeteransPopulationDO>(). + List<ComVeteransPopulationVO> comVeteransPopulationVOS = new ArrayList<>(); + List<ComVeteransPopulationDO> comVeteransPopulationDOS = comVeteransPopulationDAO.selectList(new QueryWrapper<ComVeteransPopulationDO>(). lambda().eq(ComVeteransPopulationDO::getPopulationId, populationId)); - if (null != comRehabilitationPopulationDO) { - BeanUtils.copyProperties(comVeteransPopulationDO, comVeteransPopulationVO); - comMngPopulationVO.setComVeteransPopulationVO(comVeteransPopulationVO); + if (!comVeteransPopulationDOS.isEmpty()) { + comVeteransPopulationDOS.forEach(comVeteransPopulationDO -> { + ComVeteransPopulationVO comVeteransPopulationVO = new ComVeteransPopulationVO(); + BeanUtils.copyProperties(comVeteransPopulationDO, comVeteransPopulationVO); + comVeteransPopulationVOS.add(comVeteransPopulationVO); + comMngPopulationVO.setComVeteransPopulationVOs(comVeteransPopulationVOS); + }); } //残疾人信息 - ComDisabilityPopulationVO comDisabilityPopulationVO = new ComDisabilityPopulationVO(); - ComDisabilityPopulationDO comDisabilityPopulationDO = comDisabilityPopulationDAO.selectOne(new QueryWrapper<ComDisabilityPopulationDO>(). + List<ComDisabilityPopulationVO> comDisabilityPopulationVOS = new ArrayList<>(); + List<ComDisabilityPopulationDO> comDisabilityPopulationDOS = comDisabilityPopulationDAO.selectList(new QueryWrapper<ComDisabilityPopulationDO>(). lambda().eq(ComDisabilityPopulationDO::getPopulationId, populationId)); - if (null != comRehabilitationPopulationDO) { - BeanUtils.copyProperties(comDisabilityPopulationDO, comDisabilityPopulationVO); - comMngPopulationVO.setComDisabilityPopulationVO(comDisabilityPopulationVO); + if (!comDisabilityPopulationDOS.isEmpty()) { + comDisabilityPopulationDOS.forEach(comDisabilityPopulationDO -> { + ComDisabilityPopulationVO comDisabilityPopulationVO = new ComDisabilityPopulationVO(); + BeanUtils.copyProperties(comDisabilityPopulationDO, comDisabilityPopulationVO); + comDisabilityPopulationVOS.add(comDisabilityPopulationVO); + comMngPopulationVO.setComDisabilityPopulationVOs(comDisabilityPopulationVOS); + }); } //低保户信息 - ComLowSecurityPopulationVO comLowSecurityPopulationVO = new ComLowSecurityPopulationVO(); - ComLowSecurityPopulationDO comLowSecurityPopulationDO = comLowSecurityPopulationDAO.selectOne(new QueryWrapper<ComLowSecurityPopulationDO>(). + List<ComLowSecurityPopulationVO> comLowSecurityPopulationVOS = new ArrayList<>(); + List<ComLowSecurityPopulationDO> comLowSecurityPopulationDOS = comLowSecurityPopulationDAO.selectList(new QueryWrapper<ComLowSecurityPopulationDO>(). lambda().eq(ComLowSecurityPopulationDO::getPopulationId, populationId)); - if (null != comRehabilitationPopulationDO) { - BeanUtils.copyProperties(comLowSecurityPopulationDO, comLowSecurityPopulationVO); - comMngPopulationVO.setComLowSecurityPopulationVO(comLowSecurityPopulationVO); + if (!comLowSecurityPopulationDOS.isEmpty()) { + comLowSecurityPopulationDOS.forEach(comLowSecurityPopulationDO -> { + ComLowSecurityPopulationVO comLowSecurityPopulationVO = new ComLowSecurityPopulationVO(); + BeanUtils.copyProperties(comLowSecurityPopulationDO, comLowSecurityPopulationVO); + comLowSecurityPopulationVOS.add(comLowSecurityPopulationVO); + comMngPopulationVO.setComLowSecurityPopulationVOs(comLowSecurityPopulationVOS); + }); } return R.ok(comMngPopulationVO); } @@ -613,6 +649,12 @@ populationDO = (ComMngPopulationDO)populationMap.get(populationKey); ComMngPopulationDO updatePopulationDO = updatePopulationDO(vo,populationDO,labelList); updateList.add(updatePopulationDO); + + ComMngPopulationMistakeExcelVO mistake = new ComMngPopulationMistakeExcelVO(); + BeanUtils.copyProperties(vo,mistake); + setMistake(mistake, vo); + mistake.setMistake("该实有人口已存在,执行更新,社区id::"+ populationDO.getActId()); + mistakes.add(mistake); }else{ //不存在实有人口,则新增 populationDO = savePopulationDO(vo, populationActVO, comMngVillageDO,labelList); @@ -2864,7 +2906,6 @@ BeanUtils.copyProperties(vo, populationDO); ComDrugPopulationDO comDrugPopulationDO = comDrugPopulationDAO.selectOne(new QueryWrapper<ComDrugPopulationDO>().lambda() .eq(ComDrugPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comDrugPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -2881,8 +2922,20 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comDrugPopulationDO.setCardNo(cardNoAES); - comDrugPopulationDAO.updateById(comDrugPopulationDO); + + if (comDrugPopulationDO != null) { + BeanUtils.copyProperties(vo, comDrugPopulationDO); + comDrugPopulationDO.setCardNo(cardNoAES); + comDrugPopulationDAO.updateById(comDrugPopulationDO); + }else { + comDrugPopulationDO = new ComDrugPopulationDO(); + BeanUtils.copyProperties(vo, comDrugPopulationDO); + comDrugPopulationDO.setId(Snowflake.getId()); + comDrugPopulationDO.setPopulationId(populationDO.getId()); + comDrugPopulationDO.setCommunityId(populationDO.getActId()); + comDrugPopulationDO.setStreetId(populationDO.getStreetId()); + comDrugPopulationDAO.insert(comDrugPopulationDO); + } return populationDO; } @@ -2890,7 +2943,6 @@ BeanUtils.copyProperties(vo, populationDO); ComCorrectPopulationDO comCorrectPopulationDO = comCorrectPopulationDAO.selectOne(new QueryWrapper<ComCorrectPopulationDO>().lambda() .eq(ComCorrectPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comCorrectPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -2907,8 +2959,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comCorrectPopulationDO.setCardNo(cardNoAES); - comCorrectPopulationDAO.updateById(comCorrectPopulationDO); + if (comCorrectPopulationDO != null) { + BeanUtils.copyProperties(vo, comCorrectPopulationDO); + comCorrectPopulationDO.setCardNo(cardNoAES); + comCorrectPopulationDAO.updateById(comCorrectPopulationDO); + }else { + comCorrectPopulationDO = new ComCorrectPopulationDO(); + BeanUtils.copyProperties(vo, comCorrectPopulationDO); + comCorrectPopulationDO.setId(Snowflake.getId()); + comCorrectPopulationDO.setPopulationId(populationDO.getId()); + comCorrectPopulationDO.setCommunityId(populationDO.getActId()); + comCorrectPopulationDO.setStreetId(populationDO.getStreetId()); + comCorrectPopulationDAO.insert(comCorrectPopulationDO); + } return populationDO; } @@ -2916,7 +2979,6 @@ BeanUtils.copyProperties(vo, populationDO); ComMajorPopulationDO comMajorPopulationDO = comMajorPopulationDAO.selectOne(new QueryWrapper<ComMajorPopulationDO>().lambda() .eq(ComMajorPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comMajorPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -2933,8 +2995,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comMajorPopulationDO.setCardNo(cardNoAES); - comMajorPopulationDAO.updateById(comMajorPopulationDO); + if (comMajorPopulationDO != null) { + BeanUtils.copyProperties(vo, comMajorPopulationDO); + comMajorPopulationDO.setCardNo(cardNoAES); + comMajorPopulationDAO.updateById(comMajorPopulationDO); + }else { + comMajorPopulationDO = new ComMajorPopulationDO(); + BeanUtils.copyProperties(vo, comMajorPopulationDO); + comMajorPopulationDO.setId(Snowflake.getId()); + comMajorPopulationDO.setPopulationId(populationDO.getId()); + comMajorPopulationDO.setCommunityId(populationDO.getActId()); + comMajorPopulationDO.setStreetId(populationDO.getStreetId()); + comMajorPopulationDAO.insert(comMajorPopulationDO); + } return populationDO; } @@ -2942,7 +3015,6 @@ BeanUtils.copyProperties(vo, populationDO); ComCultPopulationDO comCultPopulationDO = comCultPopulationDAO.selectOne(new QueryWrapper<ComCultPopulationDO>().lambda(). eq(ComCultPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comCultPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -2959,8 +3031,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comCultPopulationDO.setCardNo(cardNoAES); - comCultPopulationDAO.updateById(comCultPopulationDO); + if (comCultPopulationDO != null) { + BeanUtils.copyProperties(vo, comCultPopulationDO); + comCultPopulationDO.setCardNo(cardNoAES); + comCultPopulationDAO.updateById(comCultPopulationDO); + }else { + comCultPopulationDO = new ComCultPopulationDO(); + BeanUtils.copyProperties(vo, comCultPopulationDO); + comCultPopulationDO.setId(Snowflake.getId()); + comCultPopulationDO.setPopulationId(populationDO.getId()); + comCultPopulationDO.setCommunityId(populationDO.getActId()); + comCultPopulationDO.setStreetId(populationDO.getStreetId()); + comCultPopulationDAO.insert(comCultPopulationDO); + } return populationDO; } @@ -2968,7 +3051,6 @@ BeanUtils.copyProperties(vo, populationDO); ComRehabilitationPopulationDO comRehabilitationPopulationDO = comRehabilitationPopulationDAO.selectOne(new QueryWrapper<ComRehabilitationPopulationDO>().lambda(). eq(ComRehabilitationPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comRehabilitationPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -2985,8 +3067,20 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comRehabilitationPopulationDO.setCardNo(cardNoAES); - comRehabilitationPopulationDAO.updateById(comRehabilitationPopulationDO); + if (comRehabilitationPopulationDO != null) { + BeanUtils.copyProperties(vo, comRehabilitationPopulationDO); + comRehabilitationPopulationDO.setCardNo(cardNoAES); + comRehabilitationPopulationDAO.updateById(comRehabilitationPopulationDO); + }else { + comRehabilitationPopulationDO = new ComRehabilitationPopulationDO(); + BeanUtils.copyProperties(vo, comRehabilitationPopulationDO); + comRehabilitationPopulationDO.setId(Snowflake.getId()); + comRehabilitationPopulationDO.setPopulationId(populationDO.getId()); + comRehabilitationPopulationDO.setCommunityId(populationDO.getActId()); + comRehabilitationPopulationDO.setStreetId(populationDO.getStreetId()); + comRehabilitationPopulationDAO.insert(comRehabilitationPopulationDO); + } + return populationDO; } @@ -2994,7 +3088,6 @@ BeanUtils.copyProperties(vo, populationDO); ComKeyPopulationDO comKeyPopulationDO = comKeyPopulationDAO.selectOne(new QueryWrapper<ComKeyPopulationDO>().lambda(). eq(ComKeyPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comKeyPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -3011,8 +3104,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comKeyPopulationDO.setCardNo(cardNoAES); - comKeyPopulationDAO.updateById(comKeyPopulationDO); + if (comKeyPopulationDO != null) { + BeanUtils.copyProperties(vo, comKeyPopulationDO); + comKeyPopulationDO.setCardNo(cardNoAES); + comKeyPopulationDAO.updateById(comKeyPopulationDO); + }else { + comKeyPopulationDO = new ComKeyPopulationDO(); + BeanUtils.copyProperties(vo, comKeyPopulationDO); + comKeyPopulationDO.setId(Snowflake.getId()); + comKeyPopulationDO.setPopulationId(populationDO.getId()); + comKeyPopulationDO.setCommunityId(populationDO.getActId()); + comKeyPopulationDO.setStreetId(populationDO.getStreetId()); + comKeyPopulationDAO.insert(comKeyPopulationDO); + } return populationDO; } @@ -3020,7 +3124,6 @@ BeanUtils.copyProperties(vo, populationDO); ComSentencePopulationDO comSentencePopulationDO = comSentencePopulationDAO.selectOne(new QueryWrapper<ComSentencePopulationDO>().lambda(). eq(ComSentencePopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comSentencePopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -3037,8 +3140,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comSentencePopulationDO.setCardNo(cardNoAES); - comSentencePopulationDAO.updateById(comSentencePopulationDO); + if (comSentencePopulationDO != null) { + BeanUtils.copyProperties(vo, comSentencePopulationDO); + comSentencePopulationDO.setCardNo(cardNoAES); + comSentencePopulationDAO.updateById(comSentencePopulationDO); + }else { + comSentencePopulationDO = new ComSentencePopulationDO(); + BeanUtils.copyProperties(vo, comSentencePopulationDO); + comSentencePopulationDO.setId(Snowflake.getId()); + comSentencePopulationDO.setPopulationId(populationDO.getId()); + comSentencePopulationDO.setCommunityId(populationDO.getActId()); + comSentencePopulationDO.setStreetId(populationDO.getStreetId()); + comSentencePopulationDAO.insert(comSentencePopulationDO); + } return populationDO; } @@ -3046,7 +3160,6 @@ BeanUtils.copyProperties(vo, populationDO); ComVeteransPopulationDO comVeteransPopulationDO = comVeteransPopulationDAO.selectOne(new QueryWrapper<ComVeteransPopulationDO>().lambda(). eq(ComVeteransPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comVeteransPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -3063,15 +3176,25 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comVeteransPopulationDO.setCardNo(cardNoAES); - comVeteransPopulationDAO.updateById(comVeteransPopulationDO); + if (comVeteransPopulationDO != null) { + BeanUtils.copyProperties(vo, comVeteransPopulationDO); + comVeteransPopulationDO.setCardNo(cardNoAES); + comVeteransPopulationDAO.updateById(comVeteransPopulationDO); + }else { + comVeteransPopulationDO = new ComVeteransPopulationDO(); + BeanUtils.copyProperties(vo, comVeteransPopulationDO); + comVeteransPopulationDO.setId(Snowflake.getId()); + comVeteransPopulationDO.setPopulationId(populationDO.getId()); + comVeteransPopulationDO.setCommunityId(populationDO.getActId()); + comVeteransPopulationDO.setStreetId(populationDO.getStreetId()); + comVeteransPopulationDAO.insert(comVeteransPopulationDO); + } return populationDO; } private ComMngPopulationDO updateDisabilityPopulationDO(ComMngPopulationDisabilityExcelVO vo, ComMngPopulationDO populationDO,List<String> labelList){ BeanUtils.copyProperties(vo, populationDO); ComDisabilityPopulationDO comDisabilityPopulationDO = comDisabilityPopulationDAO.selectOne(new QueryWrapper<ComDisabilityPopulationDO>().lambda(). eq(ComDisabilityPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comDisabilityPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -3088,8 +3211,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comDisabilityPopulationDO.setCardNo(cardNoAES); - comDisabilityPopulationDAO.updateById(comDisabilityPopulationDO); + if (comDisabilityPopulationDO != null) { + BeanUtils.copyProperties(vo, comDisabilityPopulationDO); + comDisabilityPopulationDO.setCardNo(cardNoAES); + comDisabilityPopulationDAO.updateById(comDisabilityPopulationDO); + }else { + comDisabilityPopulationDO = new ComDisabilityPopulationDO(); + BeanUtils.copyProperties(vo, comDisabilityPopulationDO); + comDisabilityPopulationDO.setId(Snowflake.getId()); + comDisabilityPopulationDO.setPopulationId(populationDO.getId()); + comDisabilityPopulationDO.setCommunityId(populationDO.getActId()); + comDisabilityPopulationDO.setStreetId(populationDO.getStreetId()); + comDisabilityPopulationDAO.insert(comDisabilityPopulationDO); + } return populationDO; } @@ -3097,7 +3231,6 @@ BeanUtils.copyProperties(vo, populationDO); ComLowSecurityPopulationDO comLowSecurityPopulationDO = comLowSecurityPopulationDAO.selectOne(new QueryWrapper<ComLowSecurityPopulationDO>().lambda(). eq(ComLowSecurityPopulationDO::getPopulationId, populationDO.getId())); - BeanUtils.copyProperties(vo, comLowSecurityPopulationDO); List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 Iterator<String> iterator = userTag.iterator(); @@ -3114,8 +3247,19 @@ } populationDO.setLabel(Joiner.on(",").join(userTag)); populationDO.setCardNo(cardNoAES); - comLowSecurityPopulationDO.setCardNo(cardNoAES); - comLowSecurityPopulationDAO.updateById(comLowSecurityPopulationDO); + if (comLowSecurityPopulationDO != null) { + BeanUtils.copyProperties(vo, comLowSecurityPopulationDO); + comLowSecurityPopulationDO.setCardNo(cardNoAES); + comLowSecurityPopulationDAO.updateById(comLowSecurityPopulationDO); + }else { + comLowSecurityPopulationDO = new ComLowSecurityPopulationDO(); + BeanUtils.copyProperties(vo, comLowSecurityPopulationDO); + comLowSecurityPopulationDO.setId(Snowflake.getId()); + comLowSecurityPopulationDO.setPopulationId(populationDO.getId()); + comLowSecurityPopulationDO.setCommunityId(populationDO.getActId()); + comLowSecurityPopulationDO.setStreetId(populationDO.getStreetId()); + comLowSecurityPopulationDAO.insert(comLowSecurityPopulationDO); + } return populationDO; } @@ -4427,7 +4571,8 @@ } } else { //新增 - Integer count = comMngUserTagDAO.selectCount(new QueryWrapper<ComMngUserTagDO>().lambda().eq(ComMngUserTagDO::getTagName, comMngTagVO.getTagName())); + Integer count = comMngUserTagDAO.selectCount(new QueryWrapper<ComMngUserTagDO>().lambda().eq(ComMngUserTagDO::getTagName, comMngTagVO.getTagName()) + .eq(ComMngUserTagDO::getCommunityId, comMngTagVO.getCommunityId())); if (count > 0) { return R.fail("该标签已存在,标签名称重复"); } -- Gitblit v1.7.1