EventTemplate控制器编写

pqs-common/common-influxdb/src/test/java/DataTest.java

@@ -353,4 +353,27 @@ public class DataTest {
         influxDBUtil.batchInsert("test", "", ConsistencyLevel.ALL, TimeUnit.MILLISECONDS, records);
     }
 
+    public static void batchInsertPqsCommunicate(InfluxDbUtils influxDBUtil) {
+        Map<String, String> tags = new HashMap<>();
+        tags.put("line_id", "025fa0e4c91f72ad7f1c1bd29026f20a");
+
+
+        Map<String, Object> fields = new HashMap<>();
+        fields.put("description", "在线");
+        fields.put("type", 1);
+
+        influxDBUtil.insert("pqs_communicate", tags, fields, System.currentTimeMillis()-170000000, TimeUnit.MILLISECONDS);
+
+        Map<String, String> tags1 = new HashMap<>();
+        tags1.put("line_id", "025fa0e4c91f72ad7f1c1bd29026f20a");
+
+
+        Map<String, Object> fields1 = new HashMap<>();
+        fields1.put("description", "掉线");
+        fields1.put("type", 0);
+
+        influxDBUtil.insert("pqs_communicate", tags1, fields1, System.currentTimeMillis()-70000000, TimeUnit.MILLISECONDS);
+    }
+
+
 }