客户列表接口修改

zengh

2021-01-11 2087f91e1c5d3f0c489aa6017017256e354e3500

 src/main/java/org/springblade/modules/Netty/controller/nettyController.java

@@ -140,7 +140,7 @@
      response.setHeader("Access-Control-Allow-Credentials","true");
      ConcurrentHashMap<String, Channel> channelHashMap = ChannelMap.getChannelHashMap();
      System.out.println(channelHashMap);
      String s = catalogService.selectCatalogEqNUmber(pid);
      String s = "";
      if (s==null){
         return R.success("暂无设备布防");
      }
@@ -167,7 +167,7 @@
      response.setHeader("Access-Control-Allow-Credentials","true");
      ConcurrentHashMap<String, Channel> channelHashMap = ChannelMap.getChannelHashMap();
      System.out.println(channelHashMap);
      String s = catalogService.selectCatalogEqNUmber(pid);
      String s = "";
      if (s==null){
         return R.success("暂无设备撤防");
      }
@@ -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("设备撤防");

   }

}