云易保客户服务系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiangping
2024-02-02 f8b1073fbb28d37e08016eed32c682f8c5eae391 
 server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java


@@ -15,9 +15,7 @@


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;


@@ -26,6 +24,8 @@


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;


@@ -38,6 +38,7 @@


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;


@@ -55,7 +56,9 @@


    @Autowired


    private InsuranceApplyMapper insuranceApplyMapper;


    @Autowired


    private ApplyChangeMapper applyChangeMapper;


    private SmsEmailService smsEmailService;


    @Autowired


    private ApplyChangeJoinMapper applyChangeMapper;




    @Autowired


    private SystemDictDataBiz systemDictDataBiz;


@@ -63,6 +66,8 @@


    private InsuranceApplyJoinMapper insuranceApplyJoinMapper;


    @Autowired


    private CompanyMapper companyMapper;


    @Autowired


    private MemberInsuranceJoinMapper memberInsuranceJoinMapper;




    @Autowired


    private ApplyDetailMapper applyDetailMapper;


@@ -87,7 +92,12 @@


    @Autowired


    private DuSolutionMapper duSolutionMapper;


    @Autowired


    private DuSolutionJoinMapper duSolutionJoinMapper;


    @Autowired


    private DuWorktypeMapper duWorktypeMapper;




    @Autowired


    private NoticesMapper noticesMapper;




    @Override


    @Transactional(rollbackFor = {Exception.class,BusinessException.class})


@@ -103,6 +113,12 @@


        if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){


            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");


        }




        Solutions solutions = solutionsMapper.selectById(model.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");


        }




        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();


        InsuranceApply update = new InsuranceApply();


        update.setEditDate(new Date());


@@ -113,6 +129,15 @@


        update.setCheckUserId(user.getId());


        update.setId(model.getId());


        insuranceApplyMapper.updateById(update);




        //存储待办信息


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        //删除其他待办


        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));


        Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),


                model.getCompanyId(), Constants.NoticeType.FOUR);


        noticesMapper.insert(notices);






        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PLATFORM_RETURN;


        String info =applyLogType.getInfo();


@@ -179,6 +204,36 @@


        }


        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;




    }


@@ -307,7 +362,10 @@


        if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){


            throw  new BusinessException(ResponseStatus.DATA_EMPTY);


        }




        Solutions solutions = solutionsMapper.selectById(model.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");


        }


        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();


        Constants.ApplyLogType applyLogType = null;


        String info = "";


@@ -347,6 +405,7 @@


        update.setEditDate(new Date());


        update.setSignApplyNo(applyNo);


        insuranceApplyMapper.updateById(update);




        return  link;


    }


    public String uploadSignFile(String link){


@@ -364,14 +423,13 @@


                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());


@@ -382,6 +440,13 @@


        update.setId(model.getId());


        insuranceApplyMapper.updateById(update);




        //存储待办信息


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        //删除其他待办


        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId()));


        Notices notices = new Notices(noticeObjectType,Constants.ZERO,model.getId(),model.getSolutionsName(),model.getCompanyId(),Constants.NoticeType.TWO);


        noticesMapper.insert(notices);




        Multifile f = new Multifile();


        f.setIsdeleted(Constants.ZERO);


        f.setCreator(model.getCreator());


@@ -390,15 +455,19 @@


        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());


@@ -409,6 +478,17 @@


        update.setId(model.getId());


        applyChangeMapper.updateById(update);




        //存储待办信息


        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()));


        Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),model.getSolutionsName(),


                model.getCompanyId(), Constants.NoticeType.TWO);


        noticesMapper.insert(notices);




        Multifile f = new Multifile();


        f.setIsdeleted(Constants.ZERO);


        f.setCreator(model.getCreator());


@@ -417,43 +497,93 @@


        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;


            }


        }


@@ -465,7 +595,18 @@


        }


        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());


@@ -474,11 +615,19 @@


                    //如果下载失败，清除合同，下次签章重新生成新合同


                    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);


@@ -486,7 +635,7 @@


                    //如果下载失败，清除合同，下次签章重新生成新合同


                    return;


                }


                uploadChangeSignedFileDo(applyChange,fileUrl);


                uploadChangeSignedFileDo(applyChange,fileUrl,path+fileUrl);


            }


        }else if(Constants.equalsInteger(data.getSignStatus(), Constants.TWO )){


            //如果已拒签，清除合同，下次签章重新生成新合同


@@ -542,6 +691,11 @@


//        info = info.replace("${param}", update.getCheckInfo());


        ApplyLog log = new ApplyLog(update,applyLogType.getName(),StringUtils.isNotBlank(update.getCheckInfo())?info:"",update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));


        applyLogMapper.insert(log);




        //删除其他待办


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));




        return  1;




    }


@@ -566,6 +720,11 @@


            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");


        }




        Solutions solutions = solutionsMapper.selectById(model.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");


        }




        Constants.ApplyLogType applyLogType = null;


        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();


        InsuranceApply update = new InsuranceApply();


@@ -575,15 +734,26 @@


        update.setCheckInfo(insuranceApply.getCheckInfo());


        update.setCheckUserId(user.getId());


        update.setId(model.getId());


        Constants.NoticeType noticeType = Constants.NoticeType.ONE;


        if(insuranceApply.getDealBackApply() ==1){


            //如果是不通过


            applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ;


            update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());




            noticeType = Constants.NoticeType.FOUR;


        }else{


            applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS;


            update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey());


        }


        insuranceApplyMapper.updateById(update);




        //存储待办信息


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        //删除其他待办


        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(),model.getCompanyId(),noticeType);


        noticesMapper.insert(notices);




        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));


@@ -608,6 +778,10 @@


        if(!loginUserInfo.getType().equals(Constants.ONE)){


            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作");


        }


        Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");


        }


        List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();


        //判断是否存在重复信息


        List<String> idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList());


@@ -622,20 +796,37 @@


        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,solutions,applyDetailList,loginUserInfo,countCyclePriceVO);


        InsuranceApply updBean = new InsuranceApply();


        updBean.setId(insuranceApply.getId());


        updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));


        insuranceApplyMapper.updateById(updBean);


        //存储日志数据


        this.saveApplyLog(insuranceApply,insuranceApplyStatus,null);


        //发送待办业务




        //存储待办信息


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        //删除其他待办


        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));


        Notices notices = new Notices(noticeObjectType,Constants.ZERO,insuranceApply.getId(),solutions.getName(),insuranceApply.getCompanyId(),Constants.NoticeType.ZERO);


        noticesMapper.insert(notices);




        return insuranceApply.getId();


    }




@@ -681,30 +872,53 @@


        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()));




        Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");


        }




        //处理下级数据


        this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo);


        this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO);


        insuranceApply.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));


        insuranceApplyMapper.updateById(insuranceApply);


        //存储日志数据


        this.saveApplyLog(insuranceApply,insuranceApplyStatus,null);






        //存储待办信息


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        //删除其他待办


        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));


        Notices notices = new Notices(noticeObjectType,Constants.ZERO,insuranceApply.getId(),solutions.getName(),insuranceApply.getCompanyId(),Constants.NoticeType.ZERO);


        noticesMapper.insert(notices);




        return insuranceApply.getId();


    }








    public void dealApplyDetailData(InsuranceApply insuranceApply,List<ApplyDetail> applyDetailList,LoginUserInfo loginUserInfo){


        Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");


        }


    public void dealApplyDetailData(InsuranceApply insuranceApply,Solutions solutions,List<ApplyDetail> applyDetailList,LoginUserInfo loginUserInfo,CountCyclePriceVO  countCyclePriceVO){


        //查询保险方案下的所有派遣单位


        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()));


@@ -780,7 +994,7 @@


                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()+"】员工派遣单位未查询到！");


@@ -911,6 +1125,13 @@


        //企业人员查看本企业数据


        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);


            }


            queryWrapper.eq(pageWrap.getModel().getCompanyId()!=null,InsuranceApply::getCompanyId, pageWrap.getModel().getCompanyId());


        }


        if (pageWrap.getModel().getSolutionId() != null) {


            queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId());


@@ -991,6 +1212,12 @@


        //企业人员查看本企业数据


        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());


@@ -1044,7 +1271,7 @@


        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)


@@ -1055,6 +1282,11 @@


        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);




@@ -1185,8 +1417,14 @@


        if(insuranceApply.getIsdeleted().equals(Constants.ONE)){


            throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作");


        }


        Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());


        if(Objects.isNull(solutions)){


            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");


        }




        //-----TODU-------RJ-------完善退回状态分开标记------------------


        Constants.InsuranceApplyStatus insuranceApplyStatus =  Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE;


        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;


        if(insuranceApplyOptDTO.getOptType().equals(Constants.ONE)){


            if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey())


                    ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())


@@ -1200,6 +1438,15 @@


            }else  if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey())){


                insuranceApplyStatus =  Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE;


            }




            //存储待办信息


            //删除其他待办


            noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));


            Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),


                    insuranceApply.getCompanyId(), Constants.NoticeType.THREE);


            noticesMapper.insert(notices);






        }else if(insuranceApplyOptDTO.getOptType().equals(Constants.TWO)){


            insuranceApplyStatus =  Constants.InsuranceApplyStatus.CLOSE;


            if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.CLOSE.getKey())){


@@ -1210,6 +1457,8 @@


                    ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){


                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态非可申请退回!");


            }


            //删除其他待办


            noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));


        }


        insuranceApply.setStatus(insuranceApplyStatus.getKey());


        insuranceApply.setCheckDate(new Date());


@@ -1273,6 +1522,8 @@












    @Override


    public CountCyclePriceVO getCountCyclePriceVO(CountCyclePriceDTO countCyclePriceDTO){


        if(Objects.isNull(countCyclePriceDTO)


@@ -1285,21 +1536,11 @@


        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);


    }












}