From df8d4ab0ef17a7fab5dea9c47bbd9f4d4a2a40b0 Mon Sep 17 00:00:00 2001
From: 黄学彪 <hxb@hdlchina.com.cn>
Date: 星期一, 15 三月 2021 14:55:49 +0800
Subject: [PATCH] 合并前上传一个版本

---
 HDL_ON/DAL/DriverLayer/Control.cs |  400 +++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 278 insertions(+), 122 deletions(-)

diff --git a/HDL_ON/DAL/DriverLayer/Control.cs b/HDL_ON/DAL/DriverLayer/Control.cs
index 8e434c9..5b3309f 100644
--- a/HDL_ON/DAL/DriverLayer/Control.cs
+++ b/HDL_ON/DAL/DriverLayer/Control.cs
@@ -1,4 +1,4 @@
-using System;
+锘縰sing System;
 using System.Collections.Generic;
 using System.Text;
 using HDL_ON.Entity;
@@ -65,29 +65,26 @@
         /// </summary>
         public bool IsSearchLocalGatewaySuccessful = false;
       
+        bool _GatewayOnline_Local = false;
         /// <summary>
-        /// 
+        /// 缃戝叧鍦ㄧ嚎-灞�鍩熺綉
         /// </summary>
-        bool _gatewayOnline = false;
-        /// <summary>
-        /// 缃戝叧鏄惁鍦ㄧ嚎
-        /// </summary>
-        public bool GatewayOnline
+        public bool GatewayOnline_Local
         {
             get
             {
-                return _gatewayOnline;
+                return _GatewayOnline_Local;
             }
             set
             {
-                if (_gatewayOnline != value)
+                if (_GatewayOnline_Local != value)
                 {
-                    _gatewayOnline = value;
-                    //淇敼涓婚〉杩炴帴鐘舵��
-                    UI.HomePage.LoadEvent_CheckLinkStatus();
+                    _GatewayOnline_Local = value;
                     if (value)
                     {
-                        MainPage.Log($"缃戝叧鍦ㄧ嚎锛屽埛鏂拌澶囩姸鎬�");
+                        //淇敼涓婚〉杩炴帴鐘舵��
+                        HomePage.LoadEvent_CheckLinkStatus();
+                        MainPage.Log($"缃戝叧灞�鍩熺綉鍦ㄧ嚎锛屽埛鏂拌澶囩姸鎬�");
                         new System.Threading.Thread(() =>
                         {
                             System.Threading.Thread.Sleep(1000);
@@ -95,31 +92,79 @@
                         })
                         { IsBackground = true, Priority = System.Threading.ThreadPriority.AboveNormal }.Start();
                     }
+                    else
+                    {
+                        //淇敼涓婚〉杩炴帴鐘舵��
+                        HomePage.LoadEvent_CheckLinkStatus();
+                    }
                 }
             }
         }
+        bool _GatewayOnline_Cloud = false;
+        /// <summary>
+        /// 缃戝叧鍦ㄧ嚎-浜戠
+        /// </summary>
+        public bool GatewayOnline_Cloud
+        {
+            get
+            {
+                return _GatewayOnline_Cloud;
+            }
+            set
+            {
+                if (_GatewayOnline_Cloud != value)
+                {
+                    _GatewayOnline_Cloud = value;
+                    if(GatewayOnline_Local)
+                    {
+                        return;
+                    }
+                    if (value)
+                    {
+                        if (DB_ResidenceData.Instance.HomeGateway == null)
+                        {
+                            return;
+                        }
+                        if (!DB_ResidenceData.Instance.HomeGateway.gatewayStatus)//杩滅▼鎯呭喌涓嬶紝缃戝叧鏈摼鎺ユ湇鍔″櫒涓嶈兘淇敼涓婚〉缃戝叧鐘舵��
+                        {
+                            new System.Threading.Thread(() =>
+                            {
+                                System.Threading.Thread.Sleep(3000);
+                                var pm = new DAL.Server.HttpServerRequest();
+                                pm.GetGatewayInfo();
+                            })
+                            { IsBackground = true }.Start();
+                            return;
+                        }
+                        //淇敼涓婚〉杩炴帴鐘舵��
+                        HomePage.LoadEvent_CheckLinkStatus();
+                        MainPage.Log($"缃戝叧浜戠鍦ㄧ嚎锛屽埛鏂拌澶囩姸鎬�");
+                        new System.Threading.Thread(() =>
+                        {
+                            System.Threading.Thread.Sleep(1000);
+                            FunctionList.List.ReadAllFunctionStatus();
+                        })
+                        { IsBackground = true, Priority = System.Threading.ThreadPriority.AboveNormal }.Start();
+                    }
+                    else
+                    {
+                        //淇敼涓婚〉杩炴帴鐘舵��
+                        HomePage.LoadEvent_CheckLinkStatus();
+                    }
+                }
+            }
+        }
+
+
         /// <summary>
         /// 缃戝叧閫氳ID
         /// </summary>
         public string GatewayId = "";
 
-        bool _isRemote = false;
         /// <summary>
         /// 鏄惁涓鸿繙绋嬭繛鎺�
         /// </summary>
-        public bool IsRemote
-        {
-            get
-            {
-                return _isRemote;
-            }
-            set
-            {
-                _isRemote = value;
-                //淇敼涓婚〉杩炴帴鐘舵��
-                HomePage.LoadEvent_CheckLinkStatus();
-            }
-        }
+        //public bool IsRemote = false;
         /// <summary>
         /// 閫氳鍦板潃IP
         /// </summary>
@@ -183,19 +228,23 @@
         /// </summary>
         public void SearchLoaclGateway()
         {
-            MainPage.Log($"鎼滅储鏈湴缃戝叧鍒楄〃锛岀綉鍏崇被鍨�:{DB_ResidenceData.Instance.GatewayType}");
+            //2021-01-15 : 浣忓畢娌℃湁缁戝畾缃戝叧鐨勬椂鍊欎笉鐢ㄦ悳绱紝骞朵笖涓嶈兘閾炬帴mqtt
+            if(DB_ResidenceData.Instance.HomeGateway == null)
+            {
+                return;
+            }
+            Ins.GatewayOnline_Local = false;
+            var ggg = DB_ResidenceData.Instance.GatewayType == 0 ? "涓�绔彛" : "A缃戝叧";
+            var ggg1 = MainPage.InternetStatus == 1 ? "4G" : "wifi";
+            MainPage.Log($"鎼滅储缃戝叧鍒楄〃锛岀綉鍏崇被鍨�:{ggg};缃戠粶绫诲瀷:{ggg1}");
             if (MainPage.InternetStatus == 0)
             {
-                Ins.GatewayOnline = false;
+                Ins.GatewayOnline_Cloud = false;
                 return;
             }
             else if (MainPage.InternetStatus == 1)
             {
-                if (!Ins.IsRemote)
-                {
-                    Ins.IsRemote = true;
-                    DAL.Mqtt.MqttClient.InitState();
-                }
+                DAL.Mqtt.MqttClient.InitState();
             }
             else if (MainPage.InternetStatus == 2)
             {
@@ -208,7 +257,10 @@
                     for (int i = 0; i < 5; i++)
                     {
                         if (IsSearchLocalGatewaySuccessful)
+                        {
+                            Ins.GatewayOnline_Local = true;
                             break;
+                        }
                         if (DB_ResidenceData.Instance.GatewayType == 0)
                         {
                             new Control_Udp().ControlBytesSend(Command.ReadGateway, 255, 255, new byte[] { (byte)new Random().Next(255), (byte)new Random().Next(255) });
@@ -220,17 +272,7 @@
                         System.Threading.Thread.Sleep(500);
                     }
 
-                    if (!IsSearchLocalGatewaySuccessful)
-                    {
-                        //鏈湴鎼滅储涓嶅埌缃戝叧
-                        if (!Ins.IsRemote)
-                        {
-                            //杩炴帴mqtt鍓嶏紝鍏堟柇寮�--2020-12-21
-                            DAL.Mqtt.MqttClient.DisConnectRemote();
-                            Ins.IsRemote = true;
-                            DAL.Mqtt.MqttClient.InitState();
-                        }
-                    }
+                    DAL.Mqtt.MqttClient.InitState();
                 })
                 { IsBackground = true }.Start();
             }
@@ -241,9 +283,13 @@
         /// </summary>
         public void ControlScene(Scene scene)
         {
-            if (Ins.IsRemote || DB_ResidenceData.Instance.GatewayType == 1)
+            if (!Ins.GatewayOnline_Local || DB_ResidenceData.Instance.GatewayType == 1)
             {
-                ControlAProtocolScene(scene);
+                new System.Threading.Thread(() =>
+                {
+                    ControlAProtocolScene(scene);
+                })
+                { IsBackground = true }.Start();
             }
             else
             {
@@ -261,10 +307,11 @@
         /// </summary>
         /// <param name="commandString"></param>
         /// <param name="function"></param>
+        /// <param name="useRemote">鏄惁鐩存帴浣跨敤杩滅▼鍙戦��</param>
         /// <returns></returns>
-        public void SendWriteCommand(Function function, Dictionary<string, string> commandDictionary)
+        public void SendWriteCommand(Function function, Dictionary<string, string> commandDictionary, bool useRemote = false)
         {
-            function.usageCount++;
+            function.controlCounter++;
             function.refreshTime = DateTime.Now;
 
             //濡傛灉鏄帶鍒惰皟鍏夌殑寮�鏃讹紝浜害鍊间笉鑳戒负0
@@ -289,8 +336,21 @@
                 }
             }
 
-            //杩滅▼閫氳
-            if (Ins.IsRemote)
+            MainPage.Log($"鍙戦�佹暟鎹�:{Newtonsoft.Json.JsonConvert.SerializeObject(commandDictionary)}");
+
+            ///绗笁鏂规秱楦﹁澶囩粺涓�浣跨敤杩滅▼鎺у埗
+            switch(function.spk)
+            {
+                case SPK.ElectricTuyaAirCleaner:
+                case SPK.ElectricTuyaFan:
+                case SPK.ElectricTuyaWaterValve:
+                case SPK.ElectricTuyaWeepRobot:
+                    useRemote = true;
+                    break;
+            }
+
+            //杩滅▼閫氳  --娑傞甫璁惧蹇呴』闇�瑕佽繙绋�
+            if (useRemote == true)
             {
                 DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
                 //ALink鎺у埗銆丅us鎺у埗浣跨敤鍚屼竴涓帴鍙f帶鍒讹紝鐢变簯绔礋璐hВ鏋�
@@ -298,39 +358,119 @@
                 var actionObjs = new List<ApiAlinkControlActionObj>();
                 actionObjs.Add(apiControlData);
                 var pack = httpServer.ControlDevice(actionObjs);
-                //MainPage.Log($"{pack.Code}:{pack.Data}");
             }
-            //鏈湴閫氳
             else
             {
-                //Bus鎺у埗
-                if (DB_ResidenceData.Instance.GatewayType == 0)
+                ////杩滅▼閫氳
+                //if (Ins.GatewayOnline_Local == false && Ins.GatewayOnline_Cloud == true)
+                //{
+                //    DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
+                //    //ALink鎺у埗銆丅us鎺у埗浣跨敤鍚屼竴涓帴鍙f帶鍒讹紝鐢变簯绔礋璐hВ鏋�
+                //    var apiControlData = function.GetApiControlData(commandDictionary);
+                //    var actionObjs = new List<ApiAlinkControlActionObj>();
+                //    actionObjs.Add(apiControlData);
+                //    var pack = httpServer.ControlDevice(actionObjs);
+                //}
+                //鏈湴閫氳
+                if (Ins.GatewayOnline_Local)
                 {
-                    try
+                    //Bus鎺у埗
+                    if (DB_ResidenceData.Instance.GatewayType == 0)
                     {
-                        new Control_Udp().WriteBusData(function, commandDictionary);
+                        try
+                        {
+                            new Control_Udp().WriteBusData(function, commandDictionary);
+                        }
+                        catch (Exception ex)
+                        {
+                            MainPage.Log($"鍙戦�佹暟鎹紓甯�: {ex.Message}");
+                        }
                     }
-                    catch (Exception ex)
+                    //ALink鎺у埗
+                    else
                     {
-                        MainPage.Log($"鍙戦�佹暟鎹紓甯�: {ex.Message}");
+                        var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
+                        var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
+                        var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
+                        new Control_Udp().SendLocalHdlLinkData(sendBytes, functionControlDataObj.id);
+                        MainPage.Log($"鏈湴閫氳 鍙戦�丠DL-Link鏁版嵁:{functionControlDataJson}");
                     }
                 }
-                //ALink鎺у埗
+                //杩滅▼閫氳
                 else
                 {
-                    var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
-                    var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
-                    var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
-                    new Control_Udp().SendLocalHdlLinkData(sendBytes, functionControlDataObj.id);
-                    MainPage.Log($"鍙戦�丠DL-Link鏁版嵁:{functionControlDataJson}");
+                    DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
+                    //ALink鎺у埗銆丅us鎺у埗浣跨敤鍚屼竴涓帴鍙f帶鍒讹紝鐢变簯绔礋璐hВ鏋�
+                    var apiControlData = function.GetApiControlData(commandDictionary);
+                    var actionObjs = new List<ApiAlinkControlActionObj>();
+                    actionObjs.Add(apiControlData);
+                    var pack = httpServer.ControlDevice(actionObjs);
+                }
+
+            }
+        }
+        /// <summary>
+        /// 鍏ㄥ紑鍏ㄥ叧鍔熻兘
+        /// </summary>
+        public void SwtichFunctions(bool open,List<Function> functions)
+        {
+            var count = 0;
+            var logString = open ? "鎵撳紑\r\n" : "鍏抽棴\r\n";
+            List<ApiAlinkControlActionObj> actionObjs = new List<ApiAlinkControlActionObj>();
+            Dictionary<string, string> d = new Dictionary<string, string>();
+            d.Add(FunctionAttributeKey.OnOff, open ? "on" : "off");
+            var pm = new DAL.Server.HttpServerRequest();
+            foreach (var temp in functions)
+            {
+                logString += temp.spk + ":" + temp.sid + "\r\n";
+                var apiControlData = temp.GetApiControlData(d);
+                actionObjs.Add(apiControlData);
+                count++;
+                if (count > 9)
+                {
+                    var result = pm.ControlDevice(actionObjs);
+                    actionObjs = new List<ApiAlinkControlActionObj>();
+                    count = 0;
+                    MainPage.Log(logString);
+                    logString = "";
                 }
             }
+            var pack = pm.ControlDevice(actionObjs);
+            MainPage.Log(logString);
         }
 
         public void SendApiReadCommand(List<string> functionIds)
         {
             var pm = new DAL.Server.HttpServerRequest();
             var pack = pm.RefreshDeviceStatus(functionIds);
+        }
+        /// <summary>
+        /// 璇诲彇鍔熻兘璇︾粏鏁版嵁
+        /// </summary>
+        /// <param name="functionIds"></param>
+        public void ReadFunctionsInfo(List<string> functionIds)
+        {
+            var pm = new DAL.Server.HttpServerRequest();
+            var pack = pm.GetDeviceInfoList(functionIds);
+            if(pack!= null&& pack.Data!=null)
+            {
+                //寰呮祴璇�2021-03-04
+                var ddd = Newtonsoft.Json.JsonConvert.DeserializeObject<List<AlinkStatusData>>(pack.Data.ToString());
+                if(ddd!= null)
+                {
+                    foreach(var function in ddd)
+                    {
+                        var temp = FunctionList.List.GetDeviceFunctionList().Find((obj) => obj.deviceId == function.deviceId);
+                        if(temp!= null)
+                        {
+                            if (SPK.Get3tySpk(SPK.BrandType.Tuya).Contains(temp.spk))
+                            {
+                                Stan.HdlDeviceStatuPushLogic.Current.UpdateDeviceStatu(temp.sid, function.status);
+                            }
+                        }
+                    }
+                }
+            }
         }
 
         /// <summary>
@@ -340,13 +480,9 @@
         public void SendReadCommand(Function function)
         {
             function.refreshTime = DateTime.Now;
-            if (Ins.IsRemote)
+            if (Ins.GatewayOnline_Local)
             {
-                var pm = new DAL.Server.HttpServerRequest();
-                var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId });
-            }
-            else
-            {
+
                 if (DB_ResidenceData.Instance.GatewayType == 0)
                 {
                     try
@@ -374,26 +510,16 @@
                     };
                     var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
                     var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
-                    MainPage.Log($"鍙戦�丠DL-Link鏁版嵁:{functionControlDataJson}");
+                    MainPage.Log($"鏈湴閫氳 鍙戦�丠DL-Link鏁版嵁:{functionControlDataJson}");
                     new Control_Udp().SendLocalHdlLinkData(sendBytes, readDataObj.id);
                 }
             }
+            else
+            {
+                var pm = new DAL.Server.HttpServerRequest();
+                var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId });
+            }
         }
-        ///// <summary>
-        ///// 鍙戦�丄鍗忚璇诲彇鍛戒护
-        ///// </summary>
-        //public void SendReadCommand(List<Dictionary<string, string>> keyValuePairs)
-        //{
-        //    var readDataObj = new GatewayAlinkReadObj()
-        //    {
-        //        id = Ins.msg_id.ToString(),
-        //        objects = keyValuePairs,
-        //        time_stamp = Utlis.GetTimestamp()
-        //    };
-        //    var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
-        //    var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
-        //    Ins.myUdp.SendLocalHdlLinkData(sendBytes);
-        //}
 
         /// <summary>
         /// a鍗忚鎺у埗鍦烘櫙
@@ -401,10 +527,10 @@
         /// <param name="scene"></param>
         static void ControlAProtocolScene(Scene scene)
         {
-            if (Ins.IsRemote)
+            if (!Ins.GatewayOnline_Local)//缃戝叧鏈湴涓嶅湪绾�
             {
-                var pm = new HDL_ON.DAL.Server.HttpServerRequest();
-                pm.ExecuteScene(scene.userSceneId);
+                var pm = new DAL.Server.HttpServerRequest();
+                var result = pm.ExecuteScene(scene.userSceneId);
             }
             else
             {
@@ -476,8 +602,8 @@
                     }
                 }
 
-                MainPage.Log($"time 1 :{receiveObj.Topic}");
-
+                MainPage.Log($"灞�鍩熺綉淇℃伅: {receiveObj.Topic}");
+                MainPage.Log($"鍐呭: {res[1]}");
 
                 //楠岃瘉鏈夋晥鏁版嵁闀垮害
                 //if (res[1].Length != receiveObj.Length)
@@ -487,19 +613,19 @@
                 //}
                 receiveObj.BodyDataString = res[1];
 
-                var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
-                if (bodyJObj == null)
-                {
-                    return receiveObj;
-                }
                 if (receiveObj.Topic == CommunicationTopic.SearchLoaclGatewayReply)
                 {
+                    var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
+                    if (bodyJObj == null)
+                    {
+                        return receiveObj;
+                    }
                     var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
                     if (device.device_mac == DB_ResidenceData.Instance.residenceGatewayMAC)
                     {
-                        //鏈湴鎼滅储缃戝叧鎴愬姛
-                        Control.Ins.IsSearchLocalGatewaySuccessful = true;
-                        Ins.GatewayOnline = true;
+                        MainPage.Log("鏈湴鎼滅储缃戝叧鎴愬姛");
+                        Ins.IsSearchLocalGatewaySuccessful = true;
+                        Ins.GatewayOnline_Local = true;
                         if (!string.IsNullOrEmpty(device.gatewayId))
                         {
                             Ins.GatewayId = device.gatewayId;
@@ -509,7 +635,6 @@
                             Ins.GatewayId = device.device_mac;
                         }
                         reportIp = "239.0.168.188";// device.ip_address;
-                        Ins.IsRemote = false;
                     }
                 }
                 else if (receiveObj.Topic == CommunicationTopic.ct.ReadStatus + "_reply" ||
@@ -518,6 +643,11 @@
                 {
                     //TODO 鏆傛椂涓嶄紶姝g‘鐨勬暟鎹笂鍘伙紝濡傛灉鍚庨潰瑕佷紭鍖栧墠闈㈣繖浜涗唬鐮�
                     UpdataFunctionStatus(receiveObj.BodyDataString, null);
+                }
+                else
+                {
+                    //涓�浜涚壒娈婄殑涓婚澶勭悊(涓轰簡鎵ц閫熷害,灏藉彲鑳界殑鍒姞鑰楁椂鐨勬搷浣�)
+                    Stan.HdlCloudReceiveLogic.Current.CloudOverallMsgReceiveEx(receiveObj.Topic, receiveObj.BodyDataString);
                 }
             }
             return receiveObj;
@@ -528,9 +658,17 @@
         /// A鍗忚鏁版嵁
         /// </summary>
         /// <param name="updateBytes"></param>
-        public void UpdataFunctionStatus(string revString, byte[] usefulBytes)
+        public void UpdataFunctionStatus(string revString, byte[] usefulBytes,bool isCloudData = false)
         {
-            MainPage.Log($"A鍗忚鏇存柊鐘舵��:{revString}");
+
+            if (Ins.GatewayOnline_Local && isCloudData)//鏈湴閾炬帴锛岄櫎浜嗘秱楦﹁澶囨暟鎹箣澶栫殑浜戠鏁版嵁涓嶅鐞�
+            {
+                if (FunctionList.List.GetDeviceFunctionList(SPK.BrandType.Tuya).Count == 0)
+                {
+                    //MainPage.Log($"A鍗忚鏇存柊鐘舵��:鏈湴閾炬帴锛岄櫎浜嗘秱楦﹁澶囨暟鎹箣澶栫殑浜戠鏁版嵁涓嶅鐞�...");
+                    return;
+                }
+            }
             var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<AlinkFunctionStatusObj>(revString);
             if (temp != null)
             {
@@ -540,18 +678,23 @@
                 {
                     try
                     {
-                        //bool hadChange = false;//鐘舵�佹湁鍙樺寲鍐嶆洿鏂扮晫闈�
                         var localFunction = allLocalFuntion.Find((obj) => obj.sid == updateTemp.sid);
+                        if (Ins.GatewayOnline_Local && isCloudData)//鏈湴閾炬帴锛岄櫎浜嗘秱楦﹁澶囨暟鎹箣澶栫殑浜戠鏁版嵁涓嶅鐞�
+                        {
+                            if(!SPK.Get3tySpk(SPK.BrandType.All3tyBrand).Contains(localFunction.spk))
+                            {
+                                //MainPage.Log($"A鍗忚鏇存柊鐘舵��:鏈湴閾炬帴锛岄櫎浜嗘秱楦﹁澶囨暟鎹箣澶栫殑浜戠鏁版嵁涓嶅鐞�........");
+                                return;
+                            }
+                        }
+                        //MainPage.Log($"A鍗忚鏇存柊鐘舵��:{revString}");
+                        foreach (var attr in updateTemp.status)
+                        {
+                            localFunction.SetAttrState(attr.key,attr.value);
+                        }
+
                         if (localFunction != null)
                         {
-                            //var updateInfoString = $"鏇存柊璁惧:{localFunction.name}";
-                            //foreach (var attr in updateTemp.status)
-                            //{
-                            //    updateInfoString += $"  key:{attr.key};value:{attr.value}";
-                            //}
-                            //MainPage.Log(updateInfoString);
-
-
                             //鏇存柊鐣岄潰鐘舵��
                             Function localObj = null;
                             switch (localFunction.spk)
@@ -569,7 +712,6 @@
                                                 localAttr.curValue = attr.value;
                                             }
                                         }
-                                        //rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
                                         RelayPage.UpdataState(localSwitch);
                                     }
                                     break;
@@ -710,7 +852,7 @@
                                             }
                                         }
                                         ac.lastState = "";
-                                        switch (ac.trait_mode.curValue.ToString())
+                                        switch (ac.GetAttrState(FunctionAttributeKey.Mode))
                                         {
                                             case "cool":
                                                 ac.lastState = Language.StringByID(StringId.Cool);
@@ -728,7 +870,7 @@
                                                 ac.lastState = Language.StringByID(StringId.AirSupply);
                                                 break;
                                         }
-                                        switch (ac.trait_fan.curValue.ToString())
+                                        switch (ac.GetAttrState(FunctionAttributeKey.FanSpeed))
                                         {
                                             case "high":
                                                 ac.lastState += " " + Language.StringByID(StringId.HighWindSpeed);
@@ -743,7 +885,7 @@
                                                 ac.lastState += " " + Language.StringByID(StringId.Auto);
                                                 break;
                                         }
-                                        ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString;
+                                        ac.lastState += " " + ac.GetAttrState(FunctionAttributeKey.SetTemp) + ac.tempUnitString;
                                         ACPage.UpdataStates(ac);
                                     }
                                     break;
@@ -819,14 +961,28 @@
                                     }
                                     break;
                                 case SPK.ElectricTV:
-                                    break;
-                                default:
+                                    break;
+                                case SPK.ElectricTuyaAirCleaner:
+                                case SPK.ElectricTuyaFan:
+                                case SPK.ElectricTuyaWeepRobot:
+                                case SPK.ElectricTuyaWaterValve:
+                                case SPK.SensorPir:
+                                case SPK.SensorDoorWindow:
+                                case SPK.SensorSmoke:
+                                case SPK.SensorWater:
+                                case SPK.ClothesHanger:
+                                case SPK.IrAC:
+                                    //璁惧鐘舵�佹帹閫�
+                                    Stan.HdlDeviceStatuPushLogic.Current.UpdateDeviceStatu(updateTemp.sid,updateTemp.status);
                                     break;
                             }
-                            HomePage.UpdataFunctionStates(localObj);
-                            RoomPage.UpdataStates(localObj);
-                            FunctionPage.UpdataStates(localObj);
-                            ClassificationPage.UpdataInfo(localObj);
+                            if (localObj != null)
+                            {
+                                HomePage.UpdataFunctionStates(localObj);
+                                RoomPage.UpdataStates(localObj);
+                                FunctionPage.UpdataStates(localObj);
+                                ClassificationPage.UpdataInfo(localObj);
+                            }
                         }
                     }
                     catch (Exception ex)

--
Gitblit v1.8.0