用户心跳调整，解除冲突

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());
        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);
        }