备份

xm

2020-07-10 acb2b278663952ce555b06a2e821f359225f15e0

 ZigbeeApp/Shared/Phone/ZigBee/Device/FreshAir.cs

New file
@@ -0,0 +1,231 @@
using System;
using Newtonsoft.Json.Linq;

namespace ZigBee.Device
{
    [System.Serializable]
    public class FreshAir : CommonDevice
    {
        /// <summary>
        /// 该类（新风对象）包含新风设备和新风面板 
        /// </summary>
        public FreshAir()
        {
            this.Type = DeviceType.FreshAir;
        }

        /// <summary>
        /// 风速模式 
        /// <para>5:自动</para>
        /// <para>6:Smart</para>
        /// <para>15:手动</para> 
        /// </summary>
        [Newtonsoft.Json.JsonIgnore]
        public int currentFanMode = 0;
        /// <summary>
        /// 风速档位 
        /// <para>1:低风</para>
        /// <para>2:中风</para>
        /// <para>3:高风 </para> 
        /// </summary>
        [Newtonsoft.Json.JsonIgnore]
        public int currentFanSpeed = 0;
        /// <summary>
        /// 风扇状态
        /// <para>0:关闭 </para> 
        /// <para>4:打开 </para> 
        /// </summary>
        [Newtonsoft.Json.JsonIgnore]
        public int currentFanStatus = 0;

        /// <summary>
        /// 关闭
        /// </summary>
        /// <returns>The close.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> Close()
        {
            return await SetFanModeAsync(FanMode.Off);
        }

        /// <summary>
        /// 开启
        /// </summary>
        /// <returns>The open.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> Open()
        {
            return await SetFanModeAsync(FanMode.On);
        }

        /// <summary>
        /// 高风
        /// </summary>
        /// <returns>The close.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetHighSpeed()
        {
            return await SetFanModeAsync(FanMode.High);
        }

        /// <summary>
        /// 低风
        /// </summary>
        /// <returns>The open.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetLowSpeed()
        {
            return await SetFanModeAsync(FanMode.Low);
        }


        /// <summary>
        /// 手动
        /// </summary>
        /// <returns>The close.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetManual()
        {
            return await SetFanModeAsync(FanMode.Manual);
        }

        /// <summary>
        /// 自动
        /// </summary>
        /// <returns>The open.</returns>
        public async System.Threading.Tasks.Task<SetWritableValueResponAllData> SetAuto()
        {
            return await SetFanModeAsync(FanMode.Auto);
        }

        ///<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;
            });
        }


        #region ◆ 当前新风开关状态____________________

        /// <summary>
        /// 当前新风开关状态
        /// </summary>
        /// <param name="freshAir"></param>
        /// <returns></returns>
        public bool IsOpen(FreshAir freshAir)
        {
            if (freshAir.currentFanStatus == 4)
            {
                return true;
            }
            return false;
        }

        #endregion


        /// <summary>
        /// 风速档位
        /// </summary>
        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>
            /// Smart
            /// </summary>
            Smart = 6,
            /// <summary>
            /// 手动
            /// </summary>
            Manual = 15,
        }

    }
}