From 68a3e4c053d15961ede69fe7698f63fe827624c3 Mon Sep 17 00:00:00 2001
From: puhanshu <a9236326>
Date: 星期一, 13 九月 2021 16:08:44 +0800
Subject: [PATCH] Merge branch 'test' of http://gitlab.nhys.cdnhxx.com/root/zhihuishequ into auth
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComPensionAuthRecordServiceImpl.java | 300 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 300 insertions(+), 0 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComPensionAuthRecordServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComPensionAuthRecordServiceImpl.java
index ae114d0..2514852 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComPensionAuthRecordServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComPensionAuthRecordServiceImpl.java
@@ -1,7 +1,9 @@
package com.panzhihua.service_community.service.impl;
import java.text.SimpleDateFormat;
+import java.util.ArrayList;
import java.util.Date;
+import java.util.HashMap;
import java.util.List;
import java.util.Objects;
@@ -10,16 +12,30 @@
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.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.helper.AESUtil;
import com.panzhihua.common.model.vos.R;
+import com.panzhihua.common.model.vos.community.ComPensionAuthRecordVO;
+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.ComMngPopulationDAO;
import com.panzhihua.service_community.dao.ComPensionAuthPensionerDAO;
import com.panzhihua.service_community.dao.ComPensionAuthRecordDAO;
+import com.panzhihua.service_community.model.dos.ComActDO;
+import com.panzhihua.service_community.model.dos.ComMngPopulationDO;
import com.panzhihua.service_community.model.dos.ComPensionAuthPensionerDO;
import com.panzhihua.service_community.model.dos.ComPensionAuthRecordDO;
import com.panzhihua.service_community.service.ComPensionAuthRecordService;
@@ -36,6 +52,290 @@
@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));
+ }
@Resource
private ComPensionAuthRecordDAO comPensionAuthRecordDAO;
--
Gitblit v1.7.1