无为设备上报

杨鸣坤
1 parent 1371a972
Showing 5 changed files with 409 additions and 17 deletions
src/main/java/com/iot/scheduler/service/HnDeviceReportService.java
src/main/java/com/iot/scheduler/service/wuwei/JmDevicePullService.java
src/main/java/com/iot/scheduler/service/wuwei/WWDeviceReportService.java
src/main/java/com/iot/scheduler/zone/WuweiZoneScheduler.java
src/main/resources/application.yml
--- a/src/main/java/com/iot/scheduler/service/HnDeviceReportService.java
View file @7ee8a0d
+++ b/src/main/java/com/iot/scheduler/service/HnDeviceReportService.java
View file @7ee8a0d
@@ -52,8 +52,6 @@ public class HnDeviceReportService {
         log.info("开始执行怀宁设备属性上报任务");
         try {
             List<Object> needSyncDataList = initConnectAndSelectData();
-            log.info("数据库查询完成，共获取{}条数据", needSyncDataList != null ? needSyncDataList.size() : 0);
-
             if (CollectionUtils.isEmpty(needSyncDataList)) {
                 log.info("没有需要上报的数据，任务结束");
                 return;
@@ -69,8 +67,6 @@ public class HnDeviceReportService {
                     List<Object> dataList = (ArrayList) needSyncData;
                     String deviceId = dataList.get(0).toString();
-                    log.info("开始处理设备[{}]的数据，进度: {}/{}", deviceId, i + 1, needSyncDataList.size());
-
                     ReportDevice reportDevice = new ReportDevice();
                     reportDevice.setDeviceId(deviceId);
                     Map<String, Object> propertiesMap = new HashMap<>(4);
@@ -80,22 +76,18 @@ public class HnDeviceReportService {
                         propertiesMap.put("State_Run", 1);
                         propertiesMap.put("State_PowerOn", 1);
                         propertiesMap.put("State_Alarm", 0);
-                        log.info("设备[{}]状态为: RUN", deviceId);
                     } else if ("STAND".equals(status)) {
                         propertiesMap.put("State_Run", 0);
                         propertiesMap.put("State_PowerOn", 1);
                         propertiesMap.put("State_Alarm", 0);
-                        log.info("设备[{}]状态为: STAND", deviceId);
                     } else if ("ERROR".equals(status)) {
                         propertiesMap.put("State_Run", 0);
                         propertiesMap.put("State_PowerOn", 1);
                         propertiesMap.put("State_Alarm", 1);
-                        log.info("设备[{}]状态为: ERROR", deviceId);
                     } else {
                         propertiesMap.put("State_Run", 0);
                         propertiesMap.put("State_PowerOn", 0);
                         propertiesMap.put("State_Alarm", 0);
-                        log.info("设备[{}]状态为: 未知[{}]，设置为离线", deviceId, status);
                     }
                     Object outputValue = dataList.get(2);
@@ -105,14 +97,11 @@ public class HnDeviceReportService {
                         if (outputValue instanceof Double) {
                             double doubleValue = (Double) outputValue;
                             outputLong = (long) doubleValue; // 直接转型，会丢失小数部分
-                            log.info("设备[{}]输出值: {} (double转换为long: {})", deviceId, doubleValue, outputLong);
                         } else if (outputValue instanceof Number) {
                             outputLong = ((Number) outputValue).longValue();
-                            log.info("设备[{}]输出值: {} (Number转换为long: {})", deviceId, outputValue, outputLong);
                         } else {
                             // 处理字符串或其他类型
                             outputLong = Long.parseLong(outputValue.toString());
-                            log.info("设备[{}]输出值: {} (字符串转换为long: {})", deviceId, outputValue, outputLong);
                         }
                     } else {
                         log.info("设备[{}]输出值为null，使用默认值0", deviceId);
@@ -124,10 +113,8 @@ public class HnDeviceReportService {
                     boolean sendResult = sendReportDevice(reportDevice);
                     if (sendResult) {
                         successCount++;
-//                        log.info("设备[{}]数据上报成功", deviceId);
                     } else {
                         failCount++;
-//                        log.error("设备[{}]数据上报失败", deviceId);
                     }
                 } catch (Exception e) {
@@ -148,8 +135,6 @@ public class HnDeviceReportService {
     private boolean sendReportDevice(ReportDevice reportDevice) {
         String deviceId = reportDevice.getDeviceId();
-        log.info("开始上报设备[{}]的数据，请求URL: {}", deviceId, reportUrl);
-
         HttpPost httpPost = new HttpPost(reportUrl);
         CloseableHttpClient httpClient = HttpClients.createDefault();
         String requestBody = JSON.toJSONString(reportDevice);
--- a/src/main/java/com/iot/scheduler/service/wuwei/JmDevicePullService.java
View file @7ee8a0d
+++ b/src/main/java/com/iot/scheduler/service/wuwei/JmDevicePullService.java
View file @7ee8a0d
@@ -33,6 +33,7 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.text.SimpleDateFormat;
+import java.time.LocalTime;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -251,6 +252,121 @@ public class JmDevicePullService {
         return deviceInfoDetail;
     }
+
+    public void pullCreateDeviceInfo() {
+        List<String> deviceNameList = Arrays.asList(
+                "油罐", "液压叉车01", "真空浇注设备", "变压真空干燥注油设备", "汇流排（母线）加工一体机", "变压真空干燥设备", "液压叉车02",
+                "液压叉车03", "非晶装配台", "BGJ-1250型变频硅钢片纵向剪切线", "液压叉车04", "打磨机01", "真空滤油机",
+                "起重机01", "起重机02", "起重机03", "起重机04", "起重机05", "起重机06", "起重机07", "起重机08", "起重机09", "起重机10",
+                "变频调速绕线机1", "变频调速绕线机2", "电热恒温鼓风干燥箱", "电脑剪线机01", "电脑剪线机02", "自动折弯剥线机",
+                "字码打印机01", "字码打印机02", "开式可倾压力机01", "开式可倾压力机02", "开式可倾压力机03", "开式可倾压力机04",
+                "打磨机02", "打磨机03", "气体保护焊机01", "气体保护焊机02", "开式固定台压力机", "全自动电脑剥线机", "液压叉车",
+                "光纤激光打标机", "手持激光清洗机", "激光切管机");
+        LocalTime currentTime = LocalTime.now();
+        LocalTime startTime = LocalTime.of(9, 0, 0);  // 09:00:00
+        LocalTime endTime = LocalTime.of(18, 0, 0);   // 18:00:00
+        boolean isWithinRange =
+                !currentTime.isBefore(startTime) &&
+                        currentTime.isBefore(endTime);
+
+        List<QxDeviceInfo> qxDeviceInfos = new ArrayList<>();
+        List<QxDeviceInfoDetail> qxAddDeviceInfoDetails = new ArrayList<>();
+        for (int index = 0; index < deviceNameList.size(); index++) {
+            QxDeviceInfo qxDeviceInfo = new QxDeviceInfo();
+            qxDeviceInfo.setDeviceType("DIRECT_CONNECTION");
+            qxDeviceInfo.setTransportType("DEFAULT");
+            qxDeviceInfo.setOrganizationId(iotOrganizeId);
+            qxDeviceInfo.setDeviceProfileId(iotDeviceProfileId);
+            qxDeviceInfo.setProfileId(iotProfileId);
+//            //项目状态（1：在线，2：离线，3：报警）
+//            Integer projectState = deviceInfoJson.getInteger("projectState");
+//            if (projectState != null) {
+//                qxDeviceInfo.setDescription(String.valueOf(projectState));
+//            }
+
+            //项目类型
+            qxDeviceInfo.setLabel("生产设备");
+            //设备名称
+            String deviceName = deviceNameList.get(index);
+
+            qxDeviceInfo.setName(deviceName);
+            qxDeviceInfo.setBrand(deviceName);
+            //序列号
+            String dtuSn = "AGT26320123" + String.format("%03d", index);
+            qxDeviceInfo.setSn(dtuSn);
+            DeviceToken deviceToken = new DeviceToken();
+            deviceToken.setCredentialsType("ACCESS_TOKEN");
+            deviceToken.setCredentialsId(dtuSn);
+            deviceToken.setCredentialsValue(dtuSn);
+            qxDeviceInfo.setDeviceToken(deviceToken);
+            qxDeviceInfos.add(qxDeviceInfo);
+            //有序列号直接获取灯信息
+            QxDeviceInfoDetail qxDeviceInfoDetail = new QxDeviceInfoDetail();
+            qxDeviceInfoDetail.setAlarm(false);
+            //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
+            Integer lampState = isWithinRange ? 3 : 0;
+            switch (lampState) {
+                case 0:
+                    qxDeviceInfoDetail.setStatus("OFF");
+                    break;
+                case 1:
+                    qxDeviceInfoDetail.setStatus("ERROR");
+                    qxDeviceInfoDetail.setAlarm(true);
+                    break;
+                case 2:
+                    qxDeviceInfoDetail.setStatus("STAND");
+                    break;
+                case 3:
+                    qxDeviceInfoDetail.setStatus("RUN");
+                    break;
+                default:
+                    continue;
+            }
+
+            qxDeviceInfoDetail.setStartTime(new Date());
+            qxDeviceInfoDetail.setDtuSn(dtuSn);
+            qxAddDeviceInfoDetails.add(qxDeviceInfoDetail);
+        }
+
+//        //将数据同步到IOT平台
+        Map<String, String> qxParam = new HashMap<>(2);
+        qxParam.put("username", iotUserName);
+        qxParam.put("password", iotPassword);
+
+        HttpPost qxHttpPost = new HttpPost(iotTokenUrl);
+        String qxResult = sendPost(qxHttpPost, JSON.toJSONString(qxParam));
+        if (StringUtils.isBlank(qxResult)) {
+            return;
+        }
+        Map<String, Object> qxRes = JSON.parseObject(qxResult, new TypeReference<Map<String, Object>>() {
+        });
+
+        String qxAccessToken = (String) qxRes.get("token");
+        if (StringUtils.isBlank(qxAccessToken)) {
+            return;
+        }
+
+        BasicHeader qxAuthorization = new BasicHeader("X-Authorization", "Bearer " + qxAccessToken);
+        if (!CollectionUtils.isEmpty(qxDeviceInfos)) {
+            HttpPost qxDeviceInfoPost = new HttpPost(iotDeviceInfoUrl);
+            qxDeviceInfoPost.addHeader(qxAuthorization);
+            for (QxDeviceInfo qxDeviceInfo : qxDeviceInfos) {
+                // todo
+                String syncDeviceInfo = sendPost(qxDeviceInfoPost, JSON.toJSONString(qxDeviceInfo));
+                //log.info("同步设备信息 syncDeviceInfo:{}", syncDeviceInfo);
+            }
+        }
+
+        if (!CollectionUtils.isEmpty(qxAddDeviceInfoDetails)) {
+            for (QxDeviceInfoDetail qxDeviceInfoDetail : qxAddDeviceInfoDetails) {
+                String qxDeviceInfoDetailUrlStr = iotDeviceDetailUrl + qxDeviceInfoDetail.getDtuSn() + "/telemetry";
+                HttpPost qxDeviceInfoDetailPost = new HttpPost(qxDeviceInfoDetailUrlStr);
+                qxDeviceInfoDetailPost.addHeader(qxAuthorization);
+                String syncDeviceInfoDetail = sendPost(qxDeviceInfoDetailPost, JSON.toJSONString(qxDeviceInfoDetail));
+            }
+        }
+    }
+
     public String getDeviceInfo() {
         String accessToken = getAccessToken();
         // 初始化headerMap并设置Authorization
--- a/src/main/java/com/iot/scheduler/service/wuwei/WWDeviceReportService.java 0 → 100644
View file @7ee8a0d
+++ b/src/main/java/com/iot/scheduler/service/wuwei/WWDeviceReportService.java 0 → 100644
View file @7ee8a0d
+package com.iot.scheduler.service.wuwei;
+
+import com.alibaba.fastjson.JSON;
+import com.iot.scheduler.model.ReportDevice;
+import com.iot.scheduler.utils.SqlTypedValueUtils;
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 无为设备属性上报
+ */
+@Service
+@Slf4j
+public class WWDeviceReportService {
+
+    @Value("${wuwei.third.domain:http://60.169.172.121:1804/report-property}")
+    private String reportUrl;
+
+    @Value("${wuwei.third.jdbcUrl:jdbc:postgresql://106.15.73.210:5433/thingskit}")
+    private String jdbcUrl;
+
+    @Value("${wuwei.third.jdbcUserName:postgres}")
+    private String jdbcUserName;
+
+    @Value("${wuwei.third.jdbcPassword:postgres}")
+    private String jdbcPassword;
+
+    @Value("${wuwei.third.selectSql:SELECT * FROM ts_kv_dictionary;}")
+    private String selectSql;
+
+    public void deviceReport() {
+        log.info("开始执行无为设备属性上报任务");
+        try {
+            List<Object> needSyncDataList = initConnectAndSelectData();
+            if (CollectionUtils.isEmpty(needSyncDataList)) {
+                log.info("没有需要上报的数据，任务结束");
+                return;
+            }
+
+            log.info("开始处理{}条设备数据并进行上报", needSyncDataList.size());
+            int successCount = 0;
+            int failCount = 0;
+
+            for (int i = 0; i < needSyncDataList.size(); i++) {
+                Object needSyncData = needSyncDataList.get(i);
+                try {
+                    List<Object> dataList = (ArrayList) needSyncData;
+                    String deviceId = dataList.get(0).toString();
+
+                    ReportDevice reportDevice = new ReportDevice();
+                    reportDevice.setDeviceId(deviceId);
+                    Map<String, Object> propertiesMap = new HashMap<>(4);
+
+                    String status = dataList.get(1).toString();
+                    if ("RUN".equals(status)) {
+                        propertiesMap.put("State_Run", 1);
+                        propertiesMap.put("State_PowerOn", 1);
+                        propertiesMap.put("State_Alarm", 0);
+                    } else if ("STAND".equals(status)) {
+                        propertiesMap.put("State_Run", 0);
+                        propertiesMap.put("State_PowerOn", 1);
+                        propertiesMap.put("State_Alarm", 0);
+                    } else if ("ERROR".equals(status)) {
+                        propertiesMap.put("State_Run", 0);
+                        propertiesMap.put("State_PowerOn", 1);
+                        propertiesMap.put("State_Alarm", 1);
+                    } else {
+                        propertiesMap.put("State_Run", 0);
+                        propertiesMap.put("State_PowerOn", 0);
+                        propertiesMap.put("State_Alarm", 0);
+                    }
+
+
+                    reportDevice.setProperties(propertiesMap);
+
+                    boolean sendResult = sendReportDevice(reportDevice);
+                    if (sendResult) {
+                        successCount++;
+                    } else {
+                        failCount++;
+                    }
+
+                } catch (Exception e) {
+                    failCount++;
+                    log.error("处理第{}条数据时发生异常，数据内容: {}", i + 1, needSyncData, e);
+                }
+            }
+
+            log.info("设备属性上报任务完成，成功: {}条，失败: {}条，总计: {}条",
+                    successCount, failCount, needSyncDataList.size());
+
+        } catch (Exception e) {
+            log.error("执行设备属性上报任务时发生异常", e);
+        } finally {
+            log.info("无为设备属性上报任务执行结束");
+        }
+    }
+
+    private boolean sendReportDevice(ReportDevice reportDevice) {
+        String deviceId = reportDevice.getDeviceId();
+
+        HttpPost httpPost = new HttpPost(reportUrl);
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        String requestBody = JSON.toJSONString(reportDevice);
+
+        StringEntity entity = new StringEntity(requestBody, ContentType.create("application/json", Consts.UTF_8));
+        httpPost.setEntity(entity);
+        httpPost.setHeader("Content-Type", "application/json;charset=UTF-8");
+
+        try (CloseableHttpResponse execute = httpClient.execute(httpPost)) {
+            int statusCode = execute.getStatusLine().getStatusCode();
+
+            HttpEntity res = execute.getEntity();
+            String responseBody = "";
+            if (res != null) {
+                try (InputStream is = res.getContent();
+                     ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()) {
+                    byte[] buf = new byte[128];
+                    int len;
+                    while ((len = is.read(buf)) != -1) {
+                        byteArrayOutputStream.write(buf, 0, len);
+                    }
+                    responseBody = byteArrayOutputStream.toString("UTF-8");
+                }
+            }
+
+            log.info("设备[{}]上报响应，状态码: {}，响应内容: {}", deviceId, statusCode, responseBody);
+
+            if (statusCode >= 200 && statusCode < 300) {
+                return true;
+            } else {
+                log.error("设备[{}]上报失败，HTTP状态码: {}，响应: {}", deviceId, statusCode, responseBody);
+                return false;
+            }
+
+        } catch (IOException e) {
+            log.error("设备[{}]上报请求发生IO异常", deviceId, e);
+            return false;
+        } finally {
+            try {
+                httpClient.close();
+            } catch (IOException e) {
+                log.error("关闭HTTP客户端时发生异常", e);
+            }
+        }
+    }
+
+    private List<Object> initConnectAndSelectData() {
+        Connection connection = null;
+        PreparedStatement statement = null;
+        ResultSet resultSet = null;
+        HikariDataSource dataSource = null;
+        List<Object> resultList = new ArrayList<>();
+
+        log.info("开始连接数据库，URL: {}", jdbcUrl);
+
+        try {
+            HikariConfig config = new HikariConfig();
+            config.setJdbcUrl(jdbcUrl);
+            config.setUsername(jdbcUserName);
+            config.setPassword(jdbcPassword);
+            config.setDriverClassName("org.postgresql.Driver");
+            config.setMaximumPoolSize(5);
+            config.setMinimumIdle(5);
+            config.setConnectionTimeout(60000);
+            config.setConnectionTestQuery("SELECT 1");
+
+            dataSource = new HikariDataSource(config);
+            log.info("Hikari连接池配置完成");
+
+            connection = dataSource.getConnection();
+            log.info("数据库连接成功");
+
+            statement = connection.prepareStatement(selectSql);
+            log.info("执行SQL查询: {}", selectSql);
+
+            resultSet = statement.executeQuery();
+            ResultSetMetaData metaData = resultSet.getMetaData();
+            int columnCount = metaData.getColumnCount();
+            log.info("查询结果集元数据获取成功，共{}列", columnCount);
+
+            int rowCount = 0;
+            while (resultSet.next()) {
+                List<Object> result = new ArrayList<>(columnCount);
+                for (int index = 1; index <= columnCount; index++) {
+                    int columnType = metaData.getColumnType(index);
+                    Object value = SqlTypedValueUtils.getTypedValue(resultSet, index, columnType);
+                    result.add(value);
+                }
+                resultList.add(result);
+                rowCount++;
+
+                // 每处理1000行记录一次日志
+                if (rowCount % 1000 == 0) {
+                    log.info("已处理{}行数据", rowCount);
+                }
+            }
+
+            log.info("数据查询完成，共获取{}行数据", rowCount);
+
+        } catch (SQLException e) {
+            log.error("数据库操作异常，URL: {}, 用户名: {}", jdbcUrl, jdbcUserName, e);
+        } catch (Exception e) {
+            log.error("初始化数据库连接或查询数据时发生异常", e);
+        } finally {
+            // 释放资源
+            try {
+                if (resultSet != null) resultSet.close();
+                if (statement != null) statement.close();
+                if (connection != null) connection.close();
+                log.info("数据库连接资源已释放");
+            } catch (SQLException e) {
+                log.error("关闭数据库资源时发生异常", e);
+            }
+
+            if (dataSource != null) {
+                try {
+                    dataSource.close();
+                    log.info("HikariDataSource连接池已关闭");
+                } catch (Exception e) {
+                    log.error("关闭HikariDataSource连接池时发生异常", e);
+                }
+            }
+        }
+
+        log.info("数据库操作完成，返回{}条记录", resultList.size());
+        return resultList;
+    }
+}
--- a/src/main/java/com/iot/scheduler/zone/WuweiZoneScheduler.java
View file @7ee8a0d
+++ b/src/main/java/com/iot/scheduler/zone/WuweiZoneScheduler.java
View file @7ee8a0d
 package com.iot.scheduler.zone;
-import com.iot.scheduler.service.PjDeviceReportService;
 import com.iot.scheduler.service.wuwei.JmDevicePullService;
+import com.iot.scheduler.service.wuwei.WWDeviceReportService;
 import com.iot.scheduler.task.AbstractZoneScheduler;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
@@ -17,6 +17,8 @@ public class WuweiZoneScheduler extends AbstractZoneScheduler {
     @Resource
     private JmDevicePullService jmDevicePullService;
+    @Resource
+    private WWDeviceReportService wwDeviceReportService;
     @Override
     protected String getZoneName() {
@@ -31,6 +33,7 @@ public class WuweiZoneScheduler extends AbstractZoneScheduler {
             // TODO: Implement actual logic
             log.info("[{}] Simulating pulling devices...", getZoneName());
             jmDevicePullService.pullDeviceAndPushToIot();
+            jmDevicePullService.pullCreateDeviceInfo();
             Thread.sleep(1000);
         } catch (Exception e) {
             logError(taskName, e);
@@ -45,7 +48,7 @@ public class WuweiZoneScheduler extends AbstractZoneScheduler {
         logStart(taskName);
         try {
             log.info("[{}] PJ pushing devices...", getZoneName());
-//            pjDeviceReportService.batchReportEnterprise();
+            wwDeviceReportService.deviceReport();
             Thread.sleep(1000);
         } catch (Exception e) {
             logError(taskName, e);
--- a/src/main/resources/application.yml
View file @7ee8a0d
+++ b/src/main/resources/application.yml
View file @7ee8a0d
@@ -142,6 +142,44 @@ pj:
                   de.tenant_id = '0414df80-f01d-11f0-9cb8-e3376d1e7978'
                   AND de.device_profile_id = '0418b010-f01d-11f0-9cb8-e3376d1e7978';"
+wuwei:
+  third:
+    domain: "http://60.169.172.121:1804/report-property"
+    jdbcUrl: "jdbc:postgresql://106.15.73.210:5433/thingskit"
+    jdbcUserName: "postgres"
+    jdbcPassword: "postgres"
+    selectSql: "SELECT
+  dc.credentials_id AS sn,
+  CASE
+    WHEN ak2.long_v IS NULL OR (ak.bool_v = FALSE AND ak2.long_v IS NOT NULL) THEN 'OFF'
+    WHEN tkl.long_v = 1 THEN 'RUN'
+    ELSE 'STAND'
+  END AS status
+FROM
+  device de
+  LEFT JOIN attribute_kv ak ON de.id = ak.entity_id
+  AND ak.entity_type = 'DEVICE'
+  AND ak.attribute_key = 'active'
+  LEFT JOIN attribute_kv ak2 ON de.id = ak2.entity_id
+  AND ak2.entity_type = 'DEVICE'
+  AND ak2.attribute_key = 'lastActivityTime'
+  LEFT JOIN ts_kv_latest tkl ON de.id = tkl.entity_id
+  AND KEY = '525'
+  LEFT JOIN device_credentials dc ON de.id = dc.device_id
+WHERE
+  de.device_profile_id = '091b8450-00cd-11f1-9cb8-e3376d1e7978'
+  UNION ALL
+SELECT
+  dc.credentials_id as sn,
+  tkl.str_v AS status
+FROM
+  device de
+  LEFT JOIN device_credentials dc ON de.id = dc.device_id
+  LEFT JOIN ts_kv_latest tkl ON de.id = tkl.entity_id
+  AND KEY = 61
+WHERE
+  de.device_profile_id = 'e717b260-025d-11f1-9cb8-e3376d1e7978'"
+
 sh:
   iot:
     organizeId: "f82530a0-93e4-4aeb-9339-f5b6d1127840"