2020-12-03-1

陈嘉乐

2020-12-03 0f2e0147e8990e913d16d99bc1b94fb6bc53abd7

 HDL_ON/DAL/DriverLayer/Control.cs

@@ -35,6 +35,27 @@
                return _control;
            }
        }
        int _msg_id = 1;
        /// <summary>
        /// 通讯ID
        /// </summary>
        public int msg_id
        {
            get
            {
                return _msg_id++;
            }
        }
        /// <summary>
        /// 获取13位时间戳
        /// </summary>
        /// <returns></returns>
        public string Get_TimeStamp()
        {
            long t = DateTime.Now.Ticks / 10000;
            return t.ToString(); 
        }

        bool _gatewayOnline = false;
        /// <summary>
        /// 网关是否在线
@@ -51,6 +72,10 @@
                UI.HomePage.LoadEvent_CheckLinkStatus();
            }
        }
        /// <summary>
        /// 网关通讯ID
        /// </summary>
        public string GatewayId;
        /// <summary>
        /// 是否为远程连接
        /// </summary>
@@ -99,6 +124,18 @@
            UdpSocket._BusSocket.Start(port);
        }
        /// <summary>
        /// 关闭udp
        /// </summary>
        public void CloseUdp()
        {
            if(myUdp!= null)
            {
                myUdp = null;
            }
            UdpSocket._BusSocket.Stop();
        }

        /// <summary>
        /// 打开tcp客服端
        /// </summary>
        public void OpenTcpClent()
@@ -123,10 +160,6 @@
        /// </summary>
        public void SearchLoaclGateway()
        {

#if DEBUG
            DB_ResidenceData.residenceData.GatewayType = 1;
#endif
            OpenUdp(DB_ResidenceData.residenceData.GatewayType == 0 ? 6000 : 8585);

            if (DB_ResidenceData.residenceData.GatewayType == 0)
@@ -166,28 +199,45 @@
        {
            function.usageCount++;
            function.refreshTime = DateTime.Now;
            if (DB_ResidenceData.residenceData.GatewayType == 0)
            DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
            //远程通讯
            if (Ins.IsRemote)
            {
                try
                {
                    if(myUdp != null)
                    {
                        myUdp.WriteBusData(function, commandDictionary);
                    }
                }
                catch (Exception ex)
                {
                    MainPage.Log($"发送数据异常: {ex.Message}");
                }
                //ALink控制、Bus控制使用同一个接口控制，由云端负责解析
                var apiControlData = function.GetApiControlData(commandDictionary);
                var actionObjs = new List<ApiAlinkControlActionObj>();
                actionObjs.Add(apiControlData);
                httpServer.ControlDevice(actionObjs);
            }
            //本地通讯
            else
            {
                if (myTcpClient != null)
                //ALink控制
                if (DB_ResidenceData.residenceData.GatewayType == 0)
                {
                    var sendDataObj = function.GetControlSendData(commandDictionary);
                    var sendJson = Newtonsoft.Json.JsonConvert.SerializeObject(sendDataObj);
                    var sendBytes = System.Text.Encoding.UTF8.GetBytes(sendJson);
                    myTcpClient.SendMessage(sendBytes);
                    try
                    {
                        if (myUdp != null)
                        {
                            myUdp.WriteBusData(function, commandDictionary);
                        }
                    }
                    catch (Exception ex)
                    {
                        MainPage.Log($"发送数据异常: {ex.Message}");
                    }
                }
                //Bus控制
                else
                {
                    if (myUdp != null)
                    {
                        var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
                        var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
                        var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
                        myUdp.SendLocalHdlLinkData(sendBytes);
                        //MainPage.Log($"发送本地HDL-Link数据{functionControlDataJson}\r\n");
                    }
                }
            }
        }
@@ -235,12 +285,13 @@
        /// </summary>
        public byte[] ConvertSendBodyData(string topic, string bodyDataString)
        {
            string topicString = "Topic:" + topic + "/\r\n";
            string topicString = "Topic:" + topic + "\r\n";
            byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
            string lenghtString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";
            string lengthString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";

            string sendDataString = topicString + lenghtString + bodyDataString;
            string sendDataString = topicString + lengthString + bodyDataString;
            byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
            MainPage.Log($"转换HDL-Link数据\r\n{sendDataString}\r\n");

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

            string topic = "";
            int lenght = 0;

            var reString = Encoding.UTF8.GetString(bytes);
            var res = reString.Split("\r\n\r\n");
            
            var res = receiveString.Split("\r\n\r\n");

            if (res.Length == 2)
            {
@@ -269,30 +324,40 @@
                    switch (key[0])
                    {
                        case "Topic":
                            topic = key[1];
                            receiveObj.Topic = key[1];
                            break;
                        case "Lenght":
                            lenght = Convert.ToInt32(key[1]);
                        case "Length":
                            receiveObj.Length = Convert.ToInt32(key[1]);
                            break;
                    }
                }
                //验证有效数据长度
                //if (res[1].Length != receiveObj.Length)
                //{
                //    MainPage.Log($"收到数据包长度不够");
                //    return receiveObj;
                //}
                receiveObj.BodyDataString = res[1];

                switch (topic)
                var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
                if (bodyJObj == null)
                {
                    case CommunicationTopic.SearchLoaclGateway:
                        var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
                        if (jt != null)
                    return receiveObj;
                }
                switch (receiveObj.Topic)
                {
                    case CommunicationTopic.SearchLoaclGatewayReply:
                        var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
                        if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC)
                        {
                            var device = Newtonsoft.Json.JsonConvert.DeserializeObject<Entity.DeviceModule>(jt.objects.ToString());
                            //Newtonsoft.Json.Linq.JObject.FromObject(jt.objects);
                            Ins.GatewayOnline = true;
                            Ins.GatewayId = device.gatewayId;
                            reportIp = "239.0.168.188";// device.ip_address;
                        }
                        break;
                }

            }
            return receiveString;
            return receiveObj;
        }


    }
}