优化命令发布接口（6个），重复时使用新的commandId

zhubaomin

2025-04-15 deac851d71b074885553f538a396936815073fc1

 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;
@@ -25,7 +25,6 @@
import org.springframework.web.bind.annotation.RestController;

import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.util.List;
import java.util.Objects;

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

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

@@ -133,22 +132,20 @@
    @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);
        po.dt = new Date();
        po.isOver = 0 ;
        po.deleted = 0 ;
        po.init();
        int count;
        try {
            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) ;
        }
@@ -171,25 +168,104 @@
     @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) ;
         }
     }


    /**
     * 执行RTU升级任务
     * @param id RTU升级任务ID
     * @return 是否成功
     */
    @Operation(summary = "执行RTU升级任务", description = "提交RTU升级任务ID，进行执行")
    @ApiResponses(value = {
            @ApiResponse(
                    responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
                    description = "操作结果：true：成功，false：失败（BaseResponse.content）",
                    content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
                            schema = @Schema(implementation = Boolean.class))}
            )
    })
    @GetMapping(path = "execute")
    @SsoAop()
    public BaseResponse<Boolean> execute(Long id){
        if(id == null){
            return BaseResponseUtils.buildErrorMsg("id不能为空") ;
        }
        int count;
        try {
            count = this.sv.isOver(id) ;
            if(count > 0){
                return BaseResponseUtils.buildErrorMsg("任务已经结束，不能再执行") ;
            }
            count = this.sv.isExecute(id) ;
            if(count > 0){
                return BaseResponseUtils.buildErrorMsg("任务已经执行，不能再执行") ;
            }
            count = this.sv.execute(id);
        } catch (Exception e) {
            log.error("执行RTU升级任务异常", e);
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildErrorMsg("数据库操作失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }
    }

    /**
     * 结束RTU升级任务
     * @param id RTU升级任务ID
     * @return 是否成功
     */
    @Operation(summary = "结束RTU升级任务", description = "提交RTU升级任务ID，进行结束")
    @ApiResponses(value = {
            @ApiResponse(
                    responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
                    description = "操作结果：true：成功，false：失败（BaseResponse.content）",
                    content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
                            schema = @Schema(implementation = Boolean.class))}
            )
    })
    @GetMapping(path = "over")
    @SsoAop()
    public BaseResponse<Boolean> over(Long id){
        if(id == null){
            return BaseResponseUtils.buildErrorMsg("id不能为空") ;
        }
        int count;
        try {count = this.sv.isOver(id) ;
            if(count > 0){
                return BaseResponseUtils.buildErrorMsg("任务已经结束，不用再结束") ;
            }
            count = this.sv.over(id);
        } catch (Exception e) {
            log.error("结束RTU升级任务异常", e);
            return BaseResponseUtils.buildErrorMsg(e.getMessage()) ;
        }
        if(count <= 0){
            return BaseResponseUtils.buildErrorMsg("数据库操作失败") ;
        }else{
            return BaseResponseUtils.buildSuccess(true) ;
        }
    }

    /**
     * 删除RTU升级任务
@@ -209,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) ;
        }