From 9c8baf7e7e1169ebdf7d5f7ed33ab29dd5fcbf18 Mon Sep 17 00:00:00 2001
From: JLChen <551775569@qq.com>
Date: 星期一, 14 十二月 2020 17:45:17 +0800
Subject: [PATCH] 2020-12-14 1.解锁设置问题修复,增加面容ID验证。2.错误码对接增加。

---
 HDL_ON/DAL/DriverLayer/UdpSocket.cs |   30 ++++++++++++++++++++++--------
 1 files changed, 22 insertions(+), 8 deletions(-)

diff --git a/HDL_ON/DAL/DriverLayer/UdpSocket.cs b/HDL_ON/DAL/DriverLayer/UdpSocket.cs
index 4258c9b..3ffb628 100644
--- a/HDL_ON/DAL/DriverLayer/UdpSocket.cs
+++ b/HDL_ON/DAL/DriverLayer/UdpSocket.cs
@@ -21,22 +21,35 @@
 
 		//鏈湴Socket
 		private Socket busSocket;
-
+		int _port = 0;
 		/// <summary>
 		/// 鍚姩Socket鎺ユ敹鍜屽彂閫佸姛鑳�
 		/// </summary>
-		public void Start ()
+		public void Start (int port = 0)
         {
-            if (IsRunning ) {
-                return;
+			if (IsRunning)
+			{
+                if (port == _port)
+                {
+                    return;
+                }
+                else
+                {
+                    busSocket.Close();
+                }
             }
+			if (port != 0)
+				_port = port;
+			if (_port == 0)
+				return;
 
             busSocket = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
             busSocket.EnableBroadcast = true;
             try {
-                busSocket.Bind (new IPEndPoint (IPAddress.Any, 6000));
+                //busSocket.Bind (new IPEndPoint (IPAddress.Any, 6000));
+                busSocket.Bind(new IPEndPoint(IPAddress.Any, _port));
 
-				busSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("239.0.168.188")));
+                busSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("239.0.168.188")));
 			}
 			catch{
                 busSocket = null;
@@ -45,7 +58,7 @@
 
             asyncBeginReceive();
 
-            MainPage.Log ($"udp port : 6000");
+            MainPage.Log ($"udp port : {port}");
         }
 
 		/// <summary>
@@ -119,10 +132,11 @@
 				packet.Bytes = new byte[len];
 				Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length);
 
+				//MainPage.Log($"鎺ユ敹{packet.RemoteEndPoint}鏁版嵁");
 				//mqtt杩炴帴鏁版嵁璇诲彇  A鍗忚缃戠粶璁惧淇℃伅璇诲彇鍥炲 澶勭悊
 				if (((IPEndPoint)packet.RemoteEndPoint).Port == 8585)
 				{
-					DriverLayer.A_Protocal_Common.apc.ConvertReceiveData(bytes);
+					Control.Ins.ConvertReceiveData(bytes);
 				}
 				else if(((IPEndPoint)packet.RemoteEndPoint).Port == 6000)//澶勭悊bus 6000绔彛鐨勬暟鎹�
 				{

--
Gitblit v1.8.0