| | |
| | | import com.doumee.dao.business.MultifileMapper; |
| | | import com.doumee.dao.business.SolutionsMapper; |
| | | import com.doumee.dao.business.UnionApplyMapper; |
| | | import com.doumee.dao.business.dto.SaveUnionApplyDTO; |
| | | import com.doumee.dao.business.dto.UnionApplyBXDDDetailTO; |
| | | import com.doumee.dao.business.dto.UnionApplyBXDDTO; |
| | | import com.doumee.dao.business.dto.UploadMultifileDTO; |
| | | import com.doumee.dao.business.dto.*; |
| | | import com.doumee.dao.business.join.ApplyDetailJoinMapper; |
| | | import com.doumee.dao.business.join.InsuranceApplyJoinMapper; |
| | | import com.doumee.dao.business.join.UnionApplyJoinMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.service.business.SmsEmailService; |
| | | import com.doumee.service.business.UnionApplyService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | import com.github.xiaoymin.knife4j.core.util.CollectionUtils; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.ArrayList; |
| | |
| | | |
| | | @Autowired |
| | | private SignService signService; |
| | | |
| | | @Autowired |
| | | private SmsEmailService smsEmailService; |
| | | |
| | | @Value("${debug_model}") |
| | | private boolean debugModel; |
| | | |
| | | @Override |
| | | public Integer create(UnionApply unionApply) { |
| | |
| | | @Override |
| | | public PageData<UnionApply> findPage(PageWrap<UnionApply> pageWrap) { |
| | | IPage<UnionApply> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | QueryWrapper<UnionApply> queryWrapper = new QueryWrapper<>(); |
| | | MPJLambdaWrapper<UnionApply> queryWrapper = new MPJLambdaWrapper<>(); |
| | | Utils.MP.blankToNull(pageWrap.getModel()); |
| | | queryWrapper.selectAll(UnionApply.class); |
| | | queryWrapper.leftJoin(Solutions.class,Solutions::getId,UnionApply::getSolutionId); |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(user.getType().equals(Constants.TWO)){ |
| | | queryWrapper.eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId()); |
| | | } |
| | | if (pageWrap.getModel().getId() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getId, pageWrap.getModel().getId()); |
| | | queryWrapper.eq(UnionApply::getId, pageWrap.getModel().getId()); |
| | | } |
| | | if (pageWrap.getModel().getCreator() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCreator, pageWrap.getModel().getCreator()); |
| | | queryWrapper.eq(UnionApply::getCreator, pageWrap.getModel().getCreator()); |
| | | } |
| | | if (pageWrap.getModel().getQueryStartTime() != null) { |
| | | queryWrapper.ge(UnionApply::getCreateDate, pageWrap.getModel().getQueryStartTime() +" 00:00:00" ); |
| | | } |
| | | if (pageWrap.getModel().getQueryEndTime() != null) { |
| | | queryWrapper.le(UnionApply::getCreateDate, pageWrap.getModel().getQueryEndTime() +" 23:59:59"); |
| | | } |
| | | if (pageWrap.getModel().getCreateDate() != null) { |
| | | queryWrapper.lambda().ge(UnionApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.lambda().le(UnionApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.ge(UnionApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.le(UnionApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); |
| | | } |
| | | if (pageWrap.getModel().getEditor() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getEditor, pageWrap.getModel().getEditor()); |
| | | queryWrapper.eq(UnionApply::getEditor, pageWrap.getModel().getEditor()); |
| | | } |
| | | if (pageWrap.getModel().getEditDate() != null) { |
| | | queryWrapper.lambda().ge(UnionApply::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.lambda().le(UnionApply::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.ge(UnionApply::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.le(UnionApply::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); |
| | | } |
| | | if (pageWrap.getModel().getIsdeleted() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getIsdeleted, pageWrap.getModel().getIsdeleted()); |
| | | queryWrapper.eq(UnionApply::getIsdeleted, pageWrap.getModel().getIsdeleted()); |
| | | } |
| | | if (pageWrap.getModel().getRemark() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getRemark, pageWrap.getModel().getRemark()); |
| | | queryWrapper.eq(UnionApply::getRemark, pageWrap.getModel().getRemark()); |
| | | } |
| | | if (pageWrap.getModel().getSortnum() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getSortnum, pageWrap.getModel().getSortnum()); |
| | | queryWrapper.eq(UnionApply::getSortnum, pageWrap.getModel().getSortnum()); |
| | | } |
| | | if (pageWrap.getModel().getCompanyId() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId()); |
| | | queryWrapper.eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId()); |
| | | } |
| | | if (pageWrap.getModel().getEndTime() != null) { |
| | | queryWrapper.lambda().ge(UnionApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTime())); |
| | | queryWrapper.lambda().le(UnionApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTime())); |
| | | queryWrapper.ge(UnionApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTime())); |
| | | queryWrapper.le(UnionApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTime())); |
| | | } |
| | | if (pageWrap.getModel().getStartTime() != null) { |
| | | queryWrapper.lambda().ge(UnionApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTime())); |
| | | queryWrapper.lambda().le(UnionApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTime())); |
| | | queryWrapper.ge(UnionApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTime())); |
| | | queryWrapper.le(UnionApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTime())); |
| | | } |
| | | if (pageWrap.getModel().getCheckDate() != null) { |
| | | queryWrapper.lambda().ge(UnionApply::getCheckDate, Utils.Date.getStart(pageWrap.getModel().getCheckDate())); |
| | | queryWrapper.lambda().le(UnionApply::getCheckDate, Utils.Date.getEnd(pageWrap.getModel().getCheckDate())); |
| | | queryWrapper.ge(UnionApply::getCheckDate, Utils.Date.getStart(pageWrap.getModel().getCheckDate())); |
| | | queryWrapper.le(UnionApply::getCheckDate, Utils.Date.getEnd(pageWrap.getModel().getCheckDate())); |
| | | } |
| | | if (pageWrap.getModel().getCheckInfo() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCheckInfo, pageWrap.getModel().getCheckInfo()); |
| | | queryWrapper.eq(UnionApply::getCheckInfo, pageWrap.getModel().getCheckInfo()); |
| | | } |
| | | if (pageWrap.getModel().getCheckUserId() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCheckUserId, pageWrap.getModel().getCheckUserId()); |
| | | queryWrapper.eq(UnionApply::getCheckUserId, pageWrap.getModel().getCheckUserId()); |
| | | } |
| | | if (pageWrap.getModel().getCode() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCode, pageWrap.getModel().getCode()); |
| | | queryWrapper.eq(UnionApply::getCode, pageWrap.getModel().getCode()); |
| | | } |
| | | if (pageWrap.getModel().getStatus() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getStatus, pageWrap.getModel().getStatus()); |
| | | queryWrapper.eq(UnionApply::getStatus, pageWrap.getModel().getStatus()); |
| | | } |
| | | if (pageWrap.getModel().getCurrentFee() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getCurrentFee, pageWrap.getModel().getCurrentFee()); |
| | | queryWrapper.eq(UnionApply::getCurrentFee, pageWrap.getModel().getCurrentFee()); |
| | | } |
| | | if (pageWrap.getModel().getFee() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getFee, pageWrap.getModel().getFee()); |
| | | queryWrapper.eq(UnionApply::getFee, pageWrap.getModel().getFee()); |
| | | } |
| | | if (pageWrap.getModel().getSignApplyNo() != null) { |
| | | queryWrapper.lambda().eq(UnionApply::getSignApplyNo, pageWrap.getModel().getSignApplyNo()); |
| | | queryWrapper.eq(UnionApply::getSignApplyNo, pageWrap.getModel().getSignApplyNo()); |
| | | } |
| | | for(PageWrap.SortData sortData: pageWrap.getSorts()) { |
| | | if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { |
| | |
| | | queryWrapper.orderByAsc(sortData.getProperty()); |
| | | } |
| | | } |
| | | return PageData.from(unionApplyMapper.selectPage(page, queryWrapper)); |
| | | PageData<UnionApply> pageData = PageData.from(unionApplyJoinMapper.selectJoinPage(page,UnionApply.class, queryWrapper)); |
| | | return pageData; |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | @Override |
| | | public void merge(SaveUnionApplyDTO saveUnionApplyDTO){ |
| | | public UnionApply detail(Integer applyId){ |
| | | UnionApply unionApply = unionApplyJoinMapper.selectJoinOne(UnionApply.class, |
| | | new MPJLambdaWrapper<UnionApply>() |
| | | .selectAll(UnionApply.class) |
| | | .selectAs(Solutions::getName,UnionApply::getSolutionName) |
| | | .selectAs(Company::getName,UnionApply::getCompanyName) |
| | | .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.UNION_APPLY_ID = t.id ) as insureNum") |
| | | .leftJoin(Solutions.class,Solutions::getId,UnionApply::getSolutionId) |
| | | .leftJoin(Company.class,Company::getId,UnionApply::getCompanyId) |
| | | .eq(UnionApply::getId,applyId) |
| | | .last(" limit 1 ") |
| | | ); |
| | | unionApply.setServiceDays(Constants.ZERO); |
| | | if(unionApply.getStatus().equals(Constants.UnionApplyStatus.FINISH.getKey())){ |
| | | //如果当前时间大于结束日期 则使用结束日期对比开始日期 |
| | | if(DateUtil.compareDate(new Date(),unionApply.getEndTime())>=Constants.ZERO){ |
| | | unionApply.setServiceDays( |
| | | DateUtil.daysBetweenDates(unionApply.getEndTime(),unionApply.getStartTime())+1 |
| | | ); |
| | | }else if(DateUtil.compareDate(unionApply.getStartTime(),new Date())>=Constants.ZERO){ |
| | | //未开始 |
| | | unionApply.setServiceDays(Constants.ZERO); |
| | | }else{ |
| | | unionApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),unionApply.getStartTime())+1); |
| | | } |
| | | } |
| | | return unionApply; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @Override |
| | | public Integer merge(SaveUnionApplyDTO saveUnionApplyDTO){ |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(user.getType().equals(Constants.TWO)){ |
| | | if(!user.getType().equals(Constants.TWO)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户用户,无法进行该操作"); |
| | | } |
| | | if(Objects.isNull(saveUnionApplyDTO) |
| | | || Objects.isNull(saveUnionApplyDTO.getApplyIds()) |
| | | || Objects.isNull(saveUnionApplyDTO.getStartDate()) |
| | | || Objects.isNull(saveUnionApplyDTO.getEndDate()) |
| | | || Objects.isNull(saveUnionApplyDTO.getBaseSolutionId()) |
| | | ){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | |
| | | .selectAs(InsuranceApply::getSolutionBaseId,Solutions::getBaseId) |
| | | .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) |
| | | .eq(InsuranceApply::getIsdeleted, Constants.ZERO) |
| | | .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()) |
| | | .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey()) |
| | | .eq(Solutions::getBaseId,saveUnionApplyDTO.getBaseSolutionId()) |
| | | .in(InsuranceApply::getId,saveUnionApplyDTO.getApplyIds()) |
| | | .isNull(InsuranceApply::getUnionApplyId) |
| | |
| | | Integer maxDays = DateUtil.calculateBetween(saveUnionApplyDTO.getStartDate(),saveUnionApplyDTO.getEndDate(),0); |
| | | List<ApplyDetail> applyDetailList = applyDetailJoinMapper.selectList(new QueryWrapper<ApplyDetail>().lambda().select(ApplyDetail::getPrice) |
| | | .in(ApplyDetail::getApplyId,saveUnionApplyDTO.getApplyIds())); |
| | | //unionApply.setFee(insuranceApplyList.stream().map(i->i.getFee()).reduce(BigDecimal.ZERO,BigDecimal::add)); |
| | | unionApply.setFee(applyDetailList.stream().map(i->i.getPrice().multiply(new BigDecimal(maxDays))).reduce(BigDecimal.ZERO,BigDecimal::add)); |
| | | unionApplyMapper.insert(unionApply); |
| | | |
| | |
| | | .set(InsuranceApply::getUnionApplyId,unionApply.getId()) |
| | | .set(InsuranceApply::getCheckDate,new Date()) |
| | | .set(InsuranceApply::getCheckUserId,user.getId()) |
| | | .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_TOUBAOING.getKey()) |
| | | .in(InsuranceApply::getId,saveUnionApplyDTO.getApplyIds())); |
| | | |
| | | applyDetailJoinMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda() |
| | | .set(ApplyDetail::getUnionApplyId,unionApply.getId()) |
| | | .in(ApplyDetail::getApplyId,saveUnionApplyDTO.getApplyIds())); |
| | | |
| | | return unionApply.getId(); |
| | | |
| | | } |
| | | |
| | |
| | | @Transactional(rollbackFor = {Exception.class,BusinessException.class}) |
| | | public void cancelMerge(Integer id){ |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(user.getType().equals(Constants.TWO)){ |
| | | if(!user.getType().equals(Constants.TWO)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户用户,无法进行该操作!"); |
| | | } |
| | | UnionApply unionApply = unionApplyMapper.selectById(id); |
| | |
| | | if(unionApply.getStatus().equals(Constants.UnionApplyStatus.FINISH.getKey())){ |
| | | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起,合并单业务已完结,您无法进行该操作!"); |
| | | } |
| | | if(unionApply.getStatus().equals(Constants.UnionApplyStatus.CLOSE.getKey())){ |
| | | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起,合并单业务已关闭"); |
| | | } |
| | | //合并单状态处于待投保 |
| | | if(unionApply.getStatus().equals(Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey()) |
| | | || unionApply.getStatus().equals(Constants.UnionApplyStatus.WAIT_SIGNATURE.getKey())){ |
| | |
| | | .set(InsuranceApply::getUnionApplyId,null) |
| | | .set(InsuranceApply::getCheckDate,new Date()) |
| | | .set(InsuranceApply::getCheckUserId,user.getId()) |
| | | .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey()) |
| | | .eq(InsuranceApply::getUnionApplyId,unionApply.getId())); |
| | | |
| | | |
| | | applyDetailJoinMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda() |
| | | .set(ApplyDetail::getUnionApplyId,null) |
| | | .eq(ApplyDetail::getUnionApplyId,unionApply.getId())); |
| | | |
| | | |
| | | unionApplyMapper.update(null,new UpdateWrapper<UnionApply>().lambda() |
| | | .set(UnionApply::getCheckDate,new Date()) |
| | |
| | | @Transactional(rollbackFor = {Exception.class,BusinessException.class}) |
| | | public void uploadToubaodan(UploadMultifileDTO uploadMultifileDTO){ |
| | | if(uploadMultifileDTO.getBusinessId() == null |
| | | ||StringUtils.isBlank( uploadMultifileDTO.getFilePath()) |
| | | ||StringUtils.isBlank( uploadMultifileDTO.getFileName())){ |
| | | ||StringUtils.isBlank( uploadMultifileDTO.getFileurl()) |
| | | ||StringUtils.isBlank( uploadMultifileDTO.getName())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(!user.getType().equals(Constants.TWO)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户用户,无法进行该操作!"); |
| | | } |
| | | UnionApply unionApply = unionApplyMapper.selectById(uploadMultifileDTO.getBusinessId()); |
| | | if(Objects.isNull(unionApply)||!Constants.equalsInteger(unionApply.getIsdeleted(),Constants.ZERO)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY); |
| | |
| | | if(unionApply.getStatus().equals(Constants.UnionApplyStatus.MERGE.getKey())){ |
| | | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起,合并单业务已流转,您无法进行该操作!"); |
| | | } |
| | | |
| | | if(CollectionUtils.isNotEmpty(uploadMultifileDTO.getMultifileList())){ |
| | | List<Multifile> multifileList = uploadMultifileDTO.getMultifileList(); |
| | | for (Multifile multifile:multifileList) { |
| | | if(Objects.isNull(multifile.getObjId()) |
| | | ||Objects.isNull(multifile.getName()) |
| | | ||Objects.isNull(multifile.getFileurl())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"企业投保单附件参数错误"); |
| | | } |
| | | InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectOne(new QueryWrapper<InsuranceApply>().lambda() |
| | | .eq(InsuranceApply::getId,multifile.getObjId()) |
| | | .eq(InsuranceApply::getUnionApplyId,uploadMultifileDTO.getBusinessId()) |
| | | ); |
| | | if(Objects.isNull(insuranceApply)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"企业投保单未查询到"); |
| | | } |
| | | |
| | | multifile.setIsdeleted(Constants.ZERO); |
| | | multifile.setCreator(user.getId()); |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setObjType(Constants.MultiFile.COMPANY_TBD_SIGNED.getKey()); |
| | | multifile.setType(Constants.TWO); |
| | | multifileMapper.insert(multifile); |
| | | |
| | | insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda() |
| | | .set(InsuranceApply::getUnionApplyTbdStatus,Constants.ONE) |
| | | .set(InsuranceApply::getEditDate,new Date()) |
| | | .set(InsuranceApply::getEditor,user.getId()) |
| | | .eq(InsuranceApply::getId,multifile.getObjId()) |
| | | ); |
| | | |
| | | } |
| | | } |
| | | |
| | | |
| | | unionApply.setCheckDate(new Date()); |
| | | unionApply.setCheckUserId(user.getId()); |
| | |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setObjType(Constants.MultiFile.HBD_BD_SIGNED_PDF.getKey()); |
| | | multifile.setType(Constants.TWO); |
| | | multifile.setFileurl(uploadMultifileDTO.getFilePath()); |
| | | multifile.setName(uploadMultifileDTO.getFileName()); |
| | | multifile.setFileurl(uploadMultifileDTO.getFileurl()); |
| | | multifile.setName(uploadMultifileDTO.getName()); |
| | | multifileMapper.insert(multifile); |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = {Exception.class,BusinessException.class}) |
| | | public String getSignLink(Integer id) { |
| | | if(id == null ){ |
| | | public String getSignLink(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()); |
| | | } |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | UnionApply unionApply = unionApplyJoinMapper.selectById(id); |
| | | if(!user.getType().equals(Constants.TWO)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户用户,无法进行该操作!"); |
| | | } |
| | | UnionApply unionApply = unionApplyJoinMapper.selectById(smsCheckDTO.getBusinessId()); |
| | | if(unionApply == null ||!Constants.equalsInteger(unionApply.getIsdeleted(),Constants.ZERO)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY); |
| | | } |
| | |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(!user.getType().equals(Constants.TWO)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户用户,无法进行该操作!"); |
| | | } |
| | | UnionApply unionApply = unionApplyJoinMapper.selectById(unionApplyBXDDTO.getId()); |
| | | if(unionApply == null ||!Constants.equalsInteger(unionApply.getIsdeleted(),Constants.ZERO)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY); |
| | |
| | | }else if(useDays>0){ |
| | | currentFee = new BigDecimal(useDays).multiply(price); |
| | | } |
| | | //上传保单信息 |
| | | if(StringUtils.isNotBlank(unionApplyBXDDDetailTO.getFileUrl())){ |
| | | Multifile multifile = new Multifile(); |
| | | multifile.setIsdeleted(Constants.ZERO); |
| | | multifile.setCreator(user.getId()); |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setObjId(insuranceApply.getId()); |
| | | multifile.setObjType(Constants.MultiFile.BD_DONE_PDF.getKey()); |
| | | multifile.setType(Constants.TWO); |
| | | multifile.setFileurl(unionApplyBXDDDetailTO.getFileUrl()); |
| | | multifile.setName(unionApplyBXDDDetailTO.getFileName()); |
| | | multifileMapper.insert(multifile); |
| | | insuranceApply.setUnionApplyTbdStatus(Constants.ONE); |
| | | }else{ |
| | | insuranceApply.setUnionApplyTbdStatus(Constants.ZERO); |
| | | } |
| | | //更新投保申请单 |
| | | insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda() |
| | | .set(InsuranceApply::getFee, |
| | | new BigDecimal(applyDetails.size()) |
| | | .multiply(price) |
| | | ) |
| | | .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) |
| | | .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_DONE.getKey()) |
| | | .set(InsuranceApply::getUnionApplyTbdStatus,3) |
| | | .set(InsuranceApply::getFee,price.multiply(new BigDecimal(applyDetails.size())).multiply(new BigDecimal(maxDays))) |
| | | .set(InsuranceApply::getCurrentFee,currentFee.multiply(new BigDecimal(applyDetails.size()))) |
| | | .set(InsuranceApply::getStartTime,unionApplyBXDDTO.getStartTime()) |
| | | .set(InsuranceApply::getEndTime,unionApplyBXDDTO.getEndTime()) |
| | | .set(InsuranceApply::getUnionApplyTbdStatus,insuranceApply.getUnionApplyTbdStatus()) |
| | | .set(InsuranceApply::getEditDate,new Date()) |
| | | .set(InsuranceApply::getEditor,user.getId()) |
| | | .eq(InsuranceApply::getId,insuranceApply.getId())); |
| | |
| | | .set(ApplyDetail::getEndTime,unionApplyBXDDTO.getEndTime()) |
| | | .in(ApplyDetail::getId,applyDetails.stream().map(m->m.getId()).collect(Collectors.toList())) |
| | | ); |
| | | //上传保单信息 |
| | | if(StringUtils.isNotBlank(unionApplyBXDDDetailTO.getFileUrl())){ |
| | | Multifile multifile = new Multifile(); |
| | | multifile.setIsdeleted(Constants.ZERO); |
| | | multifile.setCreator(user.getId()); |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setObjId(insuranceApply.getId()); |
| | | multifile.setObjType(Constants.MultiFile.BD_APPLY_PDF.getKey()); |
| | | multifile.setType(Constants.TWO); |
| | | multifile.setFileurl(unionApplyBXDDDetailTO.getFileUrl()); |
| | | multifile.setName(unionApplyBXDDDetailTO.getFileName()); |
| | | multifileMapper.insert(multifile); |
| | | } |
| | | |
| | | sumFee = sumFee.add(price.multiply(new BigDecimal(applyDetails.size())).multiply(new BigDecimal(maxDays))); |
| | | sumCurrFee = sumCurrFee.add(currentFee.multiply(new BigDecimal(applyDetails.size()))); |
| | | } |
| | |
| | | multifile.setCreator(user.getId()); |
| | | multifile.setCreateDate(new Date()); |
| | | multifile.setObjId(unionApply.getId()); |
| | | multifile.setObjType(Constants.MultiFile.HBD_BD_APPLY_PDF.getKey()); |
| | | multifile.setObjType(Constants.MultiFile.WTB_BD_DONE_PDF.getKey()); |
| | | multifile.setType(Constants.TWO); |
| | | multifile.setFileurl(unionApplyBXDDTO.getFileUrl()); |
| | | multifile.setName(unionApplyBXDDTO.getFileName()); |
| | | multifileMapper.insert(multifile); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | |
| | | |