package com.qianwen.mdc.collect.controller;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Set;
|
|
import org.apache.iotdb.rpc.IoTDBConnectionException;
|
import org.apache.iotdb.rpc.StatementExecutionException;
|
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.qianwen.mdc.collect.config.IotDBSessionConfig;
|
import com.qianwen.mdc.collect.mqtt.MqttMessageSender;
|
import com.qianwen.mdc.collect.service.IOTMqttReceiveService;
|
import com.qianwen.mdc.collect.service.IotDBCommonService;
|
|
@RestController
|
public class MqttController {
|
@Autowired
|
private MqttMessageSender mqttMessageSender;
|
@Autowired
|
private IOTMqttReceiveService recService;
|
@Autowired
|
private IotDBSessionConfig iotdbCfg;
|
|
@Autowired
|
private IotDBCommonService iotService;
|
|
@GetMapping("/send")
|
public String send(@RequestParam String topic, @RequestParam String message) {
|
mqttMessageSender.sendMessage(topic, message);
|
return "Message sent to topic " + topic;
|
}
|
|
|
@GetMapping("/rec2")
|
public void testRec2() {
|
//数据格式：{"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174是应用id
|
//多条格式：{"174":[{"values":{"DeviceStatus":2},"ts":"1722478128278"},{"values":{"spindleSpeed":22},"ts":"1722478128281"}]}
|
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("/recalarm")
|
public void testAlarm() {
|
//数据格式：{"174":[{"values":{"d1":12},"ts":"1721978780449"}]} 174是应用id
|
//多条格式：{"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.*");
|
System.out.print(b);
|
List<String> list = iotdbCfg.getSessionPool().showPathsTemplateUsingOn(tplname);
|
|
//root.f2.output_22009
|
System.out.print(iotdbCfg.getSessionPool().showMeasurementsInTemplate(tplname));
|
|
return list;
|
}
|
@GetMapping("/tpluse")
|
public Object tpluse(String tplname,String path) throws StatementExecutionException, IoTDBConnectionException {
|
return iotService.isTemplateSetOnPath(tplname, path);
|
|
}
|
|
@GetMapping("/tpluse2")
|
public Object tpluse2(String tplname,String path) throws StatementExecutionException, IoTDBConnectionException {
|
return iotdbCfg.getSessionPool().showPathsTemplateSetOn(tplname);
|
|
}
|
|
|
|
|
}
|
