Merge remote-tracking branch 'origin/2.0.1' into 2.0.1

k94314517

2024-11-29 d1c205d29b5eacf1de22a7af29329ca370d1c2d3

 server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java

@@ -15,13 +15,12 @@
import com.doumee.core.utils.Utils;
import com.doumee.core.utils.aliyun.ALiYunUtil;
import com.doumee.dao.business.*;
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.dto.SmsCheckDTO;
import com.doumee.dao.business.dto.*;
import com.doumee.dao.business.join.*;
import com.doumee.dao.business.model.*;
import com.doumee.dao.business.vo.ApplyPowerVO;
import com.doumee.dao.business.vo.CountCyclePriceVO;
import com.doumee.dao.system.SystemUserMapper;
import com.doumee.dao.system.model.SystemUser;
import com.doumee.service.business.InsuranceApplyService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -104,6 +103,8 @@
    private DuWorktypeMapper duWorktypeMapper;
    @Autowired
    private DuWorkTypeJoinMapper duWorkTypeJoinMapper;
    @Autowired
    private SolutionWorktypeJoinMapper solutionWorktypeJoinMapper;

    @Autowired
    private NoticesMapper noticesMapper;
@@ -113,6 +114,13 @@
    private UnionChangeJoinMapper unionChangeJoinMapper;
    @Autowired
    private CompanySolutionMapper companySolutionMapper;
    @Autowired
    private ContractJoinMapper contractJoinMapper;
    @Autowired
    private SystemUserMapper systemUserMapper;
    @Autowired
    private CompanyDepartmentMapper companyDepartmentMapper;


    @Override
    @Transactional(rollbackFor = {Exception.class,BusinessException.class})
@@ -314,7 +322,7 @@
            for (ApplyDetail applyDetail:applyDetailList) {

                //查询人员信息是否存在相同的方案下是否存在 冲突数据
                this.checkMemberSolution(solutions.getBaseId(),applyDetail.getIdcardNo(),applyDetail.getMemberName(),update.getStartTime()
                this.checkMemberSolution(solutions.getParentId(),applyDetail.getIdcardNo(),applyDetail.getMemberName(),update.getStartTime()
                        ,update.getEndTime(),insuranceApply.getId());

                MemberInsurance memberInsurance = new MemberInsurance(applyDetail,user.getId());
@@ -354,8 +362,11 @@
        if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY);
        }
        if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~");
        if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) ||
                Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey()) ){
            if(model.getStartTime().getTime()<System.currentTimeMillis()){
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~");
            }
        }

        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
@@ -564,9 +575,29 @@

    public Multifile   uploadSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
        InsuranceApply update = new InsuranceApply();
        Boolean retrial = false;
        Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
        if(Constants.equalsInteger(solutions.getRetrial(),Constants.ONE)){
           ApplyLog applyLog =  applyLogMapper.selectOne(new QueryWrapper<ApplyLog>().lambda()
                    .eq(ApplyLog::getObjId,model.getId())
                   .eq(ApplyLog::getObjType,Constants.ApplyLogType.PLATFORM_CHECK_PASS.getKey())
                   .orderByDesc(ApplyLog::getCreateDate)
                   .last(" limit 1 ")
            );
           if(Objects.nonNull(applyLog)){
               SystemUser systemUser = systemUserMapper.selectById(applyLog.getCreator());
               if(Objects.nonNull(systemUser) && Objects.nonNull(systemUser.getDepartmentId())){
                   CompanyDepartment companyDepartment = companyDepartmentMapper.selectById(systemUser.getDepartmentId());
                   if(Objects.nonNull(companyDepartment)&&Objects.nonNull(companyDepartment.getHeadId())){
                       retrial = true;
                       update.setRetrialId(companyDepartment.getHeadId());
                   }
               }
           }
        }
        update.setEditDate(new Date());
        update.setEditor(model.getCreator());
        update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
        update.setStatus(retrial?Constants.InsuranceApplyStatus.REEXAMINE.getKey():Constants.InsuranceApplyStatus.SIGNATURE.getKey());
        update.setCheckDate(update.getEditDate());
        update.setCheckInfo("企业完成签署");
        update.setCheckUserId(model.getCreator());
@@ -575,10 +606,13 @@

        //存储待办信息
        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;

        //删除其他待办
        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
        noticesMapper.delete(new QueryWrapper<Notices>().lambda()
                .eq(Notices::getObjType,noticeObjectType.getKey())
                .ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
                .eq(Notices::getObjId,model.getId()));

        //平台待办
        Notices notices = new Notices(noticeObjectType,Constants.ZERO,model.getId(),model.getSolutionsName(),model.getCompanyId(),Constants.NoticeType.TWO);
        noticesMapper.insert(notices);
@@ -859,9 +893,9 @@
        UnionApply update = new UnionApply();
        update.setEditDate(new Date());
        update.setEditor(model.getCreator());
        update.setStatus(Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey());
        update.setStatus(Objects.nonNull(model.getRetrialId())?Constants.UnionApplyStatus.RETRIAL.getKey() : Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey());
        update.setCheckDate(update.getEditDate());
        update.setCheckInfo("商户完成签署");
        update.setCheckInfo(Objects.nonNull(model.getRetrialId())?"待复审":"完成签署");
        update.setCheckUserId(model.getCreator());
        update.setId(model.getId());
        unionApplyJoinMapper.updateById(update);
@@ -879,10 +913,35 @@
        f.setName("商户签署投保单.pdf");
        multifileMapper.insert(f);


        List<InsuranceApply> insuranceApplyList = insuranceApplyJoinMapper.selectList(new QueryWrapper<InsuranceApply>().
                lambda().eq(InsuranceApply::getUnionApplyId,model.getId()));
        if(CollectionUtils.isNotEmpty(insuranceApplyList)){
            for (InsuranceApply insuranceApply:insuranceApplyList) {

                f.setId(null);
                f.setIsdeleted(Constants.ZERO);
                f.setCreateDate(new Date());
                f.setObjType(Constants.MultiFile.BD_SIGNED_PDF.getKey());
                f.setType(Constants.TWO);
                f.setObjId(insuranceApply.getId());
                f.setInfo("投保单");
                f.setName("投保单.pdf");
                multifileMapper.insert(f);

                insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
                        .set(InsuranceApply::getUnionApplyTbdStatus,Constants.TWO)
                        .set(InsuranceApply::getEditDate,new Date())
                        .eq(InsuranceApply::getId,insuranceApply.getId())
                );
            }
        }

        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.IA_HBD_SIGNATURE_TBD;
        ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
                ,model.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(model));
        applyLogMapper.insert(log);


        return  f;
    }
@@ -923,6 +982,128 @@

        return  f;
    }


    public Multifile   uploadContractFirstSignedFileDo(Contract model,String fileurl,String fullUrl) {
        Contract update = new Contract();
        update.setEditDate(new Date());
        update.setEditor(model.getCreator());
        update.setFileSignUrl(fileurl);
        update.setStatus(Constants.equalsInteger(model.getType(),Constants.ZERO)?Constants.ONE:Constants.THREE);
        update.setId(model.getId());
        contractJoinMapper.updateById(update);

        Multifile f = new Multifile();
        f.setIsdeleted(Constants.ZERO);
        f.setCreator(model.getCreator());
        f.setObjId(update.getId());
        f.setCreateDate(update.getEditDate());
        f.setObjType(Constants.MultiFile.CONTRACT_FIRST_PDF.getKey());
        f.setType(Constants.TWO);
        f.setFileurl(fileurl);
        f.setFileurlFull(fullUrl);
        f.setInfo("合同签署文件");
        f.setName("合同签署文件.pdf");
        multifileMapper.insert(f);

        //存储待办信息
        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.CONTRACT;
        //删除其他待办
        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
                .ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
                .eq(Notices::getObjId,model.getId()));
        //双方签署 才会发新通知
        if(Constants.equalsInteger(model.getType(),Constants.ZERO)){
            Notices notices = new Notices(noticeObjectType,
                    Constants.equalsInteger(model.getSignType(),Constants.ZERO)?Constants.TWO:Constants.ONE
                    ,model.getId(),this.getNoticeInfo(model,companyMapper.selectById(model.getCompanyId())),model.getCompanyId(),Constants.NoticeType.ZERO);
            noticesMapper.insert(notices);
        }
        return  f;
    }

    public String getNoticeInfo(Contract contract,Company company){
        String noticeInfo = contract.getName();
        //商户信息
        if(Constants.equalsInteger(contract.getSignType(),Constants.TWO)){
            Company shop = companyMapper.selectById(contract.getPartyCompanyId());
            noticeInfo  = noticeInfo + "("+shop.getName()+"/"+company.getName()+")";
        }else{
            noticeInfo  = noticeInfo + "(平台/"+company.getName()+")";
        }
        return noticeInfo;
    }



    public Multifile  uploadContractDoneSignedFileDo(Contract model,String fileurl,String fullUrl) {
        Contract update = new Contract();
        update.setEditDate(new Date());
        update.setEditor(model.getCreator());
        update.setDoneFileUrl(fileurl);
        update.setStatus(Constants.THREE);
        update.setId(model.getId());
        contractJoinMapper.updateById(update);

        Multifile f = new Multifile();
        f.setIsdeleted(Constants.ZERO);
        f.setCreator(model.getCreator());
        f.setObjId(update.getId());
        f.setCreateDate(update.getEditDate());
        f.setObjType(Constants.MultiFile.CONTRACT_DONE_PDF.getKey());
        f.setType(Constants.TWO);
        f.setFileurl(fileurl);
        f.setFileurlFull(fullUrl);
        f.setInfo("合同签署文件");
        f.setName("合同签署文件.pdf");
        multifileMapper.insert(f);

        //存储待办信息
        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.CONTRACT;
        //删除其他待办
        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
                .ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
                .eq(Notices::getObjId,model.getId()));

        return  f;
    }


    public Multifile  uploadCompanySolutionSignedFileDo(CompanySolution model,String fileurl,String fullUrl) {
        CompanySolution update = new CompanySolution();
        update.setEditDate(new Date());
        update.setEditor(model.getCreator());
        update.setFileSignUrl(fileurl);
        update.setSignStatus(Constants.ONE);
        update.setSignUserId(model.getEditor());
        update.setSignDate(new Date());
        update.setId(model.getId());
        companySolutionMapper.updateById(update);

        Multifile f = new Multifile();
        f.setIsdeleted(Constants.ZERO);
        f.setCreator(model.getCreator());
        f.setObjId(update.getId());
        f.setCreateDate(update.getEditDate());
        f.setObjType(Constants.MultiFile.COMPANY_SOLUTION_SIGN_PDF.getKey());
        f.setType(Constants.TWO);
        f.setFileurl(fileurl);
        f.setFileurlFull(fullUrl);
        f.setInfo("方案确认书");
        f.setName("方案确认书.pdf");
        multifileMapper.insert(f);

        //存储待办信息
        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.SOLUTIONS;
        //删除其他待办
        noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
                .ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
                .eq(Notices::getObjId,model.getId()));

        return  f;
    }



    private void startSendEmail(Multifile f, String companyName, String solutionsName, String solutionEmail) {
        if(StringUtils.isBlank(solutionEmail) || f==null|| StringUtils.isBlank(f.getFileurl())){
@@ -1180,8 +1361,79 @@
        }


        /**
         * 我方签署 合同信息
         */
        List<Contract> contractFirstList = contractJoinMapper.selectJoinList(Contract.class,
                new MPJLambdaWrapper<Contract>()
                        .selectAll(Contract.class)
                        .eq(Contract::getStatus,Constants.ZERO)
                        .isNotNull(Contract::getApplyNo));
        if(contractFirstList !=null && contractFirstList.size()>0 ){
            for(Contract contract : contractFirstList){
                String status = signService.linkFileStatus(contract.getApplyNo());
                if(!StringUtils.equals(status,"3")){
                    continue;
                }
                String link = signService.linkFile(contract.getApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    continue;
                }
                uploadContractFirstSignedFileDo(contract,fileUrl,path+fileUrl);
            }
        }


        /**
         * 企业/商户签署 合同信息
         */
        List<Contract> contractDoneList = contractJoinMapper.selectJoinList(Contract.class,
                new MPJLambdaWrapper<Contract>()
                        .selectAll(Contract.class)
                        .eq(Contract::getStatus,Constants.ONE)
                        .isNotNull(Contract::getDoneApplyNo));
        if(contractDoneList !=null && contractDoneList.size()>0 ){
            for(Contract contract : contractDoneList){
                String status = signService.linkFileStatus(contract.getDoneApplyNo());
                if(!StringUtils.equals(status,"3")){
                    continue;
                }
                String link = signService.linkFile(contract.getDoneApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    continue;
                }
                uploadContractDoneSignedFileDo(contract,fileUrl,path+fileUrl);
            }
        }

        /**
         * 企业 方案确认书签署
         */
        List<CompanySolution> companySolutionList = companySolutionMapper.selectList(
                new QueryWrapper<CompanySolution>().lambda()
                        .eq(CompanySolution::getSignStatus,Constants.ZERO)
                        .isNotNull(CompanySolution::getApplyNo));
        if(companySolutionList !=null && companySolutionList.size()>0 ){
            for(CompanySolution companySolution : companySolutionList){
                String status = signService.linkFileStatus(companySolution.getApplyNo());
                if(!StringUtils.equals(status,"3")){
                    continue;
                }
                String link = signService.linkFile(companySolution.getApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    continue;
                }
                uploadCompanySolutionSignedFileDo(companySolution,fileUrl,path+fileUrl);
            }
        }
    }

    @Override
    public   String dealSignResult(NotifyDataReq data){
        if(data.getApplyNo() == null ){
@@ -1224,6 +1476,19 @@
            if(StringUtils.isNotBlank(r)){
                return  r;
            }
            r = dealContractFirstBiz(path,data,"合同我方签署");
            if(StringUtils.isNotBlank(r)){
                return  r;
            }
            r = dealContractDoneBiz(path,data,"合同企业/商户签署");
            if(StringUtils.isNotBlank(r)){
                return  r;
            }
            r = dealCompanySolutionBiz(path,data,"企业签署方案确认书");
            if(StringUtils.isNotBlank(r)){
                return  r;
            }

        }
        return "无处理数据";
    }
@@ -1253,6 +1518,100 @@
                unionChangeJoinMapper.update(null,new UpdateWrapper<UnionChange>().lambda()
                        .set(UnionChange::getSignApplyNo,null)
                        .eq(UnionChange::getSignApplyNo,data.getApplyNo()));
                return title+"合同拒签处理成功";
            }
        }
        return  title+"状态已流转，不做处理";
    }

    private String dealContractFirstBiz(String path, NotifyDataReq data, String title) {
        Contract contract = contractJoinMapper.selectOne(new QueryWrapper<Contract>()
                .lambda().
                eq(Contract::getApplyNo,data.getApplyNo())
                .last(" limit 1")
        );

        if(contract == null){
            return null;
        }
        if( Constants.equalsInteger(contract.getStatus(),Constants.ONE)){
            if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
                //完成签署已完成操作
                String link = signService.linkFile(contract.getApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    return title+"合同下载失败，等待下次推送处理";
                }

                uploadContractFirstSignedFileDo(contract,fileUrl,path+fileUrl);
                return title+"状态处理成功";
            }else{
                //如果已拒签，清除合同，下次签章重新生成新合同
                contractJoinMapper.update(null,new UpdateWrapper<Contract>().lambda()
                        .set(Contract::getApplyNo,null)
                        .eq(Contract::getApplyNo,data.getApplyNo()));
                return title+"合同拒签处理成功";
            }
        }
        return  title+"状态已流转，不做处理";
    }

    private String dealContractDoneBiz(String path, NotifyDataReq data, String title) {
        Contract contract = contractJoinMapper.selectOne(new QueryWrapper<Contract>()
                .lambda().
                eq(Contract::getDoneApplyNo,data.getApplyNo())
                .last(" limit 1")
        );
        if(contract == null){
            return null;
        }
        if( Constants.equalsInteger(contract.getStatus(),Constants.THREE)){
            if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
                //完成签署已完成操作
                String link = signService.linkFile(contract.getDoneApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    return title+"合同下载失败，等待下次推送处理";
                }
                uploadContractDoneSignedFileDo(contract,fileUrl,path+fileUrl);
                return title+"状态处理成功";
            }else{
                //如果已拒签，清除合同，下次签章重新生成新合同
                contractJoinMapper.update(null,new UpdateWrapper<Contract>().lambda()
                        .set(Contract::getDoneApplyNo,null)
                        .eq(Contract::getDoneApplyNo,data.getApplyNo()));
                return title+"合同拒签处理成功";
            }
        }
        return  title+"状态已流转，不做处理";
    }
    private String dealCompanySolutionBiz(String path, NotifyDataReq data, String title) {
        CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>()
                .lambda().
                eq(CompanySolution::getApplyNo,data.getApplyNo())
                .last(" limit 1")
        );
        if(companySolution == null){
            return null;
        }
        if( Constants.equalsInteger(companySolution.getSignStatus(),Constants.ZERO)){
            if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
                //完成签署已完成操作
                String link = signService.linkFile(companySolution.getApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    return title+"合同下载失败，等待下次推送处理";
                }
                uploadCompanySolutionSignedFileDo(companySolution,fileUrl,path+fileUrl);
                return title+"状态处理成功";
            }else{
                //如果已拒签，清除合同，下次签章重新生成新合同
                companySolutionMapper.update(null,new UpdateWrapper<CompanySolution>().lambda()
                        .set(CompanySolution::getApplyNo,null)
                        .eq(CompanySolution::getApplyNo,data.getApplyNo()));
                return title+"合同拒签处理成功";
            }
        }
@@ -1607,7 +1966,7 @@
     */
    @Override
    @Transactional(rollbackFor = {Exception.class,BusinessException.class})
    public Integer check(InsuranceApply insuranceApply) {
    public Integer check(InsuranceApply insuranceApply,UnionApplyServiceImpl unionApplyServiceImpl) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(insuranceApply.getId() == null){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
@@ -1626,9 +1985,6 @@
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
            }
        }else{
            if(!Constants.equalsObject(user.getType(),Constants.TWO)){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户端无法进行该操作");
            }
            //委托保待签署、待审核可进行退回操作
            if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
                    ||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
@@ -1687,8 +2043,122 @@
        }
        ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
        applyLogMapper.insert(log);
        return  1;
        //2024年11月8日16:12:43 如果是委托投保单则自动创建合并单数据
        if(Constants.equalsInteger(insuranceApply.getDealBackApply(),Constants.ZERO) && Constants.equalsObject(solutions.getType(),Constants.ONE)){
            SaveUnionApplyDTO saveUnionApplyDTO = new SaveUnionApplyDTO();
            List<Integer> applyIds = new ArrayList<Integer>();
            applyIds.add(update.getId());
            saveUnionApplyDTO.setApplyIds(applyIds);
            saveUnionApplyDTO.setBaseSolutionId(solutions.getBaseId());
            saveUnionApplyDTO.setStartDate(model.getStartTime());
            saveUnionApplyDTO.setEndDate(model.getEndTime());
            unionApplyServiceImpl.merge(saveUnionApplyDTO);
        }

        return  1;
    }

    /**
     * 复审 审核通过或者不通过
     * @param insuranceApply
     * @return
     */
    @Override
    @Transactional(rollbackFor = {Exception.class,BusinessException.class})
    public Integer reexamineCheck(InsuranceApply insuranceApply) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(insuranceApply.getId() == null){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());

        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(),"未查询方案信息");
        }
        if(Constants.equalsObject(solutions.getType(),Constants.ZERO)){
            if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.REEXAMINE.getKey())){
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
            }
        }else{
            if(Constants.equalsObject(user.getType(),Constants.ONE)){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"企业用户无法进行该操作");
            }
            //如果是商户端，则只能由指定人进行处理
            if(Constants.equalsInteger(user.getType(),Constants.TWO)){
                if(!Constants.equalsInteger(model.getRetrialId(),user.getId())){
                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的复审数据，无法进行审批");
                }
            }else{
                //如果是平台端，根据人员类型处理 如果是固定人员则不限制 其他人员需要比对
                if(!user.getFixed()){
                    if(!Constants.equalsInteger(model.getRetrialId(),user.getId())){
                        throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的复审数据，无法进行审批");
                    }
                }
            }
            //委托保待签署、待审核可进行退回操作
            if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
                    ||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
                    ||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())
            )){
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
            }
        }

        Constants.ApplyLogType applyLogType = null;
        InsuranceApply update = new InsuranceApply();
        update.setEditDate(new Date());
        update.setEditor(user.getId());
        update.setCheckDate(update.getEditDate());
        update.setCheckInfo(insuranceApply.getCheckInfo());
        update.setCheckUserId(user.getId());
        update.setId(model.getId());
        if(insuranceApply.getDealBackApply() ==1){
            //如果是不通过
            applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ;
            update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());
            if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
                update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.getKey());
            }
        }else{
            applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS;
            if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
                update.setStatus(Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey());
            }else{
                update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
            }
        }
        insuranceApplyMapper.updateById(update);

        //存储待办信息
        Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
        if(Constants.equalsObject(solutions.getType(),Constants.ZERO)) {
            //删除其他待办
            noticesMapper.delete(new QueryWrapper<Notices>().lambda()
                    .eq(Notices::getObjType, noticeObjectType.getKey())
                    .ne(Notices::getType, Constants.NoticeType.SIX.getStatus())
                    .eq(Notices::getObjId, model.getId()));
        }else{
            //删除全部待办
            noticesMapper.delete(new QueryWrapper<Notices>().lambda()
                    .eq(Notices::getObjType, noticeObjectType.getKey())
                    .eq(Notices::getObjId, model.getId()));
        }


        String info =applyLogType.getInfo();
        if(StringUtils.isNotBlank(update.getCheckInfo())){
            info = info.replace("${param}", update.getCheckInfo());
        }else{
            info = null;
        }
        ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
        applyLogMapper.insert(log);
        return  1;
    }


@@ -1699,14 +2169,18 @@
            || Objects.isNull(insuranceApply.getSolutionId())
            || Objects.isNull(insuranceApply.getApplyStartTime())
            || Objects.isNull(insuranceApply.getApplyEndTime())
            || Objects.isNull(insuranceApply.getCompanyId())
            || !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList())
        ) {
            throw new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!loginUserInfo.getType().equals(Constants.ONE)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作");

        Company company = companyMapper.selectById(insuranceApply.getCompanyId());
        if(Objects.isNull(company) || Constants.equalsInteger(company.getType(),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(),"未查询到方案信息");
@@ -1725,7 +2199,6 @@
                throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"保单生效起期错误");
            }
        }

        List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();
        //判断是否存在重复信息
        List<String> idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList());
@@ -1735,14 +2208,13 @@
        }
        Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD;
        if(solutions.getType().equals(Constants.ONE)){
            insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_UPLOAD;
            insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE;
        }
        insuranceApply.setCreateDate(new Date());
        insuranceApply.setCreator(loginUserInfo.getId());
        insuranceApply.setEditor(loginUserInfo.getId());
        insuranceApply.setEditDate(new Date());
        insuranceApply.setIsdeleted(Constants.ZERO);
        insuranceApply.setCompanyId(loginUserInfo.getCompanyId());
        insuranceApply.setCheckInfo(insuranceApplyStatus.getName());
        insuranceApply.setStartTime(insuranceApply.getApplyStartTime());
        insuranceApply.setCheckDate(new Date());
@@ -1765,14 +2237,9 @@
        updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));
        insuranceApplyMapper.updateById(updBean);

//        if(1==1){
//            throw new BusinessException(ResponseStatus.NOT_ALLOWED);
//        }

        //存储日志数据
        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD;
        String info =applyLogType.getInfo();
//        info = info.replace("${param}", update.getCheckInfo());
        ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),null, null);
        applyLogMapper.insert(log);
        
@@ -1893,35 +2360,48 @@

    public void dealApplyDetailData(InsuranceApply insuranceApply,Solutions solutions,List<ApplyDetail> applyDetailList,
                                    LoginUserInfo loginUserInfo,CountCyclePriceVO  countCyclePriceVO,Boolean checkNewData){
        //查询保险方案下的所有派遣单位
        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(checkNewData,DispatchUnit::getDataType,Constants.TWO)
                .eq(DuSolution::getStatus,Constants.ONE)
                .eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())
                .apply(" t1.BASE_ID in ( select du.id from dispatch_unit du where du.STATUS = 0 and du.ISDELETED = 0 ) ")
        );
        if(!CollectionUtils.isNotEmpty(duSolutionList)){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到派遣单位信息，请确保派遣单位和工作配置并审核通过！");
        //2024年11月6日15:01:34  加入  方案配置了有派遣单位 才会去验证派遣单位数据
        List<DuSolution>  duSolutionList = new ArrayList<>();
        List<DuWorktype> duWorktypeList = new ArrayList<>();
        List<Integer> worktypeIdList = new ArrayList<>();
        if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){
            //查询保险方案下的所有派遣单位
            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(checkNewData,DispatchUnit::getDataType,Constants.TWO)
                    .eq(DuSolution::getStatus,Constants.ONE)
                    .eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())
                    .apply(" t1.BASE_ID in ( select du.id from dispatch_unit du where du.STATUS = 0 and du.ISDELETED = 0 ) ")
            );
            if(!CollectionUtils.isNotEmpty(duSolutionList)){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到派遣单位信息，请确保派遣单位和工作配置并审核通过！");
            }
            //查询所有派遣单位下的工种
            List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList());
            duWorktypeList = duWorkTypeJoinMapper.selectJoinList(DuWorktype.class,new MPJLambdaWrapper<DuWorktype>()
                    .selectAll(DuWorktype.class)
                    .innerJoin(Worktype.class,Worktype::getId,DuWorktype::getWorkTypeId)
                    .eq(DuWorktype::getIsdeleted,Constants.ZERO)
                    .eq(DuWorktype::getStatus,Constants.ONE)
                    .eq(checkNewData,Worktype::getDataType,Constants.TWO)
                    .in(DuWorktype::getDuSolutionId,duSolutionIdList));
            if(!CollectionUtils.isNotEmpty(duWorktypeList)){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息，请确保派遣单位和工作配置并审核通过！");
            }
            worktypeIdList = duWorktypeList.stream().map(i->i.getWorkTypeId()).collect(Collectors.toList());
        }else{
            //查询方案下所有工种数据
            List<SolutionWorktype> solutionWorktypeList = solutionWorktypeJoinMapper.selectList(new QueryWrapper<SolutionWorktype>().lambda().eq(SolutionWorktype::getSolutionId,solutions.getId()));
            if(CollectionUtils.isEmpty(solutionWorktypeList)){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息");
            }
            worktypeIdList = solutionWorktypeList.stream().map(i->i.getWorktypeId()).collect(Collectors.toList());
        }
        //查询所有派遣单位下的工种
        List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList());
        List<DuWorktype> duWorktypeList = duWorkTypeJoinMapper.selectJoinList(DuWorktype.class,new MPJLambdaWrapper<DuWorktype>()
                .selectAll(DuWorktype.class)
                .innerJoin(Worktype.class,Worktype::getId,DuWorktype::getWorkTypeId)
                .eq(DuWorktype::getIsdeleted,Constants.ZERO)
                .eq(DuWorktype::getStatus,Constants.ONE)
                .eq(checkNewData,Worktype::getDataType,Constants.TWO)
                .in(DuWorktype::getDuSolutionId,duSolutionIdList));
        if(!CollectionUtils.isNotEmpty(duWorktypeList)){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息，请确保派遣单位和工作配置并审核通过！");
        }

        if(CollectionUtils.isNotEmpty(applyDetailList)){
            List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
                    .eq(Member::getCompanyId,insuranceApply.getCompanyId())
@@ -1950,14 +2430,12 @@
                    }
                    member.setIdcardNo(applyDetail.getIdcardNo());
                    member.setApplyId(insuranceApply.getId());
                    member.setStartTime(applyDetail.getStartTime());
                    member.setEndTime(applyDetail.getEndTime());
                    member.setDuId(applyDetail.getDuId());
                    member.setWorktypeId(applyDetail.getWorktypeId());
                    addMemberList.add(member);
                }
                //查询人员信息是否存在相同的方案下是否存在 冲突数据
                this.checkMemberSolution(solutions.getBaseId(),member.getIdcardNo(),member.getName(),insuranceApply.getStartTime(),insuranceApply.getEndTime(),insuranceApply.getId());
                this.checkMemberSolution(solutions.getParentId(),member.getIdcardNo(),member.getName(),insuranceApply.getStartTime(),insuranceApply.getEndTime(),insuranceApply.getId());
            }
            if(CollectionUtils.isNotEmpty(addMemberList)){
                memberJoinMapper.insertBatchSomeColumn(addMemberList);
@@ -1968,7 +2446,7 @@
                if(Objects.isNull(applyDetail)
                        ||StringUtils.isBlank(applyDetail.getIdcardNo())
                        ||StringUtils.isBlank(applyDetail.getMemberName())
                        ||Objects.isNull(applyDetail.getDuId())
                        || (Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)&&Objects.isNull(applyDetail.getDuId()))
                        ||Objects.isNull(applyDetail.getWorktypeId())
                ){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，投保员工信息数据缺失，请按照要求填写员工的有效信息！");
@@ -1981,6 +2459,15 @@
                applyDetail.setEndTime(insuranceApply.getApplyEndTime());
                applyDetail.setSortnum(i);
                applyDetail.setApplyId(insuranceApply.getId());

                //根据员工身份证进行判断年龄
                long age = Constants.getAgeByIdCard(applyDetail.getIdcardNo());
                if(Objects.isNull(age)
                        || age > solutions.getMaxAge()
                        || age < solutions.getMinAge()){
                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyDetail.getMemberName()+"】员工年龄超出方案配置,方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】！");
                }

                Member member = null;
                if(Objects.isNull(applyDetail.getMemberId())){
                    if(CollectionUtils.isNotEmpty(memberList)){
@@ -1994,8 +2481,6 @@
                        member.setApplyId(insuranceApply.getId());
                        member.setDuId(applyDetail.getDuId());
                        member.setWorktypeId(applyDetail.getWorktypeId());
                        member.setStartTime(applyDetail.getStartTime());
                        member.setEndTime(applyDetail.getEndTime());
                        memberMapper.updateById(member);
                    }
                }else{
@@ -2006,17 +2491,7 @@
                    member.setApplyId(insuranceApply.getId());
                    member.setDuId(applyDetail.getDuId());
                    member.setWorktypeId(applyDetail.getWorktypeId());
                    member.setStartTime(applyDetail.getStartTime());
                    member.setEndTime(applyDetail.getEndTime());
                    memberMapper.updateById(member);
                }

                //根据员工身份证进行判断年龄
                long age = Constants.getAgeByIdCard(member.getIdcardNo());
                if(Objects.isNull(age)
                    || age > solutions.getMaxAge()
                    || age < solutions.getMinAge()){
                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyDetail.getMemberName()+"】员工年龄超出方案配置,方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】！");
                }
                applyDetail.setMemberId(member.getId());
                applyDetail.setIdcardNo(member.getIdcardNo());
@@ -2032,13 +2507,19 @@
                        applyDetail.getFee().divide(new BigDecimal(maxDays),7,RoundingMode.HALF_UP)
                );
                //验证派遣单位信息是否存在
                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()+applyDetail.getIdcardNo()+"】员工派遣单位未查询到！");
                if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){
                    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()+applyDetail.getIdcardNo()+"】员工派遣单位未查询到！");
                    }
                }
                if(duWorktypeList.stream().filter(d->d.getWorkTypeId().equals(applyDetail.getWorktypeId()))
                if(worktypeIdList.stream().filter(d->Constants.equalsInteger(d,applyDetail.getWorktypeId()))
                        .collect(Collectors.toList()).size()<=Constants.ZERO){
                    throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工工种信息未查询到！");
                }
//                if(duWorktypeList.stream().filter(d->d.getWorkTypeId().equals(applyDetail.getWorktypeId()))
//                        .collect(Collectors.toList()).size()<=Constants.ZERO){
//                    throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工工种信息未查询到！");
//                }
            }
            applyDetailJoinMapper.insertBatchSomeColumn(applyDetailList);
        }
@@ -2052,20 +2533,26 @@
     * @param endTime
     */
    @Override
    public void checkMemberSolution(Integer solutionId,String idCode,String memberName,Date startTime,Date endTime,Integer applyId){
    public void checkMemberSolution(Integer solutionParentId,String idCode,String memberName,Date startTime,Date endTime,Integer applyId){
        List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
        try {
            applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
                    new MPJLambdaWrapper<ApplyDetail>()
                            .selectAll(ApplyDetail.class)
                            .selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
                            .selectAs(Company::getName,ApplyDetail::getCompanyName)
                            .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
                            .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
                            .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
                            .eq(ApplyDetail::getIdcardNo,idCode)
                            .eq(Solutions::getBaseId,solutionId)
                            .eq(ApplyDetail::getIsdeleted,Constants.ZERO)
                            .eq(Solutions::getParentId,solutionParentId)
                            .ne(Objects.nonNull(applyId),InsuranceApply::getId,applyId)
                            .notIn(InsuranceApply::getStatus
                                    ,Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()
                                    ,Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey()
                                    ,Constants.InsuranceApplyStatus.CLOSE.getKey()
                                    ,Constants.InsuranceApplyStatus.WTB_RETURN.getKey()
                                    ,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
                            .apply(" ( " +
                                    " '"+DateUtil.getPlusTime(startTime)+"'  <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
@@ -2077,8 +2564,13 @@
        }catch (Exception e){
        }
        if(applyDetailList.size() >Constants.ZERO){
            ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO);
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
            String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
            if(StringUtils.isNotBlank(companyName)){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
            }else{
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
            }

        };
    }

@@ -2090,10 +2582,13 @@
                    new MPJLambdaWrapper<ApplyDetail>()
                            .selectAll(ApplyDetail.class)
                            .selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
                            .selectAs(Company::getName,ApplyDetail::getCompanyName)
                            .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
                            .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
                            .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
                            .eq(ApplyDetail::getIdcardNo,idCode)
                            .eq(Solutions::getBaseId,solutionId)
                            .eq(ApplyDetail::getIsdeleted,Constants.ZERO)
                            .notIn(InsuranceApply::getStatus
                                    ,Constants.InsuranceApplyStatus.CLOSE.getKey()
                                    ,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
@@ -2108,9 +2603,14 @@

        }
        if(applyDetailList.size() >Constants.ZERO){
            ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO);
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
            String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
            if(StringUtils.isNotBlank(companyName)){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
            }else{
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
            }
        };

    }

    @Override
@@ -2195,48 +2695,70 @@
        MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());

/*        //数据权限开始--------------------start----------------
        LoginUserInfo userInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(userInfo!=null && userInfo.getDepartIdList()!=null){
            if(  userInfo.getDepartIdList().size() ==0){
                //只看自己
                queryWrapper.and(wrapper ->{
                    wrapper.eq(InsuranceApply::getCreator,userInfo.getId());
                });
            }else{
                //权限范围内
                queryWrapper.and(wrapper ->{
                    wrapper.in(SystemUser::getDepartmentId ,userInfo.getDepartIdList());
                });
            }
        }*/


        List<Integer> statusList = this.getCollectStatus(pageWrap.getModel().getStatusCollect());

        queryWrapper.selectAll(InsuranceApply.class);
        queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
        queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
        queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
        queryWrapper.selectAs(Solutions::getHasDispatchUnit,InsuranceApply::getHasDispatchUnit);
        queryWrapper.selectAs(Solutions::getMaxAge,InsuranceApply::getMaxAge);
        queryWrapper.selectAs(Solutions::getMinAge,InsuranceApply::getMinAge);
        queryWrapper.selectAs(Solutions::getPrice,InsuranceApply::getPrice);
        queryWrapper.selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit);
        queryWrapper.select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad left join  apply_change a on a.id = ad.APPLY_CHANGE_ID  where t.id = a.APPLY_ID  and a.status = 2  )",InsuranceApply::getChangeMoney);
        queryWrapper.select(" DATEDIFF( t.END_TIME ,now()  ) AS loseEfficacyDays  ");
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.apply_id = t.id   ) as insureNum");
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum");
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum");
        if(!Objects.isNull(pageWrap.getModel())&&!Objects.isNull(pageWrap.getModel().getType())){
            queryWrapper.select(" ifnull(( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ),0) as taxesMoney");
            queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id  where ts.status = 1 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
        }
        queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
        queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
        queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,InsuranceApply::getCreator);
        queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
        queryWrapper.eq(pageWrap.getModel().getBaseSolutionId()!=null,Solutions::getBaseId,pageWrap.getModel().getBaseSolutionId());
        queryWrapper.in(statusList.size()>0,InsuranceApply::getStatus,statusList);
        queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getSolutionName()),Solutions::getName,pageWrap.getModel().getSolutionName());
        if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.YGQ.getKey()) ){
            //如果是已過期
//            queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
            queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
        }else if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.BZZ.getKey()) ){
            //如果是保障中
//            queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
            queryWrapper.gt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
        }
//        if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.YGQ.getKey()) ){
//            //如果是已过期
//            queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
//        }else if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.BZZ.getKey()) ){
//            //如果是保障中
//            queryWrapper.gt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
//        }
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();

        //企业人员查看本企业数据
        if(loginUserInfo.getType().equals(Constants.ONE)){
            queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
            //2024年10月29日15:14:28 加入  企业合并2类投保数据
            if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ZERO)){
                queryWrapper.eq(Solutions::getType,pageWrap.getModel().getSolutionType());
            }
        }else if(loginUserInfo.getType().equals(Constants.TWO)){
            //如果是商户查看
            if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType().equals(0)){
            if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ZERO)){
                queryWrapper.exists("select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId());
            }else if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==1){
            }else if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ONE)){
                queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId());
            }else{
                queryWrapper.apply("((t1.type=0 and exists(select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" +
@@ -2286,6 +2808,18 @@
        if (pageWrap.getModel().getStatus() != null) {
            queryWrapper.in(InsuranceApply::getStatus, pageWrap.getModel().getStatus().split(","));
        }

        if (pageWrap.getModel().getTimeOut() != null) {
            if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.ZERO)){
                queryWrapper.apply("  t.START_TIME  > now() ");
            }else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.ONE)){
                queryWrapper.apply("  now()  between  t.START_TIME  and t.END_TIME  ");
            }else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.TWO)){
                queryWrapper.apply("  t.END_TIME  < now() ");
            }else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.THREE)){
                queryWrapper.apply("  t.END_TIME  > now() ");
            }
        }
        if (pageWrap.getModel().getLoseEfficacy() != null && pageWrap.getModel().getLoseEfficacy() ==1) {
            queryWrapper.apply("  DATEDIFF(t.END_TIME,CURRENT_DATE() ) <= 5  and t.END_TIME >= now() ");
        }
@@ -2305,6 +2839,8 @@
        if(pageData.getRecords()!=null){
            for (InsuranceApply apply : pageData.getRecords()){
                initApplyStatus(apply) ;
                apply.setChangeMoney(Constants.getTwoPoint(apply.getChangeMoney()));
                apply.setFee(Constants.getTwoPoint(apply.getFee()));
             }
        }
        return pageData;
@@ -2321,6 +2857,16 @@
        }
        setServiceDays(apply);
        apply.setStatusInfo(Constants.ApplyCollectStatus.getName(apply.getStatusCollect()));
        if(Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
                || Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey()) ){
            if(apply.getStartTime().getTime()>System.currentTimeMillis()){
                apply.setStatusInfo("待生效");
            }else if(apply.getEndTime().getTime()<System.currentTimeMillis()){
                apply.setStatusInfo("已过期");
            }else{
                apply.setStatusInfo("保障中");
            }
        }

    }

@@ -2334,7 +2880,7 @@
        queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
        queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.apply_id = t.id ) as insureNum");
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum");
        queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum");
        queryWrapper.select(" ( select max(ac.APPLY_START_TIME) from apply_change ac  where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate");
        queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney ");
        queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id  where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
@@ -2477,10 +3023,13 @@
                .selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit)
                .selectAs(Solutions::getType,InsuranceApply::getSolutionType)
                .selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
                .selectAs(Solutions::getHasDispatchUnit,InsuranceApply::getHasDispatchUnit)
                .selectAs(Solutions::getSignType,InsuranceApply::getSignType)
                .selectAs(Company::getName,InsuranceApply::getCompanyName)
                .select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad left join  apply_change a on a.id = ad.APPLY_CHANGE_ID  where t.id = a.APPLY_ID  and a.status = 2  )",InsuranceApply::getChangeMoney)
                .select(" ( select max(ac.APPLY_START_TIME) from apply_change ac  where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate")
                .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.apply_id = t.id ) as insureNum")
                .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum")
                .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum")
                .select(" t3.name as shopName")
                .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
                .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
@@ -2512,6 +3061,10 @@
        initApplyStatus(insuranceApply);
        //查询附件数据
        initImgData(insuranceApply);

        insuranceApply.setChangeMoney(Constants.getTwoPoint(insuranceApply.getChangeMoney()));
        insuranceApply.setFee(Constants.getTwoPoint(insuranceApply.getFee()));

        //查询操作记录
        List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class,
                new MPJLambdaWrapper<ApplyLog>()
@@ -2549,6 +3102,21 @@
    }

    private void initImgData(InsuranceApply model) {
        String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()
                +systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();

        //查询方案确认书
        CompanySolution companySolution =companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda().eq(CompanySolution::getSolutionId,model.getSolutionId()).eq(CompanySolution::getCompanyId,model.getCompanyId()).last("limit 1"));
        if(Objects.nonNull(companySolution)){
            Multifile multifile = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda()
                    .eq(Multifile::getObjId,companySolution.getId())
                    .eq(Multifile::getObjType,Constants.MultiFile.COMPANY_SOLUTION_SIGN_PDF.getKey())
                    .eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1"));
            if(Objects.nonNull(multifile)){
                multifile.setFileurlFull(path + multifile.getFileurl());
                model.setFanganFile(multifile);
            }
        }
        List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda()
                .eq(Multifile::getObjId, model.getId())
                .in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.BD_APPLY_PDF.getKey()
@@ -2559,8 +3127,11 @@
                .eq(Multifile::getIsdeleted,Constants.ZERO)
                .orderByAsc(Multifile::getId));
        if(multifiles!=null){
            String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()
                    +systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();





            for(Multifile f : multifiles){
                if(StringUtils.isBlank(f.getFileurl())){
                    continue;
@@ -2578,10 +3149,11 @@
                }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.MEMBER_LIST_LATTER.getKey())){
                    //申请单
                    model.setShenqingdanFile(f);
                }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey())){
                    //签署后确认书
                    model.setFanganFile(f);
                }
//                else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey())){
//                    //签署后确认书
//                    model.setFanganFile(f);
//                }

//                if(model.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
//                    //如果当前时间大于结束日期 则使用结束日期对比开始日期
@@ -2605,7 +3177,7 @@
                .selectAs(Solutions::getType,InsuranceApply::getSolutionType)
                .selectAs(Company::getName,InsuranceApply::getCompanyName)
                .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.apply_id = t.id ) as insureNum")
                .select(" isnull(( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now() ),0) as guaranteeNum")
                .select(" ifnull(( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id  and a.status in ( 5 , 27 )  where ad.apply_id = t.id and ad.END_TIME > now()  and ad.START_TIME < now() ),0) as guaranteeNum")
                .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
                .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
                .eq(InsuranceApply::getId,model.getId())
@@ -2710,11 +3282,6 @@
                        insuranceApply.getId(),solutions.getName(),companySolution.getShopId(),Constants.NoticeType.THREE);
                noticesMapper.insert(shopNotices);
            }






        }else if(insuranceApplyOptDTO.getOptType().equals(Constants.TWO)){
            insuranceApplyStatus =  Constants.InsuranceApplyStatus.CLOSE;
@@ -3006,10 +3573,11 @@
        if(solutions.getType().equals(Constants.ZERO)){
            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，非委托保方案保单，无法进行该操作!");
        }
        String fileUrl =  ExcelExporter.build(InsuranceApply.class).exportApplyExcelToPdf(model,"人员名单");
        String fileUrl = "https://yybred.oss-cn-hangzhou.aliyuncs.com/apply/20241120/1c80f0d7-ab35-4355-b9fe-944464643115.pdf";//ExcelExporter.build(InsuranceApply.class).exportApplyExcelToPdf(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);
        //String applyNo = signService.applySignLocalFile(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"投保名单签章",company.getSignId(),notifyUrl);
        String applyNo = signService.applySign(company.getName(),fileUrl,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl);
        if(StringUtils.isBlank(applyNo) ){
            throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
        }
@@ -3106,4 +3674,79 @@
        return  link;
    }





    /**
     * 根据保单查询是否可以进行加减保操作
     * @param applyPowerDTO
     * @return
     */
    @Override
    public ApplyPowerVO getApplyPower(ApplyPowerDTO applyPowerDTO){
        if(Objects.isNull(applyPowerDTO)
        || Objects.isNull(applyPowerDTO.getApplyId())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"参数错误");
        }
        if(Objects.isNull(applyPowerDTO.getBeginDate())){
            applyPowerDTO.setBeginDate(new Date());
        }
        InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyPowerDTO.getApplyId());
        if(Objects.isNull(insuranceApply)){
            throw new BusinessException(ResponseStatus.DATA_EMPTY);
        }
        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(),"未查询到方案信息");
        }
        ApplyPowerVO applyPowerVO = InsuranceApplyServiceImpl.getApplyPowerStatic(applyPowerDTO,insuranceApply,solutions);
        return applyPowerVO;
    }



    public static ApplyPowerVO getApplyPowerStatic(ApplyPowerDTO applyPowerDTO,InsuranceApply insuranceApply,Solutions solutions){
        if(Objects.isNull(applyPowerDTO)
                || Objects.isNull(applyPowerDTO.getApplyId())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"参数错误");
        }
        if(Objects.isNull(applyPowerDTO.getBeginDate())){
            applyPowerDTO.setBeginDate(new Date());
        }
        ApplyPowerVO applyPowerVO = new ApplyPowerVO();
        //获取方案 结束时间
        Date endTime = insuranceApply.getEndTime();
        //查询当前去加保的开始日期  yyyy-MM-dd HH:mm:ss 2024-10-29 00:00:00
        Date addStartDate = DateUtil.getMontageDate(
                DateUtil.afterDateByType(applyPowerDTO.getBeginDate(),Constants.ZERO,solutions.getAddValidDays()),
                1
        );
        applyPowerVO.setAddStartDate(addStartDate);
        //加保生效日期大于 保单结束日期 则不可以进行加保
        if(addStartDate.getTime()>=endTime.getTime()){
            applyPowerVO.setAddTrue(Constants.ONE);
        }else{
            applyPowerVO.setAddTrue(Constants.ZERO);
        }
        //查询当前去减保的开始日期  yyyy-MM-dd HH:mm:ss 2024-10-29 00:00:00
        Date delStartDate = DateUtil.getMontageDate(
                DateUtil.afterDateByType(applyPowerDTO.getBeginDate(),Constants.ZERO,solutions.getAddValidDays()),
                1
        );
        applyPowerVO.setDelStartDate(delStartDate);
        //加保生效日期大于 保单结束日期 则不可以进行减保
        if(delStartDate.getTime()>=endTime.getTime()){
            applyPowerVO.setDelTrue(Constants.ONE);
        }else{
            applyPowerVO.setDelTrue(Constants.ZERO);
        }
        return applyPowerVO;
    }

}