添加故障上报、存储

zhuguifei

2024-11-18 15206b16b0121ba7331496c0f0946e4004ad4507

 jeecg-boot-base-core/src/main/java/org/jeecg/common/constant/MqttConstant.java

@@ -5,6 +5,13 @@
 */
public interface MqttConstant {

  /**************************** MQTT角色 start *************************************/
  String ROLE_ADMIN = "admin";
  String ROLE_USER = "user";


  /**************************** MQTT角色 end *************************************/

  /**************************系统订阅strat*******************************/
  //上线订阅
  String MQTT_TOPIC_ONLINE = "$SYS/brokers/+/clients/+/connected";
@@ -28,14 +35,7 @@



  /**************************租户端向服务端发送数据start*******************************/


  String TENANT_UP_PREFIX = "tenant/up";
  String TENANT_UP_PREFIX_REALTIME_DATA = TENANT_UP_PREFIX + "/realTime/data";


  /**************************租户端向服务端发送数据end*******************************/



@@ -49,9 +49,32 @@
  String SERVICE_RES_EQU_CMD = SERVICE_DOWN_PREFIX + "/%s/cmd";
  /**************************服务端向移动端响应指令end*******************************/

  /**************************租户端向服务端发送数据start*******************************/


  String TENANT_UP_PREFIX = "tenant/up";
  String TENANT_UP_PREFIX_REALTIME_DATA = TENANT_UP_PREFIX + "/realTime/data";
  String TENANT_UP_PREFIX_FAULT_DATA = TENANT_UP_PREFIX + "/fault/data";

  String TENANT_UP_PREFIX_EQU = TENANT_UP_PREFIX + "/equipment";


  /**************************租户端向服务端发送数据end*******************************/

  /**************************服务端向租户端请求数据start*******************************/


  String SERVICE_REQ_PREFIX = "service/req";


  /**************************服务端向租户端请求数据end*******************************/

  /**************************start*******************************/
  /**************************end*******************************/

  //redis缓存
  String MQTT_ONLINE_CLIENT = "mqtt:online:client::";
  String MQTT_EQP_FAULT = "mqtt:eqp:fault";


}