花城-智慧社区
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
罗元桥
2021-09-13 e4c64bf1edc05a164406778e9cfaa86744210d05 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java


@@ -63,6 +63,7 @@




import cn.hutool.core.util.IdcardUtil;


import lombok.extern.slf4j.Slf4j;


import org.springframework.web.bind.annotation.RequestParam;




/**


 * 实有人口Service实现类


@@ -126,6 +127,8 @@


    private ComPensionAuthPensionerDAO comPensionAuthPensionerDAO;


    @Resource


    private ComEldersAuthStatisticsMapper comEldersAuthStatisticsMapper;


    @Resource


    private ComPensionAuthStatisticsDAO comPensionAuthStatisticsDAO;


    @Value("${domain.aesKey:}")


    private String aesKey;




@@ -196,7 +199,7 @@


     * @return 实有人口详情


     */


    @Override


    public R detailPopulation(Long populationId) {


    public R detailPopulation(Long populationId, Long communityId) {


        ComMngPopulationDO comMngPopulationDO = populationDAO.selectById(populationId);


        if (ObjectUtils.isEmpty(comMngPopulationDO)) {


            return R.fail("用户信息不存在");


@@ -237,7 +240,8 @@


        // 设置特殊群体标签


        ComMngPopulationCommunityTagsDO comMngPopulationCommunityTagsDO =


            comMngPopulationCommunityTagsDAO.selectOne(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda()


                .eq(ComMngPopulationCommunityTagsDO::getPopulationId, populationId));


                    .eq(ComMngPopulationCommunityTagsDO::getPopulationId, populationId)


                    .eq(ComMngPopulationCommunityTagsDO::getCommunityId, communityId));


        if (null != comMngPopulationCommunityTagsDO) {


            comMngPopulationVO.setLabel(comMngPopulationCommunityTagsDO.getLabel());


        }


@@ -272,10 +276,12 @@


            comMngPopulationVO.setCarList(carList);


        }




        if (communityId != null){


        // 吸毒信息


        List<ComDrugPopulationVO> comDrugPopulationVOs = new ArrayList<>();


        List<ComDrugPopulationDO> comDrugPopulationDOs = comDrugPopulationDAO.selectList(


            new QueryWrapper<ComDrugPopulationDO>().lambda().eq(ComDrugPopulationDO::getPopulationId, populationId));


                    new QueryWrapper<ComDrugPopulationDO>().lambda().eq(ComDrugPopulationDO::getPopulationId, populationId)


                            .eq(ComDrugPopulationDO::getCommunityId, communityId));


        if (!comDrugPopulationDOs.isEmpty()) {


            comDrugPopulationDOs.forEach(comDrugPopulationDO -> {


                ComDrugPopulationVO comDrugPopulationVO = new ComDrugPopulationVO();


@@ -289,7 +295,8 @@


        List<ComCorrectPopulationVO> comCorrectPopulationVOS = new ArrayList<>();


        List<ComCorrectPopulationDO> comCorrectPopulationDOS =


            comCorrectPopulationDAO.selectList(new QueryWrapper<ComCorrectPopulationDO>().lambda()


                .eq(ComCorrectPopulationDO::getPopulationId, populationId));


                            .eq(ComCorrectPopulationDO::getPopulationId, populationId)


                            .eq(ComCorrectPopulationDO::getCommunityId, communityId));


        if (!comCorrectPopulationDOS.isEmpty()) {


            comCorrectPopulationDOS.forEach(comCorrectPopulationDO -> {


                ComCorrectPopulationVO comCorrectPopulationVO = new ComCorrectPopulationVO();


@@ -302,7 +309,8 @@


        // 精神障碍信息


        List<ComMajorPopulationVO> comMajorPopulationVOS = new ArrayList<>();


        List<ComMajorPopulationDO> comMajorPopulationDOs = comMajorPopulationDAO.selectList(


            new QueryWrapper<ComMajorPopulationDO>().lambda().eq(ComMajorPopulationDO::getPopulationId, populationId));


                    new QueryWrapper<ComMajorPopulationDO>().lambda().eq(ComMajorPopulationDO::getPopulationId, populationId)


                            .eq(ComMajorPopulationDO::getCommunityId, communityId));


        if (!comMajorPopulationDOs.isEmpty()) {


            comMajorPopulationDOs.forEach(comMajorPopulationDO -> {


                ComMajorPopulationVO comMajorPopulationVO = new ComMajorPopulationVO();


@@ -315,7 +323,8 @@


        // 邪教信息


        List<ComCultPopulationVO> comCultPopulationVOS = new ArrayList<>();


        List<ComCultPopulationDO> comCultPopulationDOS = comCultPopulationDAO.selectList(


            new QueryWrapper<ComCultPopulationDO>().lambda().eq(ComCultPopulationDO::getPopulationId, populationId));


                    new QueryWrapper<ComCultPopulationDO>().lambda().eq(ComCultPopulationDO::getPopulationId, populationId)


                            .eq(ComCultPopulationDO::getCommunityId, communityId));


        if (!comCultPopulationDOS.isEmpty()) {


            comCultPopulationDOS.forEach(comCultPopulationDO -> {


                ComCultPopulationVO comCultPopulationVO = new ComCultPopulationVO();


@@ -329,7 +338,8 @@


        List<ComRehabilitationPopulationVO> comRehabilitationPopulationVOS = new ArrayList<>();


        List<ComRehabilitationPopulationDO> comRehabilitationPopulationDOS =


            comRehabilitationPopulationDAO.selectList(new QueryWrapper<ComRehabilitationPopulationDO>().lambda()


                .eq(ComRehabilitationPopulationDO::getPopulationId, populationId));


                            .eq(ComRehabilitationPopulationDO::getPopulationId, populationId)


                            .eq(ComRehabilitationPopulationDO::getCommunityId, communityId));


        if (!comRehabilitationPopulationDOS.isEmpty()) {


            comRehabilitationPopulationDOS.forEach(comRehabilitationPopulationDO -> {


                ComRehabilitationPopulationVO comRehabilitationPopulationVO = new ComRehabilitationPopulationVO();


@@ -342,7 +352,8 @@


        // 上访信息


        List<ComKeyPopulationVO> comKeyPopulationVOS = new ArrayList<>();


        List<ComKeyPopulationDO> comKeyPopulationDOS = comKeyPopulationDAO.selectList(


            new QueryWrapper<ComKeyPopulationDO>().lambda().eq(ComKeyPopulationDO::getPopulationId, populationId));


                    new QueryWrapper<ComKeyPopulationDO>().lambda().eq(ComKeyPopulationDO::getPopulationId, populationId)


                            .eq(ComKeyPopulationDO::getCommunityId, communityId));


        if (!comKeyPopulationDOS.isEmpty()) {


            comKeyPopulationDOS.forEach(comKeyPopulationDO -> {


                ComKeyPopulationVO comKeyPopulationVO = new ComKeyPopulationVO();


@@ -356,7 +367,8 @@


        List<ComVeteransPopulationVO> comVeteransPopulationVOS = new ArrayList<>();


        List<ComVeteransPopulationDO> comVeteransPopulationDOS =


            comVeteransPopulationDAO.selectList(new QueryWrapper<ComVeteransPopulationDO>().lambda()


                .eq(ComVeteransPopulationDO::getPopulationId, populationId));


                            .eq(ComVeteransPopulationDO::getPopulationId, populationId)


                            .eq(ComVeteransPopulationDO::getCommunityId, communityId));


        if (!comVeteransPopulationDOS.isEmpty()) {


            comVeteransPopulationDOS.forEach(comVeteransPopulationDO -> {


                ComVeteransPopulationVO comVeteransPopulationVO = new ComVeteransPopulationVO();


@@ -370,7 +382,8 @@


        List<ComDisabilityPopulationVO> comDisabilityPopulationVOS = new ArrayList<>();


        List<ComDisabilityPopulationDO> comDisabilityPopulationDOS =


            comDisabilityPopulationDAO.selectList(new QueryWrapper<ComDisabilityPopulationDO>().lambda()


                .eq(ComDisabilityPopulationDO::getPopulationId, populationId));


                            .eq(ComDisabilityPopulationDO::getPopulationId, populationId)


                            .eq(ComDisabilityPopulationDO::getCommunityId, communityId));


        if (!comDisabilityPopulationDOS.isEmpty()) {


            comDisabilityPopulationDOS.forEach(comDisabilityPopulationDO -> {


                ComDisabilityPopulationVO comDisabilityPopulationVO = new ComDisabilityPopulationVO();


@@ -384,7 +397,8 @@


        List<ComLowSecurityPopulationVO> comLowSecurityPopulationVOS = new ArrayList<>();


        List<ComLowSecurityPopulationDO> comLowSecurityPopulationDOS =


            comLowSecurityPopulationDAO.selectList(new QueryWrapper<ComLowSecurityPopulationDO>().lambda()


                .eq(ComLowSecurityPopulationDO::getPopulationId, populationId));


                            .eq(ComLowSecurityPopulationDO::getPopulationId, populationId)


                            .eq(ComLowSecurityPopulationDO::getCommunityId, communityId));


        if (!comLowSecurityPopulationDOS.isEmpty()) {


            comLowSecurityPopulationDOS.forEach(comLowSecurityPopulationDO -> {


                ComLowSecurityPopulationVO comLowSecurityPopulationVO = new ComLowSecurityPopulationVO();


@@ -398,7 +412,8 @@


        List<ComElderAuthElderliesVO> comElderAuthElderliesVOList = new ArrayList<>();


        List<ComElderAuthElderliesDO> comElderAuthElderliesDOS =


                comElderAuthElderliesDAO.selectList(new QueryWrapper<ComElderAuthElderliesDO>().lambda()


                        .eq(ComElderAuthElderliesDO::getPopulationId, populationId));


                            .eq(ComElderAuthElderliesDO::getPopulationId, populationId)


                            .eq(ComElderAuthElderliesDO::getCommunityId, communityId));


        if (!comElderAuthElderliesDOS.isEmpty()) {


            comElderAuthElderliesDOS.forEach(comElderAuthElderliesDO -> {


                ComElderAuthElderliesVO comElderAuthElderliesVO = new ComElderAuthElderliesVO();


@@ -412,7 +427,8 @@


        List<ComPensionAuthPensionerVO> comPensionAuthPensionerVOList = new ArrayList<>();


        List<ComPensionAuthPensionerDO> comPensionAuthPensionerDOS =


                comPensionAuthPensionerDAO.selectList(new QueryWrapper<ComPensionAuthPensionerDO>().lambda()


                        .eq(ComPensionAuthPensionerDO::getPopulationId, populationId));


                            .eq(ComPensionAuthPensionerDO::getPopulationId, populationId)


                            .eq(ComPensionAuthPensionerDO::getCommunityId, communityId));


        if (!comPensionAuthPensionerDOS.isEmpty()) {


            comPensionAuthPensionerDOS.forEach(comPensionAuthPensionerDO -> {


                ComPensionAuthPensionerVO comPensionAuthPensionerVO = new ComPensionAuthPensionerVO();


@@ -420,6 +436,7 @@


                comPensionAuthPensionerVOList.add(comPensionAuthPensionerVO);


                comMngPopulationVO.setComPensionAuthPensionerVOList(comPensionAuthPensionerVOList);


            });


            }


        }


        return R.ok(comMngPopulationVO);


    }


@@ -4150,8 +4167,7 @@




            // 查询当前社区标签列表


            List<String> labelList = new ArrayList<>();


            List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO


                    .selectList(null);


            List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO.selectList(null);


            if (!ObjectUtils.isEmpty(comMngUserTagDOS)) {


                labelList = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName())


                        .collect(Collectors.toList());


@@ -4890,11 +4906,11 @@


            }


            if (!comElderAuthElderliesDO.getIsAlive().equals(1) || !comElderAuthElderliesDO.getIsRegister().equals(1)) {


                if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) {


                    Calendar calendar = Calendar.getInstance();


                    Date nowDate = new Date();


                    // 获取当前年


                    int year = calendar.get(Calendar.YEAR);


                    int year = DateUtils.getYear(nowDate);


                    // 获取当前月


                    int month = calendar.get(Calendar.MONTH) + 1;


                    int month = DateUtils.getMonth(nowDate) + 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);


@@ -4922,11 +4938,11 @@


                }


            }


            if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) {


                Calendar calendar = Calendar.getInstance();


                Date nowDate = new Date();


                // 获取当前年


                int year = calendar.get(Calendar.YEAR);


                int year = DateUtils.getYear(nowDate);


                // 获取当前月


                int month = calendar.get(Calendar.MONTH) + 1;


                int month = DateUtils.getMonth(nowDate) + 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);


@@ -4942,7 +4958,8 @@


        BeanUtils.copyProperties(vo, populationDO);


        ComPensionAuthPensionerDO comPensionAuthPensionerDO =


                comPensionAuthPensionerDAO.selectOne(new QueryWrapper<ComPensionAuthPensionerDO>().lambda()


                        .eq(ComPensionAuthPensionerDO::getPopulationId, populationDO.getId()));


                        .eq(ComPensionAuthPensionerDO::getPopulationId, populationDO.getId())


                        .eq(ComPensionAuthPensionerDO::getCommunityId, communityId));


        // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr ->


        // userTagStr.split("\\(")[0]).collect(Collectors.toList());


        // //如果导入数据标签中有当前社区标签列表中不包含的标签，则删除


@@ -4966,6 +4983,23 @@


            BeanUtils.copyProperties(vo, comPensionAuthPensionerDO);


            comPensionAuthPensionerDO.setIdCard(cardNoAES);


            comPensionAuthPensionerDO.setAddress(vo.getNowAddress());


            if (!comPensionAuthPensionerDO.getIsAlive().equals(1) || !comPensionAuthPensionerDO.getIsRegister().equals(1)) {


                if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) {


                    Date nowDate = new Date();


                    // 获取当前年


                    int year = (DateUtils.getYear(nowDate));


                    ComPensionAuthStatisticsDO comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>()


                            .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId)


                            .eq(ComPensionAuthStatisticsDO::getYear, year));


                    if(null == comPensionAuthStatisticsDO){


                        comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>()


                                .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId)


                                .eq(ComPensionAuthStatisticsDO::getYear, year - 1));


                    }


                    comPensionAuthStatisticsDO.setSum(comPensionAuthStatisticsDO.getSum() + 1);


                    comPensionAuthStatisticsDAO.updateById(comPensionAuthStatisticsDO);


                }


            }


            comPensionAuthPensionerDAO.updateById(comPensionAuthPensionerDO);


        } else {


            comPensionAuthPensionerDO = new ComPensionAuthPensionerDO();


@@ -4977,6 +5011,16 @@


            comPensionAuthPensionerDO.setIdCard(cardNoAES);


            comPensionAuthPensionerDO.setAddress(vo.getNowAddress());


            comPensionAuthPensionerDAO.insert(comPensionAuthPensionerDO);


            if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) {


                Date nowDate = new Date();


                // 获取当前年


                int year = (DateUtils.getYear(nowDate));


                ComPensionAuthStatisticsDO comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>()


                        .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId)


                        .eq(ComPensionAuthStatisticsDO::getYear, year));


                comPensionAuthStatisticsDO.setSum(comPensionAuthStatisticsDO.getSum() + 1);


                comPensionAuthStatisticsDAO.updateById(comPensionAuthStatisticsDO);


            }


        }


        return populationDO;


    }