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>
|
/// 属性上报的逻辑
|
/// </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]);
|
}
|
//有可能在回调函数中移除了事件，导致报错，所以先收集，再调用
|
Application.RunOnMainThread(() =>
|
{
|
foreach (var action in list)
|
{
|
try
|
{
|
action?.Invoke(common);
|
}
|
catch (Exception ex)
|
{
|
//Log出力
|
string msg = "当前激活的界面[" + UserCenterResourse.NowActionFormID + "]";
|
HdlLogLogic.Current.WriteLog(-1, msg);
|
HdlLogLogic.Current.WriteLog(ex);
|
}
|
|
}
|
});
|
}
|
}
|
|
/// <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
|
|
#region ■ 写入设备属性_______________________
|
|
/// <summary>
|
/// 设置空调的自定义模式
|
/// </summary>
|
/// <param name="device">设备对象</param>
|
/// <param name="clusterId">镞ID</param>
|
/// <param name="attributeId">属性ID</param>
|
/// <param name="attributeDataType">数据类型</param>
|
/// <param name="attributeData">需要写入的数据</param>
|
/// <returns></returns>
|
public async System.Threading.Tasks.Task<CommonDevice.SetWritableValueResponAllData> WriteDeviceAttribute(CommonDevice device, int clusterId, int attributeId, int attributeDataType, int attributeData)
|
{
|
var MyGateway = device.Gateway;
|
if (MyGateway == null)
|
{
|
return null;
|
}
|
|
CommonDevice.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<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
|
if (temp == null)
|
{
|
d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = "网关错误回复，且数据是空" };
|
}
|
else
|
{
|
d = new CommonDevice.SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = HdlCheckLogic.Current.CheckCommonErrorCode(temp.Error) };
|
}
|
}
|
|
if (topic == gatewayID + "/" + "SetWritableValue_Respon")
|
{
|
var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.SetWritableValueResponData>(jobject["Data"].ToString());
|
if (tempData == null)
|
{
|
d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" };
|
}
|
else
|
{
|
d = new CommonDevice.SetWritableValueResponAllData { setWritableValueResponData = tempData };
|
}
|
}
|
};
|
MyGateway.Actions += action;
|
try
|
{
|
var jObject = new Newtonsoft.Json.Linq.JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", device.DeviceEpoint }, { "Cluster_ID", clusterId }, { "Command", 120 } };
|
var data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", attributeData } };
|
jObject.Add("Data", data);
|
MyGateway.Send("SetWritableValue", jObject.ToString());
|
}
|
catch { }
|
|
var timeOut = 0;
|
while (timeOut <= 30)
|
{
|
await System.Threading.Tasks.Task.Delay(100);
|
if (d != null)
|
{
|
break;
|
}
|
timeOut++;
|
}
|
if (timeOut > 30 && d == null)
|
{
|
d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = " 回复超时，请重新操作" };
|
}
|
MyGateway.Actions -= action;
|
return d;
|
}
|
|
#endregion
|
}
|
}
|
