From a18634e047b46e411dac268a0b3a995c22053ea5 Mon Sep 17 00:00:00 2001 From: tangxiaobao <303826152@qq.com> Date: 星期一, 06 九月 2021 09:18:44 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/test' into txb --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/EldersAuthServiceImpl.java | 71 +++++++++++++++++++++++++++++++++++ 1 files changed, 71 insertions(+), 0 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/EldersAuthServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/EldersAuthServiceImpl.java index 01f27d6..dc2ff75 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/EldersAuthServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/EldersAuthServiceImpl.java @@ -3,9 +3,11 @@ import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Map; import javax.annotation.Resource; +import com.panzhihua.common.model.vos.elders.ComEldersAuthHistoryVO; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -60,6 +62,8 @@ private ComEldersAuthHistoryRecordMapper comEldersAuthHistoryRecordMapper; @Resource private ComEldersAuthStatisticsMapper comEldersAuthStatisticsMapper; + @Resource + private ComActDAO comActDAO; @Value("${domain.aesKey:}") private String aesKey; @@ -524,4 +528,71 @@ }); return R.ok(authHistoryExcelVOS); } + + @Override + @Transactional(rollbackFor = Exception.class) + public R timedTaskEldersAuthJobHandler(){ + + Date nowDate = new Date(); + //查询所有启用中社区 + List<ComActDO> actList = comActDAO.selectList(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getState,0)); + + actList.forEach(act -> { + //查询社区老人认证统计信息,并存储到数据库中 + Map<String,String> resultMap = this.baseMapper.getEldersAuthStatistics(act.getCommunityId()); + if(resultMap != null){ + ComEldersAuthStatisticsDO authStatisticsDO = new ComEldersAuthStatisticsDO(); + authStatisticsDO.setCommunityId(act.getCommunityId()); + authStatisticsDO.setMonth(DateUtils.getMonth(nowDate)); + authStatisticsDO.setYear(DateUtils.getYear(nowDate)); + authStatisticsDO.setCreateAt(nowDate); + authStatisticsDO.setSum(Integer.parseInt(resultMap.get("oldCount"))); + authStatisticsDO.setNoAuthSum(Integer.parseInt(resultMap.get("noCount"))); + authStatisticsDO.setAuthSum(Integer.parseInt(resultMap.get("yesCount"))); + comEldersAuthStatisticsMapper.insert(authStatisticsDO); + } + }); + //重置所有人的认证状态 + comEldersAuthUserMapper.updateAuthStatus(); + return R.ok(); + } + + /** + * 检测上月所有视频认证记录,取最后一条记录为认证成功记录 + * @return 执行结果 + */ + @Override + @Transactional(rollbackFor = Exception.class) + public R timedTaskEldersRecordAuthJobHandler(){ + Date nowDate = new Date(); + //查询所有启用中社区 + List<ComActDO> actList = comActDAO.selectList(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getState,0)); + + actList.forEach(act -> { + //查询社区上月所有视频认证 + List<ComEldersAuthHistoryVO> authList = eldersAuthDAO.getEldersAuthRecords(act.getCommunityId()); + authList.forEach(auth -> { + if(auth.getUserId() != null){ + ComEldersAuthHistoryRecordDO authHistoryRecordDO = new ComEldersAuthHistoryRecordDO(); + authHistoryRecordDO.setCommunityId(auth.getCommunityId()); + authHistoryRecordDO.setCreateAt(auth.getCreateAt()); + authHistoryRecordDO.setAuthId(auth.getId()); + authHistoryRecordDO.setUserId(auth.getUserId()); + authHistoryRecordDO.setBrithday(auth.getBirthday()); + authHistoryRecordDO.setDomicile(auth.getDomicile()); + authHistoryRecordDO.setIdCard(auth.getIdCard()); + authHistoryRecordDO.setName(auth.getName()); + authHistoryRecordDO.setIsAuth(1); + try { + Integer age = IdcardUtil.getAgeByIdCard(auth.getIdCard()); + authHistoryRecordDO.setAge(age); + }catch (Exception e){ + log.error("年龄转换失败"); + } + comEldersAuthHistoryRecordMapper.insert(authHistoryRecordDO); + } + }); + }); + return R.ok(); + } } -- Gitblit v1.7.1