From fd13128c1f57fca80a731833ef9e52b5c2c8af11 Mon Sep 17 00:00:00 2001
From: nnnjjj123 <494715143@qq.com>
Date: Sun, 10 Jan 2021 15:36:12 +0800
Subject: [PATCH] 1.布撤防接口
---
src/main/java/org/springblade/modules/Netty/controller/nettyController.java | 38 ++++++++++++++++++++++++++++++++++++++
1 files changed, 38 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/Netty/controller/nettyController.java b/src/main/java/org/springblade/modules/Netty/controller/nettyController.java
index 8ca2ba0..a049dcb 100644
--- a/src/main/java/org/springblade/modules/Netty/controller/nettyController.java
+++ b/src/main/java/org/springblade/modules/Netty/controller/nettyController.java
@@ -183,4 +183,42 @@
}
}
+
+
+ /**
+ * 对单个设备进行布防
+ */
+ @PostMapping("/selectNettyChannelOb")
+ @ApiOperationSupport(order = 10)
+ public R selectNettyChannelOb(String deviceNumber,HttpServletResponse response) {
+ response.setHeader("Access-Control-Allow-Origin", "*");
+ response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");
+ response.setHeader("Access-Control-Allow-Credentials","true");
+ ConcurrentHashMap<String, Channel> channelHashMap = ChannelMap.getChannelHashMap();
+ List<String> outData = new ArrayList<>();
+ outData.add("LC8109085B#@");
+ Channel channel = channelHashMap.get(deviceNumber);
+ channel.writeAndFlush(Unpooled.copiedBuffer(outData.get(0), CharsetUtil.UTF_8));
+ return R.success("设备布防");
+
+ }
+
+ /**
+ * 对单个设备进行撤防
+ */
+ @PostMapping("/selectNettyChannelOc")
+ @ApiOperationSupport(order = 11)
+ public R selectNettyChannelOc(String deviceNumber,HttpServletResponse response) {
+ response.setHeader("Access-Control-Allow-Origin", "*");
+ response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");
+ response.setHeader("Access-Control-Allow-Credentials","true");
+ ConcurrentHashMap<String, Channel> channelHashMap = ChannelMap.getChannelHashMap();
+ List<String> outData = new ArrayList<>();
+ outData.add("LC8109085C#@");
+ Channel channel = channelHashMap.get(deviceNumber);
+ channel.writeAndFlush(Unpooled.copiedBuffer(outData.get(0), CharsetUtil.UTF_8));
+ return R.success("设备撤防");
+
+ }
+
}
--
Gitblit v1.9.3