package com.panzhihua.service_community.service.impl;
|
|
import cn.hutool.core.util.IdcardUtil;
|
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.google.common.base.Joiner;
|
import com.panzhihua.common.constants.Constants;
|
import com.panzhihua.common.enums.*;
|
import com.panzhihua.common.model.dtos.community.PageElderAuthRecordsDTO;
|
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.*;
|
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.*;
|
import com.panzhihua.service_community.model.dos.*;
|
import com.panzhihua.service_community.service.ComElderAuthRecordsService;
|
import lombok.extern.slf4j.Slf4j;
|
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 javax.annotation.Resource;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 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 ComEldersAuthHistoryRecordMapper comEldersAuthHistoryRecordMapper;
|
@Resource
|
private ComActDAO comActDAO;
|
@Resource
|
private ComEldersAuthStatisticsMapper comEldersAuthStatisticsMapper;
|
@Value("${domain.aesKey:}")
|
private String aesKey;
|
|
@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);
|
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 detailElderAuthRecords(Long authRecordId) {
|
ComElderAuthRecordVO comElderAuthRecordVO = comElderAuthRecordsDAO.detailElderAuthRecords(authRecordId);
|
comElderAuthRecordVO.setNextIds(comElderAuthRecordsDAO.getNextIds(comElderAuthRecordVO.getCommunityId(),authRecordId));
|
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);
|
}
|
|
int nub = comElderAuthRecordsDAO.updateById(comElderAuthRecordsDO);
|
if (nub < 1) {
|
return R.fail("审核失败");
|
}
|
return R.ok();
|
}
|
|
@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<>();
|
log.info("开始处理导入数据");
|
|
List<ComElderAuthRecordImportMistakeExcelVO> mistakes = new ArrayList<>();
|
try {
|
// 查询所有人口数据放入HashMap中
|
List<ComMngPopulationDO> populationList = comMngPopulationDAO.selectList(null);
|
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);
|
}else {
|
// 驳回状态,则新增
|
comElderAuthRecordsDO = saveElderAuthRecordsDO(vo, comElderAuthElderliesDO, authPeriod, userId,communityId,nowDate);
|
saveList.add(comElderAuthRecordsDO);
|
}
|
}else {
|
// 不存在记录,则新增
|
comElderAuthRecordsDO = saveElderAuthRecordsDO(vo, comElderAuthElderliesDO, authPeriod, userId,communityId,nowDate);
|
saveList.add(comElderAuthRecordsDO);
|
}
|
}
|
}
|
}
|
} 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("数据库更新线下认证记录完成");
|
}
|
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);
|
}
|
|
@Override
|
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());
|
}
|
comEldersAuthStatisticsMapper.insert(comEldersAuthStatisticsDO);
|
//上期已认证人数
|
String authPeriod = "";
|
if (month < 10) {
|
authPeriod = String.valueOf(year) + 0 + month;
|
} else {
|
authPeriod = String.valueOf(year) + month;
|
}
|
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, 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.setId(Snowflake.getId());
|
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));
|
}
|
|
}
|
