用户心跳调整，解除冲突

zengh

2021-03-25 11538d6abad42153bc022425be53de11506ecf27

用户心跳调整，解除冲突

 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());
        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,6 +98,8 @@
        }
        // 返回应答消息
        String request = ((TextWebSocketFrame) frame).text();

        if (!request.equals("ping")){
        //把用户信息添加到通道里
        ChannelSupervise.addChannel(ctx.channel(),request);
        //用户在线状态
@@ -104,8 +108,6 @@
        String num="1";
        //工作状态(0闲置，1工作中)
        String workSt = "0";

        if (!request.equals("ping")){
            webSocketHandler.suserService.updateUser(num,request,workSt);
        }