修改引用路径

chenqiyang

2022-06-22 dc0309e64f02227d8e1468b7326c07955f804612

 ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlDeviceAttributeLogic.cs

old mode 100755
new mode 100644
@@ -1,194 +1,638 @@
using Shared.Common;

using System;

using System.Collections.Generic;

using System.Text;

using ZigBee.Device;



namespace Shared.Phone.UserCenter

{

    /// <summary>

    /// 设备属性上报的逻辑类

    /// </summary>

    public class HdlDeviceAttributeLogic : ZigBee.Common.IStatus

    {

        #region ■ 变量声明___________________________



        /// <summary>

        /// 属性上报的逻辑

using Shared.Common;
using System;
using System.Collections.Generic;
using System.Text;
using ZigBee.Device;

namespace Shared.Phone.UserCenter
{
    /// <summary>
    /// 设备属性的逻辑类
    /// </summary>
    public class HdlDeviceAttributeLogic
    {
        #region ■ 变量声明___________________________

        /// <summary>
        /// 属性的逻辑
        /// </summary>
        private static HdlDeviceAttributeLogic m_Current = null;

        /// <summary>

        /// 属性上报的逻辑

        private static HdlDeviceAttributeLogic m_Current = null;
        /// <summary>
        /// 属性的逻辑
        /// </summary>
        public static HdlDeviceAttributeLogic Current

        {

            get

            {

                if (m_Current == null)

                {

                    m_Current = new HdlDeviceAttributeLogic();

                }

                return m_Current;

            }

            set

            {

                m_Current = value;

            }

        }



        /// <summary>

        /// 事件集合

        /// </summary>

        private Dictionary<string, Action<CommonDevice>> dicEvent = new Dictionary<string, Action<CommonDevice>>();

        /// <summary>

        /// 命令区分

        /// </summary>

        private Dictionary<string, string> dicCommandDiv = new Dictionary<string, string>();



        #endregion



        #region ■ 添加事件___________________________



        /// <summary>

        /// 添加获取设备属性的事件(属性上报的对象：device.DeviceStatusReport)

        /// </summary>

        /// <param name="mainKeys">标识事件的主键(可以随便填,主要是针对多个界面一起使用的情况)</param>

        /// <param name="comand">命令区分,比如：DeviceStatusReport,IASInfoReport等等</param>

        /// <param name="action">当接收到网关回复之后的回调函数,属性上报的对象：device.DeviceStatusReport</param>

        public void AddAttributeEvent(string mainKeys, string comand, Action<CommonDevice> action)

        {

            lock (this.dicEvent)

            {

                if (this.dicEvent.Count == 0)

                {

                    ZbGateway.StatusList.Add(this);

                }

                this.dicEvent[mainKeys] = action;

                this.dicCommandDiv[mainKeys] = comand;

            }

        }



        #endregion



        #region ■ 移除监听___________________________



        /// <summary>

        /// 移除事件

        /// </summary>

        /// <param name="mainKeys">标识事件的主键(可以随便填,主要是针对多个界面一起使用的情况)</param>

        public void RemoveEvent(string mainKeys)

        {

            lock (this.dicEvent)

            {

                if (this.dicEvent.ContainsKey(mainKeys) == true)

                {

                    var action = this.dicEvent[mainKeys];

                    this.dicEvent.Remove(mainKeys);

                    this.dicCommandDiv.Remove(mainKeys);



                    action = null;

                }

                if (this.dicEvent.Count == 0)

                {

                    ZbGateway.StatusList.Remove(this);

                }

            }

        }



        /// <summary>

        /// 移除全部的事件

        /// </summary>

        public void RemoveAllEvent()

        {

            lock (this.dicEvent)

            {

                var list = new HashSet<string>();

                foreach (var keys in this.dicEvent.Keys)

                {

                    list.Add(keys);

                }

                foreach (var keys in list)

                {

                    //需要慢慢一个一个的释放Action,听说

                    this.RemoveEvent(keys);

                }

            }

        }



        #endregion



        #region ■ 实现接口___________________________



        /// <summary>

        /// 设备状态通知

        /// </summary>

        /// <param name="common"></param>

        /// <param name="typeTag"></param>

        public void DeviceInfoChange(CommonDevice common, string typeTag)

        {

            if (common == null || string.IsNullOrEmpty(common.DeviceAddr) == true)

            {

                //我也不知道这有没有可能

                return;

            }



            lock (this.dicEvent)

            {

                var list = new List<Action<CommonDevice>>();

                foreach (string keys in this.dicEvent.Keys)

                {

                    if (this.dicCommandDiv[keys] != typeTag)

                    {

                        //命令区分不一致，则不调用回调函数

                        continue;

                    }

                    //命令区分一致时，则调用回调函数

                    list.Add(this.dicEvent[keys]);

                }

                //有可能在回调函数中移除了事件，导致报错，所以先收集，再调用

                foreach (var action in list)

                {

                    action(common);

                }

                list.Clear();

            }

        }



        /// <summary>

        /// 不使用

        /// </summary>

        /// <param name="common"></param>

        public void Changed(CommonDevice common)

        {

        }



        /// <summary>

        /// 不使用

        /// </summary>

        public void ChangedILogicStatus(ZigBee.Device.Logic logic)

        {

        }



        /// <summary>

        /// 不使用

        /// </summary>

        public void ChangedISceneStatus(Scene scene)

        {

        }

        #endregion



        #region ■ 一般方法___________________________



        /// <summary>

        /// 是否存在指定的事件

        /// </summary>

        /// <param name="mainkeys"></param>

        /// <returns></returns>

        public bool IsEsixt(string mainkeys)

        {

            return this.dicCommandDiv.ContainsKey(mainkeys);

        }



        #endregion

    }

}

        public static HdlDeviceAttributeLogic Current
        {
            get
            {
                if (m_Current == null)
                {
                    m_Current = new HdlDeviceAttributeLogic();
                }
                return m_Current;
            }
            set
            {
                m_Current = value;
            }
        }

        #endregion

        #region ■ 写入设备属性_______________________

        /// <summary>
        /// 获取更改设备私有属性的命令
        /// </summary>
        /// <param name="clusterId"></param>
        /// <param name="attributeId"></param>
        /// <param name="attributeDataType"></param>
        /// <param name="attributeData"></param>
        /// <returns></returns>
        public string GetWriteDeviceAttributeText(string DeviceAddr, int DeviceEpoint, int clusterId, int attributeId, int attributeDataType, object attributeData)
        {
            var jObject = new Newtonsoft.Json.Linq.JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", clusterId }, { "Command", 120 } };
            Newtonsoft.Json.Linq.JObject data = null;
            if (attributeData is int)
            {
                data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", Convert.ToInt32(attributeData) } };
            }
            else
            {
                data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", attributeData.ToString() } };
            }
            jObject.Add("Data", data);

            return jObject.ToString();
        }

        #endregion

        #region ■ 空调_______________________________

        /// <summary>
        /// SendACStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        public void SendACStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendFanStatuComand(device);
                System.Threading.Thread.Sleep(300);
                SendThermostatStatuComand(device);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// SendThermostatStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        public void SendThermostatStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.Thermostat },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.LocalTemperature}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.CoolingSetpoint}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.HeatingSetpoint}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.AutoSetpoint}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.SystemMode}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.AcModeSupport}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.CleanStatu}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        /// <summary>
        /// SendFanStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        private void SendFanStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.FanControl },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.FanMode}
               },
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.FanSwing}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
        }

        #endregion

        #region ■ 新风_______________________________
        /// <summary>
        /// SendFreshAirStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        public void SendFreshAirStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendFreshAirFanStatuComand(device);
                System.Threading.Thread.Sleep(300);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// SendFanStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        private void SendFreshAirFanStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.FanControl },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.FanMode}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
        }

        #endregion

        #region ■ PM2.5_______________________________
        /// <summary>
        /// SendPmSensorComand
        /// </summary>
        /// <param name="device">设备</param>
        public void SendPmSensorComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendPm2P5Comand(device);
                //读取Pm2.5传感器的温度数据
                HdlDeviceAttributeLogic.Current.SendTemperatureStatuComand(device);
                //读取Pm2.5传感器的湿度数据
                HdlDeviceAttributeLogic.Current.SendHumidityStatuComand(device);
                System.Threading.Thread.Sleep(300);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// SendFanStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        private void SendPm2P5Comand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.PmTwoPointFiveMeasurement  },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.MeasuredValue}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
        }

        #endregion

        #region ■ 空气质量传感器_______________________________
        /// <summary>
        /// SendAirQualitySensorComand
        /// </summary>
        /// <param name="device">设备</param>
        public void SendAirQualitySensorComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendSwitchStatuComand(device);
                //空气质量传感器的PM2.5数据
                SendPm2P5Comand(device);
                //空气质量传感器的CO2数据[2021.01.13产品要求暂时去掉]
                //SendCO2Comand(device);
                //空气质量传感器的温度数据
                HdlDeviceAttributeLogic.Current.SendTemperatureStatuComand(device);
                //空气质量传感器的湿度数据
                HdlDeviceAttributeLogic.Current.SendHumidityStatuComand(device);
                System.Threading.Thread.Sleep(300);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// SendCO2Comand
        /// </summary>
        /// <param name="device">设备</param>
        private void SendCO2Comand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.CO2},
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.MeasuredValue}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
        }

        #endregion

        #region ■ 晾衣架_______________________________
        /// <summary>
        /// SendAirerComand
        ///回路2:读取照明开关状态
        ///回路3:读取风干开关状态和时间值 
        ///回路4:读取烘干开关状态和时间值
        ///回路5:读取消毒开关状态和时间值
        /// </summary>
        /// <param name="device">设备</param>
        /// <param name="ctrlEpoint">控制端点</param>
        public void SendAirerComand(CommonDevice device, int ctrlEpoint)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendAirerStatuComand(device, ctrlEpoint);
                System.Threading.Thread.Sleep(300);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// SendAirerStatuComand
        /// </summary>
        /// <param name="device">设备</param>
        private void SendAirerStatuComand(CommonDevice device, int ctrlEpoint = 1)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", ctrlEpoint },
                { "Cluster_ID", (int)Cluster_ID.Switch},
                { "Command", 108 }
            };
            Newtonsoft.Json.Linq.JArray attriBute = new Newtonsoft.Json.Linq.JArray();

            //晾衣架的晾衣架的（烘干，风干，消毒,照明状态读取）
            attriBute = new Newtonsoft.Json.Linq.JArray
             {
                new Newtonsoft.Json.Linq.JObject
               {
                    //晾衣架的照明开关状态
                 { "AttriButeId", (int)AttriButeId.Switch}
               }
             };

            //if (device.DeviceEpoint != 2)
            //{
            //由于设备不支持时间功能，后期才支持，注意处理时间要根据烘干，风干，消毒是否开才发送相应大时间读取数据
            //attriBute = new Newtonsoft.Json.Linq.JArray {
            //        new Newtonsoft.Json.Linq.JObject
            //       {
            //            //晾衣架的开关状态（烘干，风干，消毒）
            //         { "AttriButeId", (int)AttriButeId.Switch}
            //       },
            //           new Newtonsoft.Json.Linq.JObject
            //       {
            //            //晾衣架的晾衣架的（烘干，风干，消毒）剩余时间
            //         { "AttriButeId", (int)AttriButeId.AirerRemainTime}
            //       },
            //       new Newtonsoft.Json.Linq.JObject
            //       {
            //           //晾衣架的（烘干，风干，消毒）时间
            //         { "AttriButeId", (int)AttriButeId.AirerTime}
            //       }
            //    };
            //}
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
        }

        #endregion

        #region ■ 窗帘_______________________________
        /// <summary>
        /// 发送获取窗帘状态命令
        /// </summary>
        /// <param name="device">窗帘</param>
        public void SendCurtainStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.WindowCovering },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.CurrentPositionLiftPercentage}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        #endregion

        #region ■ 灯光_______________________________

        /// <summary>
        /// Light
        /// </summary>
        /// <param name="device"></param>
        public void SendLightStatuComand(CommonDevice device)
        {
            SendSwitchStatuComand(device);
        }

        /// <summary>
        /// Light
        /// </summary>
        /// <param name="device"></param>
        public void SendDimmableLightStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            new System.Threading.Thread(() =>
            {
                SendSwitchStatuComand(device);
                System.Threading.Thread.Sleep(300);
                SendLevelStatuComand(device);
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// 发送获取灯光状态命令
        /// </summary>
        /// <param name="device">窗帘</param>
        private void SendSwitchStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.Switch },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.Switch}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        /// <summary>
        /// 发送获取灯光状态命令
        /// </summary>
        /// <param name="device">窗帘</param>
        public void SendLevelStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.LevelControl },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.LevelControl}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        #endregion

        #region ■ 色温灯_____________________________

        /// <summary>
        /// 发送获取色温灯状态命令
        /// </summary>
        /// <param name="device"></param>
        public void SendColorTemperatureLightStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var colorDevice = (ColorTemperatureLight)device;
            new System.Threading.Thread(() =>
            {
                colorDevice.ReadOnOffStatus();
                System.Threading.Thread.Sleep(300);
                colorDevice.ReadLevel();
                System.Threading.Thread.Sleep(300);
                colorDevice.ReadColorTemperature();
                if (LocalDevice.Current.IsMiniLight(device) == true)
                {
                    //mini夜灯需要读取蜂鸣器状态
                    System.Threading.Thread.Sleep(300);
                    colorDevice.ReadBuzzerStatu();
                }
            })
            { IsBackground = true }.Start();
        }

        #endregion

        #region ■ 温湿度_____________________________

        /// <summary>
        /// 读取温度
        /// </summary>
        /// <param name="device"></param>
        public void SendTemperatureStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.TemperatureMeasurement },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.MeasuredValue}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        /// <summary>
        /// 读取湿度
        /// </summary>
        /// <param name="device"></param>
        public void SendHumidityStatuComand(CommonDevice device)
        {
            if (device == null)
            {
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject
            {
                { "DeviceAddr",device.DeviceAddr },
                { "Epoint", device.DeviceEpoint },
                { "Cluster_ID", (int)Cluster_ID.RelativeHumidityMeasurement },
                { "Command", 108 }
            };
            var attriBute = new Newtonsoft.Json.Linq.JArray
            {
               new Newtonsoft.Json.Linq.JObject
               {
                 { "AttriButeId", (int)AttriButeId.MeasuredValue}
               }
            };
            var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
            jObject.Add("Data", data);
            device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
        }

        #endregion
    }
}