改一下

liurunyu

2024-11-23 7d6231e5b07a59c37ed45e4d8acc66a63e647578

 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/rtuUpgrade/task/UgRtuTaskCtrl.java

@@ -85,7 +85,7 @@
            return BaseResponseUtils.buildSuccess(res);
        } catch (Exception e) {
            log.error("查询RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
    }

@@ -110,7 +110,7 @@
            return BaseResponseUtils.buildSuccess(res);
        } catch (Exception e) {
            log.error("查询RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
    }

@@ -132,7 +132,7 @@
    @SsoAop()
    public BaseResponse<Boolean> save(@Parameter(description = "form表单数据", required = true) @Valid VoRtuTask vo, @Parameter(hidden = true) BindingResult bindingResult){
        if(bindingResult != null && bindingResult.hasErrors()){
            return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
            return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
        }
        UgRtuTask po = new UgRtuTask();
        vo.toPo(po);
@@ -142,10 +142,10 @@
            count = this.sv.save(po);
        } catch (Exception e) {
            log.error("保存RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildFail("数据库存储失败") ;
            return BaseResponseUtils.buildErrorMsg("数据库存储失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }
@@ -168,20 +168,20 @@
     @SsoAop()
     public BaseResponse<Boolean> update(@Parameter(description = "form表单数据", required = true) @Valid UgRtuTask po, @Parameter(hidden = true) BindingResult bindingResult){
         if(bindingResult != null && bindingResult.hasErrors()){
             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
             return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
         }
         if(po.id == null){
             return BaseResponseUtils.buildFail("无数据实体ID") ;
             return BaseResponseUtils.buildErrorMsg("无数据实体ID") ;
         }
         int count;
         try {
             count = this.sv.update(po);
         } catch (Exception e) {
             log.error("保存实体数据异常", e);
             return BaseResponseUtils.buildException(e.getMessage()) ;
             return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
         }
         if(count <= 0){
             return BaseResponseUtils.buildFail("数据库存储失败") ;
             return BaseResponseUtils.buildErrorMsg("数据库存储失败") ;
         }else{
             return BaseResponseUtils.buildSuccess(true) ;
         }
@@ -206,25 +206,25 @@
    @SsoAop()
    public BaseResponse<Boolean> execute(Long id){
        if(id == null){
            return BaseResponseUtils.buildFail("id不能为空") ;
            return BaseResponseUtils.buildErrorMsg("id不能为空") ;
        }
        int count;
        try {
            count = this.sv.isOver(id) ;
            if(count > 0){
                return BaseResponseUtils.buildError("任务已经结束，不能再执行") ;
                return BaseResponseUtils.buildErrorMsg("任务已经结束，不能再执行") ;
            }
            count = this.sv.isExecute(id) ;
            if(count > 0){
                return BaseResponseUtils.buildError("任务已经执行，不能再执行") ;
                return BaseResponseUtils.buildErrorMsg("任务已经执行，不能再执行") ;
            }
            count = this.sv.execute(id);
        } catch (Exception e) {
            log.error("结束RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            log.error("执行RTU升级任务异常", e);
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildFail("数据库操作失败") ;
            return BaseResponseUtils.buildErrorMsg("数据库操作失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }
@@ -248,20 +248,20 @@
    @SsoAop()
    public BaseResponse<Boolean> over(Long id){
        if(id == null){
            return BaseResponseUtils.buildFail("id不能为空") ;
            return BaseResponseUtils.buildErrorMsg("id不能为空") ;
        }
        int count;
        try {count = this.sv.isOver(id) ;
            if(count > 0){
                return BaseResponseUtils.buildError("任务已经结束，不用再结束") ;
                return BaseResponseUtils.buildErrorMsg("任务已经结束，不用再结束") ;
            }
            count = this.sv.over(id);
        } catch (Exception e) {
            log.error("结束RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildFail("数据库操作失败") ;
            return BaseResponseUtils.buildErrorMsg("数据库操作失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }
@@ -285,17 +285,17 @@
    @SsoAop()
    public BaseResponse<Boolean> delete(Long id){
        if(id == null){
            return BaseResponseUtils.buildFail("id不能为空") ;
            return BaseResponseUtils.buildErrorMsg("id不能为空") ;
        }
        int count;
        try {
            count = this.sv.delete(id);
        } catch (Exception e) {
            log.error("删除RTU升级任务异常", e);
            return BaseResponseUtils.buildException(e.getMessage()) ;
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildFail("数据库操作失败") ;
            return BaseResponseUtils.buildErrorMsg("数据库操作失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }