添加故障上报、存储

zhuguifei

2024-11-18 15206b16b0121ba7331496c0f0946e4004ad4507

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

@@ -54,6 +54,7 @@

  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";

@@ -64,14 +65,16 @@


  String SERVICE_REQ_PREFIX = "service/req";
  String SERVICE_REQ_EQUIPMENT = SERVICE_REQ_PREFIX + "/%s/equipment";

  String SERVICE_REQ_EQU_TOPIC = SERVICE_REQ_PREFIX + "/+/equipment";


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

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

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


}