amos-boot-module-jxiop-monitor-bize 支持influxdb

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/pom.xml

@@ -32,9 +32,10 @@
           <scope>compile</scope>
       </dependency>
       <dependency>
-          <groupId>org.springframework.boot</groupId>
-          <artifactId>spring-boot-starter-activemq</artifactId>
-          <version>2.5.4</version>
+          <groupId>com.yeejoin</groupId>
+          <artifactId>amos-component-influxdb</artifactId>
+          <version>1.8.5-SNAPSHOT</version>
+          <scope>compile</scope>
       </dependency>
   </dependencies>
   

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/DemoController.java

@@ -8,8 +8,10 @@ import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.Test;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.StationBasicServiceImpl;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.TestServiceImpl;
+import com.yeejoin.amos.component.influxdb.InfluxDbConnection;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.influxdb.dto.QueryResult;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
@@ -32,18 +34,38 @@ public class DemoController extends BaseController {
     @Autowired
     StationBasicMapper stationBasicMapper;
 
+    @Autowired
+    InfluxDbConnection influxDbConnection;
+
 
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
-    @ApiOperation(value = "demo测试")
+    @ApiOperation(value = "demo测试prodcutcion 库")
     @GetMapping("/test")
     public StationBasic demoTest() {
         return stationBasicServiceimpl.getById(1660231556607774721L);
     }
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
-    @ApiOperation(value = "demo测试1")
+    @ApiOperation(value = "demo测试中间库")
     @GetMapping("/test1")
     public List<Test> demoTest1() {
         return testServiceimpl.getList();
     }
-
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "demo测试influxdb")
+    @GetMapping("/test3")
+    public void demoTest2() {
+        QueryResult query =influxDbConnection.query("select * from iot_data  where time> now()-1s");
+        List<QueryResult.Result >  queryResults=query.getResults();
+        for (int i = 0; i <queryResults.size() ; i++) {
+           QueryResult.Result  result = queryResults.get(i);
+          List list =result.getSeries();
+            for (int j = 0; j <list.size() ; j++) {
+                QueryResult.Series series  = (QueryResult.Series) list.get(j);
+                System.out.println(series.getName());
+                System.out.println(series.getColumns());
+                System.out.println(series.getValues());
+                System.out.println(series.getTags());
+            }
+        }
+    }
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/resources/application-dev.properties

@@ -108,16 +108,16 @@ emqx.password=a123456
 emqx.max-inflight=1000
 
 
-spring.influx.url=http://39.98.246.31:8086
-spring.influx.password=Yeejoin@2020
-spring.influx.user=root
+# influxDB
+spring.influx.url= http://139.9.170.47:8086
+spring.influx.password=admin
+spring.influx.user=admin
 spring.influx.database=iot_platform
 spring.influx.retention_policy=default
 spring.influx.retention_policy_time=30d
 spring.influx.actions=10000
 spring.influx.bufferLimit=20000
 
-
 knife4j.production=false
 knife4j.enable=true
 knife4j.basic.enable=true