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