1、通信中间件重构MQTT相关下行命令的逻辑； 2、remote模块完善MQTT相关下行命令解除报警、搅拌启停、注肥启停、灌溉启停功能类；

liurunyu

2025-06-21 0c870ae5b2af348e19b10cc1a99f103f95c5a1cc

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/Command.java

@@ -3,6 +3,7 @@
import java.io.Serializable;

import com.alibaba.fastjson2.JSON ;
import com.alibaba.fastjson2.JSONObject;

public class Command implements Serializable{

@@ -10,6 +11,12 @@
   static {
      serialVersionUID = 201211292156L;
   }

   /**
    * 当命令结果返回的网址是此值时，忽略执行，例如中间件主动下发的命令，就不用返回命令结果
    */
   public static final String ignoreRtuResultSendWebUrl = "http://0.0.0.0" ;


   /**
    * 默认命令ID
@@ -21,15 +28,20 @@
    * 本条命令的ID
    * 一般是命令在数据库中存储记录ID的字符串形式
    */
   public String id; 
	
   public String id;

   /**
    * 水表协议名称，这个可以为空，因为水表上行数据解析出协议名称，然后系统把协议名称保存在水表数据记录中，从此协议名称就不再空了
    * RTU协议名称，这个可以为空，因为RTU上行数据解析出协议名称，然后系统把协议名称保存在RTU数据记录中，从此协议名称就不再空了
    */
   public String protocol;
	

   /**
    * RTU 地址
    * RTU协议名称，这个可以为空
    */
   public Short protocolVersion;

   /**
    * RTU地址 和 FBox设备号
    */
   public String rtuAddr ;

@@ -43,11 +55,11 @@
    * 功能码
    */
   public String code ; 
	

   /**
    * 不返回中间件对命令处理结果（true：不返回处理结果，false或null：返回处理结果）
    * rtu返回命令结果 发向目的地web URL
    */
   public Boolean noRtMwDealRes ;
   public String rtuResultSendWebUrl ;

   /**
    * 具体参数数据
@@ -62,10 +74,11 @@
   public String toString(){
      String s = "命令id=" + id + "\n" ;
      s += (protocol == null ? "" : ("协议=" + protocol + "\n"));
      s += (rtuAddr == null ? "" : ("IMEI号=" + rtuAddr + "\n"));
      s += "命令类型=" + (type.equals(CommandType.innerCommand)?"内部命令":"终端命令") + "\n" ;
      s += (protocolVersion == null ? "" : ("协议版本号=" + protocolVersion + "\n"));
      s += (rtuAddr == null ? "" : ("Rtu地址=" + rtuAddr + "\n"));
      s += "命令类型=" + (type.equals(CommandType.innerCommand)?"内部命令":(type.equals(CommandType.outerCommand)?"RTU命令":"透传命令")) + "\n" ;
      s += (code == null ? "" : ("功能码=" + code + "\n")) ;
      s += "返回中间件对命令处理结果=" + (noRtMwDealRes == null?"返回":(noRtMwDealRes?"不返回":"返回") + "\n") ;
      s += (rtuResultSendWebUrl == null ? "" : ("回调网址=" + rtuResultSendWebUrl + "\n"));
      if(param != null){
         s += "参数:" + param  ;
      }
@@ -82,7 +95,8 @@
   @SuppressWarnings("unused")
   public String toJson()throws Exception{
      try{
         return JSON.toJSONString(this) ;
         String json = JSON.toJSONString(this) ;
         return json ;
      }catch(Exception e){
         throw new Exception(e.getMessage() , e ) ;
      }
@@ -96,7 +110,10 @@
   @SuppressWarnings("unused")
   public static Command jsonToObject(String json)throws Exception{
      try{
         return JSON.parseObject(json, Command.class) ;
         JSONObject jsonObject = JSON.parseObject(json);
         Command command = jsonObject.to(Command.class) ;
         //command.param = jsonObject.getObject("param", class);
         return command ;
      }catch(Exception e){
         throw new Exception(e.getMessage() , e ) ;
      }
@@ -152,17 +169,6 @@
      
      return this ;
   }
   /*
   public static void main(String[] args){
      String json = "{\"attachment\":null,\"code\":\"03\",\"deviceId\":\"d8c9601f214747d98d47a4736e5\",\"id\":\"999999999\",\"meterNo\":\"23040600377\",\"productId\":16873252,\"param\":\"0002\",\"protocol\":\"HAC_NBhV2_5\",\"rtuAddr\":\"863318060168996\",\"type\":\"outerCommand\"}" ;
      try {
         Command com = jsonToObject(json) ;
         System.out.println(com.param);
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
    */

   public String getId() {
      return id;
@@ -178,7 +184,15 @@
      this.rtuAddr = rtuAddr;
      return this ;
   }
	

   public String getRtuResultSendWebUrl() {
      return rtuResultSendWebUrl;
   }

   public void setRtuResultSendWebUrl(String rtuResultSendWebUrl) {
      this.rtuResultSendWebUrl = rtuResultSendWebUrl;
   }

   public String getProtocol() {
      return protocol;
   }
@@ -198,14 +212,6 @@
   public Command setCode(String code) {
      this.code = code;
      return this ;
   }
   @SuppressWarnings("unused")
   public Boolean getNoRtMwDealRes() {
      return noRtMwDealRes;
   }
   @SuppressWarnings("unused")
   public void setNoRtMwDealRes(Boolean noRtMwDealRes) {
      this.noRtMwDealRes = noRtMwDealRes;
   }
   public Object getParam() {
      return param;