1127最新合并代码，合并嘉乐更新

wei

2020-11-27 e53a1951d6aa07ad22aad9816da4703496fcbccd

 HDL_ON/DAL/DriverLayer/Control.cs

@@ -1,15 +1,16 @@
using System;
using System.Collections.Generic;
using System.Text;
using HDL_ON.Entity;

namespace HDL_ON.DriverLayer
{

    /// <summary>
    /// 通讯方式
    /// </summary>
    public enum CommunicationMode
    {
        none,
        /// <summary>
        /// 本地udp
        /// </summary>
@@ -20,12 +21,10 @@
        tcp_local_client,
    }



    public class Control
    {
        static Control _control;
        public static Control ins
        public static Control Ins
        {
            get
            {
@@ -36,10 +35,38 @@
                return _control;
            }
        }
        int _msg_id = 1;
        /// <summary>
        /// 通讯ID
        /// </summary>
        public int msg_id
        {
            get
            {
                return _msg_id++;
            }
        }

        bool _gatewayOnline = false;
        /// <summary>
        /// 网关是否在线
        /// </summary>
        public bool gatewayOnline = false;
        public bool GatewayOnline {
            get
            {
                return _gatewayOnline;
            }
            set
            {
                _gatewayOnline = value;
                //修改主页连接状态
                UI.HomePage.LoadEvent_CheckLinkStatus();
            }
        }
        /// <summary>
        /// 是否为远程连接
        /// </summary>
        public bool IsRemote = false;
        /// <summary>
        /// 通讯地址IP
        /// </summary>
@@ -55,7 +82,7 @@
        /// <summary>
        /// 本地udp
        /// </summary>
        public Control_Udp_Bus myUdp = null;
        public Control_Udp myUdp = null;

        /// <summary>
        /// 通讯方式
@@ -72,63 +99,50 @@
        }

        /// <summary>
        /// 改变通讯方式
        /// 打开Udp
        /// </summary>
        public void ChangeCommunicationMode(CommunicationMode communicationMode)
        public void OpenUdp(int port)
        {
            if (this.communicationMode == communicationMode)
            if (myUdp == null)
            {
                return;
                myUdp = new Control_Udp();
            }

            this.communicationMode = communicationMode;


            switch (this.communicationMode)
            UdpSocket._BusSocket.Start(port);
        }
        /// <summary>
        /// 打开tcp客服端
        /// </summary>
        public void OpenTcpClent()
        {
            if (myTcpClient == null)
            {
                case CommunicationMode.local_BusUdp:
                    if (myUdp == null)
                    {
                        myUdp = new Control_Udp_Bus();
                    }
                    UdpSocket._BusSocket.Start();
                    if (myTcpClient != null)
                    {
                        myTcpClient.Close();
                        myTcpClient = null;
                    }
                    break;
                case CommunicationMode.tcp_local_client:
                    if (myTcpClient == null)
                    {
                        myTcpClient = new Control_TcpClient(reportIp);
                        myTcpClient.Connect();
                    }
                    if (myUdp != null)
                    {
                        UdpSocket._BusSocket.Stop();
                        myUdp = null;
                    }
                    break;
                myTcpClient = new Control_TcpClient(reportIp);
                myTcpClient.Connect();
            }
        }

        ///// <summary>
        ///// 改变通讯方式
        ///// </summary>
        //public void ChangeCommunicationMode(CommunicationMode communicationMode)
        //{
        //    this.communicationMode = communicationMode;
        //}

        /// <summary>
        /// 搜索本地网关列表
        /// </summary>
        public void SearchLoaclGateway()
        {
            ChangeCommunicationMode(CommunicationMode.local_BusUdp);
            OpenUdp(DB_ResidenceData.residenceData.GatewayType == 0 ? 6000 : 8585);

            if (DB_ResidenceData.residenceData.GatewayType == 0)
            {
                myUdp.ControlBytesSend(Command.ReadGateway, 255, 255, new byte[] { (byte)new Random().Next(255), (byte)new Random().Next(255) });
            }
            else if (DB_ResidenceData.residenceData.GatewayType == 1)
            {
                UdpSocket._BusSocket.SearchNetDeviceAction = (revIp) =>
                {
                    MainPage.Log($"搜索到网络设备：{revIp}");
                };
                myUdp.SearchLocalGateway();
            }
        }
@@ -224,6 +238,91 @@
            sendSidObj.type = "device_sid";
            sendSidObj.command = "get_list_response";
        }
        /// <summary>
        /// 转换通讯数据
        /// </summary>
        public byte[] ConvertSendBodyData(string topic, string bodyDataString)
        {
            string topicString = "Topic:" + topic + "\r\n";
            byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
            string lengthString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";

            string sendDataString = topicString + lengthString + bodyDataString;
            byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);

            return sendDataBytes;
        }
        /// <summary>
        /// 转换接收到的数据
        /// </summary>
        /// <returns></returns>
        public void ConvertReceiveData(byte[] receiveBytes)
        {
            var reString = Encoding.UTF8.GetString(receiveBytes);
            AnalysisReceiveData(reString);
        }
        /// <summary>
        /// 转换接收到的数据
        /// </summary>
        /// <returns></returns>
        public LocalCommunicationData AnalysisReceiveData(string receiveString)
        {
            LocalCommunicationData receiveObj = new LocalCommunicationData();

            var res = receiveString.Split("\r\n\r\n");

            if (res.Length == 2)
            {
                var topics = res[0].Split("\r\n");
                MainPage.Log(res[1]);
                foreach (var ts in topics)
                {
                    var key = ts.Split(":");
                    switch (key[0])
                    {
                        case "Topic":
                            receiveObj.Topic = key[1];
                            break;
                        case "Length":
                            receiveObj.Length = Convert.ToInt32(key[1]);
                            break;
                    }
                }

                //验证有效数据长度
                if (res[1].Length != receiveObj.Length)
                {
                    MainPage.Log($"收到数据包长度不够");
                    return receiveObj;
                }
                receiveObj.BodyDataString = res[1];

                var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
                if (bodyJObj == null)
                {
                    return receiveObj;
                }
                switch (receiveObj.Topic)
                {
                    case CommunicationTopic.SearchLoaclGateway:
                        var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
#if DEBUG
                        if (UserInfo.Current.AccountString == "464027401@qq.com")
                        {
                            DB_ResidenceData.residenceData.residenceGatewayMAC = "0000000000000000";
                        }
#endif
                        if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC)
                        {
                            Control.Ins.GatewayOnline = true;
                        }
                        break;
                }
            }
            return receiveObj;

        }


    }
}