package com.doumee.service.business.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.LoginUserInfo;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.dto.InsuranceApplyOptDTO;
|
import com.doumee.dao.business.dto.InsuranceApplyQueryDTO;
|
import com.doumee.dao.business.join.ApplyDetailJoinMapper;
|
import com.doumee.dao.business.join.ApplyLogJoinMapper;
|
import com.doumee.dao.business.join.InsuranceApplyJoinMapper;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.system.model.SystemUser;
|
import com.doumee.service.business.InsuranceApplyService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import io.swagger.models.auth.In;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 投保申请信息表Service实现
|
* @author 江蹄蹄
|
* @date 2024/01/16 10:03
|
*/
|
@Service
|
public class InsuranceApplyServiceImpl implements InsuranceApplyService {
|
|
@Autowired
|
private InsuranceApplyMapper insuranceApplyMapper;
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
@Autowired
|
private InsuranceApplyJoinMapper insuranceApplyJoinMapper;
|
|
@Autowired
|
private ApplyDetailMapper applyDetailMapper;
|
@Autowired
|
private ApplyDetailJoinMapper applyDetailJoinMapper;
|
|
@Autowired
|
private ApplyLogMapper applyLogMapper;
|
@Autowired
|
private MultifileMapper multifileMapper;
|
|
@Autowired
|
private ApplyLogJoinMapper applyLogJoinMapper;
|
|
@Autowired
|
private SolutionsMapper solutionsMapper;
|
|
@Autowired
|
private MemberMapper memberMapper;
|
@Autowired
|
private DuSolutionMapper duSolutionMapper;
|
@Autowired
|
private DuWorktypeMapper duWorktypeMapper;
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer back(InsuranceApply insuranceApply) {
|
if(insuranceApply.getId() == null ||StringUtils.isBlank(insuranceApply.getCheckInfo())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
|
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PLATFORM_RETURN;
|
String info =applyLogType.getInfo();
|
info = info.replace("${param}", update.getCheckInfo());
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return 1;
|
|
}
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer uploadBaoxiandan(InsuranceApply insuranceApply) {
|
if(insuranceApply.getId() == null
|
|| insuranceApply.getCode() == null
|
|| insuranceApply.getStartTime() == null
|
|| insuranceApply.getBaoxiandanFile() == null
|
||StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getFileurl())
|
||StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
|
InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.SIGNATURE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
if(model.getApplyEndTime()== null || insuranceApply.getStartTime().getTime()>insuranceApply.getApplyEndTime().getTime() ){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请生效周期时间不符合要求，请确认后修改重试~");
|
}
|
//计算实际截止时间
|
Date actEndTime = new Date(insuranceApply.getApplyEndTime().getTime() + (insuranceApply.getStartTime().getTime() - model.getApplyStartTime().getTime()));
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setStatus(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
update.setCode(insuranceApply.getCode());
|
update.setEndTime(actEndTime);
|
update.setStartTime(insuranceApply.getStartTime());
|
insuranceApplyMapper.updateById(update);
|
|
insuranceApply.getBaoxiandanFile().setIsdeleted(Constants.ZERO);
|
insuranceApply.getBaoxiandanFile().setCreator(user.getId());
|
insuranceApply.getToubaodanFile().setObjId(update.getId());
|
insuranceApply.getBaoxiandanFile().setCreateDate(update.getEditDate());
|
insuranceApply.getBaoxiandanFile().setObjType(Constants.MultiFile.BD_DONE_PDF.getKey());
|
insuranceApply.getBaoxiandanFile().setType(Constants.TWO);
|
multifileMapper.insert(insuranceApply.getBaoxiandanFile());
|
update.setBaoxiandanFile(insuranceApply.getBaoxiandanFile());
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD_INSURANCE;
|
String info = "";
|
if(model.getApplyStartTime()!=null && model.getApplyStartTime().getTime()/1000!= insuranceApply.getStartTime().getTime()/1000){
|
info =applyLogType.getInfo();
|
info = info.replace("${param1}",DateUtil.getPlusTime2(model.getApplyEndTime()));
|
info = info.replace("${param2}",DateUtil.getPlusTime2(insuranceApply.getStartTime()));
|
}
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return 1;
|
|
}
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer editBaoxiandan(InsuranceApply param) {
|
if(param.getId() == null
|
|| param.getCode() == null
|
|| param.getBaoxiandanFile() == null
|
|| param.getCheckInfo() == null
|
||StringUtils.isBlank( param.getBaoxiandanFile().getFileurl())
|
||StringUtils.isBlank( param.getBaoxiandanFile() .getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
|
InsuranceApply model = insuranceApplyMapper.selectById(param.getId());
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~");
|
}
|
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(param.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
update.setCode(param.getCode());
|
insuranceApplyMapper.updateById(update);
|
//删除原有的保单信息
|
multifileMapper.delete(new UpdateWrapper<Multifile>().lambda()
|
.set(Multifile::getIsdeleted,Constants.ZERO)
|
.eq(Multifile::getIsdeleted,Constants.ZERO)
|
.eq(Multifile::getObjId,update.getId())
|
.eq(Multifile::getObjType,Constants.MultiFile.BD_DONE_PDF.getKey())
|
);
|
param.getBaoxiandanFile().setIsdeleted(Constants.ZERO);
|
param.getBaoxiandanFile().setObjId(update.getId());
|
param.getBaoxiandanFile().setCreator(user.getId());
|
param.getBaoxiandanFile().setCreateDate(update.getEditDate());
|
param.getBaoxiandanFile().setObjType(Constants.MultiFile.BD_DONE_PDF.getKey());
|
param.getBaoxiandanFile().setType(Constants.TWO);
|
multifileMapper.insert(param.getBaoxiandanFile());
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PALTFORM_EDIT_BD;
|
String info = applyLogType.getInfo();
|
info = info.replace("${param}",param.getCheckInfo());
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
|
return 1;
|
|
}
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer dealBackApply(InsuranceApply insuranceApply) {
|
if(insuranceApply.getId() == null ||StringUtils.isBlank(insuranceApply.getCheckInfo())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
|
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Constants.ApplyLogType applyLogType = null;
|
String info = "";
|
InsuranceApply update = new InsuranceApply();
|
if(insuranceApply.getDealBackApply() ==1){
|
//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
applyLogType = Constants.ApplyLogType.PLATFORM_UN_AGREE_BACK;
|
info = applyLogType.getInfo();
|
info = info.replace("${param}", insuranceApply.getCheckInfo());
|
update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
|
}else{
|
//如果是同意,两种申请退回状态都可操作
|
if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())
|
||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())
|
||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
applyLogType = Constants.ApplyLogType.PLATFORM_AGREE_BACK;
|
if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())){
|
update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
|
}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())){
|
update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey());
|
}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey())){
|
update.setStatus(Constants.InsuranceApplyStatus.UPLOAD.getKey());
|
}
|
}
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return 1;
|
|
|
}
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer uploadToubaodan(InsuranceApply insuranceApply) {
|
if(insuranceApply.getId() == null
|
|| insuranceApply.getToubaodanFile() == null
|
||StringUtils.isBlank( insuranceApply.getToubaodanFile() .getFileurl())
|
||StringUtils.isBlank( insuranceApply.getToubaodanFile() .getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())
|
|| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
insuranceApply.getToubaodanFile().setIsdeleted(Constants.ZERO);
|
insuranceApply.getToubaodanFile().setCreator(user.getId());
|
insuranceApply.getToubaodanFile().setObjId(update.getId());
|
insuranceApply.getToubaodanFile().setCreateDate(update.getEditDate());
|
insuranceApply.getToubaodanFile().setObjType(Constants.MultiFile.BD_APPLY_PDF.getKey());
|
insuranceApply.getToubaodanFile().setType(Constants.TWO);
|
multifileMapper.insert(insuranceApply.getToubaodanFile());
|
update.setToubaodanFile(insuranceApply.getToubaodanFile());
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WAIT_SIGNATURE;
|
String info =applyLogType.getInfo();
|
info = info.replace("${param}", update.getCheckInfo());
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(),StringUtils.isNotBlank(update.getCheckInfo())?info:"",update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return 1;
|
|
}
|
|
/**
|
* 审核通过
|
* @param insuranceApply
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer check(InsuranceApply insuranceApply) {
|
if(insuranceApply.getId() == null ||StringUtils.isBlank(insuranceApply.getCheckInfo())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
|
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS;
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(),null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return 1;
|
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer create(InsuranceApply insuranceApply) {
|
if (Objects.isNull(insuranceApply)
|
|| Objects.isNull(insuranceApply.getSolutionId())
|
|| Objects.isNull(insuranceApply.getApplyStartTime())
|
|| Objects.isNull(insuranceApply.getApplyEndTime())
|
|| !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList())
|
) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(!loginUserInfo.getType().equals(Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作");
|
}
|
Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");
|
}
|
|
List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();
|
//判断是否存在重复信息
|
List<Integer> memberIdList = applyDetailList.stream().map(i->i.getMemberId()).collect(Collectors.toList());
|
Set<Integer> set = new HashSet<>(memberIdList);
|
if(memberIdList.size() != set.size()){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"员工信息存在重复信息");
|
}
|
Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD;
|
insuranceApply.setCreateDate(new Date());
|
insuranceApply.setCreator(loginUserInfo.getId());
|
insuranceApply.setIsdeleted(Constants.ZERO);
|
insuranceApply.setCompanyId(loginUserInfo.getCompanyId());
|
insuranceApply.setCheckInfo(insuranceApplyStatus.getName());
|
insuranceApply.setCheckDate(new Date());
|
insuranceApply.setCheckUserId(loginUserInfo.getId());
|
insuranceApply.setStatus(insuranceApplyStatus.getKey());
|
insuranceApplyMapper.insert(insuranceApply);
|
//查询保险方案下的所有派遣单位
|
List<DuSolution> duSolutionList = duSolutionMapper.selectList(new QueryWrapper<DuSolution>().lambda()
|
.eq(DuSolution::getIsdeleted,Constants.ZERO)
|
.eq(DuSolution::getStatus,Constants.ONE)
|
.eq(DuSolution::getSolutionId,insuranceApply.getSolutionId()));
|
if(!CollectionUtils.isNotEmpty(duSolutionList)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常：保险方案下未查询到派遣单位");
|
}
|
//查询所有派遣单位下的工种
|
List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList());
|
List<DuWorktype> duWorktypeList = duWorktypeMapper.selectList(new QueryWrapper<DuWorktype>().lambda()
|
.eq(DuWorktype::getIsdeleted,Constants.ZERO)
|
.eq(DuWorktype::getStatus,Constants.ONE)
|
.in(DuWorktype::getDuSolutionId,duSolutionIdList));
|
if(!CollectionUtils.isNotEmpty(duWorktypeList)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常：保险方案下未查询到工种信息");
|
}
|
for (int i = 0; i < applyDetailList.size(); i++) {
|
ApplyDetail applyDetail = applyDetailList.get(i);
|
if(Objects.isNull(applyDetail)
|
||Objects.isNull(applyDetail.getMemberId())
|
||Objects.isNull(applyDetail.getDuId())
|
||Objects.isNull(applyDetail.getWorktypeId())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"投保员工信息数据缺失");
|
}
|
applyDetail.setCreateDate(new Date());
|
applyDetail.setCreator(loginUserInfo.getId());
|
applyDetail.setIsdeleted(Constants.ZERO);
|
applyDetail.setSortnum(i);
|
applyDetail.setApplyId(insuranceApply.getId());
|
if(Objects.isNull(applyDetail.getMemberId())){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工信息存在异常数据！");
|
}
|
Member member = memberMapper.selectById(applyDetail.getMemberId());
|
if(Objects.isNull(member)){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工信息存在异常数据！");
|
}
|
applyDetail.setIdcardNo(member.getIdcardNo());
|
applyDetail.setSex(member.getSex());
|
applyDetail.setFee(Constants.countDetailFee(solutions,insuranceApply.getApplyEndTime(),insuranceApply.getApplyStartTime()));
|
//验证派遣单位信息是否存在
|
if(duSolutionList.stream().filter(d->d.getDispatchUnitId().equals(applyDetail.getDuId())).collect(Collectors.toList()).size()<=Constants.ZERO){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工派遣单位未查询到！");
|
}
|
if(duWorktypeList.stream().filter(d->d.getDuSolutionId().equals(applyDetail.getDuId())&&d.getWorkTypeId().equals(applyDetail.getWorktypeId()))
|
.collect(Collectors.toList()).size()<=Constants.ZERO){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工工种信息未查询到！");
|
}
|
applyDetailMapper.insert(applyDetail);
|
}
|
//存储日志数据
|
this.saveApplyLog(insuranceApply,insuranceApplyStatus,null);
|
return insuranceApply.getId();
|
}
|
|
public void saveApplyLog(InsuranceApply insuranceApply,Constants.InsuranceApplyStatus insuranceApplyStatus,String content){
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
ApplyLog applyLog = new ApplyLog();
|
applyLog.setCreateDate(new Date());
|
applyLog.setCreator(loginUserInfo.getId());
|
applyLog.setIsdeleted(Constants.ZERO);
|
applyLog.setApplyId(insuranceApply.getId());
|
applyLog.setTitle(insuranceApplyStatus.getName());
|
applyLog.setContent(content);
|
applyLog.setObjType(insuranceApplyStatus.getKey());
|
applyLog.setObjId( insuranceApply.getId());
|
applyLog.setStatus(insuranceApply.getStatus());
|
applyLogMapper.insert(applyLog);
|
}
|
|
|
|
// public BigDecimal countDetailFee(Solutions solutions ,Date startDate,Date endDate){
|
// //查询保险实际周期
|
// Integer cycle = DateUtil.calculateBetween(endDate,startDate,solutions.getDataType());
|
// if(cycle==-1){
|
// throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"日期信息错误!");
|
// }
|
// return solutions.getPrice().multiply(new BigDecimal(cycle));
|
// }
|
|
// public static void main(String[] args) {
|
// Date date1 = DateUtil.StringToDate("2023-03-01 00:00:00");
|
// Date date2 = DateUtil.StringToDate("2023-04-01 00:00:00");
|
// System.out.println(DateUtil.calculateBetween(date1,date2,0));
|
// System.out.println(DateUtil.calculateBetween(date1,date2,1));
|
// System.out.println(DateUtil.calculateBetween(date1,date2,2));
|
// System.out.println(DateUtil.calculateBetween(date1,date2,3));
|
//
|
// }
|
|
|
@Override
|
public void deleteById(Integer id) {
|
insuranceApplyMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(InsuranceApply insuranceApply) {
|
UpdateWrapper<InsuranceApply> deleteWrapper = new UpdateWrapper<>(insuranceApply);
|
insuranceApplyMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
insuranceApplyMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(InsuranceApply insuranceApply) {
|
insuranceApplyMapper.updateById(insuranceApply);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<InsuranceApply> insuranceApplys) {
|
if (CollectionUtils.isEmpty(insuranceApplys)) {
|
return;
|
}
|
for (InsuranceApply insuranceApply: insuranceApplys) {
|
this.updateById(insuranceApply);
|
}
|
}
|
|
@Override
|
public InsuranceApply findById(Integer id) {
|
return insuranceApplyMapper.selectById(id);
|
}
|
|
@Override
|
public InsuranceApply findOne(InsuranceApply insuranceApply) {
|
QueryWrapper<InsuranceApply> wrapper = new QueryWrapper<>(insuranceApply);
|
return insuranceApplyMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<InsuranceApply> findList(InsuranceApply insuranceApply) {
|
QueryWrapper<InsuranceApply> wrapper = new QueryWrapper<>(insuranceApply);
|
return insuranceApplyMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<InsuranceApply> findPage(PageWrap<InsuranceApplyQueryDTO> pageWrap) {
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
IPage<InsuranceApply> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
queryWrapper.selectAll(InsuranceApply.class);
|
queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
|
queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
|
queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
|
//企业人员查看本企业数据
|
if(loginUserInfo.getType().equals(Constants.ONE)){
|
queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
|
}
|
if (pageWrap.getModel().getSolutionId() != null) {
|
queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId());
|
}
|
if (pageWrap.getModel().getEndTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTimeS()));
|
}
|
if (pageWrap.getModel().getEndTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTimeE()));
|
}
|
if (pageWrap.getModel().getStartTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTimeS()));
|
}
|
if (pageWrap.getModel().getStartTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTimeE()));
|
}
|
if (pageWrap.getModel().getCreateTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateTimeS()));
|
}
|
if (pageWrap.getModel().getCreateTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateTimeE()));
|
}
|
|
if (pageWrap.getModel().getCode() != null) {
|
queryWrapper.eq(InsuranceApply::getCode, pageWrap.getModel().getCode());
|
}
|
if (pageWrap.getModel().getStatus() != null) {
|
queryWrapper.eq(InsuranceApply::getStatus, pageWrap.getModel().getStatus());
|
}
|
for(PageWrap.SortData sortData: pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
PageData<InsuranceApply> pageData = PageData.from(insuranceApplyJoinMapper.selectJoinPage(page,InsuranceApply.class, queryWrapper));
|
return pageData;
|
}
|
|
|
|
@Override
|
public long count(InsuranceApply insuranceApply) {
|
QueryWrapper<InsuranceApply> wrapper = new QueryWrapper<>(insuranceApply);
|
return insuranceApplyMapper.selectCount(wrapper);
|
}
|
|
|
|
@Override
|
public InsuranceApply findDetail(Integer id) {
|
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Company::getName,ApplyLog::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getId,id)
|
.last("limit 1");
|
|
InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(Objects.isNull(insuranceApply)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
insuranceApply.setInsureNum(applyDetailMapper.selectCount(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId())
|
.eq(ApplyDetail::getIsdeleted,Constants.ZERO)));
|
|
//设置在保时长（天数）
|
if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
|
//如果当前时间大于结束日期 则使用结束日期对比开始日期
|
if(DateUtil.compareDate(new Date(),insuranceApply.getEndTime())>=Constants.ZERO){
|
insuranceApply.setServiceDays(DateUtil.daysBetweenDates(insuranceApply.getEndTime(),insuranceApply.getStartTime()));
|
}else if(DateUtil.compareDate(insuranceApply.getStartTime(),new Date())>=Constants.ZERO){
|
//未开始
|
insuranceApply.setServiceDays(Constants.ZERO);
|
}else{
|
insuranceApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),insuranceApply.getStartTime()));
|
}
|
}
|
|
//查询附件数据
|
initImgData(insuranceApply);
|
|
//查询操作记录
|
List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class,
|
new MPJLambdaWrapper<ApplyLog>()
|
.selectAll(ApplyLog.class)
|
.selectAs(Member::getName,ApplyLog::getCreatorName)
|
.selectAs(Company::getName,ApplyLog::getCompanyName)
|
.leftJoin(Member.class,Member::getId,ApplyLog::getCreator)
|
.leftJoin(Company.class,Company::getId,Member::getCompanyId)
|
.eq(ApplyLog::getApplyId,insuranceApply.getId())
|
.orderByAsc(ApplyLog::getCreateDate)
|
);
|
insuranceApply.setApplyLogList(applyLogList);
|
return insuranceApply;
|
}
|
private void initImgData(InsuranceApply model) {
|
List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda()
|
.eq(Multifile::getObjId,model.getId())
|
.in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.BD_APPLY_PDF.getKey()
|
,Constants.MultiFile.BD_SIGNED_PDF.getKey()
|
,Constants.MultiFile.BD_DONE_PDF.getKey()}))
|
.eq(Multifile::getIsdeleted,Constants.ZERO));
|
if(multifiles!=null){
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
|
for(Multifile f : multifiles){
|
if(StringUtils.isBlank(f.getFileurl())){
|
continue;
|
}
|
f.setFileurlFull(path+f.getFileurl());
|
if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_APPLY_PDF.getKey())){
|
//签署前的投保单
|
model.setBaoxiandanFile(f);
|
}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_SIGNED_PDF.getKey())){
|
//签署后的投保单
|
model.setToubaodanSignedFile(f);
|
}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_DONE_PDF.getKey())){
|
//最終保险单
|
model.setBaoxiandanFile(f);
|
}
|
}
|
}
|
}
|
@Override
|
public InsuranceApply findDetailForExport(InsuranceApply model){
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Company::getName,ApplyLog::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getId,model.getId())
|
.last("limit 1");
|
|
InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(Objects.isNull(insuranceApply)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
MPJLambdaWrapper wrapper1= new MPJLambdaWrapper<ApplyDetail>()
|
.selectAll(ApplyDetail.class)
|
.selectAs(Worktype::getName,ApplyDetail::getWorkTypeName)
|
.selectAs(DispatchUnit::getName,ApplyDetail::getDuName)
|
.leftJoin(Worktype.class,Worktype::getId,ApplyDetail::getWorktypeId)
|
.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyDetail::getDuId)
|
.eq(InsuranceApply::getId,model.getId());
|
//查询明细
|
List<ApplyDetail> detailList =applyDetailJoinMapper.selectJoinList(ApplyDetail.class,wrapper1);
|
if(detailList!=null){
|
insuranceApply.setInsureNum(detailList.size());
|
insuranceApply.setApplyDetailList(detailList);
|
}
|
insuranceApply.setRemark(model.getRemark());
|
return insuranceApply;
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void applyOpt(InsuranceApplyOptDTO insuranceApplyOptDTO){
|
if(Objects.isNull(insuranceApplyOptDTO)
|
||Objects.isNull(insuranceApplyOptDTO.getApplyId())
|
||StringUtils.isBlank(insuranceApplyOptDTO.getOptIllustration())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(loginUserInfo.getType().equals(Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作");
|
}
|
InsuranceApply insuranceApply = insuranceApplyMapper.selectById(insuranceApplyOptDTO.getApplyId());
|
if(Objects.isNull(insuranceApply)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(insuranceApply.getIsdeleted().equals(Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作");
|
}
|
//-----TODU-------RJ-------完善退回状态分开标记------------------
|
Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE;
|
if(insuranceApplyOptDTO.getOptType().equals(Constants.ONE)){
|
if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态非可申请退回!");
|
}
|
if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey())){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD;
|
}else if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE;
|
}else if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey())){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE;
|
}
|
}else if(insuranceApplyOptDTO.getOptType().equals(Constants.TWO)){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.CLOSE;
|
if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.CLOSE.getKey())){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"已关闭，请勿重复操作");
|
}
|
if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态非可申请退回!");
|
}
|
}
|
insuranceApply.setStatus(insuranceApplyStatus.getKey());
|
insuranceApply.setCheckDate(new Date());
|
insuranceApply.setCheckInfo(insuranceApplyOptDTO.getOptIllustration());
|
insuranceApply.setCheckUserId(loginUserInfo.getId());
|
insuranceApplyMapper.updateById(insuranceApply);
|
//存储日志数据
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.COMPANY_APPLY_RETURN;
|
String info =applyLogType.getInfo();
|
info = info.replace("${param}", insuranceApplyOptDTO.getOptIllustration());
|
ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),JSONObject.toJSONString(insuranceApply), JSONObject.toJSONString(insuranceApply));
|
applyLogMapper.insert(log);
|
// this.saveApplyLog(insuranceApply,insuranceApplyStatus,null);
|
}
|
|
|
|
}
|
