修改bug

liurunyu

2025-08-06 1b910faabb48b3355783a612e41c5b55942c34a4

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

@@ -5,8 +5,8 @@
import com.dy.common.webUtil.BaseResponseUtils;
import com.dy.common.webUtil.QueryResultVo;
import com.dy.common.webUtil.ResultCodeMsg;
import com.dy.pipIrrGlobal.pojoRm.UgRtuTask;
import com.dy.pipIrrGlobal.voRm.VoRtuTask;
import com.dy.pipIrrGlobal.pojoUg.UgRtuTask;
import com.dy.pipIrrGlobal.voUg.VoRtuTask;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.media.Content;
@@ -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) ;
        }