若依微服务1.1.6版本

数据处理服务处理设备状态上下线信息

ruoyi-modules/hw-data-process/src/main/java/com/ruoyi/dataprocess/mqtt/client/config/MqttConfiguration.java

@@ -129,7 +129,7 @@ public class MqttConfiguration {
                         if (topic.startsWith(dataTopicFilter.replace("#",""))) {
                             dataProcessService.processBusinessData(payloadString, imagePath, imagePatterns);
                         } else if (topic.equals(deviceStatusTopic)) {
-                            deviceStatusService.handleDeviceStatus();
+                            deviceStatusService.handleDeviceStatus(payloadString,clientId);
                         }
                     }
                 });

ruoyi-modules/hw-data-process/src/main/java/com/ruoyi/dataprocess/service/IDeviceStatusService.java

@@ -9,5 +9,5 @@ package com.ruoyi.dataprocess.service;
  */
 public interface IDeviceStatusService {
 
-    public void handleDeviceStatus();
+    public void handleDeviceStatus(String payloadString,String clientId);
 }

ruoyi-modules/hw-data-process/src/main/java/com/ruoyi/dataprocess/service/impl/DeviceStatusServiceImpl.java

@@ -1,10 +1,20 @@
 package com.ruoyi.dataprocess.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.core.constant.TdEngineConstants;
+import com.ruoyi.dataprocess.domain.HwDevice;
+import com.ruoyi.dataprocess.mapper.HwDeviceMapper;
 import com.ruoyi.dataprocess.service.IDeviceStatusService;
 import com.ruoyi.tdengine.api.RemoteTdEngineService;
+import com.ruoyi.tdengine.api.domain.TdField;
+import com.ruoyi.tdengine.api.domain.TdTableVo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @Description: 设备状态处理服务
@@ -16,12 +26,48 @@ import javax.annotation.Resource;
 @Service
 public class DeviceStatusServiceImpl implements IDeviceStatusService {
 
+    @Autowired
+    private HwDeviceMapper hwDeviceMapper;
+
     @Resource
     private RemoteTdEngineService remoteTdEngineService;
 
     @Override
-    public void handleDeviceStatus(){
+    public void handleDeviceStatus(String payloadString, String clientId) {
+        System.out.println("ddd:" + payloadString);
+//        ddd:{"msg":"设备设备连接状态信息","deviceType":"edge","connectStatus":1,
+//                "statusTime":1694506127199,"deviceCode":"hw-data-process-1"}
+        JSONObject json = JSON.parseObject(payloadString);
+        String deviceCode = json.getString("deviceCode");
+        if (clientId.equals(deviceCode)) { //校验是不是自己，如果是自己则不记录状态，返回即可。
+            return;
+        }
+        HwDevice hwDevice = hwDeviceMapper.selectHwDeviceByDeviceCode(deviceCode);
+        if (hwDevice != null) {
+            Long deviceId = hwDevice.getDeviceId();
+            TdTableVo tdTableVo = new TdTableVo();
+            tdTableVo.setDatabaseName(TdEngineConstants.PLATFORM_DB_NAME);
+            tdTableVo.setTableName(TdEngineConstants.DEFAULT_DEVICE_STATUS_TABLE_NAME_PREFIX + deviceId);
+
+            List<TdField> schemaFields = new ArrayList<>();
+            TdField onlineStatusField = new TdField();
+            onlineStatusField.setFieldName("onlineStatus");
+            onlineStatusField.setFieldValue(json.getInteger("connectStatus"));
+            schemaFields.add(onlineStatusField);
+
+            TdField deviceTypeField = new TdField();
+            deviceTypeField.setFieldName("deviceType");
+            deviceTypeField.setFieldValue(json.getString("deviceType"));
+            schemaFields.add(deviceTypeField);
 
-        System.out.println("handleDeviceStatus");
+            TdField tsField = new TdField();
+            tsField.setFieldName(TdEngineConstants.DEFAULT_FIRST_FIELD_NAME);
+            tsField.setFieldValue(json.getLong("statusTime"));
+            schemaFields.add(tsField);
+
+            tdTableVo.setSchemaFields(schemaFields);
+
+            this.remoteTdEngineService.insertTable(tdTableVo);
+        }
     }
 }