开发业务接口

jiangping

2024-01-25 c4b7eb0821312740c17c9eaada5afb012ac5ca34

开发业务接口

 server/platform/src/main/java/com/doumee/task/ScheduleTool.java

@@ -39,6 +39,15 @@
    /**
     * @throws Exception
     */
    @Scheduled(fixedDelay= 60*1000*60,initialDelay = 30000)
    public void deal() throws Exception {
        log.info("==============定时查询企业电子签签署状态=======start======");
        insuranceApplyService.dealWaitSignedData();
        log.info("==============定时查询企业电子签签署状态======end=======");
    }
    /**
     * @throws Exception
     */
    @Scheduled(fixedDelay= 60*1000,initialDelay = 30000)
    public void dealComSigIdStatus() throws Exception {
        log.info("==============定时上传待上传的企业电子印章数据=======start======");

 server/service/src/main/java/com/doumee/service/business/InsuranceApplyService.java

@@ -125,4 +125,6 @@
    String getSignLink(Integer id);

    void dealSignResult(NotifyDataReq data);

    void dealWaitSignedData();
}

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

@@ -409,6 +409,39 @@

    }
    @Override
    public   void dealWaitSignedData(){
        List<InsuranceApply> applyList = insuranceApplyMapper.selectList(new QueryWrapper<InsuranceApply>().lambda()
                .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE)
                .isNotNull(InsuranceApply::getSignApplyNo));
        if(applyList !=null && applyList.size()>0 ){
            for(InsuranceApply model : applyList){
                String link = signService.linkFile(model.getSignApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    return;
                }
                uploadSignedFileDo(model,fileUrl);
                return;
            }
        }
        List<ApplyChange> chagneList = applyChangeMapper.selectList(new QueryWrapper<ApplyChange>().lambda()
                .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD)
                .isNotNull(ApplyChange::getSignApplyNo));
        if(chagneList !=null && chagneList.size()>0 ){
            for(ApplyChange model : chagneList){
                String link = signService.linkFile(model.getSignApplyNo());
                String fileUrl = uploadSignFile(link);
                if(StringUtils.isBlank(fileUrl)){
                    //如果下载失败，清除合同，下次签章重新生成新合同
                    return;
                }
                uploadChangeSignedFileDo(model,fileUrl);
                return;
            }
        }
    }
    @Override
    public   void dealSignResult(NotifyDataReq data){
        if(data.getApplyNo() == null ){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);