From 21f93fe6b95e868659bc1af9658a0cd7ba43b203 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 26 May 2021 20:15:20 +0800 Subject: [PATCH] Merge branch 'otc' of http://120.27.238.55:7000/r/exchange into otc --- src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java | 21 ++++++++++++--------- 1 files changed, 12 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java b/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java index 7fb6fa9..875461a 100644 --- a/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java +++ b/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java @@ -1,9 +1,13 @@ package com.xcong.excoin.netty.logic.impl; +import cn.hutool.core.util.StrUtil; import com.xcong.excoin.netty.bean.RequestBean; +import com.xcong.excoin.netty.common.ChannelManager; import com.xcong.excoin.netty.common.Contans; +import com.xcong.excoin.netty.common.NettyTools; import com.xcong.excoin.netty.logic.MsgLogic; import com.xcong.excoin.netty.logic.WebSocketLogic; +import io.netty.channel.Channel; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -20,16 +24,15 @@ @Override public void webSocketMsgLogic(RequestBean requestBean) { -// switch (requestBean.getType()) { -// case Contans.WEB_REQ_CONNECTION : -// webSocketLogic.webReqConnection(requestBean); -// break; + + switch (requestBean.getType()) { + case Contans.AUTH_CHECK: + webSocketLogic.authCheck(requestBean); + break; // case Contans.HOME_SYMBOLS: -// webSocketLogic.reqHomeSymbols(requestBean); -// default: -// webSocketLogic.defaultReq(requestBean); -// break; -// } + default: + break; + } } -- Gitblit v1.9.1