[Feat]提供乘客屏注册sn到司机屏的接口

This commit is contained in:
chenfufeng
2022-05-17 17:37:21 +08:00
parent ed32517ecf
commit 7c4a07efee
4 changed files with 23 additions and 12 deletions

View File

@@ -36,26 +36,26 @@ PASSWORD=xintai2018
RELEASE=true
# AI CLOUD 云平台
# 工具类
MOGO_UTILS_VERSION=1.3.55
MOGO_UTILS_VERSION=1.3.56
# 网络请求
MOGO_NETWORK_VERSION=1.3.55
MOGO_NETWORK_VERSION=1.3.56
# 网络DNS
MOGO_HTTPDNS_VERSION=1.3.55
MOGO_HTTPDNS_VERSION=1.3.56
# 鉴权
MOGO_PASSPORT_VERSION=1.3.55
MOGO_PASSPORT_VERSION=1.3.56
# 常链接
MOGO_SOCKET_VERSION=1.3.55
MOGO_SOCKET_VERSION=1.3.56
# 数据采集
MOGO_REALTIME_VERSION=1.3.55
MOGO_REALTIME_VERSION=1.3.56
# 探路,道路事件发布,获取
MOGO_TANLU_VERSION=1.3.55
MOGO_TANLU_VERSION=1.3.56
# 直播推流
MOGO_LIVE_VERSION=1.3.55
MOGO_LIVE_VERSION=1.3.56
# 直播拉流
MOGO_TRAFFICLIVE_VERSION=1.3.55
MOGO_TRAFFICLIVE_VERSION=1.3.56
# 定位服务
MOGO_LOCATION_VERSION=1.3.55
MOGO_LOCATION_VERSION=1.3.56
# 远程通讯模块
MOGO_TELEMATIC_VERSION=1.3.55
MOGO_TELEMATIC_VERSION=1.3.56
# v2x
MOGO_V2X_VERSION=1.3.55
MOGO_V2X_VERSION=1.3.56

View File

@@ -83,6 +83,13 @@ public class NSDNettyManager {
mListener.onChannelDisConnect(channel);
}
}
@Override
public void onReceiveClientSign(Channel channel, String sn) {
if (mListener != null) {
mListener.onReceiveClientSign(channel, sn);
}
}
};
/**

View File

@@ -35,6 +35,9 @@ public class MogoProtocolServerHandler extends SimpleChannelInboundHandler<MogoP
if (msg.getProtocolType() == MogoProtocolMsg.IDENTITY_REGIST) {
String sn = new String(msg.getBody());
NettyTcpServer.getInstance().putChannelSN(ctx.channel().id(), sn);
if (mListener != null) {
mListener.onReceiveClientSign(ctx.channel(), sn);
}
} else {
if (mListener != null) {
mListener.onMessageResponseServer(msg, ctx.channel());

View File

@@ -40,4 +40,5 @@ public interface NettyServerListener<T> {
*/
void onChannelDisConnect(Channel channel);
default void onReceiveClientSign(Channel channel, String sn) {}
}