|  |  | 
 |  |  |             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if( | 
 |  |  | //                Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey()) | 
 |  |  | //                ||Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.SIGNATURE.getKey()) | 
 |  |  | //                || | 
 |  |  |                 Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.APPROVE.getKey())){ | 
 |  |  |             //已提交和已完成状态不支持审核不通过 | 
 |  |  |             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
 |  |  |         if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){ | 
 |  |  |             if(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.APPROVE.getKey())){ | 
 |  |  |                 //已提交和已完成状态不支持审核不通过 | 
 |  |  |                 throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
 |  |  |             } | 
 |  |  |         }else if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){ | 
 |  |  |             if(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey()) | 
 |  |  |             || Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.SIGNATURE.getKey()) ){ | 
 |  |  |                 //已提交和已完成状态不支持审核不通过 | 
 |  |  |                 throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
 |  |  |         ApplyChange update = new ApplyChange(); | 
 |  |  | 
 |  |  |         noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId())); | 
 |  |  |         Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),solutions.getName(), | 
 |  |  |                 insuranceApply.getCompanyId(), Constants.NoticeType.FOUR); | 
 |  |  | //        notices.setParam1(insuranceApply.getId().toString()); | 
 |  |  |         noticesMapper.insert(notices); | 
 |  |  |  | 
 |  |  |         Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PLATFORM_CHECK_PASS_NO; | 
 |  |  |         String info =applyLogType.getInfo(); | 
 |  |  |         info = info.replace("${param}", update.getCheckInfo()); | 
 |  |  |         ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(), JSONObject.toJSONString(model), JSONObject.toJSONString(update)); | 
 |  |  |         ApplyLog log = new ApplyLog(update,applyLogType.getName(), | 
 |  |  |                 info,update.getId(),applyLogType.getKey(), JSONObject.toJSONString(model), JSONObject.toJSONString(update)); | 
 |  |  |         applyLogMapper.insert(log); | 
 |  |  |         return  1; | 
 |  |  |  | 
 |  |  | 
 |  |  | //        if(1==1){ | 
 |  |  | //            throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  | //        } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; | 
 |  |  |         if(model.getType().equals(Constants.ONE)){ | 
 |  |  |             noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; | 
 |  |  |         } | 
 |  |  |         //删除其他待办 | 
 |  |  |         noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId())); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PLATFORM_APPROVE; | 
 |  |  |         String info = ""; | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 处理加减保明细数据 | 
 |  |  |      * 处理换厂明细数据 | 
 |  |  |      * @param update | 
 |  |  |      */ | 
 |  |  |     private void dealDetailsDUdata(ApplyChange update,InsuranceApply insuranceApply) { | 
 |  |  | 
 |  |  |         //实际批单生效日期 | 
 |  |  |         Date applyStartTime = DateUtil.getMontageDate(update.getApplyStartTime(),1); | 
 |  |  |         for(ApplyChagneDetail detail : detailList){ | 
 |  |  |             //查询减保人员是否存在 冲突的 保单明细数据 | 
 |  |  |             if(applyDetailJoinMapper.selectCount(new QueryWrapper<ApplyDetail>() | 
 |  |  |                     .lambda() | 
 |  |  |                     .eq(ApplyDetail::getApplyId,update.getApplyId()) | 
 |  |  | 
 |  |  |         if (Objects.isNull(insuranceApply)) { | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  |         } | 
 |  |  |         if (!Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())) { | 
 |  |  |         if (!(Constants.equalsInteger(insuranceApply.getStatus(), Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) | 
 |  |  |                 ||Constants.equalsInteger(insuranceApply.getStatus(), Constants.InsuranceApplyStatus.WTB_DONE.getKey()) | 
 |  |  |             ) | 
 |  |  |         ) { | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "保单状态错误"); | 
 |  |  |         } | 
 |  |  |         if (DateUtil.compareDate(insuranceApply.getEndTime(),new Date()) >= Constants.ZERO | 
 |  |  | 
 |  |  |         if (Objects.isNull(insuranceApply)) { | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  |         } | 
 |  |  |         if (!Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())) { | 
 |  |  |         if (!(Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) | 
 |  |  |         ||Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey()) | 
 |  |  |         )) { | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "保单状态错误"); | 
 |  |  |         } | 
 |  |  |         if (DateUtil.compareDate(insuranceApply.getEndTime(),new Date()) >= Constants.ZERO | 
 |  |  | 
 |  |  |         ApplyLog log = new ApplyLog(applyChange,applyLogType.getName(),info,applyChange.getId(),applyLogType.getKey(), null, null); | 
 |  |  |         applyLogMapper.insert(log); | 
 |  |  |  | 
 |  |  |         Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; | 
 |  |  |         if(applyChange.getType().equals(Constants.ONE)){ | 
 |  |  |             noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; | 
 |  |  |         } | 
 |  |  |         noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,applyChange.getId())); | 
 |  |  |  | 
 |  |  |         return applyChange.getId(); | 
 |  |  |     } | 
 |  |  | 
 |  |  |                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该企业分配保险方案无法进行减保"); | 
 |  |  |             } | 
 |  |  |             //减保明细数据 计算金额  根据批单时间 前一天 计算 | 
 |  |  |             applyChangeCyclePriceDTO.setValidTime(DateUtil.getMontageDate(applyChange.getValidTime(),2)); | 
 |  |  |             applyChangeCyclePriceDTO.setValidTime(DateUtil.getMontageDate(applyChange.getValidTime(),3)); | 
 |  |  |  | 
 |  |  |             CountCyclePriceVO countCyclePriceVO =  this.getChangeCountCyclePriceVO(applyChangeCyclePriceDTO); | 
 |  |  |             BigDecimal detailFee = countCyclePriceVO.getCyclePrice(); | 
 |  |  |             this.delChangeDetail(applyChange,delDetailList,insuranceApply,solutions,loginUserInfo,detailFee,applyChangeCyclePriceDTO.getValidTime()); | 
 |  |  | 
 |  |  |         //换厂业务 | 
 |  |  |         List<ApplyChagneDetail> changeDetailList = applyChange.getChangeDetailList(); | 
 |  |  |         if (CollectionUtils.isNotEmpty(changeDetailList)) { | 
 |  |  |             //验证是否存在重复数据 | 
 |  |  |             List<String> idcarNo = changeDetailList.stream().map(m->m.getIdcardNo()).collect(Collectors.toList()); | 
 |  |  |             Set<String> set = new HashSet<>(idcarNo); | 
 |  |  |             if(idcarNo.size() != set.size()){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起,人员录入数据存在相同数据!"); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             this.changeDetail(applyChange,changeDetailList,duWorktypeList,duSolutionList,loginUserInfo); | 
 |  |  |         } | 
 |  |  |         return fee; | 
 |  |  | 
 |  |  |             if (applyChange.getValidTime().compareTo(applyDetail.getEndTime()) > 0) { | 
 |  |  |                 throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至:【" + applyDetail.getEndTime() + "】无法通过本次申请"); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |             applyChagneDetail.setPrice(applyDetail.getPrice()); | 
 |  |  |             applyChagneDetail.setCreateDate(new Date()); | 
 |  |  |             applyChagneDetail.setCreator(loginUserInfo.getId()); | 
 |  |  |             applyChagneDetail.setIsdeleted(Constants.ZERO); | 
 |  |  | 
 |  |  |             member.setEndTime(applyChagneDetail.getEndTime()); | 
 |  |  |             memberMapper.updateById(member); | 
 |  |  |  | 
 |  |  |             applyChagneDetail.setFee( detailFee.multiply(new BigDecimal(-1))); | 
 |  |  |             //查询减保日期 | 
 |  |  |             Integer delDays = DateUtil.daysBetweenDates(applyDetail.getEndTime(),endTime); | 
 |  |  |  | 
 |  |  |             applyChagneDetail.setFee( new BigDecimal(delDays).multiply(applyDetail.getPrice()).multiply(new BigDecimal(-1))); | 
 |  |  |             applyChagneDetailJoinMapper.insert(applyChagneDetail); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  | 
 |  |  |                 throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下,加保人员【" + applyChagneDetail.getMemberName() + "】存在日期冲突的数据"); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             ApplyDetail applyDetail = applyDetailJoinMapper.selectOne(new QueryWrapper<ApplyDetail>() | 
 |  |  |                             .lambda() | 
 |  |  |                             .eq(ApplyDetail::getApplyId,applyChange.getApplyId()).last("limit 1")); | 
 |  |  |             if(Objects.isNull(applyDetail)){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "保单中未存在明细记录"); | 
 |  |  |             } | 
 |  |  |             applyChagneDetail.setPrice(applyDetail.getPrice()); | 
 |  |  |             applyChagneDetail.setCreateDate(new Date()); | 
 |  |  |             applyChagneDetail.setCreator(loginUserInfo.getId()); | 
 |  |  |             applyChagneDetail.setIsdeleted(Constants.ZERO); | 
 |  |  | 
 |  |  |             && applyChagneDetail.getOldWorktypeId().equals(applyChagneDetail.getWorktypeId())){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】换厂数据相同!"); | 
 |  |  |             } | 
 |  |  |             applyChagneDetail.setPrice(applyDetail.getPrice()); | 
 |  |  |             applyChagneDetail.setCreateDate(new Date()); | 
 |  |  |             applyChagneDetail.setCreator(loginUserInfo.getId()); | 
 |  |  |             applyChagneDetail.setIsdeleted(Constants.ZERO); | 
 |  |  | 
 |  |  |                         Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), | 
 |  |  |                         Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) | 
 |  |  |                 .eq(!Objects.isNull(model.getUnionApplyId()),InsuranceApply::getUnionApplyId,model.getUnionApplyId()) | 
 |  |  | //                .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getCompanyId()),InsuranceApply::getCompanyId,model.getCompanyId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) | 
 |  |  |                 .eq(!Objects.isNull(model.getApplyId()),ApplyChange::getApplyId,model.getApplyId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getBaseSolutionsId()),Solutions::getBaseId,model.getBaseSolutionsId()) | 
 |  |  | 
 |  |  |  | 
 |  |  |         queryWrapper.orderByDesc(ApplyDetail::getCreateDate); | 
 |  |  |  | 
 |  |  | //        for(PageWrap.SortData sortData: pageWrap.getSorts()) { | 
 |  |  | //            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { | 
 |  |  | //                queryWrapper.orderByDesc(sortData.getProperty()); | 
 |  |  | //            } else { | 
 |  |  | //                queryWrapper.orderByAsc(sortData.getProperty()); | 
 |  |  | //            } | 
 |  |  | //        } | 
 |  |  |         PageData<ApplyChange> pageData = PageData.from(applyChangeJoinMapper.selectJoinPage(page,ApplyChange.class, queryWrapper)); | 
 |  |  |         return pageData; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public List<ApplyChange> findListForCompany(ApplyChange model) { | 
 |  |  |         MPJLambdaWrapper<ApplyChange> queryWrapper = new MPJLambdaWrapper<>(); | 
 |  |  |         queryWrapper | 
 |  |  |                 .selectAll(ApplyChange.class) | 
 |  |  |                 .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) | 
 |  |  |                 .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) | 
 |  |  |                 .selectAs(InsuranceApply::getCode,ApplyChange::getValidCode) | 
 |  |  |                 .selectAs(InsuranceApply::getEndTime,ApplyChange::getEndTime) | 
 |  |  |                 .selectAs(Solutions::getName,ApplyChange::getSolutionsName) | 
 |  |  |                 .selectAs(Solutions::getType,ApplyChange::getSolutionType) | 
 |  |  |                 .selectAs(Company::getName,ApplyChange::getCompanyName) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0  )",ApplyChange::getAddNum) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1  )",ApplyChange::getDelNum) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2  )",ApplyChange::getChangeNum) | 
 |  |  |                 .select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID  )",ApplyChange::getChangeMoney) | 
 |  |  |                 .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) | 
 |  |  |                 .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
 |  |  |                 .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
 |  |  |                 .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) | 
 |  |  |                 .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.getUnionApplyId()),InsuranceApply::getUnionApplyId,model.getUnionApplyId()) | 
 |  |  | //                .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) | 
 |  |  |                 .eq(!Objects.isNull(model.getApplyId()),ApplyChange::getApplyId,model.getApplyId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getUnionChangeId()),ApplyChange::getUnionChangeId,model.getUnionChangeId()) | 
 |  |  |                 .eq(!Objects.isNull(model.getBaseSolutionsId()),Solutions::getBaseId,model.getBaseSolutionsId()) | 
 |  |  |                 .like(StringUtils.isNotBlank(model.getSolutionsName()),Solutions::getName,model.getSolutionsName()) | 
 |  |  |                 .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) | 
 |  |  |                 .le(StringUtils.isNotBlank(model.getCreateDateE()),ApplyChange::getCreateDate, model.getCreateDateE()+" 23:59:59" ) | 
 |  |  |                 .ge(StringUtils.isNotBlank(model.getApplyStartS()),ApplyChange::getApplyStartTime, model.getApplyStartS()+" 00:00:00" ) | 
 |  |  |                 .le(StringUtils.isNotBlank(model.getApplyStartE()),ApplyChange::getApplyStartTime, model.getApplyStartE()+" 23:59:59" ); | 
 |  |  |         LoginUserInfo loginUserInfo =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
 |  |  |         //企业人员查看本企业数据 | 
 |  |  |         if(loginUserInfo.getType().equals(Constants.ONE)){ | 
 |  |  |             queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); | 
 |  |  |         }else if(loginUserInfo.getType().equals(Constants.TWO)){ | 
 |  |  |             //如果是商户查看 | 
 |  |  |             if(model.getSolutionType()!=null && model.getSolutionType() ==0){ | 
 |  |  |                 queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()); | 
 |  |  |             }else if(model.getSolutionType()!=null && model.getSolutionType() ==1){ | 
 |  |  |                 queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId()); | 
 |  |  |             }else{ | 
 |  |  |                 queryWrapper.apply("((t2.type=0 and exists(select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + | 
 |  |  |                         "t2.type=1 and t2.shop_id="+loginUserInfo.getCompanyId()+"))") ; | 
 |  |  |             } | 
 |  |  |         }else{ | 
 |  |  |             if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ | 
 |  |  |                 queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); | 
 |  |  |             }else{ | 
 |  |  |                 queryWrapper.eq(InsuranceApply::getCompanyId, -1); | 
 |  |  |             } | 
 |  |  |             queryWrapper.eq(model.getCompanyId()!=null,InsuranceApply::getCompanyId, model.getCompanyId()); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         queryWrapper.orderByDesc(ApplyDetail::getCreateDate); | 
 |  |  |         List<ApplyChange> list =applyChangeJoinMapper.selectJoinList(ApplyChange.class,queryWrapper); | 
 |  |  |         if(Constants.equalsObject(model.getGetFiles(),Constants.ONE)){ | 
 |  |  |             //如果是合并单,需要查询附件信息 | 
 |  |  |             initFileForList(list); | 
 |  |  |         } | 
 |  |  |         return list; | 
 |  |  |     } | 
 |  |  |     private void initFileForList(List<ApplyChange> list) { | 
 |  |  |         List<Integer> objList =  new ArrayList<>(); | 
 |  |  |         if(list!=null && list.size()>0){ | 
 |  |  |             for(ApplyChange param : list){ | 
 |  |  |                 objList.add(param.getId()); | 
 |  |  |             } | 
 |  |  |         }else{ | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda() | 
 |  |  |                 .in(Multifile::getObjId,objList) | 
 |  |  |                 .in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.CA_PD_PDF.getKey()})) | 
 |  |  |                 .eq(Multifile::getIsdeleted,Constants.ZERO) | 
 |  |  |                 .orderByAsc(Multifile::getId)); | 
 |  |  |         if(multifiles!=null && multifiles.size()>0){ | 
 |  |  |             String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode() | 
 |  |  |                     +systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); | 
 |  |  |             for(ApplyChange model : list){ | 
 |  |  |                 for(Multifile f : multifiles) { | 
 |  |  |                     if (StringUtils.isBlank(f.getFileurl())) { | 
 |  |  |                         continue; | 
 |  |  |                     } | 
 |  |  |                     f.setFileurlFull(path+f.getFileurl()); | 
 |  |  |                     if(Constants.equalsInteger(f.getObjId(), model.getId()) ){ | 
 |  |  |                         if (Constants.equalsInteger(f.getObjType(), Constants.MultiFile.CA_PD_PDF.getKey())) { | 
 |  |  |                             //签署前的投保单 | 
 |  |  |                             model.setPidanFile(f); | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |             Notices notices = new Notices(noticeObjectType,Constants.ZERO,applyChange.getId(),solutions.getName(), | 
 |  |  |                     insuranceApply.getCompanyId(), Constants.NoticeType.THREE); | 
 |  |  |             noticesMapper.insert(notices); | 
 |  |  |  | 
 |  |  |             //商户待办 | 
 |  |  |             if(Objects.nonNull(solutions.getShopId())){ | 
 |  |  |                 Notices shopNotices = new Notices(noticeObjectType,Constants.TWO, | 
 |  |  |                         applyChange.getId(),solutions.getName(),solutions.getShopId(),Constants.NoticeType.THREE); | 
 |  |  |                 noticesMapper.insert(shopNotices); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |         }else if(applyChangeOptDTO.getOptType().equals(4)){ | 
 |  |  |             applyLogType = Constants.ApplyLogType.CA_PLATFORM_AGREE_BACK_APPLY; | 
 |  |  | 
 |  |  |         }else if(applyChangeOptDTO.getOptType().equals(6)){ | 
 |  |  |             //企业关闭 | 
 |  |  |             applyLogType = Constants.ApplyLogType.CA_COMPANY_CLOSE; | 
 |  |  |             if(!loginUserInfo.getType().equals(Constants.ONE)){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作"); | 
 |  |  |             } | 
 |  |  |             if(!applyChange.getStatus().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey())){ | 
 |  |  |             if(!(applyChange.getStatus().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()) | 
 |  |  |                     ||applyChange.getStatus().equals(Constants.ApplyChangeStatus.CHECHED_PASSED.getKey()))){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); | 
 |  |  |             } | 
 |  |  |             applyChange.setStatus(Constants.ApplyChangeStatus.CLOSE.getKey()); | 
 |  |  |  | 
 |  |  |             //存储待办信息 | 
 |  |  |             //删除其他待办 | 
 |  |  |             noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,applyChange.getId())); | 
 |  |  | 
 |  |  |         MPJLambdaWrapper<ApplyChange> queryWrapper = new MPJLambdaWrapper<>(); | 
 |  |  |         queryWrapper.selectAll(ApplyChange.class) | 
 |  |  |                 .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) | 
 |  |  |                 .selectAs(Company::getId,ApplyChange::getCompanyId) | 
 |  |  |                 .selectAs(Company::getName,ApplyChange::getCompanyName) | 
 |  |  |                 .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) | 
 |  |  |                 .selectAs(InsuranceApply::getEndTime,ApplyChange::getEndTime) | 
 |  |  |                 .selectAs(Solutions::getName,ApplyChange::getSolutionsName) | 
 |  |  |                 .selectAs(Solutions::getType,ApplyChange::getSolutionType) | 
 |  |  |                 .selectAs(Solutions::getId,ApplyChange::getSolutionsId) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0  )",ApplyChange::getAddNum) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1  )",ApplyChange::getDelNum) | 
 |  |  |                 .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2  )",ApplyChange::getChangeNum) | 
 |  |  |                 .select(" ( select max(ac.APPLY_START_TIME) from apply_change ac  where ac.apply_id = t.apply_id and ac.status = 2 ) as lastChangeDate") | 
 |  |  |                 .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) | 
 |  |  |                 .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) | 
 |  |  |                 .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) | 
 |  |  | 
 |  |  |         applyChange.setApplyLogList(applyLogList); | 
 |  |  |  | 
 |  |  |         List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda() | 
 |  |  |                 .eq(Multifile::getObjId,Constants.equalsInteger(applyChange.getSolutionType(),Constants.ZERO)? applyChange.getId():applyChange.getUnionChangeId()) | 
 |  |  |                 .in(Multifile::getObjType, Arrays.asList(new Integer[]{Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() | 
 |  |  |                         ,Constants.MultiFile.CA_PD_PDF.getKey() | 
 |  |  |                         ,Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey()})) | 
 |  |  |                 .eq(Multifile::getObjId, applyChange.getId() ) | 
 |  |  | //                .in(Multifile::getObjType, Arrays.asList(new Integer[]{Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() | 
 |  |  | //                        ,Constants.MultiFile.CA_PD_PDF.getKey() | 
 |  |  | //                        ,Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey()})) | 
 |  |  |                 .eq(Multifile::getIsdeleted,Constants.ZERO)); | 
 |  |  |         if(multifiles!=null){ | 
 |  |  |             String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode() | 
 |  |  | 
 |  |  |         } | 
 |  |  |         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
 |  |  |         Company company = user.getCompany(); | 
 |  |  |         if(debugModel){ | 
 |  |  |         /*if(debugModel){ | 
 |  |  |             company = companyMapper.selectById(model.getCompanyId()); | 
 |  |  |         } | 
 |  |  |         }*/ | 
 |  |  |         if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,企业尚未具备在线签章条件,请联系平台管理员确认~"); | 
 |  |  |         } | 
 |  |  | 
 |  |  |         if(Objects.isNull(solutions)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); | 
 |  |  |         } | 
 |  |  |         ApplyDetail applyDetail = applyDetailJoinMapper.selectOne(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getIsdeleted,Constants.ZERO).eq(ApplyDetail::getApplyId,insuranceApply.getId()).last("limit 1")); | 
 |  |  |         if(Objects.isNull(applyDetail)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单明细记录"); | 
 |  |  |         } | 
 |  |  |         //根据批单日期 和 结束日期 计算金额 | 
 |  |  |         //验证批单日期是否在当前日期后 且 在保单结束日期前 申请时间必须处于保单的时间范围内 | 
 |  |  |         if (!(DateUtil.compareDate( insuranceApply.getStartTime(),applyChangeCyclePriceDTO.getValidTime()) >= Constants.ZERO | 
 |  |  | 
 |  |  |         BigDecimal sumPrice = countCyclePriceVO.getCyclePrice(); | 
 |  |  |         CountCyclePriceVO returnCountCyclePriceVO = new CountCyclePriceVO(); | 
 |  |  |         //加减保金额 | 
 |  |  |         returnCountCyclePriceVO.setCyclePrice(sumPrice.multiply(new BigDecimal(optDays)).divide(new BigDecimal(sumDays),2, RoundingMode.HALF_UP)); | 
 |  |  | //        returnCountCyclePriceVO.setCyclePrice(sumPrice.multiply(new BigDecimal(optDays)).divide(new BigDecimal(sumDays),2, RoundingMode.HALF_UP)); | 
 |  |  |         returnCountCyclePriceVO.setCyclePrice(applyDetail.getPrice().multiply(new BigDecimal(optDays)).setScale(2, RoundingMode.HALF_UP)); | 
 |  |  |         return returnCountCyclePriceVO; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |         } | 
 |  |  |         ApplyChange model = this.queryApplyChangeData(smsCheckDTO.getBusinessId()); | 
 |  |  |         if(Objects.isNull(model)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询加减保信息"); | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询加减保/换厂信息"); | 
 |  |  |         } | 
 |  |  |         if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  |         } | 
 |  |  |         if(!Constants.equalsInteger(Constants.ZERO,model.getStatus())){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,该申请状态已流转,当前不支持签章操作!"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
 |  |  |         Company company = user.getCompany(); | 
 |  |  |         if(debugModel){ | 
 |  |  |             company = companyMapper.selectById(model.getCompanyId()); | 
 |  |  |         } | 
 |  |  |         Company company = companyMapper.selectById(model.getCompanyId()); | 
 |  |  |         if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,企业尚未具备在线签章条件,请联系平台管理员确认~"); | 
 |  |  |         } | 
 |  |  | 
 |  |  |         if(Objects.isNull(solutions)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); | 
 |  |  |         } | 
 |  |  |         if(solutions.getType().equals(Constants.ZERO)){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,非委托保方案保单,无法进行该操作!"); | 
 |  |  |         } | 
 |  |  |         String fileUrl = null; | 
 |  |  |         if(Constants.equalsObject(model.getType(), Constants.ONE)){ | 
 |  |  |             fileUrl = ExcelExporter.build(ApplyChange.class).exportChangeUnitExcelToPdf(model,"换厂申请表","被保险人"); | 
 |  |  |         if(solutions.getType().equals(Constants.ONE)){ | 
 |  |  |             if(!Constants.equalsInteger(Constants.ZERO,model.getStatus())){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,该申请状态已流转,当前不支持签章操作!"); | 
 |  |  |             } | 
 |  |  |             if(Constants.equalsObject(model.getType(), Constants.ONE)){ | 
 |  |  |                 fileUrl = ExcelExporter.build(ApplyChange.class).exportChangeUnitExcelToPdf(model,"换厂申请表","被保险人"); | 
 |  |  |             }else{ | 
 |  |  |                 fileUrl = ExcelExporter.build(ApplyChange.class).exportJiajianBaoExcelToPdf(model,"加减保申请表","被保险人"); | 
 |  |  |             } | 
 |  |  |             String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode(); | 
 |  |  |             notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString()); | 
 |  |  |             String applyNo = signService.applySignLocalFile(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"人员名单签章",company.getSignId(),notifyUrl); | 
 |  |  |             if(StringUtils.isBlank(applyNo) ){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
 |  |  |             } | 
 |  |  |             String link = signService.signLink(applyNo,company.getName(),company.getCode()); | 
 |  |  |             if(StringUtils.isBlank(link) ){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
 |  |  |             } | 
 |  |  |             ApplyChange update= new ApplyChange(); | 
 |  |  |             update.setId(model.getId()); | 
 |  |  |             update.setEditor(user.getId()); | 
 |  |  |             update.setEditDate(new Date()); | 
 |  |  |             update.setSignMemberListNo(applyNo); | 
 |  |  |             applyChangeMapper.updateById(update); | 
 |  |  |             return link; | 
 |  |  |         }else{ | 
 |  |  |             fileUrl = ExcelExporter.build(ApplyChange.class).exportJiajianBaoExcelToPdf(model,"加减保申请表","被保险人"); | 
 |  |  |             if(model.getType().equals(Constants.ONE)){ | 
 |  |  |                 return this.getSignLinkChangeUnit(model); | 
 |  |  |             }else{ | 
 |  |  |                 return this.getSignLinkJiajiabao(model); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |         String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode(); | 
 |  |  |         notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString()); | 
 |  |  |         String applyNo = signService.applySignLocalFile(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"人员名单签章",company.getSignId(),notifyUrl); | 
 |  |  |         if(StringUtils.isBlank(applyNo) ){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
 |  |  |         } | 
 |  |  |         String link = signService.signLink(applyNo,company.getName(),company.getCode()); | 
 |  |  |         if(StringUtils.isBlank(link) ){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起,获取在线签章地址失败,请稍后重试!"); | 
 |  |  |         } | 
 |  |  |         ApplyChange update= new ApplyChange(); | 
 |  |  |         update.setId(model.getId()); | 
 |  |  |         update.setEditor(user.getId()); | 
 |  |  |         update.setEditDate(new Date()); | 
 |  |  |         update.setSignMemberListNo(applyNo); | 
 |  |  |         applyChangeMapper.updateById(update); | 
 |  |  |         return  link; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |         } | 
 |  |  |         if(applyChange.getId() == null){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.BAD_REQUEST); | 
 |  |  |         }  | 
 |  |  |         if(Objects.isNull(applyChange)){ | 
 |  |  |             throw  new BusinessException(ResponseStatus.DATA_EMPTY); | 
 |  |  |         } | 
 |  |  |         ApplyChange model = applyChangeJoinMapper.selectJoinOne(ApplyChange.class, | 
 |  |  |                 new MPJLambdaWrapper<ApplyChange>() | 
 |  |  | 
 |  |  |         if(solutions.getType().equals(Constants.ZERO)){ | 
 |  |  |            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"直保单据无法进行该操作"); | 
 |  |  |         }else{ | 
 |  |  |             if(!Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.COMPANY_SIGN.getKey())){ | 
 |  |  |             if(!Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.SIGNATURE.getKey())){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,该申请状态已流转,当前不支持该操作~"); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  | 
 |  |  |         update.setId(model.getId()); | 
 |  |  |         if(applyChange.getDealBackApply() ==1){ | 
 |  |  |             //如果是不通过 | 
 |  |  |             update.setStatus(Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS_NO.getKey()); | 
 |  |  |             update.setStatus(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()); | 
 |  |  |         }else{ | 
 |  |  |             update.setStatus(Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS.getKey()); | 
 |  |  |             update.setStatus(Constants.ApplyChangeStatus.CHECHED_PASSED.getKey()); | 
 |  |  |         } | 
 |  |  |         applyChangeJoinMapper.updateById(update); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_AUDIT; | 
 |  |  |         String info = applyChange.getCheckInfo(); | 
 |  |  |         if(StringUtils.isNotBlank(applyChange.getCheckInfo())){ | 
 |  |  |             info = info.replace("${param}", applyChange.getCheckInfo()); | 
 |  |  |         }else{ | 
 |  |  |             info = info.replace("${param}", ""); | 
 |  |  |         } | 
 |  |  |         ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(), null, null); | 
 |  |  |         applyLogMapper.insert(log); | 
 |  |  |  | 
 |  |  |         Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; | 
 |  |  |         if(Constants.equalsInteger(model.getType(),Constants.ONE)){ | 
 |  |  |             noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; | 
 |  |  |         } | 
 |  |  |         //删除全部待办 | 
 |  |  |         noticesMapper.delete(new QueryWrapper<Notices>().lambda() | 
 |  |  |                 .eq(Notices::getObjType, noticeObjectType.getKey()) | 
 |  |  |                 .eq(Notices::getObjId, model.getId())); | 
 |  |  |         return  1; | 
 |  |  |  | 
 |  |  |     } |