| | |
| | | { |
| | | public class Send |
| | | { |
| | | |
| | | #region ----Logic所有发送命令 |
| | | /// <summary> |
| | | /// 获取LogicId的方法 |
| | |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | List<int> logicIdList = new List<int>(); |
| | | |
| | | Action<string, string> action = (topic, data) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | |
| | | { |
| | | return; |
| | | } |
| | | |
| | | |
| | | if (topic == $"{gatewayID}/Logic/GetLogicList_Respon") |
| | | { |
| | | |
| | |
| | | { |
| | | var logicId = int.Parse(listIfon["LogicId"].ToString()); |
| | | logicIdList.Add(logicId); |
| | | |
| | | } |
| | | |
| | | } |
| | |
| | | accounts.Add(location); |
| | | } |
| | | break; |
| | | case 8: |
| | | { |
| | | var accounts1 = new JObject(); |
| | | if (dictionary.ContainsKey("Type")) |
| | | { |
| | | accounts1.Add("Type", int.Parse(dictionary["Type"])); |
| | | } |
| | | if (dictionary.ContainsKey("Option4")) |
| | | { |
| | | accounts1.Add("Option4", dictionary["Option4"]); |
| | | } |
| | | if (dictionary.ContainsKey("Option2")) |
| | | { |
| | | accounts1.Add("Option2", int.Parse(dictionary["Option2"])); |
| | | } |
| | | accounts.Add(accounts1); |
| | | } |
| | | break; |
| | | } |
| | | |
| | | } |
| | |
| | | //服务返回来没有门锁成员信息,没有必要再去请求成员列表, |
| | | //原因:节约时间,体验效果好; |
| | | result = await UserCenter.UserCenterLogic.GetResponseDataByRequestHttps("ZigbeeUsers/GetSubAccountByDistributedMark", false, pra); |
| | | }
|
| | | if (string.IsNullOrEmpty(result))
|
| | | {
|
| | | //防止为空抛异常;
|
| | | return userlist; |
| | | } |
| | | var listInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<List<UserCenter.MemberInfoRes>>(result); |
| | | var listInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<List<UserCenter.MemberInfoRes>>(result);
|
| | | if (listInfo == null)
|
| | | {
|
| | | //防止为空抛异常;
|
| | | return userlist; |
| | | } |
| | | for (int i = 0; i < listInfo.Count; i++) |
| | | { |
| | | |
| | |
| | | /// <param name="method">请求方式为POST/GET</param> |
| | | /// <param name="second">超时时间</param> |
| | | /// <returns></returns> |
| | | public static async System.Threading.Tasks.Task<string> HttpWebRequest(string getUrl, string str, string method, int second = 3) |
| | | public static async System.Threading.Tasks.Task<string> HttpWebRequest(string getUrl, string str, string method, int second = 3, bool _bool = false) |
| | | { |
| | | |
| | | HttpWebRequest request = WebRequest.Create(getUrl) as HttpWebRequest; //创建请求 |
| | | request.Method = method; //请求方式为POST/GET |
| | | request.ContentType = "application/json"; |
| | | request.Timeout = second * 1000;//超时时间 |
| | | if (method == "POST") |
| | | { |
| | | byte[] jsonbyte = System.Text.Encoding.UTF8.GetBytes(str); |
| | | request.ContentLength = jsonbyte.Length; |
| | | Stream postStream = request.GetRequestStream(); |
| | | postStream.Write(jsonbyte, 0, jsonbyte.Length); |
| | | postStream.Close(); |
| | | } |
| | | //发送请求并获取相应回应数据 |
| | | HttpWebResponse res; |
| | | try |
| | | { |
| | | res = (HttpWebResponse)request.GetResponse(); |
| | | if (_bool) |
| | | { |
| | | //用于高胜可视对讲接口 |
| | | request.Headers.Add("Authorization", Config.Instance.Token); |
| | | } |
| | | if (method == "POST") |
| | | { |
| | | byte[] jsonbyte = System.Text.Encoding.UTF8.GetBytes(str); |
| | | request.ContentLength = jsonbyte.Length; |
| | | Stream postStream = request.GetRequestStream(); |
| | | postStream.Write(jsonbyte, 0, jsonbyte.Length); |
| | | postStream.Close(); |
| | | } |
| | | //发送请求并获取相应回应数据 |
| | | HttpWebResponse res; |
| | | try |
| | | { |
| | | res = (HttpWebResponse)request.GetResponse(); |
| | | } |
| | | catch (WebException ex) |
| | | { |
| | | res = (HttpWebResponse)ex.Response; |
| | | } |
| | | StreamReader sr = new StreamReader(res.GetResponseStream(), System.Text.Encoding.UTF8); |
| | | string content = sr.ReadToEnd(); //获得响应字符串 |
| | | return content; |
| | | } |
| | | catch (WebException ex) |
| | | catch |
| | | { |
| | | res = (HttpWebResponse)ex.Response; |
| | | return null; |
| | | } |
| | | StreamReader sr = new StreamReader(res.GetResponseStream(), System.Text.Encoding.UTF8); |
| | | string content = sr.ReadToEnd(); //获得响应字符串 |
| | | return content; |
| | | } |
| | | /// <summary> |
| | | /// 请求服务器的方法 |
| | |
| | | #endregion |
| | | |
| | | #region 存取本地文件的方法 ---暂时不用合并该方法--- |
| | | /// <summary> |
| | | /// 判断是否开启GPS服务 |
| | | /// </summary> |
| | | public static string It_Exist |
| | | { |
| | | get |
| | | { |
| | | //读取本地GPS服务状态 |
| | | if (ReadLocalFile("GPS_File") == "0") |
| | | { |
| | | return "0"; |
| | | } |
| | | return "1"; |
| | | } |
| | | |
| | | } |
| | | /// <summary>
|
| | | /// 文件保存
|
| | | /// </summary>
|
| | |
| | | var byteData = System.Text.Encoding.UTF8.GetBytes(data);
|
| | | //写入数据;
|
| | | Shared.IO.FileUtils.WriteFileByBytes(FileName, byteData);
|
| | | } |
| | | /// <summary>
|
| | | /// 文件保存
|
| | | /// </summary>
|
| | | /// <param name="FileName">文件路径</param>
|
| | | /// <param name="data">字符串</param> |
| | | public static void SaveLocalFile(string FileName, string data)
|
| | | {
|
| | | //先序列化数据;
|
| | | //数据转换为字节流;
|
| | | var byteData = System.Text.Encoding.UTF8.GetBytes(data);
|
| | | //写入数据;
|
| | | Shared.IO.FileUtils.WriteFileByBytes(FileName, byteData);
|
| | | }
|
| | |
|
| | | /// <summary>
|
| | | /// 文件读取
|
| | | /// </summary>
|
| | | /// <param name="FileName">文件路径</param>
|
| | | /// <returns></returns>
|
| | | public static string ReadLocalFile(string FileName)
|
| | | {
|
| | | if (System.IO.File.Exists(FileName) == false)
|
| | | {
|
| | | ///判断是否有文件;
|
| | | return null;
|
| | | }
|
| | | { |
| | | //读出保存该路径的文件;
|
| | | var varByte = Shared.IO.FileUtils.ReadFile(FileName);
|
| | | //字节流转换为字符串;
|
| | |
| | | /// 判断字典是否存在的方法 |
| | | /// </summary> |
| | | /// <param name="deviceConditionsInfo"></param> |
| | | /// <param name="Key"></param> |
| | | /// <param name="Value"></param> |
| | | /// <param name="Key">键</param> |
| | | /// <param name="Value">键值</param> |
| | | public static void dictionary(Dictionary<string, string> deviceConditionsInfo, string Key, string Value) |
| | | { |
| | | if (deviceConditionsInfo.ContainsKey(Key)) |
| | |
| | | deviceConditionsInfo.Add(Key, Value); |
| | | } |
| | | |
| | | |
| | | |
| | | } |
| | | } |