1.2.7:

时序数据库influxdb模块初始版本

ruoyi-modules/hwmom-tsdb/src/main/java/org/dromara/tsdb/controller/InfluxDbController.java

@@ -1,5 +1,6 @@
 package org.dromara.tsdb.controller;
 
+import org.dromara.tsdb.domain.bo.InfluxMeasurementBo;
 import org.dromara.tsdb.service.IInfluxDbService;
 import org.influxdb.dto.QueryResult;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,12 +17,8 @@ public class InfluxDbController {
      * 写入数据到InfluxDB
      */
     @PostMapping("/write")
-    public String writeData(@RequestParam String measurement,
+    public String writeData(@RequestBody InfluxMeasurementBo influxMeasurementBo) {
-                            @RequestParam String tagKey,
+        influxDbService.writeData(influxMeasurementBo);
-                            @RequestParam String tagValue,
-                            @RequestParam String fieldKey,
-                            @RequestParam String fieldValue) {
-        influxDbService.writeData(measurement, tagKey, tagValue, fieldKey, fieldValue);
         return "Data written to InfluxDB successfully!";
     }
 

ruoyi-modules/hwmom-tsdb/src/main/java/org/dromara/tsdb/domain/bo/InfluxMeasurementBo.java

@@ -0,0 +1,23 @@
+package org.dromara.tsdb.domain.bo;
+
+import lombok.Data;
+
+@Data
+public class InfluxMeasurementBo {
+
+     /** @param measurement 表名
+     * @param tagKey      标签键
+     * @param tagValue    标签值
+     * @param fieldKey    字段键
+     * @param fieldValue  字段值*/
+    private String measurement;
+
+    private String tagKey;
+
+    private String tagValue;
+
+    private String fieldKey;
+
+    private String fieldValue;
+
+}

ruoyi-modules/hwmom-tsdb/src/main/java/org/dromara/tsdb/service/IInfluxDbService.java

@@ -1,18 +1,14 @@
 package org.dromara.tsdb.service;
 
+import org.dromara.tsdb.domain.bo.InfluxMeasurementBo;
 import org.influxdb.dto.QueryResult;
 
 public interface IInfluxDbService {
     /**
      * 写入数据到InfluxDB
-     *
+     * @param influxMeasurementBo
-     * @param measurement 表名
-     * @param tagKey      标签键
-     * @param tagValue    标签值
-     * @param fieldKey    字段键
-     * @param fieldValue  字段值
      */
-    public void writeData(String measurement, String tagKey, String tagValue, String fieldKey, String fieldValue);
+    public void writeData(InfluxMeasurementBo influxMeasurementBo);
 
     /**
      * 查询数据

ruoyi-modules/hwmom-tsdb/src/main/java/org/dromara/tsdb/service/impl/InfluxDbServiceImpl.java

@@ -1,5 +1,6 @@
 package org.dromara.tsdb.service.impl;
 
+import org.dromara.tsdb.domain.bo.InfluxMeasurementBo;
 import org.dromara.tsdb.service.IInfluxDbService;
 import org.influxdb.InfluxDB;
 import org.influxdb.dto.Point;
@@ -18,18 +19,13 @@ public class InfluxDbServiceImpl implements IInfluxDbService {
 
     /**
      * 写入数据到InfluxDB
-     *
+     * @param influxMeasurementBo
-     * @param measurement 表名
-     * @param tagKey      标签键
-     * @param tagValue    标签值
-     * @param fieldKey    字段键
-     * @param fieldValue  字段值
      */
     @Override
-    public void writeData(String measurement, String tagKey, String tagValue, String fieldKey, String fieldValue) {
+    public void writeData(InfluxMeasurementBo influxMeasurementBo) {
-        Point point = Point.measurement(measurement)
+        Point point = Point.measurement(influxMeasurementBo.getMeasurement())
-            .tag(tagKey, tagValue)
+            .tag(influxMeasurementBo.getTagKey(), influxMeasurementBo.getTagValue())
-            .addField(fieldKey, fieldValue)
+            .addField(influxMeasurementBo.getFieldKey(), influxMeasurementBo.getFieldValue())
             .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
             .build();
         influxDB.write(point);