From 910131c0e5271f018c516480cfd926f8660d2dbb Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 04 九月 2024 10:22:10 +0800
Subject: [PATCH] 整理代码格式
---
collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java | 11 ++++++++---
1 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java b/collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java
index 7e6925a..5b16ccd 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java
@@ -27,12 +27,12 @@
@Autowired
private RedisUtil redisUtil;
/**
- * 澶勭悊鏀跺埌鐨勬秷鎭�
+ * 澶勭悊鏀跺埌鐨勬秷鎭�,瀵瑰簲TelemetryDataPostingConsumer
* @param payload
*/
public void handle(String payload) {
//System.out.println("Received message122: " + payload);
- //瑙ｆ瀽娑堟伅鏈�
+ //瑙ｆ瀽娑堟伅
List<TelemetryData> teleList = parsePayload(payload);
collectDataService.handleCollectData(teleList);
@@ -86,10 +86,15 @@
return dtList;
}
+ /**
+ * 鏍规嵁瀵瑰簲琛ㄧ紦瀛橈紝鑾峰彇appId瀵瑰簲鐨刬d
+ * @param appId
+ * @return
+ */
public long getWorkstationIdByAppId(String appId) {
Object wid = redisUtil.hget("workstation-appid-map", appId);
- String workstationId = String.valueOf(Optional.ofNullable(wid).orElse("-1"));
+ String workstationId = String.valueOf(Optional.ofNullable(wid).orElse(appId));
return Long.parseLong(workstationId);
}
--
Gitblit v1.9.3