From 31a2a1e82c6d1a80b62ef65bcfba46e084e372aa Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期三, 31 一月 2024 09:37:05 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- server/service/src/main/java/com/doumee/service/business/impl/ApplyChangeServiceImpl.java | 409 ++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 354 insertions(+), 55 deletions(-) diff --git a/server/service/src/main/java/com/doumee/service/business/impl/ApplyChangeServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/ApplyChangeServiceImpl.java index 0203ee3..3370231 100644 --- a/server/service/src/main/java/com/doumee/service/business/impl/ApplyChangeServiceImpl.java +++ b/server/service/src/main/java/com/doumee/service/business/impl/ApplyChangeServiceImpl.java @@ -1,6 +1,8 @@ package com.doumee.service.business.impl; 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; @@ -10,17 +12,22 @@ 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; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.doumee.service.business.third.SignService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.lang3.StringUtils; @@ -48,11 +55,20 @@ private ApplyChangeMapper applyChangeMapper; @Autowired + private DuSolutionJoinMapper duSolutionJoinMapper; + @Autowired private InsuranceApplyMapper insuranceApplyMapper; + + @Autowired + private CompanySolutionMapper companySolutionMapper; @Autowired private ApplyChangeJoinMapper applyChangeJoinMapper; + @Autowired + private SystemDictDataBiz systemDictDataBiz; + @Autowired + private SignService signService; @Autowired private ApplyChagneDetailJoinMapper applyChagneDetailJoinMapper; @@ -348,7 +364,7 @@ } } if(addList!=null && addList.size()>0){ - applyChagneDetailJoinMapper.insertBatchSomeColumn(addList); + applyDetailJoinMapper.insertBatchSomeColumn(addList); } if(totalFee.compareTo(new BigDecimal(0)) != 0){ //濡傛灉淇濆崟閲戦鍙戠敓缂栫爜锛屾洿鏂版�讳繚鍗曢噾棰� @@ -430,7 +446,7 @@ || 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); } @@ -442,10 +458,11 @@ 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(), "淇濆崟宸茶繃淇濓紝鏃犳硶杩涜璇ユ搷浣�"); } @@ -453,46 +470,77 @@ if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌淇濋櫓鏂规"); } + CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda() + .eq(CompanySolution::getCompanyId,loginUserInfo.getCompanyId()) + .eq(CompanySolution::getSolutionBaseId,solutions.getId()) + .eq(CompanySolution::getIsdeleted,Constants.ZERO) + .last(" limit 1 ") + ); + if(Objects.isNull(companySolution)){ + 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(), "鏁版嵁寮傚父锛氫繚闄╂柟妗堜笅鏈煡璇㈠埌娲鹃仯鍗曚綅"); + //鏌ヨ淇濋櫓鏂规涓嬬殑鎵�鏈夋淳閬e崟浣� + 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(),"鏁版嵁寮傚父锛氫繚闄╂柟妗堜笅鏈煡璇㈠埌娲鹃仯鍗曚綅"); } //鏌ヨ鎵�鏈夋淳閬e崟浣嶄笅鐨勫伐绉� - 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)) { + if(companySolution.getCanAdd().equals(Constants.ZERO)){ + 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)) { - this.delChangeDetail(applyChange,delDetailList,insuranceApply,solutions,loginUserInfo); + if(companySolution.getCanReduce().equals(Constants.ZERO)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "璇ヤ紒涓氬垎閰嶄繚闄╂柟妗堟棤娉曡繘琛屽噺淇�"); + } + 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)) { @@ -500,8 +548,6 @@ } this.saveApplyLog(applyChange,Constants.ApplyChangeLogStatus.UPLOAD,null); - - return applyChange.getId(); } @@ -514,7 +560,11 @@ 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()); @@ -555,7 +605,7 @@ 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()); @@ -563,9 +613,17 @@ 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); } @@ -583,15 +641,51 @@ */ 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( @@ -603,30 +697,31 @@ 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() + "銆戝憳宸ユ淳閬e崟浣嶆湭鏌ヨ鍒帮紒"); } - 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); @@ -669,20 +764,20 @@ 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() + "銆戝憳宸ユ淳閬e崟浣嶆湭鏌ヨ鍒帮紒"); } - 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() + "銆戝憳宸ュ伐绉嶄俊鎭湭鏌ヨ鍒帮紒"); } @@ -762,7 +857,10 @@ .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" ) @@ -803,7 +901,10 @@ .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" ) @@ -843,16 +944,24 @@ 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)){ @@ -863,7 +972,7 @@ )){ 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)){ @@ -874,21 +983,29 @@ )){ 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()); } @@ -910,6 +1027,188 @@ ApplyChange applyChange = applyChangeJoinMapper.selectOne(queryWrapper); return applyChange; } + /** + * 瀵煎嚭鎹㈠巶鐢宠琛� + * @param param + * @return + */ + @Override + public ApplyChange exportChangeUnitExcel(ApplyChange param){ + ApplyChange model = findJoinDetail(param); + if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getType())){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + + //鏌ヨ鏄庣粏 + List<ApplyChagneDetail> detailList =findJoinChangeDetailList(model); + model.setChangeDetailList(detailList!=null?detailList:new ArrayList<>()); + model.setChangeNum(model.getChangeDetailList().size()); + return model; + } + /** + * 瀵煎嚭鎹㈠巶鐢宠琛� + * @param param + * @return + */ + @Override + public String getSignLinkJiajiabao(ApplyChange param){ + ApplyChange model = exportJiajianBaoExcel(param); + return getOnlineSignLink(model); + } + /** + * 瀵煎嚭鎹㈠巶鐢宠琛� + * @param param + * @return + */ + @Override + public String getSignLinkChangeUnit(ApplyChange param){ + ApplyChange model = exportChangeUnitExcel(param); + return getOnlineSignLink(model); + } + + private String getOnlineSignLink(ApplyChange model) { + if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getType())){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + if(!Constants.equalsInteger(Constants.ZERO,model.getStatus())){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"瀵逛笉璧凤紝璇ョ敵璇风姸鎬佸凡娴佽浆锛屽綋鍓嶄笉鏀寔绛剧珷鎿嶄綔锛�"); + } + LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + Company company = user.getCompany(); + if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.ONE)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝浼佷笟灏氭湭鍏峰鍦ㄧ嚎绛剧珷鏉′欢锛岃鑱旂郴骞冲彴绠$悊鍛樼‘璁"); + } + + String fileUrl = ExcelExporter.build(ApplyChange.class).exportChangeUnitExcelToPdf(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(),fileUrl,company.getName(),company.getCode(),company.getEmail(),null,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(),"瀵逛笉璧凤紝鑾峰彇鍦ㄧ嚎绛剧珷鍦板潃澶辫触锛岃绋嶅悗閲嶈瘯锛�"); + } + ApplyChange update= new ApplyChange(); + update.setId(model.getId()); + update.setEditor(user.getId()); + update.setEditDate(new Date()); + update.setSignApplyNo(applyNo); + applyChangeMapper.updateById(update); + return link; + } + + + /** + * 瀵煎嚭鍔犲噺淇濈敵璇疯〃 + * @param param + * @return + */ + @Override + public ApplyChange exportJiajianBaoExcel(ApplyChange param){ + + ApplyChange model = findJoinDetail(param); + if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getType())){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + + //鏌ヨ鏄庣粏 + List<ApplyChagneDetail> detailList =findJoinDetailList(model); + model.setAddDetailList(new ArrayList<>()); + model.setDelDetailList(new ArrayList<>()); + if(detailList!=null){ + for(ApplyChagneDetail ad :detailList){ + if(Constants.equalsInteger(ad.getType(),Constants.ZERO)){ + model.getAddDetailList().add(ad); + }else{ + model.getDelDetailList().add(ad); + } + } + } + model.setDelNum(model.getDelDetailList().size()); + model.setAddNum(model.getAddDetailList().size()); + return model; + } + private ApplyChange findJoinDetail(ApplyChange param) { + MPJLambdaWrapper wrapper= new MPJLambdaWrapper<ApplyChange>() + .selectAll(ApplyChange.class) + .selectAs(Solutions::getName,ApplyChange::getSolutionsName) + .selectAs(Company::getName,ApplyChange::getCompanyName) + .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) + .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) + .selectAs(InsuranceApply::getStartTime,ApplyChange::getEndTime) + .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) + .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) + .leftJoin(Company.class,Company::getId,ApplyChange::getCompanyId) + .eq(ApplyChange::getId,param.getId()) + .last("limit 1"); + + ApplyChange model = applyChangeJoinMapper.selectJoinOne(ApplyChange.class,wrapper); + return model; + } + private List<ApplyChagneDetail> findJoinDetailList(ApplyChange model) { + MPJLambdaWrapper wrapper1= new MPJLambdaWrapper<ApplyChagneDetail>() + .selectAll(ApplyChagneDetail.class) + .selectAs(Member::getName,ApplyChagneDetail::getMemberName) + .selectAs(Member::getSex,ApplyChagneDetail::getSex) + .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo) + .selectAs(Worktype::getName,ApplyChagneDetail::getWorkTypeName) + .selectAs(DispatchUnit::getName,ApplyChagneDetail::getDuName) + .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId) + .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId) + .leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId) + .eq(ApplyChagneDetail::getIsdeleted,Constants.ZERO) + .eq(ApplyChagneDetail::getApplyChangeId,model.getId()); + //鏌ヨ鏄庣粏 + List<ApplyChagneDetail> detailList =applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class,wrapper1); + return detailList; + } + private List<ApplyChagneDetail> findJoinChangeDetailList(ApplyChange model) { + MPJLambdaWrapper wrapper1= new MPJLambdaWrapper<ApplyChagneDetail>() + .selectAll(ApplyChagneDetail.class) + .selectAs(Member::getName,ApplyChagneDetail::getMemberName) + .selectAs(Member::getSex,ApplyChagneDetail::getSex) + .select("t1.name as worktypeName") + .select("t2.name as duName") + .select("t3.name as oldWorktypeName") + .select("t4.name as oldDuName") + .selectAs(Member::getSex,ApplyChagneDetail::getSex) + .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo) + .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId) + .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId) + .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getOldWorktypeId) + .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getOldDuId) + .leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId) + .eq(ApplyChagneDetail::getIsdeleted,Constants.ZERO) + .eq(ApplyChagneDetail::getApplyChangeId,model.getId()); + //鏌ヨ鏄庣粏 + List<ApplyChagneDetail> detailList =applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class,wrapper1); + return detailList; + } + + + @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; + + } -- Gitblit v1.9.3