From 7c4a07efee66d91c198cc10d36866732e20d4ec8 Mon Sep 17 00:00:00 2001
From: chenfufeng <chenfufeng@zhidaoauto.com>
Date: Tue, 17 May 2022 17:37:21 +0800
Subject: [PATCH] =?UTF-8?q?[Feat]=E6=8F=90=E4=BE=9B=E4=B9=98=E5=AE=A2?=
 =?UTF-8?q?=E5=B1=8F=E6=B3=A8=E5=86=8Csn=E5=88=B0=E5=8F=B8=E6=9C=BA?=
 =?UTF-8?q?=E5=B1=8F=E7=9A=84=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 gradle.properties                             | 24 +++++++++----------
 .../com/mogo/telematic/NSDNettyManager.java   |  7 ++++++
 .../netty/MogoProtocolServerHandler.java      |  3 +++
 .../server/netty/NettyServerListener.java     |  1 +
 4 files changed, 23 insertions(+), 12 deletions(-)

diff --git a/gradle.properties b/gradle.properties
index 114ed64..98395db 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -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
diff --git a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java
index cf10c6a..ae5f991 100644
--- a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java
+++ b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java
@@ -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);
+            }
+        }
     };
 
     /**
diff --git a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/MogoProtocolServerHandler.java b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/MogoProtocolServerHandler.java
index aeadf68..36a099e 100644
--- a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/MogoProtocolServerHandler.java
+++ b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/MogoProtocolServerHandler.java
@@ -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());
diff --git a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/NettyServerListener.java b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/NettyServerListener.java
index 8d9f4c7..2cf66dc 100644
--- a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/NettyServerListener.java
+++ b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/server/netty/NettyServerListener.java
@@ -40,4 +40,5 @@ public interface NettyServerListener<T> {
      */
     void onChannelDisConnect(Channel channel);
 
+    default void onReceiveClientSign(Channel channel, String sn) {}
 }