向iot推送消息配置代码

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -151,6 +151,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
     @Value("${isSendApp}")
     private Boolean isSendApp;
 
+    @Value("${isSendIot:false}")
+    private Boolean isSendIot;
+
     private static Boolean bool = Boolean.FALSE;
 
     @Override
@@ -171,6 +174,10 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         if (eqIotCodeList.size() > 1) {
             log.info("有重复的{}数据！", iotCode);
         }
+        //给 iot服务 推送消息 插数据到 influxdb
+        if (isSendIot) {
+            mqttSendGateway.sendToMqtt("influxdb/" + topic.substring(0, endIndex), message);
+        }
         EquipmentSpecificVo vo = eqIotCodeList.get(0);
         topicEntity.setType(vo.getType());
         topicEntity.setCode(vo.getCode());

amos-boot-system-equip/src/main/resources/application-dev.properties

@@ -93,4 +93,6 @@ equipment.plan.pump=92010600,92030600,92130400,92140200,92150300
 #iot.code.prefix.have.used=20210003,20210004,20210005
 # 电力使用
 iot.code.prefix.have.used=
+#是否向iot推送消息
+isSendIot=false