Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

zhubaomin

2 天以前 c2976b80e8850be2d28dc2132c6659856b871f3c

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/ComTransCtrl.java

@@ -33,13 +33,14 @@
 * @Date: 2025/4/30 16:08
 * @Description
 */

@Slf4j
@Tag(name = "远程透传命令", description = "远程透传命令")
@RestController
@RequestMapping(path = "comTrans")
@RequiredArgsConstructor
public class ComTransCtrl {

    private static final String RtuSuccessMsg = "控制器接收并执行命令成功";

    @Autowired
    private Environment env ;
@@ -112,14 +113,9 @@
                try{
                    //等待通信中间件通知控制器执行命令上行数据（命令结果）
                    JSONObject resultData = feature.get(waitMwRtnResultTimeout, TimeUnit.SECONDS);
                    Long commandId = resultData.getLong("commandId");
                    if (commandId.equals(comId)) {
                        return BaseResponseUtils.buildSuccess(resultData);
                    } else {
                        return BaseResponseUtils.buildSuccess("控制器执行命令成功");
                    }
                    return BaseResponseUtils.buildSuccess(this.createRtnMsg(dto.comCode, resultData));
                }catch (Exception e){
                    return BaseResponseUtils.buildFail("等待通信中间件通知命令结果超时或异常");
                    return BaseResponseUtils.buildFail("等待通信中间件通知命令结果超时");
                }
            }
        }catch (Exception e){
@@ -153,4 +149,114 @@
        return null ;
    }

    private String createRtnMsg(String code, JSONObject resultData){
        String msg;
        if(resultData != null){
            JSONObject codeData = resultData.getJSONObject("data") ;
            switch (code){
                case "3C": msg = createCd3CRtnMsg(codeData); break;
                case "10": msg = createCd10RtnMsg(codeData); break;
                case "21": msg = createCd21RtnMsg(codeData); break;
                case "37": msg = createCd37RtnMsg(codeData); break;
                case "50": msg = createCd50RtnMsg(codeData); break;
                case "65": msg = createCd65RtnMsg(codeData); break;
                case "66": msg = createCd66RtnMsg(codeData); break;
                case "67": msg = createCd67RtnMsg(codeData); break;
                case "91": msg = createCd91RtnMsg(codeData); break;
                case "92": msg = createCd92RtnMsg(codeData); break;
                case "93": msg = createCd93RtnMsg(codeData); break;
                default: msg = RtuSuccessMsg; break;
            }
        }else{
            msg = RtuSuccessMsg ;
        }
        return msg;
    }
    private String createCd3CRtnMsg(JSONObject codeData){
        if(codeData == null){
           return RtuSuccessMsg ;
        }else{
            Integer minute = codeData.getInteger("minute");
            return "设置成功，自报周期：" + minute + "分钟" ;
        }
    }
    private String createCd10RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            String newRtuAddr = codeData.getString("newRtuAddr");
            return "设置成功，控制器地址：" + newRtuAddr;
        }
    }
    private String createCd21RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            String ip = codeData.getString("ip");
            Integer port = codeData.getInteger("port");
            return "设置成功，IP地址：" + ip + "，端口号：" + port;
        }
    }
    private String createCd37RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            Integer second = codeData.getInteger("second");
            return "设置成功，流量采集周期：" + second + "秒";
        }
    }
   private String createCd50RtnMsg(JSONObject codeData){
       if(codeData == null){
           return RtuSuccessMsg ;
       }else {
           String rtuAddr = codeData.getString("rtuAddr");
           return "查询成功，控制器地址：" + rtuAddr;
       }
    }
    private String createCd65RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            Integer minute = codeData.getInteger("minute");
            return "查询成功，自报周期：" + minute + "分钟";
        }
    }
    private String createCd66RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            String ip = codeData.getString("ip");
            Integer port = codeData.getInteger("port");
            return "查询成功，IP地址：" + ip + "，端口号：" + port;
        }
    }
    private String createCd67RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            Integer second = codeData.getInteger("second");
            return "查询成功，流量采集周期：" + second + "秒";
        }
    }
    private String createCd91RtnMsg(JSONObject codeData){
        //此命令的codeData是null
        return "控制器清空历史记录成功" ;
    }
    private String createCd92RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            Boolean success = codeData.getBoolean("success");
            return success ? "控制器已执行遥控开阀命令" : "控制器拒绝执行遥控开阀命令";
        }
    }
    private String createCd93RtnMsg(JSONObject codeData){
        if(codeData == null){
            return RtuSuccessMsg ;
        }else {
            Boolean success = codeData.getBoolean("success");
            return success ? "控制器已执行遥控关阀命令" : "控制器拒绝执行遥控关阀命令";
        }
    }

}