From a0d0ad8de7ac244aa29d1ca84d13b90e74729e33 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 19 Oct 2020 13:16:04 +0800
Subject: [PATCH] 增加获取六参五分钟平均值接口
---
src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java b/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
index 9b42ef0..12e9cb8 100644
--- a/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
+++ b/src/main/java/com/moral/webSocketServer/BSTestWebsocketServer.java
@@ -24,15 +24,15 @@
import java.util.concurrent.ConcurrentHashMap;
@Slf4j
-@ServerEndpoint("/web/testWebSocket/{param}")
+@ServerEndpoint("/web/WebSocket/{param}")
@Component
-/**
+/**
* @Description: ���������������websocket
- * @Param:
- * @return:
+ * @Param:
+ * @return:
* @Author: ������������
* @Date: 2020/9/30
- */
+ */
public class BSTestWebsocketServer {
public static DeviceService deviceService;
@@ -116,17 +116,17 @@
channel.basicConsume(queue, false, new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
- //������MQ������������������������������������������������������������
+ //������MQ������������������������������������������������������������
Map message = (Map) JSON.parse((String) JSON.parse(new String(body)));
sendWindInfo(message);
-
+
//���������������������������������������mac���������������������������������mac������������
if(mac!=null&&(!mac.equals(0)))
sendDeviceInfo(message,deviceMap);
-
+
//������������
channel.basicAck(envelope.getDeliveryTag(), true);
-
+
//������socket������������������
if (!webSocketMap.containsKey(accountId)) {
RabbitMQUtils.closeConnectionChannel(connection, channel);
@@ -171,13 +171,13 @@
}
}
- /**
+ /**
* @Description: ���������������������socket���������������������������������
* @Param: [param]
* @return: void
* @Author: ���������
* @Date: 2020/9/30
- */
+ */
private void sendWindInfo(Map<String, Object> param) {
try {
Map<String, Object> map = new HashMap<>();
@@ -191,13 +191,13 @@
}
}
- /**
+ /**
* @Description: ������������mac������accountid���������������������mac������������������
* @Param: [param]
* @return: void
* @Author: ���������
* @Date: 2020/9/30
- */
+ */
private void sendDeviceInfo(Map<String, Object> param,Map<String,Device> deviceMap) {
String deviceMac = (String) param.get("mac");
if (mac.equals(deviceMac)) {
--
Gitblit v1.8.0