From 5a6a6c94d0c02732e0be3410d126d652acb8ad10 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 11 三月 2026 08:46:44 +0800
Subject: [PATCH] 1
---
component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java | 6 ++----
1 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java b/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
index bb79b77..14f96b2 100644
--- a/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
+++ b/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
@@ -29,8 +29,6 @@
@Autowired
private InfluxDBClient influxDBClient;
-
-
/**
* 鍐欏叆鏁版嵁
*
@@ -38,11 +36,11 @@
* @param tags 鏍囩
* @param fields 瀛楁
*/
- public void writeData(String measurement, Map<String, String> tags, Map<String, Object> fields) {
+ public void writeData(String measurement, Map<String, String> tags, Map<String, Object> fields,Long timestamp) {
Point point = Point.measurement(measurement)
.setTags(tags)
.setFields(fields)
- .setTimestamp(Instant.now().toEpochMilli(), WritePrecision.MS);
+ .setTimestamp(timestamp, WritePrecision.MS);
try {
influxDBClient.writePoint(point);
} catch (Exception e) {
--
Gitblit v1.9.1