| | |
| | | { |
| | | public class Send |
| | | { |
| | | |
| | | #region ----Logic所有发送命令 |
| | | /// <summary> |
| | | /// 获取LogicId的方法 |
| | |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | List<int> logicIdList = new List<int>(); |
| | | |
| | | |
| | | bool if_theme = false; |
| | | int if_number = -1; |
| | | Action<string, string> action = (topic, data) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | |
| | | |
| | | if (topic == $"{gatewayID}/Logic/GetLogicList_Respon") |
| | | { |
| | | |
| | | var list = jObjectdata["Data"]["LogicList"]; |
| | | if (list == null) |
| | | if_theme = true; |
| | | var list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Dictionary<string, string>>>(jObjectdata["Data"]["LogicList"].ToString()); |
| | | if_number = list.Count; |
| | | if (list.Count == 0) |
| | | { |
| | | return; |
| | | } |
| | | foreach (var listIfon in list) |
| | | { |
| | | var logicId = int.Parse(listIfon["LogicId"].ToString()); |
| | | var logicId = int.Parse(listIfon["LogicId"]); |
| | | logicIdList.Add(logicId); |
| | | |
| | | } |
| | | |
| | | } |
| | | }; |
| | | var mainGateWay = ZbGateway.MainGateWay; |
| | |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < 3 * 1000) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (logicIdList.Count != 0) |
| | | if (if_theme) |
| | | { |
| | | break; |
| | | if (if_number == 0 || if_number == logicIdList.Count) |
| | | { |
| | | break;//回复没有数据立刻返回 |
| | | } |
| | | |
| | | } |
| | | } |
| | | ZbGateway.MainGateWay.GwResDataAction -= action; |
| | |
| | | |
| | | if (topic == $"{gatewayID}/Logic/GetLogicInfo_Respon") |
| | | { |
| | | |
| | | logic = new Common.Logic(); |
| | | var Logicifon = jObjectdata["Data"]; |
| | | logic.LogicId = int.Parse(Logicifon["LogicId"]?.ToString()); |
| | |
| | | { |
| | | try |
| | | { |
| | | Logicifon = new Common.Logic(); |
| | | Logicifon = Newtonsoft.Json.JsonConvert.DeserializeObject<Common.Logic>(jObjectdata["Data"].ToString()); |
| | | } |
| | | catch (Exception ex) |
| | |
| | | { |
| | | |
| | | var listLogic = new List<Common.Logic>();
|
| | | // bool @bool = false;
|
| | | Action<string, string> action = (topic, data) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | |
| | | |
| | | if (topic == $"{gatewayID}/Logic/GetAllLogicListInfo_Respon") |
| | | { |
| | | |
| | | var logic = new Common.Logic(); |
| | | var Logicifon = jObjectdata["Data"]; |
| | | logic.LogicId = int.Parse(Logicifon["LogicId"].ToString()); |
| | |
| | | } |
| | | |
| | | } |
| | | //if (topic == $"{gatewayID}/Logic/AllLogicNum_Respon") |
| | | //{ |
| | | // @bool = true; |
| | | //} |
| | | |
| | | }; |
| | | var mainGateWay = ZbGateway.MainGateWay; |
| | | if (mainGateWay == null) |
| | |
| | | { |
| | | break; |
| | | } |
| | | //if (@bool) |
| | | //{ |
| | | // break; |
| | | //} |
| | | } |
| | | ZbGateway.MainGateWay.GwResDataAction -= action; |
| | | return listLogic; |
| | |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < 3 * 1000) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (sceneui != null) |
| | | if (sceneui != null && sceneui.Id > 0) |
| | | { |
| | | break; |
| | | } |
| | |
| | | |
| | | #region 存取本地文件的方法 ---暂时不用合并该方法--- |
| | | /// <summary>
|
| | | /// 判断是否开启GPS服务 |
| | | /// </summary> |
| | | public static string If_Exist |
| | | { |
| | | get |
| | | { |
| | | string value = ReadLocalFile(Config.Instance.HomeId+"_GPS_File"); |
| | | //读取本地GPS服务状态 |
| | | if (value == "0"||string.IsNullOrEmpty(value)) |
| | | { |
| | | return "0"; |
| | | } |
| | | return "1"; |
| | | } |
| | | |
| | | } |
| | | /// <summary> |
| | | /// 文件保存
|
| | | /// </summary>
|
| | | /// <param name="FileName">文件路径</param>
|
| | |
| | | //写入数据;
|
| | | 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>
|
| | |
| | | /// <returns></returns>
|
| | | public static string ReadLocalFile(string FileName)
|
| | | {
|
| | | if (System.IO.File.Exists(FileName) == false)
|
| | | {
|
| | | ///判断是否有文件;
|
| | | return null;
|
| | | }
|
| | | //读出保存该路径的文件;
|
| | | var varByte = Shared.IO.FileUtils.ReadFile(FileName);
|
| | | //字节流转换为字符串;
|
| | |
| | | deviceConditionsInfo.Add(Key, Value); |
| | | } |
| | | |
| | | |
| | | |
| | | } |
| | | } |