From 0fb38e938ff2f943a6b8cc5c3247a23fc1276d24 Mon Sep 17 00:00:00 2001 From: 101captain <237651143@qq.com> Date: 星期一, 11 十月 2021 16:47:18 +0800 Subject: [PATCH] 爱心义仓代码提交 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComElderAuthRecordsServiceImpl.java | 151 +++++++++++++++++++++++++++++++++++--------------- 1 files changed, 105 insertions(+), 46 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 6f809d7..92cb759 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 @@ -15,6 +15,8 @@ import javax.annotation.Resource; +import com.panzhihua.service_community.dao.*; +import com.panzhihua.service_community.model.dos.*; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -38,21 +40,9 @@ 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.common.utlis.WxUtil; import com.panzhihua.common.utlis.WxXCXTempSend; -import com.panzhihua.service_community.dao.ComActActSignDAO; -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.service_community.service.ComElderAuthRecordsService; import cn.hutool.core.util.IdcardUtil; @@ -86,6 +76,14 @@ 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; @Override public R pageElderAuthRecords(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) { @@ -155,7 +153,7 @@ } else { sendAuthSubscribe(comElderAuthRecordsDO.getSubmitUserId(), "高龄认证", comElderAuthRecordVO.getRejectReason()); } - comElderAuthRecordsDO.setApprovalDate(new Date()); +// comElderAuthRecordsDO.setApprovalDate(new Date()); int nub = comElderAuthRecordsDAO.updateById(comElderAuthRecordsDO); if (nub < 1) { return R.fail("审核失败"); @@ -335,42 +333,104 @@ 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){ + BeanUtils.copyProperties(authElderliesDO,authHistoryRecordDO); + authHistoryRecordDO.setBrithday(IdcardUtil.getBirthByIdCard(authElderliesDO.getIdCard())); + 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(IdcardUtil.getBirthByIdCard(authElderliesDO.getIdCard())); + 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){ + BeanUtils.copyProperties(authPensionerDO,pensionAuthDO); + pensionAuthDO.setBrithday(IdcardUtil.getBirthByIdCard(authPensionerDO.getIdCard())); + 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(IdcardUtil.getBirthByIdCard(authPensionerDO.getIdCard())); + 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(); } @@ -393,7 +453,6 @@ , 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); -- Gitblit v1.7.1