From 160785587667cc0d927f85e44c139ec9dde13a9e Mon Sep 17 00:00:00 2001 From: 黄学彪 <hxb@hdlchina.com.cn> Date: 星期一, 25 十一月 2019 14:30:13 +0800 Subject: [PATCH] 原来的 IOS 工程舍弃(注:没有合并其他组员的代码) --- ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayReceiveLogic.cs | 297 ++++++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 244 insertions(+), 53 deletions(-) diff --git a/ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayReceiveLogic.cs b/ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayReceiveLogic.cs index f1c7924..6993d9f 100755 --- a/ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayReceiveLogic.cs +++ b/ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayReceiveLogic.cs @@ -39,7 +39,7 @@ /// <summary> /// 鍛戒护鍖哄垎 /// </summary> - private Dictionary<string, string> dicCommandDiv = new Dictionary<string, string>(); + private Dictionary<string, ReceiveComandDiv> dicCommandDiv = new Dictionary<string, ReceiveComandDiv>(); #endregion @@ -65,6 +65,7 @@ UserCenterLogic.ReLoginAgain(UserCenterResourse.UserInfo.Account, false); }); + return; } else if (topic == "BeingSqueezedOffline") { @@ -77,6 +78,7 @@ UserCenterLogic.ReLoginAgain(UserCenterResourse.UserInfo.Account, false); }); + return; } else if (topic == "YouIpAndPortNoRecord") { @@ -89,6 +91,7 @@ UserCenterLogic.ReLoginAgain(UserCenterResourse.UserInfo.Account, false); }); + return; } try { @@ -102,12 +105,12 @@ if (reportTopic == "DeviceStatusReport") { //璁惧灞炴�т笂鎶� - //this.DeviceAttributeReportPush(receiveData); + this.DeviceAttributeReportPush(receiveData); } //浼犳劅鍣ㄤ笂鎶� else if (reportTopic == "IASInfoReport") { - //this.SensorDeviceReportPush(receiveData); + this.SensorDeviceReportPush(receiveData); } //闂ㄩ攣涓婃姤 else if (topic == gatewayId + "/Alarms/SendAlarmInform") @@ -117,13 +120,175 @@ //閫氳繃澶栭儴鏂瑰紡甯冮槻鎾ら槻鎴愬姛鏃舵姤鍛� else if (topic == gatewayId + "/Security/EnOrWithdrawSucceedReport") { - SecurityEnOrWithdrawSucceedReport(receiveData); + this.SecurityEnOrWithdrawSucceedReport(receiveData); + } + //璁惧鍦ㄧ嚎鐘舵�佹洿鏂板弽棣� + else if (reportTopic == "OnlineStatusChange_Respon") + { + this.DeviceOnlineChangePush(receiveData); + } + //鎾ら槻 + else if (topic == gatewayId + "/Security/WithdrawMode_Respon") + { + this.RemoveSafetyGarrisonPush(receiveData); + } + //甯冮槻 + else if (topic == gatewayId + "/Security/EnableMode_Respon") + { + this.SetSafetyGarrisonPush(receiveData); + } + //閫昏緫瑙﹀彂涓婃姤 + else if (topic == gatewayId + "/Logic/Execute_Respon") + { + this.LogicExecutePush(receiveData); + } + //鍦烘櫙瑙﹀彂涓婃姤 + else if (topic == gatewayId + "/Scene/Exec_Respon") + { + this.SceneExecPush(receiveData); } } catch (Exception ex) { //Log鍑哄姏 HdlLogLogic.Current.WriteLog(ex); + } + } + + #endregion + + #region 鈻� 璁惧灞炴�т笂鎶______________________ + + /// <summary> + /// 璁惧灞炴�т笂鎶� + /// </summary> + /// <param name="receiveData"></param> + private void DeviceAttributeReportPush(JObject receiveData) + { + var deviceAddr = receiveData.Value<string>("DeviceAddr"); + var deviceEpoint = receiveData.Value<int>("Epoint"); + + var tempDevice = new CommonDevice { DeviceAddr = deviceAddr, DeviceEpoint = deviceEpoint }; + tempDevice.DeviceStatusReport = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DeviceStatusReportData>(receiveData["Data"].ToString()); + + this.DeviceReportPush(tempDevice, ReceiveComandDiv.A璁惧灞炴�т笂鎶�); + } + + #endregion + + #region 鈻� 浼犳劅鍣ㄤ笂鎶________________________ + + /// <summary> + /// 浼犳劅鍣ㄨ澶囦笂鎶� + /// </summary> + /// <param name="receiveData"></param> + private void SensorDeviceReportPush(JObject receiveData) + { + var ias = new IASZone() { DeviceAddr = receiveData.Value<string>("DeviceAddr"), DeviceEpoint = receiveData.Value<int>("Epoint") }; + ias.iASInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.IASInfoData>(receiveData["Data"].ToString()); + + //濡傛灉娌℃湁娣诲姞鍏ュ畨闃� + if (HdlSafeguardLogic.Current.GetZoneIdByIASZone(ias) != -1) + { + //淇濆瓨瀹夐槻鎶ヨ淇℃伅鍒版湰鍦� + HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(ias); + } + + this.DeviceReportPush(ias, ReceiveComandDiv.A浼犳劅鍣ㄤ笂鎶�); + + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); + } + + #endregion + + #region 鈻� 闂ㄩ攣涓婃姤___________________________ + + /// <summary> + /// 闂ㄩ攣涓婃姤 + /// </summary> + /// <param name="receiveData"></param> + private void DoorLockDeviceReportPush(JObject receiveData) + { + //淇濆瓨闂ㄩ攣淇℃伅鍒版湰鍦� + HdlAlarmsLogic.Current.SaveDoorLockAlarmInfo(receiveData); + + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); + } + + #endregion + + #region 鈻� 璁惧鍦ㄧ嚎鐘舵�佹洿鏂板弽棣坃______________ + + /// <summary> + /// 璁惧鍦ㄧ嚎鐘舵�佹洿鏂板弽棣� + /// </summary> + /// <param name="receiveData"></param> + private void DeviceOnlineChangePush (JObject receiveData) + { + var tempDevice = new CommonDevice() { DeviceAddr = receiveData.Value<string>("DeviceAddr"), DeviceEpoint = receiveData.Value<int>("Epoint") }; + tempDevice.IsOnline = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(receiveData["Data"]["IsOnline"].ToString()); + + this.DeviceReportPush(tempDevice, ReceiveComandDiv.A璁惧鍦ㄧ嚎涓婃姤); + } + + #endregion + + #region 鈻� 甯冮槻_______________________________ + + /// <summary> + /// 甯冮槻鎺ㄩ�� + /// </summary> + /// <param name="receiveData"></param> + private void SetSafetyGarrisonPush(JObject receiveData) + { + var data = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.EnableModeResponseData>(receiveData["Data"].ToString()); + if (data.Result == 0) + { + var garrison = GarrisonMode.None; + //鍦ㄥ甯冮槻 + if (data.ModeId == 1) { garrison = GarrisonMode.AtHome; } + //绂诲甯冮槻 + else if (data.ModeId == 2) { garrison = GarrisonMode.RemoveHome; } + else { return; } + + //淇濆瓨鎶ヨ淇℃伅鐒跺悗鎺ㄩ�佸埌鐣岄潰涓� + HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(garrison); + if (UserCenterResourse.DicActionForm.ContainsKey("SafetyManagementMainForm") == true) + { + //鎺ㄩ�� + var form = (Safety.SafetyManagementMainForm)UserCenterResourse.DicActionForm["SafetyManagementMainForm"]; + form?.GarrisonModePush(garrison); + } + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); + } + } + + #endregion + + #region 鈻� 鎾ら槻_______________________________ + + /// <summary> + /// 鎾ら槻鎺ㄩ�� + /// </summary> + /// <param name="receiveData"></param> + private void RemoveSafetyGarrisonPush(JObject receiveData) + { + var data = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.WithdrawModeResponseData>(receiveData["Data"].ToString()); + if (data.Result == 0) + { + //淇濆瓨鎶ヨ淇℃伅鐒跺悗鎺ㄩ�佸埌鐣岄潰涓� + HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(GarrisonMode.RemoveGarrison); + if (UserCenterResourse.DicActionForm.ContainsKey("SafetyManagementMainForm") == true) + { + //鎺ㄩ�� + var form = (Safety.SafetyManagementMainForm)UserCenterResourse.DicActionForm["SafetyManagementMainForm"]; + form?.GarrisonModePush(GarrisonMode.RemoveGarrison); + } + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); } } @@ -162,7 +327,15 @@ else if (data.OperationWay == 1) { appendText = "(" + Language.StringByID(R.MyInternationalizationString.uPanelOperation) + ")"; } //淇濆瓨鎶ヨ淇℃伅鐒跺悗鎺ㄩ�佸埌鐣岄潰涓� - HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(garrison, appendText, true); + HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(garrison, appendText); + if (UserCenterResourse.DicActionForm.ContainsKey("SafetyManagementMainForm") == true) + { + //鎺ㄩ�� + var form = (Safety.SafetyManagementMainForm)UserCenterResourse.DicActionForm["SafetyManagementMainForm"]; + form?.GarrisonModePush(garrison); + } + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); } /// <summary> @@ -186,59 +359,34 @@ #endregion - #region 鈻� 璁惧灞炴�т笂鎶______________________ + #region 鈻� 閫昏緫瑙﹀彂涓婃姤_______________________ /// <summary> - /// 璁惧灞炴�т笂鎶� + /// 閫昏緫瑙﹀彂涓婃姤 /// </summary> /// <param name="receiveData"></param> - private void DeviceAttributeReportPush(JObject receiveData) + private void LogicExecutePush(JObject receiveData) { - var deviceAddr = receiveData.Value<string>("DeviceAddr"); - var deviceEpoint = receiveData.Value<int>("Epoint"); + //鐩墠涓嶅鐞嗛�昏緫涓婃姤鍐呭 - var tempDevice = new CommonDevice { DeviceAddr = deviceAddr, DeviceEpoint = deviceEpoint }; - tempDevice.DeviceStatusReport = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DeviceStatusReportData>(receiveData["Data"].ToString()); - - this.DeviceReportPush(tempDevice, "DeviceStatusReport"); + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); } #endregion - #region 鈻� 浼犳劅鍣ㄤ笂鎶________________________ + #region 鈻� 鍦烘櫙瑙﹀彂涓婃姤_______________________ /// <summary> - /// 浼犳劅鍣ㄨ澶囦笂鎶� + /// 鍦烘櫙瑙﹀彂涓婃姤 /// </summary> /// <param name="receiveData"></param> - private void SensorDeviceReportPush(JObject receiveData) + private void SceneExecPush(JObject receiveData) { - var ias = new IASZone() { DeviceAddr = receiveData.Value<string>("DeviceAddr"), DeviceEpoint = receiveData.Value<int>("Epoint") }; - ias.iASInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.IASInfoData>(receiveData["Data"].ToString()); + //鐩墠涓嶅鐞嗗満鏅笂鎶ュ唴瀹� - //濡傛灉娌℃湁娣诲姞鍏ュ畨闃� - if (HdlSafeguardLogic.Current.GetZoneIdByIASZone(ias) == -1) - { - } - else - { - //淇濆瓨瀹夐槻鎶ヨ淇℃伅鍒版湰鍦� - HdlAlarmsLogic.Current.SaveSafeguardAlarmInfo(ias); - } - } - - #endregion - - #region 鈻� 闂ㄩ攣涓婃姤___________________________ - - /// <summary> - /// 闂ㄩ攣涓婃姤 - /// </summary> - /// <param name="receiveData"></param> - private void DoorLockDeviceReportPush(JObject receiveData) - { - //淇濆瓨闂ㄩ攣淇℃伅鍒版湰鍦� - HdlAlarmsLogic.Current.SaveDoorLockAlarmInfo(receiveData); + //鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + this.ShowHadNewMessageAppeal(); } #endregion @@ -249,12 +397,20 @@ /// 娣诲姞鑾峰彇璁惧灞炴�х殑浜嬩欢(鎺ㄩ�佸凡缁忓己鍒舵寚瀹氳繍琛屼簬涓荤嚎绋嬶紝灞炴�т笂鎶ョ殑瀵硅薄锛歞evice.DeviceStatusReport) /// </summary> /// <param name="mainKeys">鏍囪瘑浜嬩欢鐨勪富閿�(鍙互闅忎究濉�,涓昏鏄拡瀵瑰涓晫闈竴璧蜂娇鐢ㄧ殑鎯呭喌)</param> - /// <param name="comand">鍛戒护鍖哄垎,姣斿锛欴eviceStatusReport,IASInfoReport绛夌瓑</param> - /// <param name="action">褰撴帴鏀跺埌缃戝叧鍥炲涔嬪悗鐨勫洖璋冨嚱鏁�,灞炴�т笂鎶ョ殑瀵硅薄锛歞evice.DeviceStatusReport</param> - public void AddAttributeEvent(string mainKeys, string comand, Action<CommonDevice> action) + /// <param name="comand">鍛戒护鍖哄垎</param> + /// <param name="action"> + /// <para>褰撴帴鏀跺埌缃戝叧鍥炲涔嬪悗鐨勫洖璋冨嚱鏁�</para> + /// <para>璁惧灞炴�т笂鎶ョ殑瀵硅薄锛歞evice.DeviceStatusReport</para> + /// <para>浼犳劅鍣ㄤ笂鎶ョ殑瀵硅薄锛歩as.iASInfo</para> + /// <para>璁惧鍦ㄧ嚎涓婃姤鐨勫璞★細device.IsOnline</para></param> + public void AddAttributeEvent(string mainKeys, ReceiveComandDiv comand, Action<CommonDevice> action) { lock (this.dicDeviceEvent) { + if (this.dicDeviceEvent.ContainsKey(mainKeys) == true) + { + this.RemoveEvent(mainKeys); + } this.dicDeviceEvent[mainKeys] = action; this.dicCommandDiv[mainKeys] = comand; } @@ -305,14 +461,14 @@ #endregion - #region 鈻� 璁惧涓婃姤鎺ㄩ�乢______________________ + #region 鈻� 涓�鑸柟娉昣__________________________ /// <summary> /// 璁惧涓婃姤鎺ㄩ�� /// </summary> /// <param name="common"></param> - /// <param name="typeTag"></param> - private void DeviceReportPush(CommonDevice common, string reportTopic) + /// <param name="comand"></param> + private void DeviceReportPush(CommonDevice common, ReceiveComandDiv comand) { lock (this.dicDeviceEvent) { @@ -325,7 +481,7 @@ var list = new List<Action<CommonDevice>>(); foreach (string keys in this.dicDeviceEvent.Keys) { - if (this.dicCommandDiv[keys] != reportTopic) + if (this.dicCommandDiv[keys] != comand) { //鍛戒护鍖哄垎涓嶄竴鑷达紝鍒欎笉璋冪敤鍥炶皟鍑芥暟 continue; @@ -354,10 +510,6 @@ } } - #endregion - - #region 鈻� 涓�鑸柟娉昣__________________________ - /// <summary> /// 鏄惁瀛樺湪鎸囧畾鐨勪簨浠� /// </summary> @@ -368,6 +520,45 @@ return this.dicCommandDiv.ContainsKey(mainkeys); } + /// <summary> + /// 鏄剧ず鏈夋柊娑堟伅鐨勭壒鏁� + /// </summary> + private void ShowHadNewMessageAppeal() + { + //鏈夋柊娑堟伅(鐗规晥杩樺湪鏃�,涓嶉渶瑕佸啀澶勭悊) + if (ControlCommonResourse.HadNewMessage == false) + { + HdlThreadLogic.Current.RunMain(() => + { + for (int i = 0; i < ControlCommonResourse.listMessageManaContr.Count; i++) + { + //鏄剧ず瑙掓爣鐗规晥 + ControlCommonResourse.listMessageManaContr[i].IsSelected = true; + } + ControlCommonResourse.HadNewMessage = true; + }); + } + } + #endregion } + + /// <summary> + /// 鎺ユ敹鍛戒护鍖哄垎 + /// </summary> + public enum ReceiveComandDiv + { + /// <summary> + /// 璁惧灞炴�т笂鎶� + /// </summary> + A璁惧灞炴�т笂鎶� = 1, + /// <summary> + /// 浼犳劅鍣ㄤ笂鎶� + /// </summary> + A浼犳劅鍣ㄤ笂鎶� = 2, + /// <summary> + /// 璁惧鍦ㄧ嚎涓婃姤 + /// </summary> + A璁惧鍦ㄧ嚎涓婃姤 = 3 + } } -- Gitblit v1.8.0