From 6fa9d69da922c8049f5acfcbb9ce9fd26811024c Mon Sep 17 00:00:00 2001
From: xm <1271024303@qq.com>
Date: 星期四, 16 四月 2020 17:10:57 +0800
Subject: [PATCH] 请合并代码
---
ZigbeeApp/Shared/Phone/ZigBee/Device/ZbGateway.cs | 4351 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 4,351 insertions(+), 0 deletions(-)
diff --git a/ZigbeeApp/Shared/Phone/ZigBee/Device/ZbGateway.cs b/ZigbeeApp/Shared/Phone/ZigBee/Device/ZbGateway.cs
new file mode 100755
index 0000000..a105443
--- /dev/null
+++ b/ZigbeeApp/Shared/Phone/ZigBee/Device/ZbGateway.cs
@@ -0,0 +1,4351 @@
+锘縰sing System;
+using System.Collections.Generic;
+using ZigBee.Common;
+using Shared;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Net.Sockets;
+using System.Net;
+using Newtonsoft.Json.Linq;
+using MQTTnet;
+using Shared.Common;
+using Shared.Phone.UserView;
+using MQTTnet.Client;
+using System.Threading.Tasks;
+
+namespace ZigBee.Device
+{
+ /// <summary>茠
+ /// ZigBee缃戝叧瀵硅薄
+ /// </summary>
+ [System.Serializable]
+ public class ZbGateway : ZbGatewayData
+ {
+ public ZbGateway()
+ {
+ this.Type = DeviceType.ZbGateway;
+ }
+
+
+
+ #region 缃戝叧鐗规畩淇℃伅澶勭悊
+ /// <summary>
+ /// 涓荤綉鍏�
+ /// </summary>
+ /// <value>The main gate way.</value>
+ public static ZbGateway MainGateWay
+ {
+ get
+ {
+ return GateWayList.Find((obj) => { return obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId && obj.getGatewayBaseInfo.IsMainGateWay; });
+ }
+ }
+
+ /// <summary>
+ /// 涓荤綉鍏�
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public bool IsMainGateWay
+ {
+ get
+ {
+ return getGatewayBaseInfo != null && getGatewayBaseInfo.IsMainGateWay;
+ }
+ }
+
+ /// <summary>
+ /// 鏄惁浣跨敤杩滅▼杩炴帴妯″紡
+ /// </summary>
+ /// <value><c>true</c> if is remote; otherwise, <c>false</c>.</value>
+ public static bool IsRemote;
+
+ /// <summary>
+ /// 鏄惁鎷ユ湁杩滅▼杩炴帴鐨勬潈闄�
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public static bool AllowRemoteCtrl = true;
+
+ /// <summary>
+ /// 缃戝叧淇濆瓨璺緞
+ /// </summary>
+ /// <value>The file path.</value>
+ [Newtonsoft.Json.JsonIgnore]
+ public override string FilePath
+ {
+ get
+ {
+ var deviceType = Type.ToString();
+ var fileName = "Gateway_" + deviceType + "_" + this.getGatewayBaseInfo?.gwID;
+ return fileName;
+ }
+ }
+
+ /// <summary>
+ /// 灞�鍩熺綉鍔犲瘑瀵嗙爜
+ /// </summary>
+ string password;
+ /// <summary>
+ /// 灞�鍩熺綉鍔犲瘑瀵嗛挜
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public string Password
+ {
+ get
+ {
+ if (password == null)
+ {
+ password = Guid.NewGuid().ToString().Substring(0, 16);
+ }
+ return password;
+ }
+ }
+
+ #region variable
+ /// <summary>
+ /// 杩滅▼杩炴帴鎴愬姛鏃剁殑鏃堕棿
+ /// </summary>
+ public static DateTime LoginRemoteDateTime = DateTime.Now;
+
+ /// <summary>
+ /// 鍚屾鍒拌繙绋嬬殑褰撳墠鏃堕棿鎴�
+ /// </summary>Re
+ public static ulong CurrentTimeStamp
+ {
+ get
+ {
+ return RemoteTimeStamp + (ulong)(DateTime.Now - LoginRemoteDateTime).TotalSeconds;
+ }
+ }
+
+ /// <summary>
+ /// 杩滅▼杩炴帴鎴愬姛鏃剁殑鏃堕棿鎴�
+ /// </summary>
+ public static ulong RemoteTimeStamp;
+ /// <summary>
+ /// 缃戝叧鏄惁鍔犲瘑
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public bool IsEncry;
+ /// <summary>
+ /// 缃戝叧褰撳墠鍏挜
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public string PubKey;
+ /// <summary>
+ /// 鎵�鏈夌殑缃戝叧鍒楄〃
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public static List<ZbGateway> GateWayList = new List<ZbGateway>();
+
+ //褰撳墠缃戝叧涓殑璁惧鍒楄〃
+ [Newtonsoft.Json.JsonIgnore]
+ public List<CommonDevice> DeviceList = new List<CommonDevice>();
+
+ /// <summary>
+ /// 缃戝叧涓満鏅垪琛�
+ /// 涓�涓満鏅腑鍖呭惈鎵�鏈変俊鎭紝鍖呮嫭鍦烘櫙璁惧淇℃伅
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public static List<Scene.GetSceneAllInfo> AllSceneList = new List<Scene.GetSceneAllInfo>();
+
+ /// <summary>
+ /// 缃戝叧涓満鏅殑璁惧鍒楄〃
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public List<Scene.GetSceneDeviceListInfo> SceneDeviceList = new List<Scene.GetSceneDeviceListInfo>();
+
+ #region action variable
+ /// <summary>
+ /// 鎺ユ敹鏁版嵁鍚庡洖璋�
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ Action<object> action;
+ /// <summary>
+ /// 璁剧疆鏁版嵁鍥炶皟
+ /// </summary>
+ public void SetAction(Action<object> action, int timeOut = 1000)
+ {
+ this.action = action;
+ }
+
+ /// <summary>
+ /// 缃戝叧鎺ㄩ�佹暟鎹�
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceInComingRespon:璁惧鏂颁笂鎶�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceStatusReport:璁惧涓婃姤</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� IASInfoReport:IAS瀹夐槻淇℃伅涓婃姤</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceStatusReport:璁惧涓婃姤</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� EnOrWithdrawSucceedReport:閫氳繃澶栭儴鏂瑰紡甯冮槻鎾ら槻鎴愬姛鏃舵姤鍛�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DownloadFileProgress:涓嬭浇杩涘害</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� CordinatorUpgradePercent:鍗忚皟鍣ㄥ崌绾х櫨鍒嗘瘮</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceUpgradePercent:鑺傜偣璁惧鍗囩骇鐧惧垎姣�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� VirtualDriveUpgrade:铏氭嫙璁惧鍗囩骇杩涘害</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� ZoneTriggerReport:闃插尯琚Е鍙戞椂鎶ュ憡</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� LogicExecuteReport:閫昏緫琚皟鐢ㄥ弽棣�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� TimingWillArrive:鏃堕棿鐐规潯浠舵帹杩熸墽琛�</para>
+ /// para>绗竴涓弬鏁帮細 濡傛灉涓� ModeTriggerReport:妯″紡瀹夐槻鍔ㄤ綔琚渶缁堟縺娲绘椂鍙戦�佹姤璀︿俊鎭�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� EnOrWithdrawSucceedReport:閫氳繃澶栭儴鏂瑰紡甯冮槻鎾ら槻鎴愬姛鏃舵姤鍛婃伅</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� PushTargetInfoReport:鑳佽揩瀵嗙爜鎾ら槻鏃剁煭淇℃帹閫�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceDefaultAck:鑺傜偣璁惧榛樿鍙嶉</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DDevice/IsGetEpointInfo:鏈夋柊璁惧鍔犲叆zigbee缃戠粶鍙嶉</para>璁惧璇锋眰APP鑾峰彇鍗囩骇鏁版嵁
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� Device/DeviceJoinZbNet:鑾峰彇鏂拌澶囨墍鏈夌鐐逛俊鎭槸鍚︽垚鍔熷弽棣�</para>
+ /// <para>绗竴涓弬鏁帮細濡傛灉涓� DeviceRequestAcUpdateData: 璁惧璇锋眰绌鸿皟鍙戝崌绾ф暟鎹�</para>
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public Action<string, object> ReportAction;
+ /// <summary>
+ /// 浜戠閫氳閿欒鏁版嵁涓婃姤
+ ///<para>"ForwardGatewayNoOnLine", "褰撳墠鎿嶄綔鐨勭綉鍏充笉鍦ㄧ嚎"</para>
+ ///<para>"AppTimeOut", "浠庝簯绔幏鍙栨暟鎹秴鏃讹紝璇烽噸鏂拌幏鍙�"</para>
+ ///<para>"AppNoLogin", "鐧诲綍杩囨湡锛岃閲嶆柊鐧诲綍"</para>
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public Action<string, string> CloudErrorAction;
+
+ /// <summary>
+ /// 缃戝叧鏂囦欢娴佸唴瀹归�氱煡
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public Action<string, byte[]> FileContentAction;
+
+ /// <summary>
+ /// 缃戝叧鍥炲鏁版嵁鍐呭閫氱煡
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public Action<string, string> GwResDataAction;
+
+ /// <summary>
+ /// 涓庣綉鍏抽�氳鏃跺彂閫佸拰鎺ユ敹鏁版嵁閫氱煡
+ /// </summary>
+ [Newtonsoft.Json.JsonIgnore]
+ public Action<string, string> Actions;
+ #endregion
+ #endregion
+ #endregion
+
+ #region 缃戝叧API
+ #region 缃戝叧淇℃伅
+ /// <summary>
+ ///鑾峰彇缃戝叧鐗堟湰淇℃伅
+ /// <para> gateway锛氬綋鍓嶇綉鍏�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GetGwVersionAllData> GetZbGwVersionInfoAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GetGwVersionAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GetGwVersionAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GetGwVersionAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GetZbGwVersionRespon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ gatewayTemp.getGwVersion = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwVersionData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.getGwVersion == null)
+ {
+ d = new GetGwVersionAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GetGwVersionAllData { getGwVersion = gatewayTemp.getGwVersion };
+ AppVersion = gatewayTemp.getGwVersion.AppVersion;
+ ZigbeeVersion = gatewayTemp.getGwVersion.ZigbeeVersion;
+ //Save();
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GetGwVersionData_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 92 } };
+ Send("GetZbGwVersion", 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 GetGwVersionAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GetGwVersionData_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鑾峰彇缃戝叧淇℃伅
+ /// <summary>
+ /// 鑾峰彇缃戝叧淇℃伅
+ /// <para> gateway锛氬綋鍓嶇綉鍏�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GetGwAllData> GetZbGwInfoAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GetGwAllData data = null;
+ Action<string, string> action = (topic, message) =>
+ {
+ var gatewayID = topic.Split('/')[0];
+ if (topic == gatewayID + "/" + "GetZbGwInfo_Respon")
+ {
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
+ gatewayTemp.getGwInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.getGwInfo == null)
+ {
+ data = new GetGwAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ data = new GetGwAllData { getGwData = gatewayTemp.getGwInfo };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{topic}");
+ }
+ }
+ };
+ Actions += action;
+
+ DebugPrintLog("GetGwData_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 95 } };
+ Send("GetZbGwInfo", jObject.ToString());
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (data != null)
+ {
+ break;
+ }
+ }
+
+ Actions -= action;
+ DebugPrintLog("GetGwData_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return data;
+ });
+ }
+ #endregion
+
+ #region 璇诲彇鍗忚皟鍣∕AC鍦板潃.
+ ///<summary >
+ /// 璇诲彇鍗忚皟鍣∕AC鍦板潃/绔偣榛樿鏄�08
+ /// </summary>
+ public async System.Threading.Tasks.Task<GetMacResponData> ReadMacAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GetMacResponData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GetMacResponData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GetMacResponData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGw/GetMac_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<MacAddrData>(jobject["Data"].ToString());
+
+ if (tempData == null)
+ {
+ d = new GetMacResponData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GetMacResponData { macAddrData = tempData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+
+ Actions += action;
+ var jObject = new JObject { { "Cluster_ID", 64512 }, { "Command", 13 } };
+ Send(("ZbGw/GetMac"), jObject.ToString());
+
+ 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 GetMacResponData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ return d;
+ });
+ }
+ #endregion
+
+ #region 淇敼缃戝叧鍚嶇О
+ /// <summary>
+ /// 淇敼缃戝叧鍚嶇О
+ ///<para>gwName锛氱綉鍏冲悕绉�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GwReNameAllData> GwReNameAsync(string gwName)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GwReNameAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GwReNameAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GwReNameAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GwReName_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ gatewayTemp.gwRename = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwReNameData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.gwRename == null)
+ {
+ d = new GwReNameAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GwReNameAllData { gwReNameData = gatewayTemp.gwRename };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GwReName_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var bytes = new byte[32];
+ var reamarkGwBytes = System.Text.Encoding.UTF8.GetBytes(gwName);
+ System.Array.Copy(reamarkGwBytes, 0, bytes, 0, 32 < reamarkGwBytes.Length ? 32 : reamarkGwBytes.Length);
+ gwName = System.Text.Encoding.UTF8.GetString(bytes);
+
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 91 } };
+ var data = new JObject { { "GwName", gwName } };
+ jObject.Add("Data", data);
+ Send("GwReName", 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 GwReNameAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GwReName_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 璁惧畾缃戝叧浣忓畢id
+ /// <summary>
+ /// 璁惧畾缃戝叧浣忓畢id
+ /// <para>homeId:浣忓畢id</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GwSetHomeIdAllData> GwSetHomeIdAsync(string homeId)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GwSetHomeIdAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GwSetHomeIdAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GwSetHomeIdAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GwSetHomeId_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ gatewayTemp.gwSetHomeId = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwSetHomeIdData>(jobject["Data"].ToString());
+ if (gatewayTemp.gwSetHomeId == null)
+ {
+ d = new GwSetHomeIdAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GwSetHomeIdAllData { gwSetHomeIdData = gatewayTemp.gwSetHomeId };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GwReName_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ //璐﹀彿ID
+ string accountId = string.Empty;
+ if (homeId != string.Empty)
+ {
+ if (Shared.Phone.UserCenter.UserCenterResourse.UserInfo.AuthorityNo == 1)
+ {
+ //涓昏处鍙�
+ accountId = Config.Instance.Guid;
+ }
+ else
+ {
+ accountId = Config.Instance.Home.MainUserDistributedMark;
+ }
+ }
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 82 } };
+ var data = new JObject { { "HomeId", homeId }, { "AccountId", accountId } };
+ jObject.Add("Data", data);
+ //浣忓畢ID鐨勮缃�,鍥哄畾浣跨敤灞�鍩熺綉,涓嶅瓨鍦ㄨ繙绋嬬殑璇存硶
+ SendLocation("GwSetHomeId", System.Text.Encoding.UTF8.GetBytes(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 GwSetHomeIdAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+
+ Actions -= action;
+ DebugPrintLog("GwReName_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鑾峰彇宸插叆缃戣澶囦俊鎭�
+ /// <summary>
+ /// 鑾峰彇缃戝叧璁惧淇℃伅(娉ㄦ剰锛岃繖涓帴鍙ｄ細琚幓鎺夛級
+ /// </summary>
+ public async System.Threading.Tasks.Task<List<CommonDevice>> GetGwDeviceList()
+ {
+ DeviceList.Clear();
+ return await System.Threading.Tasks.Task.Run((Func<System.Threading.Tasks.Task<List<CommonDevice>>>)(async () =>
+ {
+ var dateTime = DateTime.Now;
+ bool canBreak = false;
+ Action<string, string> action = (topic, message) =>
+ {
+ var gatewayID = topic.Split('/')[0];
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
+
+ if (topic == gatewayID + "/" + "DeviceInfoRespon")
+ {
+ dateTime = DateTime.Now;
+ var totalNum = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["TotalNum"].ToString());
+ if (totalNum == 0)
+ {
+ canBreak = true;
+ return;
+ }
+ var deviceID = jobject.Value<int>("Device_ID");
+ switch ((DeviceType)(deviceID))
+ {
+ //case DeviceType.DimmableLight:
+ // var dimmableLight = new DimmableLight() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // dimmableLight.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<DimmableLight.DeviceInfoData>(jobject["Data"].ToString());
+ // if (dimmableLight.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var light = DeviceList.Find(obj => obj.DeviceID == dimmableLight.DeviceID && obj.DeviceAddr == dimmableLight.DeviceAddr && obj.DeviceEpoint == dimmableLight.DeviceEpoint);
+ // if (light == null)
+ // {
+ // DeviceList.Add(dimmableLight);
+ // dimmableLight.DeviceName = dimmableLight.DeviceInfo.MacName;
+ // dimmableLight.DeviceEpointName = dimmableLight.DeviceInfo.DeviceName;
+ // dimmableLight.ImgVersion = dimmableLight.DeviceInfo.ImgVersion;
+ // dimmableLight.HwVersion = dimmableLight.DeviceInfo.HwVersion;
+ // dimmableLight.IsOnline = dimmableLight.DeviceInfo.IsOnline;
+ // dimmableLight.DriveCode = dimmableLight.DeviceInfo.DriveCode;
+ // dimmableLight.ImgTypeId = dimmableLight.DeviceInfo.ImgTypeId;
+ // dimmableLight.IasDeviceType = dimmableLight.DeviceInfo.DeviceType;
+ // dimmableLight.Profile = dimmableLight.DeviceInfo.Profile;
+ // dimmableLight.InClusterList = dimmableLight.DeviceInfo.InClusterList;
+ // dimmableLight.OutClusterList = dimmableLight.DeviceInfo.OutClusterList;
+ // dimmableLight.AttributeStatus = dimmableLight.DeviceInfo.AttributeStatus;
+ // //dimmableLight.Save();
+ // }
+ // else
+ // {
+ // light.DeviceInfo = dimmableLight.DeviceInfo;
+ // light.DeviceName = dimmableLight.DeviceInfo.MacName;
+ // light.DeviceEpointName = dimmableLight.DeviceInfo.DeviceName;
+ // light.ImgVersion = dimmableLight.DeviceInfo.ImgVersion;
+ // light.HwVersion = dimmableLight.DeviceInfo.HwVersion;
+ // light.IsOnline = dimmableLight.DeviceInfo.IsOnline;
+ // light.DriveCode = dimmableLight.DeviceInfo.DriveCode;
+ // light.ImgTypeId = dimmableLight.DeviceInfo.ImgTypeId;
+ // light.IasDeviceType = dimmableLight.DeviceInfo.DeviceType;
+ // light.Profile = dimmableLight.DeviceInfo.Profile;
+ // light.InClusterList = dimmableLight.DeviceInfo.InClusterList;
+ // light.OutClusterList = dimmableLight.DeviceInfo.OutClusterList;
+ // light.AttributeStatus = dimmableLight.DeviceInfo.AttributeStatus;
+ // //dimmableLight.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ // break;
+ //case DeviceType.OnOffSwitch:
+ // var panel = new Panel() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // panel.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<Panel.DeviceInfoData>(jobject["Data"].ToString());
+ // if (panel.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var panelInfo = DeviceList.Find(obj => obj.DeviceID == panel.DeviceID && obj.DeviceAddr == panel.DeviceAddr && obj.DeviceEpoint == panel.DeviceEpoint);
+ // if (panelInfo == null)
+ // {
+ // DeviceList.Add(panel);
+ // panel.DeviceName = panel.DeviceInfo.MacName;
+ // panel.DeviceEpointName = panel.DeviceInfo.DeviceName;
+ // panel.ImgTypeId = panel.DeviceInfo.ImgTypeId;
+ // panel.ImgVersion = panel.DeviceInfo.ImgVersion;
+ // panel.HwVersion = panel.DeviceInfo.HwVersion;
+ // panel.IasDeviceType = panel.DeviceInfo.DeviceType;
+ // panel.IsOnline = panel.DeviceInfo.IsOnline;
+ // panel.DriveCode = panel.DeviceInfo.DriveCode;
+ // panel.Profile = panel.DeviceInfo.Profile;
+ // panel.InClusterList = panel.DeviceInfo.InClusterList;
+ // panel.OutClusterList = panel.DeviceInfo.OutClusterList;
+ // panel.AttributeStatus = panel.DeviceInfo.AttributeStatus;
+ // //panel.Save();
+ // }
+ // else
+ // {
+ // panelInfo.DeviceInfo = panel.DeviceInfo;
+ // panelInfo.DeviceName = panel.DeviceInfo.MacName;
+ // panelInfo.DeviceEpointName = panel.DeviceInfo.DeviceName;
+ // panelInfo.ImgVersion = panel.DeviceInfo.ImgVersion;
+ // panelInfo.HwVersion = panel.DeviceInfo.HwVersion;
+ // panelInfo.IsOnline = panel.DeviceInfo.IsOnline;
+ // panelInfo.DriveCode = panel.DeviceInfo.DriveCode;
+ // panelInfo.IasDeviceType = panel.DeviceInfo.DeviceType;
+ // panelInfo.Profile = panel.DeviceInfo.Profile;
+ // panelInfo.ImgTypeId = panel.DeviceInfo.ImgTypeId;
+ // panelInfo.InClusterList = panel.DeviceInfo.InClusterList;
+ // panelInfo.OutClusterList = panel.DeviceInfo.OutClusterList;
+ // panelInfo.AttributeStatus = panel.DeviceInfo.AttributeStatus;
+ // //panel.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ // break;
+ //case DeviceType.OnOffOutput:
+ // var toggleLight = new ToggleLight() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // toggleLight.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ToggleLight.DeviceInfoData>(jobject["Data"].ToString());
+ // if (toggleLight.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var toggleLightInfo = DeviceList.Find(obj => obj.DeviceID == toggleLight.DeviceID && obj.DeviceAddr == toggleLight.DeviceAddr && obj.DeviceEpoint == toggleLight.DeviceEpoint);
+ // if (toggleLightInfo == null)
+ // {
+ // DeviceList.Add(toggleLight);
+ // toggleLight.DeviceName = toggleLight.DeviceInfo.MacName;
+ // toggleLight.DeviceEpointName = toggleLight.DeviceInfo.DeviceName;
+ // toggleLight.ImgVersion = toggleLight.DeviceInfo.ImgVersion;
+ // toggleLight.HwVersion = toggleLight.DeviceInfo.HwVersion;
+ // toggleLight.IsOnline = toggleLight.DeviceInfo.IsOnline;
+ // toggleLight.DriveCode = toggleLight.DeviceInfo.DriveCode;
+ // toggleLight.IasDeviceType = toggleLight.DeviceInfo.DeviceType;
+ // toggleLight.Profile = toggleLight.DeviceInfo.Profile;
+ // toggleLight.ImgTypeId = toggleLight.DeviceInfo.ImgTypeId;
+ // toggleLight.InClusterList = toggleLight.DeviceInfo.InClusterList;
+ // toggleLight.OutClusterList = toggleLight.DeviceInfo.OutClusterList;
+ // toggleLight.AttributeStatus = toggleLight.DeviceInfo.AttributeStatus;
+ // //toggleLight.Save();
+ // }
+ // else
+ // {
+ // toggleLightInfo.DeviceName = toggleLight.DeviceInfo.MacName;
+ // toggleLightInfo.DeviceEpointName = toggleLight.DeviceInfo.DeviceName;
+ // toggleLightInfo.ImgVersion = toggleLight.DeviceInfo.ImgVersion;
+ // toggleLightInfo.HwVersion = toggleLight.DeviceInfo.HwVersion;
+ // toggleLightInfo.IsOnline = toggleLight.DeviceInfo.IsOnline;
+ // toggleLightInfo.DriveCode = toggleLight.DeviceInfo.DriveCode;
+ // toggleLightInfo.IasDeviceType = toggleLight.DeviceInfo.DeviceType;
+ // toggleLightInfo.Profile = toggleLight.DeviceInfo.Profile;
+ // toggleLightInfo.ImgTypeId = toggleLight.DeviceInfo.ImgTypeId;
+ // toggleLightInfo.InClusterList = toggleLight.DeviceInfo.InClusterList;
+ // toggleLightInfo.OutClusterList = toggleLight.DeviceInfo.OutClusterList;
+ // toggleLightInfo.AttributeStatus = toggleLight.DeviceInfo.AttributeStatus;
+ // toggleLightInfo.DeviceInfo = toggleLight.DeviceInfo;
+ // //toggleLightInfo.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ // break;
+ //case DeviceType.AirSwitch:
+ // var airSwitch = new AirSwitch() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // airSwitch.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<AirSwitch.DeviceInfoData>(jobject["Data"].ToString());
+ // if (airSwitch.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var airSwitchInfo = DeviceList.Find(obj => obj.DeviceID == airSwitch.DeviceID && obj.DeviceAddr == airSwitch.DeviceAddr && obj.DeviceEpoint == airSwitch.DeviceEpoint);
+ // if (airSwitchInfo == null)
+ // {
+ // DeviceList.Add(airSwitch);
+ // airSwitch.DeviceName = airSwitch.DeviceInfo.MacName;
+ // airSwitch.DeviceEpointName = airSwitch.DeviceInfo.DeviceName;
+ // airSwitch.ImgVersion = airSwitch.DeviceInfo.ImgVersion;
+ // airSwitch.HwVersion = airSwitch.DeviceInfo.HwVersion;
+ // airSwitch.IsOnline = airSwitch.DeviceInfo.IsOnline;
+ // airSwitch.DriveCode = airSwitch.DeviceInfo.DriveCode;
+ // airSwitch.IasDeviceType = airSwitch.DeviceInfo.DeviceType;
+ // airSwitch.Profile = airSwitch.DeviceInfo.Profile;
+ // airSwitch.ImgTypeId = airSwitch.DeviceInfo.ImgTypeId;
+ // airSwitch.InClusterList = airSwitch.DeviceInfo.InClusterList;
+ // airSwitch.OutClusterList = airSwitch.DeviceInfo.OutClusterList;
+ // airSwitch.AttributeStatus = airSwitch.DeviceInfo.AttributeStatus;
+ // //airSwitch.Save();
+ // }
+ // else
+ // {
+ // airSwitchInfo.DeviceName = airSwitch.DeviceInfo.MacName;
+ // airSwitchInfo.DeviceEpointName = airSwitch.DeviceInfo.DeviceName;
+ // airSwitchInfo.ImgVersion = airSwitch.DeviceInfo.ImgVersion;
+ // airSwitchInfo.HwVersion = airSwitch.DeviceInfo.HwVersion;
+ // airSwitchInfo.IsOnline = airSwitch.DeviceInfo.IsOnline;
+ // airSwitchInfo.DriveCode = airSwitch.DeviceInfo.DriveCode;
+ // airSwitchInfo.IasDeviceType = airSwitch.DeviceInfo.DeviceType;
+ // airSwitchInfo.Profile = airSwitch.DeviceInfo.Profile;
+ // airSwitchInfo.ImgTypeId = airSwitch.DeviceInfo.ImgTypeId;
+ // airSwitchInfo.InClusterList = airSwitch.DeviceInfo.InClusterList;
+ // airSwitchInfo.OutClusterList = airSwitch.DeviceInfo.OutClusterList;
+ // airSwitchInfo.AttributeStatus = airSwitch.DeviceInfo.AttributeStatus;
+ // airSwitchInfo.DeviceInfo = airSwitch.DeviceInfo;
+ // // airSwitchInfo.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ // break;
+ //case DeviceType.WindowCoveringDevice:
+ // var windowCovering = new Rollershade() { DeviceID = jobject.Value<int>((object)"Device_ID"), DeviceAddr = jobject.Value<string>((object)"DeviceAddr"), DeviceEpoint = jobject.Value<int>((object)"Epoint"), DataID = jobject.Value<int>((object)"Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // windowCovering.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<Rollershade.DeviceInfoData>(jobject["Data"].ToString());
+ // if (windowCovering.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var wc = DeviceList.Find(obj => obj.DeviceID == windowCovering.DeviceID && obj.DeviceAddr == windowCovering.DeviceAddr && obj.DeviceEpoint == windowCovering.DeviceEpoint);
+ // if (wc == null)
+ // {
+ // DeviceList.Add(windowCovering);
+ // windowCovering.DeviceName = windowCovering.DeviceInfo.MacName;
+ // windowCovering.DeviceEpointName = windowCovering.DeviceInfo.DeviceName;
+ // windowCovering.ImgVersion = windowCovering.DeviceInfo.ImgVersion;
+ // windowCovering.HwVersion = windowCovering.DeviceInfo.HwVersion;
+ // windowCovering.IsOnline = windowCovering.DeviceInfo.IsOnline;
+ // windowCovering.DriveCode = windowCovering.DeviceInfo.DriveCode;
+ // windowCovering.IasDeviceType = windowCovering.DeviceInfo.DeviceType;
+ // windowCovering.Profile = windowCovering.DeviceInfo.Profile;
+ // windowCovering.ImgTypeId = windowCovering.DeviceInfo.ImgTypeId;
+ // windowCovering.InClusterList = windowCovering.DeviceInfo.InClusterList;
+ // windowCovering.OutClusterList = windowCovering.DeviceInfo.OutClusterList;
+ // windowCovering.AttributeStatus = windowCovering.DeviceInfo.AttributeStatus;
+ // //windowCovering.Save();
+ // }
+ // else
+ // {
+ // wc.DeviceName = windowCovering.DeviceInfo.MacName;
+ // wc.DeviceEpointName = windowCovering.DeviceInfo.DeviceName;
+ // wc.DeviceInfo = windowCovering.DeviceInfo;
+ // wc.ImgVersion = windowCovering.DeviceInfo.ImgVersion;
+ // wc.HwVersion = windowCovering.DeviceInfo.HwVersion;
+ // wc.IsOnline = windowCovering.DeviceInfo.IsOnline;
+ // wc.DriveCode = windowCovering.DeviceInfo.DriveCode;
+ // wc.IasDeviceType = windowCovering.DeviceInfo.DeviceType;
+ // wc.Profile = windowCovering.DeviceInfo.Profile;
+ // wc.ImgTypeId = windowCovering.DeviceInfo.ImgTypeId;
+ // wc.InClusterList = windowCovering.DeviceInfo.InClusterList;
+ // wc.OutClusterList = windowCovering.DeviceInfo.OutClusterList;
+ // wc.AttributeStatus = windowCovering.DeviceInfo.AttributeStatus;
+ // // wc.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ // break;
+ //case DeviceType.IASZone:
+ // var ias = new IASZone() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ // ias.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.DeviceInfoData>(jobject["Data"].ToString());
+ // if (ias.DeviceInfo == null)
+ // {
+ // return;
+ // }
+ // var infoIAS = DeviceList.Find(obj => obj.DeviceID == ias.DeviceID && obj.DeviceAddr == ias.DeviceAddr && obj.DeviceEpoint == ias.DeviceEpoint);
+ // if (infoIAS == null)
+ // {
+ // DeviceList.Add(ias);
+ // ias.DeviceName = ias.DeviceInfo.MacName;
+ // ias.DeviceEpointName = ias.DeviceInfo.DeviceName;
+ // ias.ImgVersion = ias.DeviceInfo.ImgVersion;
+ // ias.HwVersion = ias.DeviceInfo.HwVersion;
+ // ias.IsOnline = ias.DeviceInfo.IsOnline;
+ // ias.DriveCode = ias.DeviceInfo.DriveCode;
+ // ias.IasDeviceType = ias.DeviceInfo.DeviceType;
+ // ias.Profile = ias.DeviceInfo.Profile;
+ // ias.ImgTypeId = ias.DeviceInfo.ImgTypeId;
+ // ias.InClusterList = ias.DeviceInfo.InClusterList;
+ // ias.OutClusterList = ias.DeviceInfo.OutClusterList;
+ // ias.AttributeStatus = ias.DeviceInfo.AttributeStatus;
+ // //ias.Save();
+ // }
+ // else
+ // {
+ // infoIAS.DeviceName = ias.DeviceInfo.MacName;
+ // infoIAS.DeviceEpointName = ias.DeviceInfo.DeviceName;
+ // infoIAS.DeviceEpointName = ias.DeviceInfo.DeviceName;
+ // infoIAS.ImgVersion = ias.DeviceInfo.ImgVersion;
+ // infoIAS.HwVersion = ias.DeviceInfo.HwVersion;
+ // infoIAS.IsOnline = ias.DeviceInfo.IsOnline;
+ // infoIAS.DriveCode = ias.DeviceInfo.DriveCode;
+ // infoIAS.IasDeviceType = ias.DeviceInfo.DeviceType;
+ // infoIAS.Profile = ias.DeviceInfo.Profile;
+ // infoIAS.ImgTypeId = ias.DeviceInfo.ImgTypeId;
+ // infoIAS.InClusterList = ias.DeviceInfo.InClusterList;
+ // infoIAS.OutClusterList = ias.DeviceInfo.OutClusterList;
+ // infoIAS.AttributeStatus = ias.DeviceInfo.AttributeStatus;
+ // infoIAS.DeviceInfo = ias.DeviceInfo;
+ // //ias.ReSave();
+ // }
+ // DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ // break;
+ //case DeviceType.OtaDevice:
+ //case DeviceType.OtaPanelDevice:
+ //var ota = new OTADevice() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ //ota.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceInfoData>(jobject["Data"].ToString());
+ //if (ota.DeviceInfo == null)
+ //{
+ // return;
+ //}
+ //var infoOta = DeviceList.Find(obj => obj.DeviceID == ota.DeviceID && obj.DeviceAddr == ota.DeviceAddr && obj.DeviceEpoint == ota.DeviceEpoint);
+ //if (infoOta == null)
+ //{
+ // DeviceList.Add(ota);
+ // ota.DeviceName = ota.DeviceInfo.MacName;
+ // ota.DeviceEpointName = ota.DeviceInfo.DeviceName;
+ // ota.ImgVersion = ota.DeviceInfo.ImgVersion;
+ // ota.HwVersion = ota.DeviceInfo.HwVersion;
+ // ota.IsOnline = ota.DeviceInfo.IsOnline;
+ // ota.DriveCode = ota.DeviceInfo.DriveCode;
+ // ota.IasDeviceType = ota.DeviceInfo.DeviceType;
+ // ota.Profile = ota.DeviceInfo.Profile;
+ // ota.ImgTypeId = ota.DeviceInfo.ImgTypeId;
+ // ota.InClusterList = ota.DeviceInfo.InClusterList;
+ // ota.OutClusterList = ota.DeviceInfo.OutClusterList;
+ // ota.AttributeStatus = ota.DeviceInfo.AttributeStatus;
+ // //ota.Save();
+ //}
+ //else
+ //{
+ // infoOta.DeviceName = ota.DeviceInfo.MacName;
+ // infoOta.DeviceEpointName = ota.DeviceInfo.DeviceName;
+ // infoOta.DeviceEpointName = ota.DeviceInfo.DeviceName;
+ // infoOta.ImgVersion = ota.DeviceInfo.ImgVersion;
+ // infoOta.HwVersion = ota.DeviceInfo.HwVersion;
+ // infoOta.IsOnline = ota.DeviceInfo.IsOnline;
+ // infoOta.DriveCode = ota.DeviceInfo.DriveCode;
+ // infoOta.IasDeviceType = ota.DeviceInfo.DeviceType;
+ // infoOta.Profile = ota.DeviceInfo.Profile;
+ // infoOta.ImgTypeId = ota.DeviceInfo.ImgTypeId;
+ // infoOta.InClusterList = ota.DeviceInfo.InClusterList;
+ // infoOta.OutClusterList = ota.DeviceInfo.OutClusterList;
+ // infoOta.AttributeStatus = ota.DeviceInfo.AttributeStatus;
+ // infoOta.DeviceInfo = ota.DeviceInfo;
+ // //ota.ReSave();
+ //}
+ //DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ //break;
+ //case DeviceType.Thermostat:
+ //var thermostat = new ThermostatObj() { 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 };
+ //thermostat.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ThermostatObj.DeviceInfoData>(jobject["Data"].ToString());
+ //if (thermostat.DeviceInfo == null)
+ //{
+ // return;
+ //}
+ //var ther = gateway.DeviceList.Find(obj => obj.DeviceID == thermostat.DeviceID && obj.DeviceAddr == thermostat.DeviceAddr && obj.DeviceEpoint == thermostat.DeviceEpoint);
+ //if (ther == null)
+ //{
+ // gateway.DeviceList.Add(thermostat);
+ // thermostat.DeviceName = thermostat.DeviceInfo.DeviceName;
+ // IO.LocalFileUtils.SaveDeviceInfo(thermostat, thermostat.DeviceEpoint.ToString());
+ //}
+ //else
+ //{
+ // ther.DeviceName = thermostat.DeviceInfo.DeviceName;
+ // ther.DeviceInfo = thermostat.DeviceInfo;
+ // ZigBee.IO.LocalFileUtils.SaveDeviceInfo(ther, ther.DeviceEpoint.ToString());
+ //}
+ //break;
+ //case DeviceType.TemperatureSensor:
+ //var temperatureSensor = new TemperatureSensor() { 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 };
+ //temperatureSensor.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<TemperatureSensor.DeviceInfoData>(jobject["Data"].ToString());
+ //if (temperatureSensor.DeviceInfo == null)
+ //{
+ // return;
+ //}
+ //var ts = gateway.DeviceList.Find(obj => obj.DeviceID == temperatureSensor.DeviceID && obj.DeviceAddr == temperatureSensor.DeviceAddr && obj.DeviceEpoint == temperatureSensor.DeviceEpoint);
+ //if (ts == null)
+ //{
+ // gateway.DeviceList.Add(temperatureSensor);
+ // temperatureSensor.DeviceName = temperatureSensor.DeviceInfo.DeviceName;
+ // IO.LocalFileUtils.SaveDeviceInfo(temperatureSensor, temperatureSensor.DeviceEpoint.ToString());
+ //}
+ //else
+ //{
+ // ts.DeviceName = temperatureSensor.DeviceInfo.DeviceName;
+ // ts.DeviceInfo = temperatureSensor.DeviceInfo;
+ // IO.LocalFileUtils.SaveDeviceInfo(ts, ts.DeviceEpoint.ToString());
+ //}
+ //break;
+
+ }
+ }
+ else if (topic == gatewayID + "/" + "DeviceInfoResponEnd")
+ {
+ canBreak = true;
+ }
+ };
+
+ Actions += action;
+ DebugPrintLog("DeviceInfo Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 93 } };
+ Send("GetDeviceInfo", jObject.ToString());
+ }
+ catch { }
+
+ while (canBreak == false && (DateTime.Now - dateTime).TotalMilliseconds < 6000)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ }
+
+ Actions -= action;
+ DebugPrintLog("DeviceInfo_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return DeviceList;
+ }));
+ }
+ #endregion
+
+ #region 鑾峰彇缃戝叧璁板綍鐨勮澶囧睘鎬х姸鎬�
+ /// <summary>
+ ///鑾峰彇缃戝叧璁板綍鐨勮澶囧睘鎬х姸鎬�
+ /// </summary>
+ public async System.Threading.Tasks.Task<GetStatusRecordAllInfo> GetStatusRecordAsync(string deviceAddr, int deviceEpoint)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GetStatusRecordAllInfo 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GetStatusRecordAllInfo { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GetStatusRecordAllInfo { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GetStatusRecord_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 = this.getGatewayBaseInfo?.gwID };
+ gatewayTemp.getStatusRecordInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GetStatusRecordInfo>(jobject["Data"].ToString());
+
+ if (gatewayTemp.getStatusRecordInfo == null)
+ {
+ d = new GetStatusRecordAllInfo { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GetStatusRecordAllInfo { getStatusRecordInfo = gatewayTemp.getStatusRecordInfo };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GetStatusRecord_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var jObject = new JObject { { "DeviceAddr", deviceAddr }, { "Epoint", deviceEpoint }, { "Cluster_ID", 0 }, { "Command", 80 } };
+ Send("GetStatusRecord", 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 GetStatusRecordAllInfo { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GetStatusRecord_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鍏佽璁惧鍏ョ綉
+ ///<summary >
+ /// 鎼滅储鏂板叆缃戠殑璁惧锛堝厑璁歌澶囧叆缃戯級
+ /// <para>Time:0-255,0:鍏抽棴鎼滅储,255:涓�鐩村紑鍚�</para>
+ /// </summary>
+ public async void AddNewDeviceToGateway(int time = 3)
+ {
+ await System.Threading.Tasks.Task.Run(async () =>
+ {
+ CommonDevice commonDev = null;
+ Action<string, string> action1 = (topic, message) => { };
+ Actions += action1;
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 94 } };
+ var data = new JObject { { "Time", time } };
+ jObject.Add("Data", data);
+ Send(("SearchNewDevice"), jObject.ToString());
+
+ Actions -= action1;
+ });
+ }
+ #endregion
+
+ #region 鍗忚皟鍣ㄦ仮澶嶅嚭鍘傝缃�
+ ///<summary >
+ ///zigbee鍗忚皟鍣ㄦ仮澶嶅嚭鍘傝缃�
+ /// <para>DelAllInfo:0/1</para>
+ ///<para> 0:浠呭皢鍗忚皟鍣ㄦ仮澶嶅嚭鍘傝缃紝涓嶅垹闄ょ綉鍏充繚瀛樼殑璁惧鍒楄〃锛岀粍鍒楄〃锛屽満鏅垪琛ㄧ瓑淇℃伅銆�</para>
+ ///<para>1锛氬皢鍗忚皟鍣ㄦ仮澶嶅嚭鍘傝缃紝骞跺垹闄ょ綉鍏充繚瀛樼殑璁惧鍒楄〃锛岀粍鍒楄〃锛屽満鏅垪琛ㄧ瓑淇℃伅銆�</para>
+ /// </summary>
+ public void GwOperationReset(int delAllInfo)
+ {
+ Action<string, string> action = (topic, message) => { };
+ Actions += action;
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 160 } };
+ var data = new JObject { { "DelAllInfo", delAllInfo } };
+ jObject.Add("Data", data);
+ Send(("ZbGwOperation/Reset"), jObject.ToString());
+ }
+ catch { }
+
+ Actions -= action;
+ }
+ #endregion
+
+ #region 缃戝叧鎭㈠鍑哄巶璁剧疆
+ ///<summary >
+ ///缃戝叧鎭㈠鍑哄巶璁剧疆
+ /// <para>璇ユ寚浠ょ敤浜庣綉鍏砽inux绯荤粺鎭㈠鍑哄巶璁剧疆銆傛仮澶嶅嚭鍘傝缃悗锛岀郴缁熷皢鑷姩閲嶅惎</para>
+ /// <para>0锛氬懡浠ゅ凡鎺ユ敹锛岀郴缁熷嵆灏嗘仮澶嶅嚭鍘傚苟閲嶅惎銆�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GwLinuxResetResponData> GwLinuxResetAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GwLinuxResetResponData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GwLinuxResetResponData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GwLinuxResetResponData { errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GwLinuxReset_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 = this.getGatewayBaseInfo?.gwID };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"].ToString());
+
+ if (result == null)
+ {
+ d = new GwLinuxResetResponData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GwLinuxResetResponData { Result = result };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GwLinuxReset Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 84 } };
+ Send("GwLinuxReset", 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 GwLinuxResetResponData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GwLinuxReset Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 閲嶅惎缃戝叧绯荤粺
+ ///<summary >
+ ///閲嶅惎缃戝叧绯荤粺
+ /// <para>鍙戦�佽鎸囦护灏嗕娇缃戝叧涓诲姩鏂紑鎵�鏈塵qtt杩炴帴骞舵墽琛岄噸鍚�傞噸鍚椂闂村ぇ绾﹂渶瑕�60绉�</para>
+ /// <para>杩斿洖鍊兼槸0:鍛戒护宸叉帴鏀讹紝绯荤粺鍗冲皢閲嶅惎銆�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<GwRebootResponAllData> GwRebootAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GwRebootResponAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new GwRebootResponAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GwRebootResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "GwReboot_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 = this.getGatewayBaseInfo?.gwID };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"].ToString());
+
+ if (result == null)
+ {
+ d = new GwRebootResponAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new GwRebootResponAllData { Result = result };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("GwReboot Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 83 } };
+ Send("GwReboot", 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 GwRebootResponAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GwReboot Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 缃戝叧鍜屽崗璋冨櫒鍗囩骇
+ ///<summary >
+ ///淇濆瓨zigbee鍗忚皟鍣ㄧ粍缃戜俊鎭�
+ /// </summary>
+ public async System.Threading.Tasks.Task<SaveNVFileResponseAllData> SaveNVFile(string imageName, string imagePath)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ SaveNVFileResponseAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new SaveNVFileResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new SaveNVFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGwOperation/SaveNVFile_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.zbGwOperationSaveNVFileData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.SaveNVFileResponseData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.zbGwOperationSaveNVFileData == null)
+ {
+ d = new SaveNVFileResponseAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new SaveNVFileResponseAllData { saveNVFileResponseData = gatewayTemp.zbGwOperationSaveNVFileData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("ZbGwOperation/SaveNVFile Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 500 } };
+ var data = new JObject { { "ImageName", imageName }, { "ImagePath", imagePath } };
+ jObject.Add("Data", data);
+ Send(("ZbGwOperation/SaveNVFile"), 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 SaveNVFileResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("ZbGwOperation/SaveNVFile Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鍗忚皟鍣ㄦ仮澶嶇粍缃戜俊鎭�
+ ///<summary >
+ ///鍗忚皟鍣ㄦ仮澶嶇粍缃戜俊鎭�
+ /// </summary>
+ public async System.Threading.Tasks.Task<RestoreNVAllDtta> RestoreNV(string imageName, string imagePath)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ RestoreNVAllDtta 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new RestoreNVAllDtta { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new RestoreNVAllDtta { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+
+ if (topic == gatewayID + "/" + "ZbGwOperation/RestoreNV_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.RestoreNVDtta>(jobject["Data"].ToString());
+
+ if (tempData == null)
+ {
+ d = new RestoreNVAllDtta { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new RestoreNVAllDtta { restoreNVDtta = tempData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("ZbGwOperation/RestoreNV Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 501 } };
+ var data = new JObject { { "ImageName", imageName }, { "ImagePath", imagePath } };
+ jObject.Add("Data", data);
+ Send(("ZbGwOperation/RestoreNV"), 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 RestoreNVAllDtta { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("ZbGwOperation/RestoreNV Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鑾峰彇鍗忚皟鍣ㄥ綋鍓嶄俊閬�.
+ ///<summary >
+ /// 鑾峰彇鍗忚皟鍣ㄥ綋鍓嶄俊閬�
+ /// </summary>
+ public async System.Threading.Tasks.Task<GwGetChannelResponData> GetChannelAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ GwGetChannelResponData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+ if (temp == null)
+ {
+ d = new GwGetChannelResponData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new GwGetChannelResponData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGw/GetChannel_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var channel = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Channel"].ToString());
+ d = new GwGetChannelResponData { channel = channel };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ };
+
+ Actions += action;
+ DebugPrintLog("ZbGw/GetChannel Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 64512 }, { "Command", 8 } };
+ Send(("ZbGw/GetChannel"), 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 GwGetChannelResponData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("ZbGw/GetChannel Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鏇存敼鍗忚皟鍣ㄥ綋鍓嶄俊閬�
+ ///<summary >
+ /// 鏇存敼鍗忚皟鍣ㄥ綋鍓嶄俊閬�
+ /// <para>Channel:瑕佹洿鏀圭殑淇￠亾: 11 -26</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<ChangeChannelResponAllData> ChangeChannelAsync(int channel)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ ChangeChannelResponAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new ChangeChannelResponAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new ChangeChannelResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGw/ChangeChannel_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var tempInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ChangeChannelResponData>(jobject["Data"].ToString());
+
+ if (tempInfo == null)
+ {
+ d = new ChangeChannelResponAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new ChangeChannelResponAllData { changeChannelResponData = tempInfo };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+
+ }
+ }
+ };
+
+ Actions += action;
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 64512 }, { "Command", 9 } };
+ var data = new JObject { { "Channel", channel } };
+ jObject.Add("Data", data);
+ Send(("ZbGw/ChangeChannel"), 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 ChangeChannelResponAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鏁版嵁閫忎紶1锛堟暟鎹槸鍗佸叚杩涘埗褰㈠紡鐨勫瓧绗︿覆锛�
+ ///<summary >
+ ///瀹㈡埛绔悜鑺傜偣璁惧閫忎紶鏁版嵁锛岋紙鏁版嵁鏄崄鍏繘鍒跺舰寮忕殑瀛楃涓诧級
+ /// <para>deviceAddr:璁惧鐨刴ac鍦板潃</para>
+ /// <para>devicePoint:璁惧绔彛鍙�</para>
+ /// <para>PassData:閫忎紶鐨勬暟鎹紝鏈�澶�256涓瓧绗︼紝涔熷氨鏄�忎紶128涓瓧鑺�</para>
+ /// </summary>
+ public async void ClientDataPassthrough(string deviceAddr, int devicePoint, string passData)
+ {
+ await System.Threading.Tasks.Task.Run(async () =>
+ {
+ Action<string, string> action = (topic, message) => { };
+ Actions += action;
+ try
+ {
+ var jObject = new JObject { { "DeviceAddr", deviceAddr }, { "Epoint", devicePoint }, { "Cluster_ID", 64513 }, { "Command", 0 } };
+ Send(("ClientDataPassthrough"), jObject.ToString());
+ }
+ catch { }
+ Actions -= action;
+ });
+ }
+
+ #region 鏁版嵁閫忎紶2锛堟暟鎹槸浜岃繘鍒舵祦锛�
+ ///<summary >
+ /// 瀹㈡埛绔彂閫佹枃浠舵祦鍒扮綉鍏筹紙鏁版嵁鏄簩杩涘埗娴侊級
+ ///<para> passData: 閫忎紶鏁版嵁</para>
+ ///<para>Result 0: 鏁版嵁鍐欏叆鎴愬姛,璇锋眰鍙戦�佷笅涓�涓暟鎹寘</para>
+ ///<para>Result1锛氭暟鎹啓鍏ュけ璐�</para>
+ ///<para>Result2锛氭暟鎹В鏋愰敊璇�</para>
+ ///<para>Result3锛氬彂閫佹暟鎹ぇ灏忚秴鍑洪檺鍒�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<Panel.PanelSwitchLevelInfo> ClientDataPassthroughBytesAsync(string deviceAddr, int devicePoint, long dataLength, byte[] passData)
+ {
+ Panel.PanelSwitchLevelInfo result = null;
+ if (Gateway == null)
+ {
+ result = new Panel.PanelSwitchLevelInfo { errorMessageBase = "褰撳墠娌℃湁缃戝叧" };
+ return result;
+ }
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ 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)
+ {
+ result = new Panel.PanelSwitchLevelInfo { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ result = new Panel.PanelSwitchLevelInfo { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbDataPassthrough")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.clientDataPassthroughResponseData == null)
+ {
+ result = new Panel.PanelSwitchLevelInfo { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ if (gatewayTemp.clientDataPassthroughResponseData?.PassData != null)
+ {
+ var data = gatewayTemp.clientDataPassthroughResponseData.PassData;
+ if (data.Length == 14)
+ {
+ var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
+ if (command == "0407")
+ {
+ var level1 = Convert.ToInt32(data[10].ToString() + data[11].ToString(), 16);
+ var level2 = Convert.ToInt32(data[12].ToString() + data[13].ToString(), 16);
+ result = new Panel.PanelSwitchLevelInfo { panelDirectionsLevel = level1, panelBacklightLevel = level2 };
+ System.Console.WriteLine($"UI鏀跺埌閫氱煡鍚庣殑涓婚_command:0406_{ topic}");
+ }
+ }
+ }
+ }
+ }
+ };
+
+ Gateway.Actions += action;
+ System.Console.WriteLine("ClientDataPassthrough_Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var sendDataBytes = new byte[12 + dataLength];
+ sendDataBytes[0] = 0xfe;
+ //璁惧绔偣锛�1涓猙ytes
+ sendDataBytes[1] = Convert.ToByte(devicePoint);
+ //璁惧mac鍦板潃锛屽皬绔粨鏋�,8涓猙ytes
+ //var addrAllBytes = new byte[8];
+ int j = 0;
+ for (int i = 14; i >= 0; i = i - 2)
+ {
+ var curByte = deviceAddr.Substring(i, 2); //00 0d 6f ff fe 04 51 52
+
+ sendDataBytes[2 + j] = Convert.ToByte(string.Format("0x{0}", curByte), 16);
+ j++;
+ }
+ //鏁版嵁闀垮害锛�1涓猙ytes
+ sendDataBytes[10] = Convert.ToByte(dataLength % 256); // DataLen 0x01 鍒� 0x800 锛堝嵆姣忔鏈�澶у彂閫�2048瀛楄妭锛�2
+ sendDataBytes[11] = Convert.ToByte(dataLength / 256);
+ //閫忎紶鏁版嵁
+ System.Array.Copy(passData, 0, sendDataBytes, 12, dataLength);
+ await Send("ClientDataPassthrough", sendDataBytes);
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (result != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ result = new Panel.PanelSwitchLevelInfo { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Gateway.Actions -= action;
+ System.Console.WriteLine("ClientDataPassthrough_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return result;
+ });
+ }
+ #endregion
+
+ #endregion
+
+ #region 鍚敤鎴栧叧闂�忎紶鏁版嵁涓婁紶鎺ュ彛
+ /// <summary>
+ /// 鍚敤鎴栧叧闂�忎紶鏁版嵁涓婁紶鎺ュ彛
+ /// </summary>
+ /// <returns>The scene new identifier async.</returns>
+ /// <param name="gateway">Gateway.</param>
+ /// <param name="IsOn">0锛氬叧闂�忎紶鏁版嵁涓婁紶 ;1锛氬紑鍚�忎紶鏁版嵁涓婁紶</param>
+ public async System.Threading.Tasks.Task<PassthroughAllData> GetSceneNewIdAsync(int IsOn)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ PassthroughAllData 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() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new PassthroughAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ d = new PassthroughAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbDataPassthrough")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<string>(jobject["Data"].ToString());
+
+ if (gatewayTemp.getGwVersion == null)
+ {
+ d = new PassthroughAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new PassthroughAllData { passData = temp };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("ZbDataPassthrough_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 64513 }, { "Command", 1 } };
+ Send("GetZbGwVersion", 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 PassthroughAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("GetGwVersionData_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 缃戝叧鍗囩骇
+ /// <summary>
+ /// 缃戝叧鍗囩骇
+ /// </summary>
+ /// <returns>The upgrade async.</returns>
+ /// <param name="imageName">Image name:(鍗囩骇鍥轰欢鍚嶇О锛屽悕绉颁腑瑕佸甫鏈夆�淟INUXMODULE鈥濇爣璇嗭紝鍚﹀垯灏嗕笉浼氬崌绾с�傛渶澶�128瀛楄妭</param>
+ public async System.Threading.Tasks.Task<LinuxUpgradeAllData> LinuxUpgradeAsync(string imageName)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ LinuxUpgradeAllData 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 = this.getGatewayBaseInfo?.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new LinuxUpgradeAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ d = new LinuxUpgradeAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGwOperation/LinuxUpgrade_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
+ d = new LinuxUpgradeAllData { Result = result };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ };
+ Actions += action;
+ DebugPrintLog("ZbGwOperation/LinuxUpgrade_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 503 } };
+ var data = new JObject {
+ { "IsForce", 0},
+ { "SaveChange", 1},
+ { "ImageName", imageName},
+ { "ImagePath", "/tmp"}
+ };
+ jObject.Add("Data", data);
+ Send(("ZbGwOperation/LinuxUpgrade"), jObject.ToString());
+ }
+ catch { }
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < 30 * 1000)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (d != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > 30 * 1000)
+ {
+ d = new LinuxUpgradeAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("ZbGwOperation/LinuxUpgrade_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鍗忚皟鍣ㄥ崌绾�
+ /// <summary>
+ /// 鍗忚皟鍣ㄥ崌绾�
+ /// </summary>
+ /// <returns>The NVA sync.</returns>
+ /// <param name="imageName">Image name:(鍗囩骇闀滃儚鍚嶇О锛屽悕绉颁腑瑕佸甫鏈夆�淶BMODULE鈥濇爣璇嗭紝鍚﹀垯涓嶅厑璁稿崌绾с�傛渶澶�128瀛楄妭銆�)</param>
+ public async System.Threading.Tasks.Task<ZbGwOperationUpgradeAllData> UpgradeNVAsync(string imageName)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ ZbGwOperationUpgradeAllData 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new ZbGwOperationUpgradeAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ d = new ZbGwOperationUpgradeAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "ZbGwOperation/Upgrade_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ZbGwOperationUpgradeData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.zbGwOperationUpgradeData == null)
+ {
+ d = new ZbGwOperationUpgradeAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new ZbGwOperationUpgradeAllData { bGwOperationUpgradeData = gatewayTemp.zbGwOperationUpgradeData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("ZbGwOperation/Upgrade_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 502 } };
+ var data = new JObject { { "ImageName", imageName }, { "ImagePath", "/tmp" } };
+ jObject.Add("Data", data);
+ Send(("ZbGwOperation/Upgrade"), jObject.ToString());
+ }
+ catch
+ { }
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < 30 * 1000)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (d != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > 30 * 1000)
+ {
+ d = new ZbGwOperationUpgradeAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+
+ }
+ Actions -= action;
+ DebugPrintLog("ZbGwOperation/Upgrade_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 涓嬭浇浜戠鍥轰欢.
+ /// <summary>
+ /// 涓嬭浇浜戠缃戝叧鎴栧崗璋冨櫒鍥轰欢.
+ /// </summary>
+ /// <returns>The file async.</returns>
+ /// <param name="distributedMark">Distributed mark:鍥轰欢鍞竴鏍囪瘑</param>
+ /// <param name="imageName">Image name:鍥轰欢鐗堟湰</param>
+ public async System.Threading.Tasks.Task<DownloadFileResponAllData> DownloadFileAsync(string distributedMark, string imageName)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ DownloadFileResponAllData 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new DownloadFileResponAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ d = new DownloadFileResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "DownloadFile_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.downloadFileResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DownloadFileResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.downloadFileResponData == null)
+ {
+ d = new DownloadFileResponAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new DownloadFileResponAllData { downloadFileResponData = gatewayTemp.downloadFileResponData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("DownloadFile_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 6000 } };
+ var data = new JObject {
+ { "DistributeMark", distributedMark},
+ { "DownloadPath", "/tmp" },
+ { "FileName", imageName }
+ };
+ jObject.Add("Data", data);
+ Send(("DownloadFile"), jObject.ToString());
+ }
+ catch { }
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < 30 * 1000)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (d != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > 30 * 1000)
+ {
+ d = new DownloadFileResponAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+
+ }
+ Actions -= action;
+ DebugPrintLog("DownloadFile_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+ #endregion
+
+ #region 鏌ョ湅缃戝叧璁板綍鐨勮櫄鎷熼┍鍔�.
+ /// <summary>
+ /// 鏌ョ湅缃戝叧璁板綍鐨勮櫄鎷熼┍鍔�
+ /// </summary>
+ public async System.Threading.Tasks.Task<CheckVDDriveCodeResponseAllData> CheckVDDriveCodeAsync()
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ CheckVDDriveCodeResponseAllData 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new CheckVDDriveCodeResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ d = new CheckVDDriveCodeResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "VirtualDrive/CatDriveCode_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.vDriveDriveCodeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VDriveDriveCodeResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.vDriveDriveCodeResponData == null)
+ {
+ d = new CheckVDDriveCodeResponseAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new CheckVDDriveCodeResponseAllData { vDriveDriveCodeResponData = gatewayTemp.vDriveDriveCodeResponData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("VirtualDriveDriveCode_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 505 } };
+ Send(("VirtualDrive/CatDriveCode"), 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 CheckVDDriveCodeResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("VirtualDriveDriveCode_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+
+ #endregion
+
+ #region 鍗囩骇铏氭嫙椹卞姩璁惧.
+ /// <summary>
+ /// 鍗囩骇铏氭嫙椹卞姩璁惧
+ /// <para>oTAImageName:鍗囩骇闀滃儚鍚嶇О</para>
+ /// <para>driveCode:椹卞姩浠ｅ彿</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<VirtualDriveUpgradeResponseAllData> VirtualDriveUpgradeAsync(string imageName, int driveCode)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ VirtualDriveUpgradeResponseAllData 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ d = new VirtualDriveUpgradeResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+
+ else
+ {
+ d = new VirtualDriveUpgradeResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "VirtualDrive/Upgrade_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.virtualDriveUpgradeResponData == null)
+ {
+ d = new VirtualDriveUpgradeResponseAllData { errorMessageBase = "缃戝叧杩斿洖鐨勬暟鎹负绌�" };
+ }
+ else
+ {
+ d = new VirtualDriveUpgradeResponseAllData { virtualDriveUpgradeResponData = gatewayTemp.virtualDriveUpgradeResponData };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{topic}");
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("VirtualDrive/Upgrade_Actions 鍚姩" + "_" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 504 } };
+ var data = new JObject { { "ImageName", imageName }, { "ImagePath", "/tmp" }, { "DriveCode", driveCode } };
+ jObject.Add("Data", data);
+ Send(("VirtualDrive/Upgrade"), jObject.ToString());
+ }
+ catch { }
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < 30 * 1000)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (d != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > 30 * 1000)
+ {
+ d = new VirtualDriveUpgradeResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ }
+ Actions -= action;
+ DebugPrintLog("VirtualDrive/Upgrade_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+
+ return d;
+ });
+ }
+
+ #endregion
+
+ //#region 涓婁紶绉佹湁鏁版嵁
+ //private bool backupSuccess = false;
+ /// <summary>
+ /// 涓婁紶绉佹湁鏁版嵁
+ /// </summary>
+ /// <returns>The data to gateway.</returns>
+ /// <param name="fileName">File name.</param>
+ /// <param name="dev">Dev.</param>
+ //public async System.Threading.Tasks.Task<SendFileResponseAllData> BackupDataToGateway(string fileName, CommonDevice dev)
+ //{
+ // return await System.Threading.Tasks.Task.Run(async () =>
+ // {
+ // SendFileResponseAllData backUpStatus = null;
+ // var file = await System.Threading.Tasks.Task.Factory.StartNew(() => Newtonsoft.Json.JsonConvert.SerializeObject(dev));
+ // var data = System.Text.Encoding.UTF8.GetBytes(file);
+ // //缃戝叧涓垱寤哄瓨鍌ㄦ暟鎹殑鏂囦欢
+ // var saveFileName = await dev.Gateway.CreateFileAsync(fileName);
+ // if (saveFileName != null && saveFileName.Result == 0)
+ // {
+ // backupSuccess = false;
+ // //涓婁紶鏁版嵁鍒扮綉鍏�
+ // var saveData = await dev.Gateway.SendFileAsync(data);
+ // if (saveData != null)
+ // {
+ // backUpStatus = new SendFileResponseAllData { Result = saveData.Result };
+ // }
+ // }
+ // var dateTime = DateTime.Now;
+ // while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ // {
+ // await System.Threading.Tasks.Task.Delay(10);
+ // if (backUpStatus != null)
+ // {
+ // break;
+ // }
+ // }
+ // if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ // {
+ // backUpStatus = new SendFileResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ // };
+ // return backUpStatus;
+ // });
+ //}
+
+ /// <summary>
+ /// 涓嬭浇绉佹湁鏁版嵁
+ /// </summary>
+ /// <returns>The data from gateway.</returns>
+ /// <param name="fileName">File name.</param>
+ /// <param name="dev">Dev.</param>
+ //public async System.Threading.Tasks.Task<System.Collections.Generic.List<byte>> DownloadDataFromGateway(string fileName, CommonDevice dev)
+ //{
+ // return await System.Threading.Tasks.Task.Run(async () =>
+ // {
+ // byteSource.Clear();
+ // System.Collections.Generic.List<byte> backUpData = null;
+ // var dateTime = DateTime.Now;
+ // //鑾峰彇褰撳墠鏂囦欢鐨勫叿浣撲俊鎭�
+ // //var getFileSize = await currentKey.Gateway.GetCurrentFileInfoAsync(fileName);
+ // //涓嬭浇鏂囦欢
+ // var saveFileName = await dev.Gateway.SetDownloadFileAsync(fileName);
+ // Action<string, byte[]> action = (topic, dataContent) =>
+ // {
+ // if (topic.Split('/')[0] + "/" + topic.Split('/')[1] + "/" + topic.Split('/')[2] == topic.Split('/')[0] + "/" + "FileTransfer/DownloadFile")
+ // {
+ // dateTime = DateTime.Now;
+ // byte[] fileBytes = dataContent;
+ // if (fileBytes[5] != 1)
+ // {
+ // if (fileBytes.Length == 2056)
+ // {
+ // var tempBytes = new byte[2048];
+ // System.Array.Copy(fileBytes, 8, tempBytes, 0, 2048);
+ // byteSource.AddRange(tempBytes);
+ // }
+ // else
+ // {
+ // var tempBytes = new byte[fileBytes.Length - 8];
+ // System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
+ // byteSource.AddRange(tempBytes);
+ // }
+ // }
+ // else
+ // {
+ // var tempBytes = new byte[fileBytes.Length - 8];
+ // System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
+ // byteSource.AddRange(tempBytes);
+
+ // if (byteSource != null )
+ // {
+ // backUpData = byteSource;
+ // }
+ // }
+
+ // }
+ // };
+ // dev.Gateway.FileContentAction += action;
+
+ // while ((DateTime.Now - dateTime).TotalMilliseconds < 2000)
+ // {
+ // await System.Threading.Tasks.Task.Delay(10);
+ // }
+ // dev.Gateway.FileContentAction -= action;
+ // return byteSource;
+ // });
+ //}
+
+ //#endregion
+
+ #region 瀹㈡埛绔笂浼犳枃浠跺埌缃戝叧.
+ /// <summary>
+ /// 瀹㈡埛绔笂浼犳枃浠跺埌缃戝叧
+ /// </summary>
+ /// <returns>The admin password async.</returns>
+ /// <param name="fileName">涓婁紶鏂囦欢鍚庯紝淇濆瓨鐨勬枃浠跺悕绉�</param>
+ /// <param name="filePath">鏂囦欢淇濆瓨鍦ㄧ郴缁熺殑鐩綍璺緞锛屽鏋滅洰褰曚笉瀛樺湪绯荤粺灏嗚嚜鍔ㄥ垱寤鸿鐩綍銆傚锛�/tmp/. </param>
+ public async System.Threading.Tasks.Task<CreateFileResponseAllData> CreateFileAsync(string fileName, string filePath = "/etc/hdlDat")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ CreateFileResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new CreateFileResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new CreateFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/CreateFile_Respon")
+ {
+ var security = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
+ dataRes = new CreateFileResponseAllData { Result = result };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/CreateFile_Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3000 } };
+ var data = new JObject { { "FileName", fileName }, { "FilePath", filePath } };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/CreateFile"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new CreateFileResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+
+ Actions -= action;
+ DebugPrintLog("FileTransfer/CreateFile_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 瀹㈡埛绔彂閫佹枃浠舵祦鍒扮綉鍏�
+ ///<summary >
+ /// 瀹㈡埛绔彂閫佹枃浠舵祦鍒扮綉鍏�
+ ///<para>Result 0: 鏁版嵁鍐欏叆鎴愬姛,璇锋眰鍙戦�佷笅涓�涓暟鎹寘</para>
+ ///<para>Result1锛氭暟鎹啓鍏ュけ璐�</para>
+ ///<para>Result2锛氭暟鎹В鏋愰敊璇�</para>
+ ///<para>Result3锛氬彂閫佹暟鎹ぇ灏忚秴鍑洪檺鍒�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<SendFileResponseAllData> SendFileAsync(byte[] data)
+ {
+ if (data == null)
+ {
+ return new SendFileResponseAllData { errorMessageBase = "鏁版嵁鍐呭鏄┖" };
+ }
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ var isRespond = true;
+ SendFileResponseAllData dataRes = null;
+ Action<string, string> action = (topic, message) =>
+ {
+ var gatewayID = topic.Split('/')[0];
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
+
+ if (topic == gatewayID + "/FileTransfer/SendFile_Respon")
+ {
+ var gateway = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
+ dataRes = new SendFileResponseAllData { Result = result };
+ if (result == 0)
+ {
+ isRespond = true;
+ }
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/SendFile_Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var fileBytes = data;
+ var size = 2048;
+ var dateTime = DateTime.Now;
+ for (int i = 0, tempSize = 0; i < fileBytes.Length; i += tempSize)
+ {
+ while (!isRespond)
+ {
+ if (WaitReceiveDataTime < (DateTime.Now - dateTime).TotalMilliseconds)
+ {
+ return new SendFileResponseAllData { errorMessageBase = "鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" }; ;
+ }
+ await System.Threading.Tasks.Task.Delay(10);
+ }
+ isRespond = false;
+
+ byte finish = 0;
+ if (i + size < fileBytes.Length)
+ {
+ tempSize = size;
+ }
+ else if (i + size == fileBytes.Length)
+ {
+ tempSize = size;
+ finish = 1;
+ }
+ else
+ {
+ tempSize = fileBytes.Length % size;
+ finish = 1;
+ }
+ var bytes = new byte[8 + tempSize];
+ bytes[0] = 0xfe;
+ bytes[1] = 0;
+ bytes[2] = 0;
+ bytes[3] = 0;
+ bytes[4] = 0;
+ bytes[5] = finish;//0x00 鎴� 0x01
+ bytes[6] = Convert.ToByte(tempSize % 256); // DataLen 0x01 鍒� 0x800 锛堝嵆姣忔鏈�澶у彂閫�2048瀛楄妭锛�2
+ bytes[7] = Convert.ToByte(tempSize / 256);
+ System.Array.Copy(fileBytes, i, bytes, 8, tempSize);
+ dateTime = DateTime.Now;
+ await Send("FileTransfer/SendFile", bytes);
+ DebugPrintLog($"涓婁紶鍒扮綉鍏冲綋鍓嶆暟鎹暟閲廮{i}_鏄笉鏄渶鍚庝竴涓猒{finish}_{System.DateTime.Now.ToString()}");
+ }
+ }
+ catch { }
+ finally
+ {
+ Actions -= action;
+ }
+ DebugPrintLog("Security/ChangeAdminPassword_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 鏌ョ湅缃戝叧鐩綍鏂囦欢淇℃伅.
+ /// <summary>
+ /// 鏌ョ湅缃戝叧鐩綍鏂囦欢淇℃伅
+ /// </summary>
+ /// <returns>The admin password async.</returns>
+ /// <param name="filePath">鏂囦欢淇濆瓨鍦ㄧ郴缁熺殑鐩綍璺緞锛屽鏋滅洰褰曚笉瀛樺湪绯荤粺灏嗚嚜鍔ㄥ垱寤鸿鐩綍銆傚锛�/tmp/. </param>
+ public async System.Threading.Tasks.Task<FileTransferLsDiResponseAllData> FileTransferLsDirAsync(string filePath = "/etc/hdlDat")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ FileTransferLsDiResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new FileTransferLsDiResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new FileTransferLsDiResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/lsDir_Respon")
+ {
+ var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
+ var resultlsDir = Newtonsoft.Json.JsonConvert.DeserializeObject<FileTransferLsDiResponseData>(jobject["Data"].ToString());
+ if (resultlsDir != null)
+ {
+ dataRes = new FileTransferLsDiResponseAllData { fileTransferLsDiResponseData = resultlsDir };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ else
+ {
+ dataRes = new FileTransferLsDiResponseAllData { errorMessageBase = "鏀跺埌鐨勭綉鍏宠繑鍥炴暟鎹槸绌�" };
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/lsDir_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3002 } };
+ var data = new JObject { { "FilePath", filePath } };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/lsDir"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new FileTransferLsDiResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+ Actions -= action;
+ DebugPrintLog("FileTransfer/lsDir_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 鏌ョ湅鍗曚釜鏂囦欢淇℃伅.
+ /// <summary>
+ /// 鏌ョ湅鍗曚釜鏂囦欢淇℃伅
+ /// </summary>
+ /// <returns>The admin password async.</returns>
+ /// <param name="filePath">鏂囦欢淇濆瓨鍦ㄧ郴缁熺殑鐩綍璺緞锛屽鏋滅洰褰曚笉瀛樺湪绯荤粺灏嗚嚜鍔ㄥ垱寤鸿鐩綍銆傚锛�/tmp/. </param>
+ public async System.Threading.Tasks.Task<FileTransferGetFileInfoResponseAllData> GetCurrentFileInfoAsync(string fileName, string filePath = "/etc/hdlDat/")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ FileTransferGetFileInfoResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new FileTransferGetFileInfoResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new FileTransferGetFileInfoResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/GetFileInfo_Respon")
+ {
+ var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
+ var resultlsDir = Newtonsoft.Json.JsonConvert.DeserializeObject<FileTransferGetFileInfoResponseData>(jobject["Data"].ToString());
+ if (resultlsDir != null)
+ {
+ dataRes = new FileTransferGetFileInfoResponseAllData { fileTransferGetFileInfoResponseData = resultlsDir };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ else
+ {
+ dataRes = new FileTransferGetFileInfoResponseAllData { errorMessageBase = "鏀跺埌鐨勭綉鍏宠繑鍥炴暟鎹槸绌�" };
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/GetFileInfo_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var tempFilePath = filePath + fileName;
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3007 } };
+ var data = new JObject { { "File", tempFilePath } };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/GetFileInfo"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new FileTransferGetFileInfoResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+ Actions -= action;
+ DebugPrintLog("FileTransfer/GetFileInfo_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 瀹㈡埛绔瀹氳涓嬭浇鐨勬枃浠跺悕绉板拰璺緞
+ /// <summary>
+ /// 瀹㈡埛绔瀹氳涓嬭浇鐨勬枃浠跺悕绉板拰璺緞
+ /// <para>fileName:涓嬭浇鐨勬枃浠跺悕绉�.</para>
+ /// <para>blockStartAddress:鍙拷鐣ワ紝榛樿涓�0銆備笅杞藉紑濮嬪湴鍧�锛岀敤浜庢柇鐐圭画浼犮�傚锛氭枃浠舵�诲ぇ灏忎负1000Byte锛屽鎴风涓嬭浇浜�200Byte鍚庤繛鎺ユ剰澶栨柇寮�銆傚綋瀹㈡埛绔噸鏂拌繛鎺ュ悗鎯崇户缁笅杞藉悗缁枃浠舵祦鑰屼笉鎯充粠鏂囦欢澶撮噸鏂板紑濮嬩笅杞斤紝鍙皢璇ュ弬鏁拌缃负200锛岀綉鍏冲皢浠庣2001Byte寮�濮嬪彂閫佹枃浠舵祦銆�</para>
+ /// <para>filePath">鏂囦欢鎵�鍦ㄧ郴缁熺殑鐩綍璺緞銆傚锛�/tmp.</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<SetDownloadFileResponseAllData> SetDownloadFileAsync(string fileName, int blockStartAddress = 0, string filePath = "/etc/hdlDat")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ SetDownloadFileResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new SetDownloadFileResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new SetDownloadFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/SetDownloadFile_Respon")
+ {
+ var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
+ var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetDownloadFileResponseData>(jobject["Data"].ToString());
+ if (tempData != null)
+ {
+ dataRes = new SetDownloadFileResponseAllData { };
+ var tempDa = new SetDownloadFileResponseData();
+ if (tempData.Result == 0)
+ {
+ ZbGateway.byteSource.Clear();
+ }
+ tempDa.Result = tempData.Result;
+ dataRes.setDownloadFileResponseData = tempDa;
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ else
+ {
+ dataRes = new SetDownloadFileResponseAllData { errorMessageBase = "鏀跺埌鐨勭綉鍏宠繑鍥炴暟鎹槸绌�" };
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/SetDownloadFile_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3003 } };
+ var data = new JObject {
+ { "FileName", fileName },
+ { "FilePath", filePath },
+ { "BlockStartAddress", blockStartAddress }
+ };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/SetDownloadFile"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new SetDownloadFileResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+ Actions -= action;
+ DebugPrintLog("FileTransfer/SetDownloadFile_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 缃戝叧鍙戦�佹枃浠舵祦鍒板鎴风
+ static System.Collections.Generic.List<byte> byteSource = new System.Collections.Generic.List<byte>();
+ ///<summary >
+ /// 涓嬭浇鏂囦欢涓殑鏁版嵁
+ /// </summary>
+ public void DownloadFileConfirmAsync(byte[] fileBytes)
+ {
+ int result = 0;
+
+ if (fileBytes[5] != 1)
+ {
+ if (fileBytes.Length == 2056)
+ {
+ result = 0;
+ var tempBytes = new byte[2048];
+ System.Array.Copy(fileBytes, 8, tempBytes, 0, 2048);
+ byteSource.AddRange(tempBytes);
+ }
+ else
+ {
+ var tempBytes = new byte[fileBytes.Length - 8];
+ System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
+ byteSource.AddRange(tempBytes);
+ return;
+ }
+ }
+ else
+ {
+ var tempBytes = new byte[fileBytes.Length - 8];
+ System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
+ byteSource.AddRange(tempBytes);
+ return;
+ }
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3004 } };
+ var data = new JObject { { "Result", result } };
+ jObject.Add("Data", data);
+ Send("FileTransfer/DownloadFile_Respon", jObject.ToString());
+ }
+ catch { }
+ }
+ #endregion
+
+ #region 鍒犻櫎鏂囦欢鎴栫洰褰�
+ /// <summary>
+ /// 鍒犻櫎鏂囦欢鎴栫洰褰�
+ /// </summary>
+ /// <returns>The admin password async.</returns>
+ /// <param name="path">鍒犻櫎鐩綍鎴栨枃浠剁殑璺緞銆傚锛�/tmp/锛屽垯鍒犻櫎tmp鐩綍銆�/tmp/aa.txt锛屽垯鍒犻櫎tmp鐩綍涓嬬殑aa.txt鏂囦欢銆� </param>
+ public async System.Threading.Tasks.Task<DelFileOrDirResponseAllData> DelFileOrDirAsync(string path = "/etc/hdlDat")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ DelFileOrDirResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new DelFileOrDirResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new DelFileOrDirResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/DelFileOrDir_Respon")
+ {
+ var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
+ var resultDelFileOrDir = Newtonsoft.Json.JsonConvert.DeserializeObject<DelFileOrDirResponseData>(jobject["Data"].ToString());
+ if (resultDelFileOrDir != null)
+ {
+ dataRes = new DelFileOrDirResponseAllData { delFileOrDirResponseData = resultDelFileOrDir };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ else
+ {
+ dataRes = new DelFileOrDirResponseAllData { errorMessageBase = "鏀跺埌鐨勭綉鍏宠繑鍥炴暟鎹槸绌�" };
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/DelFileOrDir_Actions 鍚姩" + System.DateTime.Now.ToString());
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3005 } };
+ var data = new JObject { { "Path", path } };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/DelFileOrDir"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new DelFileOrDirResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+ Actions -= action;
+ DebugPrintLog("FileTransfer/DelFileOrDir_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 鍒涘缓涓�涓洰褰�.
+ /// <summary>
+ /// 鍒涘缓涓�涓洰褰�
+ /// </summary>
+ /// <returns>The admin password async.</returns>
+ /// <param name="path">鍒犻櫎鐩綍鎴栨枃浠剁殑璺緞銆傚锛�/tmp/锛屽垯鍒犻櫎tmp鐩綍銆�/tmp/aa.txt锛屽垯鍒犻櫎tmp鐩綍涓嬬殑aa.txt鏂囦欢銆� </param>
+ public async System.Threading.Tasks.Task<CreateDirResponseAllData> CreateDirAsync(string path = "/etc/hdlDat")
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ CreateDirResponseAllData dataRes = 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 = getGatewayBaseInfo.gwID };
+ var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
+
+ if (temp == null)
+ {
+ dataRes = new CreateDirResponseAllData { errorMessageBase = "缃戝叧閿欒鍥炲锛屼笖鏁版嵁鏄┖" };
+ }
+ else
+ {
+ dataRes = new CreateDirResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
+ }
+ }
+
+ if (topic == gatewayID + "/" + "FileTransfer/CreateDir_Respon")
+ {
+ var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
+ var resultCreateDir = Newtonsoft.Json.JsonConvert.DeserializeObject<CreateDirResponseData>(jobject["Data"].ToString());
+ if (resultCreateDir != null)
+ {
+ dataRes = new CreateDirResponseAllData { createDirResponseData = resultCreateDir };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ else
+ {
+ dataRes = new CreateDirResponseAllData { errorMessageBase = "鏀跺埌鐨勭綉鍏宠繑鍥炴暟鎹槸绌�" };
+ }
+ }
+ };
+ Actions += action;
+ DebugPrintLog("FileTransfer/CreateDir_Actions 鍚姩" + System.DateTime.Now.ToString());
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 3006 } };
+ var data = new JObject { { "Path", path } };
+ jObject.Add("Data", data);
+ Send(("FileTransfer/CreateDir"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (dataRes != null)
+ {
+ break;
+ }
+ }
+ if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
+ {
+ dataRes = new CreateDirResponseAllData { errorMessageBase = " 鍥炲瓒呮椂锛岃閲嶆柊鎿嶄綔" };
+ };
+ Actions -= action;
+ DebugPrintLog("FileTransfer/CreateDir_Actions 閫�鍑�" + System.DateTime.Now.ToString());
+ return dataRes;
+ });
+ }
+ #endregion
+
+ #region 瀹㈡埛绔彂閫佸瘑閽ュ埌缃戝叧
+ ///<summary >
+ /// 瀹㈡埛绔彂閫丏ES瀵嗛挜鍒扮綉鍏�
+ /// <para>DES瀵嗛挜缁廟SA鍏挜鍔犲瘑杞垚base64鍚庢墍寰楃殑瀛楃涓蹭俊鎭�</para>
+ /// </summary>
+ public async System.Threading.Tasks.Task<SendKeyResponData> SendAesKeyAsync(string aesKey)
+ {
+ return await System.Threading.Tasks.Task.Run(async () =>
+ {
+ SendKeyResponData sendKeyResponData = null;
+ Action<string, string> action = (topic, message) =>
+ {
+ var gatewayID = topic.Split('/')[0];
+
+ if (topic == gatewayID + "/" + "SendAESKey_Respon")
+ {
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
+ sendKeyResponData = new SendKeyResponData { Result = result };
+ DebugPrintLog($"UI鏀跺埌閫氱煡鍚庣殑涓婚_{ topic}");
+ }
+ };
+
+ Actions += action;
+ DebugPrintLog($"SendAESKey_Actions 鍚姩_{System.DateTime.Now.ToString()}");
+
+ try
+ {
+ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 100 } };
+ var data = new JObject { { "AesKey", aesKey } };
+ jObject.Add("Data", data);
+ Send(("SendAESKey"), jObject.ToString());
+ }
+ catch { }
+
+ var dateTime = DateTime.Now;
+ while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
+ {
+ await System.Threading.Tasks.Task.Delay(10);
+ if (sendKeyResponData != null)
+ {
+ break;
+ }
+ }
+
+ Actions -= action;
+ DebugPrintLog($"SendAESKey_Actions 閫�鍑篲{System.DateTime.Now.ToString()}");
+ return sendKeyResponData;
+ });
+ }
+
+
+ #endregion
+ #endregion
+
+ #region 璁惧鐘舵�佹洿鏂�
+ /// <summary>
+ /// 璁惧鐘舵�佺洃鍚垪琛�
+ /// <para>杩涘叆褰撳墠鐣岄潰鏃惰娣诲姞</para>
+ /// <para>閫�鍑哄綋鍓嶇晫闈㈡椂瑕佸叧闂�</para>
+ /// </summary>
+ public static readonly System.Collections.Generic.List<IStatus> StatusList = new System.Collections.Generic.List<IStatus>();
+
+ /// <summary>
+ /// 璁惧淇℃伅鍙樺寲
+ /// <para>type锛氬鏋滀负 DeviceInComingRespon:璁惧鏂颁笂鎶�</para>
+ /// <para>type锛氬鏋滀负 IASInfoReport:RemoveDeviceRespon</para>
+ /// <para>type锛氬鏋滀负 DeviceStatusReport:璁惧涓婃姤</para>
+ /// <para>type锛氬鏋滀负 IASInfoReport:IAS瀹夐槻淇℃伅涓婃姤</para>
+ /// <para>type锛氬鏋滀负 OnlineStatusChange: 璁惧鍦ㄧ嚎鐘舵�佹洿鏂�</para>
+ /// </summary>
+ /// <param name="commonDevice">Common device.</param>
+ public static void UpdateDeviceInfo(CommonDevice commonDevice, string type)
+ {
+ if (commonDevice == null)
+ {
+ return;
+ }
+ for (int i = 0; i < StatusList.Count; i++)
+ {
+ StatusList[i].DeviceInfoChange(commonDevice, type);
+ }
+ }
+ #endregion
+
+ #region 閫氳杩炴帴
+ /// <summary>
+ /// 灞�鍩熺綉鐨凪QTT
+ /// </summary>
+ IMqttClient localMqttClient = new MqttFactory().CreateMqttClient();
+ bool localMqttIsConnecting;
+ public bool localIsConnected;
+ /// <summary>
+ /// 鎵嬫満鏍囪瘑
+ /// </summary>
+ static Guid currentGuid = Guid.NewGuid();
+
+ public async System.Threading.Tasks.Task SendAesKey()
+ {
+ if (PubKey != null)
+ {
+ IsEncry = false;
+ var rsaString = ZigBee.Common.SecuritySet.RSAEncrypt(PubKey, Password);
+ var resultVerityfy = await SendAesKeyAsync(rsaString);
+ if (resultVerityfy == null)
+ {
+ resultVerityfy = await SendAesKeyAsync(rsaString);
+ }
+
+ if (resultVerityfy != null && resultVerityfy.Result == 0)
+ {
+ IsEncry = true;
+ }
+ }
+ }
+
+ public async System.Threading.Tasks.Task StartLocalMqtt(string brokerName)
+ {
+ if (localMqttIsConnecting
+ || !Shared.Common.Config.Instance.IsLogin
+ || Shared.Common.Config.Instance.HomeId == ""
+ || localIsConnected)
+ {
+ return;
+ }
+ await System.Threading.Tasks.Task.Factory.StartNew(async () =>
+ {
+ try
+ {
+ lock (localMqttClient)
+ {
+ //琛ㄧず鍚庨潰灏嗚繘琛岃繛鎺�
+ localMqttIsConnecting = true;
+
+ //(3)褰揫杩炴帴Mqtt鎴愬姛鍚嶿鎴栬�匸Mqtt杞彂鏁版嵁缁欑綉鍏虫垚鍔熷悗],澶勭悊鎺ユ敹鍒版暟鎹寘鍝嶅簲鏃跺湪mqttClient_ApplicationMessageReceived杩欎釜鏂规硶澶勭悊
+ if (localMqttClient.ApplicationMessageReceivedHandler == null)
+ {
+ localMqttClient.UseApplicationMessageReceivedHandler((e) =>
+ {
+ if (!localMqttClient.IsConnected)
+ {
+ return;
+ }
+ mqttClient_MqttMsgPublishReceived(e);
+ });
+ }
+
+ if (localMqttClient.DisconnectedHandler == null)
+ {
+ localMqttClient.UseDisconnectedHandler(async (e) =>
+ {
+ DebugPrintLog($" 鏈湴杩炴帴鏂紑_缃戝叧IP:{brokerName}_缃戝叧鏄惁鍔�:{IsEncry}");
+ await DisConnectLocalMqttClient("StartLocalMqtt.DisconnectedHandler");
+ //await StartLocalMqtt("ReConnect");
+ });
+ }
+ if (localMqttClient.ConnectedHandler == null)
+ {
+ localMqttClient.UseConnectedHandler(async (e) =>
+ {
+ DebugPrintLog($" 鏈湴杩炴帴鎴愬姛_缃戝叧IP:{brokerName}_缃戝叧鏄惁鍔�:{IsEncry}_褰撳墠瀵嗙爜:{Password}");
+ IsRemote = false;
+ Shared.Phone.UserCenter.HdlGatewayLogic.Current.CheckGatewayByConnectChanged(Shared.Phone.UserCenter.GatewayConnectMode.WIFI);
+ });
+ }
+
+ var dateTime = DateTime.Now;
+
+ new System.Threading.Thread(async () =>
+ {
+ try
+ {
+ if (localMqttClient.Options == null)
+ {
+ var options = new MQTTnet.Client.Options.MqttClientOptionsBuilder()//MQTT杩炴帴鍙傛暟濉厖
+ .WithClientId(currentGuid.ToString())//瀹㈡埛绔疘D
+ .WithTcpServer(brokerName, 1883)//TCP鏈嶅姟绔� 1883 锛屽嵆MQTT鏈嶅姟绔�
+ .WithCredentials("", "")//"", "")//鍑瘉 甯愬彿 瀵嗙爜
+ .WithCommunicationTimeout(new TimeSpan(0, 0, 60)) //閲嶈繛瓒呮椂鏃堕棿锛岄粯璁�5s
+ .WithKeepAlivePeriod(new TimeSpan(0, 0, 15)) //淇濇寔杩炴帴鏃堕棿锛岄粯璁�5s锛屽績璺冲寘
+ .Build();//
+ await localMqttClient.ConnectAsync(options);
+ }
+ else
+ {
+ await DisConnectLocalMqttClient("StartLocalMqtt");
+ await localMqttClient.ReconnectAsync();
+ }
+ localIsConnected = true;
+ await SendAesKey();
+ }
+ catch { }
+ dateTime = DateTime.MinValue;
+ })
+ { IsBackground = true }.Start();
+ while (dateTime != DateTime.MinValue)
+ {
+ System.Threading.Thread.Sleep(100);
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"灞�鍩熺綉閫氳杩炴帴鍑哄紓甯�:{ex.Message}");
+ }
+ finally
+ {
+ localMqttIsConnecting = false;
+ }
+ });
+ }
+
+ class GateWayBaseInfomation
+ {
+ //public string GatewayUniqueId;//"Emq缃戝叧1", <!-- 缃戝叧Mac -->
+ public bool MqttOnlineStatus;//: true, <!-- 缃戝叧鍦ㄤ簯绔疎mq鏄惁鍦ㄧ嚎 -->
+ public string AesKey;// : "a5d8da8a-ddea-48", <!-- 涓庢缃戝叧鍦ㄤ簯绔疎mq閫氫俊鏃讹紝璐熻浇鍔犺В鐨�16浣岮es瀵嗛挜 -->
+ public string MacMark;//: "61eaa0ea-4812-4a7a-86d6-3098c61e64ed" <!-- 缃戝叧瀵瑰簲鐨勫敮涓�鐮� -->
+ }
+ /// <summary>
+ /// 褰撳墠鏈夊笎鍙蜂笅鎵�鏈夌殑缃戝叧鍒楄〃鍙婁俊鎭�
+ /// </summary>
+ static Dictionary<string, GateWayBaseInfomation> GateWayBaseInfomations = new Dictionary<string, GateWayBaseInfomation> { };
+ /// <summary>
+ /// 鑾峰彇褰撳墠甯愬彿鎵�鏈夌殑缃戝叧淇℃伅
+ /// </summary>
+ /// <returns></returns>
+ static async System.Threading.Tasks.Task initGateWayBaseInfomation()
+ {
+ if (AllowRemoteCtrl == false)
+ {
+ //娌℃湁杩滅▼杩炴帴鐨勬潈闄�
+ return;
+ }
+ string loginToken = Config.Instance.Token;
+ if (Config.Instance.Home.IsOthreShare == true)
+ {
+ //鑾峰彇鎴愬憳鐨勭壒娈奣oken
+ var pra = new
+ {
+ CommonPage.RequestVersion,
+ LoginAccessToken = Config.Instance.Token,
+ MainAccountId = Config.Instance.Home.MainUserDistributedMark,
+ SharedHid = Config.Instance.Home.Id
+ };
+
+ var listNotShow = new List<string>() { "NotSetAgain" };
+ var resultData = await Shared.Phone.UserCenter.UserCenterLogic.GetByteResponseDataByRequestHttps("App/GetSharedHomeApiControl", false, pra, listNotShow);
+ if (resultData == null)
+ {
+ return;
+ }
+ var revertObj = Newtonsoft.Json.JsonConvert.DeserializeObject<Shared.Common.ResponseEntity.ResponsePack>(Encoding.UTF8.GetString(resultData));
+ //鍒嗕韩閾炬帴
+ var info = Newtonsoft.Json.JsonConvert.DeserializeObject<Shared.Phone.UserCenter.MemberAdministratorResult>(revertObj.ResponseData.ToString());
+ loginToken = info.RequestToken;
+ }
+
+ try
+ {
+ //璁剧疆璁块棶鎺ュ彛鐨勫弬鏁�
+ var pra2 = new Shared.Phone.UserCenter.GetGatewayPra();
+ pra2.IsOtherAccountCtrl = Config.Instance.Home.IsOthreShare;
+ pra2.ReqDto.PageSetting.Page = 1;
+ pra2.ReqDto.PageSetting.PageSize = 20;
+ pra2.ReqDto.LoginAccessToken = loginToken;
+ var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(pra2));
+
+ var result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/App/GetSingleHomeGatewayPagger", bytes, loginToken);
+ if (result != null)
+ {
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(Encoding.UTF8.GetString(result));
+
+ var statuCode = jobject["StateCode"].ToString();
+ if (statuCode != "Success")
+ {
+ //搴忓垪鍖栧璞�
+ var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject(pra2);
+ //Log鍑哄姏
+ string errorMsg = "鎺ュ彛璁块棶澶辫触鈽咃細App/GetSingleHomeGatewayPagger " + statuCode + "\r\n";
+ errorMsg += "鍙傛暟锛歕r\n" + requestJson;
+ Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(-1, errorMsg);
+ return;
+ }
+
+ var responseData = jobject["ResponseData"];
+ if (responseData != null)
+ {
+ if (responseData["PageData"] != null)
+ {
+ var list = JArray.Parse(responseData["PageData"].ToString());
+ foreach (var v in list)
+ {
+ GateWayBaseInfomations[v["GatewayUniqueId"].ToString()] = new GateWayBaseInfomation { AesKey = v["AesKey"].ToString(), MacMark = v["MacMark"].ToString(), MqttOnlineStatus = bool.Parse(v["MqttOnlineStatus"].ToString()) };
+ //if (RemoteMqttClient.IsConnected)
+ {
+ await RemoteMqttClient.SubscribeAsync($"/ZigbeeGateWayToClient/{v["MacMark"].ToString()}/#", MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce);
+ }
+ }
+ }
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(ex);
+ }
+ }
+
+ /// <summary>
+ /// 澶栫綉鐨凪QTT鏄惁姝ｅ湪杩炴帴
+ /// </summary>
+ static bool remoteMqttIsConnecting;
+ static bool IsLoginAgain;
+ /// <summary>
+ /// 杩滅▼MqttClient
+ /// </summary>
+ public static IMqttClient RemoteMqttClient= new MqttFactory().CreateMqttClient();
+ static bool remoteIsConnected;
+ private int IsLogin = 0;
+ [Newtonsoft.Json.JsonIgnore]
+ static Action actionTemp;
+
+ /// <summary>
+ /// 鍚姩杩滅▼Mqtt
+ /// </summary>
+ /// <returns>The start.</returns>
+ /// <param name="brokerName">Broker name.</param>
+ public static async System.Threading.Tasks.Task StartRemoteMqtt()
+ {
+ //杩藉姞锛氭病鏈夎繙绋嬭繛鎺ョ殑鏉冮檺
+ if (AllowRemoteCtrl == false
+ || remoteMqttIsConnecting
+ || !Shared.Common.Config.Instance.IsLogin
+ || Shared.Common.Config.Instance.HomeId == ""
+ || remoteIsConnected)
+ {
+ return;
+ }
+ await System.Threading.Tasks.Task.Factory.StartNew(async () =>
+ {
+ try
+ {
+ lock (RemoteMqttClient)
+ {
+ //琛ㄧず鍚庨潰灏嗚繘琛岃繛鎺�
+ remoteMqttIsConnecting = true;
+
+ #region 鍒濆鍖栬繙绋婱qtt
+ //(3)褰揫杩炴帴浜戠鐨凪qtt鎴愬姛鍚嶿鎴栬�匸浠ュ強鍚庨潰App閫氳繃浜戠Mqtt杞彂鏁版嵁缁欑綉鍏虫垚鍔熷悗],澶勭悊鎺ユ敹鍒颁簯绔暟鎹寘鍝嶅簲鏃跺湪mqttServerClient_ApplicationMessageReceived杩欎釜鏂规硶澶勭悊
+ if (RemoteMqttClient.ApplicationMessageReceivedHandler == null)
+ {
+ RemoteMqttClient.UseApplicationMessageReceivedHandler((e) =>
+ {
+ //杩欓噷鏄壒娈婄殑涓婚
+ if (e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.ConnEmqClientId + "/Push/NotifySqueeze"//韪汉涓嬬嚎
+ || e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/Deleted"//鍒嗕韩鍒犻櫎
+ || e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/DeletedShareData"//鍒嗕韩鍒犻櫎
+ || e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/Update"//鎴愬憳鏉冮檺鍙樻洿
+ || e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Home.Id + "_" + Config.Instance.Guid + "/PrimaryUserDelYou")//瀛愯处鍙疯鍒犻櫎
+ {
+ mqttRemoteClient_MqttMsgPublishReceived(e);
+ return;
+ }
+ if (!RemoteMqttClient.IsConnected || !IsRemote)
+ {
+ return;
+ }
+ mqttRemoteClient_MqttMsgPublishReceived(e);
+ });
+ }
+
+ if (RemoteMqttClient.DisconnectedHandler == null)
+ {
+ RemoteMqttClient.UseDisconnectedHandler(async (e) =>
+ {
+ DebugPrintLog($"杩滅▼杩炴帴鏂紑");
+ await DisConnectRemoteMqttClient("StartRemoteMqtt.DisconnectedHandler");
+ //await StartRemoteMqtt();
+ });
+ }
+ if (RemoteMqttClient.ConnectedHandler == null)
+ {
+ RemoteMqttClient.UseConnectedHandler(async (e) =>
+ {
+ DebugPrintLog($"杩滅▼杩炴帴鎴愬姛");
+
+ if (Config.Instance.Home.IsOthreShare == true)
+ {
+ //璁㈤槄涓�涓垚鍛樿鍒犻櫎鐨勪富棰�
+ string myGuid = Config.Instance.Guid;
+ await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/Deleted");
+ //璁㈤槄涓�涓垎浜暟鎹凡缁忓彉鏇寸殑涓婚
+ await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/DeletedShareData");
+ //璁㈤槄涓�涓瓙璐﹀彿琚垹闄ょ殑涓婚
+ await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + Config.Instance.Home.Id + "_" + myGuid + "/PrimaryUserDelYou");
+ //璁㈤槄涓�涓垚鍛樻潈闄愬凡缁忓彉鏇寸殑涓婚
+ await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/Update");
+ }
+ //璁㈤槄涓�涓尋涓嬬嚎鐨勪富棰�
+ await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + Config.Instance.ConnEmqClientId + "/Push/NotifySqueeze");
+
+ await initGateWayBaseInfomation();
+ Shared.Phone.UserCenter.HdlGatewayLogic.Current.CheckGatewayByConnectChanged(Shared.Phone.UserCenter.GatewayConnectMode.Remote);
+ //娌℃湁涓荤綉鍏虫椂涓诲姩璇诲彇锛岃幏鍙栦富缃戝叧淇℃伅
+ var gateWayList = GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);
+ if (gateWayList.Find(obj => obj.getGatewayBaseInfo.IsMainGateWay == true) == null)
+ {
+ if (gateWayList.Count == 1)
+ {
+ gateWayList[0].getGatewayBaseInfo.IsMainGateWay = true;
+ }
+ else
+ {
+ for (int i = 0; i < gateWayList.Count; i++)
+ {
+ var gateWay = gateWayList[i];
+ var info = await gateWay.GetZbGwInfoAsync();
+ if (info == null || info.getGwData == null)
+ {
+ continue;
+ }
+ if (info.getGwData.IsDominant == 1)
+ {
+ for (int j = 0; j < gateWayList.Count; j++)
+ {
+ if (gateWayList[i].getGatewayBaseInfo.gwID == info.getGwData.GwId)
+ {
+ gateWayList[i].getGatewayBaseInfo.IsMainGateWay = true;
+ }
+ else
+ {
+ gateWayList[i].getGatewayBaseInfo.IsMainGateWay = false;
+ }
+ }
+ break;
+ }
+ }
+ }
+ }
+ });
+ }
+ #endregion
+ }
+
+ try
+ {
+ byte[] result = null;
+ if (Config.Instance.Home.IsOthreShare == false)
+ {
+ //涓讳汉
+ var jsonData = new Dictionary<string, object>
+ {
+ ["RequestVersion"] = CommonPage.RequestVersion,
+ ["RequestSource"] = 0,
+ ["LoginAccessToken"] = Config.Instance.Token,
+ ["RequestProtocolType"] = 0,
+ ["PlatformStr"] = "h",//杩欎袱涓�煎鏋滀笉璁剧疆,鍒欎簯绔笉鍙戝竷涓婚
+ ["PublishPayloadJsonStr"] = "1"
+ };
+ var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(jsonData));
+ result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/EmqMqtt/GetConnMqttInfo", bytes, Config.Instance.Token);
+ }
+ else
+ {
+ //鍒嗕韩鐨�
+ var jsonData = new Dictionary<string, object>
+ {
+ ["RequestVersion"] = CommonPage.RequestVersion,
+ ["RequestSource"] = 0,
+ ["LoginAccessToken"] = Config.Instance.Token,
+ ["RequestProtocolType"] = 0,
+ ["MainUserDistributedMark"] = Config.Instance.Home.MainUserDistributedMark,
+ ["HomeId"] = Config.Instance.Home.Id,
+ ["PlatformStr"] = "h",//杩欎袱涓�煎鏋滀笉璁剧疆,鍒欎簯绔笉鍙戝竷涓婚
+ ["PublishPayloadJsonStr"] = "1"
+ };
+ var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(jsonData));
+ result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/EmqMqtt/ShareMemberConnMqttInfo", bytes, Config.Instance.Token);
+ }
+ if (result != null)
+ {
+ var jobject = Newtonsoft.Json.Linq.JObject.Parse(Encoding.UTF8.GetString(result));
+ if (jobject["StateCode"].ToString() == "NotAllowRemoteCtrl")
+ {
+ //娌℃湁杩滅▼杩炴帴鐨勬潈闄�
+ AllowRemoteCtrl = false;
+ return;
+ }
+ //铏界劧涓嶇煡閬撳鎸や笅绾块偅涓�鍧楁湁娌℃湁鐢�,涓嶈繃鍏堣繖涔堝紕
+ await System.Threading.Tasks.Task.Delay(1500);
+
+ var responseData = jobject["ResponseData"];
+ if (responseData != null)
+ {
+ var connEmqDomainPort = responseData["ConnEmqDomainPort"]?.ToString();
+ var connEmqClientId = responseData["ConnEmqClientId"]?.ToString();
+ var connEmqUserName = responseData["ConnEmqUserName"]?.ToString();
+ var connEmqPwd = responseData["ConnEmqPwd"]?.ToString();
+ //璁板綍璧峰綋鍓嶇殑瀹㈡埛绔疘D
+ Config.Instance.ConnEmqClientId = connEmqClientId;
+
+ var connEmqDomainPorts = connEmqDomainPort.Replace("//", "").Split(':');
+ var domain = connEmqDomainPorts[1];
+ var port = connEmqDomainPorts[2];
+
+ var options = new MQTTnet.Client.Options.MqttClientOptionsBuilder()
+ .WithClientId(connEmqClientId)
+ .WithTcpServer(domain, int.Parse(port))
+ .WithCredentials(connEmqUserName, connEmqPwd)
+ .WithKeepAlivePeriod(TimeSpan.FromSeconds(20))
+ .WithCleanSession()
+ //.WithCommunicationTimeout(TimeSpan.FromSeconds(10))
+ .Build();
+ await DisConnectRemoteMqttClient("StartRemoteMqtt");
+ await RemoteMqttClient.ConnectAsync(options, CancellationToken.None);
+
+ remoteIsConnected = true;
+ }
+ }
+ }
+ catch { }
+ finally
+ {
+ //鏈�缁堣閲婃斁杩炴帴鐘舵��
+ remoteMqttIsConnecting = false;
+ }
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"杩滅▼杩炴帴閫氳杩炴帴鍑哄紓甯�:{ex.Message}");
+ }
+ });
+ }
+
+ /// <summary>
+ /// 鏂紑鏈嶅姟鍣ㄨ繛鎺�
+ /// </summary>
+ public async System.Threading.Tasks.Task DisConnectLocalMqttClient(string s)
+ {
+ try
+ {
+ if (localIsConnected)
+ {
+ localIsConnected = false;
+ DebugPrintLog($"Local涓诲姩鏂紑_{s}");
+ //await localMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
+ await localMqttClient.DisconnectAsync();
+ }
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"Local鏂紑閫氳杩炴帴鍑哄紓甯�:{ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 鏂紑杩滅▼Mqtt鐨勯摼鎺�
+ /// </summary>
+ public static async System.Threading.Tasks.Task DisConnectRemoteMqttClient(string s="")
+ {
+ try
+ {
+ if (remoteIsConnected)
+ {
+ remoteIsConnected = false;
+ DebugPrintLog($"Remote涓诲姩鏂紑_{s}");
+ //await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
+ await RemoteMqttClient.DisconnectAsync();
+ }
+ }
+ catch(Exception e) {
+ DebugPrintLog($"Remote鏂紑閫氳杩炴帴鍑哄紓甯�:{e.Message}");
+ }
+ }
+
+ #endregion
+
+ /// <summary>
+ /// 鍙戦�佹秷鎭埌鏈嶅姟鍣�
+ /// </summary>
+ /// <returns>The send.</returns>
+ /// <param name="topic">Topic.</param>
+ /// <param name="cluster_ID">Cluster identifier.</param>
+ /// <param name="commnand">Commnand.</param>
+ /// <param name="message">Message.</param>
+ public void Send(string topic, Cluster_ID cluster_ID, Command commnand, Newtonsoft.Json.Linq.JObject message = null)
+ {
+ var jObject = new Newtonsoft.Json.Linq.JObject() {
+ {
+ "Cluster_ID", (int)cluster_ID },
+ {
+ "Command", (int)commnand }
+ };
+ if (message != null)
+ {
+ jObject.Add("Data", message);
+ }
+ Send(topic, System.Text.Encoding.UTF8.GetBytes(jObject.ToString()));
+ }
+
+ /// <summary>
+ /// 杩滅▼鍙戦�佹暟鎹牸寮�
+ /// </summary>
+ async System.Threading.Tasks.Task SendRemoteMsg(string topicName, byte[] message, bool retain = false)
+ {
+ try
+ {
+ if (this.getGatewayBaseInfo?.gwID == null || !GateWayBaseInfomations.ContainsKey(this.getGatewayBaseInfo?.gwID))
+ {
+ return;
+ }
+ var gateWayBaseInfomation = GateWayBaseInfomations[this.getGatewayBaseInfo?.gwID];
+ message = SecuritySet.AesEncryptBytes(message, gateWayBaseInfomation.AesKey);
+ var topicEncStr = $"/ClientToZigbeeGateWay/{gateWayBaseInfomation.MacMark}/Common/{topicName}";
+ //(6)鏋勫缓Mqtt闇�瑕佸彂甯冪殑鏁版嵁鍖�,鍙戝竷缁欎簯绔殑MqttBroker
+ if (remoteIsConnected)
+ {
+ try
+ {
+ await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicEncStr, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce });
+ }
+ catch (Exception e)
+ {
+ await DisConnectRemoteMqttClient(e.Message);
+ await StartRemoteMqtt();
+ if (remoteIsConnected)
+ {
+ await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicEncStr, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce });
+ }
+ }
+ }
+ }
+ catch
+ {
+ }
+ }
+
+ /// <summary>
+ /// 鍙戦�佹秷鎭埌鏈嶅姟鍣�
+ /// </summary>
+ /// <returns></returns>
+ /// <param name="topic"></param>
+ /// <param name="message"></param>
+ /// <param name="retain"></param>
+ public async System.Threading.Tasks.Task Send(string topic, byte[] message, bool retain = false)
+ {
+ try
+ {
+ if (Shared.Common.Config.Instance.HomeId == "")
+ {
+ return;
+ }
+
+ if (IsRemote)
+ {
+ await SendRemoteMsg(topic, message, retain);
+ DebugPrintLog($"杩滅▼鈥斺�斿彂閫佸埌缃戝叧鐨勪富棰�:{topic}_鍙戦�佸埌缃戝叧鐨勬暟鎹�:{System.Text.Encoding.UTF8.GetString(message)}_褰撳墠缃戝叧{CurrentGateWayId}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
+ }
+ else
+ {
+ DebugPrintLog($"灞�鍩熺綉鈥斺�斿彂閫佸埌缃戝叧鐨勪富棰�:{topic}_鍙戦�佸埌缃戝叧鐨勬暟鎹�:{System.Text.Encoding.UTF8.GetString(message)}_褰撳墠缃戝叧{CurrentGateWayId} 鏄惁鍔犲瘑:{IsEncry}");
+
+ if (IsEncry)
+ {
+ //鏂囦欢娴佷笉鐢ㄥ姞瀵�
+ if (topic != "FileTransfer/SendFile")
+ {
+ message = SecuritySet.AesEncryptBytes(message, password);
+ }
+ }
+ if (localIsConnected)
+ {
+ try
+ {
+ await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
+ }
+ catch(Exception e)
+ {
+ DebugPrintLog($"Local涓诲姩鏂紑_{e.Message}");
+ await DisConnectLocalMqttClient(e.Message);
+ await StartLocalMqtt("ReConnect");
+ if (localIsConnected)
+ {
+ DebugPrintLog($"灞�鍩熺綉鈥斺�斾簩娆″彂閫佸埌缃戝叧鐨勪富棰�:{topic}_鍙戦�佸埌缃戝叧鐨勬暟鎹�:{System.Text.Encoding.UTF8.GetString(message)}_褰撳墠缃戝叧{CurrentGateWayId} 鏄惁鍔犲瘑:{IsEncry}");
+ await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
+ }
+ }
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"Send:{ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 鍙戦�佹秷鎭埌鏈嶅姟鍣�
+ /// </summary>
+ /// <returns></returns>
+ /// <param name="topic"></param>
+ /// <param name="message"></param>
+ /// <param name="retain"></param>
+ public async System.Threading.Tasks.Task Send(string topic, string message, bool retain = false)
+ {
+ if (string.IsNullOrEmpty(message))
+ {
+ return;
+ }
+ await Send(topic, System.Text.Encoding.UTF8.GetBytes(message), retain);
+ }
+
+ /// <summary>
+ /// 寮哄埗鎸囧畾浣跨敤鏈湴灞�鍩熺綉鍙戦�佹秷鎭埌鏈嶅姟鍣�
+ /// </summary>
+ /// <returns></returns>
+ /// <param name="topic"></param>
+ /// <param name="message"></param>
+ /// <param name="retain"></param>
+ public async Task SendLocation(string topic, byte[] message, bool retain = false)
+ {
+ try
+ {
+ if (Shared.Common.Config.Instance.HomeId == "")
+ {
+ return;
+ }
+
+ DebugPrintLog($"灞�鍩熺綉鈥斺�斿彂閫佸埌缃戝叧鐨勪富棰�:{topic}_鍙戦�佸埌缃戝叧鐨勬暟鎹�:{System.Text.Encoding.UTF8.GetString(message)}_褰撳墠缃戝叧{CurrentGateWayId} 鏄惁鍔犲瘑:{IsEncry}");
+
+ if (IsEncry)
+ {
+ //鏂囦欢娴佷笉鐢ㄥ姞瀵�
+ if (topic != "FileTransfer/SendFile")
+ {
+ message = SecuritySet.AesEncryptBytes(message, password);
+ }
+ }
+ if (localIsConnected)
+ {
+ try
+ {
+ await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
+ }
+ catch (Exception e)
+ {
+ DebugPrintLog($"Local涓诲姩鏂紑_{e.Message}");
+ await DisConnectLocalMqttClient(e.Message);
+ await StartLocalMqtt("ReConnect");
+ if (localIsConnected)
+ {
+ DebugPrintLog($"灞�鍩熺綉鈥斺�斾簩娆″彂閫佸埌缃戝叧鐨勪富棰�:{topic}_鍙戦�佸埌缃戝叧鐨勬暟鎹�:{System.Text.Encoding.UTF8.GetString(message)}_褰撳墠缃戝叧{CurrentGateWayId} 鏄惁鍔犲瘑:{IsEncry}");
+ await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
+ }
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"Send:{ex.Message}");
+ }
+ }
+
+ [Serializable]
+ public class CloudTimeResponse
+ {
+ public string StateCode;
+ public string Info;
+ public string CloudTimestamp;
+ }
+
+ /// <summary>
+ /// 鎺ユ敹杩滅▼鏁版嵁澶勭悊
+ /// </summary>
+ /// <param name="sender">Sender.</param>
+ /// <param name="e">E.</param>
+ static void mqttRemoteClient_MqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs e)
+ {
+ try
+ {
+ var topic = e.ApplicationMessage.Topic.TrimStart('/');
+ var payload = e.ApplicationMessage.Payload;
+
+ var message = string.Empty;
+ //浣犲綋鍓嶇殑IP鍙婄鍙ｅ湪浜戠涓嶅瓨鍦�,璇烽噸鏂扮櫥褰曡繛鎺ヤ笅!
+
+ var topics = topic.Split("/");
+ if (topics.Length < 3)
+ {
+ return;
+ }
+ if (topics[0] != "ZigbeeGateWayToClient")
+ {
+ return;
+ }
+ if (topics[2]== "NotifyGateWayInfoChange") {
+ initGateWayBaseInfomation();
+ return;
+ }
+ if (topics[2] == "Common")
+ {
+ var macMark = topics[1];
+ topic = topic.Substring(topics[0].Length + topics[1].Length + topics[2].Length + 3);
+ if (payload[0] == (byte)'{' && payload[payload.Length - 1] == (byte)'}')
+ {
+ message = System.Text.Encoding.UTF8.GetString(payload);
+ }
+ else
+ {
+ foreach (var key in GateWayBaseInfomations.Keys)
+ {
+ var value = GateWayBaseInfomations[key];
+ if (value.MacMark == macMark)
+ {
+ topic = $"{key}/{topic}";
+ message = System.Text.Encoding.UTF8.GetString(ZigBee.Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, value.AesKey));
+ break;
+ }
+ }
+ }
+ }
+
+ DebugPrintLog($"杩滅▼杩斿洖鐨勪富棰�:{ topic}_杩滅▼杩斿洖鐨勬暟鎹甠{message}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
+
+ ReceiveMessage(topic, message, payload);
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"鎺ユ敹浜戠鏁版嵁寮傚父:{ex.Message} ");
+ }
+ }
+
+ /// <summary>
+ /// 鎺ユ敹灞�鍩熺綉涓殑鏁版嵁
+ /// 褰撹闃呮秷鎭垚鍔熷悗锛岃浜嬩欢浼氳璋冪敤
+ /// </summary>
+ /// <param name="sender">Sender.</param>
+ /// <param name="e">E.</param>
+ void mqttClient_MqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs e)
+ {
+ try
+ {
+ var topic = e.ApplicationMessage.Topic;
+ string payloadString = "";
+
+ if (IsEncry)
+ {
+ //涓婚
+ //涓嬭浇鐨勫瓧鑺傛祦涓嶉渶瑕佽В瀵�
+ if (topic.Split('/')[0] + "/" + topic.Split('/')[1] == topic.Split('/')[0] + "/" + "FileTransfer")
+ {
+ if (topic.Split('/')[2] != "DownloadFile")
+ {
+ payloadString = System.Text.Encoding.UTF8.GetString(Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, Password));
+ }
+ }
+ else if (topic == topic.Split('/')[0] + "/" + "SendAESKey_Respon") { }//鍥炲涓婚鏄鏂囷紝鏁版嵁鏄槑鏂�
+ else
+ {
+ payloadString = System.Text.Encoding.UTF8.GetString(Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, Password));
+ }
+ }
+ else
+ {
+ payloadString = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
+ }
+ DebugPrintLog($"缃戝叧杩斿洖鐨勪富棰�:{topic}_缃戝叧杩斿洖鐨勮礋杞�:{payloadString}");
+ ReceiveMessage(topic, payloadString, e.ApplicationMessage.Payload);
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"鎺ユ敹缃戝叧鏁版嵁寮傚父:{ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 鏁版嵁鎺ユ敹澶勭悊
+ /// </summary>
+ /// <param name="topic">Topic.</param>
+ /// <param name="message">Message.</param>
+ /// <param name="e">E.</param>
+ static void ReceiveMessage(string topic, string message, byte []payload)
+ {
+ try
+ {
+ if (string.IsNullOrEmpty(message))
+ {
+ message = "{}";
+ }
+ var gatewayID = topic.Split('/')[0];//缃戝叧杩斿洖鐨勭綉鍏矷D
+ var reportStatus = "";
+ reportStatus = topic.Split('/')[1];//涓婚涓鸿澶囦笂鎶ョ殑涓婚
+ string addr = "";//涓婃姤鐨勮澶嘺ddr
+ string epoint = "";//涓婃姤鐨勮澶噀point
+ string cluID = "";//涓婃姤鐨勮澶嘽luID
+ string attrId = "";//涓婃姤鐨勮澶嘺ttrId
+ if (reportStatus == "DeviceStatusReport")
+ {
+ addr = topic.Split('/')[2];
+ epoint = topic.Split('/')[3];
+ cluID = topic.Split('/')[4];
+ attrId = topic.Split('/')[5];
+ }
+
+ //鍏ㄥ眬鎺ユ敹缃戝叧鎺ㄩ�佺殑鐨勯�昏緫(涓轰簡鎵ц閫熷害,灏藉彲鑳界殑鍒姞鑰楁椂鐨勬搷浣�)
+ Shared.Phone.UserCenter.HdlGatewayReceiveLogic.Current.GatewayOverallMsgReceive(gatewayID, topic, reportStatus, message);
+
+ var gwa = GateWayList.Find(obj => obj.getGatewayBaseInfo.gwID == gatewayID);
+ if (gwa == null)
+ {
+ return;
+ }
+
+ if (gwa.Actions != null)
+ {
+ gwa?.Actions(topic, message);
+ }
+
+ gwa.GwResDataAction?.Invoke(topic, message);
+ gwa.CurrentGateWayId = gatewayID;
+
+ var jobject = new Newtonsoft.Json.Linq.JObject();
+ if (topic.Split('/')[0] + "/" + topic.Split('/')[1] == topic.Split('/')[0] + "/" + "FileTransfer")
+ {
+ if (topic.Split('/')[2] == "DownloadFile")
+ {
+ gwa.DownloadFileConfirmAsync(payload);
+ message = System.Text.Encoding.UTF8.GetString(payload);
+ gwa.FileContentAction?.Invoke(topic, payload);
+ DebugPrintLog($"缃戝叧杩斿洖鏁版嵁娴乢{message}");
+ return;
+ }
+ }
+ else
+ {
+ jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
+ }
+
+ #region 杩滅▼,涓荤綉鍏充笂鎶ラ�氱煡
+ if (IsRemote)
+ {
+ if (topic == gatewayID + "/" + "BeMainGw_Report")
+ {
+ var gwData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GetGwData>(jobject["Data"].ToString());
+ if (gwData != null)
+ {
+ var gwList = GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);
+ for (int i = 0; i < gwList.Count; i++)
+ {
+ if (gwList[i].getGatewayBaseInfo.gwID == gatewayID)
+ {
+ gwList[i].getGatewayBaseInfo.IsMainGateWay = true;
+ }
+ else
+ {
+ gwList[i].getGatewayBaseInfo.IsMainGateWay = false;
+ }
+ }
+ }
+ }
+ }
+
+ #endregion
+ #region 璁惧鏂颁笂鎶�
+ //姝ラ1锛夌綉鍏冲憡鐭ュ鎴风鏈夋柊璁惧鍔犲叆zigbee缃戠粶銆�
+ if (topic == gatewayID + "/" + "Device/DeviceJoinZbNet_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ gatewayTemp.deviceDeviceJoinZbNetResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceDeviceJoinZbNetResponData>(jobject["Data"].ToString());
+ if (gatewayTemp.deviceDeviceJoinZbNetResponData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("Device/DeviceJoinZbNet宸茬粡閫氱煡");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("Device/DeviceJoinZbNet", gatewayTemp);
+ }
+ }
+ //姝ラ2锛夌綉鍏冲憡鐭ュ鎴风鑾峰彇鏂拌澶囨墍鏈夌鐐逛俊鎭槸鍚︽垚鍔�
+ if (topic == gatewayID + "/" + "Device/IsGetEpointInfo_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ gatewayTemp.deviceIsGetEpointInfoResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceIsGetEpointInfoResponData>(jobject["Data"].ToString());
+ if (gatewayTemp.deviceIsGetEpointInfoResponData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("Device/IsGetEpointInfo宸茬粡閫氱煡");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("Device/IsGetEpointInfo", gatewayTemp);
+ }
+ }
+ //姝ラ3锛夌綉鍏充笂鎶ヨ妭鐐硅澶囨墍鏈夌鐐逛俊鎭�
+ if (topic == gatewayID + "/" + "DeviceInComingRespon")
+ {
+ //鏂拌澶囦笂鎶ワ紝閲嶆柊鍙戣幏鍙栨墍鏈夌殑璁惧
+ var tempDevice = new CommonDevice() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ tempDevice.getNewDeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.NewDeviceInfoData>(jobject["Data"].ToString());
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("DeviceInComingRespon宸茬粡閫氱煡");
+ gwa.ReportAction("DeviceInComingRespon", tempDevice.getNewDeviceInfo);
+ }
+ UpdateDeviceInfo(tempDevice, "DeviceInComingRespon");
+ }
+ #endregion
+ #region 璁惧鍦ㄧ嚎鐘舵�佹洿鏂板弽棣�
+ else if (topic == gatewayID + "/" + "OnlineStatusChange_Respon")
+ {
+ var tempDevice = new CommonDevice() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ tempDevice.IsOnline = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["IsOnline"].ToString());
+
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("OnlineStatusChange宸茬粡閫氱煡");
+ gwa.ReportAction("OnlineStatusChange", tempDevice);
+ }
+ var infoTempDevice = gwa.DeviceList.Find(obj => obj.DeviceID == tempDevice.DeviceID && obj.DeviceAddr == tempDevice.DeviceAddr);
+ if (infoTempDevice == null)
+ {
+ gwa.DeviceList.Add(tempDevice);
+ UpdateDeviceInfo(tempDevice, "OnlineStatusChange");
+ }
+ else
+ {
+ if (infoTempDevice.DeviceInfo != null)
+ {
+ infoTempDevice.DeviceInfo.IsOnline = infoTempDevice.IsOnline;
+ }
+ UpdateDeviceInfo(infoTempDevice, "OnlineStatusChange");
+ }
+ }
+ #endregion
+ #region 璁惧琚垹闄や笂鎶�
+ else if (topic == gatewayID + "/" + "RemoveDeviceRespon")
+ {
+ var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ gatewayTemp.removeDeviceResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.RemoveDeviceResponseData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.removeDeviceResponseData != null)
+ {
+ try
+ {
+ if (gatewayTemp.removeDeviceResponseData.Result == 0)
+ {
+ foreach (var delD in gatewayTemp.removeDeviceResponseData.DeviceList)
+ {
+ var tempDevice = new CommonDevice() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ tempDevice.removeDeviceResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.RemoveDeviceResponseData>(jobject["Data"].ToString());
+ if (tempDevice.removeDeviceResponseData == null)
+ {
+ return;
+ }
+ else
+ {
+ UpdateDeviceInfo(tempDevice, "RemoveDeviceRespon");
+ if (tempDevice.removeDeviceResponseData.Result == 0)
+ {
+ var infoTempDevice = gwa.DeviceList.Find((CommonDevice obj) => obj.DeviceID == tempDevice.DeviceID && obj.DeviceAddr == tempDevice.DeviceAddr && obj.DeviceEpoint == tempDevice.DeviceEpoint);
+ if (infoTempDevice != null)
+ {
+ gwa.DeviceList.Remove(infoTempDevice);
+ }
+ }
+ }
+ }
+ }
+ }
+ catch { }
+ }
+ }
+ #endregion
+ #region 璁惧鐘舵�佷笂鎶�
+ else if (topic == gatewayID + "/" + "DeviceStatusReport" + "/" + addr + "/" + epoint + "/" + cluID + "/" + attrId)
+ {
+ var deviceID = jobject.Value<int>("Device_ID");
+ var deviceAddr = jobject.Value<string>("DeviceAddr");
+ var tempEpoint = jobject.Value<int>("Epoint");
+ var dataId = jobject.Value<int>("Data_ID");
+
+ var tempDevice = new CommonDevice { DeviceID = deviceID, DeviceAddr = deviceAddr, DeviceEpoint = tempEpoint, DataID = dataId };
+ tempDevice.DeviceStatusReport = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DeviceStatusReportData>(jobject["Data"].ToString());
+ UpdateDeviceInfo(tempDevice, "DeviceStatusReport");
+ }
+ #endregion
+ #region 闂ㄩ攣鎿嶄綔浜嬩欢閫氱煡
+ else if (topic == gatewayID + "/" + "DoorLock/DoorLockOperatingEventNotificationCommand")
+ {
+ var deviceID = jobject.Value<int>("Device_ID");
+ switch ((DeviceType)(deviceID))
+ {
+ case DeviceType.DoorLock:
+ var doorLock = new DoorLock() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ var OperatingEventNotificationDatad = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Device.DoorLock.DoorLockOperatingEventNotificationCommand>(jobject["Data"].ToString());
+ if (OperatingEventNotificationDatad != null)
+ {
+ doorLock.doorLockOperatingEventNotificationCommand = OperatingEventNotificationDatad;
+ }
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("DoorLockProgrammingEventNotificationCommand宸茬粡閫氱煡");
+ gwa.ReportAction("DoorLockProgrammingEventNotificationCommand", doorLock);
+ }
+ UpdateDeviceInfo(doorLock, "DoorLockProgrammingEventNotificationCommand");
+ break;
+ }
+ }
+ #endregion
+ #region 闂ㄩ攣缂栫▼浜嬩欢閫氱煡
+ else if (topic == gatewayID + "/" + "DoorLock/DoorLockProgrammingEventNotificationCommand")
+ {
+ var deviceID = jobject.Value<int>("Device_ID");
+ switch ((DeviceType)(deviceID))
+ {
+ case DeviceType.DoorLock:
+ var doorLock = new DoorLock() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ var ProgrammingEventNotificationData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Device.DoorLock.DoorLockProgrammingEventNotificationCommand>(jobject["Data"].ToString());
+ if (ProgrammingEventNotificationData != null)
+ {
+ doorLock.doorLockProgrammingEventNotificationCommand = ProgrammingEventNotificationData;
+ }
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("DoorLockProgrammingEventNotificationCommand宸茬粡閫氱煡");
+ gwa.ReportAction("DoorLockProgrammingEventNotificationCommand", doorLock);
+ }
+ UpdateDeviceInfo(doorLock, "DoorLockProgrammingEventNotificationCommand");
+ break;
+ }
+ }
+ #endregion
+ #region IAS瀹夐槻淇℃伅涓婃姤
+ else if (topic == gatewayID + "/" + "IASInfoReport")
+ {
+ var deviceID = jobject.Value<int>("Device_ID");
+ switch ((DeviceType)(deviceID))
+ {
+ case DeviceType.IASZone:
+ var ias = new IASZone() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
+ ias.iASInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.IASInfoData>(jobject["Data"].ToString());
+ //涓婃姤绫诲瀷閫氱煡锛屽繀闇�鍏堣皟鐢紝鐒跺悗鎵嶆湁閫氱煡锛屽惁鍒欐槸绌轰笉浼氶�氱煡鐨�
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("IASInfoReport宸茬粡閫氱煡");
+ //ias.Save();
+ gwa.ReportAction("IASInfoReport", ias.iASInfo);
+ }
+ UpdateDeviceInfo(ias, "IASInfoReport");
+ break;
+ }
+ }
+ #endregion
+ #region 涓嬭浇杩涘害涓婃姤
+ else if (topic == gatewayID + "/" + "DownloadFile_Progress")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.downloadFileProgressResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DownloadFileProgressResponData>(jobject["Data"].ToString());
+ if (gatewayTemp.downloadFileProgressResponData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("DownloadFileProgress");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("DownloadFileProgress", gatewayTemp);
+ }
+ }
+ else if (topic == gatewayID + "/" + "ZbGwOperation/Upgrade_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGwOperationUpgradeData>(jobject["Data"].ToString());
+ if (gatewayTemp.zbGwOperationUpgradeData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("鍗忚皟鍣ㄥ崌绾х櫨鍒嗘瘮");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("CordinatorUpgradePercent", gatewayTemp);
+ }
+ }
+ else if (topic == gatewayID + "/" + "OTA/Schedule_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.oTAScheduleResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<OTAScheduleResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.oTAScheduleResponData == null)
+ {
+ return;
+ }
+
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("鑺傜偣璁惧鍗囩骇鐧惧垎姣�");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("DeviceUpgradePercent", gatewayTemp);
+ }
+ }
+ else if (topic == gatewayID + "/" + "VirtualDrive/Upgrade_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
+ gatewayTemp.virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.virtualDriveUpgradeResponData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("铏氭嫙椹卞姩鍗囩骇鐧惧垎姣�");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("VirtualDriveUpgrade", gatewayTemp);
+ }
+ }
+ #endregion
+ #region 閲嶅惎缃戝叧绯荤粺
+ else if (topic == gatewayID + "/" + "GwReboot_Respon")
+ {
+ var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID") };
+ gatewayTemp.gwRebootResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<GwRebootResponData>(jobject["Data"].ToString());
+
+ if (gatewayTemp.gwRebootResponData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("GwReboot_Respon宸茬粡閫氱煡");
+ gatewayTemp.CurrentGateWayId = gatewayID;//杩欓噷鐨凜urrentGateWayId鏄綋鍓嶆柊new ZbGateway鐨勫��
+ gwa.ReportAction("GwReboot_Respon", gatewayTemp);
+ }
+ }
+ #endregion
+ #region 闃插尯琚Е鍙戞椂鎶ュ憡
+ else if (topic == gatewayID + "/" + "Security/ZoneTriggerReport")
+ {
+ var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ ias.zoneTriggerReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.ZoneTriggerReportData>(jobject["Data"].ToString());
+
+ if (ias.zoneTriggerReportData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("ZoneTriggerReport宸茬粡閫氱煡");
+ gwa.ReportAction("ZoneTriggerReport", ias.zoneTriggerReportData);
+ }
+ }
+ #endregion
+ #region 閫昏緫琚皟鐢ㄥ弽棣�
+ else if (topic == gatewayID + "/" + "Logic/Execute_Respon")
+ {
+ //var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ //logic.logicExecuteRespo = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.ExecuteResponse>(jobject["Data"].ToString());
+
+ //if (logic.logicExecuteRespo == null)
+ //{
+ // return;
+ //}
+ ////涓婃姤绫诲瀷閫氱煡
+ //if (gwa.ReportAction != null)
+ //{
+ // DebugPrintLog("LogicExecuteReport宸茬粡閫氱煡");
+ // gwa.ReportAction("LogicExecuteReport", logic.logicExecuteRespo);
+ //}
+ }
+ #endregion
+ #region 鏃堕棿鐐规潯浠舵帹杩熸墽琛�
+ else if (topic == gatewayID + "/" + "Logic/TimingWillArrive")
+ {
+ //var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ //logic.timingWillArriveData = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.TimingWillArriveData>(jobject["Data"].ToString());
+
+ //if (logic.timingWillArriveData == null)
+ //{
+ // return;
+ //}
+ ////涓婃姤绫诲瀷閫氱煡
+ //if (gwa.ReportAction != null)
+ //{
+ // DebugPrintLog("TimingWillArrive宸茬粡閫氱煡");
+ // gwa.ReportAction("TimingWillArrive", logic.timingWillArriveData);
+ //}
+ }
+ #endregion
+ #region 妯″紡瀹夐槻鍔ㄤ綔琚渶缁堟縺娲绘椂鍙戦�佹姤璀︿俊鎭�
+ else if (topic == gatewayID + "/" + "Security/ModeTriggerReport")
+ {
+ var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ ias.modeTriggerReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.ModeTriggerReportData>(jobject["Data"].ToString());
+ if (ias.modeTriggerReportData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("ModeTriggerReport宸茬粡閫氱煡");
+ gwa.ReportAction("ModeTriggerReport", ias.modeTriggerReportData);
+ }
+ }
+ #endregion
+ #region 閫氳繃澶栭儴鏂瑰紡甯冮槻鎾ら槻鎴愬姛鏃舵姤鍛婃伅
+ else if (topic == gatewayID + "/" + "Security/EnOrWithdrawSucceedReport")
+ {
+ var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ ias.enOrWithdrawSucceedReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.EnOrWithdrawSucceedReportData>(jobject["Data"].ToString());
+ if (ias.enOrWithdrawSucceedReportData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("EnOrWithdrawSucceedReport");
+ gwa.ReportAction("EnOrWithdrawSucceedReport", ias.enOrWithdrawSucceedReportData);
+ }
+ }
+ #endregion
+ #region 鑳佽揩瀵嗙爜鎾ら槻鏃剁煭淇℃帹閫�
+ else if (topic == gatewayID + "/" + "Security/PushTargetInfo")
+ {
+ var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
+ ias.coercedPWDWithdrawReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.CoercedPWDWithdrawReportData>(jobject["Data"].ToString());
+ if (ias.coercedPWDWithdrawReportData == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("PushTargetInfoReport");
+ gwa.ReportAction("PushTargetInfoReport", ias.coercedPWDWithdrawReportData);
+ }
+ }
+ #endregion
+ #region 鑺傜偣璁惧榛樿鍙嶉
+ else if (topic == gatewayID + "/" + "DeviceDefaultAck")
+ {
+ var deviceDefaultAck = 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 = gwa.getGatewayBaseInfo.gwID };
+ if (deviceDefaultAck == null)
+ {
+ return;
+ }
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ DebugPrintLog("DeviceDefaultAck");
+ gwa.ReportAction("DeviceDefaultAck", deviceDefaultAck);
+ }
+ }
+ #endregion
+
+ #region 璁惧璇锋眰APP鑾峰彇鍗囩骇鏁版嵁
+ else if (topic == gatewayID + "/" + "ZbDataPassthrough")
+ {
+ //涓婃姤绫诲瀷閫氱煡
+ if (gwa.ReportAction != null)
+ {
+ var clientDataPassthrough = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
+ if (clientDataPassthrough != null)
+ {
+ DebugPrintLog("DeviceRequestAcUpdateData");
+ gwa.ReportAction("DeviceRequestAcUpdateData", clientDataPassthrough);
+ }
+ }
+ }
+ #endregion
+ }
+ catch (Exception ex)
+ {
+ DebugPrintLog($"澶勭悊鍥炲鐨勬暟鎹姏鍑哄紓甯革細{ex.Message}");
+ }
+
+ }
+ }
+}
--
Gitblit v1.8.0