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