From a33c33d48c2c16995130b825355b6883be4eb159 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期一, 02 九月 2024 15:26:41 +0800
Subject: [PATCH] 加入定时任务，启动时打固定点 ，并且加入工位数据缓存
---
collect/src/main/java/com/qianwen/mdc/collect/controller/MqttController.java | 31 ++-----------------------------
1 files changed, 2 insertions(+), 29 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 c6034a2..31b7bf5 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
@@ -53,38 +53,11 @@
public void testRec2() {
//鏁版嵁鏍煎紡锛歿"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174鏄簲鐢╥d
//澶氭潯鏍煎紡锛歿"174":[{"values":{"DeviceStatus":2},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
- String payload = "{\"174\":[{\"values\":{\"DeviceStatus\":2,\"Output\":34},\"ts\":\"1723709061525\"}]}";
+ String payload = "{\"174\":[{\"values\":{\"DeviceStatus\":2,\"Output\":34},\"ts\":\"1725247557768\"}]}";
//payload = "{\"174\":[{\"values\":{\"Output\":11},\"ts\":\"1722478128278\"},{\"values\":{\"SpindleSpeed\":22},\"ts\":\"1722478128281\"}]}";
recService.handle(payload);
}
- @GetMapping("/rec")
- public void testRec() {
- ////鏁版嵁鏍煎紡锛歿"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174鏄簲鐢╥d
- //澶氭潯鏍煎紡锛歿"174":[{"values":{"output":11},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
- String payload = "{\"174\":[{\"values\":{\"output\":12},\"ts\":\"1721978780449\"}]}";
-
- JSONObject jsonObj = JSONObject.parseObject(payload);
- //鏁版嵁鏍煎紡锛歿"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174鏄簲鐢╥d
- Set<String> keys = jsonObj.keySet();
- String appId = keys.toArray(new String[] {})[0];
- JSONArray dtArr = jsonObj.getJSONArray(appId);
- JSONObject data = dtArr.getJSONObject(0);
- long time = data.getLong("ts");
- String output = data.getJSONObject("values").getString("output");
- //AggrgateData ad = recService.fillFactoryData(payload);
-
- List<String> fields = new ArrayList<>();
- List<String> values = new ArrayList<>();
- //long time = System.currentTimeMillis();
- fields.add("output");
- fields.add("factory_year");
- fields.add("factory_month");
- fields.add("factory_date");//INT64, INT64,factory_date INT64,factory_week
- values.add(output);
-
-
- //iotdbCfg.insertRecord("root.qa.myoutput_"+ad.getWorkstationId(), time, fields, values);
- }
+
@GetMapping("/tpl")
public Object tpl(String tplname) throws StatementExecutionException, IoTDBConnectionException {
--
Gitblit v1.9.3