瀏覽代碼

fix mqtt send msg topic

tags/v0.8.5^2
yk 2 年之前
父節點
當前提交
156e9a7de0
共有 2 個檔案被更改,包括 4 行新增1 行删除
  1. +3
    -0
      xueyi-common/xueyi-common-mqtt/src/main/java/com/xueyi/common/mqtt/configure/MqttConfig.java
  2. +1
    -1
      xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/emcs/controller/DmExceptionLogController.java

+ 3
- 0
xueyi-common/xueyi-common-mqtt/src/main/java/com/xueyi/common/mqtt/configure/MqttConfig.java 查看文件

@@ -33,6 +33,9 @@ public class MqttConfig {
@Value("${emqx.topics}")
private String topics;

@Value("${emqx.prefix}")
private String prefix;

@Value("${emqx.fetchLogTopic}")
private String fetchLogTopic;



+ 1
- 1
xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/emcs/controller/DmExceptionLogController.java 查看文件

@@ -256,7 +256,7 @@ public class DmExceptionLogController extends BaseController<DmExceptionLogQuery
devId = StringUtils.isEmpty(devId) ? json.getString("id") : devId;
JSONObject jsonObject = new JSONObject();
jsonObject.put("devId", devId);
mqttService.sendMessage(mqttConfig.getFetchLogTopic(), jsonObject.toJSONString());
mqttService.sendMessage(mqttConfig.getPrefix()+"/"+devId+mqttConfig.getFetchLogTopic(), jsonObject.toJSONString());
return success("操作成功");
}



Loading…
取消
儲存