From 9a9b747962cc00801d8cce4137d1e123d556a79b Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 02 十一月 2024 16:59:59 +0800
Subject: [PATCH] 修复iotdb大批插入数据问题
---
collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java | 19 -------------------
1 files changed, 0 insertions(+), 19 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 3246a2f..be25cb6 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
@@ -26,8 +26,6 @@
@Autowired
private PackedDataService packedDataService;
@Autowired
- private RedisUtil redisUtil;
- @Autowired
private WorkstationDatapointsService dpService;
/**
* 澶勭悊鏀跺埌鐨勬秷鎭�,瀵瑰簲TelemetryDataPostingConsumer
@@ -108,21 +106,4 @@
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(StringUtils.EMPTY));
- if(ObjectUtil.isEmpty(workstationId)) {
- return null;
- }
- return Long.parseLong(workstationId);
- }
- */
}
--
Gitblit v1.9.3