From c1e48a47b39dbd6919bfd9cf2e7023e9f3d6fee8 Mon Sep 17 00:00:00 2001 From: 101captain <237651143@qq.com> Date: 星期五, 05 十一月 2021 10:24:21 +0800 Subject: [PATCH] 1105测试代码修改 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java | 383 +++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 276 insertions(+), 107 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java index 7938f05..8010f0f 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java @@ -1,18 +1,23 @@ package com.panzhihua.service_community.service.impl; +import static com.panzhihua.common.enums.IdentityApprovalStatusEnum.PASS_THROUGH; +import static com.panzhihua.common.enums.IdentityApprovalStatusEnum.PENDING_REVIEW; +import static com.panzhihua.common.enums.IdentityAuthMethodEnum.FACE_AUTH; +import static com.panzhihua.common.enums.IdentityAuthStatusEnum.CERTIFIED; + import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; +import java.util.Map; import java.util.Objects; import javax.annotation.Resource; -import com.panzhihua.common.model.vos.community.ComElderAuthRecordExcleVO; -import com.panzhihua.common.model.vos.community.ComElderAuthRecordImportExcelVO; -import com.panzhihua.common.model.vos.community.ComElderAuthRecordImportMistakeExcelVO; -import com.panzhihua.common.model.vos.community.ComElderAuthRecordStatisticExcleVO; +import com.panzhihua.service_community.dao.*; +import com.panzhihua.service_community.model.dos.*; +import com.panzhihua.service_community.service.ComElderAuthElderliesService; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -23,35 +28,26 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.panzhihua.common.enums.PopulHouseUseEnum; import com.panzhihua.common.model.dtos.community.AddIdentityAuthDTO; import com.panzhihua.common.model.dtos.community.PageElderAuthRecordsDTO; import com.panzhihua.common.model.dtos.community.PageIdentityAuthRecordDTO; +import com.panzhihua.common.model.dtos.community.elder.PageElderAuthStatisticDTO; import com.panzhihua.common.model.helper.AESUtil; import com.panzhihua.common.model.vos.R; +import com.panzhihua.common.model.vos.community.ComElderAuthRecordExcleVO; +import com.panzhihua.common.model.vos.community.ComElderAuthRecordImportExcelVO; +import com.panzhihua.common.model.vos.community.ComElderAuthRecordImportMistakeExcelVO; +import com.panzhihua.common.model.vos.community.ComElderAuthRecordStatisticExcleVO; import com.panzhihua.common.model.vos.community.ComElderAuthRecordVO; import com.panzhihua.common.utlis.AgeUtils; import com.panzhihua.common.utlis.DateUtils; -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.ComElderAuthElderliesDAO; -import com.panzhihua.service_community.dao.ComElderAuthRecordsDAO; -import com.panzhihua.service_community.dao.ComEldersAuthStatisticsMapper; -import com.panzhihua.service_community.dao.ComMngPopulationDAO; -import com.panzhihua.service_community.model.dos.ComActDO; -import com.panzhihua.service_community.model.dos.ComElderAuthElderliesDO; -import com.panzhihua.service_community.model.dos.ComElderAuthRecordsDO; -import com.panzhihua.service_community.model.dos.ComEldersAuthStatisticsDO; -import com.panzhihua.service_community.model.dos.ComMngPopulationDO; +import com.panzhihua.common.utlis.WxUtil; +import com.panzhihua.common.utlis.WxXCXTempSend; import com.panzhihua.service_community.service.ComElderAuthRecordsService; +import cn.hutool.core.util.IdcardUtil; import lombok.extern.slf4j.Slf4j; - -import static com.panzhihua.common.enums.IdentityApprovalStatusEnum.PASS_THROUGH; -import static com.panzhihua.common.enums.IdentityApprovalStatusEnum.PENDING_REVIEW; -import static com.panzhihua.common.enums.IdentityAuthMethodEnum.FACE_AUTH; -import static com.panzhihua.common.enums.IdentityAuthStatusEnum.CERTIFIED; /** * title: ComElderAuthRecordsServiceImpl 社区政务》高龄老人认证》认证记录表服务实现类 @@ -77,8 +73,20 @@ private ComActDAO comActDAO; @Resource private ComEldersAuthStatisticsMapper comEldersAuthStatisticsMapper; + @Resource + private ComActActSignDAO comActActSignDAO; @Value("${domain.aesKey:}") private String aesKey; + @Resource + private ComEldersAuthHistoryRecordMapper comEldersAuthHistoryRecordMapper; + @Resource + private ComPensionAuthHistoryRecordMapper comPensionAuthHistoryRecordMapper; + @Resource + private ComPensionAuthRecordDAO comPensionAuthRecordDAO; + @Resource + private ComPensionAuthPensionerDAO comPensionAuthPensionerDAO; + @Resource + private ComElderAuthElderliesService comElderAuthElderliesService; @Override public R pageElderAuthRecords(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) { @@ -93,6 +101,15 @@ } page.setSize(pageSize); page.setCurrent(pageNum); + + try { + //关键词为空时需要进行加密,通过加密去检索身份证号筛选高龄认证记录 + String idCard = AESUtil.encrypt128(pageElderAuthRecordsDTO.getSearchKey(), aesKey); + pageElderAuthRecordsDTO.setIdCard(idCard); + }catch (Exception e){ + log.error("查询高龄认证记录转换身份证号失败"); + } + IPage<ComElderAuthRecordVO> iPage = comElderAuthRecordsDAO.pageElderAuthRecords(page, pageElderAuthRecordsDTO); if (!iPage.getRecords().isEmpty()) { iPage.getRecords().forEach(comElderAuthRecordVO -> { @@ -107,6 +124,12 @@ @Override public R detailElderAuthRecords(Long authRecordId) { ComElderAuthRecordVO comElderAuthRecordVO = comElderAuthRecordsDAO.detailElderAuthRecords(authRecordId); + comElderAuthRecordVO.setNextIds(comElderAuthRecordsDAO.getNextIds(comElderAuthRecordVO.getCommunityId(),authRecordId)); + try { + comElderAuthRecordVO.setAge(IdcardUtil.getAgeByIdCard(comElderAuthRecordVO.getIdCard())); + }catch (Exception e){ + log.error("身份证转换失败"); + } return R.ok(comElderAuthRecordVO); } @@ -116,16 +139,49 @@ if (comElderAuthRecordsDO == null) { return R.fail("未查询到高龄老人认证记录"); } - BeanUtils.copyProperties(comElderAuthRecordVO, comElderAuthRecordsDO); - if (comElderAuthRecordVO.getApprovalStatus().equals(PASS_THROUGH.getStatus())) { - comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus()); + if(!comElderAuthRecordsDO.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.dsh)){ + return R.fail("该记录已审核,不可重复审核"); } - comElderAuthRecordsDO.setApprovalDate(new Date()); + ComElderAuthElderliesDO authElderliesDO = comElderAuthElderliesDAO.selectById(comElderAuthRecordsDO.getElderliesId()); + if(authElderliesDO == null){ + return R.fail("未查询到老人信息"); + } + + Date nowDate = new Date(); + BeanUtils.copyProperties(comElderAuthRecordVO, comElderAuthRecordsDO); + comElderAuthRecordsDO.setApprovalDate(nowDate); + if (comElderAuthRecordVO.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.tg)) { + comElderAuthRecordsDO.setAuthStatus(ComElderAuthRecordsDO.authStatus.yrz); + sendAuthSubscribe(comElderAuthRecordsDO.getSubmitUserId(), "高龄认证", "认证成功!"); + + authElderliesDO.setAddress(comElderAuthRecordVO.getAddress()); + comElderAuthElderliesDAO.updateById(authElderliesDO); + } else { + sendAuthSubscribe(comElderAuthRecordsDO.getSubmitUserId(), "高龄认证", comElderAuthRecordVO.getRejectReason()); + } +// comElderAuthRecordsDO.setApprovalDate(new Date()); int nub = comElderAuthRecordsDAO.updateById(comElderAuthRecordsDO); if (nub < 1) { return R.fail("审核失败"); } return R.ok(); + } + + private void sendAuthSubscribe(Long userId, String name, String result) { + //发送订阅通知 + Map<String, String> map = comActActSignDAO.getUserOpenId(userId); + if (map != null) { + String openid = map.get("openid"); + try { + WxXCXTempSend util = new WxXCXTempSend(); + String accessToken = util.getAppAccessToken(); + WxUtil.sendSubscribeRZSH(openid, accessToken, name, + DateUtils.format(new Date(), DateUtils.ymdhms_format), + result); + } catch (Exception e) { + log.error("推送审核状态订阅消息失败,失败原因:" + e.getMessage()); + } + } } @Override @@ -162,7 +218,11 @@ List<ComElderAuthRecordsDO> saveList = new ArrayList<>(); // 需要修改的认证记录集合 List<ComElderAuthRecordsDO> updateList = new ArrayList<>(); + //需要更新的老人信息 + List<ComElderAuthElderliesDO> updateElderliesList = new ArrayList<>(); log.info("开始处理导入数据"); + + List<ComElderAuthRecordImportMistakeExcelVO> mistakes = new ArrayList<>(); try { // 查询所有人口数据放入HashMap中 @@ -172,9 +232,8 @@ String key = population.getCardNo(); populationMap.put(key, population); }); - + Date nowDate = new Date(); for (ComElderAuthRecordImportExcelVO vo : list) { - String cardNoAES = AESUtil.encrypt128(vo.getIdCard(), aesKey); // 判断实有人口是否已存在 log.info("开始查询实有人口是否已存在"); ComMngPopulationDO populationDO = null; @@ -188,58 +247,64 @@ if (null == comElderAuthElderliesDO) { ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO(); BeanUtils.copyProperties(vo, mistake); - setMistake(mistake, vo); - mistake.setMistake("该实有人口已存在,但本社区不存在高龄信息,请先导入高龄人口"); + mistake.setMistake("该实有人口已存在,但本社区不存在高龄老人信息,请先导入高龄老人"); + mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format)); mistakes.add(mistake); }else { //存在高龄信息,判断是否满足认证条件 if (StringUtils.isNotEmpty(vo.getBirthday())) { - int age = AgeUtils.getAgeFromBirthTimes(vo.getBirthday()); + int age = IdcardUtil.getAgeByIdCard(vo.getIdCard()); if (age < 80 || !comElderAuthElderliesDO.getIsRegister().equals(1) || !comElderAuthElderliesDO.getIsAlive().equals(1)) { ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO(); BeanUtils.copyProperties(vo, mistake); - setMistake(mistake, vo); mistake.setMistake("该人口未满80岁,或者不健在,或者未做高龄老人登记"); + mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format)); mistakes.add(mistake); }else { + //满足认证条件,判断是否存在当期认证记录 + List<ComElderAuthRecordsDO> elderAuthRecordList = null; ComElderAuthRecordsDO comElderAuthRecordsDO = null; - Date nowDate = new Date(); - // 获取当前年 - int year = DateUtils.getYear(nowDate); - // 获取当前月 - int month = DateUtils.getMonth(nowDate) + 1; - String authPeriod = ""; - if (month < 10) { - authPeriod = String.valueOf(year) + "0" + String.valueOf(month); - }else { - authPeriod = String.valueOf(year) + String.valueOf(month); - } - comElderAuthRecordsDO = comElderAuthRecordsDAO.selectOne(new QueryWrapper<ComElderAuthRecordsDO>().lambda(). - eq(ComElderAuthRecordsDO::getElderliesId, comElderAuthElderliesDO.getId()).eq(ComElderAuthRecordsDO::getAuthPeriod, authPeriod)); - if (null != comElderAuthRecordsDO) { + String authPeriod = vo.getAuthPeriod(); + elderAuthRecordList = comElderAuthRecordsDAO.selectList(new QueryWrapper<ComElderAuthRecordsDO>().lambda() + .eq(ComElderAuthRecordsDO::getElderliesId, comElderAuthElderliesDO.getId()) + .eq(ComElderAuthRecordsDO::getAuthPeriod, authPeriod).orderByDesc(ComElderAuthRecordsDO::getCreateAt)); + if (null != elderAuthRecordList && elderAuthRecordList.size() > 0) { + comElderAuthRecordsDO = elderAuthRecordList.get(0); //存在记录且状态为已认证,不能修改 - if (comElderAuthRecordsDO.getAuthStatus().equals(CERTIFIED.getStatus())) { + if (comElderAuthRecordsDO.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.tg)) { ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO(); BeanUtils.copyProperties(vo, mistake); - setMistake(mistake, vo); - mistake.setMistake("该人口本期已认证,不能修改"); + mistake.setMistake("该人口本期已认证通过,不能重复认证"); + mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format)); mistakes.add(mistake); + }else if (comElderAuthRecordsDO.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.dsh)) { + comElderAuthRecordsDO = updateElderAuthRecordsDO(vo, comElderAuthRecordsDO,userId,communityId,nowDate); + updateList.add(comElderAuthRecordsDO); + + if(StringUtils.isNotEmpty(vo.getAddress())){ + comElderAuthElderliesDO.setAddress(vo.getAddress()); + updateElderliesList.add(comElderAuthElderliesDO); + } }else { - //存在记录,执行修改 - ComElderAuthRecordsDO comElderAuthRecordsDO1 = - updateElderAuthRecordsDO(vo, comElderAuthRecordsDO, userId); - updateList.add(comElderAuthRecordsDO1); - ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO(); - BeanUtils.copyProperties(vo, mistake); - setMistake(mistake, vo); - mistake.setMistake("该认证已存在,执行更新"); - mistakes.add(mistake); + // 驳回状态,则新增 + comElderAuthRecordsDO = saveElderAuthRecordsDO(vo, comElderAuthElderliesDO, authPeriod, userId,communityId,nowDate); + saveList.add(comElderAuthRecordsDO); + + if(StringUtils.isNotEmpty(vo.getAddress())){ + comElderAuthElderliesDO.setAddress(vo.getAddress()); + updateElderliesList.add(comElderAuthElderliesDO); + } } }else { // 不存在记录,则新增 - comElderAuthRecordsDO = saveElderAuthRecordsDO(vo, comElderAuthElderliesDO, authPeriod, userId); + comElderAuthRecordsDO = saveElderAuthRecordsDO(vo, comElderAuthElderliesDO, authPeriod, userId,communityId,nowDate); saveList.add(comElderAuthRecordsDO); + + if(StringUtils.isNotEmpty(vo.getAddress())){ + comElderAuthElderliesDO.setAddress(vo.getAddress()); + updateElderliesList.add(comElderAuthElderliesDO); + } } } } @@ -248,8 +313,8 @@ // 不存在实有人口,则新增 ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO(); BeanUtils.copyProperties(vo, mistake); - setMistake(mistake, vo); mistake.setMistake("不存在该实有人口,请先导入实有人口信息"); + mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format)); mistakes.add(mistake); } log.info("开始查询实有人口是否已存在完成"); @@ -270,6 +335,9 @@ comElderAuthRecordsDAO.updateAll(updateList); log.info("数据库更新线下认证记录完成"); } + if(!updateElderliesList.isEmpty()){ + comElderAuthElderliesService.updateBatchById(updateElderliesList); + } log.info("执行数据库导入完成"); if (!mistakes.isEmpty()) { @@ -280,7 +348,7 @@ } @Override - public R exportElderAuthRecordsStatistic(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) { + public R exportElderAuthRecordsStatistic(PageElderAuthStatisticDTO pageElderAuthRecordsDTO) { List<ComElderAuthRecordStatisticExcleVO> comElderAuthRecordStatisticExcleVOS = comElderAuthRecordsDAO.exportElderAuthRecordsStatistic(pageElderAuthRecordsDTO); if (null != comElderAuthRecordStatisticExcleVOS && comElderAuthRecordStatisticExcleVOS.size() > 0) { comElderAuthRecordStatisticExcleVOS.forEach(comElderAuthRecordStatisticExcleVO -> { @@ -292,75 +360,143 @@ return R.ok(comElderAuthRecordStatisticExcleVOS); } + /** + * 身份认证定时任务 + * @return 执行结果 + */ @Override + @Transactional(rollbackFor = Exception.class) public R timedTaskElderAuthStatisticsJobHandler() { - Date nowDate = new Date(); - int month = DateUtils.getMonth(nowDate) + 1; - int year = DateUtils.getYear(nowDate); - //查询所有启用中社区 - List<ComActDO> actList = comActDAO.selectList(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getState,0)); - actList.forEach(act -> { - //高龄认证统计本期应认证人数 - ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = new ComEldersAuthStatisticsDO(); - comEldersAuthStatisticsDO.setCommunityId(act.getCommunityId()); - comEldersAuthStatisticsDO.setMonth(month); - comEldersAuthStatisticsDO.setYear(year); - comEldersAuthStatisticsDO.setCreateAt(nowDate); - List<ComElderAuthElderliesDO> comElderAuthElderliesDOS = comElderAuthElderliesDAO.selectList(new QueryWrapper<ComElderAuthElderliesDO>().lambda() - .eq(ComElderAuthElderliesDO::getCommunityId, act.getCommunityId()) - .eq(ComElderAuthElderliesDO::getIsAlive, 1) - .eq(ComElderAuthElderliesDO::getIsRegister, 1)); - if (null != comElderAuthElderliesDOS) { - comEldersAuthStatisticsDO.setSum(comElderAuthElderliesDOS.size()); + //查询高龄认证记录列表 + List<ComElderAuthRecordsDO> authRecordsList = comElderAuthRecordsDAO.selectList(new QueryWrapper<ComElderAuthRecordsDO>().lambda() + .eq(ComElderAuthRecordsDO::getAuthStatus,ComElderAuthRecordsDO.authStatus.yrz)); + //遍历高龄认证记录列表 + authRecordsList.forEach(authRecords -> { + if(authRecords.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.tg)){ + ComEldersAuthHistoryRecordDO authHistoryRecordDO = comEldersAuthHistoryRecordMapper.selectOne(new QueryWrapper<ComEldersAuthHistoryRecordDO>().lambda() + .eq(ComEldersAuthHistoryRecordDO::getElderliesId,authRecords.getElderliesId()) + .eq(ComEldersAuthHistoryRecordDO::getAuthPeriod,authRecords.getAuthPeriod())); + if(authHistoryRecordDO != null){//存在记录 + if(authHistoryRecordDO.getIsAuth().equals(ComEldersAuthHistoryRecordDO.isAuth.no)){ + //查询老人信息 + ComElderAuthElderliesDO authElderliesDO = comElderAuthElderliesDAO.selectById(authRecords.getElderliesId()); + if(authElderliesDO != null){ + Long authId = authHistoryRecordDO.getId(); + BeanUtils.copyProperties(authElderliesDO,authHistoryRecordDO); + authHistoryRecordDO.setId(authId); + authHistoryRecordDO.setBrithday(DateUtils.format(IdcardUtil.getBirthDate(authElderliesDO.getIdCard()),DateUtils.yyyyMMdd_format)); + authHistoryRecordDO.setAge(IdcardUtil.getAgeByIdCard(authElderliesDO.getIdCard())); + } + authHistoryRecordDO.setIsAuth(ComEldersAuthHistoryRecordDO.isAuth.yes); + authHistoryRecordDO.setAuthDate(authRecords.getApprovalDate()); + authHistoryRecordDO.setApprovalDate(authRecords.getApprovalDate()); + authHistoryRecordDO.setApproverId(authRecords.getApproverId()); + authHistoryRecordDO.setSubmitUserId(authRecords.getSubmitUserId()); + authHistoryRecordDO.setAuthMethod(authRecords.getAuthMethod()); + authHistoryRecordDO.setVerificationResult(authRecords.getVerificationResult()); + authHistoryRecordDO.setAuthId(authRecords.getId()); + + comEldersAuthHistoryRecordMapper.updateById(authHistoryRecordDO); + } + }else{ + authHistoryRecordDO = new ComEldersAuthHistoryRecordDO(); + //查询老人信息 + ComElderAuthElderliesDO authElderliesDO = comElderAuthElderliesDAO.selectById(authRecords.getElderliesId()); + if(authElderliesDO != null){ + BeanUtils.copyProperties(authElderliesDO,authHistoryRecordDO); + authHistoryRecordDO.setBrithday(DateUtils.format(IdcardUtil.getBirthDate(authElderliesDO.getIdCard()),DateUtils.yyyyMMdd_format)); + authHistoryRecordDO.setAge(IdcardUtil.getAgeByIdCard(authElderliesDO.getIdCard())); + } + BeanUtils.copyProperties(authRecords,authHistoryRecordDO); + authHistoryRecordDO.setAuthDate(authRecords.getApprovalDate()); + authHistoryRecordDO.setMark(null); + authHistoryRecordDO.setIsAuth(ComEldersAuthHistoryRecordDO.isAuth.yes); + authHistoryRecordDO.setAuthId(authRecords.getId()); + comEldersAuthHistoryRecordMapper.insert(authHistoryRecordDO); + } } - comEldersAuthStatisticsMapper.insert(comEldersAuthStatisticsDO); - //上期已认证人数 - String authPeriod = ""; - if (month < 10) { - authPeriod = String.valueOf(year) + 0 + month; - } else { - authPeriod = String.valueOf(year) + month; + }); + + //查询养老认证记录列表 + List<ComPensionAuthRecordDO> pensionAuthList = comPensionAuthRecordDAO.selectList(new QueryWrapper<ComPensionAuthRecordDO>().lambda() + .eq(ComPensionAuthRecordDO::getAuthStatus,ComPensionAuthRecordDO.authStatus.rez)); + //遍历养老认证记录列表 + pensionAuthList.forEach(authRecords -> { + ComPensionAuthHistoryRecordDO pensionAuthDO = comPensionAuthHistoryRecordMapper.selectOne(new QueryWrapper<ComPensionAuthHistoryRecordDO>().lambda() + .eq(ComPensionAuthHistoryRecordDO::getElderliesId,authRecords.getPensionerId()) + .eq(ComPensionAuthHistoryRecordDO::getAuthPeriod,authRecords.getAuthPeriod())); + if(pensionAuthDO != null){//存在记录 + if(pensionAuthDO.getIsAuth().equals(ComPensionAuthHistoryRecordDO.isAuth.no)){ + //查询老人信息 + ComPensionAuthPensionerDO authPensionerDO = comPensionAuthPensionerDAO.selectById(authRecords.getPensionerId()); + if(authPensionerDO != null){ + Long authId = pensionAuthDO.getId(); + BeanUtils.copyProperties(authPensionerDO,pensionAuthDO); + pensionAuthDO.setId(authId); + pensionAuthDO.setBrithday(DateUtils.format(IdcardUtil.getBirthDate(authPensionerDO.getIdCard()),DateUtils.yyyyMMdd_format)); + pensionAuthDO.setAge(IdcardUtil.getAgeByIdCard(authPensionerDO.getIdCard())); + } + pensionAuthDO.setIsAuth(ComPensionAuthHistoryRecordDO.isAuth.yes); + pensionAuthDO.setAuthDate(authRecords.getApprovalDate()); + pensionAuthDO.setApprovalDate(authRecords.getApprovalDate()); + pensionAuthDO.setApproverId(authRecords.getApproverId()); + pensionAuthDO.setSubmitUserId(authRecords.getSubmitUserId()); + pensionAuthDO.setAuthMethod(authRecords.getAuthMethod()); + pensionAuthDO.setVerificationResult(authRecords.getVerificationResult()); + pensionAuthDO.setAuthId(authRecords.getId()); + comPensionAuthHistoryRecordMapper.updateById(pensionAuthDO); + } + }else{ + pensionAuthDO = new ComPensionAuthHistoryRecordDO(); + //查询老人信息 + ComPensionAuthPensionerDO authPensionerDO = comPensionAuthPensionerDAO.selectById(authRecords.getPensionerId()); + if(authPensionerDO != null){ + BeanUtils.copyProperties(authPensionerDO,pensionAuthDO); + pensionAuthDO.setBrithday(DateUtils.format(IdcardUtil.getBirthDate(authPensionerDO.getIdCard()),DateUtils.yyyyMMdd_format)); + pensionAuthDO.setAge(IdcardUtil.getAgeByIdCard(authPensionerDO.getIdCard())); + } + BeanUtils.copyProperties(authRecords,pensionAuthDO); + pensionAuthDO.setAuthDate(authRecords.getApprovalDate()); + pensionAuthDO.setMark(null); + pensionAuthDO.setIsAuth(ComPensionAuthHistoryRecordDO.isAuth.yes); + pensionAuthDO.setAuthId(authRecords.getId()); + comPensionAuthHistoryRecordMapper.insert(pensionAuthDO); } - int authSum = comElderAuthElderliesDAO.haveElderAuthElderliesAmount(act.getCommunityId(), authPeriod); - ComEldersAuthStatisticsDO comEldersAuthStatisticsDO1 = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() - .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, act.getCommunityId()).eq(ComEldersAuthStatisticsDO::getYear, year) - .eq(ComEldersAuthStatisticsDO::getMonth, month - 1)); - comEldersAuthStatisticsDO1.setAuthSum(authSum); - comEldersAuthStatisticsDO1.setNoAuthSum(comEldersAuthStatisticsDO1.getSum() - comEldersAuthStatisticsDO1.getAuthSum()); - comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO1); }); return R.ok(); } - private ComElderAuthRecordsDO updateElderAuthRecordsDO(ComElderAuthRecordImportExcelVO vo, ComElderAuthRecordsDO comElderAuthRecordsDO, Long userId) { + private ComElderAuthRecordsDO updateElderAuthRecordsDO(ComElderAuthRecordImportExcelVO vo + , ComElderAuthRecordsDO comElderAuthRecordsDO, Long userId, Long communityId,Date date) { BeanUtils.copyProperties(vo, comElderAuthRecordsDO); comElderAuthRecordsDO.setSubmitUserId(userId); comElderAuthRecordsDO.setApproverId(userId); - comElderAuthRecordsDO.setApprovalStatus(PASS_THROUGH.getStatus()); - comElderAuthRecordsDO.setApprovalDate(new Date()); - comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus()); + comElderAuthRecordsDO.setCommunityId(communityId); + comElderAuthRecordsDO.setApprovalStatus(ComElderAuthRecordsDO.approvalStatus.tg); + comElderAuthRecordsDO.setApprovalDate(date); + comElderAuthRecordsDO.setAuthStatus(ComElderAuthRecordsDO.authStatus.yrz); + comElderAuthRecordsDO.setAuthMethod(ComElderAuthRecordsDO.authMethod.xxrz); + comElderAuthRecordsDO.setMark(vo.getMark()); return comElderAuthRecordsDO; } - private ComElderAuthRecordsDO saveElderAuthRecordsDO(ComElderAuthRecordImportExcelVO vo, ComElderAuthElderliesDO comElderAuthElderliesDO, String authPeriod, Long userId) { + private ComElderAuthRecordsDO saveElderAuthRecordsDO(ComElderAuthRecordImportExcelVO vo + , ComElderAuthElderliesDO comElderAuthElderliesDO, String authPeriod, Long userId, Long communityId,Date date) { ComElderAuthRecordsDO comElderAuthRecordsDO = new ComElderAuthRecordsDO(); BeanUtils.copyProperties(vo, comElderAuthRecordsDO); - comElderAuthRecordsDO.setId(Snowflake.getId()); comElderAuthRecordsDO.setElderliesId(comElderAuthElderliesDO.getId()); comElderAuthRecordsDO.setAuthPeriod(authPeriod); comElderAuthRecordsDO.setSubmitUserId(userId); comElderAuthRecordsDO.setApproverId(userId); - comElderAuthRecordsDO.setApprovalStatus(PASS_THROUGH.getStatus()); - comElderAuthRecordsDO.setApprovalDate(new Date()); - comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus()); + comElderAuthRecordsDO.setApprovalStatus(ComElderAuthRecordsDO.approvalStatus.tg); + comElderAuthRecordsDO.setApprovalDate(date); + comElderAuthRecordsDO.setAuthStatus(ComElderAuthRecordsDO.authStatus.yrz); + comElderAuthRecordsDO.setCommunityId(communityId); + comElderAuthRecordsDO.setAuthMethod(ComElderAuthRecordsDO.authMethod.xxrz); + comElderAuthRecordsDO.setMark(vo.getMark()); + comElderAuthRecordsDO.setCreateAt(date); return comElderAuthRecordsDO; } - - private void setMistake(ComElderAuthRecordImportMistakeExcelVO mvo, - ComElderAuthRecordImportExcelVO vo) { - mvo.setIsAlive(PopulHouseUseEnum.getCnDescByName(vo.getIsAlive())); - } - /** * 判重方法 @@ -431,6 +567,9 @@ if (this.baseMapper.insert(comElderAuthRecordsDO) < 0) { return R.fail("认证失败,请重新尝试"); } + if (addIdentityAuthDTO.getAuthMethod().intValue() == FACE_AUTH.getMethod()) { + sendAuthSubscribe(addIdentityAuthDTO.getSubmitUserId(), "高龄认证", "认证成功!"); + } return R.ok(); } @@ -454,4 +593,34 @@ public R retrieveElderAuthDetail(Long identityAuthId) { return R.ok(comElderAuthRecordsDAO.findById(identityAuthId)); } + + @Override + public R add(ComElderAuthRecordVO comElderAuthRecordVO) { + if(!comElderAuthRecordVO.getIdCard().isEmpty()){ + List<ComMngPopulationDO> comMngPopulationDOS=comMngPopulationDAO.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getCardNoStr,comElderAuthRecordVO.getIdCard()).orderByDesc(ComMngPopulationDO::getCreateAt)); + if(!comMngPopulationDOS.isEmpty()){ + ComMngPopulationDO comMngPopulationDO=comMngPopulationDOS.get(0); + ComElderAuthElderliesDO comElderAuthElderliesDO=comElderAuthElderliesDAO.selectOne(new QueryWrapper<ComElderAuthElderliesDO>().lambda().eq(ComElderAuthElderliesDO::getPopulationId,comMngPopulationDO.getId())); + if(comElderAuthElderliesDO!=null){ + Integer count=comElderAuthRecordsDAO.selectCount(new QueryWrapper<ComElderAuthRecordsDO>().lambda().eq(ComElderAuthRecordsDO::getElderliesId,comElderAuthElderliesDO.getId()).eq(ComElderAuthRecordsDO::getAuthPeriod,comElderAuthRecordVO.getAuthPeriod())); + if(count==0){ + ComElderAuthRecordsDO comElderAuthRecordsDO=new ComElderAuthRecordsDO(); + BeanUtils.copyProperties(comElderAuthRecordVO,comElderAuthRecordsDO); + comElderAuthRecordsDO.setApprovalStatus(PASS_THROUGH.getStatus()); + comElderAuthRecordsDO.setApprovalDate(new Date()); + comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus()); + comElderAuthRecordsDO.setAuthMethod(ComPensionAuthRecordDO.authMethod.xxrz); + if (this.baseMapper.insert(comElderAuthRecordsDO) < 0) { + return R.fail("认证失败,请重新尝试"); + } + return R.ok(); + } + return R.fail("当前期数已认证,请勿重复认证"); + } + return R.fail("无养老认证数据"); + } + return R.fail("该身份证无实有人口信息"); + } + return R.fail("身份证不能为空"); + } } -- Gitblit v1.7.1