| | |
| | | public class BindObj : CommonDevice |
| | | { |
| | | #region 设备绑定 |
| | | /// <summary> |
| | | ///设备绑定 |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<AddedDeviceBindResponseAllData> AddDeviceBindAsync(AddBindData addBindData) |
| | | { |
| | | |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | var result = new AddedDeviceBindResponseAllData(); |
| | | var mainGateway = ZbGateway.MainGateWay; |
| | | if (mainGateway == null) |
| | | { |
| | | result.errorMessageBase = "当前没有主网关"; |
| | | return result; |
| | | } |
| | | Action<string, string> action = (topic, message) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | | var jobject = Newtonsoft.Json.Linq.JObject.Parse(message); |
| | | if (topic == gatewayID + "/" + "Error_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = ZbGateway.MainGateWay.getGatewayBaseInfo.gwID }; |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | result.errorMessageBase = "网关错误回复,且数据是空"; |
| | | } |
| | | else |
| | | { |
| | | result.errorResponData = temp; |
| | | result.errorMessageBase = ErrorMess(temp.Error); |
| | | } |
| | | } |
| | | else if (topic == gatewayID + "/" + "Bind/SetBind_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = ZbGateway.MainGateWay.getGatewayBaseInfo.gwID }; |
| | | var tempBindList = Newtonsoft.Json.Linq.JArray.Parse(jobject["Data"]["BindList"].ToString()); |
| | | if (tempBindList == null) |
| | | { |
| | | result.errorMessageBase = "网关返回的数据为空"; |
| | | } |
| | | else |
| | | { |
| | | var dataBindRes = new AddedDeviceBindResponseData(); |
| | | for (int m = 0; tempBindList != null && m < tempBindList.Count; m++) |
| | | { |
| | | var tempBind = tempBindList[m]; |
| | | dataBindRes.BindList.Add(Newtonsoft.Json.JsonConvert.DeserializeObject<AddBindListResponseObj>(tempBind.ToString())); |
| | | } |
| | | if (dataBindRes != null) |
| | | { |
| | | result.addedDeviceBindResponseData = dataBindRes; |
| | | DebugPrintLog($"UI收到通知后的主题_{topic}"); |
| | | } |
| | | } |
| | | } |
| | | else if (topic == gatewayID + "/" + "Bind/BindResult") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = ZbGateway.MainGateWay.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<AddBindResultResponseData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData != null) |
| | | { |
| | | result.addBindResultResponseData = tempData; |
| | | } |
| | | } |
| | | }; |
| | | mainGateway.Actions += action; |
| | | DebugPrintLog("Bind/SetBind_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | if (addBindData != null) |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", addBindData.DeviceAddr }, { "Epoint", addBindData.Epoint }, { "Cluster_ID", 0 }, { "Command", 5001 } }; |
| | | var bindList = new JArray { }; |
| | | foreach (var bindInfo in addBindData.BindList) |
| | | { |
| | | if (bindInfo.BindType == 0) |
| | | { |
| | | var dInfo = new JObject{ |
| | | { "BindMacAddr",bindInfo.BindMacAddr}, |
| | | { "BindEpoint", bindInfo.BindEpoint} , |
| | | { "BindCluster", bindInfo.BindCluster} , |
| | | { "BindType",bindInfo.BindType} |
| | | }; |
| | | bindList.Add(dInfo); |
| | | } |
| | | else if (bindInfo.BindType == 1) |
| | | { |
| | | var dInfo = new JObject{ |
| | | { "BindCluster", bindInfo.BindCluster} , |
| | | { "BindType",bindInfo.BindType}, |
| | | { "BindScenesId", bindInfo.BindScenesId} |
| | | }; |
| | | bindList.Add(dInfo); |
| | | } |
| | | } |
| | | var data = new JObject{ |
| | | {"BindName",addBindData.BindName}, |
| | | { "BindList", bindList } |
| | | }; |
| | | jObject.Add("Data", data); |
| | | //ZbGateway.MainGateWay.CurrentGateWayId = ZbGateway.MainGateWay.getGatewayBaseInfo?.gwID; |
| | | mainGateway.Send("Bind/SetBind", jObject.ToString()); |
| | | } |
| | | } |
| | | catch |
| | | { |
| | | } |
| | | |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (result == null || result.addedDeviceBindResponseData == null) |
| | | { |
| | | continue; |
| | | } |
| | | if (0 < result.addedDeviceBindResponseData.BindList.FindAll((obj) => obj.BindType == 0 && obj.Result == 2).Count) |
| | | { |
| | | if (result.addBindResultResponseData != null) |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime) |
| | | { |
| | | result.errorMessageBase = " 回复超时,请重新操作"; |
| | | } |
| | | mainGateway.Actions -= action; |
| | | System.Console.WriteLine($"Bind/SetBind_Actions 退出 {System.DateTime.Now}"); |
| | | return result; |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 绑定设备信息,网关反馈信息 |
| | | /// </summary> |
| | | public AddedDeviceBindResponseAllData addedDeviceBindResponseAllData; |
| | | [System.Serializable] |
| | | public class AddedDeviceBindResponseAllData |
| | | public class AddedDeviceBindResponseAllData : ErrorResponCommon |
| | | { |
| | | /// <summary> |
| | | /// 错误信息 |
| | | /// </summary> |
| | | public string errorMessageBase; |
| | | /// <summary> |
| | | /// 网关信息错误反馈 |
| | | /// <para>当网关接收到客户端信息后,出现以下异常情况将反馈错误。</para> |
| | | /// </summary> |
| | | public ErrorResponData errorResponData; |
| | | /// <summary> |
| | | /// 网关直接反馈绑定设备信息 |
| | | /// </summary> |
| | | public AddedDeviceBindResponseData addedDeviceBindResponseData; |
| | | /// <summary> |
| | | /// 按键设备的确认反馈绑定设备信息 |
| | | /// </summary> |
| | | public AddBindResultResponseData addBindResultResponseData; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 绑定设备信息 |
| | | /// </summary> |
| | | public AddedDeviceBindResponseData addedDeviceBindResponseData; |
| | | [System.Serializable] |
| | | public class AddedDeviceBindResponseData |
| | | { |
| | |
| | | /// <summary> |
| | | ///绑定列表 ,当Status=0时存在 |
| | | /// </summary> |
| | | public List<AddBindListResponseObj> BindList = new List<AddBindListResponseObj>(); |
| | | public List<BindListResponseObj> BindList = new List<BindListResponseObj>(); |
| | | /// <summary> |
| | | /// 0:绑定所有目标成功 |
| | | ///<para>1:绑定目标失败,绑定设备目标有漏掉</para> |
| | | /// </summary> |
| | | public int Result = -1; |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <summary> |
| | | /// 绑定设备的数据 |
| | | /// </summary> |
| | | public AddBindData addBindData; |
| | | [System.Serializable] |
| | | public class AddBindData |
| | | { |
| | |
| | | #endregion |
| | | |
| | | #region 解除绑定 |
| | | /// <summary> |
| | | /// 解除绑定 |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<DelDeviceBindResponseAllData> DelDeviceBindAsync(DelDeviceBindData delDeviceBindData) |
| | | { |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | var responseData = new DelDeviceBindResponseAllData(); |
| | | var mainGateway = ZbGateway.MainGateWay; |
| | | if (mainGateway == null) |
| | | { |
| | | responseData.errorMessageBase = "当前没有主网关"; |
| | | return responseData; |
| | | } |
| | | |
| | | Action<string, string> action = (topic, message) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | | var jobject = Newtonsoft.Json.Linq.JObject.Parse(message); |
| | | |
| | | if (topic == gatewayID + "/" + "Error_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | responseData.errorMessageBase = "网关错误回复,且数据是空"; |
| | | } |
| | | else |
| | | { |
| | | responseData.errorResponData = temp; |
| | | responseData.errorMessageBase = ErrorMess(temp.Error); |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "Bind/RemoveBind_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = Gateway.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<DelDeviceBindResponseData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | responseData.errorMessageBase = "网关返回的数据为空"; |
| | | |
| | | } |
| | | else |
| | | { |
| | | responseData.delDeviceBindResponseData = tempData; |
| | | System.Console.WriteLine($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "Bind/RemoveBindResult") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<RemoveBindResultResponseData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData != null) |
| | | { |
| | | responseData.removeBindResultResponseData = tempData; |
| | | System.Console.WriteLine($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | mainGateway.Actions += action; |
| | | System.Console.WriteLine("DeviceBind/DelBind_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | if (delDeviceBindData != null) |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", delDeviceBindData.DeviceAddr }, { "Epoint", delDeviceBindData.Epoint }, { "Cluster_ID", 0 }, { "Command", 5003 } }; |
| | | var removeBindList = new JArray { }; |
| | | foreach (var removeBindInfo in delDeviceBindData.RemoveBindList) |
| | | { |
| | | if (removeBindInfo.BindType == 0) |
| | | { |
| | | var dInfo = new JObject{ |
| | | { "BindMacAddr",removeBindInfo.BindMacAddr}, |
| | | { "BindEpoint", removeBindInfo.BindEpoint} , |
| | | { "BindCluster", removeBindInfo.BindCluster} , |
| | | { "BindType",removeBindInfo.BindType} |
| | | }; |
| | | removeBindList.Add(dInfo); |
| | | } |
| | | else if (removeBindInfo.BindType == 1) |
| | | { |
| | | var dInfo = new JObject{ |
| | | { "BindCluster", removeBindInfo.BindCluster} , |
| | | { "BindType",removeBindInfo.BindType}, |
| | | { "BindScenesId", removeBindInfo.BindScenesId} |
| | | }; |
| | | removeBindList.Add(dInfo); |
| | | } |
| | | } |
| | | var data = new JObject { |
| | | {"RemoveBindList",removeBindList} |
| | | }; |
| | | jObject.Add("Data", data); |
| | | //ZbGateway.MainGateWay.CurrentGateWayId = ZbGateway.MainGateWay.getGatewayBaseInfo?.gwID; |
| | | mainGateway.Send("Bind/RemoveBind", jObject.ToString()); |
| | | } |
| | | } |
| | | catch { } |
| | | |
| | | |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (responseData == null || responseData.delDeviceBindResponseData == null) |
| | | { |
| | | continue; |
| | | } |
| | | if (0 < responseData.delDeviceBindResponseData.RemoveBindList.FindAll((obj) => obj.BindType == 0).Count) |
| | | { |
| | | if (responseData.removeBindResultResponseData != null) |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | |
| | | if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime) |
| | | { |
| | | responseData.errorMessageBase = "回复超时,请重新操作"; |
| | | } |
| | | mainGateway.Actions -= action; |
| | | System.Console.WriteLine("DeviceBind/DelBind_Actions 退出" + System.DateTime.Now.ToString()); |
| | | |
| | | return responseData; |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | ///解除绑定数据,网关反馈信息 |
| | | /// </summary> |
| | | public DelDeviceBindResponseAllData delDeviceBindResponseAllData; |
| | | |
| | | /// <summary> |
| | | ///解除绑定数据,网关反馈信息 |
| | | /// </summary> |
| | | [System.Serializable] |
| | | public class DelDeviceBindResponseAllData |
| | | public class DelDeviceBindResponseAllData : ErrorResponCommon |
| | | { |
| | | /// <summary> |
| | | /// 错误信息 |
| | | /// </summary> |
| | | public string errorMessageBase; |
| | | /// <summary> |
| | | /// 网关信息错误反馈 |
| | | /// <para>当网关接收到客户端信息后,出现以下异常情况将反馈错误。</para> |
| | | /// </summary> |
| | | public ErrorResponData errorResponData; |
| | | /// <summary> |
| | | /// 解除绑定数据信息 |
| | | /// </summary> |
| | |
| | | public RemoveBindResultResponseData removeBindResultResponseData; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 解除绑定数据 |
| | | /// </summary> |
| | | public DelDeviceBindResponseData delDeviceBindResponseData; |
| | | /// <summary> |
| | | /// 解除绑定数据 |
| | | /// </summary> |
| | |
| | | /// 0:移除成功(该状态只适用用于跨网关绑定、绑定场景、失效设备(设备已经从网关的设备列表中删除)。同网关设备间的解除绑定需要节点设备的确认成功信息,不会直接反馈成功。) |
| | | ///<para>1:失败,设备不在绑定列表中</para> |
| | | ///<para>3:失败,在等待节点设备确认是否解除绑定成功(当网关还在等待某节点设备确认是否解除绑定成功的反馈信息时,客户端再次发送解除绑定该节点设备的指令,将反馈该状态。)</para> |
| | | ///<para>4:未知,由节点设备反馈发送“Bind/RemoveBindResult”主题消息确定是否成功。</para> |
| | | ///<para>2:未知,由节点设备反馈发送“Bind/RemoveBindResult”主题消息确定是否成功。</para> |
| | | /// </summary> |
| | | public int Result; |
| | | |
| | |
| | | public string DeviceName; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 解除绑定数据 |
| | | /// </summary> |
| | | public DelDeviceBindData delDeviceBindData; |
| | | /// <summary> |
| | | /// 解除绑定数据 |
| | | /// </summary> |
| | |
| | | #endregion |
| | | |
| | | #region (从网关中)获取所有绑定 |
| | | /// <summary> |
| | | ///获取所有绑定 |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<GetDeviceBindResponseAllData> GetDeviceBindAsync() |
| | | { |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | GetDeviceBindResponseAllData d = null; |
| | | var mainGateway = ZbGateway.MainGateWay; |
| | | if (mainGateway == null) |
| | | { |
| | | d = new GetDeviceBindResponseAllData { errorMessageBase = "当前没有主网关" }; |
| | | return d; |
| | | } |
| | | |
| | | Action<string, string> action = (topic, message) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | | var jobject = Newtonsoft.Json.Linq.JObject.Parse(message); |
| | | |
| | | if (topic == gatewayID + "/" + "Error_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new GetDeviceBindResponseAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new GetDeviceBindResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "Bind/GetDeviceBind_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<GetDeviceBindResponseData>(jobject["Data"].ToString()); |
| | | //var tempBindList = Newtonsoft.Json.Linq.JArray.Parse(jobject["Data"]["BindList"].ToString()); |
| | | if (tempData == null) |
| | | { |
| | | d = new GetDeviceBindResponseAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new GetDeviceBindResponseAllData { getAllBindResponseData = tempData }; |
| | | System.Console.WriteLine($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | mainGateway.Actions += action; |
| | | |
| | | try |
| | | { |
| | | System.Console.WriteLine("Bind/GetDeviceBind_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 0 }, { "Command", 5007 } }; |
| | | mainGateway.Send("Bind/GetDeviceBind", jObject.ToString()); |
| | | } |
| | | catch { } |
| | | |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(10); |
| | | if (d != null) |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime) |
| | | { |
| | | d = new GetDeviceBindResponseAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | mainGateway.Actions -= action; |
| | | System.Console.WriteLine("Bind/GetDeviceBind_Actions 退出" + System.DateTime.Now.ToString()); |
| | | |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | ///获取所有绑定数据,网关反馈信息 |
| | | /// </summary> |
| | | public GetDeviceBindResponseAllData getAllBindResponseAllData; |
| | | [System.Serializable] |
| | | public class GetDeviceBindResponseAllData |
| | | public class GetDeviceBindResponseAllData : ErrorResponCommon |
| | | { |
| | | /// <summary> |
| | | /// 错误信息 |
| | | /// </summary> |
| | | public string errorMessageBase; |
| | | /// <summary> |
| | | /// 网关信息错误反馈 |
| | | /// <para>当网关接收到客户端信息后,出现以下异常情况将反馈错误。</para> |
| | | /// </summary> |
| | | public ErrorResponData errorResponData; |
| | | /// <summary> |
| | | /// 控制设备绑定的设备列表回复数据 |
| | | /// </summary> |
| | |
| | | /// <summary> |
| | | /// 获取所有绑定回复的数据 |
| | | /// </summary> |
| | | public GetDeviceBindResponseData getAllBindResponseData; |
| | | [System.Serializable] |
| | | public class GetDeviceBindResponseData |
| | | { |
| | |
| | | #endregion |
| | | |
| | | #region 从节点设备本地记录读取绑定列表信息 |
| | | /// <summary> |
| | | ///从节点设备本地记录读取绑定列表信息 |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<GetDeviceLocalBindResponseAllData> GetDeviceLocalBindAsync(int startIndex = 0) |
| | | { |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | GetDeviceLocalBindResponseAllData d = null; |
| | | var mainGateway = ZbGateway.MainGateWay; |
| | | if (mainGateway == null) |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { errorMessageBase = "当前没有主网关" }; |
| | | return d; |
| | | } |
| | | |
| | | Action<string, string> action = (topic, message) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | | var jobject = Newtonsoft.Json.Linq.JObject.Parse(message); |
| | | |
| | | if (topic == gatewayID + "/" + "Error_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "Bind/GetDeviceLocalBind_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = mainGateway.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<GetDeviceLocalBindResponseData>(jobject["Data"].ToString());
|
| | | if (tempData == null) |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { getDeviceLocalBindResponseData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | mainGateway.Actions += action; |
| | | |
| | | try |
| | | { |
| | | DebugPrintLog("Bind/GetDeviceLocalBind_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Cluster_ID", 0 }, { "Command", 5008 } }; |
| | | var data = new JObject { { "StartIndex", startIndex } }; |
| | | mainGateway.Send("Bind/GetDeviceLocalBind", jObject.ToString()); |
| | | } |
| | | catch { } |
| | | |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(10); |
| | | if (d != null) |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime) |
| | | { |
| | | d = new GetDeviceLocalBindResponseAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | mainGateway.Actions -= action; |
| | | DebugPrintLog("Bind/GetDeviceLocalBind_Actions 退出" + System.DateTime.Now.ToString()); |
| | | |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | ///从节点设备本地记录读取绑定列表信息回复的数据,网关反馈信息 |
| | | /// </summary> |
| | | public GetDeviceLocalBindResponseAllData getDeviceLocalBindResponseAllData; |
| | | [System.Serializable] |
| | | public class GetDeviceLocalBindResponseAllData |
| | | public class GetDeviceLocalBindResponseAllData : ErrorResponCommon |
| | | { |
| | | /// <summary> |
| | | /// 错误信息 |
| | | /// </summary> |
| | | public string errorMessageBase; |
| | | /// <summary> |
| | | /// 网关信息错误反馈 |
| | | /// <para>当网关接收到客户端信息后,出现以下异常情况将反馈错误。</para> |
| | | /// </summary> |
| | | public ErrorResponData errorResponData; |
| | | /// <summary> |
| | | /// 从节点设备本地记录读取绑定列表信息回复的数据 |
| | | /// </summary> |
| | |
| | | /// <summary> |
| | | /// 从节点设备本地记录读取绑定列表信息回复的数据 |
| | | /// </summary> |
| | | public GetDeviceLocalBindResponseData getDeviceLocalBindResponseData; |
| | | [System.Serializable] |
| | | public class GetDeviceLocalBindResponseData |
| | | { |
| | |
| | | #endregion |
| | | |
| | | #region 删除一个控制设备所有绑定信息 |
| | | /// <summary> |
| | | ///删除一个控制设备所有绑定信息 |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<ClearBindInfoResponseAllData> ClearBindInfoAsync() |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | ClearBindInfoResponseAllData d = null; |
| | | Action<string, string> action = (topic, message) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | | var jobject = Newtonsoft.Json.Linq.JObject.Parse(message); |
| | | |
| | | if (topic == gatewayID + "/" + "Error_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = Gateway.getGatewayBaseInfo.gwID }; |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new ClearBindInfoResponseAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new ClearBindInfoResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "Bind/ClearBindInfo_Respon") |
| | | { |
| | | var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = Gateway.getGatewayBaseInfo.gwID }; |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClearBindInfoResponseData>(jobject["Data"].ToString()); |
| | | if (tempData == null) |
| | | { |
| | | d = new ClearBindInfoResponseAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new ClearBindInfoResponseAllData { clearBindInfoResponseData = tempData }; |
| | | System.Console.WriteLine($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("Bind/ClearBindInfo_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 0 }, { "Command", 5006 } }; |
| | | Gateway.Send("Bind/ClearBindInfo", jObject.ToString()); |
| | | } |
| | | catch { } |
| | | |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(10); |
| | | if (d != null) |
| | | { |
| | | break; |
| | | } |
| | | } |
| | | if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime) |
| | | { |
| | | d = new ClearBindInfoResponseAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("Bind/ClearBindInfo_Actions 退出" + System.DateTime.Now.ToString()); |
| | | |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | ///删除一个控制设备所有绑定数据,网关反馈信息 |
| | | /// </summary> |
| | | public ClearBindInfoResponseAllData clearBindInfoResponseAllData; |
| | | [System.Serializable] |
| | | public class ClearBindInfoResponseAllData |
| | | public class ClearBindInfoResponseAllData : ErrorResponCommon |
| | | { |
| | | /// <summary> |
| | | /// 错误信息 |
| | | /// </summary> |
| | | public string errorMessageBase; |
| | | /// <summary> |
| | | /// 网关信息错误反馈 |
| | | /// <para>当网关接收到客户端信息后,出现以下异常情况将反馈错误。</para> |
| | | /// </summary> |
| | | public ErrorResponData errorResponData; |
| | | /// <summary> |
| | | /// 控制设备绑定的设备列表回复数据 |
| | | /// </summary> |
| | |
| | | /// <summary> |
| | | /// 删除一个控制设备所有绑定信息回复的数据 |
| | | /// </summary> |
| | | public ClearBindInfoResponseData clearBindInfoResponseData; |
| | | [System.Serializable] |
| | | public class ClearBindInfoResponseData |
| | | { |