From 312fd03ae1ee528892129a10630d44de92c73c37 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 05 九月 2024 11:41:20 +0800
Subject: [PATCH] 增加告警信息入库
---
collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java | 23 ++++++++++-------------
1 files changed, 10 insertions(+), 13 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java b/collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java
index 31b7bf5..256c604 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java
@@ -36,19 +36,7 @@
return "Message sent to topic " + topic;
}
- @GetMapping("/create")
- public String create(@RequestParam String topic, @RequestParam String message) {
- try {
- iotdbCfg.getSessionPool().createTimeseries("root.f2.myt1", TSDataType.UNKNOWN, null, null);
- } catch (IoTDBConnectionException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (StatementExecutionException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- return "Message sent to topic " + topic;
- }
+
@GetMapping("/rec2")
public void testRec2() {
//鏁版嵁鏍煎紡锛歿"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174鏄簲鐢╥d
@@ -59,6 +47,15 @@
}
+ @GetMapping("/recalarm")
+ public void testAlarm() {
+ //鏁版嵁鏍煎紡锛歿"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174鏄簲鐢╥d
+ //澶氭潯鏍煎紡锛歿"174":[{"values":{"DeviceStatus":2},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
+ String payload = "{\"174\":[{\"values\":{\"Alarm\":\"鍛婅淇℃伅1\"},\"ts\":\"1725504995056\"}]}";
+ //payload = "{\"174\":[{\"values\":{\"Output\":11},\"ts\":\"1722478128278\"},{\"values\":{\"SpindleSpeed\":22},\"ts\":\"1722478128281\"}]}";
+ recService.handle(payload);
+ }
+
@GetMapping("/tpl")
public Object tpl(String tplname) throws StatementExecutionException, IoTDBConnectionException {
boolean b = iotdbCfg.getSessionPool().checkTimeseriesExists("root.f2.output_22005.*");
--
Gitblit v1.9.3