package com.doumee.service.business.impl;
|
|
import cn.hutool.core.util.IdcardUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.extension.api.R;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.annotation.excel.ExcelExporter;
|
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.core.utils.aliyun.ALiYunUtil;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.dto.CountCyclePriceDTO;
|
import com.doumee.dao.business.dto.InsuranceApplyOptDTO;
|
import com.doumee.dao.business.dto.InsuranceApplyQueryDTO;
|
import com.doumee.dao.business.dto.SmsCheckDTO;
|
import com.doumee.dao.business.join.*;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.vo.CountCyclePriceVO;
|
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.doumee.service.business.SmsEmailService;
|
import com.doumee.service.business.third.EmailService;
|
import com.doumee.service.business.third.SignService;
|
import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import com.jzq.common.bean.sign.NotifyDataReq;
|
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.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.File;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 投保申请信息表Service实现
|
* @author 江蹄蹄
|
* @date 2024/01/16 10:03
|
*/
|
@Service
|
public class InsuranceApplyServiceImpl implements InsuranceApplyService {
|
@Value("${debug_model}")
|
private boolean debugModel;
|
|
@Autowired
|
private InsuranceApplyMapper insuranceApplyMapper;
|
@Autowired
|
private SmsEmailService smsEmailService;
|
@Autowired
|
private ApplyChangeJoinMapper applyChangeMapper;
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
@Autowired
|
private InsuranceApplyJoinMapper insuranceApplyJoinMapper;
|
@Autowired
|
private CompanyMapper companyMapper;
|
@Autowired
|
private MemberInsuranceJoinMapper memberInsuranceJoinMapper;
|
|
@Autowired
|
private ApplyDetailMapper applyDetailMapper;
|
@Autowired
|
private ApplyDetailJoinMapper applyDetailJoinMapper;
|
|
@Autowired
|
private ApplyLogMapper applyLogMapper;
|
@Autowired
|
private SignService signService;
|
@Autowired
|
private MultifileMapper multifileMapper;
|
|
@Autowired
|
private ApplyLogJoinMapper applyLogJoinMapper;
|
|
@Autowired
|
private SolutionsMapper solutionsMapper;
|
|
@Autowired
|
private MemberMapper memberMapper;
|
@Autowired
|
private MemberJoinMapper memberJoinMapper;
|
@Autowired
|
private DuSolutionMapper duSolutionMapper;
|
@Autowired
|
private DuSolutionJoinMapper duSolutionJoinMapper;
|
@Autowired
|
private DuWorktypeMapper duWorktypeMapper;
|
@Autowired
|
private DuWorkTypeJoinMapper duWorkTypeJoinMapper;
|
|
@Autowired
|
private NoticesMapper noticesMapper;
|
@Autowired
|
private UnionApplyJoinMapper unionApplyJoinMapper;
|
@Autowired
|
private UnionChangeJoinMapper unionChangeJoinMapper;
|
@Autowired
|
private CompanySolutionMapper companySolutionMapper;
|
|
@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);
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
InsuranceApply update = new InsuranceApply();
|
if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){
|
if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
update.setStatus(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey());
|
}else{
|
if( !(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())
|
|| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
|
|| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.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);
|
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),
|
model.getCompanyId(), Constants.NoticeType.FOUR);
|
noticesMapper.insert(notices);
|
|
|
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 closeWtbForShop(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.WTB_BUSINESS_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.WTB_CLOSED.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.SHOP_CLOSE_WTB_APPLY;
|
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 || model.getStartTime().getTime()>model.getApplyEndTime().getTime() ){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请生效周期时间不符合要求，请确认后修改重试~");
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
//计算实际截止时间
|
Date actEndTime = new Date(model.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());
|
CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO();
|
countCyclePriceDTO.setSolutionsId(model.getSolutionId());
|
countCyclePriceDTO.setStartDate(insuranceApply.getStartTime());
|
update.setFinalEndTime(this.getCountCyclePriceVO(countCyclePriceDTO).getEndDate());
|
insuranceApplyMapper.updateById(update);
|
|
//修改明细行的开始结束日期
|
applyDetailMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda()
|
.set(ApplyDetail::getStartTime,insuranceApply.getStartTime())
|
.set(ApplyDetail::getEndTime,actEndTime)
|
.eq(ApplyDetail::getApplyId,model.getId()));
|
|
multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda()
|
.eq(Multifile::getIsdeleted,Constants.ZERO)
|
.eq(Multifile::getObjType,Constants.MultiFile.BD_DONE_PDF.getKey())
|
.eq(Multifile::getObjId,update.getId())
|
.set(Multifile::getIsdeleted,Constants.ONE)
|
.set(Multifile::getEditDate,update.getEditDate())
|
.set(Multifile::getEditor,update.getEditor())
|
);
|
|
insuranceApply.getBaoxiandanFile().setIsdeleted(Constants.ZERO);
|
insuranceApply.getBaoxiandanFile().setCreator(user.getId());
|
insuranceApply.getBaoxiandanFile().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());
|
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,Constants.NoticeObjectType.INSURANCE_APPLY.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
|
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.getStartTime()));
|
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);
|
|
|
//存储员工信息投保记录
|
//查询单据明细记录
|
MPJLambdaWrapper<ApplyDetail> queryWrapper = new MPJLambdaWrapper<>();
|
queryWrapper.selectAll(ApplyDetail.class);
|
queryWrapper.selectAs(DispatchUnit::getName,ApplyDetail::getDuName);
|
queryWrapper.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode);
|
queryWrapper.selectAs(Solutions::getId,ApplyDetail::getSolutionId);
|
queryWrapper.selectAs(Solutions::getName,ApplyDetail::getSolutionName);
|
queryWrapper.selectAs(Worktype::getName,ApplyDetail::getWorkTypeName);
|
queryWrapper.selectAs(Member::getIdcardNo,ApplyDetail::getIdcardNo);
|
queryWrapper.selectAs(Member::getName,ApplyDetail::getMemberName);
|
queryWrapper.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyDetail::getDuId);
|
queryWrapper.leftJoin(Worktype.class,Worktype::getId,ApplyDetail::getWorktypeId);
|
queryWrapper.leftJoin(Member.class,Member::getId,ApplyDetail::getMemberId);
|
queryWrapper.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId);
|
queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
|
queryWrapper.eq(ApplyDetail::getApplyId,insuranceApply.getId());
|
List<ApplyDetail> applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,queryWrapper);
|
|
if(CollectionUtils.isNotEmpty(applyDetailList)){
|
List<MemberInsurance> memberInsuranceList = new ArrayList<>();
|
for (ApplyDetail applyDetail:applyDetailList) {
|
|
//查询人员信息是否存在相同的方案下是否存在 冲突数据
|
this.checkMemberSolution(solutions.getBaseId(),applyDetail.getIdcardNo(),applyDetail.getMemberName(),update.getStartTime()
|
,update.getEndTime(),insuranceApply.getId());
|
|
MemberInsurance memberInsurance = new MemberInsurance(applyDetail,user.getId());
|
memberInsurance.setRelationType(Constants.ZERO);
|
memberInsuranceList.add(memberInsurance);
|
|
memberMapper.update(null,new UpdateWrapper<Member>()
|
.lambda()
|
.set(Member::getStartTime,memberInsurance.getStartTime())
|
.set(Member::getEndTime,memberInsurance.getEndTime())
|
.set(Member::getDuId,memberInsurance.getDuId())
|
.set(Member::getWorktypeId,memberInsurance.getWorktypeId())
|
.eq(Member::getId, memberInsurance.getMemberId())
|
);
|
|
}
|
memberInsuranceJoinMapper.insertBatchSomeColumn(memberInsuranceList);
|
}
|
|
this.updateApplyCurrentFee(insuranceApply.getId(),null);
|
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);
|
//修改员工保单记录
|
memberInsuranceJoinMapper.update(null,new UpdateWrapper<MemberInsurance>()
|
.lambda()
|
.set(MemberInsurance::getBdCode,param.getCode())
|
.eq(MemberInsurance::getApplyId,model.getId())
|
);
|
|
//删除原有的保单信息
|
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());
|
update.setStatus(model.getStatus());
|
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 = "";
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
//处理退回申请通知
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
InsuranceApply update = new InsuranceApply();
|
if(insuranceApply.getDealBackApply() ==1){
|
//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
|
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())||
|
Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey()))
|
){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
applyLogType = Constants.ApplyLogType.PLATFORM_UN_AGREE_BACK;
|
info = applyLogType.getInfo();
|
info = info.replace("${param}", insuranceApply.getCheckInfo());
|
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());
|
}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey())){
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.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;
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());
|
|
|
//通知企业 已退回
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.nonNull(solutions)){
|
Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),
|
insuranceApply.getCompanyId(), Constants.NoticeType.FOUR);
|
noticesMapper.insert(notices);
|
}
|
}
|
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
|
public String getSignLink(Integer id) {
|
if(id == null ){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getSignKeyword,InsuranceApply::getSignKeyword)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(InsuranceApply::getId,id)
|
.last("limit 1");
|
|
InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Constants.ApplyLogType applyLogType = null;
|
String info = "";
|
//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
Company company = user.getCompany();
|
if(debugModel){
|
company = companyMapper.selectById(model.getCompanyId());
|
}
|
if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~");
|
}
|
|
Multifile f = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda()
|
.eq(Multifile::getObjId,model.getId())
|
.eq(Multifile::getObjType,Constants.MultiFile.BD_APPLY_PDF.getKey())
|
.eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1"));
|
if(f == null || StringUtils.isBlank(f.getFileurl())){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取待签章文件失败，请联系平台管理员确认投保单是否正确！");
|
}
|
String url = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode()+f.getFileurl();
|
String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode();
|
notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString());
|
String applyNo = signService.applySign(company.getName(),url,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl);
|
if(StringUtils.isBlank(applyNo) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
String link = signService.signLink(applyNo,company.getName(),company.getCode());
|
if(StringUtils.isBlank(link) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
InsuranceApply update= new InsuranceApply();
|
update.setId(model.getId());
|
update.setEditor(user.getId());
|
update.setEditDate(new Date());
|
update.setCheckUserId(user.getId());
|
update.setCheckDate(new Date());
|
update.setSignApplyNo(applyNo);
|
insuranceApplyMapper.updateById(update);
|
return link;
|
}
|
|
|
public String uploadSignFile(String link){
|
try {
|
String bucketName = systemDictDataBiz.queryByCode(Constants.OSS,Constants.BUCKETNAME).getCode();
|
String access_id= systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_ID).getCode();
|
String access_key= systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_KEY).getCode();
|
String endpoint = systemDictDataBiz.queryByCode(Constants.OSS,Constants.ENDPOINT).getCode();
|
String folder = systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
|
String tempFileName = DateUtil.getNowShortDate() + "/" + UUID.randomUUID().toString() + ".pdf";
|
String key = folder + tempFileName;// 文件名
|
ALiYunUtil obs = new ALiYunUtil(endpoint,access_id, access_key);
|
if (obs.uploadOnlineObject(link,bucketName, key,null)) {
|
// 移动成功,返回文件名
|
return tempFileName;
|
}
|
}catch (Exception e){
|
}
|
return null;
|
|
}
|
|
|
public Multifile uploadSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("企业完成签署");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,model.getId()));
|
//平台待办
|
Notices notices = new Notices(noticeObjectType,Constants.ZERO,model.getId(),model.getSolutionsName(),model.getCompanyId(),Constants.NoticeType.TWO);
|
noticesMapper.insert(notices);
|
|
CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda()
|
.eq(CompanySolution::getIsdeleted,Constants.ZERO)
|
.eq(CompanySolution::getSolutionId,model.getSolutionId())
|
.eq(CompanySolution::getCompanyId,model.getCompanyId())
|
.last("limit 1")
|
);
|
//商户待办
|
if(Objects.nonNull(companySolution)&&Objects.nonNull(companySolution.getShopId())){
|
Notices shopNotices = new Notices(noticeObjectType,Constants.TWO,
|
model.getId(),model.getSolutionsName(),companySolution.getShopId(),Constants.NoticeType.ZERO);
|
noticesMapper.insert(shopNotices);
|
}
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.BD_SIGNED_PDF.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("投保单企业签约合同");
|
f.setName("投保单签约合同.pdf");
|
multifileMapper.insert(f);
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.SIGNATURE;
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
|
startSendEmail(f, model.getCompanyName(),model.getSolutionsName(),model.getSolutionEmail());
|
return f;
|
}
|
|
/**
|
* 委托保 方案确认书（企业）
|
* @param model
|
* @param fileurl
|
* @param fullUrl
|
* @return
|
*/
|
public Multifile uploadFAQRSSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setStatus(Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("企业完成签署方案确认书");
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("企业完成签署方案确认书");
|
f.setName("方案确认书.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WTB_FINISH_FAQRS;
|
ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
|
,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return f;
|
}
|
|
/**
|
* 委托保 企业签署投保申请书
|
* @param model
|
* @param fileurl
|
* @param fullUrl
|
* @return
|
*/
|
public Multifile uploadTBSQSSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setUnionApplyTbdStatus(Constants.TWO);
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("委托保企业完成签署投保申请书");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.BD_SIGNED_PDF.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("委托保企业完成签署投保申请书");
|
f.setName("投保申请书.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.SIGNATURE;
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), null
|
,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
return f;
|
}
|
|
/**
|
* 委托保 企业签署 人员名单
|
* @param model
|
* @param fileurl
|
* @param fullUrl
|
* @return
|
*/
|
public Multifile uploadApplyMemberListSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setStatus(Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("企业完成签署人员名单");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
insuranceApplyMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.MEMBER_LIST_LATTER.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("企业完成签署人员名单");
|
f.setName("人员名单.pdf");
|
multifileMapper.insert(f);
|
|
|
|
//数据日志
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WTB_FINISH_MEMBER_LIST;
|
ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
|
,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
//待办通知
|
if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
Notices notices = new Notices(noticeObjectType,Constants.TWO,model.getId(),model.getSolutionsName(),
|
solutions.getShopId(), Constants.NoticeType.SEVEN);
|
notices.setParam1(model.getId().toString());
|
noticesMapper.insert(notices);
|
}
|
|
|
return f;
|
}
|
|
|
public Multifile uploadChangeSignedFileDo(ApplyChange model,String fileurl,String fullurl) {
|
Integer companyId = model.getCompanyId();
|
ApplyChange update = new ApplyChange();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("企业完成签署");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
applyChangeMapper.updateById(update);
|
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE;
|
if(model.getType().equals(Constants.ONE)){
|
noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY;
|
}
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,model.getId()));
|
Notices notices = new Notices(noticeObjectType,Constants.ZERO,model.getId(),model.getSolutionsName(),
|
companyId, Constants.NoticeType.TWO);
|
notices.setParam1(model.getApplyId().toString());
|
noticesMapper.insert(notices);
|
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionsId());
|
//商户待办
|
if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
|
Notices shopNotices = new Notices(noticeObjectType,Constants.TWO,
|
model.getId(),solutions.getName(),solutions.getShopId(),Constants.NoticeType.TWO);
|
notices.setParam1(model.getApplyId().toString());
|
noticesMapper.insert(shopNotices);
|
}
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.equalsInteger(Constants.ZERO,model.getType())?Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() : Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullurl);
|
f.setInfo("企业申请表签署文件");
|
f.setName("签章申请表.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType =Constants.equalsInteger(Constants.ZERO,model.getType())? Constants.ApplyLogType.CA_JIAJIAN_APPLY_SIGN: Constants.ApplyLogType.CA_CHANGUNIT_APPLY_SIGN;
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
|
startSendEmail(f,model.getCompanyName(),model.getSolutionsName(),model.getSolutionEmail());
|
return f;
|
}
|
|
|
public Multifile uploadChangeMemberListSignedFileDo(ApplyChange model,String fileurl,String fullurl) {
|
ApplyChange update = new ApplyChange();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("企业完成签署人员名单");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
applyChangeMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
if(model.getType().equals(Constants.ZERO)){
|
f.setObjType(Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey());
|
}else{
|
f.setObjType(Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey());
|
}
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullurl);
|
f.setInfo("企业完成签署人员名单");
|
f.setName("签章人员名单.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_WTB_FINISH_MEMBER_LIST;
|
ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
|
applyLogMapper.insert(log);
|
|
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionsId());
|
//待办通知
|
if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE;
|
if(model.getType().equals(Constants.ONE)){
|
noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY;
|
}
|
Notices notices = new Notices(noticeObjectType,Constants.TWO,model.getId(),model.getSolutionsName(),
|
solutions.getShopId(), Constants.NoticeType.SEVEN);
|
notices.setParam1(model.getApplyId().toString());
|
noticesMapper.insert(notices);
|
}
|
return f;
|
}
|
|
/**
|
* 商户合并单 商户签署投保申请单
|
* @param model
|
* @param fileurl
|
* @param fullUrl
|
* @return
|
*/
|
public Multifile uploadUnionApplySignedFileDo(UnionApply model,String fileurl,String fullUrl) {
|
UnionApply update = new UnionApply();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setStatus(Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo("商户完成签署");
|
update.setCheckUserId(model.getCreator());
|
update.setId(model.getId());
|
unionApplyJoinMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.HBD_BD_SIGNED_PDF.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("商户签署投保单");
|
f.setName("商户签署投保单.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.IA_HBD_SIGNATURE_TBD;
|
ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
|
,model.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(model));
|
applyLogMapper.insert(log);
|
|
return f;
|
}
|
|
|
/**
|
* 商户合并单(加减保/换厂) 商户签署投保申请单
|
* @param model
|
* @param fileurl
|
* @param fullUrl
|
* @return
|
*/
|
public Multifile uploadUnionChangeSignedFileDo(UnionChange model,String fileurl,String fullUrl) {
|
UnionChange update = new UnionChange();
|
update.setEditDate(new Date());
|
update.setEditor(model.getCreator());
|
update.setStatus(Constants.UnionChangeStatus.UPLOAD_INSURANCE_POLICY.getKey());
|
update.setId(model.getId());
|
unionChangeJoinMapper.updateById(update);
|
|
Multifile f = new Multifile();
|
f.setIsdeleted(Constants.ZERO);
|
f.setCreator(model.getCreator());
|
f.setObjId(update.getId());
|
f.setCreateDate(update.getEditDate());
|
f.setObjType(Constants.MultiFile.WTB_CA_TBD_PDF.getKey());
|
f.setType(Constants.TWO);
|
f.setFileurl(fileurl);
|
f.setFileurlFull(fullUrl);
|
f.setInfo("投保申请单 -申请单");
|
f.setName("投保申请单.pdf");
|
multifileMapper.insert(f);
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_SIGNATURE_TBD;
|
ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
|
,model.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(model));
|
applyLogMapper.insert(log);
|
|
return f;
|
}
|
|
private void startSendEmail(Multifile f, String companyName, String solutionsName, String solutionEmail) {
|
if(StringUtils.isBlank(solutionEmail) || f==null|| StringUtils.isBlank(f.getFileurl())){
|
return;
|
}
|
SmsEmail email = new SmsEmail();
|
email.setTitle(f.getInfo());
|
email.setEmail(solutionEmail);
|
email.setContent("来自企业【"+companyName+"】关于保险方案【"+solutionsName+"】的"+f.getInfo());
|
File file = Constants.getFileByNetFile(f.getFileurlFull(),f.getName());
|
if(file!=null && file.isFile()){
|
Map<String,Object> files = new HashMap<>();
|
files.put("name",f.getName());
|
files.put("file",file);
|
email.setFileList(new ArrayList<>());
|
email.getFileList().add(files);
|
smsEmailService.sendEmail(email);
|
file.delete();//发送后删除临时文件
|
}
|
}
|
|
@Override
|
public void dealWaitSignedData(){
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
|
//直保保单 企业签章数据处理
|
List<InsuranceApply> applyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())
|
.eq(Solutions::getType,Constants.ZERO)
|
.isNotNull(InsuranceApply::getSignApplyNo));
|
if(applyList !=null && applyList.size()>0 ){
|
for(InsuranceApply model : applyList){
|
String status = signService.linkFileStatus(model.getSignApplyNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
//委托保 企业签署投保确认书
|
applyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
|
.eq(Solutions::getType,Constants.ONE)
|
.isNotNull(InsuranceApply::getSignQrsNo));
|
if(applyList !=null && applyList.size()>0 ){
|
for(InsuranceApply model : applyList){
|
String status = signService.linkFileStatus(model.getSignQrsNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignQrsNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadFAQRSSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
|
//委托保 企业签署人员名单
|
applyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
|
.eq(Solutions::getType,Constants.ONE)
|
.isNotNull(InsuranceApply::getSignMemberListNo));
|
if(applyList !=null && applyList.size()>0 ){
|
for(InsuranceApply model : applyList){
|
String status = signService.linkFileStatus(model.getSignMemberListNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignMemberListNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadApplyMemberListSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
|
//委托保企业签署投保申请单
|
applyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(InsuranceApply::getUnionApplyTbdStatus,Constants.ONE)
|
.eq(Solutions::getType,Constants.ONE)
|
.isNotNull(InsuranceApply::getApplyTbdNo));
|
|
if(applyList !=null && applyList.size()>0 ){
|
for(InsuranceApply model : applyList){
|
String status = signService.linkFileStatus(model.getApplyTbdNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getApplyTbdNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadTBSQSSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
|
|
|
List<ApplyChange> chagneList = applyChangeMapper.selectJoinList(ApplyChange.class,
|
new MPJLambdaWrapper<ApplyChange>()
|
.selectAll(ApplyChange.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Solutions::getId,ApplyChange::getSolutionsId)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.selectAs(InsuranceApply::getCompanyId,ApplyChange::getCompanyId)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD.getKey())
|
.eq(Solutions::getType,Constants.ZERO)
|
.isNotNull(ApplyChange::getSignApplyNo));
|
if(chagneList !=null && chagneList.size()>0 ){
|
for(ApplyChange model : chagneList){
|
String status = signService.linkFileStatus(model.getSignApplyNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadChangeSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
|
//委托保 加减保/换厂 签署人员名单
|
chagneList = applyChangeMapper.selectJoinList(ApplyChange.class,
|
new MPJLambdaWrapper<ApplyChange>()
|
.selectAll(ApplyChange.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Solutions::getId,ApplyChange::getSolutionsId)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.selectAs(InsuranceApply::getCompanyId,ApplyChange::getCompanyId)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD.getKey())
|
.eq(Solutions::getType,Constants.ONE)
|
.isNotNull(ApplyChange::getSignMemberListNo));
|
if(chagneList !=null && chagneList.size()>0 ){
|
for(ApplyChange model : chagneList){
|
String status = signService.linkFileStatus(model.getSignMemberListNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignMemberListNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadChangeMemberListSignedFileDo(model,fileUrl,path+fileUrl);
|
// return;
|
}
|
}
|
|
|
|
/**
|
*合并投保单 签署业务
|
*/
|
List<UnionApply> unionApplyList = unionApplyJoinMapper.selectJoinList(UnionApply.class,
|
new MPJLambdaWrapper<UnionApply>()
|
.selectAll(UnionApply.class)
|
.eq(UnionApply::getStatus,Constants.UnionApplyStatus.WAIT_SIGNATURE.getKey())
|
.isNotNull(UnionApply::getSignApplyNo));
|
if(unionApplyList !=null && unionApplyList.size()>0 ){
|
for(UnionApply model : unionApplyList){
|
String status = signService.linkFileStatus(model.getSignApplyNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadUnionApplySignedFileDo(model,fileUrl,path+fileUrl);
|
}
|
}
|
|
/**
|
*合并加减保换厂 签署业务
|
*/
|
List<UnionChange> unionChangeList = unionChangeJoinMapper.selectJoinList(UnionChange.class,
|
new MPJLambdaWrapper<UnionChange>()
|
.selectAll(UnionChange.class)
|
.eq(UnionChange::getStatus,Constants.UnionChangeStatus.MERGE.getKey())
|
.isNotNull(UnionChange::getSignApplyNo));
|
if(unionChangeList !=null && unionChangeList.size()>0 ){
|
for(UnionChange model : unionChangeList){
|
String status = signService.linkFileStatus(model.getSignApplyNo());
|
if(!StringUtils.equals(status,"3")){
|
continue;
|
}
|
String link = signService.linkFile(model.getSignApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
continue;
|
}
|
uploadUnionChangeSignedFileDo(model,fileUrl,path+fileUrl);
|
}
|
}
|
|
|
|
}
|
@Override
|
public String dealSignResult(NotifyDataReq data){
|
if(data.getApplyNo() == null ){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )
|
|| Constants.equalsInteger(data.getSignStatus(), Constants.TWO )){
|
//如果已保全,可下载签约附件
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
|
String r = dealXBTBBiz(path,data,"直保-投保申请签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealWTBQYQRSBiz(path,data,"委托保-企业方案确认书签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealWTBQYRYMQDBiz(path,data,"委托保-企业人员名单签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealWTBTBSQBiz(path,data,"委托保-投保申请书签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealZBJJBQYBiz(path,data,"直保-加减保企业签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealWTBJJBQYBiz(path,data,"委托保-加减保企业签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealHBDSHBiz(path,data,"投保合并单-商户签署签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
r = dealHBCHANGEQYBiz(path,data,"合并加减保/换厂签署");
|
if(StringUtils.isNotBlank(r)){
|
return r;
|
}
|
}
|
return "无处理数据";
|
}
|
|
private String dealHBCHANGEQYBiz(String path, NotifyDataReq data, String title) {
|
UnionChange unionChange = unionChangeJoinMapper.selectOne(
|
new MPJLambdaWrapper<UnionChange>()
|
.selectAll(UnionChange.class)
|
.eq(UnionChange::getSignApplyNo,data.getApplyNo())
|
.last(" limit 1 "));
|
if(unionChange == null){
|
return null;
|
}
|
if( Constants.equalsInteger(unionChange.getStatus(),Constants.UnionChangeStatus.MERGE.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(unionChange.getSignApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadUnionChangeSignedFileDo(unionChange,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
unionChangeJoinMapper.update(null,new UpdateWrapper<UnionChange>().lambda()
|
.set(UnionChange::getSignApplyNo,null)
|
.eq(UnionChange::getSignApplyNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
private String dealHBDSHBiz(String path, NotifyDataReq data, String title) {
|
//投保合并单 商户签署保单
|
UnionApply unionApply = unionApplyJoinMapper.selectOne(new QueryWrapper<UnionApply>()
|
.lambda().eq(UnionApply::getSignApplyNo,data.getApplyNo()).last(" limit 1 "));
|
if(unionApply == null){
|
return null;
|
}
|
if( Constants.equalsInteger(unionApply.getStatus(),Constants.UnionApplyStatus.WAIT_SIGNATURE.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadUnionApplySignedFileDo(unionApply,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
unionApplyJoinMapper.update(null,new UpdateWrapper<UnionApply>().lambda()
|
.set(UnionApply::getSignApplyNo,null)
|
.eq(UnionApply::getSignApplyNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
return title+"状态已流转，不做处理";
|
|
}
|
|
private String dealWTBJJBQYBiz(String path, NotifyDataReq data, String title) {
|
//委托保 加减保企业签署
|
ApplyChange applyChangeMemberList = applyChangeMapper.selectJoinOne(ApplyChange.class,
|
new MPJLambdaWrapper<ApplyChange>()
|
.selectAll(ApplyChange.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Solutions::getId,ApplyChange::getSolutionsId)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.selectAs(InsuranceApply::getCompanyId,ApplyChange::getCompanyId)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ONE)
|
.eq(ApplyChange::getSignMemberListNo,data.getApplyNo()).last("limit 1" ));
|
if(applyChangeMemberList == null){
|
return null;
|
}
|
if( Constants.equalsInteger(applyChangeMemberList.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadChangeMemberListSignedFileDo(applyChangeMemberList,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
applyChangeMapper.update(null,new UpdateWrapper<ApplyChange>().lambda()
|
.set(ApplyChange::getSignMemberListNo,null)
|
.eq(ApplyChange::getSignMemberListNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
private String dealZBJJBQYBiz(String path, NotifyDataReq data, String title) {
|
//直保 加减保企业签署
|
ApplyChange applyChange = applyChangeMapper.selectJoinOne(ApplyChange.class,
|
new MPJLambdaWrapper<ApplyChange>()
|
.selectAll(ApplyChange.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Solutions::getId,ApplyChange::getSolutionsId)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.selectAs(InsuranceApply::getCompanyId,ApplyChange::getCompanyId)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ZERO)
|
.eq(ApplyChange::getSignApplyNo,data.getApplyNo()).last("limit 1" ));
|
if(applyChange == null){
|
return null;
|
}
|
if( Constants.equalsInteger(applyChange.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadChangeSignedFileDo(applyChange,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
applyChangeMapper.update(null,new UpdateWrapper<ApplyChange>().lambda()
|
.set(ApplyChange::getSignApplyNo,null)
|
.eq(ApplyChange::getSignApplyNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
|
return title+"状态已流转，不做处理";
|
}
|
|
private String dealWTBTBSQBiz(String path, NotifyDataReq data, String title) {
|
//委托保 投保申请书签署
|
InsuranceApply modelTBQSQ = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ONE)
|
.eq(InsuranceApply::getApplyTbdNo,data.getApplyNo())
|
.last("limit 1" ));
|
if(modelTBQSQ == null){
|
return null;
|
}
|
if( Constants.equalsInteger(modelTBQSQ.getUnionApplyTbdStatus(),Constants.ONE)){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadTBSQSSignedFileDo(modelTBQSQ,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
|
.set(InsuranceApply::getApplyTbdNo,null)
|
.eq(InsuranceApply::getApplyTbdNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
private String dealWTBQYRYMQDBiz(String path, NotifyDataReq data, String title) {
|
//委托保 企业签署人员名单
|
InsuranceApply modelMemberList = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ONE)
|
.eq(InsuranceApply::getSignMemberListNo,data.getApplyNo())
|
.last("limit 1" ));
|
if(modelMemberList == null){
|
return null;
|
}
|
if( Constants.equalsInteger(modelMemberList.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadApplyMemberListSignedFileDo(modelMemberList,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
|
.set(InsuranceApply::getSignMemberListNo,null)
|
.eq(InsuranceApply::getSignMemberListNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
private String dealWTBQYQRSBiz(String path, NotifyDataReq data, String title) {
|
//委托保 企业方案确认书
|
InsuranceApply modelTBQRS = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ONE)
|
.eq(InsuranceApply::getSignQrsNo,data.getApplyNo())
|
.last("limit 1" ));
|
if(modelTBQRS == null){
|
return null;
|
}
|
if( Constants.equalsInteger(modelTBQRS.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())){
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
//完成签署已完成操作
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title+"合同下载失败，等待下次推送处理";
|
}
|
uploadFAQRSSignedFileDo(modelTBQRS,fileUrl,path+fileUrl);
|
return title+"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
|
.set(InsuranceApply::getSignQrsNo,null)
|
.eq(InsuranceApply::getSignQrsNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
/**
|
* 投保直保申请签署
|
* @param path
|
* @param data
|
* @return
|
*/
|
private String dealXBTBBiz(String path, NotifyDataReq data,String title) {
|
InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,
|
new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.eq(Solutions::getType,Constants.ZERO)
|
.eq(InsuranceApply::getSignApplyNo,data.getApplyNo())
|
.last("limit 1" ));
|
if(model == null){
|
return null;
|
}
|
if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){
|
//完成签署已完成操作
|
if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
|
String link = signService.linkFile(data.getApplyNo());
|
String fileUrl = uploadSignFile(link);
|
if(StringUtils.isBlank(fileUrl)){
|
//如果下载失败，清除合同，下次签章重新生成新合同
|
return title + "合同下载失败，等待下次推送处理";
|
}
|
uploadSignedFileDo(model,fileUrl,path+fileUrl);
|
return title +"状态处理成功";
|
}else{
|
//如果已拒签，清除合同，下次签章重新生成新合同
|
insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
|
.set(InsuranceApply::getSignApplyNo,null)
|
.eq(InsuranceApply::getSignApplyNo,data.getApplyNo()));
|
return title+"合同拒签处理成功";
|
}
|
|
}
|
return title+"状态已流转，不做处理";
|
}
|
|
|
@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.WAIT_SIGNATURE.getKey())
|
|| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.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);
|
|
multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda()
|
.eq(Multifile::getIsdeleted,Constants.ZERO)
|
.eq(Multifile::getObjType,Constants.MultiFile.BD_APPLY_PDF.getKey())
|
.eq(Multifile::getObjId,update.getId())
|
.set(Multifile::getIsdeleted,Constants.ONE)
|
.set(Multifile::getEditDate,update.getEditDate())
|
.set(Multifile::getEditor,update.getEditor())
|
);
|
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);
|
|
//删除其他待办
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));
|
|
Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),solutions.getName(),
|
model.getCompanyId(), Constants.NoticeType.ONE);
|
noticesMapper.insert(notices);
|
|
return 1;
|
|
}
|
|
/**
|
* 审核通过或者不通过
|
* @param insuranceApply
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer check(InsuranceApply insuranceApply) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(insuranceApply.getId() == null){
|
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);
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
if(Constants.equalsObject(solutions.getType(),Constants.ZERO)){
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
}else{
|
if(!Constants.equalsObject(user.getType(),Constants.TWO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户端无法进行该操作");
|
}
|
//委托保待签署、待审核可进行退回操作
|
if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
|
||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
|
||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())
|
)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
}
|
|
Constants.ApplyLogType applyLogType = null;
|
InsuranceApply update = new InsuranceApply();
|
update.setEditDate(new Date());
|
update.setEditor(user.getId());
|
update.setCheckDate(update.getEditDate());
|
update.setCheckInfo(insuranceApply.getCheckInfo());
|
update.setCheckUserId(user.getId());
|
update.setId(model.getId());
|
if(insuranceApply.getDealBackApply() ==1){
|
//如果是不通过
|
applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ;
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());
|
if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
|
update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.getKey());
|
}
|
}else{
|
applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS;
|
if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
|
update.setStatus(Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey());
|
}else{
|
update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey());
|
}
|
}
|
insuranceApplyMapper.updateById(update);
|
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
if(Constants.equalsObject(solutions.getType(),Constants.ZERO)) {
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda()
|
.eq(Notices::getObjType, noticeObjectType.getKey())
|
.ne(Notices::getType, Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId, model.getId()));
|
}else{
|
//删除全部待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda()
|
.eq(Notices::getObjType, noticeObjectType.getKey())
|
.eq(Notices::getObjId, model.getId()));
|
}
|
|
|
String info =applyLogType.getInfo();
|
if(StringUtils.isNotBlank(update.getCheckInfo())){
|
info = info.replace("${param}", update.getCheckInfo());
|
}else{
|
info = null;
|
}
|
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 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(),"未查询到方案信息");
|
}
|
if(!(solutions.getIsdeleted().equals(Constants.ZERO)||solutions.getStatus().equals(Constants.ZERO))){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"方案信息已被禁用");
|
}
|
if(solutions.getValidType().equals(Constants.ZERO)){
|
if(DateUtil.getMontageDate(
|
DateUtil.addDaysToDate(new Date(),solutions.getValidTypeNum()),1).getTime()
|
>insuranceApply.getApplyStartTime().getTime()){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"保单生效起期错误");
|
}
|
}else{
|
if(DateUtil.getMontageDate(DateUtil.getNextMonthFirst(new Date()),1).getTime()>insuranceApply.getApplyStartTime().getTime()){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"保单生效起期错误");
|
}
|
}
|
|
List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();
|
//判断是否存在重复信息
|
List<String> idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList());
|
Set<String> set = new HashSet<>(idCardList);
|
if(idCardList.size() != set.size()){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"员工信息存在重复信息");
|
}
|
Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD;
|
if(solutions.getType().equals(Constants.ONE)){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_UPLOAD;
|
}
|
insuranceApply.setCreateDate(new Date());
|
insuranceApply.setCreator(loginUserInfo.getId());
|
insuranceApply.setEditor(loginUserInfo.getId());
|
insuranceApply.setEditDate(new Date());
|
insuranceApply.setIsdeleted(Constants.ZERO);
|
insuranceApply.setCompanyId(loginUserInfo.getCompanyId());
|
insuranceApply.setCheckInfo(insuranceApplyStatus.getName());
|
insuranceApply.setStartTime(insuranceApply.getApplyStartTime());
|
insuranceApply.setCheckDate(new Date());
|
insuranceApply.setCurrentFee(BigDecimal.ZERO);
|
insuranceApply.setCheckUserId(loginUserInfo.getId());
|
insuranceApply.setStatus(insuranceApplyStatus.getKey());
|
insuranceApply.setUnionApplyTbdStatus(Constants.ZERO);
|
CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO();
|
countCyclePriceDTO.setSolutionsId(insuranceApply.getSolutionId());
|
countCyclePriceDTO.setStartDate(insuranceApply.getStartTime());
|
CountCyclePriceVO countCyclePriceVO = this.getCountCyclePriceVO(countCyclePriceDTO);
|
insuranceApply.setApplyEndTime(countCyclePriceVO.getEndDate());
|
insuranceApply.setEndTime(countCyclePriceVO.getEndDate());
|
insuranceApply.setFinalEndTime(countCyclePriceVO.getEndDate());
|
insuranceApplyMapper.insert(insuranceApply);
|
//处理下级数据
|
this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO,true);
|
InsuranceApply updBean = new InsuranceApply();
|
updBean.setId(insuranceApply.getId());
|
updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));
|
insuranceApplyMapper.updateById(updBean);
|
|
// if(1==1){
|
// throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
// }
|
|
//存储日志数据
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD;
|
String info =applyLogType.getInfo();
|
// info = info.replace("${param}", update.getCheckInfo());
|
ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),null, null);
|
applyLogMapper.insert(log);
|
|
//直保业务发送待办
|
if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
//存储平台待办
|
Notices notices = new Notices(noticeObjectType,Constants.ZERO,insuranceApply.getId(),solutions.getName(),insuranceApply.getCompanyId(),Constants.NoticeType.ZERO);
|
noticesMapper.insert(notices);
|
CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda()
|
.eq(CompanySolution::getIsdeleted,Constants.ZERO)
|
.eq(CompanySolution::getSolutionId,solutions.getId())
|
.eq(CompanySolution::getCompanyId,insuranceApply.getCompanyId())
|
.last("limit 1")
|
);
|
//商户待办
|
if(Objects.nonNull(companySolution)&&Objects.nonNull(companySolution.getShopId())){
|
Notices shopNotices = new Notices(noticeObjectType,Constants.TWO,
|
insuranceApply.getId(),solutions.getName(),companySolution.getShopId(),Constants.NoticeType.ZERO);
|
noticesMapper.insert(shopNotices);
|
}
|
}
|
return insuranceApply.getId();
|
}
|
|
|
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public Integer updateData(InsuranceApply insuranceApply) {
|
if (Objects.isNull(insuranceApply)
|
|| Objects.isNull(insuranceApply.getId())
|
|| 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(),"用户类型错误：非企业用户无法进行该操作");
|
}
|
InsuranceApply dbInsuranceApply = insuranceApplyMapper.selectById(insuranceApply.getId());
|
if(Objects.isNull(dbInsuranceApply)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到修改对象信息");
|
}
|
if(!(dbInsuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey())
|
|| dbInsuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()))
|
){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"状态错误，当前状态无法进行该操作");
|
}
|
List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();
|
//判断是否存在重复信息
|
List<String> idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList());
|
Set<String> set = new HashSet<>(idCardList);
|
if(idCardList.size() != set.size()){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"员工信息存在重复信息");
|
}
|
Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD;
|
insuranceApply.setEditDate(new Date());
|
insuranceApply.setEditor(loginUserInfo.getId());
|
insuranceApply.setIsdeleted(Constants.ZERO);
|
insuranceApply.setCompanyId(loginUserInfo.getCompanyId());
|
insuranceApply.setCheckInfo(insuranceApplyStatus.getName());
|
insuranceApply.setStartTime(insuranceApply.getApplyStartTime());
|
insuranceApply.setCheckDate(new Date());
|
insuranceApply.setCurrentFee(BigDecimal.ZERO);
|
insuranceApply.setCheckUserId(loginUserInfo.getId());
|
insuranceApply.setStatus(insuranceApplyStatus.getKey());
|
|
CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO();
|
countCyclePriceDTO.setSolutionsId(insuranceApply.getSolutionId());
|
countCyclePriceDTO.setStartDate(insuranceApply.getStartTime());
|
CountCyclePriceVO countCyclePriceVO = this.getCountCyclePriceVO(countCyclePriceDTO);
|
insuranceApply.setApplyEndTime(countCyclePriceVO.getEndDate());
|
insuranceApply.setEndTime(countCyclePriceVO.getEndDate());
|
|
applyDetailMapper.delete(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId()));
|
|
Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");
|
}
|
|
//处理下级数据
|
this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO,false);
|
insuranceApply.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));
|
insuranceApplyMapper.updateById(insuranceApply);
|
//存储日志数据
|
|
Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD_AGAIN;
|
String info =applyLogType.getInfo();
|
// info = info.replace("${param}", update.getCheckInfo());
|
ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),null, null);
|
applyLogMapper.insert(log);
|
|
|
//存储待办信息
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
Notices notices = new Notices(noticeObjectType,Constants.ZERO,insuranceApply.getId(),solutions.getName(),insuranceApply.getCompanyId(),Constants.NoticeType.ZERO);
|
noticesMapper.insert(notices);
|
|
return insuranceApply.getId();
|
}
|
|
|
|
public void dealApplyDetailData(InsuranceApply insuranceApply,Solutions solutions,List<ApplyDetail> applyDetailList,
|
LoginUserInfo loginUserInfo,CountCyclePriceVO countCyclePriceVO,Boolean checkNewData){
|
//查询保险方案下的所有派遣单位
|
List<DuSolution> duSolutionList = duSolutionJoinMapper.selectJoinList(DuSolution.class,new MPJLambdaWrapper<DuSolution>()
|
.selectAll(DuSolution.class)
|
.innerJoin(DispatchUnit.class,DispatchUnit::getId,DuSolution::getDispatchUnitId)
|
.eq(DispatchUnit::getCompanyId,insuranceApply.getCompanyId())
|
.eq(DispatchUnit::getIsdeleted,Constants.ZERO)
|
.eq(DispatchUnit::getUnitStatus,Constants.ONE)
|
.eq(DuSolution::getIsdeleted,Constants.ZERO)
|
.eq(checkNewData,DispatchUnit::getDataType,Constants.TWO)
|
.eq(DuSolution::getStatus,Constants.ONE)
|
.eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())
|
.apply(" t1.BASE_ID in ( select du.id from dispatch_unit du where du.STATUS = 0 and du.ISDELETED = 0 ) ")
|
);
|
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 = duWorkTypeJoinMapper.selectJoinList(DuWorktype.class,new MPJLambdaWrapper<DuWorktype>()
|
.selectAll(DuWorktype.class)
|
.innerJoin(Worktype.class,Worktype::getId,DuWorktype::getWorkTypeId)
|
.eq(DuWorktype::getIsdeleted,Constants.ZERO)
|
.eq(DuWorktype::getStatus,Constants.ONE)
|
.eq(checkNewData,Worktype::getDataType,Constants.TWO)
|
.in(DuWorktype::getDuSolutionId,duSolutionIdList));
|
if(!CollectionUtils.isNotEmpty(duWorktypeList)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息，请确保派遣单位和工作配置并审核通过！");
|
}
|
|
if(CollectionUtils.isNotEmpty(applyDetailList)){
|
List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
|
.eq(Member::getCompanyId,insuranceApply.getCompanyId())
|
.eq(Member::getIsdeleted,Constants.ZERO));
|
|
List<Member> addMemberList = new ArrayList<>();
|
for (int i = 0; i < applyDetailList.size(); i++) {
|
ApplyDetail applyDetail = applyDetailList.get(i);
|
Member member = null;
|
if(CollectionUtils.isNotEmpty(memberList)){
|
Optional<Member> optional = memberList.stream().filter(m->m.getIdcardNo().equals(applyDetail.getIdcardNo())).findFirst();
|
if(optional.isPresent()){
|
member = optional.get();
|
}
|
}
|
if(Objects.isNull(member)){
|
member = new Member();
|
member.setCreateDate(new Date());
|
member.setCreator(loginUserInfo.getId());
|
member.setIsdeleted(Constants.ZERO);
|
member.setName(applyDetail.getMemberName());
|
member.setCompanyId(insuranceApply.getCompanyId());
|
member.setSex(Constants.getSexByIdCard(applyDetail.getIdcardNo()));
|
if(!IdcardUtil.isValidCard(applyDetail.getIdcardNo())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，投保员工【"+member.getName()+"】身份证信息【"+applyDetail.getIdcardNo()+"】错误");
|
}
|
member.setIdcardNo(applyDetail.getIdcardNo());
|
member.setApplyId(insuranceApply.getId());
|
// member.setStartTime(applyDetail.getStartTime());
|
// member.setEndTime(applyDetail.getEndTime());
|
member.setDuId(applyDetail.getDuId());
|
member.setWorktypeId(applyDetail.getWorktypeId());
|
addMemberList.add(member);
|
}
|
//查询人员信息是否存在相同的方案下是否存在 冲突数据
|
this.checkMemberSolution(solutions.getBaseId(),member.getIdcardNo(),member.getName(),insuranceApply.getStartTime(),insuranceApply.getEndTime(),insuranceApply.getId());
|
}
|
if(CollectionUtils.isNotEmpty(addMemberList)){
|
memberJoinMapper.insertBatchSomeColumn(addMemberList);
|
}
|
memberList.addAll(addMemberList);
|
for (int i = 0; i < applyDetailList.size(); i++) {
|
ApplyDetail applyDetail = applyDetailList.get(i);
|
if(Objects.isNull(applyDetail)
|
||StringUtils.isBlank(applyDetail.getIdcardNo())
|
||StringUtils.isBlank(applyDetail.getMemberName())
|
||Objects.isNull(applyDetail.getDuId())
|
||Objects.isNull(applyDetail.getWorktypeId())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，投保员工信息数据缺失，请按照要求填写员工的有效信息！");
|
}
|
applyDetail.setChangeStatus(Constants.ZERO);
|
applyDetail.setCreateDate(new Date());
|
applyDetail.setCreator(loginUserInfo.getId());
|
applyDetail.setIsdeleted(Constants.ZERO);
|
applyDetail.setStartTime(insuranceApply.getApplyStartTime());
|
applyDetail.setEndTime(insuranceApply.getApplyEndTime());
|
applyDetail.setSortnum(i);
|
applyDetail.setApplyId(insuranceApply.getId());
|
|
//根据员工身份证进行判断年龄
|
long age = Constants.getAgeByIdCard(applyDetail.getIdcardNo());
|
if(Objects.isNull(age)
|
|| age > solutions.getMaxAge()
|
|| age < solutions.getMinAge()){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyDetail.getMemberName()+"】员工年龄超出方案配置,方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】！");
|
}
|
|
Member member = null;
|
if(Objects.isNull(applyDetail.getMemberId())){
|
if(CollectionUtils.isNotEmpty(memberList)){
|
Optional<Member> optional = memberList.stream().filter(m->m.getIdcardNo().equals(applyDetail.getIdcardNo())).findFirst();
|
if(optional.isPresent()){
|
member = optional.get();
|
}
|
}
|
//查询是否存在该用户
|
if(!Objects.isNull(member)){
|
member.setApplyId(insuranceApply.getId());
|
member.setDuId(applyDetail.getDuId());
|
member.setWorktypeId(applyDetail.getWorktypeId());
|
// member.setStartTime(applyDetail.getStartTime());
|
// member.setEndTime(applyDetail.getEndTime());
|
memberMapper.updateById(member);
|
}
|
}else{
|
member = memberMapper.selectById(applyDetail.getMemberId());
|
if(Objects.isNull(member)){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工信息存在异常数据！");
|
}
|
member.setApplyId(insuranceApply.getId());
|
member.setDuId(applyDetail.getDuId());
|
member.setWorktypeId(applyDetail.getWorktypeId());
|
// member.setStartTime(applyDetail.getStartTime());
|
// member.setEndTime(applyDetail.getEndTime());
|
memberMapper.updateById(member);
|
}
|
|
|
applyDetail.setMemberId(member.getId());
|
applyDetail.setIdcardNo(member.getIdcardNo());
|
applyDetail.setSex(member.getSex());
|
applyDetail.setFee(countCyclePriceVO.getCyclePrice());
|
applyDetail.setCurrentFee(BigDecimal.ZERO);
|
//获取计算总天数
|
Integer maxDays = DateUtil.calculateBetween(applyDetail.getStartTime(),applyDetail.getEndTime(),0);
|
if(Constants.equalsInteger(maxDays,0)||Objects.isNull(applyDetail.getFee())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"投保信息异常：投保总天数与总金额错误");
|
}
|
applyDetail.setPrice(
|
applyDetail.getFee().divide(new BigDecimal(maxDays),7,RoundingMode.HALF_UP)
|
);
|
//验证派遣单位信息是否存在
|
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()+applyDetail.getIdcardNo()+"】员工派遣单位未查询到！");
|
}
|
if(duWorktypeList.stream().filter(d->d.getWorkTypeId().equals(applyDetail.getWorktypeId()))
|
.collect(Collectors.toList()).size()<=Constants.ZERO){
|
throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工工种信息未查询到！");
|
}
|
}
|
applyDetailJoinMapper.insertBatchSomeColumn(applyDetailList);
|
}
|
}
|
|
|
/**
|
* 查询 会员信息在方案下是否存在冲突数据
|
* @param solutionId
|
* @param startTime
|
* @param endTime
|
*/
|
@Override
|
public void checkMemberSolution(Integer solutionId,String idCode,String memberName,Date startTime,Date endTime,Integer applyId){
|
List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
|
try {
|
applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
|
new MPJLambdaWrapper<ApplyDetail>()
|
.selectAll(ApplyDetail.class)
|
.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(ApplyDetail::getIdcardNo,idCode)
|
.eq(ApplyDetail::getIsdeleted,Constants.ZERO)
|
.eq(Solutions::getBaseId,solutionId)
|
.ne(Objects.nonNull(applyId),InsuranceApply::getId,applyId)
|
.notIn(InsuranceApply::getStatus
|
,Constants.InsuranceApplyStatus.CLOSE.getKey()
|
,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
|
.apply(" ( " +
|
" '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
|
" or " +
|
" ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
|
" or " +
|
" ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
|
" ) " ));
|
}catch (Exception e){
|
}
|
if(applyDetailList.size() >Constants.ZERO){
|
ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO);
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
|
};
|
}
|
|
public static void checkStaticMemberSolution(Integer solutionId,String idCode,String memberName,Date startTime,
|
Date endTime,ApplyDetailJoinMapper applyDetailJoinMapper){
|
List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
|
try {
|
applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
|
new MPJLambdaWrapper<ApplyDetail>()
|
.selectAll(ApplyDetail.class)
|
.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(ApplyDetail::getIdcardNo,idCode)
|
.eq(Solutions::getBaseId,solutionId)
|
.eq(ApplyDetail::getIsdeleted,Constants.ZERO)
|
.notIn(InsuranceApply::getStatus
|
,Constants.InsuranceApplyStatus.CLOSE.getKey()
|
,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
|
.apply(" ( " +
|
" '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
|
" or " +
|
" ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
|
" or " +
|
" ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
|
" ) " ));
|
}catch (Exception e){
|
|
}
|
if(applyDetailList.size() >Constants.ZERO){
|
ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO);
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
|
};
|
}
|
|
@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);
|
}
|
|
public List<Integer> getCollectStatus(Integer collectStatus){
|
if(collectStatus ==null){
|
return new ArrayList<>();
|
}
|
List<Integer> statusList = Constants.InsuranceApplyStatus.getKesByStatus(collectStatus);
|
if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.DCD.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBDCD.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.DSP.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBDSH.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.BZZ.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBBZZ.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.YTH.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBYTH.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.YGB.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBYGB.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.DQYQZ.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBDQS.getKey()));
|
}else if(Constants.equalsInteger(collectStatus,Constants.ApplyCollectStatus.YGQ.getKey())){
|
statusList.addAll(Constants.InsuranceApplyStatus.getKesByStatus(Constants.ApplyCollectStatus.WTBBZZ.getKey()));
|
statusList.add(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
|
}
|
|
return statusList;
|
}
|
|
@Override
|
public PageData<InsuranceApply> findPage(PageWrap<InsuranceApplyQueryDTO> pageWrap) {
|
IPage<InsuranceApply> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
|
List<Integer> statusList = this.getCollectStatus(pageWrap.getModel().getStatusCollect());
|
|
queryWrapper.selectAll(InsuranceApply.class);
|
queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
|
queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
|
queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
|
queryWrapper.selectAs(Solutions::getMaxAge,InsuranceApply::getMaxAge);
|
queryWrapper.selectAs(Solutions::getMinAge,InsuranceApply::getMinAge);
|
queryWrapper.selectAs(Solutions::getPrice,InsuranceApply::getPrice);
|
queryWrapper.selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit);
|
queryWrapper.select(" DATEDIFF( t.END_TIME ,now() ) AS loseEfficacyDays ");
|
queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum");
|
queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum");
|
if(!Objects.isNull(pageWrap.getModel())&&!Objects.isNull(pageWrap.getModel().getType())){
|
queryWrapper.select(" ifnull(( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ),0) as taxesMoney");
|
queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status = 1 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
|
}
|
queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
|
queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
|
queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
|
queryWrapper.eq(pageWrap.getModel().getBaseSolutionId()!=null,Solutions::getBaseId,pageWrap.getModel().getBaseSolutionId());
|
queryWrapper.in(statusList.size()>0,InsuranceApply::getStatus,statusList);
|
queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getSolutionName()),Solutions::getName,pageWrap.getModel().getSolutionName());
|
if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.YGQ.getKey()) ){
|
//如果是已過期
|
// queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
|
queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
|
}else if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.BZZ.getKey()) ){
|
//如果是保障中
|
// queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
|
queryWrapper.gt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
|
}
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
|
//企业人员查看本企业数据
|
if(loginUserInfo.getType().equals(Constants.ONE)){
|
queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
|
}else if(loginUserInfo.getType().equals(Constants.TWO)){
|
//如果是商户查看
|
if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType().equals(0)){
|
queryWrapper.exists("select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId());
|
}else if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==1){
|
queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId());
|
}else{
|
queryWrapper.apply("((t1.type=0 and exists(select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" +
|
"t1.type=1 and t1.shop_id="+loginUserInfo.getCompanyId()+"))") ;
|
}
|
}else{
|
if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){
|
queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList());
|
}else{
|
queryWrapper.eq(InsuranceApply::getCompanyId, -1);
|
}
|
queryWrapper.eq(pageWrap.getModel().getCompanyId()!=null,InsuranceApply::getCompanyId, pageWrap.getModel().getCompanyId());
|
}
|
if (pageWrap.getModel().getCompanyId() != null) {
|
queryWrapper.eq(InsuranceApply::getCompanyId, pageWrap.getModel().getCompanyId());
|
}
|
if (pageWrap.getModel().getSolutionId() != null) {
|
queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId());
|
}
|
if (pageWrap.getModel().getSolutionType() != null) {
|
queryWrapper.eq(Solutions::getType, pageWrap.getModel().getSolutionType());
|
}
|
if (pageWrap.getModel().getEndTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTimeS()));
|
}
|
if (pageWrap.getModel().getEndTimeE() != null) {
|
queryWrapper.lt(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.lt(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.lt(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateTimeE()));
|
}
|
if (pageWrap.getModel().getType() != null) {
|
queryWrapper.eq(Solutions::getType, pageWrap.getModel().getType());
|
}
|
if (pageWrap.getModel().getCode() != null) {
|
queryWrapper.eq(InsuranceApply::getCode, pageWrap.getModel().getCode());
|
}
|
if (pageWrap.getModel().getStatus() != null) {
|
queryWrapper.in(InsuranceApply::getStatus, pageWrap.getModel().getStatus().split(","));
|
}
|
if (pageWrap.getModel().getLoseEfficacy() != null && pageWrap.getModel().getLoseEfficacy() ==1) {
|
queryWrapper.apply(" DATEDIFF(t.END_TIME,CURRENT_DATE() ) <= 5 and t.END_TIME >= now() ");
|
}
|
if(CollectionUtils.isNotEmpty(pageWrap.getSorts())){
|
for(PageWrap.SortData sortData: pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
}else{
|
queryWrapper.orderByDesc(InsuranceApply::getCreateDate);
|
}
|
|
PageData<InsuranceApply> pageData = PageData.from(insuranceApplyJoinMapper.selectJoinPage(page,InsuranceApply.class, queryWrapper));
|
if(pageData.getRecords()!=null){
|
for (InsuranceApply apply : pageData.getRecords()){
|
initApplyStatus(apply) ;
|
}
|
}
|
return pageData;
|
}
|
|
public void initApplyStatus(InsuranceApply apply){
|
apply.setStatusCollect(Constants.InsuranceApplyStatus.getCollectStatus(apply.getStatus()));
|
if(Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
|
|| Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey())){
|
//如果已完成
|
if(apply.getEndTime()==null || System.currentTimeMillis()>apply.getEndTime().getTime()){
|
apply.setStatusCollect(Constants.THREE);//已过期
|
}
|
}
|
setServiceDays(apply);
|
apply.setStatusInfo(Constants.ApplyCollectStatus.getName(apply.getStatusCollect()));
|
|
}
|
|
@Override
|
public List<InsuranceApply> findListByDTO(InsuranceApplyQueryDTO model) {
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
|
MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
|
queryWrapper.selectAll(InsuranceApply.class);
|
queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
|
queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
|
queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
|
queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum");
|
queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum");
|
queryWrapper.select(" ( select max(ac.APPLY_START_TIME) from apply_change ac where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate");
|
queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney ");
|
queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
|
queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
|
queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
|
queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
|
queryWrapper.eq(model.getUnionApplyId()!=null,InsuranceApply::getUnionApplyId, model.getUnionApplyId());
|
queryWrapper.eq(model.getBaseSolutionId()!=null,Solutions::getBaseId,model.getBaseSolutionId());
|
//企业人员查看本企业数据
|
if(loginUserInfo.getType().equals(Constants.ONE)){
|
queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
|
}else if(loginUserInfo.getType().equals(Constants.TWO)){
|
//如果是商家查看
|
queryWrapper.eq(Solutions::getShopId, loginUserInfo.getCompanyId());
|
}else{
|
if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){
|
queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList());
|
}else{
|
queryWrapper.eq(InsuranceApply::getCompanyId, -1);
|
}
|
}
|
if (model.getSolutionId() != null) {
|
queryWrapper.eq(InsuranceApply::getSolutionId, model.getSolutionId());
|
}
|
if (model.getSolutionType() != null) {
|
queryWrapper.eq(Solutions::getType,model.getSolutionType() );
|
}
|
if (model.getEndTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(model.getEndTimeS()));
|
}
|
if (model.getEndTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(model.getEndTimeE()));
|
}
|
if (model.getStartTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(model.getStartTimeS()));
|
}
|
if (model.getStartTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(model.getStartTimeE()));
|
}
|
if (model.getCreateTimeS() != null) {
|
queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(model.getCreateTimeS()));
|
}
|
if (model.getCreateTimeE() != null) {
|
queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(model.getCreateTimeE()));
|
}
|
if (model.getType() != null) {
|
queryWrapper.eq(Solutions::getType, model.getType());
|
}
|
if (model.getCode() != null) {
|
queryWrapper.eq(InsuranceApply::getCode, model.getCode());
|
}
|
if (model.getStatus() != null) {
|
queryWrapper.in(InsuranceApply::getStatus, model.getStatus().split(","));
|
}
|
if (CollectionUtils.isNotEmpty(model.getIds())) {
|
queryWrapper.in(InsuranceApply::getId, model.getIds());
|
}
|
if (CollectionUtils.isNotEmpty(model.getIds())) {
|
queryWrapper.in(InsuranceApply::getId, model.getIds());
|
}
|
if (model.getIsEffective() != null && model.getIsEffective().equals(Constants.ZERO)) {
|
queryWrapper.ge(InsuranceApply::getEndTime,DateUtil.DateToStr(new Date(),"yyyy-MM-dd HH:mm:ss"));
|
}
|
List<InsuranceApply> list = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class, queryWrapper);
|
if(Constants.equalsObject(model.getGetFiles(),Constants.ONE)){
|
//如果是合并单,需要查询附件信息
|
initFileForList(list);
|
}
|
return list;
|
}
|
|
private void initFileForList(List<InsuranceApply> list) {
|
List<Integer> objList = new ArrayList<>();
|
if(list!=null && list.size()>0){
|
for(InsuranceApply param : list){
|
objList.add(param.getId());
|
}
|
}else{
|
return;
|
}
|
List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda()
|
.in(Multifile::getObjId,objList)
|
.in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.BD_APPLY_PDF.getKey()
|
,Constants.MultiFile.BD_SIGNED_PDF.getKey()
|
,Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey()
|
,Constants.MultiFile.MEMBER_LIST_LATTER.getKey()
|
,Constants.MultiFile.BD_DONE_PDF.getKey()}))
|
.eq(Multifile::getIsdeleted,Constants.ZERO)
|
.orderByAsc(Multifile::getId));
|
if(multifiles!=null && multifiles.size()>0){
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
|
for(InsuranceApply model : list){
|
for(Multifile f : multifiles) {
|
if (StringUtils.isBlank(f.getFileurl())) {
|
continue;
|
}
|
f.setFileurlFull(path+f.getFileurl());
|
if(Constants.equalsInteger(f.getObjId(), model.getId()) ){
|
if (Constants.equalsInteger(f.getObjType(), Constants.MultiFile.BD_APPLY_PDF.getKey())) {
|
//签署前的投保单
|
model.setToubaodanFile(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);
|
} else if (Constants.equalsInteger(f.getObjType(), Constants.MultiFile.MEMBER_LIST_LATTER.getKey())) {
|
//申请单
|
model.setShenqingdanFile(f);
|
} else if (Constants.equalsInteger(f.getObjType(), Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey())) {
|
//签署后确认书
|
model.setFanganFile(f);
|
}
|
}
|
}
|
}
|
}
|
|
}
|
|
|
@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::getMaxAge,InsuranceApply::getMaxAge)
|
.selectAs(Solutions::getMinAge,InsuranceApply::getMinAge)
|
.selectAs(Solutions::getPrice,InsuranceApply::getPrice)
|
.selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit)
|
.selectAs(Solutions::getType,InsuranceApply::getSolutionType)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.select(" ( select max(ac.APPLY_START_TIME) from apply_change ac where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate")
|
.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum")
|
.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum")
|
.select(" t3.name as shopName")
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
|
.leftJoin(Company.class,Company::getId,Solutions::getShopId)
|
.eq(InsuranceApply::getId,id)
|
.last("limit 1");
|
|
InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(Objects.isNull(insuranceApply)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到方案信息");
|
}
|
if(solutions.getDataType().equals(Constants.ONE)){
|
Solutions newVersionSolution = solutionsMapper.selectOne(new QueryWrapper<Solutions>().lambda().eq(Solutions::getBaseId,solutions.getBaseId()).eq(Solutions::getDataType,Constants.TWO).last("limit 1"));
|
if(Objects.isNull(newVersionSolution)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到方案最新版本信息");
|
}
|
insuranceApply.setNewVersionSolutionId(newVersionSolution.getId());
|
}else{
|
insuranceApply.setNewVersionSolutionId(solutions.getId());
|
}
|
if(insuranceApply.getStartTime().compareTo(new Date())<0 && insuranceApply.getEndTime().compareTo(new Date()) > 0 ){
|
insuranceApply.setLoseEfficacyDays(DateUtil.daysBetweenDates(insuranceApply.getEndTime(),new Date()));
|
}
|
initApplyStatus(insuranceApply);
|
//查询附件数据
|
initImgData(insuranceApply);
|
//查询操作记录
|
List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class,
|
new MPJLambdaWrapper<ApplyLog>()
|
.selectAll(ApplyLog.class)
|
.selectAs(SystemUser::getRealname,ApplyLog::getCreatorName)
|
.selectAs(Company::getName,ApplyLog::getCompanyName)
|
.selectAs(SystemUser::getType,ApplyLog::getCreatorType)
|
.leftJoin(SystemUser.class,SystemUser::getId,ApplyLog::getCreator)
|
.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId)
|
.in(ApplyLog::getObjType,Constants.ApplyLogType.getTypeList(Constants.ZERO))
|
.eq(ApplyLog::getApplyId,insuranceApply.getId())
|
.orderByAsc(ApplyLog::getCreateDate)
|
);
|
insuranceApply.setApplyLogList(applyLogList);
|
return insuranceApply;
|
}
|
|
private void setServiceDays(InsuranceApply insuranceApply) {
|
//设置在保时长（天数）
|
insuranceApply.setServiceDays(Constants.ZERO);
|
if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
|
|| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_DONE.getKey())){
|
//如果当前时间大于结束日期 则使用结束日期对比开始日期
|
if(DateUtil.compareDate(new Date(),insuranceApply.getEndTime())>=Constants.ZERO){
|
insuranceApply.setServiceDays(
|
DateUtil.daysBetweenDates(insuranceApply.getEndTime(),insuranceApply.getStartTime())+1
|
);
|
}else if(DateUtil.compareDate(insuranceApply.getStartTime(),new Date())>=Constants.ZERO){
|
//未开始
|
insuranceApply.setServiceDays(Constants.ZERO);
|
}else{
|
insuranceApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),insuranceApply.getStartTime())+1);
|
}
|
}
|
}
|
|
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.WTB_CONFIRMATION_LATTER.getKey()
|
,Constants.MultiFile.MEMBER_LIST_LATTER.getKey()
|
,Constants.MultiFile.BD_DONE_PDF.getKey()}))
|
.eq(Multifile::getIsdeleted,Constants.ZERO)
|
.orderByAsc(Multifile::getId));
|
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.setToubaodanFile(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);
|
}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.MEMBER_LIST_LATTER.getKey())){
|
//申请单
|
model.setShenqingdanFile(f);
|
}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey())){
|
//签署后确认书
|
model.setFanganFile(f);
|
}
|
|
// if(model.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
|
// //如果当前时间大于结束日期 则使用结束日期对比开始日期
|
// if(DateUtil.compareDate(new Date(),model.getEndTime())>=Constants.ZERO){
|
// model.setServiceDays(DateUtil.daysBetweenDates(model.getEndTime(),model.getStartTime()));
|
// }else if(DateUtil.compareDate(model.getStartTime(),new Date())>=Constants.ZERO){
|
// //未开始
|
// model.setServiceDays(Constants.ZERO);
|
// }else{
|
// model.setServiceDays(DateUtil.daysBetweenDates(new Date(),model.getStartTime()));
|
// }
|
// }
|
}
|
}
|
}
|
@Override
|
public InsuranceApply findDetailForExport(InsuranceApply model){
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.selectAs(Solutions::getType,InsuranceApply::getSolutionType)
|
.selectAs(Company::getName,InsuranceApply::getCompanyName)
|
.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum")
|
.select(" ifnull(( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() ),0) as guaranteeNum")
|
.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)
|
.ge(ApplyDetail::getEndTime,DateUtil.getPlusTime2(new Date()))
|
.eq(ApplyDetail::getApplyId,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())){
|
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(),"数据已删除,无法进行该操作");
|
}
|
Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");
|
}
|
|
//-----TODU-------RJ-------完善退回状态分开标记------------------
|
Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE;
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
|
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.PLATFORM_CHECK_PASS.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey()))
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
|
|| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
|
|| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_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(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey())){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS;
|
}
|
|
else if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
|
|| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
|
|| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())){
|
insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_RETURN;
|
}
|
|
//存储待办信息
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
|
.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
|
.eq(Notices::getObjId,insuranceApply.getId()));
|
|
Notices notices = new Notices(noticeObjectType,Constants.ZERO,insuranceApply.getId(),solutions.getName(),
|
insuranceApply.getCompanyId(), Constants.NoticeType.THREE);
|
noticesMapper.insert(notices);
|
|
|
CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda()
|
.eq(CompanySolution::getIsdeleted,Constants.ZERO)
|
.eq(CompanySolution::getSolutionId,solutions.getId())
|
.eq(CompanySolution::getCompanyId,insuranceApply.getCompanyId())
|
.last("limit 1")
|
);
|
//商户待办
|
if(Objects.nonNull(companySolution)&&Objects.nonNull(companySolution.getShopId())){
|
Notices shopNotices = new Notices(noticeObjectType,Constants.TWO,
|
insuranceApply.getId(),solutions.getName(),companySolution.getShopId(),Constants.NoticeType.THREE);
|
noticesMapper.insert(shopNotices);
|
}
|
|
|
|
|
|
|
}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.FAIL_RETURN.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey())
|
||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_RETURN.getKey())
|
)
|
){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态无法进行关闭!");
|
}
|
//删除其他待办
|
noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));
|
}
|
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();
|
if(StringUtils.isNotBlank(insuranceApplyOptDTO.getOptIllustration())){
|
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);
|
}
|
|
|
/**
|
* 企业保障中人数
|
* @return
|
*/
|
@Override
|
public Integer guaranteeNum() {
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(loginUserInfo.getType().equals(Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作");
|
}
|
MPJLambdaWrapper<ApplyDetail> lambdaWrapper = new MPJLambdaWrapper<ApplyDetail>();
|
lambdaWrapper.select(ApplyDetail::getId)
|
.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
|
.and(i->i.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
|
.or().eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_DONE.getKey()))
|
.eq(InsuranceApply::getCompanyId,loginUserInfo.getCompanyId())
|
.apply(" now() between t.START_TIME and t.END_TIME ");
|
|
Integer count = applyDetailJoinMapper.selectJoinCount(lambdaWrapper);
|
return count;
|
}
|
|
|
|
|
/**
|
* 更新保单实际金额
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void updateApplyCurrentFee(Integer id,Integer unionId){
|
List<InsuranceApply> insuranceApplyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.eq(InsuranceApply::getIsdeleted,Constants.ZERO)
|
.in(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey(),Constants.InsuranceApplyStatus.WTB_DONE.getKey())
|
.eq(!Objects.isNull(id),InsuranceApply::getId,id)
|
.eq(!Objects.isNull(unionId),InsuranceApply::getUnionApplyId,unionId)
|
.le(InsuranceApply::getStartTime,DateUtil.getDate(new Date(),"yyyy-MM-dd") + " 00:00:00")
|
.ge(InsuranceApply::getEndTime,DateUtil.getDate(new Date(),"yyyy-MM-dd") + " 23:59:59")
|
);
|
if(CollectionUtils.isNotEmpty(insuranceApplyList)){
|
for (InsuranceApply insuranceApply:insuranceApplyList) {
|
Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
|
if(Objects.isNull(solutions)){
|
continue;
|
}
|
BigDecimal sumAmount = BigDecimal.ZERO;
|
List<ApplyDetail> applyDetailList = applyDetailMapper
|
.selectList(new QueryWrapper<ApplyDetail>().lambda()
|
.ne(ApplyDetail::getChangeStatus,Constants.TWO)
|
.eq(ApplyDetail::getApplyId,insuranceApply.getId()));
|
if(CollectionUtils.isNotEmpty(applyDetailList)){
|
for (ApplyDetail applyDetail: applyDetailList) {
|
BigDecimal fee = Objects.isNull(insuranceApply.getServerCost())?
|
solutions.getPrice():
|
solutions.getPrice().add(insuranceApply.getServerCost());
|
//在开始结束日期之间
|
if(applyDetail.getStartTime().compareTo(new Date()) <= 0 && applyDetail.getEndTime().compareTo(new Date()) >= 0 ){
|
applyDetail.setCurrentFee(Constants.produceFee(solutions,fee,insuranceApply.getStartTime(),insuranceApply.getFinalEndTime(),applyDetail.getStartTime()));
|
applyDetailMapper.updateById(applyDetail);
|
}else if(applyDetail.getStartTime().compareTo(new Date()) <= 0&&applyDetail.getEndTime().compareTo(new Date()) <= 0){
|
//在结束日期之后
|
applyDetail.setCurrentFee(applyDetail.getFee());
|
applyDetailMapper.updateById(applyDetail);
|
}
|
if(Constants.equalsInteger(applyDetail.getChangeStatus(),Constants.ZERO) || applyDetail.getEndTime().getTime()>System.currentTimeMillis()){
|
sumAmount = sumAmount.add(applyDetail.getCurrentFee());
|
}
|
}
|
}
|
insuranceApply.setCurrentFee(sumAmount);
|
insuranceApplyMapper.updateById(insuranceApply);
|
}
|
}
|
}
|
|
|
|
|
|
@Override
|
public CountCyclePriceVO getCountCyclePriceVO(CountCyclePriceDTO countCyclePriceDTO){
|
if(Objects.isNull(countCyclePriceDTO)
|
|| Objects.isNull(countCyclePriceDTO.getSolutionsId())
|
|| Objects.isNull(countCyclePriceDTO.getStartDate())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Solutions solutions = solutionsMapper.selectById(countCyclePriceDTO.getSolutionsId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
return Constants.countPriceVO(countCyclePriceDTO.getStartDate(),solutions);
|
}
|
|
|
/**
|
* 生成 待审批通知
|
*/
|
@Override
|
public void generateNotice(){
|
List<InsuranceApply> insuranceApplyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
|
.ge(InsuranceApply::getEndTime,DateUtil.getDate(new Date(),"yyyy-MM-dd HH:mm:ss"))
|
.apply(" DATEDIFF(t.END_TIME,CURRENT_DATE() ) <= 5 ")
|
.notExists(" select 1 from notices n where n.obj_type = 0 and n.type = 6 and n.obj_id = t.id ")
|
);
|
for (InsuranceApply insuranceApply:insuranceApplyList) {
|
Notices notices = new Notices(Constants.NoticeObjectType.INSURANCE_APPLY,Constants.ONE,insuranceApply.getId(),insuranceApply.getSolutionsName(),
|
insuranceApply.getCompanyId(), Constants.NoticeType.SIX);
|
noticesMapper.insert(notices);
|
}
|
}
|
|
|
/**
|
* 委托宝 投保确认书
|
* @param smsCheckDTO
|
* @return
|
*/
|
@Override
|
public String getSignTBQRSLink(SmsCheckDTO smsCheckDTO) {
|
if(Objects.isNull(smsCheckDTO)
|
|| Objects.isNull(smsCheckDTO.getBusinessId())
|
// || StringUtils.isBlank(smsCheckDTO.getCode())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
// if(!debugModel){
|
// smsEmailService.validateCode(smsCheckDTO.getCode());
|
// }
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getSignKeyword,InsuranceApply::getSignKeyword)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(InsuranceApply::getId,smsCheckDTO.getBusinessId())
|
.last("limit 1");
|
InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
if(Constants.equalsInteger(solutions.getType(),(Constants.ZERO))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，非委托保方案保单!");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Constants.ApplyLogType applyLogType = null;
|
String info = "";
|
//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
Company company = user.getCompany();
|
if(debugModel){
|
company = companyMapper.selectById(model.getCompanyId());
|
}
|
if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~");
|
}
|
Multifile f = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda()
|
.eq(Multifile::getObjId,solutions.getId())
|
.eq(Multifile::getObjType,Constants.MultiFile.SOLUTIONS_CONFIRMATION_LATTER.getKey())
|
.eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1"));
|
if(f == null || StringUtils.isBlank(f.getFileurl())){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取确认书文件失败，请联系商户确认投保确认书是否正确！");
|
}
|
String url = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode()+f.getFileurl();
|
String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode();
|
notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString());
|
String applyNo = signService.applySign(company.getName(),url,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl);
|
if(StringUtils.isBlank(applyNo) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
String link = signService.signLink(applyNo,company.getName(),company.getCode());
|
if(StringUtils.isBlank(link) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
InsuranceApply update= new InsuranceApply();
|
update.setId(model.getId());
|
update.setEditor(user.getId());
|
update.setEditDate(new Date());
|
update.setSignQrsNo(applyNo);
|
insuranceApplyMapper.updateById(update);
|
return link;
|
}
|
|
|
|
@Override
|
public InsuranceApply queryApplyDetail(Integer applyId){
|
InsuranceApply model = findDetail(applyId);
|
if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
//查询保单明细信息
|
List<ApplyDetail> applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,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)
|
.isNull(ApplyDetail::getFromId)
|
.eq(ApplyDetail::getApplyId,model.getId())
|
.orderByAsc(ApplyDetail::getId)
|
);
|
model.setApplyDetailList(applyDetailList);
|
return model;
|
}
|
|
|
|
/**
|
* 人员名单签章
|
*/
|
@Override
|
public String getMemberListOnlineSignLink(SmsCheckDTO smsCheckDTO) {
|
if(Objects.isNull(smsCheckDTO)
|
|| Objects.isNull(smsCheckDTO.getBusinessId())
|
// || StringUtils.isBlank(smsCheckDTO.getCode())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
//验证 验证码
|
// if(!debugModel){
|
// smsEmailService.validateCode(smsCheckDTO.getCode());
|
// }
|
InsuranceApply model = this.queryApplyDetail(smsCheckDTO.getBusinessId());
|
if(Objects.isNull(model)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询保单信息");
|
}
|
if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey(),model.getStatus())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该申请状态已流转，当前不支持签章操作！");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Company company = user.getCompany();
|
if(debugModel){
|
company = companyMapper.selectById(model.getCompanyId());
|
}
|
if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~");
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
if(solutions.getType().equals(Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，非委托保方案保单，无法进行该操作!");
|
}
|
String fileUrl = ExcelExporter.build(InsuranceApply.class).exportApplyExcelToPdf(model,"人员名单");
|
String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode();
|
notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString());
|
String applyNo = signService.applySignLocalFile(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"投保名单签章",company.getSignId(),notifyUrl);
|
if(StringUtils.isBlank(applyNo) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
String link = signService.signLink(applyNo,company.getName(),company.getCode());
|
if(StringUtils.isBlank(link) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
InsuranceApply update= new InsuranceApply();
|
update.setId(model.getId());
|
update.setEditor(user.getId());
|
update.setEditDate(new Date());
|
update.setSignMemberListNo(applyNo);
|
insuranceApplyMapper.updateById(update);
|
return link;
|
}
|
|
|
/**
|
* 委托保 投保申请签署
|
* @param smsCheckDTO
|
* @return
|
*/
|
@Override
|
public String getSignWTBTBDLink(SmsCheckDTO smsCheckDTO) {
|
if(Objects.isNull(smsCheckDTO)
|
|| Objects.isNull(smsCheckDTO.getBusinessId())
|
// || StringUtils.isBlank(smsCheckDTO.getCode())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
//验证 验证码
|
// if(!debugModel){
|
// smsEmailService.validateCode(smsCheckDTO.getCode());
|
// }
|
MPJLambdaWrapper wrapper= new MPJLambdaWrapper<InsuranceApply>()
|
.selectAll(InsuranceApply.class)
|
.selectAs(Solutions::getSignKeyword,InsuranceApply::getSignKeyword)
|
.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
|
.eq(InsuranceApply::getId,smsCheckDTO.getBusinessId())
|
.last("limit 1");
|
|
InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
|
if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
|
if(Objects.isNull(solutions)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
|
}
|
if(solutions.getType().equals(Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，非委托保方案保单!");
|
}
|
if(!model.getUnionApplyTbdStatus().equals(Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，商户未上传或已签署");
|
}
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
Constants.ApplyLogType applyLogType = null;
|
String info = "";
|
//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
|
if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_TOUBAOING.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
|
}
|
Company company = user.getCompany();
|
if(debugModel){
|
company = companyMapper.selectById(model.getCompanyId());
|
}
|
if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~");
|
}
|
Multifile f = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda()
|
.eq(Multifile::getObjId,model.getId())
|
.eq(Multifile::getObjType,Constants.MultiFile.BD_APPLY_PDF.getKey())
|
.eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1"));
|
if(f == null || StringUtils.isBlank(f.getFileurl())){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取确认书文件失败，请联系商户确认投保申请书是否正确！");
|
}
|
String url = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode()+f.getFileurl();
|
String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode();
|
notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString());
|
String applyNo = signService.applySign(company.getName(),url,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl);
|
if(StringUtils.isBlank(applyNo) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
String link = signService.signLink(applyNo,company.getName(),company.getCode());
|
if(StringUtils.isBlank(link) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
|
}
|
InsuranceApply update= new InsuranceApply();
|
update.setId(model.getId());
|
update.setEditor(user.getId());
|
update.setEditDate(new Date());
|
update.setApplyTbdNo(applyNo);
|
insuranceApplyMapper.updateById(update);
|
return link;
|
}
|
|
}
|
