using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using Newtonsoft.Json.Linq;
|
|
namespace ZigBee.Device
|
{
|
public class TemperatureSensor : CommonDevice
|
{
|
public TemperatureSensor()
|
{
|
this.Type = DeviceType.TemperatureSensor;
|
}
|
|
/// <summary>
|
/// 因为这两个东西共用同一个设备ID，所以 1：温度传感器 2:湿度传感器
|
/// </summary>
|
public int SensorDiv = 1;
|
|
/// <summary>
|
/// 温度
|
/// </summary>
|
public decimal currentTemperature = 0;
|
/// <summary>
|
/// 湿度
|
/// </summary>
|
public decimal currentHumidity = 0;
|
/// <summary>
|
/// 当前PM2.5值
|
/// </summary>
|
public decimal currentPmData = 0;
|
/// <summary>
|
/// 当前CO2
|
/// </summary>
|
public decimal currentCO2 = 0;
|
/// <summary>
|
/// 开光状态:0=关,1=开,
|
/// </summary>
|
[Newtonsoft.Json.JsonIgnore]
|
public int OnOffStatus = 0;
|
/// <summary>
|
/// 空气质量传感器时间失效列表
|
/// key:序号，value：LedTimeData
|
/// </summary>
|
[Newtonsoft.Json.JsonIgnore]
|
public Dictionary<int, LedTimeData> AirQualitySensorLedTimeList = new Dictionary<int, LedTimeData> { };
|
|
#region 开关
|
///<summary >
|
///开关控制(仅用于cluster=6的设备）
|
/// <para>设备支持cluster=6的设备才能调用该接口</para>
|
/// <para>command的值</para>
|
///<para>0 : 关闭</para>
|
///<para>1: 打开</para>
|
///<para>2：取反</para>
|
/// </summary>
|
public void SwitchControl(int command)
|
{
|
try
|
{
|
var jobject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", 6 }, { "Command", command }, { "SendMode", 2 } };
|
Gateway?.Send(("DeviceControl"), jobject.ToString());
|
System.Console.WriteLine("SwitchControl_发送数据" + "_" + jobject.ToString() + "_" + System.DateTime.Now.ToString());
|
}
|
catch { }
|
}
|
|
/// <summary>
|
/// 发送获取灯光状态命令
|
/// </summary>
|
/// <param name="device">窗帘</param>
|
public void SendSwitchStatuComand()
|
{
|
var jObject = new Newtonsoft.Json.Linq.JObject
|
{
|
{ "DeviceAddr",DeviceAddr },
|
{ "Epoint",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);
|
Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
|
}
|
#endregion
|
|
/// <summary>
|
/// 读取温/湿度
|
/// </summary>
|
public void ReadTemperatureOrHumidity()
|
{
|
if (SensorDiv == 1)
|
{
|
ReadAttri(Device.Cluster_ID.TemperatureMeasurement, AttriButeId.MeasuredValue);
|
}
|
else if (SensorDiv == 2)
|
{
|
ReadAttri(Device.Cluster_ID.RelativeHumidityMeasurement, AttriButeId.MeasuredValue);
|
}
|
}
|
|
/// <summary>
|
/// 空气质量等级(1:优；2:良；3：污染）
|
/// </summary>
|
/// <param name="tempera"></param>
|
/// <returns></returns>
|
public int AirQuality(TemperatureSensor tempera)
|
{
|
//空气质量
|
int curQuality = 0;
|
//pm等级(1:优；2:良；3：轻度污染；4:重度污染；）
|
int pmQuality = 0;
|
//co2等级(1:优（清晰）；2:良（浑浊）；3：轻度污染（缺氧）；4:重度污染（严重缺氧）；）
|
int co2Quality = 0;
|
//温度
|
string temperature = string.Empty;
|
//湿度
|
string humidity = string.Empty;
|
//PM2.5
|
string pm = string.Empty;
|
//CO2
|
string co2 = string.Empty;
|
|
if (tempera.currentPmData <= 35 && tempera.currentPmData >= 0)
|
{
|
pmQuality = 1;
|
}
|
else if (tempera.currentPmData <= 75 && tempera.currentPmData > 35)
|
{
|
pmQuality = 2;
|
}
|
else if (tempera.currentPmData <= 115 && tempera.currentPmData > 75)
|
{
|
pmQuality = 3;
|
}
|
else if (tempera.currentPmData > 115)
|
{
|
pmQuality = 4;
|
}
|
else
|
{
|
pmQuality = 0;
|
}
|
|
if (tempera.currentCO2 <= 1000 && tempera.currentCO2 >= 0)
|
{
|
co2Quality = 1;
|
}
|
else if (tempera.currentCO2 <= 2000 && tempera.currentCO2 > 1000)
|
{
|
co2Quality = 2;
|
}
|
else if (tempera.currentCO2 <= 5000 && tempera.currentCO2 > 2000)
|
{
|
co2Quality = 3;
|
}
|
else if (tempera.currentCO2 > 5000)
|
{
|
co2Quality = 4;
|
}
|
else
|
{
|
co2Quality = 0;
|
}
|
//产品部要求，暂时去掉Co2
|
/*if (tempera.currentPmData == 0 && tempera.currentCO2 == 0)
|
{
|
curQuality = 0;
|
}
|
else
|
{
|
if (co2Quality == 1 && pmQuality == 1)
|
{
|
curQuality = 1;
|
}
|
else
|
{
|
if (co2Quality > 2 || pmQuality > 2)
|
{
|
curQuality = 3;
|
}
|
else
|
{
|
curQuality = 2;
|
}
|
}
|
}if (tempera.currentPmData == 0 && tempera.currentCO2 == 0)
|
{
|
curQuality = 0;
|
}
|
else
|
{
|
if (co2Quality == 1 && pmQuality == 1)
|
{
|
curQuality = 1;
|
}
|
else
|
{
|
if (co2Quality > 2 || pmQuality > 2)
|
{
|
curQuality = 3;
|
}
|
else
|
{
|
curQuality = 2;
|
}
|
}
|
}*/
|
|
if (tempera.currentPmData == 0)
|
{
|
curQuality = 0;
|
}
|
else
|
{
|
if (pmQuality == 1)
|
{
|
curQuality = 1;
|
}
|
else
|
{
|
if (pmQuality > 2)
|
{
|
curQuality = 3;
|
}
|
else
|
{
|
curQuality = 2;
|
}
|
}
|
}
|
return curQuality;
|
}
|
|
#region led时间
|
///<summary >
|
/// 配置led失能时间
|
/// <para>number:序号</para>
|
/// </summary>
|
public async System.Threading.Tasks.Task<ResponseAllData> SetAirQualitySensorLedTime(LedTimeData ledTimeData)
|
{
|
ResponseAllData result = null;
|
if (Gateway == null)
|
{
|
return result;
|
}
|
return await System.Threading.Tasks.Task.Run(async () =>
|
{
|
Action<string, string> action = (topic, message) =>
|
{
|
var gatewayID = topic.Split('/')[0];
|
var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
|
|
if (topic == gatewayID + "/" + "ZbDataPassthrough")
|
{
|
var clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
|
|
if (clientDataPassthroughResponseData != null)
|
{
|
if (clientDataPassthroughResponseData?.PassData != null)
|
{
|
var data = clientDataPassthroughResponseData.PassData;
|
if (data.Length == 16)
|
{
|
var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
|
if (command == "0002")
|
{
|
var tempD = new ResponseData();
|
tempD.command = data[12].ToString() + data[13].ToString() + data[10].ToString() + data[11].ToString();
|
tempD.status = Convert.ToInt32(data[14].ToString() + data[15].ToString(), 16);
|
if (tempD.command == "0412")
|
{
|
result = new ResponseAllData { responseData = tempD };
|
System.Console.WriteLine($"UI收到通知后的主题_command:0400_{ topic}");
|
}
|
}
|
}
|
}
|
}
|
}
|
};
|
|
Gateway.Actions += action;
|
System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());
|
|
try
|
{
|
var passData = SetAirQualitySensorLedTimeDataStr(ledTimeData);
|
var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
|
var data = new JObject { { "PassData", passData } };
|
jObject.Add("Data", data);
|
Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
|
}
|
catch { }
|
|
var dateTime = DateTime.Now;
|
while ((DateTime.Now - dateTime).TotalMilliseconds < 9000)// WaitReceiveDataTime)
|
{
|
await System.Threading.Tasks.Task.Delay(10);
|
if (result != null)
|
{
|
break;
|
}
|
}
|
if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
|
{
|
result = null;
|
}
|
Gateway.Actions -= action;
|
System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());
|
|
return result;
|
});
|
}
|
|
/// <summary>
|
///配置led失能时间数据
|
/// </summary>
|
string SetAirQualitySensorLedTimeDataStr(LedTimeData ledTimeData)
|
{
|
string data = "";
|
string dataLength = "10";
|
string dataComand1 = "12";
|
string dataComand2 = "04";
|
string dataSerialNum = "01";
|
string addDataLength = "6";
|
string serialNum = "";
|
string sEnable = "";
|
string startHour = "";
|
string startMin = "";
|
string endHour = "";
|
string endMin = "";
|
string remark = "";
|
try
|
{
|
if (ledTimeData == null)
|
{
|
return "";
|
}
|
|
int dataLength1 = 10;
|
int addDataLength1 = 6;
|
if (!string.IsNullOrEmpty(ledTimeData.remark))
|
{
|
var reamarkGwBytes = System.Text.Encoding.UTF8.GetBytes(ledTimeData.remark);
|
int len = 36 < reamarkGwBytes.Length ? 36 : reamarkGwBytes.Length;
|
dataLength1 += len;
|
addDataLength1 += len;
|
}
|
|
dataLength = Convert.ToString(dataLength1, 16);
|
if (dataLength.Length == 1)
|
{
|
dataLength = "0" + dataLength;
|
}
|
|
addDataLength = Convert.ToString(addDataLength1, 16);
|
if (addDataLength.Length == 1)
|
{
|
addDataLength = "0" + addDataLength;
|
}
|
|
//因为只有0～4个序号，总共5个
|
serialNum = "0" + ledTimeData.serialNum.ToString();
|
|
if (ledTimeData.enable == 1)
|
{
|
sEnable = "01";
|
}
|
else
|
{
|
sEnable = "00";
|
}
|
|
startHour = Convert.ToString(ledTimeData.startHour, 16);
|
if (startHour.Length == 1)
|
{
|
startHour = "0" + startHour;
|
}
|
|
startMin = Convert.ToString(ledTimeData.startMin, 16);
|
if (startMin.Length == 1)
|
{
|
startMin = "0" + startMin;
|
}
|
|
endHour = Convert.ToString(ledTimeData.endHour, 16);
|
if (endHour.Length == 1)
|
{
|
endHour = "0" + endHour;
|
}
|
|
endMin = Convert.ToString(ledTimeData.endMin, 16);
|
if (endMin.Length == 1)
|
{
|
endMin = "0" + endMin;
|
}
|
|
remark = StringToHexString(ledTimeData.remark);
|
|
data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
|
serialNum + sEnable + startHour + startMin + endHour + endMin + remark;
|
}
|
catch { };
|
|
return data;
|
}
|
|
private string StringToHexString(string s)
|
{
|
var reamarkGwBytes = System.Text.Encoding.UTF8.GetBytes(s);
|
int len = 36 < reamarkGwBytes.Length ? 36 : reamarkGwBytes.Length;
|
var bytes = new byte[len];
|
System.Array.Copy(reamarkGwBytes, 0, bytes, 0, len);
|
string result = string.Empty;
|
for (int i = 0; i < bytes.Length; i++)//逐字节变为16进制字符
|
{
|
string temp = Convert.ToString(bytes[i], 16);
|
if (temp.Length == 1)
|
{
|
temp = "0" + temp;
|
}
|
result += temp;
|
}
|
return result;
|
}
|
|
///<summary >
|
/// 获取led失能时间
|
/// <para>number:序号</para>
|
/// </summary>
|
public async System.Threading.Tasks.Task<LedTimeData> ReadAirQualitySensorLedTime(int number)
|
{
|
LedTimeData result = null;
|
if (Gateway == null)
|
{
|
return result;
|
}
|
return await System.Threading.Tasks.Task.Run(async () =>
|
{
|
Action<string, string> action = (topic, message) =>
|
{
|
var gatewayID = topic.Split('/')[0];
|
var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
|
|
if (topic == gatewayID + "/" + "ZbDataPassthrough")
|
{
|
var clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
|
|
if (clientDataPassthroughResponseData != null)
|
{
|
if (clientDataPassthroughResponseData?.PassData != null)
|
{
|
var data = clientDataPassthroughResponseData.PassData;
|
var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
|
if (command == "0413")
|
{
|
result = new LedTimeData();
|
result.serialNum = Convert.ToInt32(data[10].ToString() + data[11].ToString(), 16);
|
result.enable = Convert.ToInt32(data[12].ToString() + data[13].ToString(), 16);
|
result.startHour = Convert.ToInt32(data[14].ToString() + data[15].ToString(), 16);
|
result.startMin = Convert.ToInt32(data[16].ToString() + data[17].ToString(), 16);
|
result.endHour = Convert.ToInt32(data[18].ToString() + data[19].ToString(), 16);
|
result.endMin = Convert.ToInt32(data[20].ToString() + data[21].ToString(), 16);
|
string remark = data.Substring(22, data.Length - 22);
|
var bytes = new byte[remark.Length / 2];
|
for (int i = 0; i < bytes.Length; i++)
|
{
|
bytes[i] = (byte)Convert.ToInt32(remark.Substring(i * 2, 2), 16);
|
}
|
result.remark = System.Text.Encoding.UTF8.GetString(bytes);
|
}
|
}
|
}
|
}
|
};
|
|
Gateway.Actions += action;
|
System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());
|
|
try
|
{
|
var passData = ReadAirQualitySensorLedTimeDataStr(number);
|
var jObject = new JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
|
var data = new JObject { { "PassData", passData } };
|
jObject.Add("Data", data);
|
Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
|
}
|
catch { }
|
|
var dateTime = DateTime.Now;
|
while ((DateTime.Now - dateTime).TotalMilliseconds < 9000)// WaitReceiveDataTime)
|
{
|
await System.Threading.Tasks.Task.Delay(10);
|
if (result != null)
|
{
|
break;
|
}
|
}
|
if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
|
{
|
result = null;
|
}
|
Gateway.Actions -= action;
|
System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());
|
|
return result;
|
});
|
}
|
|
/// <summary>
|
/// 获取led失能时间
|
/// </summary>
|
string ReadAirQualitySensorLedTimeDataStr(int number)
|
{
|
string data = "";
|
string dataLength = "05";
|
string dataComand1 = "11";
|
string dataComand2 = "04";
|
string dataSerialNum = "01";
|
string addDataLength = "01";
|
string num = "";
|
try
|
{
|
if (number == 1)
|
{
|
num = "01";
|
}
|
else
|
{
|
num = "00";
|
}
|
|
data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
|
num;
|
}
|
catch { };
|
|
return data;
|
}
|
|
/// <summary>
|
/// 配置led失能时间数据
|
/// </summary>
|
[System.Serializable]
|
public class LedTimeData
|
{
|
/// <summary>
|
/// 序号(正常序号0～4，共5个）
|
/// </summary>
|
public int serialNum = -1;
|
/// <summary>
|
/// 使能位
|
/// <para>0-无效 1--有效</para>
|
/// </summary>
|
public int enable = 0;
|
/// <summary>
|
/// 起始时
|
/// </summary>
|
public int startHour = -1;
|
/// <summary>
|
/// 起始分
|
/// </summary>
|
public int startMin;
|
/// <summary>
|
/// 结束时
|
/// </summary>
|
public int endHour = -1;
|
/// <summary>
|
/// 结束分
|
/// </summary>
|
public int endMin;
|
/// <summary>
|
/// 备注
|
/// </summary>
|
public string remark;
|
}
|
#endregion
|
}
|
}
|
