20201126;网关搜索

wxr

2020-11-26 31da051cc6648c750ddeac9878369a84367d6f9a

 HDL_ON/DAL/DriverLayer/A_Protocol_Common.cs

@@ -25,67 +25,6 @@
            return t;
        }

        /// <summary>
        /// 转换通讯数据
        /// </summary>
        public byte[] ConvertSendBodyData(string topic, string bodyDataString)
        {
            string topicString = "Topic:" + topic + "/r/n";
            byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
            string lenghtString = "Length:" + bodyBytes.Length.ToString() + "/r/n" + "/r/n";

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

            return sendDataBytes;
        }
        /// <summary>
        /// 转换接收到的数据
        /// </summary>
        /// <returns></returns>
        public string ConvertReceiveData(byte[] bytes)
        {
            string receiveString = "";

            string topic = "";
            int lenght = 0;

            var reString = System.Text.Encoding.UTF8.GetString(bytes);
            var res = reString.Split("/r/n/r/n");


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

                switch (topic)
                {
                    case CommunicationTopic.SearchLoaclGateway:
                        var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
                        if (jt != null)
                        {
                            var device = Newtonsoft.Json.JsonConvert.DeserializeObject<Entity.DeviceModule>(jt.objects.ToString());
                            //Newtonsoft.Json.Linq.JObject.FromObject(jt.objects);
                        }
                        break;
                }

            }
            return receiveString;
        }
    }
    /// <summary>
    /// 通讯回复数据包