预警时间分布接口新增

Administrator

2021-04-07 eb3440d7c0c7baef5e6fc888fd0076b1787643d9

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/webscoket/WebSocketHandler.java

@@ -64,11 +64,13 @@
      System.out.println("客户端断开连接：" + ctx.channel());
      //用户离线状态
      String name = ChannelSupervise.findName(ctx.channel().id().asShortText());
      String num="0";
      //工作状态(0闲置，1工作中)
      String workSt = "0";
      webSocketHandler.suserService.updateUser(num,name,workSt);
      ChannelSupervise.removeChannel(ctx.channel());
      if ( name != null &&!name.equals("ping") ){
         String num="0";
         //工作状态(0闲置，1工作中)
         String workSt = "0";
         webSocketHandler.suserService.updateUser(num,name,workSt);
         ChannelSupervise.removeChannel(ctx.channel());
      }
   }

   @Override
@@ -96,16 +98,16 @@
      }
      // 返回应答消息
      String request = ((TextWebSocketFrame) frame).text();
      //把用户信息添加到通道里
      ChannelSupervise.addChannel(ctx.channel(),request);
      //用户在线状态
      this.on=request;
      //在线状态（0掉线，1在线）
      String num="1";
      //工作状态(0闲置，1工作中)
      String workSt = "0";

      if (!request.equals("ping")){
         //把用户信息添加到通道里
         ChannelSupervise.addChannel(ctx.channel(),request);
         //用户在线状态
         this.on=request;
         //在线状态（0掉线，1在线）
         String num="1";
         //工作状态(0闲置，1工作中)
         String workSt = "0";
         webSocketHandler.suserService.updateUser(num,request,workSt);
      }