New file |
| | |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using Newtonsoft.Json.Linq; |
| | | namespace ZigBee.Device |
| | | { |
| | | [System.Serializable] |
| | | public class AC : CommonDevice |
| | | { |
| | | public AC() |
| | | { |
| | | this.Type = DeviceType.Thermostat; |
| | | } |
| | | |
| | | /// <summary> |
| | | ///当前室内温度 |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentLocalTemperature = 0; |
| | | /// <summary> |
| | | /// 当前加热度数 |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentHeatingSetpoint = 0; |
| | | /// <summary> |
| | | /// 当前制冷度数 |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentCoolingSetpoint = 0; |
| | | /// <summary> |
| | | /// 当前自动温度 |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentAutoSetpoint; |
| | | /// <summary> |
| | | /// 恒温设备当前模式 |
| | | /// <para>恒温设备具备功能,SystemMode Attribute Values如下</para> |
| | | /// <para>0:Off </para> |
| | | /// <para>1:Auto </para> |
| | | /// <para>3:Cool </para> |
| | | /// <para>4:Heat </para> |
| | | /// <para>5:Emergency heating </para> |
| | | /// <para>6:Precooling</para> |
| | | /// <para>7:Fan only </para> |
| | | /// <para>8:Dry </para> |
| | | /// <para>9:Sleep</para> |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentSystemMode = 0; |
| | | /// <summary> |
| | | /// 风扇当前模式 |
| | | /// <para>0:Off </para> |
| | | /// <para>1:Low </para> |
| | | /// <para>2:Medium</para> |
| | | /// <para>3:High </para> |
| | | /// <para>4:On </para> |
| | | /// <para>5:Auto </para> |
| | | /// <para>6:Smart</para> |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentFanMode = 0; |
| | | /// <summary> |
| | | /// 风扇zz扫风当前模式 |
| | | /// <para>0:1挡 </para> |
| | | /// <para>1:2</para> |
| | | /// <para>2:3</para> |
| | | /// <para>3:4 </para> |
| | | /// <para>4:5 </para> |
| | | /// <para>7:Auto </para> |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public int currentFanSwingMode = 0; |
| | | /// <summary> |
| | | /// <para>自定义空调支持的模式(默认全开)</para>
|
| | | /// <para>数组索引 -> 0:制冷 1:制热 2:送风 3:除湿 4:自动</para>
|
| | | /// <para>值 -> 1:代表使用 0:代表不使用</para>
|
| | | /// </summary> |
| | | public int[] listSupportMode = new int[5] { 1, 1, 1, 1, 1 }; |
| | | /// <summary>
|
| | | /// 是否启用摆风功能 false:不使用摆风功能 true:使用摆风功能
|
| | | /// </summary> |
| | | public bool UseSwingFunction = true; |
| | | /// <summary>
|
| | | /// 空调模块版本
|
| | | /// </summary> |
| | | public string AcModelVersion = string.Empty; |
| | | /// <summary> |
| | | /// 过滤网清洗状态 |
| | | /// </summary> |
| | | [Newtonsoft.Json.JsonIgnore] |
| | | public bool CleanStatu = false; |
| | | |
| | | /// <summary> |
| | | /// 获取当前室内温度. |
| | | /// <para>AttriButeId=0 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadLocalTemperature() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.LocalTemperature); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取当前制冷度数. |
| | | /// <para>AttriButeId=17 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadCoolingSetpoint() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.CoolingSetpoint); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取当前加热度数. |
| | | /// <para>AttriButeId=18 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadHeatingSetpoint() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.HeatingSetpoint); |
| | | } |
| | | |
| | | |
| | | /// <summary> |
| | | /// 获取当前自动度数. |
| | | /// <para>AttriButeId=18 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadAutoSetpoint() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.AutoSetpoint); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取恒温设备类型(******测试设备返回的AttriBute属性是空) |
| | | /// <para>AttriButeId=27 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadControlSequenceOfOperation() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.ControlSequenceOfOperation); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取恒温设备当前工作模式 |
| | | /// <para>AttriButeId=28 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadSystemMode() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.SystemMode); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取风扇模式。 |
| | | /// <para>AttriButeId=0 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadFanMode() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.FanControl, AttriButeId.FanMode); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取风扇拥有的工作模式种类. |
| | | /// <para>AttriButeId=1 (先调用发现属性接口,查看设备是否支持该接口的属性)</para> |
| | | /// </summary> |
| | | public void ReadFanModeSequence() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.FanControl, AttriButeId.FanModeSequence); |
| | | } |
| | | |
| | | /// <summary>
|
| | | /// 获取空调自定义设置的支持模式
|
| | | /// </summary> |
| | | public void ReadModeSupport()
|
| | | {
|
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.AcModeSupport);
|
| | | } |
| | | |
| | | /// <summary> |
| | | /// 过滤网清洗状态 |
| | | /// </summary> |
| | | public void ReadCleanStatu() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.Thermostat, AttriButeId.CleanStatu); |
| | | }
|
| | |
|
| | | /// <summary> |
| | | /// 获取是否启用空调摆风模式的状态(打开 或者 关闭) |
| | | /// </summary> |
| | | public void ReadUseSwingFunctionStatu() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.FanControl, AttriButeId.UseAcSwingFunctionStatu); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 扫风模式 |
| | | /// </summary> |
| | | public enum FanSwingMode |
| | | { |
| | | /// <summary> |
| | | /// 一档 |
| | | /// </summary> |
| | | First = 0, |
| | | /// <summary> |
| | | /// 二挡 |
| | | /// </summary> |
| | | Second = 1, |
| | | /// <summary> |
| | | /// 三挡 |
| | | /// </summary> |
| | | Thrid = 2, |
| | | /// <summary> |
| | | /// 四挡 |
| | | /// </summary> |
| | | Fourth = 3, |
| | | /// <summary> |
| | | /// 五档 |
| | | /// </summary> |
| | | Fifth = 4, |
| | | /// <summary> |
| | | /// 自动 |
| | | /// </summary> |
| | | Auto = 7 |
| | | } |
| | | /// <summary> |
| | | /// 获取扫风模式 |
| | | /// </summary> |
| | | public void ReadSystemFansSwingMode() |
| | | { |
| | | ReadAttri(Device.Cluster_ID.FanSwing, AttriButeId.FanSwing); |
| | | } |
| | | /// <summary> |
| | | /// 设置扫风模式 |
| | | /// </summary> |
| | | /// <param name="fanSwing"></param> |
| | | /// <returns></returns> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetFanSwingAsyncMode(FanSwingMode fanSwing) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 514 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 4096 }, { "AttributeDataType", 48 }, { "AttributeData", (int)fanSwing } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | |
| | | ///<summary > |
| | | ///设置制冷度数. |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetCoolingTemperatureAsync(int temperature) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 513 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 17 }, { "AttributeDataType", 41 }, { "AttributeData", (int)temperature } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | ///<summary > |
| | | ///设置制热度数. |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetHeatingTemperatureAsync(int temperature) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 513 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 18 }, { "AttributeDataType", 41 }, { "AttributeData", (int)temperature } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | ///<summary > |
| | | ///设置自动度数. |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetAutoTemperatureAsync(int temperature) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 513 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 4096 }, { "AttributeDataType", 41 }, { "AttributeData", (int)temperature } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | ///<summary > |
| | | ///设置恒温器设备当前工作模式. |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetSystemModeAsync(AcMode acMode) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 513 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 28 }, { "AttributeDataType", 48 }, { "AttributeData", (int)acMode } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | public enum AcMode |
| | | { |
| | | /// <summary> |
| | | /// 关闭模式(测试恒温面板时发现:2,5,6,7,8,9都是可以打开的) |
| | | /// </summary> |
| | | Off = 0, |
| | | /// <summary> |
| | | /// 自动模式 |
| | | /// </summary> |
| | | Auto = 1, |
| | | /// <summary> |
| | | /// 制冷模式 |
| | | /// </summary> |
| | | Cool = 3, |
| | | /// <summary> |
| | | /// 制热模式 |
| | | /// </summary> |
| | | Heat = 4, |
| | | /// <summary> |
| | | /// 紧急制热模式 |
| | | /// </summary> |
| | | EmergencyHeating = 5, |
| | | /// <summary> |
| | | /// 预冷模式 |
| | | /// </summary> |
| | | Precooling = 6, |
| | | /// <summary> |
| | | /// 只有风速模式 |
| | | /// </summary> |
| | | FanOnly = 7, |
| | | /// <summary> |
| | | /// 干燥模式 |
| | | /// </summary> |
| | | Dry = 8, |
| | | /// <summary> |
| | | /// 睡眠模式 |
| | | /// </summary> |
| | | Sleep = 9 |
| | | } |
| | | |
| | | ///<summary > |
| | | ///设置恒温器设备当前风速. |
| | | /// </summary> |
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetFanModeAsync(FanMode fanMode) |
| | | { |
| | | if (Gateway == null) |
| | | { |
| | | return null; |
| | | } |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | SetWritableValueResponAllData 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 temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (temp == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关错误回复,且数据是空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) }; |
| | | } |
| | | } |
| | | |
| | | if (topic == gatewayID + "/" + "SetWritableValue_Respon") |
| | | { |
| | | var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetWritableValueResponData>(jobject["Data"].ToString()); |
| | | |
| | | if (tempData == null) |
| | | { |
| | | d = new SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" }; |
| | | } |
| | | else |
| | | { |
| | | d = new SetWritableValueResponAllData { setWritableValueResponData = tempData }; |
| | | DebugPrintLog($"UI收到通知后的主题_{ topic}"); |
| | | } |
| | | } |
| | | }; |
| | | Gateway.Actions += action; |
| | | DebugPrintLog("SetWritableValue_Actions 启动" + "_" + System.DateTime.Now.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 514 }, { "Command", 120 } }; |
| | | var data = new JObject { { "Undivided", 0 }, { "AttributeId", 0 }, { "AttributeDataType", 48 }, { "AttributeData", (int)fanMode } }; |
| | | jObject.Add("Data", data); |
| | | Gateway.Send("SetWritableValue", 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 SetWritableValueResponAllData { errorMessageBase = " 回复超时,请重新操作" }; |
| | | } |
| | | Gateway.Actions -= action; |
| | | DebugPrintLog("SetWritableValue_Actions 退出" + System.DateTime.Now.ToString()); |
| | | return d; |
| | | }); |
| | | } |
| | | |
| | | public enum FanMode |
| | | { |
| | | /// <summary> |
| | | /// 关闭风速 |
| | | /// </summary> |
| | | Off = 0, |
| | | /// <summary> |
| | | /// 低风 |
| | | /// </summary> |
| | | Low = 1, |
| | | /// <summary> |
| | | /// 中风 |
| | | /// </summary> |
| | | Medium = 2, |
| | | /// <summary> |
| | | /// 高风 |
| | | /// </summary> |
| | | High = 3, |
| | | /// <summary> |
| | | /// 打开风速 |
| | | /// </summary> |
| | | On = 4, |
| | | /// <summary> |
| | | /// 自动 |
| | | /// </summary> |
| | | Auto = 5, |
| | | /// <summary> |
| | | /// 聪明fe |
| | | /// </summary> |
| | | Smart = 6, |
| | | } |
| | | |
| | | ///<summary > |
| | | ///设置恒温设备加热或制冷度数(没有测试成功) |
| | | /// <para>mode要调节的模式 0:加热;1:制冷;2:自动调节</para> |
| | | ///<para>temperature:要变化的度数,单位:0.1℃</para> |
| | | /// </summary> |
| | | public void SetTemperature(int mode, int temperature) |
| | | { |
| | | var jObject = new JObject { |
| | | { "DeviceAddr", DeviceAddr}, |
| | | { "Epoint", DeviceEpoint}, |
| | | { "Cluster_ID",513}, |
| | | { "Command", 0}, |
| | | { "SendMode", 2 } |
| | | }; |
| | | var data = new JObject { |
| | | { "Mode", mode }, |
| | | { "Amount", temperature } |
| | | }; |
| | | jObject.Add("Data", data); |
| | | Gateway?.Send("DeviceControl", jObject.ToString()); |
| | | }
|
| | |
|
| | | /// <summary>
|
| | | /// 关闭
|
| | | /// </summary>
|
| | | /// <returns>The close.</returns>
|
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> Close()
|
| | | {
|
| | | return await SetSystemModeAsync(AcMode.Off);
|
| | | }
|
| | |
|
| | | /// <summary>
|
| | | /// 开启
|
| | | /// </summary>
|
| | | /// <returns>The open.</returns>
|
| | | /// <param name="acMode">Ac mode.</param>
|
| | | public async System.Threading.Tasks.Task<SetWritableValueResponAllData> Open(AcMode acMode = AcMode.Cool)
|
| | | {
|
| | | return await SetSystemModeAsync(acMode);
|
| | | } |
| | | } |
| | | } |