From d07d62be7111d78b2aaa44c9cdee23a7d22b4dda Mon Sep 17 00:00:00 2001
From: wei <kaede@kaededeMacBook-Air.local>
Date: 星期二, 22 十二月 2020 10:38:15 +0800
Subject: [PATCH] 20201222-1

---
 HDL_ON/DAL/DriverLayer/Control.cs |  486 ++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 345 insertions(+), 141 deletions(-)

diff --git a/HDL_ON/DAL/DriverLayer/Control.cs b/HDL_ON/DAL/DriverLayer/Control.cs
index 13996e8..8e434c9 100644
--- a/HDL_ON/DAL/DriverLayer/Control.cs
+++ b/HDL_ON/DAL/DriverLayer/Control.cs
@@ -25,6 +25,8 @@
 
     public class Control
     {
+       
+
         static Control _control;
         public static Control Ins
         {
@@ -58,11 +60,20 @@
             return t.ToString();
         }
 
+        /// <summary>
+        /// 鏄惁鎼滅储鏈湴缃戝叧鎴愬姛
+        /// </summary>
+        public bool IsSearchLocalGatewaySuccessful = false;
+      
+        /// <summary>
+        /// 
+        /// </summary>
         bool _gatewayOnline = false;
         /// <summary>
         /// 缃戝叧鏄惁鍦ㄧ嚎
         /// </summary>
-        public bool GatewayOnline {
+        public bool GatewayOnline
+        {
             get
             {
                 return _gatewayOnline;
@@ -90,13 +101,14 @@
         /// <summary>
         /// 缃戝叧閫氳ID
         /// </summary>
-        public string GatewayId ="";
+        public string GatewayId = "";
 
         bool _isRemote = false;
         /// <summary>
         /// 鏄惁涓鸿繙绋嬭繛鎺�
         /// </summary>
-        public bool IsRemote {
+        public bool IsRemote
+        {
             get
             {
                 return _isRemote;
@@ -166,42 +178,61 @@
             }
         }
 
-        ///// <summary>
-        ///// 鏀瑰彉閫氳鏂瑰紡
-        ///// </summary>
-        //public void ChangeCommunicationMode(CommunicationMode communicationMode)
-        //{
-        //    this.communicationMode = communicationMode;
-        //}
-
         /// <summary>
         /// 鎼滅储鏈湴缃戝叧鍒楄〃
         /// </summary>
         public void SearchLoaclGateway()
         {
-            OpenUdp(DB_ResidenceData.Instance.GatewayType == 0 ? 6000 : 8585);
-            new System.Threading.Thread(() =>
+            MainPage.Log($"鎼滅储鏈湴缃戝叧鍒楄〃锛岀綉鍏崇被鍨�:{DB_ResidenceData.Instance.GatewayType}");
+            if (MainPage.InternetStatus == 0)
             {
-                for (int i = 0; i < 5; i++)
+                Ins.GatewayOnline = false;
+                return;
+            }
+            else if (MainPage.InternetStatus == 1)
+            {
+                if (!Ins.IsRemote)
                 {
-                    if (GatewayOnline)
-                        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) });
-                    }
-                    else if (DB_ResidenceData.Instance.GatewayType == 1)
-                    {
-                        new Control_Udp().SearchLocalGateway();
-                    }
-                    System.Threading.Thread.Sleep(500);
+                    Ins.IsRemote = true;
+                    DAL.Mqtt.MqttClient.InitState();
                 }
-            })
-            { IsBackground = true }.Start();
-            if (!GatewayOnline)//缃戝叧涓嶅湪绾跨殑鏃跺�欐墠鍙皾璇曡繙绋嬭繛鎺�
+            }
+            else if (MainPage.InternetStatus == 2)
             {
-                Ins.IsRemote = true;
-                DAL.Mqtt.MqttClient.InitState();
+                OpenUdp(DB_ResidenceData.Instance.GatewayType == 0 ? 6000 : 8585);
+                //閲嶇疆鎼滅储缃戝叧鏍囧織
+                IsSearchLocalGatewaySuccessful = false;
+
+                new System.Threading.Thread(() =>
+                {
+                    for (int i = 0; i < 5; i++)
+                    {
+                        if (IsSearchLocalGatewaySuccessful)
+                            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) });
+                        }
+                        else if (DB_ResidenceData.Instance.GatewayType == 1)
+                        {
+                            new Control_Udp().SearchLocalGateway();
+                        }
+                        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();
+                        }
+                    }
+                })
+                { IsBackground = true }.Start();
             }
         }
 
@@ -235,10 +266,33 @@
         {
             function.usageCount++;
             function.refreshTime = DateTime.Now;
-            DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
+
+            //濡傛灉鏄帶鍒惰皟鍏夌殑寮�鏃讹紝浜害鍊间笉鑳戒负0
+            if (commandDictionary.Count > 2)
+            {
+                if (commandDictionary.ContainsKey(FunctionAttributeKey.OnOff) && commandDictionary.ContainsKey(FunctionAttributeKey.Brightness))
+                {
+                    if (commandDictionary[FunctionAttributeKey.OnOff] == "on")
+                    {
+                        if (commandDictionary[FunctionAttributeKey.Brightness] == "0")
+                        {
+                            commandDictionary[FunctionAttributeKey.Brightness] = "100";
+                        }
+                    }
+                    if (commandDictionary[FunctionAttributeKey.OnOff] == "off")
+                    {
+                        if (commandDictionary[FunctionAttributeKey.Brightness] != "0")
+                        {
+                            commandDictionary[FunctionAttributeKey.Brightness] = "0";
+                        }
+                    }
+                }
+            }
+
             //杩滅▼閫氳
             if (Ins.IsRemote)
             {
+                DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
                 //ALink鎺у埗銆丅us鎺у埗浣跨敤鍚屼竴涓帴鍙f帶鍒讹紝鐢变簯绔礋璐hВ鏋�
                 var apiControlData = function.GetApiControlData(commandDictionary);
                 var actionObjs = new List<ApiAlinkControlActionObj>();
@@ -268,6 +322,7 @@
                     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}");
                 }
             }
         }
@@ -288,7 +343,7 @@
             if (Ins.IsRemote)
             {
                 var pm = new DAL.Server.HttpServerRequest();
-                var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId});
+                var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId });
             }
             else
             {
@@ -319,7 +374,8 @@
                     };
                     var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
                     var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
-                    new Control_Udp().SendLocalHdlLinkData(sendBytes,readDataObj.id);
+                    MainPage.Log($"鍙戦�丠DL-Link鏁版嵁:{functionControlDataJson}");
+                    new Control_Udp().SendLocalHdlLinkData(sendBytes, readDataObj.id);
                 }
             }
         }
@@ -365,7 +421,7 @@
                 };
                 var aLinkJson = Newtonsoft.Json.JsonConvert.SerializeObject(aLinkData);
                 var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlScene, aLinkJson);
-                new Control_Udp().SendLocalHdlLinkData(sendBytes,aLinkData.id);
+                new Control_Udp().SendLocalHdlLinkData(sendBytes, aLinkData.id);
             }
         }
         /// <summary>
@@ -379,7 +435,7 @@
 
             string sendDataString = topicString + lengthString + bodyDataString;
             byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
-            MainPage.Log($"杞崲HDL-Link鏁版嵁\r\n{sendDataString}\r\n");
+            //MainPage.Log($"杞崲HDL-Link鏁版嵁\r\n{sendDataString}\r\n");
 
             return sendDataBytes;
         }
@@ -419,6 +475,10 @@
                             break;
                     }
                 }
+
+                MainPage.Log($"time 1 :{receiveObj.Topic}");
+
+
                 //楠岃瘉鏈夋晥鏁版嵁闀垮害
                 //if (res[1].Length != receiveObj.Length)
                 //{
@@ -437,8 +497,10 @@
                     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;
-                        if(!string.IsNullOrEmpty( device.gatewayId))
+                        if (!string.IsNullOrEmpty(device.gatewayId))
                         {
                             Ins.GatewayId = device.gatewayId;
                         }
@@ -450,11 +512,12 @@
                         Ins.IsRemote = false;
                     }
                 }
-                else if(receiveObj.Topic == CommunicationTopic.ct.ReadStatus+"_reply" ||
+                else if (receiveObj.Topic == CommunicationTopic.ct.ReadStatus + "_reply" ||
+                    receiveObj.Topic == CommunicationTopic.ct.ControlFunctionTopic + "_reply" ||
                     receiveObj.Topic == CommunicationTopic.ct.GatewayUpStatus)
                 {
                     //TODO 鏆傛椂涓嶄紶姝g‘鐨勬暟鎹笂鍘伙紝濡傛灉鍚庨潰瑕佷紭鍖栧墠闈㈣繖浜涗唬鐮�
-                    UpdataFunctionStatus(receiveObj.BodyDataString,null);
+                    UpdataFunctionStatus(receiveObj.BodyDataString, null);
                 }
             }
             return receiveObj;
@@ -465,164 +528,305 @@
         /// A鍗忚鏁版嵁
         /// </summary>
         /// <param name="updateBytes"></param>
-        public void UpdataFunctionStatus(string revString,byte []usefulBytes)
+        public void UpdataFunctionStatus(string revString, byte[] usefulBytes)
         {
             MainPage.Log($"A鍗忚鏇存柊鐘舵��:{revString}");
             var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<AlinkFunctionStatusObj>(revString);
             if (temp != null)
             {
-                Control_Udp.ReceiveRepeatManager(temp.id,usefulBytes);
+                Control_Udp.ReceiveRepeatManager(temp.id, usefulBytes);
                 var allLocalFuntion = FunctionList.List.GetDeviceFunctionList();
                 foreach (var updateTemp in temp.objects)
                 {
                     try
                     {
                         //bool hadChange = false;//鐘舵�佹湁鍙樺寲鍐嶆洿鏂扮晫闈�
-                        var updataObj = allLocalFuntion.Find((obj) => obj.sid == updateTemp.sid);
-                        if (updataObj != null)
+                        var localFunction = allLocalFuntion.Find((obj) => obj.sid == updateTemp.sid);
+                        if (localFunction != null)
                         {
-                            foreach (var attr in updateTemp.status)
-                            {
-                                foreach (var locatAttr in updataObj.attributes)
-                                {
-                                    if (attr.key == locatAttr.key)
-                                    {
-                                        if (locatAttr.curValue.ToString() == attr.value)
-                                        {
-                                            continue;
-                                        }
-                                        locatAttr.curValue = attr.value;
-                                        //hadChange = true;
-                                    }
-                                }
-                            }
-                            //2020-12-13 濡傛灉鎺у埗鏃讹紝绔嬪嵆鏇存柊鐣岄潰鍗崇姸鎬侊紝鏀跺埌鏁版嵁涓嶇敤鍦ㄥ鐞嗭紝鐩墠鍙慨鏀硅澶囩姸鎬侊紝鐣岄潰娌℃湁鏇存柊锛岃繕鏄渶瑕佹帴鏀舵暟鎹洿鏂�
-                            //if (!hadChange)//鐘舵�佹湁鍙樺寲鍐嶆洿鏂扮晫闈�
+                            //var updateInfoString = $"鏇存柊璁惧:{localFunction.name}";
+                            //foreach (var attr in updateTemp.status)
                             //{
-                            //    continue;
+                            //    updateInfoString += $"  key:{attr.key};value:{attr.value}";
                             //}
+                            //MainPage.Log(updateInfoString);
+
+
                             //鏇存柊鐣岄潰鐘舵��
-                            switch (updataObj.spk)
+                            Function localObj = null;
+                            switch (localFunction.spk)
                             {
                                 case SPK.LightSwitch:
-                                    RelayPage.UpdataState(updataObj as Light);
+                                    var localSwitch = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (localSwitch != null)
+                                    {
+                                        localObj = localSwitch;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = localSwitch.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        //rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
+                                        RelayPage.UpdataState(localSwitch);
+                                    }
                                     break;
                                 case SPK.LightDimming:
-                                    var dimming = updataObj as Light;
-                                    dimming.lastState = Language.StringByID(StringId.Brightness) + " : " + dimming.brightness + "%";
-                                    DimmerPage.UpdataStates(dimming);
+                                    var dimming = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (dimming != null)
+                                    {
+                                        localObj = dimming;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = dimming.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        dimming.lastState = Language.StringByID(StringId.Brightness) + " : " + dimming.brightness + "%";
+                                        DimmerPage.UpdataStates(dimming);
+                                    }
                                     break;
                                 case SPK.ElectricFan:
-                                    var fan = updataObj as Fan;
-                                    fan.lastState = Language.StringByID(StringId.Level) + " : " + fan.openLevel;
-                                    FanPage.UpdataState(fan);
+                                    var fan = FunctionList.List.fans.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (fan != null)
+                                    {
+                                        localObj = fan;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = fan.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        fan.lastState = Language.StringByID(StringId.Level) + " : " + fan.openLevel;
+                                        FanPage.UpdataState(fan);
+                                    }
                                     break;
                                 case SPK.LightRGB:
-                                    var rgb = updataObj as Light;
-                                    rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
-                                    RGBPage.UpdataStates(rgb);
+                                    var rgb = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (rgb != null)
+                                    {
+                                        localObj = rgb;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = rgb.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
+                                        RGBPage.UpdataStates(rgb);
+                                    }
                                     break;
                                 case SPK.LightRGBW:
-                                case SPK.LightCCT:
+                                    break;
+                                case SPK.LightCCT:
+                                    var lightCCT = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (lightCCT != null)
+                                    {
+                                        localObj = lightCCT;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = lightCCT.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        lightCCT.lastState = Language.StringByID(StringId.Brightness) + " : " + lightCCT.brightness + "%";
+                                        ColorTureLampPage.UpdataStates(lightCCT);
+                                    }
                                     break;
                                 case SPK.CurtainSwitch:
-                                    var curtain = updataObj as Curtain;
-                                    curtain.lastState = curtain.trait_on_off.curValue.ToString() == "on" ? Language.StringByID(StringId.Open) : Language.StringByID(StringId.Close);
-                                    CurtainModulePage.UpdataState(curtain);
+                                    var curtain = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (curtain != null)
+                                    {
+                                        localObj = curtain;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = curtain.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        curtain.lastState = curtain.trait_on_off.curValue.ToString() == "on" ? Language.StringByID(StringId.Open) : Language.StringByID(StringId.Close);
+                                        CurtainModulePage.UpdataState(curtain);
+                                    }
                                     break;
                                 case SPK.CurtainTrietex:
-                                    var trietex = updataObj as Curtain;
-                                    trietex.lastState = Language.StringByID(StringId.Open) + trietex.percent + "%";
-                                    MotorCurtainPage.UpdataState(trietex);
+                                    var trietex = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (trietex != null)
+                                    {
+                                        localObj = trietex;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = trietex.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        trietex.lastState = Language.StringByID(StringId.Open) + trietex.percent + "%";
+                                        MotorCurtainPage.UpdataState(trietex);
+                                    }
                                     break;
                                 case SPK.CurtainRoller:
-                                    var roller = updataObj as Curtain;
-                                    roller.lastState = Language.StringByID(StringId.Open) + roller.percent + "%";
-                                    RollingShutterPage.UpdataState(roller);
+                                    var roller = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (roller != null)
+                                    {
+                                        localObj = roller;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = roller.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        roller.lastState = Language.StringByID(StringId.Open) + roller.percent + "%";
+                                        RollingShutterPage.UpdataState(roller);
+                                    }
                                     break;
                                 case SPK.CurtainShades:
                                     break;
                                 case SPK.AcStandard:
-                                    var ac = updataObj as AC;
-                                    ac.lastState = "";
-                                    switch (ac.trait_mode.curValue.ToString())
+                                    var ac = FunctionList.List.aCs.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (ac != null)
                                     {
-                                        case "cool":
-                                            ac.lastState = Language.StringByID(StringId.Cool);
-                                            break;
-                                        case "heat":
-                                            ac.lastState = Language.StringByID(StringId.Heat);
-                                            break;
-                                        case "dry":
-                                            ac.lastState = Language.StringByID(StringId.Dry);
-                                            break;
-                                        case "auto":
-                                            ac.lastState = Language.StringByID(StringId.Auto);
-                                            break;
-                                        case "fan":
-                                            ac.lastState = Language.StringByID(StringId.AirSupply);
-                                            break;
+                                        localObj = ac;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = ac.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        ac.lastState = "";
+                                        switch (ac.trait_mode.curValue.ToString())
+                                        {
+                                            case "cool":
+                                                ac.lastState = Language.StringByID(StringId.Cool);
+                                                break;
+                                            case "heat":
+                                                ac.lastState = Language.StringByID(StringId.Heat);
+                                                break;
+                                            case "dry":
+                                                ac.lastState = Language.StringByID(StringId.Dry);
+                                                break;
+                                            case "auto":
+                                                ac.lastState = Language.StringByID(StringId.Auto);
+                                                break;
+                                            case "fan":
+                                                ac.lastState = Language.StringByID(StringId.AirSupply);
+                                                break;
+                                        }
+                                        switch (ac.trait_fan.curValue.ToString())
+                                        {
+                                            case "high":
+                                                ac.lastState += " " + Language.StringByID(StringId.HighWindSpeed);
+                                                break;
+                                            case "medium":
+                                                ac.lastState += " " + Language.StringByID(StringId.MiddleWindSpeed);
+                                                break;
+                                            case "low":
+                                                ac.lastState += " " + Language.StringByID(StringId.LowWindSpeed);
+                                                break;
+                                            case "auto":
+                                                ac.lastState += " " + Language.StringByID(StringId.Auto);
+                                                break;
+                                        }
+                                        ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString;
+                                        ACPage.UpdataStates(ac);
                                     }
-                                    switch (ac.trait_fan.curValue.ToString())
-                                    {
-                                        case "high":
-                                            ac.lastState += " " + Language.StringByID(StringId.HighWindSpeed);
-                                            break;
-                                        case "medium":
-                                            ac.lastState += " " + Language.StringByID(StringId.MiddleWindSpeed);
-                                            break;
-                                        case "low":
-                                            ac.lastState += " " + Language.StringByID(StringId.LowWindSpeed);
-                                            break;
-                                        case "auto":
-                                            ac.lastState += " " + Language.StringByID(StringId.Auto);
-                                            break;
-                                    }
-                                    ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString;
-                                    ACPage.UpdataStates(ac);
                                     break;
                                 case SPK.FloorHeatStandard:
-                                    var fh = updataObj as FloorHeating;
-                                    switch (fh.trait_mode.curValue)
+                                    var fh = FunctionList.List.floorHeatings.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (fh != null)
                                     {
-                                        case "normal":
-                                            fh.lastState = Language.StringByID(StringId.Normal);
-                                            break;
-                                        case "day":
-                                            fh.lastState = Language.StringByID(StringId.Day);
-                                            break;
-                                        case "night":
-                                            fh.lastState = Language.StringByID(StringId.Night);
-                                            break;
-                                        case "timer":
-                                            fh.lastState = Language.StringByID(StringId.Auto);
-                                            break;
-                                        case "away":
-                                            fh.lastState = Language.StringByID(StringId.Away);
-                                            break;
+                                        localObj = fh;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = fh.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        switch (fh.trait_mode.curValue)
+                                        {
+                                            case "normal":
+                                                fh.lastState = Language.StringByID(StringId.Normal);
+                                                break;
+                                            case "day":
+                                                fh.lastState = Language.StringByID(StringId.Day);
+                                                break;
+                                            case "night":
+                                                fh.lastState = Language.StringByID(StringId.Night);
+                                                break;
+                                            case "timer":
+                                                fh.lastState = Language.StringByID(StringId.Auto);
+                                                break;
+                                            case "away":
+                                                fh.lastState = Language.StringByID(StringId.Away);
+                                                break;
+                                        }
+                                        fh.lastState += " " + fh.trait_temp.curValue + fh.tempUnitString;
+                                        FloorHeatingPage.UpdataStates(fh);
                                     }
-                                    fh.lastState += " " + fh.trait_temp.curValue + fh.tempUnitString;
-                                    FloorHeatingPage.UpdataStates(fh);
                                     break;
                                 case SPK.SensorPm25:
                                 case SPK.SensorCO2:
                                 case SPK.SensorTVOC:
                                 case SPK.SensorTemperature:
                                 case SPK.SensorHumidity:
-                                    var sensor = updataObj as Sensor;
-                                    EnvironmentalSciencePage.LoadEvent_UpdataStatus(sensor);
+                                    var sensor = FunctionList.List.sensorsEnvironmentalScience.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (sensor != null)
+                                    {
+                                        localObj = sensor;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = sensor.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        EnvironmentalSciencePage.LoadEvent_UpdataStatus(sensor);
+                                    }
                                     break;
                                 case SPK.ElectricSocket:
+                                    var es = FunctionList.List.switchSockets.Find((obj) => obj.sid == updateTemp.sid);
+                                    if (es != null)
+                                    {
+                                        localObj = es;
+                                        foreach (var attr in updateTemp.status)
+                                        {
+                                            var localAttr = es.attributes.Find((obj) => obj.key == attr.key);
+                                            if (localAttr != null)
+                                            {
+                                                localAttr.curValue = attr.value;
+                                            }
+                                        }
+                                        SocketPage.UpdataState(es);
+                                    }
                                     break;
                                 case SPK.ElectricTV:
                                     break;
                                 default:
                                     break;
                             }
-                            HomePage.UpdataFunctionStates(updataObj);
-                            RoomPage.UpdataStates(updataObj);
-                            FunctionPage.UpdataStates(updataObj);
-                            ClassificationPage.UpdataInfo(updataObj);
+                            HomePage.UpdataFunctionStates(localObj);
+                            RoomPage.UpdataStates(localObj);
+                            FunctionPage.UpdataStates(localObj);
+                            ClassificationPage.UpdataInfo(localObj);
                         }
                     }
                     catch (Exception ex)

--
Gitblit v1.8.0