|  |  | 
 |  |  | 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.join.ApplyDetailJoinMapper; | 
 |  |  | import com.doumee.dao.business.join.ApplyLogJoinMapper; | 
 |  |  | import com.doumee.dao.business.join.InsuranceApplyJoinMapper; | 
 |  |  | import com.doumee.dao.business.join.*; | 
 |  |  | import com.doumee.dao.business.model.*; | 
 |  |  | import com.doumee.dao.business.vo.CountCyclePriceVO; | 
 |  |  | import com.doumee.dao.system.model.SystemUser; | 
 |  |  | 
 |  |  | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; | 
 |  |  | import com.baomidou.mybatisplus.core.metadata.IPage; | 
 |  |  | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | 
 |  |  | import com.doumee.service.business.SmsEmailService; | 
 |  |  | import com.doumee.service.business.third.EmailService; | 
 |  |  | import com.doumee.service.business.third.SignService; | 
 |  |  | import com.github.xiaoymin.knife4j.core.util.CollectionUtils; | 
 |  |  | import com.github.yulichang.wrapper.MPJLambdaWrapper; | 
 |  |  | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | import org.springframework.transaction.annotation.Transactional; | 
 |  |  |  | 
 |  |  | import java.io.File; | 
 |  |  | import java.math.BigDecimal; | 
 |  |  | import java.util.*; | 
 |  |  | import java.util.stream.Collectors; | 
 |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private InsuranceApplyMapper insuranceApplyMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private ApplyChangeMapper applyChangeMapper; | 
 |  |  |     private SmsEmailService smsEmailService; | 
 |  |  |     @Autowired | 
 |  |  |     private ApplyChangeJoinMapper applyChangeMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SystemDictDataBiz systemDictDataBiz; | 
 |  |  | 
 |  |  |     private InsuranceApplyJoinMapper insuranceApplyJoinMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private CompanyMapper companyMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private MemberInsuranceJoinMapper memberInsuranceJoinMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ApplyDetailMapper applyDetailMapper; | 
 |  |  | 
 |  |  |     private MemberMapper memberMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private DuSolutionMapper duSolutionMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private DuSolutionJoinMapper duSolutionJoinMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private DuWorktypeMapper duWorktypeMapper; | 
 |  |  |  | 
 |  |  | 
 |  |  |         } | 
 |  |  |         ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); | 
 |  |  |         applyLogMapper.insert(log); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         //存储员工信息投保记录 | 
 |  |  |         //查询单据明细记录 | 
 |  |  |         MPJLambdaWrapper<ApplyDetail> queryWrapper = new MPJLambdaWrapper<>(); | 
 |  |  |         queryWrapper.selectAll(ApplyDetail.class); | 
 |  |  |         queryWrapper.selectAs(DispatchUnit::getName,ApplyDetail::getDuName); | 
 |  |  |         queryWrapper.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode); | 
 |  |  |         queryWrapper.selectAs(Solutions::getId,ApplyDetail::getSolutionId); | 
 |  |  |         queryWrapper.selectAs(Solutions::getName,ApplyDetail::getSolutionName); | 
 |  |  |         queryWrapper.selectAs(Worktype::getName,ApplyDetail::getWorkTypeName); | 
 |  |  |         queryWrapper.selectAs(Member::getIdcardNo,ApplyDetail::getIdcardNo); | 
 |  |  |         queryWrapper.selectAs(Member::getName,ApplyDetail::getMemberName); | 
 |  |  |         queryWrapper.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyDetail::getDuId); | 
 |  |  |         queryWrapper.leftJoin(Worktype.class,Worktype::getId,ApplyDetail::getWorktypeId); | 
 |  |  |         queryWrapper.leftJoin(Member.class,Member::getId,ApplyDetail::getMemberId); | 
 |  |  |         queryWrapper.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId); | 
 |  |  |         queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId); | 
 |  |  |         queryWrapper.eq(ApplyDetail::getApplyId,insuranceApply.getId()); | 
 |  |  |         List<ApplyDetail> applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,queryWrapper); | 
 |  |  |  | 
 |  |  |         if(CollectionUtils.isNotEmpty(applyDetailList)){ | 
 |  |  |             List<MemberInsurance> memberInsuranceList = new ArrayList<>(); | 
 |  |  |             for (ApplyDetail applyDetail:applyDetailList) { | 
 |  |  |                 MemberInsurance memberInsurance = new MemberInsurance(applyDetail,user.getId()); | 
 |  |  |                 memberInsuranceList.add(memberInsurance); | 
 |  |  |             } | 
 |  |  |             memberInsuranceJoinMapper.insertBatchSomeColumn(memberInsuranceList); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         return  1; | 
 |  |  |  | 
 |  |  |     } | 
 |  |  | 
 |  |  |                 return tempFileName; | 
 |  |  |             } | 
 |  |  |         }catch (Exception e){ | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |         return  null; | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public Integer uploadSignedFileDo(InsuranceApply model,String fileurl) { | 
 |  |  |     public Multifile   uploadSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) { | 
 |  |  |         InsuranceApply update = new InsuranceApply(); | 
 |  |  |         update.setEditDate(new Date()); | 
 |  |  |         update.setEditor(model.getCreator()); | 
 |  |  | 
 |  |  |         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  1; | 
 |  |  |  | 
 |  |  |         startSendEmail(f, model.getCompanyName(),model.getSolutionsName(),model.getSolutionEmail()); | 
 |  |  |         return  f; | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |     public Integer uploadChangeSignedFileDo(ApplyChange model,String fileurl) { | 
 |  |  |     public Multifile  uploadChangeSignedFileDo(ApplyChange model,String fileurl,String fullurl) { | 
 |  |  |         ApplyChange update = new ApplyChange(); | 
 |  |  |         update.setEditDate(new Date()); | 
 |  |  |         update.setEditor(model.getCreator()); | 
 |  |  | 
 |  |  |         f.setObjType(Constants.equalsInteger(Constants.ZERO,model.getType())?Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() : Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey()); | 
 |  |  |         f.setType(Constants.TWO); | 
 |  |  |         f.setFileurl(fileurl); | 
 |  |  |         f.setFileurlFull(fullurl); | 
 |  |  |         f.setInfo("企业申请表签署文件"); | 
 |  |  |         f.setName("签章申请表.pdf"); | 
 |  |  |         multifileMapper.insert(f); | 
 |  |  |         Constants.ApplyLogType applyLogType =Constants.equalsInteger(Constants.ZERO,model.getType())? Constants.ApplyLogType.CA_JIAJIAN_APPLY_SIGN: Constants.ApplyLogType.CA_CHANGUNIT_APPLY_SIGN; | 
 |  |  |         ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); | 
 |  |  |         applyLogMapper.insert(log); | 
 |  |  |         return  1; | 
 |  |  |  | 
 |  |  |         startSendEmail(f,model.getCompanyName(),model.getSolutionsName(),model.getSolutionEmail()); | 
 |  |  |         return f; | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private void startSendEmail(Multifile f, String companyName, String solutionsName, String solutionEmail) { | 
 |  |  |         if(StringUtils.isBlank(solutionEmail) || f==null|| StringUtils.isBlank(f.getFileurl())){ | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         SmsEmail email = new SmsEmail(); | 
 |  |  |         email.setTitle(f.getInfo()); | 
 |  |  |         email.setEmail(solutionEmail); | 
 |  |  |         email.setContent("来自企业【"+companyName+"】关于保险方案【"+solutionsName+"】的"+f.getInfo()); | 
 |  |  |         File file = Constants.getFileByNetFile(f.getFileurlFull(),f.getName()); | 
 |  |  |         if(file!=null && file.isFile()){ | 
 |  |  |             Map<String,Object> files = new HashMap<>(); | 
 |  |  |             files.put("name",f.getName()); | 
 |  |  |             files.put("file",file); | 
 |  |  |             email.setFileList(new ArrayList<>()); | 
 |  |  |             email.getFileList().add(files); | 
 |  |  |             smsEmailService.sendEmail(email); | 
 |  |  |             file.delete();//发送后删除临时文件 | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public   void dealWaitSignedData(){ | 
 |  |  |         List<InsuranceApply> applyList = insuranceApplyMapper.selectList(new QueryWrapper<InsuranceApply>().lambda() | 
 |  |  |                 .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE) | 
 |  |  |         List<InsuranceApply> 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.WAIT_SIGNATURE.getKey()) | 
 |  |  |                 .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()); | 
 |  |  |                 if(!StringUtils.equals(status,"3")){ | 
 |  |  |                     continue; | 
 |  |  |                 } | 
 |  |  |                 String link = signService.linkFile(model.getSignApplyNo()); | 
 |  |  |                 String fileUrl = uploadSignFile(link); | 
 |  |  |                 if(StringUtils.isBlank(fileUrl)){ | 
 |  |  |                     //如果下载失败,清除合同,下次签章重新生成新合同 | 
 |  |  |                     return; | 
 |  |  |                 } | 
 |  |  |                 uploadSignedFileDo(model,fileUrl); | 
 |  |  |                 uploadSignedFileDo(model,fileUrl,path+fileUrl); | 
 |  |  |                 return; | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         List<ApplyChange> chagneList = applyChangeMapper.selectList(new QueryWrapper<ApplyChange>().lambda() | 
 |  |  |                 .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD) | 
 |  |  |         List<ApplyChange> chagneList = applyChangeMapper.selectJoinList(ApplyChange.class, | 
 |  |  |                 new MPJLambdaWrapper<ApplyChange>() | 
 |  |  |                 .selectAll(ApplyChange.class) | 
 |  |  |                 .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) | 
 |  |  |                 .selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail) | 
 |  |  |                 .selectAs(Company::getName,InsuranceApply::getCompanyName) | 
 |  |  |                 .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()) | 
 |  |  |                 .isNotNull(ApplyChange::getSignApplyNo)); | 
 |  |  |         if(chagneList !=null && chagneList.size()>0 ){ | 
 |  |  |             for(ApplyChange model : chagneList){ | 
 |  |  |                 String status = signService.linkFileStatus(model.getSignApplyNo()); | 
 |  |  |                 if(!StringUtils.equals(status,"3")){ | 
 |  |  |                     continue; | 
 |  |  |                 } | 
 |  |  |                 String link = signService.linkFile(model.getSignApplyNo()); | 
 |  |  |                 String fileUrl = uploadSignFile(link); | 
 |  |  |                 if(StringUtils.isBlank(fileUrl)){ | 
 |  |  |                     //如果下载失败,清除合同,下次签章重新生成新合同 | 
 |  |  |                     return; | 
 |  |  |                 } | 
 |  |  |                 uploadChangeSignedFileDo(model,fileUrl); | 
 |  |  |                 uploadChangeSignedFileDo(model,fileUrl,path+fileUrl); | 
 |  |  |                 return; | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  | 
 |  |  |         } | 
 |  |  |         if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){ | 
 |  |  |             //如果已保全,可下载签约附件 | 
 |  |  |             InsuranceApply model = insuranceApplyMapper.selectOne(new QueryWrapper<InsuranceApply>().lambda().eq(InsuranceApply::getSignApplyNo,data.getApplyNo()).last("limit 1" )); | 
 |  |  |             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(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::getSignApplyNo,data.getApplyNo()) | 
 |  |  |                             .last("limit 1" )); | 
 |  |  |             if(model != null && Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){ | 
 |  |  |                 //完成签署已完成操作 | 
 |  |  |                 String link = signService.linkFile(data.getApplyNo()); | 
 |  |  | 
 |  |  |                     //如果下载失败,清除合同,下次签章重新生成新合同 | 
 |  |  |                     return; | 
 |  |  |                 } | 
 |  |  |                 uploadSignedFileDo(model,fileUrl); | 
 |  |  |                 uploadSignedFileDo(model,fileUrl,path+fileUrl); | 
 |  |  |                 return; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             ApplyChange applyChange = applyChangeMapper.selectOne(new QueryWrapper<ApplyChange>().lambda().eq(ApplyChange::getSignApplyNo,data.getApplyNo()).last("limit 1" )); | 
 |  |  |             ApplyChange applyChange = applyChangeMapper.selectJoinOne(ApplyChange.class, | 
 |  |  |                     new MPJLambdaWrapper<ApplyChange>() | 
 |  |  |                             .selectAll(ApplyChange.class) | 
 |  |  |                             .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) | 
 |  |  |                             .selectAs(Solutions::getEmail,InsuranceApply::getSolutionEmail) | 
 |  |  |                             .selectAs(Company::getName,InsuranceApply::getCompanyName) | 
 |  |  |                             .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) | 
 |  |  |                             .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
 |  |  |                             .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
 |  |  |                             .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()); | 
 |  |  |                 String fileUrl = uploadSignFile(link); | 
 |  |  | 
 |  |  |                     //如果下载失败,清除合同,下次签章重新生成新合同 | 
 |  |  |                     return; | 
 |  |  |                 } | 
 |  |  |                 uploadChangeSignedFileDo(applyChange,fileUrl); | 
 |  |  |                 uploadChangeSignedFileDo(applyChange,fileUrl,path+fileUrl); | 
 |  |  |             } | 
 |  |  |         }else if(Constants.equalsInteger(data.getSignStatus(), Constants.TWO )){ | 
 |  |  |             //如果已拒签,清除合同,下次签章重新生成新合同 | 
 |  |  | 
 |  |  |         insuranceApply.setCompanyId(loginUserInfo.getCompanyId()); | 
 |  |  |         insuranceApply.setCheckInfo(insuranceApplyStatus.getName()); | 
 |  |  |         insuranceApply.setStartTime(insuranceApply.getApplyStartTime()); | 
 |  |  |         insuranceApply.setEndTime(insuranceApply.getApplyEndTime()); | 
 |  |  |         insuranceApply.setCheckDate(new Date()); | 
 |  |  |         insuranceApply.setCurrentFee(BigDecimal.ZERO); | 
 |  |  |         insuranceApply.setCheckUserId(loginUserInfo.getId()); | 
 |  |  |         insuranceApply.setStatus(insuranceApplyStatus.getKey()); | 
 |  |  |  | 
 |  |  |         CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO(); | 
 |  |  |         countCyclePriceDTO.setSolutionsId(insuranceApply.getSolutionId()); | 
 |  |  |         countCyclePriceDTO.setStartDate(insuranceApply.getStartTime()); | 
 |  |  |         CountCyclePriceVO  countCyclePriceVO = this.getCountCyclePriceVO(countCyclePriceDTO); | 
 |  |  |         insuranceApply.setApplyEndTime(countCyclePriceVO.getEndDate()); | 
 |  |  |         insuranceApply.setEndTime(countCyclePriceVO.getEndDate()); | 
 |  |  |         insuranceApplyMapper.insert(insuranceApply); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         //处理下级数据 | 
 |  |  |         this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo); | 
 |  |  |         this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo,countCyclePriceVO); | 
 |  |  |         InsuranceApply updBean = new InsuranceApply(); | 
 |  |  |         updBean.setId(insuranceApply.getId()); | 
 |  |  |         updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
 |  |  | 
 |  |  |         insuranceApply.setCompanyId(loginUserInfo.getCompanyId()); | 
 |  |  |         insuranceApply.setCheckInfo(insuranceApplyStatus.getName()); | 
 |  |  |         insuranceApply.setStartTime(insuranceApply.getApplyStartTime()); | 
 |  |  |         insuranceApply.setEndTime(insuranceApply.getApplyEndTime()); | 
 |  |  |         insuranceApply.setCheckDate(new Date()); | 
 |  |  |         insuranceApply.setCurrentFee(BigDecimal.ZERO); | 
 |  |  |         insuranceApply.setCheckUserId(loginUserInfo.getId()); | 
 |  |  |         insuranceApply.setStatus(insuranceApplyStatus.getKey()); | 
 |  |  |  | 
 |  |  |         CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO(); | 
 |  |  |         countCyclePriceDTO.setSolutionsId(insuranceApply.getSolutionId()); | 
 |  |  |         countCyclePriceDTO.setStartDate(insuranceApply.getStartTime()); | 
 |  |  |         CountCyclePriceVO  countCyclePriceVO = this.getCountCyclePriceVO(countCyclePriceDTO); | 
 |  |  |         insuranceApply.setApplyEndTime(countCyclePriceVO.getEndDate()); | 
 |  |  |         insuranceApply.setEndTime(countCyclePriceVO.getEndDate()); | 
 |  |  |  | 
 |  |  |         applyDetailMapper.delete(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId())); | 
 |  |  |         //处理下级数据 | 
 |  |  |         this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo); | 
 |  |  |         this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo,countCyclePriceVO); | 
 |  |  |         insuranceApply.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
 |  |  |         insuranceApplyMapper.updateById(insuranceApply); | 
 |  |  |         //存储日志数据 | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public void dealApplyDetailData(InsuranceApply insuranceApply,List<ApplyDetail> applyDetailList,LoginUserInfo loginUserInfo){ | 
 |  |  |     public void dealApplyDetailData(InsuranceApply insuranceApply,List<ApplyDetail> applyDetailList,LoginUserInfo loginUserInfo,CountCyclePriceVO  countCyclePriceVO){ | 
 |  |  |         Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); | 
 |  |  |         if(Objects.isNull(solutions)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息"); | 
 |  |  |         } | 
 |  |  |         //查询保险方案下的所有派遣单位 | 
 |  |  |         List<DuSolution> duSolutionList = duSolutionMapper.selectList(new QueryWrapper<DuSolution>().lambda() | 
 |  |  |         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())); | 
 |  |  | 
 |  |  |                 applyDetail.setMemberId(member.getId()); | 
 |  |  |                 applyDetail.setIdcardNo(member.getIdcardNo()); | 
 |  |  |                 applyDetail.setSex(member.getSex()); | 
 |  |  |                 applyDetail.setFee(Constants.countDetailFee(solutions,insuranceApply.getApplyEndTime(),insuranceApply.getApplyStartTime())); | 
 |  |  |                 applyDetail.setFee(countCyclePriceVO.getCyclePrice()); | 
 |  |  |                 //验证派遣单位信息是否存在 | 
 |  |  |                 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()+"】员工派遣单位未查询到!"); | 
 |  |  | 
 |  |  |         //企业人员查看本企业数据 | 
 |  |  |         if(loginUserInfo.getType().equals(Constants.ONE)){ | 
 |  |  |             queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); | 
 |  |  |         }else{ | 
 |  |  |             if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ | 
 |  |  |                 queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); | 
 |  |  |             }else{ | 
 |  |  |                 queryWrapper.eq(InsuranceApply::getCompanyId, -1); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         if (pageWrap.getModel().getSolutionId() != null) { | 
 |  |  |             queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId()); | 
 |  |  | 
 |  |  |         //企业人员查看本企业数据 | 
 |  |  |         if(loginUserInfo.getType().equals(Constants.ONE)){ | 
 |  |  |             queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); | 
 |  |  |         }else{ | 
 |  |  |             if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ | 
 |  |  |                 queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); | 
 |  |  |             }else{ | 
 |  |  |                 queryWrapper.eq(InsuranceApply::getCompanyId, -1); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         if (model.getSolutionId() != null) { | 
 |  |  |             queryWrapper.eq(InsuranceApply::getSolutionId, model.getSolutionId()); | 
 |  |  | 
 |  |  |         MPJLambdaWrapper wrapper=  new MPJLambdaWrapper<InsuranceApply>() | 
 |  |  |                 .selectAll(InsuranceApply.class) | 
 |  |  |                 .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) | 
 |  |  |                 .selectAs(Company::getName,ApplyLog::getCompanyName) | 
 |  |  |                 .selectAs(Company::getName,InsuranceApply::getCompanyName) | 
 |  |  |                 .select(" ( select count(1) from apply_detail ad  where ad.apply_id = t.id ) as insureNum") | 
 |  |  |                 .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
 |  |  |                 .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
 |  |  | 
 |  |  |         if(Objects.isNull(insuranceApply)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if(insuranceApply.getStartTime().compareTo(new Date())<0  && insuranceApply.getEndTime().compareTo(new Date()) > 0 ){ | 
 |  |  |             insuranceApply.setLoseEfficacyDays(DateUtil.daysBetweenDates(insuranceApply.getEndTime(),new Date())); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         initApplyStatus(insuranceApply); | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public CountCyclePriceVO getCountCyclePriceVO(CountCyclePriceDTO countCyclePriceDTO){ | 
 |  |  |         if(Objects.isNull(countCyclePriceDTO) | 
 |  |  | 
 |  |  |         if(Objects.isNull(solutions)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); | 
 |  |  |         } | 
 |  |  |         CountCyclePriceVO countCyclePriceVO = new CountCyclePriceVO(); | 
 |  |  |         if(solutions.getInsureCycleUnit().equals(Constants.ZERO)){ | 
 |  |  |             countCyclePriceVO.setEndDate(DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),0,solutions.getInsureCycle())); | 
 |  |  |         }else if(solutions.getInsureCycleUnit().equals(Constants.TWO)){ | 
 |  |  |             Integer monthDays = DateUtil.monthDays(countCyclePriceDTO.getStartDate()); | 
 |  |  |             Date afterDate = DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),0,monthDays); | 
 |  |  |             countCyclePriceVO.setEndDate(DateUtil.afterDateByType(afterDate,0,-1)); | 
 |  |  |         }else if(solutions.getInsureCycleUnit().equals(Constants.THREE)){ | 
 |  |  |             Date afterDate = DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),2,solutions.getInsureCycle()); | 
 |  |  |             countCyclePriceVO.setEndDate(DateUtil.afterDateByType(afterDate,0,-1)); | 
 |  |  |         } | 
 |  |  |         countCyclePriceVO.setCyclePrice(Constants.countDetailFee(solutions,countCyclePriceVO.getEndDate(),countCyclePriceDTO.getStartDate())); | 
 |  |  |         return countCyclePriceVO; | 
 |  |  |         return Constants.countPriceVO(countCyclePriceDTO.getStartDate(),solutions); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  | } |