package com.panzhihua.service_community.service.impl;
|
|
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.panzhihua.common.enums.PopulHouseUseEnum;
|
import com.panzhihua.common.model.dtos.community.PageElderAuthRecordsDTO;
|
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.ComPensionAuthPensionerService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.service_community.service.ComPensionAuthRecordService;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
|
import javax.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* @title: ComPensionAuthRecordServiceImpl
|
* @projectName: 成都呐喊信息技术有限公司-智慧社区项目
|
* @description: 养老认证记录服务实现类
|
* @author: hans
|
* @date: 2021/09/01 17:35
|
*/
|
@Slf4j
|
@Service
|
public class ComPensionAuthRecordServiceImpl extends ServiceImpl<ComPensionAuthRecordDAO, ComPensionAuthRecordDO> implements ComPensionAuthRecordService {
|
@Resource
|
private ComPensionAuthRecordDAO comPensionAuthRecordDAO;
|
@Resource
|
private ComMngPopulationDAO comMngPopulationDAO;
|
@Resource
|
private ComPensionAuthPensionerDAO comPensionAuthPensionerDAO;
|
@Resource
|
private ComPensionAuthRecordService comPensionAuthRecordService;
|
@Resource
|
private ComActDAO comActDAO;
|
@Resource
|
private ComPensionAuthStatisticsDAO comPensionAuthStatisticsDAO;
|
@Value("${domain.aesKey:}")
|
private String aesKey;
|
|
@Override
|
public R pagePensionAuthRecords(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<ComPensionAuthRecordVO> iPage = comPensionAuthRecordDAO.pagePensionAuthRecords(page, pageElderAuthRecordsDTO);
|
if (!iPage.getRecords().isEmpty()) {
|
iPage.getRecords().forEach(comPensionAuthRecordVO -> {
|
if (StringUtils.isNotEmpty(comPensionAuthRecordVO.getBirthday())) {
|
comPensionAuthRecordVO.setAge(AgeUtils.getAgeFromBirthTimes(comPensionAuthRecordVO.getBirthday()));
|
}
|
});
|
}
|
return R.ok(iPage);
|
}
|
|
@Override
|
public R detailPensionAuthRecords(Long authRecordId) {
|
ComPensionAuthRecordVO comPensionAuthRecordVO = comPensionAuthRecordDAO.detailPensionAuthRecords(authRecordId);
|
return R.ok(comPensionAuthRecordVO);
|
}
|
|
@Override
|
public R examinePensionAuthRecords(ComPensionAuthRecordVO comPensionAuthRecordVO) {
|
ComPensionAuthRecordDO comPensionAuthRecordDO = comPensionAuthRecordDAO.selectById(comPensionAuthRecordVO.getId());
|
if (comPensionAuthRecordDO == null) {
|
return R.fail("未查询到养老认证记录");
|
}
|
BeanUtils.copyProperties(comPensionAuthRecordVO, comPensionAuthRecordDO);
|
if (comPensionAuthRecordVO.getApprovalStatus().equals(3)) {
|
comPensionAuthRecordDO.setAuthStatus(1);
|
}
|
comPensionAuthRecordDO.setApprovalDate(new Date());
|
int nub = comPensionAuthRecordDAO.updateById(comPensionAuthRecordDO);
|
if (nub < 1) {
|
return R.fail("审核失败");
|
}
|
return R.ok();
|
}
|
|
@Override
|
public R signPensionAuthRecords(ComPensionAuthRecordVO comPensionAuthRecordVO) {
|
ComPensionAuthRecordDO comPensionAuthRecordDO = comPensionAuthRecordDAO.selectById(comPensionAuthRecordVO.getId());
|
if (comPensionAuthRecordDO == null) {
|
return R.fail("未查询到养老认证记录");
|
}
|
BeanUtils.copyProperties(comPensionAuthRecordVO, comPensionAuthRecordDO);
|
int nub = comPensionAuthRecordDAO.updateById(comPensionAuthRecordDO);
|
if (nub < 1) {
|
return R.fail("标记失败");
|
}
|
return R.ok();
|
}
|
|
@Override
|
public R getPensionAuthRecordsByIds(List<Long> ids) {
|
List<ComPensionAuthRecordExcleVO> comPensionAuthRecordExcleVOS = comPensionAuthRecordDAO.getPensionAuthRecordsByIds(ids);
|
return R.ok(comPensionAuthRecordExcleVOS);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public R listSavePensionAuthRecordExcelVO(List<ComPensionAuthRecordImportExcelVO> list, Long communityId, Long userId) {
|
// 需要新增的认证记录集合
|
List<ComPensionAuthRecordDO> saveList = new ArrayList<>();
|
// 需要修改的认证记录集合
|
List<ComPensionAuthRecordDO> updateList = new ArrayList<>();
|
log.info("开始处理导入数据");
|
List<ComPensionAuthRecordImportMistakeExcelVO> 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);
|
});
|
|
for (ComPensionAuthRecordImportExcelVO vo : list) {
|
String cardNoAES = AESUtil.encrypt128(vo.getIdCard(), aesKey);
|
// 判断实有人口是否已存在
|
log.info("开始查询实有人口是否已存在");
|
ComMngPopulationDO populationDO = null;
|
String populationKey = vo.getIdCard();
|
if (!isOnly(populationKey, populationMap)) {
|
// 存在实有人口信息，则查询养老信息（是否符合认证条件（健在且登记了养老认证））
|
populationDO = (ComMngPopulationDO)populationMap.get(populationKey);
|
ComPensionAuthPensionerDO comPensionAuthPensionerDO = comPensionAuthPensionerDAO.selectOne(new QueryWrapper<ComPensionAuthPensionerDO>()
|
.lambda().eq(ComPensionAuthPensionerDO::getPopulationId, populationDO.getId()).eq(ComPensionAuthPensionerDO::getCommunityId, communityId));
|
//不存在养老信息，需要先导入养老信息
|
if (null == comPensionAuthPensionerDO) {
|
ComPensionAuthRecordImportMistakeExcelVO mistake = new ComPensionAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
setMistake(mistake, vo);
|
mistake.setMistake("该实有人口已存在，但本社区不存在养老信息，请先导入养老人口");
|
mistakes.add(mistake);
|
}else {
|
//存在养老信息，判断是否满足认证条件
|
if (!comPensionAuthPensionerDO.getIsRegister().equals(1) || !comPensionAuthPensionerDO.getIsAlive().equals(1)) {
|
ComPensionAuthRecordImportMistakeExcelVO mistake = new ComPensionAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
setMistake(mistake, vo);
|
mistake.setMistake("该人口不健在，或者未做养老登记");
|
mistakes.add(mistake);
|
}else {
|
//满足认证条件，判断是否存在当期认证记录
|
ComPensionAuthRecordDO comPensionAuthRecordDO = null;
|
Date nowDate = new Date();
|
// 获取当前年
|
int year = DateUtils.getYear(nowDate);
|
String authPeriod = "";
|
if (nowDate.before(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(String.valueOf(year) + "-03-01 00:00:00"))) {
|
authPeriod = String.valueOf(year - 1);
|
}else {
|
authPeriod = String.valueOf(year);
|
}
|
|
comPensionAuthRecordDO = comPensionAuthRecordDAO.selectOne(new QueryWrapper<ComPensionAuthRecordDO>().lambda().
|
eq(ComPensionAuthRecordDO::getPensionerId, comPensionAuthPensionerDO.getId()).eq(ComPensionAuthRecordDO::getAuthPeriod, authPeriod));
|
if (null != comPensionAuthRecordDO) {
|
//存在记录且状态为已认证，不能修改
|
if (comPensionAuthRecordDO.getAuthStatus().equals(1)) {
|
ComPensionAuthRecordImportMistakeExcelVO mistake = new ComPensionAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
setMistake(mistake, vo);
|
mistake.setMistake("该人口本期已认证，不能修改");
|
mistakes.add(mistake);
|
}else {
|
//存在记录，执行修改
|
ComPensionAuthRecordDO comPensionAuthRecordDO1 =
|
updatePensionAuthRecordsDO(vo, comPensionAuthRecordDO, userId);
|
updateList.add(comPensionAuthRecordDO1);
|
ComPensionAuthRecordImportMistakeExcelVO mistake = new ComPensionAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
setMistake(mistake, vo);
|
mistake.setMistake("该认证已存在，执行更新");
|
mistakes.add(mistake);
|
}
|
}else {
|
// 不存在记录,则新增
|
comPensionAuthRecordDO = savePensionAuthRecordsDO(vo, comPensionAuthPensionerDO, authPeriod, userId);
|
saveList.add(comPensionAuthRecordDO);
|
}
|
}
|
}
|
} else {
|
// 不存在实有人口,则新增
|
ComPensionAuthRecordImportMistakeExcelVO mistake = new ComPensionAuthRecordImportMistakeExcelVO();
|
BeanUtils.copyProperties(vo, mistake);
|
setMistake(mistake, vo);
|
mistake.setMistake("不存在该实有人口，请先导入实有人口信息");
|
mistakes.add(mistake);
|
}
|
log.info("开始查询实有人口是否已存在完成");
|
}
|
} catch (Exception e) {
|
log.info("出现错误，错误原因：" + e.getMessage());
|
}
|
log.info("处理完成导入数据");
|
|
log.info("开始执行数据库导入");
|
if (!saveList.isEmpty()) {
|
log.info("执行数据库导入线下认证记录");
|
comPensionAuthRecordService.saveBatch(saveList);
|
log.info("数据库导入线下认证记录完成");
|
}
|
if (!updateList.isEmpty()) {
|
log.info("执行数据库更新线下认证记录");
|
comPensionAuthRecordDAO.updateAll(updateList);
|
log.info("数据库更新线下认证记录完成");
|
}
|
log.info("执行数据库导入完成");
|
|
if (!mistakes.isEmpty()) {
|
log.info("返回错误数据");
|
return R.fail(mistakes);
|
}
|
return R.ok(mistakes);
|
}
|
|
@Override
|
public R exportPensionAuthRecordsStatistic(PageElderAuthRecordsDTO pageElderAuthRecordsDTO) {
|
List<ComPensionAuthRecordStatisticExcleVO> comPensionAuthRecordStatisticExcleVOS = comPensionAuthRecordDAO.exportPensionAuthRecordsStatistic(pageElderAuthRecordsDTO);
|
return R.ok(comPensionAuthRecordStatisticExcleVOS);
|
}
|
|
@Override
|
public R timedTaskPensionAuthStatisticsJobHandler() {
|
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 -> {
|
//养老认证统计
|
ComPensionAuthStatisticsDO comPensionAuthStatisticsDO = new ComPensionAuthStatisticsDO();
|
comPensionAuthStatisticsDO.setCommunityId(act.getCommunityId());
|
comPensionAuthStatisticsDO.setMonth(month);
|
comPensionAuthStatisticsDO.setYear(year);
|
comPensionAuthStatisticsDO.setCreateAt(nowDate);
|
//本期应认证人数
|
List<ComPensionAuthPensionerDO> comPensionAuthPensionerDOS = comPensionAuthPensionerDAO.selectList(new QueryWrapper<ComPensionAuthPensionerDO>().lambda()
|
.eq(ComPensionAuthPensionerDO::getCommunityId, act.getCommunityId())
|
.eq(ComPensionAuthPensionerDO::getIsAlive, 1)
|
.eq(ComPensionAuthPensionerDO::getIsRegister, 1));
|
if (null != comPensionAuthPensionerDOS) {
|
comPensionAuthStatisticsDO.setSum(comPensionAuthPensionerDOS.size());
|
}
|
comPensionAuthStatisticsDAO.insert(comPensionAuthStatisticsDO);
|
//上期已认证人数
|
int authSum = comPensionAuthPensionerDAO.havePensionAuthPensionerAmount(act.getCommunityId(), String.valueOf(year - 1));
|
ComPensionAuthStatisticsDO comPensionAuthStatisticsDO1 = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>()
|
.lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, act.getCommunityId()).eq(ComPensionAuthStatisticsDO::getYear, year - 1));
|
comPensionAuthStatisticsDO1.setAuthSum(authSum);
|
comPensionAuthStatisticsDO1.setNoAuthSum(comPensionAuthStatisticsDO1.getSum() - comPensionAuthStatisticsDO1.getAuthSum());
|
comPensionAuthStatisticsDAO.updateById(comPensionAuthStatisticsDO1);
|
});
|
return R.ok();
|
}
|
|
private ComPensionAuthRecordDO updatePensionAuthRecordsDO(ComPensionAuthRecordImportExcelVO vo, ComPensionAuthRecordDO comPensionAuthRecordsDO, Long userId) {
|
BeanUtils.copyProperties(vo, comPensionAuthRecordsDO);
|
comPensionAuthRecordsDO.setSubmitUserId(userId);
|
comPensionAuthRecordsDO.setApproverId(userId);
|
comPensionAuthRecordsDO.setApprovalStatus(3);
|
comPensionAuthRecordsDO.setApprovalDate(new Date());
|
comPensionAuthRecordsDO.setAuthStatus(1);
|
return comPensionAuthRecordsDO;
|
}
|
|
private ComPensionAuthRecordDO savePensionAuthRecordsDO(ComPensionAuthRecordImportExcelVO vo, ComPensionAuthPensionerDO comPensionAuthPensionerDO, String authPeriod, Long userId) {
|
ComPensionAuthRecordDO comPensionAuthRecordDO = new ComPensionAuthRecordDO();
|
BeanUtils.copyProperties(vo, comPensionAuthRecordDO);
|
comPensionAuthRecordDO.setId(Snowflake.getId());
|
comPensionAuthRecordDO.setPensionerId(comPensionAuthPensionerDO.getId());
|
comPensionAuthRecordDO.setAuthPeriod(authPeriod);
|
comPensionAuthRecordDO.setSubmitUserId(userId);
|
comPensionAuthRecordDO.setApproverId(userId);
|
comPensionAuthRecordDO.setApprovalStatus(3);
|
comPensionAuthRecordDO.setApprovalDate(new Date());
|
comPensionAuthRecordDO.setAuthStatus(1);
|
return comPensionAuthRecordDO;
|
}
|
|
private void setMistake(ComPensionAuthRecordImportMistakeExcelVO mvo,
|
ComPensionAuthRecordImportExcelVO vo) {
|
mvo.setIsAlive(PopulHouseUseEnum.getCnDescByName(vo.getIsAlive()));
|
}
|
|
/**
|
* 判重方法
|
*
|
* @param key
|
* 主键
|
* @param hashMap
|
* 数据集
|
* @return 存在即为false 不存在则为true
|
*/
|
private boolean isOnly(String key, HashMap<String, Object> hashMap) {
|
return ObjectUtils.isEmpty(hashMap.get(key));
|
}
|
}
|
