using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using ZigBee.Device;
|
|
namespace Shared.Phone.UserCenter
|
{
|
/// <summary>
|
/// 设备的共通逻辑
|
/// </summary>
|
public class HdlDeviceCommonLogic
|
{
|
#region ■ 变量声明___________________________
|
|
/// <summary>
|
/// 设备的共通逻辑
|
/// </summary>
|
private static HdlDeviceCommonLogic m_Current = null;
|
/// <summary>
|
/// 设备的共通逻辑
|
/// </summary>
|
public static HdlDeviceCommonLogic Current
|
{
|
get
|
{
|
if (m_Current == null)
|
{
|
m_Current = new HdlDeviceCommonLogic();
|
}
|
return m_Current;
|
}
|
set
|
{
|
m_Current = value;
|
}
|
}
|
|
#endregion
|
|
#region ■ 发送数据___________________________
|
|
/// <summary>
|
/// 发送数据到网关，并接受网关返回的数据(非透传,ReceiptData为返回值)
|
/// </summary>
|
/// <param name="device">设备对象</param>
|
/// <param name="sendTopic">发送的主题</param>
|
/// <param name="sendData">需要发送的数据 JObject.ToString()的东西</param>
|
/// <param name="receiptTopic">指定接收哪个主题</param>
|
/// <param name="waitTime">超时时间(秒)</param>
|
/// <returns>网关返回的数据</returns>
|
public ReceiptGatewayResult SendJobjectDataToGateway(CommonDevice device, string sendTopic, string sendData, string receiptTopic, int waitTime = 5)
|
{
|
//发送数据到网关，并接受网关返回的数据
|
return this.SendJobjectDataToGateway(device, sendTopic, sendData, new List<string>() { receiptTopic }, waitTime);
|
}
|
|
/// <summary>
|
/// 发送数据到网关，并接受网关返回的数据(非透传),listReceiptData为返回值(全部主题全部接收得到,才会返回,不然会返回超时)
|
/// </summary>
|
/// <param name="device">设备对象</param>
|
/// <param name="sendTopic">发送的主题</param>
|
/// <param name="sendData">需要发送的数据 JObject.ToString()的东西</param>
|
/// <param name="listReceiptTopic">指定接收哪些主题</param>
|
/// <param name="waitTime">超时时间(秒)</param>
|
/// <returns>网关返回的数据</returns>
|
public ReceiptGatewayResult SendJobjectDataToGateway(CommonDevice device, string sendTopic, string sendData, List<string> listReceiptTopic, int waitTime = 5)
|
{
|
var reResult = new ReceiptGatewayResult();
|
reResult.listReceiptData = new string[listReceiptTopic.Count];
|
var myGateway = device.Gateway;
|
if (myGateway == null)
|
{
|
//获取网关对象失败
|
reResult.ErrorMsg = Language.StringByID(R.MyInternationalizationString.uGetGatewayTagartFail);
|
reResult.ErrorMsgDiv = -1;
|
return reResult;
|
}
|
//网关ID
|
string gatewayID = device.Gateway.GwId;
|
//错误主题
|
string errorTopic = gatewayID + "/" + "Error_Respon";
|
//检测对象的主题
|
for (int i = 0; i < listReceiptTopic.Count; i++)
|
{
|
listReceiptTopic[i] = gatewayID + "/" + listReceiptTopic[i];
|
}
|
|
//接收数
|
int receiptCount = 0;
|
Action<string, string> receiptAction = (topic, message) =>
|
{
|
var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
|
|
//网关回复错误
|
if (topic == errorTopic)
|
{
|
var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());
|
reResult.ErrorMsg = HdlCheckLogic.Current.CheckCommonErrorCode(temp.Error);
|
}
|
//如果是指定的主题
|
for (int i = 0; i < listReceiptTopic.Count; i++)
|
{
|
if (topic == listReceiptTopic[i])
|
{
|
string deviceMac = jobject["DeviceAddr"].ToString();
|
int deviceEpoint = 200;
|
if (jobject.Property("Epoint") != null)
|
{
|
//拥有此键值
|
deviceEpoint = Convert.ToInt32(jobject["Epoint"].ToString());
|
}
|
if (device.DeviceAddr != deviceMac)
|
{
|
//不是同一个东西Mac
|
return;
|
}
|
if (device.DeviceEpoint != deviceEpoint && deviceEpoint != 200)
|
{
|
//不是同一个东西,这里应该需要特殊处理200端点
|
return;
|
}
|
reResult.listReceiptData[i] = jobject["Data"].ToString();
|
receiptCount++;
|
}
|
}
|
|
};
|
myGateway.Actions += receiptAction;
|
//发送数据
|
myGateway.Send(sendTopic, sendData);
|
|
//超时时间
|
int TimeOut = 0;
|
waitTime = 20 * waitTime;
|
while (receiptCount != listReceiptTopic.Count && TimeOut < waitTime)
|
{
|
//全部接收才退出
|
System.Threading.Thread.Sleep(50);
|
TimeOut++;
|
}
|
myGateway.Actions -= receiptAction;
|
receiptAction = null;
|
if (receiptCount != listReceiptTopic.Count)
|
{
|
reResult.ErrorMsgDiv = 0;
|
}
|
else
|
{
|
//正常接收到网关返回的数据
|
if (reResult.listReceiptData.Length == 1)
|
{
|
//如果只有一个主题,则替换变量
|
reResult.ReceiptData = reResult.listReceiptData[0];
|
reResult.listReceiptData = null;
|
}
|
}
|
|
return reResult;
|
}
|
|
/// <summary>
|
/// 发送数据到网关，并接受网关返回的数据(透传专用)
|
/// </summary>
|
/// <param name="device">设备对象</param>
|
/// <param name="sendData">需要发送的数据 JObject.ToString()的东西</param>
|
/// <param name="receiptCommand">指定接收命令符</param>
|
/// <param name="receiptDataLength">指定接收数据的长度</param>
|
/// <param name="waitTime">超时时间(秒)</param>
|
/// <param name="listReceiptLength">附加检测数据接收长度,当接收的长度在这列表里面时,代表接收成功(旨在对应新旧设备,透传回复的长度可能不同)</param>
|
/// <returns>网关返回的数据</returns>
|
public ReceiptGatewayResult SendJobjectDataToGateway2(CommonDevice device, string sendData, string receiptCommand, int receiptDataLength,
|
int waitTime = 5, List<int> listReceiptLength = null)
|
{
|
var reResult = new ReceiptGatewayResult();
|
var myGateway = device.Gateway;
|
if (myGateway == null)
|
{
|
//获取网关对象失败
|
reResult.ErrorMsg = Language.StringByID(R.MyInternationalizationString.uGetGatewayTagartFail);
|
reResult.ErrorMsgDiv = -1;
|
return reResult;
|
}
|
//网关ID
|
string gatewayID = device.Gateway.GwId;
|
//错误主题
|
string errorTopic = gatewayID + "/" + "Error_Respon";
|
//检测对象的主题
|
string checkTopic = gatewayID + "/ZbDataPassthrough";
|
|
Action<string, string> receiptAction = (topic, message) =>
|
{
|
var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
|
|
//网关回复错误
|
if (topic == errorTopic)
|
{
|
var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());
|
reResult.ErrorMsg = HdlCheckLogic.Current.CheckCommonErrorCode(temp.Error);
|
}
|
//如果是指定的主题
|
if (topic == checkTopic)
|
{
|
string deviceMac = jobject["DeviceAddr"].ToString();
|
int deviceEpoint = 200;
|
if (jobject.Property("Epoint") != null)
|
{
|
//拥有此键值
|
deviceEpoint = Convert.ToInt32(jobject["Epoint"].ToString());
|
}
|
if (device.DeviceAddr != deviceMac)
|
{
|
//不是同一个东西Mac
|
return;
|
}
|
if (device.DeviceEpoint != deviceEpoint && deviceEpoint != 200)
|
{
|
//不是同一个东西,这里应该需要特殊处理200端点
|
return;
|
}
|
|
var responseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ClientDataPassthroughResponseData>(jobject["Data"].ToString());
|
//长度不一致
|
if (responseData.PassData.Length != receiptDataLength)
|
{
|
if (listReceiptLength == null)
|
{
|
//如果没有附加检测长度,则直接返回
|
return;
|
}
|
if (listReceiptLength.Contains(responseData.PassData.Length) == false)
|
{
|
//如果附加的检测长度里面,还不存在的话,直接返回
|
return;
|
}
|
}
|
|
var command = responseData.PassData[4].ToString()
|
+ responseData.PassData[5].ToString()
|
+ responseData.PassData[2].ToString()
|
+ responseData.PassData[3].ToString();
|
//并且是这个命令
|
if (command == receiptCommand)
|
{
|
reResult.ReceiptData = responseData.PassData;
|
}
|
}
|
};
|
myGateway.Actions += receiptAction;
|
//发送数据
|
myGateway.Send("ClientDataPassthrough", sendData);
|
|
//超时时间
|
int TimeOut = 0;
|
waitTime = 20 * waitTime;
|
while (reResult.ReceiptData == null && TimeOut < waitTime)
|
{
|
System.Threading.Thread.Sleep(50);
|
TimeOut++;
|
}
|
myGateway.Actions -= receiptAction;
|
receiptAction = null;
|
if (reResult.ReceiptData == null)
|
{
|
//超时
|
reResult.ErrorMsgDiv = 0;
|
}
|
return reResult;
|
}
|
|
#endregion
|
}
|
}
|
