using System;
using System.Net.Sockets;
using System.Net;
using HDL_ON.DAL.Net;
//using HDL_ON.UI;

namespace HDL_ON
{
	/// <summary>
	/// 接收处理UDP数据包
	/// </summary>
	/// <typeparam name="T"></typeparam>
	public static class BusSocket
	{
		//监听端口
	    static int port;

		//本地Socket
		private static Socket busSocket;

        /// <summary>
        /// 启动Socket接收和发送功能
        /// </summary>
        /// <param name="port"></param>
        public static void Start (int port)
        {
            if (IsRunning) {
                return;
            }

            BusSocket.port = port;

            busSocket = new Socket (AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            busSocket.EnableBroadcast = true;
            try {
                busSocket.Bind (new IPEndPoint (IPAddress.Any, port));

				busSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse("224.0.168.188")));
			}
			catch{
                busSocket = null;
                return;
            }

            //socket = new Socket (AddressFamily.InterNetwork, SocketType.Raw, ProtocolType.IP);
            //socket.Bind (new IPEndPoint (IPAddress.Parse (ip), 0)); //绑定套接字
            //socket.SetSocketOption (SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption (IPAddress.Parse ("224.0.168.188")));
            //if (SetSocketOption () == false) error_occurred = true;

            asyncBeginReceive ();

            MainPage.Log ("BusSocket启动成功！");
        }

		/// <summary>
		/// 停止Socket
		/// </summary>
		public static void Stop()
		{
			if (!IsRunning)
			{
				return;
			}
			try
			{
				busSocket.Close();
			}
			catch { }
			busSocket = null;
            MainPage.Log("BusSocket关闭成功!");
		}

		/// <summary>
		/// 当前的Socket是否运行
		/// </summary>
		public static bool IsRunning
		{
			get
			{
				return null == busSocket ? false : true;
			}
		}

		/// <summary>
		/// 开始异步接收数据
		/// </summary>
		private static void asyncBeginReceive()
		{
			if (!IsRunning)
			{
				return;
			}

            try {
                Packet packet = new Packet ();
                busSocket.BeginReceiveFrom (packet.Bytes, 0, packet.Bytes.Length, SocketFlags.None, ref packet.RemoteEndPoint, new AsyncCallback (asyncEndReceive), packet);
            } 
            catch (Exception e) {
                System.Threading.Thread.Sleep (1);
                asyncBeginReceive ();
                Console.WriteLine($"asyncBeginReceive {e.Message}");
            } 
		}

		/// <summary>
		/// 异步接收数据结束
		/// </summary>
		/// <param name="iar"></param>
		private static void asyncEndReceive(IAsyncResult iar)
		{
			if (!IsRunning)
			{
				return;
			}

			try
			{
				asyncBeginReceive();
				Packet packet = (Packet)iar.AsyncState;
				int len = busSocket.EndReceiveFrom(iar, ref packet.RemoteEndPoint);

				byte[] bytes = packet.Bytes;
				packet.Bytes = new byte[len];
				Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length);

				//mqtt连接数据读取
				if (packet.RemoteEndPoint.ToString() == "172.16.2.237:6688")
				{
					//var reString = DAL.CommonPage.MyEncodingUTF8.GetString(bytes);
					//var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(reString);
					//var gateway_objects = jt.GetValue("objects").ToString();
					//var jt2 = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(gateway_objects);
					//MqttCommon.mqttClientIP = jt2.GetValue("gateway_ip").ToString();
					//MqttCommon.mqttGatewayMAC = jt2.GetValue("board_id").ToString();
				}

				packet.Manager();
			}
			catch (Exception ex)
			{
				MainPage.Log($"异步接收数据结束 {ex.Message},{((Packet)iar.AsyncState).Bytes}");
			}
		}

		/// <summary>
		/// 异步发送数据
		/// </summary>
		/// <param name="tempPacket"></param>
		public static void AsyncBeginSend(Packet tempPacket)
		{
			try
			{
				if (!IsRunning)
				{
					tempPacket.HaveSendCount++;
					return;
				}
				tempPacket.FlagDateTime = System.DateTime.Now;
				tempPacket.HaveSendCount++;
				busSocket.BeginSendTo(tempPacket.Bytes, 0, tempPacket.Bytes.Length, SocketFlags.None, tempPacket.RemoteEndPoint, new AsyncCallback(asyncEndSend), tempPacket);
			}
			catch (Exception ex)
			{
				MainPage.Log($"AsyncBeginSend error {ex.Message}");
			}
		}

		/// <summary>
		/// 异步发送数据结束
		/// </summary>
		/// <param name="iar"></param>
		private static void asyncEndSend(IAsyncResult iar)
		{
			Packet tempUDPPacketBuffer = (Packet)iar.AsyncState;
			try
			{
				int bytesSent = busSocket.EndSendTo(iar);
			}
			catch {
            
            }
		}
	}
}