| | |
| | | |
| | | import javax.annotation.Resource; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.segments.MergeSegments; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | private ComElderAuthElderliesDAO comElderAuthElderliesDAO; |
| | | @Resource |
| | | private ComPensionAuthPensionerDAO comPensionAuthPensionerDAO; |
| | | @Resource |
| | | private ComEldersAuthStatisticsMapper comEldersAuthStatisticsMapper; |
| | | @Value("${domain.aesKey:}") |
| | | private String aesKey; |
| | | |
| | |
| | | updateList.add(updatePopulationDO); |
| | | } else { |
| | | // 不存在实有人口,则新增 |
| | | populationDO = saveElderPopulationDO(vo, populationActVO, comMngVillageDO, userId); |
| | | populationDO = saveElderPopulationDO(vo, populationActVO, comMngVillageDO, userId,communityId); |
| | | saveList.add(populationDO); |
| | | } |
| | | log.info("开始查询实有人口是否已存在完成"); |
| | |
| | | Long communityId, Long userId) { |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComDrugPopulationDO comDrugPopulationDO = comDrugPopulationDAO.selectOne(new QueryWrapper<ComDrugPopulationDO>() |
| | | .lambda().eq(ComDrugPopulationDO::getPopulationId, populationDO.getId())); |
| | | .lambda().eq(ComDrugPopulationDO::getPopulationId, populationDO.getId()).eq(ComDrugPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comDrugPopulationDO); |
| | | comDrugPopulationDO.setId(Snowflake.getId()); |
| | | comDrugPopulationDO.setPopulationId(populationDO.getId()); |
| | | comDrugPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comDrugPopulationDO.setCommunityId(communityId); |
| | | comDrugPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comDrugPopulationDAO.insert(comDrugPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComCorrectPopulationDO comCorrectPopulationDO = |
| | | comCorrectPopulationDAO.selectOne(new QueryWrapper<ComCorrectPopulationDO>().lambda() |
| | | .eq(ComCorrectPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComCorrectPopulationDO::getPopulationId, populationDO.getId()).eq(ComCorrectPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comCorrectPopulationDO); |
| | | comCorrectPopulationDO.setId(Snowflake.getId()); |
| | | comCorrectPopulationDO.setPopulationId(populationDO.getId()); |
| | | comCorrectPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comCorrectPopulationDO.setCommunityId(communityId); |
| | | comCorrectPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comCorrectPopulationDAO.insert(comCorrectPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComMajorPopulationDO comMajorPopulationDO = |
| | | comMajorPopulationDAO.selectOne(new QueryWrapper<ComMajorPopulationDO>().lambda() |
| | | .eq(ComMajorPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComMajorPopulationDO::getPopulationId, populationDO.getId()).eq(ComMajorPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comMajorPopulationDO); |
| | | comMajorPopulationDO.setId(Snowflake.getId()); |
| | | comMajorPopulationDO.setPopulationId(populationDO.getId()); |
| | | comMajorPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comMajorPopulationDO.setCommunityId(communityId); |
| | | comMajorPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comMajorPopulationDAO.insert(comMajorPopulationDO); |
| | | } |
| | |
| | | Long communityId, Long userId) { |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComCultPopulationDO comCultPopulationDO = comCultPopulationDAO.selectOne(new QueryWrapper<ComCultPopulationDO>() |
| | | .lambda().eq(ComCultPopulationDO::getPopulationId, populationDO.getId())); |
| | | .lambda().eq(ComCultPopulationDO::getPopulationId, populationDO.getId()).eq(ComCultPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comCultPopulationDO); |
| | | comCultPopulationDO.setId(Snowflake.getId()); |
| | | comCultPopulationDO.setPopulationId(populationDO.getId()); |
| | | comCultPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comCultPopulationDO.setCommunityId(communityId); |
| | | comCultPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comCultPopulationDAO.insert(comCultPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComRehabilitationPopulationDO comRehabilitationPopulationDO = |
| | | comRehabilitationPopulationDAO.selectOne(new QueryWrapper<ComRehabilitationPopulationDO>().lambda() |
| | | .eq(ComRehabilitationPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComRehabilitationPopulationDO::getPopulationId, populationDO.getId()).eq(ComRehabilitationPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comRehabilitationPopulationDO); |
| | | comRehabilitationPopulationDO.setId(Snowflake.getId()); |
| | | comRehabilitationPopulationDO.setPopulationId(populationDO.getId()); |
| | | comRehabilitationPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comRehabilitationPopulationDO.setCommunityId(communityId); |
| | | comRehabilitationPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comRehabilitationPopulationDAO.insert(comRehabilitationPopulationDO); |
| | | } |
| | |
| | | Long communityId, Long userId) { |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComKeyPopulationDO comKeyPopulationDO = comKeyPopulationDAO.selectOne(new QueryWrapper<ComKeyPopulationDO>() |
| | | .lambda().eq(ComKeyPopulationDO::getPopulationId, populationDO.getId())); |
| | | .lambda().eq(ComKeyPopulationDO::getPopulationId, populationDO.getId()).eq(ComKeyPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comKeyPopulationDO); |
| | | comKeyPopulationDO.setId(Snowflake.getId()); |
| | | comKeyPopulationDO.setPopulationId(populationDO.getId()); |
| | | comKeyPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comKeyPopulationDO.setCommunityId(communityId); |
| | | comKeyPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comKeyPopulationDAO.insert(comKeyPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComSentencePopulationDO comSentencePopulationDO = |
| | | comSentencePopulationDAO.selectOne(new QueryWrapper<ComSentencePopulationDO>().lambda() |
| | | .eq(ComSentencePopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComSentencePopulationDO::getPopulationId, populationDO.getId()).eq(ComSentencePopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comSentencePopulationDO); |
| | | comSentencePopulationDO.setId(Snowflake.getId()); |
| | | comSentencePopulationDO.setPopulationId(populationDO.getId()); |
| | | comSentencePopulationDO.setCommunityId(populationDO.getActId()); |
| | | comSentencePopulationDO.setCommunityId(communityId); |
| | | comSentencePopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comSentencePopulationDAO.insert(comSentencePopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComVeteransPopulationDO comVeteransPopulationDO = |
| | | comVeteransPopulationDAO.selectOne(new QueryWrapper<ComVeteransPopulationDO>().lambda() |
| | | .eq(ComVeteransPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComVeteransPopulationDO::getPopulationId, populationDO.getId()).eq(ComVeteransPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comVeteransPopulationDO); |
| | | comVeteransPopulationDO.setId(Snowflake.getId()); |
| | | comVeteransPopulationDO.setPopulationId(populationDO.getId()); |
| | | comVeteransPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comVeteransPopulationDO.setCommunityId(communityId); |
| | | comVeteransPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comVeteransPopulationDAO.insert(comVeteransPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComDisabilityPopulationDO comDisabilityPopulationDO = |
| | | comDisabilityPopulationDAO.selectOne(new QueryWrapper<ComDisabilityPopulationDO>().lambda() |
| | | .eq(ComDisabilityPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComDisabilityPopulationDO::getPopulationId, populationDO.getId()).eq(ComDisabilityPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comDisabilityPopulationDO); |
| | | comDisabilityPopulationDO.setId(Snowflake.getId()); |
| | | comDisabilityPopulationDO.setPopulationId(populationDO.getId()); |
| | | comDisabilityPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comDisabilityPopulationDO.setCommunityId(communityId); |
| | | comDisabilityPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comDisabilityPopulationDAO.insert(comDisabilityPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComLowSecurityPopulationDO comLowSecurityPopulationDO = |
| | | comLowSecurityPopulationDAO.selectOne(new QueryWrapper<ComLowSecurityPopulationDO>().lambda() |
| | | .eq(ComLowSecurityPopulationDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComLowSecurityPopulationDO::getPopulationId, populationDO.getId()).eq(ComLowSecurityPopulationDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | BeanUtils.copyProperties(vo, comLowSecurityPopulationDO); |
| | | comLowSecurityPopulationDO.setId(Snowflake.getId()); |
| | | comLowSecurityPopulationDO.setPopulationId(populationDO.getId()); |
| | | comLowSecurityPopulationDO.setCommunityId(populationDO.getActId()); |
| | | comLowSecurityPopulationDO.setCommunityId(communityId); |
| | | comLowSecurityPopulationDO.setStreetId(populationDO.getStreetId()); |
| | | comLowSecurityPopulationDAO.insert(comLowSecurityPopulationDO); |
| | | } |
| | |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | ComElderAuthElderliesDO comElderAuthElderliesDO = |
| | | comElderAuthElderliesDAO.selectOne(new QueryWrapper<ComElderAuthElderliesDO>().lambda() |
| | | .eq(ComElderAuthElderliesDO::getPopulationId, populationDO.getId())); |
| | | .eq(ComElderAuthElderliesDO::getPopulationId, populationDO.getId()).eq(ComElderAuthElderliesDO::getCommunityId, communityId)); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); |
| | | } |
| | | } |
| | | if (!comElderAuthElderliesDO.getIsAlive().equals(1) || !comElderAuthElderliesDO.getIsRegister().equals(1)) { |
| | | if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | // 获取当前年 |
| | | int year = calendar.get(Calendar.YEAR); |
| | | // 获取当前月 |
| | | int month = calendar.get(Calendar.MONTH) + 1; |
| | | ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() |
| | | .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); |
| | | comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); |
| | | comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); |
| | | } |
| | | } |
| | | comElderAuthElderliesDAO.updateById(comElderAuthElderliesDO); |
| | | } else { |
| | | comElderAuthElderliesDO = new ComElderAuthElderliesDO(); |
| | | BeanUtils.copyProperties(vo, comElderAuthElderliesDO); |
| | | comElderAuthElderliesDO.setId(Snowflake.getId()); |
| | | comElderAuthElderliesDO.setPopulationId(populationDO.getId()); |
| | | comElderAuthElderliesDO.setCommunityId(populationDO.getActId()); |
| | | comElderAuthElderliesDO.setCommunityId(communityId); |
| | | comElderAuthElderliesDO.setStreetId(populationDO.getStreetId()); |
| | | comElderAuthElderliesDO.setIdCard(cardNoAES); |
| | | comElderAuthElderliesDO.setAddress(vo.getNowAddress()); |
| | |
| | | }else if (age >= 100){ |
| | | comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); |
| | | } |
| | | } |
| | | if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | // 获取当前年 |
| | | int year = calendar.get(Calendar.YEAR); |
| | | // 获取当前月 |
| | | int month = calendar.get(Calendar.MONTH) + 1; |
| | | ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() |
| | | .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); |
| | | comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); |
| | | comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); |
| | | } |
| | | comElderAuthElderliesDAO.insert(comElderAuthElderliesDO); |
| | | } |
| | |
| | | } |
| | | |
| | | private ComMngPopulationDO saveElderPopulationDO(ComMngPopulationElderExcelVO vo, |
| | | ComPopulationActVO comActDO, ComMngVillageDO comMngVillageDO, Long userId) { |
| | | ComPopulationActVO comActDO, ComMngVillageDO comMngVillageDO, Long userId, Long communityId) { |
| | | ComMngPopulationDO populationDO = new ComMngPopulationDO(); |
| | | ComElderAuthElderliesDO comElderAuthElderliesDO = new ComElderAuthElderliesDO(); |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | |
| | | comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); |
| | | } |
| | | } |
| | | if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | // 获取当前年 |
| | | int year = calendar.get(Calendar.YEAR); |
| | | // 获取当前月 |
| | | int month = calendar.get(Calendar.MONTH) + 1; |
| | | ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() |
| | | .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); |
| | | comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); |
| | | comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); |
| | | } |
| | | comElderAuthElderliesDAO.insert(comElderAuthElderliesDO); |
| | | return populationDO; |
| | | } |