From 3b20c91323abd42512a45a8796871a81454f53b8 Mon Sep 17 00:00:00 2001
From: cuikaidong <ckd2942379034@163.com>
Date: 星期五, 29 八月 2025 09:54:58 +0800
Subject: [PATCH] 设备单表设备编号处理
---
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java | 17 +----------------
1 files changed, 1 insertions(+), 16 deletions(-)
diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java
index b6bfba0..810ca82 100644
--- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java
+++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java
@@ -91,7 +91,6 @@
// 鑾峰彇褰撳墠鏃堕棿
LocalDateTime now = LocalDateTime.now();
// 鍑忓幓涓�鍒嗛挓
-// LocalDateTime oneMinuteAgo = now.minusMinutes(1);
LocalDateTime oneMinuteAgo = now.minusSeconds(2);
// 鏍煎紡鍖栦负瀛楃涓诧紙鍙�夛級
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
@@ -109,22 +108,9 @@
LocalDateTime endTime = LocalDateTime.parse(end.get(), inputFormatter);
// 瀹氫箟鏃ユ湡鏃堕棿鏍煎紡鍣紙ISO_LOCAL_DATE_TIME 瀵瑰簲 "yyyy-MM-ddTHH:mm:ss"锛�
DateTimeFormatter formatter1 = DateTimeFormatter.ISO_LOCAL_DATE_TIME;
-
- // 瑙ｆ瀽瀛楃涓蹭负 LocalDateTime 瀵硅薄
- LocalDateTime startDateTime = LocalDateTime.parse(startTime.toString(), formatter1);// 瑙ｆ瀽瀛楃涓蹭负 LocalDateTime 瀵硅薄
- LocalDateTime endDateTime = LocalDateTime.parse(endTime.toString(), formatter1);
-
- // 鍔犱笂 8 灏忔椂
- LocalDateTime startNewDateTime = startDateTime.minusHours(8);
- LocalDateTime endNewDateTime = endDateTime.minusHours(8);
-// String query = "from(bucket: \"IOT\") \n" +
-// "|> range(start: "+startNewDateTime+"Z, stop: "+endNewDateTime+"Z) \n" +
-// "|> fill(usePrevious: true) \n" +
-// "|> filter(fn: (r) => r[\"_field\"] == \"TimeStamp\" or r[\"_field\"] == \"Value\")";
String query = "from(bucket: \"" + influxBucket + "\") " +
"|> range(start: -5s) " +
"|> filter(fn: (r) => r[\"_field\"] == \"TimeStamp\" or r[\"_field\"] == \"Value\")";
-
// 鎵ц鏌ヨ
try {
List<FluxTable> tables = queryApi.query(query, influxOrg);
@@ -158,7 +144,6 @@
)),
Collectors.toList()
));
-
// 澶勭悊璁惧鐘舵��
int lastIndex = table.lastIndexOf('.');
String code = table.substring(lastIndex + 1);
@@ -212,7 +197,7 @@
values[influxdbList.size() + 1] = dateTime;
int index = tableName.indexOf("_");
if (index != -1) {
- values[influxdbList.size()] = tableName.substring(0, index);
+ values[influxdbList.size()] = tableName.substring(index + 1);
}
if (databaseType.equals("SqlServer")) {
equipmentService.insertSqlServerData(tableName, columns, values);
--
Gitblit v1.9.3