|  |  |  | 
|---|
|  |  |  | import com.doumee.core.utils.DateUtil; | 
|---|
|  |  |  | import com.doumee.core.utils.Utils; | 
|---|
|  |  |  | import com.doumee.dao.business.*; | 
|---|
|  |  |  | import com.doumee.dao.business.dto.ApplyChangeCyclePriceDTO; | 
|---|
|  |  |  | import com.doumee.dao.business.dto.ApplyChangeOptDTO; | 
|---|
|  |  |  | import com.doumee.dao.business.dto.CountCyclePriceDTO; | 
|---|
|  |  |  | import com.doumee.dao.business.dto.InsuranceApplyOptDTO; | 
|---|
|  |  |  | import com.doumee.dao.business.join.ApplyChagneDetailJoinMapper; | 
|---|
|  |  |  | import com.doumee.dao.business.join.ApplyChangeJoinMapper; | 
|---|
|  |  |  | import com.doumee.dao.business.join.ApplyDetailJoinMapper; | 
|---|
|  |  |  | import com.doumee.dao.business.join.DuSolutionJoinMapper; | 
|---|
|  |  |  | import com.doumee.dao.business.model.*; | 
|---|
|  |  |  | import com.doumee.dao.business.vo.CountCyclePriceVO; | 
|---|
|  |  |  | import com.doumee.service.business.ApplyChangeService; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ApplyChangeMapper applyChangeMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private DuSolutionJoinMapper duSolutionJoinMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private InsuranceApplyMapper insuranceApplyMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | || Objects.isNull(applyChange.getApplyId()) | 
|---|
|  |  |  | || Objects.isNull(applyChange.getValidTime()) | 
|---|
|  |  |  | || Objects.isNull(applyChange.getType()) | 
|---|
|  |  |  | || !(applyChange.getType().equals(Constants.ZERO) || applyChange.getType().equals(Constants.TWO)) | 
|---|
|  |  |  | || !(applyChange.getType().equals(Constants.ZERO) || applyChange.getType().equals(Constants.ONE)) | 
|---|
|  |  |  | ) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if (Objects.isNull(insuranceApply)) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())) { | 
|---|
|  |  |  | System.out.println(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()); | 
|---|
|  |  |  | if (!Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "保单状态错误"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (DateUtil.compareDate(new Date(), insuranceApply.getEndTime()) >= Constants.ZERO | 
|---|
|  |  |  | if (DateUtil.compareDate(insuranceApply.getEndTime(),new Date()) >= Constants.ZERO | 
|---|
|  |  |  | ) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "保单已过保,无法进行该操作"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业分配保险方案信息"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //申请时间必须处于保单的时间范围内 | 
|---|
|  |  |  | if (!(DateUtil.compareDate(applyChange.getValidTime(), insuranceApply.getStartTime()) >= Constants.ZERO | 
|---|
|  |  |  | && DateUtil.compareDate(insuranceApply.getEndTime(), applyChange.getValidTime()) >= Constants.ZERO)) { | 
|---|
|  |  |  | if (!(DateUtil.compareDate( insuranceApply.getStartTime(),applyChange.getValidTime()) >= Constants.ZERO | 
|---|
|  |  |  | && DateUtil.compareDate( applyChange.getValidTime(),insuranceApply.getEndTime()) >= Constants.ZERO)) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "申请日期未处于保单日期内,无法进行该操作"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyChange.setCreateDate(new Date()); | 
|---|
|  |  |  | applyChange.setCreator(loginUserInfo.getId()); | 
|---|
|  |  |  | applyChange.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | applyChange.setApplyStartTime(applyChange.getValidTime()); | 
|---|
|  |  |  | applyChange.setStatus(Constants.ZERO); | 
|---|
|  |  |  | applyChangeMapper.insert(applyChange); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<DuSolution> duSolutionList = duSolutionMapper.selectList(new QueryWrapper<DuSolution>().lambda() | 
|---|
|  |  |  | .eq(DuSolution::getIsdeleted, Constants.ZERO) | 
|---|
|  |  |  | .eq(DuSolution::getStatus, Constants.ONE) | 
|---|
|  |  |  | .eq(DuSolution::getSolutionId, insuranceApply.getSolutionId())); | 
|---|
|  |  |  | if (!CollectionUtils.isNotEmpty(duSolutionList)) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "数据异常:保险方案下未查询到派遣单位"); | 
|---|
|  |  |  | //查询保险方案下的所有派遣单位 | 
|---|
|  |  |  | List<DuSolution>  duSolutionList = duSolutionJoinMapper.selectJoinList(DuSolution.class,new MPJLambdaWrapper<DuSolution>() | 
|---|
|  |  |  | .selectAll(DuSolution.class) | 
|---|
|  |  |  | .innerJoin(DispatchUnit.class,DispatchUnit::getId,DuSolution::getDispatchUnitId) | 
|---|
|  |  |  | .eq(DispatchUnit::getCompanyId,insuranceApply.getCompanyId()) | 
|---|
|  |  |  | .eq(DispatchUnit::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(DispatchUnit::getUnitStatus,Constants.ONE) | 
|---|
|  |  |  | .eq(DuSolution::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(DuSolution::getStatus,Constants.ONE) | 
|---|
|  |  |  | .eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())); | 
|---|
|  |  |  | if(!CollectionUtils.isNotEmpty(duSolutionList)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常:保险方案下未查询到派遣单位"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //查询所有派遣单位下的工种 | 
|---|
|  |  |  | List<Integer> duSolutionIdList = duSolutionList.stream().map(i -> i.getId()).collect(Collectors.toList()); | 
|---|
|  |  |  | List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList()); | 
|---|
|  |  |  | List<DuWorktype> duWorktypeList = duWorktypeMapper.selectList(new QueryWrapper<DuWorktype>().lambda() | 
|---|
|  |  |  | .eq(DuWorktype::getIsdeleted, Constants.ZERO) | 
|---|
|  |  |  | .eq(DuWorktype::getStatus, Constants.ONE) | 
|---|
|  |  |  | .in(DuWorktype::getDuSolutionId, duSolutionIdList)); | 
|---|
|  |  |  | .eq(DuWorktype::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(DuWorktype::getStatus,Constants.ONE) | 
|---|
|  |  |  | .in(DuWorktype::getDuSolutionId,duSolutionIdList)); | 
|---|
|  |  |  | if (!CollectionUtils.isNotEmpty(duWorktypeList)) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "数据异常:保险方案下未查询到工种信息"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | BigDecimal fee = BigDecimal.ZERO; | 
|---|
|  |  |  | //加保数据 | 
|---|
|  |  |  | List<ApplyChagneDetail> addDetailList = applyChange.getAddDetailList(); | 
|---|
|  |  |  | if (CollectionUtils.isNotEmpty(addDetailList)) { | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该企业分配保险方案无法进行加保"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | this.addChangeDetail(applyChange,addDetailList,duWorktypeList,duSolutionList,insuranceApply,solutions,loginUserInfo); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | fee = addDetailList.stream().map(ApplyChagneDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //减保数据 | 
|---|
|  |  |  | List<ApplyChagneDetail> delDetailList = applyChange.getDelDetailList(); | 
|---|
|  |  |  | if (CollectionUtils.isNotEmpty(delDetailList)) { | 
|---|
|  |  |  | if(companySolution.getCanReduce().equals(Constants.ZERO)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该企业分配保险方案无法进行加保"); | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该企业分配保险方案无法进行减保"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | this.delChangeDetail(applyChange,delDetailList,insuranceApply,solutions,loginUserInfo); | 
|---|
|  |  |  | this.delChangeDetail(applyChange,delDetailList,insuranceApply,solutions,loginUserInfo); | 
|---|
|  |  |  | fee = fee.add(delDetailList.stream().map(ApplyChagneDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | ApplyChange applyChangeFee = new ApplyChange(); | 
|---|
|  |  |  | applyChangeFee.setId(applyChange.getId()); | 
|---|
|  |  |  | applyChangeFee.setFee(fee); | 
|---|
|  |  |  | applyChangeMapper.updateById(applyChangeFee); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //换厂业务 | 
|---|
|  |  |  | List<ApplyChagneDetail> changeDetailList = applyChange.getChangeDetailList(); | 
|---|
|  |  |  | if (CollectionUtils.isNotEmpty(changeDetailList)) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | this.saveApplyLog(applyChange,Constants.ApplyChangeLogStatus.UPLOAD,null); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return applyChange.getId(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | applyLog.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | applyLog.setApplyId(applyChange.getApplyId()); | 
|---|
|  |  |  | applyLog.setTitle(applyChangeLogStatus.getName()); | 
|---|
|  |  |  | applyLog.setContent(content); | 
|---|
|  |  |  | if(StringUtils.isNotBlank(content)){ | 
|---|
|  |  |  | applyLog.setContent(applyChangeLogStatus.getInfo().replace("${param}",content)); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | applyLog.setContent(applyChangeLogStatus.getInfo()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyLog.setObjType(applyChangeLogStatus.getKey()); | 
|---|
|  |  |  | applyLog.setObjId( applyChange.getId()); | 
|---|
|  |  |  | applyLog.setStatus(applyChange.getStatus()); | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】保单信息异常,存在多条数据"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO); | 
|---|
|  |  |  | if (applyChange.getValidTime().compareTo(applyDetail.getEndTime()) <= 0) { | 
|---|
|  |  |  | if (applyChange.getValidTime().compareTo(applyDetail.getEndTime()) > 0) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至:【" + applyDetail.getEndTime() + "】无法通过本次申请"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyChagneDetail.setCreateDate(new Date()); | 
|---|
|  |  |  | 
|---|
|  |  |  | applyChagneDetail.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | applyChagneDetail.setApplyChangeId(applyChange.getId()); | 
|---|
|  |  |  | applyChagneDetail.setType(Constants.ONE); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | System.out.println(DateUtil.dateToString(applyDetail.getEndTime(),"yyyy-MM-dd")); | 
|---|
|  |  |  | System.out.println(DateUtil.dateToString(applyDetail.getStartTime(),"yyyy-MM-dd")); | 
|---|
|  |  |  | System.out.println(DateUtil.dateToString(applyChange.getValidTime(),"yyyy-MM-dd")); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | BigDecimal sumFee = Constants.countDetailFee(solutions, applyDetail.getEndTime(),applyDetail.getStartTime()); | 
|---|
|  |  |  | BigDecimal useFee = Constants.countDetailFee(solutions, applyChange.getValidTime(),applyDetail.getStartTime()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | applyChagneDetail.setFee( | 
|---|
|  |  |  | Constants.countDetailFee(solutions, applyDetail.getEndTime(),applyDetail.getStartTime()) | 
|---|
|  |  |  | .subtract(Constants.countDetailFee(solutions,applyChange.getValidTime(), applyDetail.getStartTime())) | 
|---|
|  |  |  | .subtract(Constants.countDetailFee(solutions,applyChange.getValidTime(), applyDetail.getStartTime())).multiply(new BigDecimal(-1)) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | applyChagneDetailJoinMapper.insert(applyChagneDetail); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public void addChangeDetail(ApplyChange applyChange ,List<ApplyChagneDetail> addDetailList,List<DuWorktype> duWorktypeList,List<DuSolution> duSolutionList,InsuranceApply insuranceApply,Solutions solutions,LoginUserInfo loginUserInfo){ | 
|---|
|  |  |  | for (ApplyChagneDetail applyChagneDetail : addDetailList) { | 
|---|
|  |  |  | if (Objects.isNull(applyChagneDetail.getMemberId()) | 
|---|
|  |  |  | || Objects.isNull(applyChagneDetail.getDuId()) | 
|---|
|  |  |  | if (    Objects.isNull(applyChagneDetail.getDuId()) | 
|---|
|  |  |  | || Objects.isNull(applyChagneDetail.getWorktypeId()) | 
|---|
|  |  |  | || StringUtils.isBlank(applyChagneDetail.getIdcardNo()) | 
|---|
|  |  |  | ) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】必填项缺失"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Member member = memberMapper.selectById(applyChagneDetail.getMemberId()); | 
|---|
|  |  |  | if (Objects.isNull(member)) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】未查询到系统人员信息"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Member member = new Member(); | 
|---|
|  |  |  | if(Objects.isNull(applyChagneDetail.getMemberId())){ | 
|---|
|  |  |  | //查询是否存在该用户 | 
|---|
|  |  |  | member = memberMapper.selectOne(new QueryWrapper<Member>().lambda() | 
|---|
|  |  |  | .eq(Member::getCompanyId,insuranceApply.getCompanyId()) | 
|---|
|  |  |  | .eq(Member::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(Member::getIdcardNo,applyChagneDetail.getIdcardNo()) | 
|---|
|  |  |  | .last(" limit 1") | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(Objects.isNull(member)){ | 
|---|
|  |  |  | member = new Member(); | 
|---|
|  |  |  | member.setCreateDate(new Date()); | 
|---|
|  |  |  | member.setCreator(loginUserInfo.getId()); | 
|---|
|  |  |  | member.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | member.setName(applyChagneDetail.getMemberName()); | 
|---|
|  |  |  | member.setCompanyId(insuranceApply.getCompanyId()); | 
|---|
|  |  |  | member.setSex(Constants.getSexByIdCard(applyChagneDetail.getIdcardNo())); | 
|---|
|  |  |  | member.setIdcardNo(applyChagneDetail.getIdcardNo()); | 
|---|
|  |  |  | member.setApplyId(insuranceApply.getId()); | 
|---|
|  |  |  | member.setDuId(applyChagneDetail.getDuId()); | 
|---|
|  |  |  | member.setWorktypeId(applyChagneDetail.getWorktypeId()); | 
|---|
|  |  |  | memberMapper.insert(member); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | member.setApplyId(insuranceApply.getId()); | 
|---|
|  |  |  | member.setDuId(applyChagneDetail.getDuId()); | 
|---|
|  |  |  | member.setWorktypeId(applyChagneDetail.getWorktypeId()); | 
|---|
|  |  |  | memberMapper.updateById(member); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | member = memberMapper.selectById(applyChagneDetail.getMemberId()); | 
|---|
|  |  |  | if(Objects.isNull(member)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】未查询到系统人员信息"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | member.setApplyId(insuranceApply.getId()); | 
|---|
|  |  |  | member.setDuId(applyChagneDetail.getDuId()); | 
|---|
|  |  |  | member.setWorktypeId(applyChagneDetail.getWorktypeId()); | 
|---|
|  |  |  | memberMapper.updateById(member); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //查询员工是否存在  0待签署 1已签章 的此类业务保数据 同一主单下 | 
|---|
|  |  |  | if (applyChagneDetailJoinMapper.selectJoinCount( | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】存在申请中的加减保/换厂单据"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //查询员工是在主单下 是否存在生效中的数据 | 
|---|
|  |  |  | if (applyDetailJoinMapper.selectCount(new QueryWrapper<ApplyDetail>().lambda() | 
|---|
|  |  |  | .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) | 
|---|
|  |  |  | .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) | 
|---|
|  |  |  | .le(ApplyDetail::getStartTime, "now()") | 
|---|
|  |  |  | .ge(ApplyDetail::getEndTime, "now()") | 
|---|
|  |  |  | ) > Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】存在保障中的保单信息,无法进行加保"); | 
|---|
|  |  |  | if(!Objects.isNull(applyChagneDetail.getMemberId())){ | 
|---|
|  |  |  | if (applyDetailJoinMapper.selectCount(new QueryWrapper<ApplyDetail>().lambda() | 
|---|
|  |  |  | .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) | 
|---|
|  |  |  | .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) | 
|---|
|  |  |  | .le(ApplyDetail::getStartTime, "now()") | 
|---|
|  |  |  | .ge(ApplyDetail::getEndTime, "now()") | 
|---|
|  |  |  | ) > Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】存在保障中的保单信息,无法进行加保"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //验证派遣单位信息 与工种信息 是否存在 | 
|---|
|  |  |  | if (duSolutionList.stream().filter(d -> d.getDispatchUnitId().equals(applyChagneDetail.getDuId())).collect(Collectors.toList()).size() <= Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "【" + applyChagneDetail.getMemberName() + "】员工派遣单位未查询到!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (duWorktypeList.stream().filter(d -> d.getDuSolutionId().equals(applyChagneDetail.getDuId()) && d.getWorkTypeId().equals(applyChagneDetail.getWorktypeId())) | 
|---|
|  |  |  | if (duWorktypeList.stream().filter(d ->  d.getWorkTypeId().equals(applyChagneDetail.getWorktypeId())) | 
|---|
|  |  |  | .collect(Collectors.toList()).size() <= Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "【" + applyChagneDetail.getMemberName() + "】员工工种信息未查询到!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyChagneDetail.setMemberId(member.getId()); | 
|---|
|  |  |  | applyChagneDetail.setCreateDate(new Date()); | 
|---|
|  |  |  | applyChagneDetail.setCreator(loginUserInfo.getId()); | 
|---|
|  |  |  | applyChagneDetail.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | applyChagneDetail.setApplyChangeId(applyChange.getId()); | 
|---|
|  |  |  | applyChagneDetail.setType(Constants.ZERO); | 
|---|
|  |  |  | applyChagneDetail.setFee( | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Constants.countDetailFee(solutions,insuranceApply.getEndTime(),applyChange.getValidTime()) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | applyChagneDetailJoinMapper.insert(applyChagneDetail); | 
|---|
|  |  |  | 
|---|
|  |  |  | List<ApplyDetail>  applyDetailList = applyDetailJoinMapper.selectList(new QueryWrapper<ApplyDetail>().lambda() | 
|---|
|  |  |  | .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) | 
|---|
|  |  |  | .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) | 
|---|
|  |  |  | .le(ApplyDetail::getStartTime, "now()") | 
|---|
|  |  |  | .ge(ApplyDetail::getEndTime, "now()")); | 
|---|
|  |  |  | .le(ApplyDetail::getStartTime, DateUtil.getDate(new Date(),"yyyy-MM-dd HH:mm:ss")) | 
|---|
|  |  |  | .ge(ApplyDetail::getEndTime, DateUtil.getDate(new Date(),"yyyy-MM-dd HH:mm:ss"))); | 
|---|
|  |  |  | if(applyDetailList.size()>Constants.ONE){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】保单信息异常,存在多条数据"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO); | 
|---|
|  |  |  | if(applyChange.getValidTime().compareTo( applyDetail.getEndTime())<=0){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至:【"+applyDetail.getEndTime()+"】无法通过本次申请"); | 
|---|
|  |  |  | if(applyChange.getValidTime().compareTo( applyDetail.getEndTime())>0){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至:【"+DateUtil.getDate(applyDetail.getEndTime(),"yyyy-MM-dd HH:mm:ss")+"】无法通过本次申请"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //验证派遣单位信息 与工种信息 是否存在 | 
|---|
|  |  |  | if (duSolutionList.stream().filter(d -> d.getDispatchUnitId().equals(applyChagneDetail.getDuId())).collect(Collectors.toList()).size() <= Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】员工派遣单位未查询到!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (duWorktypeList.stream().filter(d -> d.getDuSolutionId().equals(applyChagneDetail.getDuId()) && d.getWorkTypeId().equals(applyChagneDetail.getWorktypeId())) | 
|---|
|  |  |  | if (duWorktypeList.stream().filter(d ->  d.getWorkTypeId().equals(applyChagneDetail.getWorktypeId())) | 
|---|
|  |  |  | .collect(Collectors.toList()).size() <= Constants.ZERO) { | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】员工工种信息未查询到!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) | 
|---|
|  |  |  | .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getStatus()),ApplyChange::getStatus,model.getStatus()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) | 
|---|
|  |  |  | .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus, | 
|---|
|  |  |  | Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), | 
|---|
|  |  |  | Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getCompanyId()),InsuranceApply::getCompanyId,model.getCompanyId()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) | 
|---|
|  |  |  | .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) | 
|---|
|  |  |  | 
|---|
|  |  |  | .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) | 
|---|
|  |  |  | .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getStatus()),ApplyChange::getStatus,model.getStatus()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) | 
|---|
|  |  |  | .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus, | 
|---|
|  |  |  | Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), | 
|---|
|  |  |  | Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getCompanyId()),InsuranceApply::getCompanyId,model.getCompanyId()) | 
|---|
|  |  |  | .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) | 
|---|
|  |  |  | .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Constants.ApplyChangeLogStatus applyChangeLogStatus = Constants.ApplyChangeLogStatus.RETURN_APPLY; | 
|---|
|  |  |  | if(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()) | 
|---|
|  |  |  | ||applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey())){ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(applyChangeOptDTO.getOptType().equals(3)){ | 
|---|
|  |  |  | //发起退回申请 | 
|---|
|  |  |  | if(loginUserInfo.getType().equals(Constants.ONE)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(!applyChange.getStatus().equals(Constants.ApplyChangeStatus.UPLOAD.getKey()) ){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); | 
|---|
|  |  |  | if(!(applyChange.getStatus().equals(Constants.ApplyChangeStatus.UPLOAD.getKey()) | 
|---|
|  |  |  | || applyChange.getStatus().equals(Constants.ApplyChangeStatus.SIGNATURE.getKey()))){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进退回申请!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey())){ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(applyChange.getStatus().equals(Constants.ApplyChangeStatus.UPLOAD.getKey())){ | 
|---|
|  |  |  | applyChange.setStatus(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | applyChange.setStatus(Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(4)){ | 
|---|
|  |  |  | applyChangeLogStatus = Constants.ApplyChangeLogStatus.PLATFORM_AGREE; | 
|---|
|  |  |  | //平台同意退回 | 
|---|
|  |  |  | if(loginUserInfo.getType().equals(Constants.ZERO)){ | 
|---|
|  |  |  | 
|---|
|  |  |  | )){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.UPLOAD.getKey())){ | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(5)){ | 
|---|
|  |  |  | applyChangeLogStatus = Constants.ApplyChangeLogStatus.PLATFORM_UN_AGREE; | 
|---|
|  |  |  | //平台驳回退回 | 
|---|
|  |  |  | if(loginUserInfo.getType().equals(Constants.ZERO)){ | 
|---|
|  |  |  | 
|---|
|  |  |  | )){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.CLOSE.getKey())){ | 
|---|
|  |  |  | applyChangeLogStatus = Constants.ApplyChangeLogStatus.CLOSE; | 
|---|
|  |  |  | if(applyChange.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey())){ | 
|---|
|  |  |  | applyChange.setStatus(Constants.ApplyChangeStatus.UPLOAD.getKey()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | applyChange.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if(applyChangeOptDTO.getOptType().equals(6)){ | 
|---|
|  |  |  | //企业关闭 | 
|---|
|  |  |  | applyChangeLogStatus = Constants.ApplyChangeLogStatus.CLOSE; | 
|---|
|  |  |  | if(loginUserInfo.getType().equals(Constants.ONE)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(!applyChange.getStatus().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey())){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyChange.setStatus(Constants.ApplyChangeStatus.CLOSE.getKey()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST  ); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | applyChange.setStatus(applyChangeOptDTO.getOptType()); | 
|---|
|  |  |  | applyChange.setEditor(loginUserInfo.getId()); | 
|---|
|  |  |  | applyChange.setEditDate(new Date()); | 
|---|
|  |  |  | applyChangeMapper.updateById(applyChange); | 
|---|
|  |  |  | //        //存储日志数据 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //存储日志数据 | 
|---|
|  |  |  | this.saveApplyLog(applyChange,applyChangeLogStatus,applyChangeOptDTO.getOptIllustration()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | if(StringUtils.isBlank(applyNo) ){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | String link = signService.signLink(applyNo,company.getEmail(),company.getCode()); | 
|---|
|  |  |  | String link = signService.signLink(applyNo,company.getName(),company.getCode()); | 
|---|
|  |  |  | if(StringUtils.isBlank(link) ){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public CountCyclePriceVO getChangeCountCyclePriceVO(ApplyChangeCyclePriceDTO applyChangeCyclePriceDTO){ | 
|---|
|  |  |  | if(Objects.isNull(applyChangeCyclePriceDTO) | 
|---|
|  |  |  | || Objects.isNull(applyChangeCyclePriceDTO.getApplyId()) | 
|---|
|  |  |  | || Objects.isNull(applyChangeCyclePriceDTO.getValidTime())){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyChangeCyclePriceDTO.getApplyId()); | 
|---|
|  |  |  | if(Objects.isNull(insuranceApply)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); | 
|---|
|  |  |  | if(Objects.isNull(solutions)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | CountCyclePriceVO countCyclePriceVO = new CountCyclePriceVO(); | 
|---|
|  |  |  | countCyclePriceVO.setCyclePrice(Constants.countDetailFee(solutions,insuranceApply.getEndTime(),applyChangeCyclePriceDTO.getValidTime())); | 
|---|
|  |  |  | return countCyclePriceVO; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|