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.user.SysTemplateConfigVO;
|
import com.panzhihua.common.service.user.UserService;
|
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;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
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.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.StringUtils;
|
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;
|
|
/**
|
* title: ComElderAuthRecordsServiceImpl 社区政务》高龄老人认证》认证记录表服务实现类
|
* projectName 成都呐喊信息技术有限公司-智慧社区项目
|
* description: 社区政务》高龄老人认证》认证记录表服务实现类
|
*
|
* @author txb
|
* @date 2021/9/01 14:12
|
*/
|
@Slf4j
|
@Service
|
public class ComElderAuthRecordsServiceImpl extends ServiceImpl<ComElderAuthRecordsDAO, ComElderAuthRecordsDO> implements ComElderAuthRecordsService {
|
|
@Resource
|
private ComElderAuthRecordsDAO comElderAuthRecordsDAO;
|
@Resource
|
private ComElderAuthElderliesDAO comElderAuthElderliesDAO;
|
@Resource
|
private ComMngPopulationDAO comMngPopulationDAO;
|
@Resource
|
private ComElderAuthRecordsService comElderAuthRecordsService;
|
@Resource
|
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;
|
@Resource
|
private UserService userService;
|
|
@Override
|
public R pageElderAuthRecords(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) {
|
Page page = new Page<>();
|
Long pageNum = pageElderAuthRecordsDTO.getPageNum();
|
Long pageSize = pageElderAuthRecordsDTO.getPageSize();
|
if (null == pageNum || 0 == pageNum) {
|
pageNum = 1L;
|
}
|
if (null == pageSize || 0 == pageSize) {
|
pageSize = 10L;
|
}
|
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 -> {
|
if (StringUtils.isNotEmpty(comElderAuthRecordVO.getBirthday())) {
|
comElderAuthRecordVO.setAge(AgeUtils.getAgeFromBirthTimes(comElderAuthRecordVO.getBirthday()));
|
}
|
});
|
}
|
return R.ok(iPage);
|
}
|
|
@Override
|
public R export(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) {
|
try {
|
//关键词为空时需要进行加密，通过加密去检索身份证号筛选高龄认证记录
|
String idCard = AESUtil.encrypt128(pageElderAuthRecordsDTO.getSearchKey(), aesKey);
|
pageElderAuthRecordsDTO.setIdCard(idCard);
|
}catch (Exception e){
|
log.error("查询高龄认证记录转换身份证号失败");
|
}
|
return R.ok(comElderAuthRecordsDAO.export(pageElderAuthRecordsDTO));
|
}
|
|
@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);
|
}
|
|
@Override
|
public R examineElderAuthRecords(ComElderAuthRecordVO comElderAuthRecordVO) {
|
ComElderAuthRecordsDO comElderAuthRecordsDO = comElderAuthRecordsDAO.selectById(comElderAuthRecordVO.getId());
|
if (comElderAuthRecordsDO == null) {
|
return R.fail("未查询到高龄老人认证记录");
|
}
|
if(!comElderAuthRecordsDO.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.dsh)){
|
return R.fail("该记录已审核，不可重复审核");
|
}
|
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(), "高龄认证", "认证成功！",comElderAuthRecordVO.getAreaCode());
|
|
authElderliesDO.setAddress(comElderAuthRecordVO.getAddress());
|
comElderAuthElderliesDAO.updateById(authElderliesDO);
|
} else {
|
sendAuthSubscribe(comElderAuthRecordsDO.getSubmitUserId(), "高龄认证", comElderAuthRecordVO.getRejectReason(),comElderAuthRecordVO.getAreaCode());
|
}
|
// 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,String areaCode) {
|
//发送订阅通知
|
Map<String, String> map = comActActSignDAO.getUserOpenId(userId);
|
if (map != null) {
|
String openid = map.get("openid");
|
try {
|
WxXCXTempSend util = new WxXCXTempSend();
|
String accessToken = util.getAccessToken();
|
R<SysTemplateConfigVO> sysTemplateConfigVO=userService.selectTemplate(areaCode,5);
|
WxUtil.sendSubscribeRZSH(openid, accessToken, name,
|
DateUtils.format(new Date(), DateUtils.ymdhms_format),
|
result,sysTemplateConfigVO.getData().getTemplateId());
|
} catch (Exception e) {
|
log.error("推送审核状态订阅消息失败，失败原因：" + e.getMessage());
|
}
|
}
|
}
|
|
@Override
|
public R signElderAuthRecords(ComElderAuthRecordVO comElderAuthRecordVO) {
|
ComElderAuthRecordsDO comElderAuthRecordsDO = comElderAuthRecordsDAO.selectById(comElderAuthRecordVO.getId());
|
if (comElderAuthRecordsDO == null) {
|
return R.fail("未查询到高龄老人认证记录");
|
}
|
BeanUtils.copyProperties(comElderAuthRecordVO, comElderAuthRecordsDO);
|
int nub = comElderAuthRecordsDAO.updateById(comElderAuthRecordsDO);
|
if (nub < 1) {
|
return R.fail("标记失败");
|
}
|
return R.ok();
|
}
|
|
@Override
|
public R getElderAuthRecordsByIds(List<Long> ids) {
|
List<ComElderAuthRecordExcleVO> comElderAuthRecordExcleVOS = comElderAuthRecordsDAO.getElderAuthRecordsByIds(ids);
|
if (null != comElderAuthRecordExcleVOS && comElderAuthRecordExcleVOS.size() > 0) {
|
comElderAuthRecordExcleVOS.forEach(comElderAuthRecordExcleVO -> {
|
if (StringUtils.isNotEmpty(comElderAuthRecordExcleVO.getBirthday())) {
|
comElderAuthRecordExcleVO.setAge(AgeUtils.getAgeFromBirthTimes(comElderAuthRecordExcleVO.getBirthday()));
|
}
|
});
|
}
|
return R.ok(comElderAuthRecordExcleVOS);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R listSaveElderAuthRecordExcelVO(List<ComElderAuthRecordImportExcelVO> list, Long communityId, Long userId) {
|
// 需要新增的认证记录集合
|
List<ComElderAuthRecordsDO> saveList = new ArrayList<>();
|
// 需要修改的认证记录集合
|
List<ComElderAuthRecordsDO> updateList = new ArrayList<>();
|
//需要更新的老人信息
|
List<ComElderAuthElderliesDO> updateElderliesList = new ArrayList<>();
|
log.info("开始处理导入数据");
|
|
|
List<ComElderAuthRecordImportMistakeExcelVO> mistakes = new ArrayList<>();
|
try {
|
// 查询所有人口数据放入HashMap中
|
// List<ComMngPopulationDO> populationList = comMngPopulationDAO.selectList(null);
|
List<ComMngPopulationDO> populationList = comMngPopulationDAO.selectListIds();
|
HashMap<String, Object> populationMap = new HashMap<>();
|
populationList.forEach(population -> {
|
String key = population.getCardNo();
|
populationMap.put(key, population);
|
});
|
Date nowDate = new Date();
|
for (ComElderAuthRecordImportExcelVO vo : list) {
|
// 判断实有人口是否已存在
|
log.info("开始查询实有人口是否已存在");
|
ComMngPopulationDO populationDO = null;
|
String populationKey = vo.getIdCard();
|
if (!isOnly(populationKey, populationMap)) {
|
// 存在实有人口信息，则查询高龄信息（是否符合认证条件（健在且登记了高龄认证））
|
populationDO = (ComMngPopulationDO)populationMap.get(populationKey);
|
ComElderAuthElderliesDO comElderAuthElderliesDO = comElderAuthElderliesDAO.selectOne(new QueryWrapper<ComElderAuthElderliesDO>()
|
.lambda().eq(ComElderAuthElderliesDO::getPopulationId, populationDO.getId()).eq(ComElderAuthElderliesDO::getCommunityId, communityId));
|
//不存在高龄信息，需要先导入高龄信息
|
if (null == comElderAuthElderliesDO) {
|
ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
mistake.setMistake("该实有人口已存在，但本社区不存在高龄老人信息，请先导入高龄老人");
|
mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format));
|
mistakes.add(mistake);
|
}else {
|
//存在高龄信息，判断是否满足认证条件
|
if (StringUtils.isNotEmpty(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);
|
mistake.setMistake("该人口未满80岁，或者不健在，或者未做高龄老人登记");
|
mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format));
|
mistakes.add(mistake);
|
}else {
|
|
//满足认证条件，判断是否存在当期认证记录
|
List<ComElderAuthRecordsDO> elderAuthRecordList = null;
|
ComElderAuthRecordsDO comElderAuthRecordsDO = null;
|
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.getApprovalStatus().equals(ComElderAuthRecordsDO.approvalStatus.tg)) {
|
ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
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 = 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,communityId,nowDate);
|
saveList.add(comElderAuthRecordsDO);
|
|
if(StringUtils.isNotEmpty(vo.getAddress())){
|
comElderAuthElderliesDO.setAddress(vo.getAddress());
|
updateElderliesList.add(comElderAuthElderliesDO);
|
}
|
}
|
}
|
}
|
}
|
} else {
|
// 不存在实有人口,则新增
|
ComElderAuthRecordImportMistakeExcelVO mistake = new ComElderAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
mistake.setMistake("不存在该实有人口，请先导入实有人口信息");
|
mistake.setAuthDate(DateUtils.format(vo.getAuthDate(),DateUtils.yyyyMMdd_format));
|
mistakes.add(mistake);
|
}
|
log.info("开始查询实有人口是否已存在完成");
|
}
|
} catch (Exception e) {
|
log.info("出现错误，错误原因：" + e.getMessage());
|
}
|
log.info("处理完成导入数据");
|
|
log.info("开始执行数据库导入");
|
if (!saveList.isEmpty()) {
|
log.info("执行数据库导入线下认证记录");
|
comElderAuthRecordsService.saveBatch(saveList);
|
log.info("数据库导入线下认证记录完成");
|
}
|
if (!updateList.isEmpty()) {
|
log.info("执行数据库更新线下认证记录");
|
comElderAuthRecordsDAO.updateAll(updateList);
|
log.info("数据库更新线下认证记录完成");
|
}
|
if(!updateElderliesList.isEmpty()){
|
comElderAuthElderliesService.updateBatchById(updateElderliesList);
|
}
|
log.info("执行数据库导入完成");
|
|
if (!mistakes.isEmpty()) {
|
log.info("返回错误数据");
|
return R.fail(mistakes);
|
}
|
return R.ok(mistakes);
|
}
|
|
@Override
|
public R exportElderAuthRecordsStatistic(PageElderAuthStatisticDTO pageElderAuthRecordsDTO) {
|
List<ComElderAuthRecordStatisticExcleVO> comElderAuthRecordStatisticExcleVOS = comElderAuthRecordsDAO.exportElderAuthRecordsStatistic(pageElderAuthRecordsDTO);
|
if (null != comElderAuthRecordStatisticExcleVOS && comElderAuthRecordStatisticExcleVOS.size() > 0) {
|
comElderAuthRecordStatisticExcleVOS.forEach(comElderAuthRecordStatisticExcleVO -> {
|
if (StringUtils.isNotEmpty(comElderAuthRecordStatisticExcleVO.getBirthday())) {
|
comElderAuthRecordStatisticExcleVO.setAge(AgeUtils.getAgeFromBirthTimes(comElderAuthRecordStatisticExcleVO.getBirthday()));
|
}
|
});
|
}
|
return R.ok(comElderAuthRecordStatisticExcleVOS);
|
}
|
|
/**
|
* 身份认证定时任务
|
* @return 执行结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R timedTaskElderAuthStatisticsJobHandler() {
|
//查询高龄认证记录列表
|
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);
|
}
|
}
|
});
|
|
//查询养老认证记录列表
|
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);
|
}
|
});
|
return R.ok();
|
}
|
|
private ComElderAuthRecordsDO updateElderAuthRecordsDO(ComElderAuthRecordImportExcelVO vo
|
, ComElderAuthRecordsDO comElderAuthRecordsDO, Long userId, Long communityId,Date date) {
|
BeanUtils.copyProperties(vo, comElderAuthRecordsDO);
|
comElderAuthRecordsDO.setSubmitUserId(userId);
|
comElderAuthRecordsDO.setApproverId(userId);
|
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, Long communityId,Date date) {
|
ComElderAuthRecordsDO comElderAuthRecordsDO = new ComElderAuthRecordsDO();
|
BeanUtils.copyProperties(vo, comElderAuthRecordsDO);
|
comElderAuthRecordsDO.setElderliesId(comElderAuthElderliesDO.getId());
|
comElderAuthRecordsDO.setAuthPeriod(authPeriod);
|
comElderAuthRecordsDO.setSubmitUserId(userId);
|
comElderAuthRecordsDO.setApproverId(userId);
|
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;
|
}
|
|
/**
|
* 判重方法
|
*
|
* @param key
|
* 主键
|
* @param hashMap
|
* 数据集
|
* @return 存在即为false 不存在则为true
|
*/
|
private boolean isOnly(String key, HashMap<String, Object> hashMap) {
|
return ObjectUtils.isEmpty(hashMap.get(key));
|
}
|
|
/**
|
* 新增高龄认证
|
* @param addIdentityAuthDTO 请求参数
|
* @return 新增结果
|
*/
|
@Override
|
public R addElderAuth(AddIdentityAuthDTO addIdentityAuthDTO) {
|
String idCard;
|
try {
|
idCard = AESUtil.encrypt128(addIdentityAuthDTO.getIdCard(), aesKey);
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("加密失败【{}】", e.getMessage());
|
return R.fail("认证失败，请重新尝试");
|
}
|
ComElderAuthElderliesDO comElderAuthElderliesDO = comElderAuthElderliesDAO.selectOne(new QueryWrapper<ComElderAuthElderliesDO>()
|
.lambda().eq(ComElderAuthElderliesDO::getIdCard, idCard).eq(ComElderAuthElderliesDO::getCommunityId, addIdentityAuthDTO.getCommunityId()));
|
if (Objects.isNull(comElderAuthElderliesDO)) {
|
return R.fail("该人员未在社区报道无法认证");
|
}
|
boolean isInfoCorrect = !comElderAuthElderliesDO.getName().equals(addIdentityAuthDTO.getName()) ||
|
!(comElderAuthElderliesDO.getIsRegister().equals(1) && comElderAuthElderliesDO.getIsAlive().equals(1));
|
if (isInfoCorrect) {
|
return R.fail("信息有误,请检查!");
|
}
|
Date dateNow = new Date();
|
String currentAuthPeriod = new SimpleDateFormat("yyyyMM").format(dateNow);
|
List<ComElderAuthRecordsDO> currentAuthPeriodRecords = comElderAuthRecordsDAO
|
.selectList(new QueryWrapper<ComElderAuthRecordsDO>().lambda()
|
.eq(ComElderAuthRecordsDO::getAuthPeriod, currentAuthPeriod)
|
.eq(ComElderAuthRecordsDO::getElderliesId, comElderAuthElderliesDO.getId()));
|
if (!currentAuthPeriodRecords.isEmpty()) {
|
boolean alreadyAuth = currentAuthPeriodRecords.stream()
|
.filter(record -> record.getAuthStatus().equals(CERTIFIED.getStatus())).findFirst().isPresent();
|
if (alreadyAuth) {
|
return R.fail(String.format("该人员%s期已认证无需重复认证", currentAuthPeriod));
|
}
|
boolean isPendingReview = currentAuthPeriodRecords.stream()
|
.filter(record -> record.getApprovalStatus().intValue() == PENDING_REVIEW.getStatus()).findFirst().isPresent();
|
if (isPendingReview) {
|
return R.fail("该人员本期有尚未审核的认证，请稍后再试！");
|
}
|
}
|
ComElderAuthRecordsDO comElderAuthRecordsDO = new ComElderAuthRecordsDO();
|
BeanUtils.copyProperties(addIdentityAuthDTO, comElderAuthRecordsDO);
|
comElderAuthRecordsDO.setElderliesId(comElderAuthElderliesDO.getId());
|
comElderAuthRecordsDO.setAuthDate(dateNow);
|
comElderAuthRecordsDO.setAuthPeriod(currentAuthPeriod);
|
if (addIdentityAuthDTO.getAuthMethod().intValue() == FACE_AUTH.getMethod()) {
|
comElderAuthRecordsDO.setApprovalStatus(PASS_THROUGH.getStatus());
|
comElderAuthRecordsDO.setApprovalDate(dateNow);
|
comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus());
|
}
|
if (this.baseMapper.insert(comElderAuthRecordsDO) < 0) {
|
return R.fail("认证失败，请重新尝试");
|
}
|
if (addIdentityAuthDTO.getAuthMethod().intValue() == FACE_AUTH.getMethod()) {
|
sendAuthSubscribe(addIdentityAuthDTO.getSubmitUserId(), "高龄认证", "认证成功！",addIdentityAuthDTO.getAreaCode());
|
}
|
return R.ok();
|
}
|
|
/**
|
* 分页查询高龄认证记录
|
* @param pageIdentityAuthRecordDTO 高龄认证记录vo
|
* @return 高龄认证记录列表
|
*/
|
@Override
|
public R queryRecordWithPage(PageIdentityAuthRecordDTO pageIdentityAuthRecordDTO) {
|
return R.ok(comElderAuthRecordsDAO.queryRecordWithPage(new Page(pageIdentityAuthRecordDTO.getPageNum(),
|
pageIdentityAuthRecordDTO.getPageSize()), pageIdentityAuthRecordDTO));
|
}
|
|
/**
|
* 获取高龄认证详情
|
* @param identityAuthId 认证id
|
* @return 认证记录详情
|
*/
|
@Override
|
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.setElderliesId(comElderAuthElderliesDO.getId());
|
comElderAuthRecordsDO.setApprovalStatus(PASS_THROUGH.getStatus());
|
comElderAuthRecordsDO.setApprovalDate(new Date());
|
comElderAuthRecordsDO.setAuthStatus(CERTIFIED.getStatus());
|
comElderAuthRecordsDO.setAuthMethod(ComPensionAuthRecordDO.authMethod.xxrz);
|
comElderAuthRecordsDO.setApproverId(comElderAuthRecordVO.getSubmitUserId());
|
comElderAuthRecordsDO.setSubmitUserId(comElderAuthRecordVO.getSubmitUserId());
|
if (this.baseMapper.insert(comElderAuthRecordsDO) < 0) {
|
return R.fail("认证失败，请重新尝试");
|
}
|
comMngPopulationDO.setPhone(comElderAuthRecordVO.getPhone());
|
comMngPopulationDAO.updateById(comMngPopulationDO);
|
comElderAuthElderliesDO.setAddress(comElderAuthRecordVO.getAddress());
|
comElderAuthElderliesDO.setPhone(comElderAuthRecordVO.getPhone());
|
comElderAuthElderliesDO.setIdCard(null);
|
comElderAuthElderliesDAO.updateById(comElderAuthElderliesDO);
|
ComPensionAuthPensionerDO comPensionAuthPensionerDO=comPensionAuthPensionerDAO.selectOne(new QueryWrapper<ComPensionAuthPensionerDO>().lambda().eq(ComPensionAuthPensionerDO::getPopulationId,comMngPopulationDO.getId()));
|
if(comPensionAuthPensionerDO!=null){
|
comPensionAuthPensionerDO.setAddress(comElderAuthRecordVO.getAddress());
|
comPensionAuthPensionerDO.setPhone(comElderAuthRecordVO.getPhone());
|
comPensionAuthPensionerDO.setIdCard(null);
|
comPensionAuthPensionerDAO.updateById(comPensionAuthPensionerDO);
|
}
|
return R.ok();
|
}
|
return R.fail("当前期数已认证，请勿重复认证");
|
}
|
return R.fail("无养老认证数据");
|
}
|
return R.fail("该身份证无实有人口信息");
|
}
|
return R.fail("身份证不能为空");
|
}
|
}
|
