Skip to content

A
amos-boot-biz
Commit c441c027 authored by KeYong's avatar KeYong
Browse files
Options

Merge remote-tracking branch 'origin/develop_dl_3.7.0.9' into develop_dl_3.7.0.9

parents cf23da4d 0bf8e898
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 5 deletions
amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java
View file @ c441c027
...@@ -404,11 +404,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -404,11 +404,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
String iotCode = equipmentSpecific.getIotCode(); String iotCode = equipmentSpecific.getIotCode();
StringBuilder endIndex = new StringBuilder(iotCode).insert(8, '/'); StringBuilder endIndex = new StringBuilder(iotCode).insert(8, '/');
String iotTopic = "influxdb/" + endIndex; String iotTopic = "influxdb/" + endIndex;
if (isSendIot) { JSONObject msg = new JSONObject();
JSONObject msg = new JSONObject(); msg.put(equipmentSpeIndex.getEquipmentIndexKey(), value);
msg.put(equipmentSpeIndex.getEquipmentIndexKey(), value); mqttSendGateway.sendToMqtt(iotTopic, JSON.toJSONString(msg));
mqttSendGateway.sendToMqtt(iotTopic, JSON.toJSONString(msg));
}
List<EquipmentSpecificVo> eqIotCodeList = iEquipmentSpecificSerivce.getEquipAndCarIotcodeByIotcode(iotCode); List<EquipmentSpecificVo> eqIotCodeList = iEquipmentSpecificSerivce.getEquipAndCarIotcodeByIotcode(iotCode);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment