|  |  |  | 
|---|
|  |  |  | package com.doumee.service.business.impl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import cn.hutool.core.util.IdcardUtil; | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | 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.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 java.io.File; | 
|---|
|  |  |  | import java.math.BigDecimal; | 
|---|
|  |  |  | import java.math.RoundingMode; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.stream.Collectors; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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}) | 
|---|
|  |  |  | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.DATA_EMPTY); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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.setStatus(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()); | 
|---|
|  |  |  | update.setCheckDate(update.getEditDate()); | 
|---|
|  |  |  | update.setCheckInfo(insuranceApply.getCheckInfo()); | 
|---|
|  |  |  | update.setCheckUserId(user.getId()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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())); | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 = ""; | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) { | 
|---|
|  |  |  | 
|---|
|  |  |  | 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){ | 
|---|
|  |  |  | //如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作 | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 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.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 ){ | 
|---|
|  |  |  | 
|---|
|  |  |  | 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(); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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(); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.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) { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
|---|
|  |  |  | .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
|---|
|  |  |  | .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()) | 
|---|
|  |  |  | .eq(Solutions::getType,Constants.ZERO) | 
|---|
|  |  |  | .isNotNull(InsuranceApply::getSignApplyNo)); | 
|---|
|  |  |  | String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+ | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); | 
|---|
|  |  |  | if(applyList !=null && applyList.size()>0 ){ | 
|---|
|  |  |  | for(InsuranceApply model : applyList){ | 
|---|
|  |  |  | String status = signService.linkFileStatus(model.getSignApplyNo()); | 
|---|
|  |  |  | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadSignedFileDo(model,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | //                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 fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadChangeSignedFileDo(model,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | //                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   void dealSignResult(NotifyDataReq data){ | 
|---|
|  |  |  | 
|---|
|  |  |  | //如果已保全,可下载签约附件 | 
|---|
|  |  |  | String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+ | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); | 
|---|
|  |  |  | //直保 投保申请 | 
|---|
|  |  |  | InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class, | 
|---|
|  |  |  | new MPJLambdaWrapper<InsuranceApply>() | 
|---|
|  |  |  | .selectAll(InsuranceApply.class) | 
|---|
|  |  |  | 
|---|
|  |  |  | .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 && Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){ | 
|---|
|  |  |  | 
|---|
|  |  |  | uploadSignedFileDo(model,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //委托保 企业方案确认书 | 
|---|
|  |  |  | 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 && Constants.equalsInteger(modelTBQRS.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())){ | 
|---|
|  |  |  | //完成签署已完成操作 | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadFAQRSSignedFileDo(modelTBQRS,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //委托保 企业签署人员名单 | 
|---|
|  |  |  | 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 && Constants.equalsInteger(modelMemberList.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())){ | 
|---|
|  |  |  | //完成签署已完成操作 | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadApplyMemberListSignedFileDo(modelMemberList,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //委托保 投保申请书签署 | 
|---|
|  |  |  | 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(modelTBQRS != null && Constants.equalsInteger(modelTBQSQ.getUnionApplyTbdStatus(),Constants.ONE)){ | 
|---|
|  |  |  | //完成签署已完成操作 | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadTBSQSSignedFileDo(modelTBQSQ,fileUrl,path+fileUrl); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //直保 加减保企业签署 | 
|---|
|  |  |  | 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 &&Constants.equalsInteger(applyChange.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey())){ | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadChangeSignedFileDo(applyChange,fileUrl,path+fileUrl); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //委托保 加减保企业签署 | 
|---|
|  |  |  | 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 &&Constants.equalsInteger(applyChangeMemberList.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey())){ | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadChangeMemberListSignedFileDo(applyChangeMemberList,fileUrl,path+fileUrl); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //投保合并单 商户签署保单 | 
|---|
|  |  |  | UnionApply unionApply = unionApplyJoinMapper.selectOne(new QueryWrapper<UnionApply>() | 
|---|
|  |  |  | .lambda().eq(UnionApply::getSignApplyNo,data.getApplyNo()).last(" limit 1 ")); | 
|---|
|  |  |  | if(unionApply != null &&Constants.equalsInteger(unionApply.getStatus(),Constants.UnionApplyStatus.WAIT_SIGNATURE.getKey())){ | 
|---|
|  |  |  | String link = signService.linkFile(data.getApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadUnionApplySignedFileDo(unionApply,fileUrl,path+fileUrl); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | *合并加减保换厂 签署业务 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | UnionChange unionChange = unionChangeJoinMapper.selectOne( | 
|---|
|  |  |  | new MPJLambdaWrapper<UnionChange>() | 
|---|
|  |  |  | .selectAll(UnionChange.class) | 
|---|
|  |  |  | .eq(UnionChange::getSignApplyNo,data.getApplyNo()) | 
|---|
|  |  |  | .last(" limit 1 ")); | 
|---|
|  |  |  | if(unionChange != null &&Constants.equalsInteger(unionChange.getStatus(),Constants.UnionChangeStatus.MERGE.getKey())){ | 
|---|
|  |  |  | String link = signService.linkFile(model.getSignApplyNo()); | 
|---|
|  |  |  | String fileUrl = uploadSignFile(link); | 
|---|
|  |  |  | if(StringUtils.isBlank(fileUrl)){ | 
|---|
|  |  |  | //如果下载失败,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | uploadUnionChangeSignedFileDo(unionChange,fileUrl,path+fileUrl); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else if(Constants.equalsInteger(data.getSignStatus(), Constants.TWO )){ | 
|---|
|  |  |  | //如果已拒签,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda() | 
|---|
|  |  |  | .set(InsuranceApply::getSignApplyNo,null) | 
|---|
|  |  |  | .eq(InsuranceApply::getSignApplyNo,data.getApplyNo())); | 
|---|
|  |  |  | //如果已拒签,清除合同,下次签章重新生成新合同 | 
|---|
|  |  |  | applyChangeMapper.update(null,new UpdateWrapper<ApplyChange>().lambda() | 
|---|
|  |  |  | .set(ApplyChange::getSignApplyNo,null) | 
|---|
|  |  |  | .eq(ApplyChange::getSignApplyNo,data.getApplyNo())); | 
|---|
|  |  |  | insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda() | 
|---|
|  |  |  | .set(InsuranceApply::getSignQrsNo,null) | 
|---|
|  |  |  | .eq(InsuranceApply::getSignQrsNo,data.getApplyNo())); | 
|---|
|  |  |  | insuranceApplyMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda() | 
|---|
|  |  |  | .set(InsuranceApply::getSignMemberListNo,null) | 
|---|
|  |  |  | .eq(InsuranceApply::getSignMemberListNo,data.getApplyNo())); | 
|---|
|  |  |  | unionApplyJoinMapper.update(null,new UpdateWrapper<UnionApply>().lambda() | 
|---|
|  |  |  | .set(UnionApply::getSignApplyNo,null) | 
|---|
|  |  |  | .eq(UnionApply::getSignApplyNo,data.getApplyNo())); | 
|---|
|  |  |  | applyChangeMapper.update(null,new UpdateWrapper<ApplyChange>().lambda() | 
|---|
|  |  |  | .set(ApplyChange::getSignMemberListNo,null) | 
|---|
|  |  |  | .eq(ApplyChange::getSignMemberListNo,data.getApplyNo())); | 
|---|
|  |  |  | unionChangeJoinMapper.update(null,new UpdateWrapper<UnionChange>().lambda() | 
|---|
|  |  |  | .set(UnionChange::getSignApplyNo,null) | 
|---|
|  |  |  | .eq(UnionChange::getSignApplyNo,data.getApplyNo())); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional(rollbackFor = {Exception.class,BusinessException.class}) | 
|---|
|  |  |  | public Integer uploadToubaodan(InsuranceApply insuranceApply) { | 
|---|
|  |  |  | 
|---|
|  |  |  | model.getCompanyId(), Constants.NoticeType.ONE); | 
|---|
|  |  |  | noticesMapper.insert(notices); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return  1; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.DATA_EMPTY); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | Constants.NoticeType noticeType = Constants.NoticeType.ONE; | 
|---|
|  |  |  | update.setId(model.getId()); | 
|---|
|  |  |  | if(insuranceApply.getDealBackApply() ==1){ | 
|---|
|  |  |  | //如果是不通过 | 
|---|
|  |  |  | applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ; | 
|---|
|  |  |  | update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | noticeType = Constants.NoticeType.FOUR; | 
|---|
|  |  |  | if(Constants.equalsObject(solutions.getType(),Constants.ONE)){ | 
|---|
|  |  |  | update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.getKey()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS; | 
|---|
|  |  |  | update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()); | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | //删除其他待办 | 
|---|
|  |  |  | 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.ONE,model.getId(),solutions.getName(),model.getCompanyId(),noticeType); | 
|---|
|  |  |  | //        noticesMapper.insert(notices); | 
|---|
|  |  |  | 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())){ | 
|---|
|  |  |  | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.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); | 
|---|
|  |  |  | 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)); | 
|---|
|  |  |  | 
|---|
|  |  |  | //        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); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //直保业务发送待办 | 
|---|
|  |  |  | 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(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //处理下级数据 | 
|---|
|  |  |  | this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO); | 
|---|
|  |  |  | this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO,false); | 
|---|
|  |  |  | insuranceApply.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | insuranceApplyMapper.updateById(insuranceApply); | 
|---|
|  |  |  | //存储日志数据 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public void dealApplyDetailData(InsuranceApply insuranceApply,Solutions solutions,List<ApplyDetail> applyDetailList,LoginUserInfo loginUserInfo,CountCyclePriceVO  countCyclePriceVO){ | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | .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())); | 
|---|
|  |  |  | .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 = duWorktypeMapper.selectList(new QueryWrapper<DuWorktype>().lambda() | 
|---|
|  |  |  | 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(),"数据异常:保险方案下未查询到工种信息"); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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()+"]"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | member.setIdcardNo(applyDetail.getIdcardNo()); | 
|---|
|  |  |  | member.setApplyId(insuranceApply.getId()); | 
|---|
|  |  |  | member.setStartTime(applyDetail.getStartTime()); | 
|---|
|  |  |  | member.setEndTime(applyDetail.getEndTime()); | 
|---|
|  |  |  | member.setDuId(applyDetail.getDuId()); | 
|---|
|  |  |  | member.setWorktypeId(applyDetail.getWorktypeId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | memberMapper.insert(member); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | member.setApplyId(insuranceApply.getId()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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()+"】员工派遣单位未查询到!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 = Constants.InsuranceApplyStatus.getKesByStatus(pageWrap.getModel().getStatusCollect()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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.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"); | 
|---|
|  |  |  | 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  = 1 and td.INSURANCE_APPLY_ID = t.id ),0) as taxesMoney"); | 
|---|
|  |  |  | 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.eq(InsuranceApply::getIsdeleted,Constants.ZERO); | 
|---|
|  |  |  | queryWrapper.eq(pageWrap.getModel().getBaseSolutionId()!=null,Solutions::getBaseId,pageWrap.getModel().getBaseSolutionId()); | 
|---|
|  |  |  | queryWrapper.in(statusList.size()>0,InsuranceApply::getStatus,statusList); | 
|---|
|  |  |  | if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.THREE) ){ | 
|---|
|  |  |  | queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()); | 
|---|
|  |  |  | 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(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); | 
|---|
|  |  |  | }else if(loginUserInfo.getType().equals(Constants.TWO)){ | 
|---|
|  |  |  | //如果是商户查看 | 
|---|
|  |  |  | if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==0){ | 
|---|
|  |  |  | queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t.company_id and cs.shop_id="+loginUserInfo.getCompanyId()); | 
|---|
|  |  |  | 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 where cs.isdeleted=0 and cs.company_id=t.company_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + | 
|---|
|  |  |  | 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{ | 
|---|
|  |  |  | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public void    initApplyStatus(InsuranceApply apply){ | 
|---|
|  |  |  | apply.setStatusCollect(Constants.InsuranceApplyStatus.getCollectStatus(apply.getStatus())); | 
|---|
|  |  |  | if(Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ | 
|---|
|  |  |  | 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);//已过期 | 
|---|
|  |  |  | 
|---|
|  |  |  | @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 sum(td.fee) from taxes ts inner join tax_detial td on ts.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 ts.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.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.apply_id = t.id ) as insureNum"); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | .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(" 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"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | private void setServiceDays(InsuranceApply insuranceApply) { | 
|---|
|  |  |  | //设置在保时长(天数) | 
|---|
|  |  |  | insuranceApply.setServiceDays(Constants.ZERO); | 
|---|
|  |  |  | if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ | 
|---|
|  |  |  | 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( | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private void initImgData(InsuranceApply model) { | 
|---|
|  |  |  | List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda() | 
|---|
|  |  |  | .eq(Multifile::getObjId,Constants.equalsInteger(model.getSolutionType(),Constants.ZERO)? model.getId():model.getUnionApplyId()) | 
|---|
|  |  |  | .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)); | 
|---|
|  |  |  | .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(); | 
|---|
|  |  |  | 
|---|
|  |  |  | }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())){ | 
|---|
|  |  |  | 
|---|
|  |  |  | MPJLambdaWrapper wrapper=  new MPJLambdaWrapper<InsuranceApply>() | 
|---|
|  |  |  | .selectAll(InsuranceApply.class) | 
|---|
|  |  |  | .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) | 
|---|
|  |  |  | .selectAs(Solutions::getType,InsuranceApply::getSolutionType) | 
|---|
|  |  |  | .selectAs(Company::getName,InsuranceApply::getCompanyName) | 
|---|
|  |  |  | .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
|---|
|  |  |  | .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.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_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)){ | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.PLATFORM_CHECK_PASS.getKey()) | 
|---|
|  |  |  | ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_RETURN.getKey()) | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | ){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态无法进行关闭!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //删除其他待办 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 企业保障中人数 | 
|---|
|  |  |  | * @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}) | 
|---|
|  |  |  | public void updateApplyCurrentFee(Integer id){ | 
|---|
|  |  |  | List<InsuranceApply> insuranceApplyList = insuranceApplyMapper.selectList(new QueryWrapper<InsuranceApply>().lambda() | 
|---|
|  |  |  | @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) | 
|---|
|  |  |  | .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) | 
|---|
|  |  |  | .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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | BigDecimal sumAmount = BigDecimal.ZERO; | 
|---|
|  |  |  | List<ApplyDetail> applyDetailList = applyDetailMapper.selectList(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId())); | 
|---|
|  |  |  | List<ApplyDetail> applyDetailList = applyDetailMapper | 
|---|
|  |  |  | .selectList(new QueryWrapper<ApplyDetail>().lambda() | 
|---|
|  |  |  | .eq(ApplyDetail::getApplyId,insuranceApply.getId())); | 
|---|
|  |  |  | if(CollectionUtils.isNotEmpty(applyDetailList)){ | 
|---|
|  |  |  | for (ApplyDetail applyDetail: applyDetailList) { | 
|---|
|  |  |  | //2024-1-30 10:04:24 修改 根据实际天数进行计算 当前费用  总金额/总天数*实际天数 | 
|---|
|  |  |  | Integer maxDays = DateUtil.calculateBetween(applyDetail.getStartTime(),applyDetail.getEndTime(),0); | 
|---|
|  |  |  | BigDecimal fee = applyDetail.getFee(); | 
|---|
|  |  |  | 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 ){ | 
|---|
|  |  |  | Integer days =  DateUtil.calculateBetween(applyDetail.getStartTime(),new Date(),0); | 
|---|
|  |  |  | applyDetail.setCurrentFee(fee.divide(BigDecimal.valueOf(maxDays),2, BigDecimal.ROUND_HALF_UP).multiply(BigDecimal.valueOf(days))); | 
|---|
|  |  |  | 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(fee); | 
|---|
|  |  |  | }else  if(applyDetail.getStartTime().compareTo(new Date()) <= 0&&applyDetail.getEndTime().compareTo(new Date()) <= 0){ | 
|---|
|  |  |  | //在结束日期之后 | 
|---|
|  |  |  | applyDetail.setCurrentFee(applyDetail.getFee()); | 
|---|
|  |  |  | applyDetailMapper.updateById(applyDetail); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | sumAmount = sumAmount.add(applyDetail.getCurrentFee()); | 
|---|
|  |  |  | 
|---|
|  |  |  | //        if(1==1){ | 
|---|
|  |  |  | //            throw new BusinessException(ResponseStatus.NOT_ALLOWED); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 委托宝 投保确认书 | 
|---|
|  |  |  | * @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()) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|