| | |
| | | using System.Collections.Generic; |
| | | using System.Text; |
| | | using HDL_ON.Entity; |
| | | using HDL_ON.UI; |
| | | using Shared; |
| | | |
| | | namespace HDL_ON.DriverLayer |
| | | { |
| | |
| | | } |
| | | set |
| | | { |
| | | _gatewayOnline = value; |
| | | //修改主页连接状态 |
| | | UI.HomePage.LoadEvent_CheckLinkStatus(); |
| | | FunctionList.List.ReadAllFunctionStatus(); |
| | | if (_gatewayOnline != value) |
| | | { |
| | | _gatewayOnline = value; |
| | | //修改主页连接状态 |
| | | UI.HomePage.LoadEvent_CheckLinkStatus(); |
| | | if (value) |
| | | { |
| | | MainPage.Log($"网关在线,刷新设备状态"); |
| | | FunctionList.List.ReadAllFunctionStatus(); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | /// <summary> |
| | |
| | | set |
| | | { |
| | | _isRemote = value; |
| | | if(value) |
| | | { |
| | | DAL.Mqtt.MqttClient.InitState(); |
| | | }else |
| | | { |
| | | DAL.Mqtt.MqttClient.DisConnectRemote(); |
| | | } |
| | | //修改主页连接状态 |
| | | HomePage.LoadEvent_CheckLinkStatus(); |
| | | } |
| | | } |
| | | /// <summary> |
| | |
| | | } |
| | | }) |
| | | { IsBackground = true }.Start(); |
| | | if (!GatewayOnline)//网关不在线的时候才可尝试远程连接 |
| | | { |
| | | Ins.IsRemote = true; |
| | | DAL.Mqtt.MqttClient.InitState(); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | function.refreshTime = DateTime.Now; |
| | | DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest(); |
| | | //远程通讯 |
| | | if (Ins.IsRemote || true) |
| | | if (Ins.IsRemote) |
| | | { |
| | | //ALink控制、Bus控制使用同一个接口控制,由云端负责解析 |
| | | var apiControlData = function.GetApiControlData(commandDictionary); |
| | |
| | | function.refreshTime = DateTime.Now; |
| | | if (Ins.IsRemote) |
| | | { |
| | | |
| | | var pm = new DAL.Server.HttpServerRequest(); |
| | | var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId}); |
| | | } |
| | | else |
| | | { |
| | | if (function.bus_Data != null) |
| | | if (DB_ResidenceData.residenceData.GatewayType == 0) |
| | | { |
| | | try |
| | | { |
| | |
| | | var readKey = new Dictionary<string, string>(); |
| | | readKey.Add("sid", function.sid); |
| | | |
| | | var readDataObj = new GatewayAlinkReadObj() |
| | | var readDataObj = new AlinkReadFunctionStatusObj() |
| | | { |
| | | id = Ins.msg_id.ToString(), |
| | | objects = new List<Dictionary<string, string>>() |
| | | { |
| | | readKey |
| | | }, |
| | | //time_stamp = |
| | | time_stamp = Utlis.GetTimestamp() |
| | | }; |
| | | var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj); |
| | | var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson); |
| | |
| | | } |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// 发送A协议读取命令 |
| | | /// </summary> |
| | | public void SendReadCommand(List<Dictionary<string, string>> keyValuePairs) |
| | | { |
| | | var readDataObj = new GatewayAlinkReadObj() |
| | | { |
| | | id = Ins.msg_id.ToString(), |
| | | objects = keyValuePairs, |
| | | //time_stamp = |
| | | }; |
| | | var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj); |
| | | var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson); |
| | | Ins.myUdp.SendLocalHdlLinkData(sendBytes); |
| | | } |
| | | ///// <summary> |
| | | ///// 发送A协议读取命令 |
| | | ///// </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协议场景 |
| | |
| | | { |
| | | return receiveObj; |
| | | } |
| | | switch (receiveObj.Topic) |
| | | if (receiveObj.Topic == CommunicationTopic.SearchLoaclGatewayReply) |
| | | { |
| | | case CommunicationTopic.SearchLoaclGatewayReply: |
| | | var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString()); |
| | | if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC) |
| | | var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString()); |
| | | if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC) |
| | | { |
| | | Ins.GatewayOnline = true; |
| | | if(!string.IsNullOrEmpty( device.gatewayId)) |
| | | { |
| | | Ins.GatewayOnline = true; |
| | | Ins.GatewayId = device.gatewayId; |
| | | reportIp = "239.0.168.188";// device.ip_address; |
| | | Ins.IsRemote = false; |
| | | } |
| | | break; |
| | | else |
| | | { |
| | | Ins.GatewayId = device.device_mac; |
| | | } |
| | | reportIp = "239.0.168.188";// device.ip_address; |
| | | Ins.IsRemote = false; |
| | | } |
| | | } |
| | | else if(receiveObj.Topic == CommunicationTopic.ct.ReadStatus+"_reply" || |
| | | receiveObj.Topic == CommunicationTopic.ct.GatewayUpStatus) |
| | | { |
| | | UpdataFunctionStatus(receiveObj.BodyDataString); |
| | | } |
| | | } |
| | | return receiveObj; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 更新设备状态 |
| | | /// A协议数据 |
| | | /// </summary> |
| | | /// <param name="updateBytes"></param> |
| | | public void UpdataFunctionStatus(string revString) |
| | | { |
| | | MainPage.Log($"A协议更新状态:{revString}"); |
| | | var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<AlinkFunctionStatusObj>(revString); |
| | | if (temp != null) |
| | | { |
| | | var allLocalFuntion = FunctionList.List.GetAllDeviceFunctionList(); |
| | | foreach (var updateTemp in temp.objects) |
| | | { |
| | | try |
| | | { |
| | | bool hadChange = false;//状态有变化再更新界面 |
| | | var updataObj = allLocalFuntion.Find((obj) => obj.sid == updateTemp.sid); |
| | | if (updataObj != 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; |
| | | } |
| | | } |
| | | } |
| | | if (!hadChange)//状态有变化再更新界面 |
| | | { |
| | | continue; |
| | | } |
| | | //更新界面状态 |
| | | switch (updataObj.spk) |
| | | { |
| | | case SPK.LightSwitch: |
| | | RelayPage.UpdataState(updataObj as Light); |
| | | break; |
| | | case SPK.LightDimming: |
| | | var dimming = updataObj as Light; |
| | | 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); |
| | | break; |
| | | case SPK.LightRGB: |
| | | var rgb = updataObj as Light; |
| | | rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%"; |
| | | RGBPage.UpdataStates(rgb); |
| | | break; |
| | | case SPK.LightRGBW: |
| | | case SPK.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); |
| | | break; |
| | | case SPK.CurtainTrietex: |
| | | var trietex = updataObj as Curtain; |
| | | 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); |
| | | break; |
| | | case SPK.CurtainShades: |
| | | break; |
| | | case SPK.AcStandard: |
| | | var ac = updataObj as AC; |
| | | 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); |
| | | break; |
| | | case SPK.FloorHeatStandard: |
| | | var fh = updataObj as FloorHeating; |
| | | 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); |
| | | 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); |
| | | break; |
| | | case SPK.ElectricSocket: |
| | | break; |
| | | case SPK.ElectricTV: |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | HomePage.UpdataFunctionStates(updataObj); |
| | | RoomPage.UpdataStates(updataObj); |
| | | FunctionPage.UpdataStates(updataObj); |
| | | ClassificationPage.UpdataInfo(updataObj); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | MainPage.Log($"A协议更新状态异常:{ex.Message}"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |