using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using HDL_ON.Entity;
|
|
namespace HDL_ON.DriverLayer
|
{
|
/// <summary>
|
/// 通讯方式
|
/// </summary>
|
public enum CommunicationMode
|
{
|
none,
|
/// <summary>
|
/// 本地udp
|
/// </summary>
|
local_BusUdp,
|
/// <summary>
|
/// 本地tcp客户端
|
/// </summary>
|
tcp_local_client,
|
}
|
|
public class Control
|
{
|
static Control _control;
|
public static Control Ins
|
{
|
get
|
{
|
if (_control == null)
|
{
|
_control = new Control();
|
}
|
return _control;
|
}
|
}
|
int _msg_id = 1;
|
/// <summary>
|
/// 通讯ID
|
/// </summary>
|
public int msg_id
|
{
|
get
|
{
|
return _msg_id++;
|
}
|
}
|
/// <summary>
|
/// 获取13位时间戳
|
/// </summary>
|
/// <returns></returns>
|
public string Get_TimeStamp()
|
{
|
long t = DateTime.Now.Ticks / 10000;
|
return t.ToString();
|
}
|
|
bool _gatewayOnline = false;
|
/// <summary>
|
/// 网关是否在线
|
/// </summary>
|
public bool GatewayOnline {
|
get
|
{
|
return _gatewayOnline;
|
}
|
set
|
{
|
_gatewayOnline = value;
|
//修改主页连接状态
|
UI.HomePage.LoadEvent_CheckLinkStatus();
|
}
|
}
|
/// <summary>
|
/// 网关通讯ID
|
/// </summary>
|
public string GatewayId;
|
|
bool _isRemote = false;
|
/// <summary>
|
/// 是否为远程连接
|
/// </summary>
|
public bool IsRemote {
|
get
|
{
|
return _isRemote;
|
}
|
set
|
{
|
_isRemote = value;
|
if(value)
|
{
|
DAL.Mqtt.MqttClient.InitState();
|
}else
|
{
|
DAL.Mqtt.MqttClient.DisConnectRemote();
|
}
|
}
|
}
|
/// <summary>
|
/// 通讯地址IP
|
/// </summary>
|
public string reportIp = "255.255.255.255";
|
/// <summary>
|
/// tcp服务端
|
/// </summary>
|
public Control_TcpServer myTcpServer = null;
|
/// <summary>
|
/// tcp客服端
|
/// </summary>
|
public Control_TcpClient myTcpClient = null;
|
/// <summary>
|
/// 本地udp
|
/// </summary>
|
public Control_Udp myUdp = null;
|
|
/// <summary>
|
/// 通讯方式
|
/// </summary>
|
public CommunicationMode communicationMode;
|
|
/// <summary>
|
/// 打开tcp服务端
|
/// </summary>
|
public void OpenTcpServer()
|
{
|
myTcpServer = new Control_TcpServer();
|
myTcpServer.OpenServer();
|
}
|
|
/// <summary>
|
/// 打开Udp
|
/// </summary>
|
public void OpenUdp(int port)
|
{
|
if (myUdp == null)
|
{
|
myUdp = new Control_Udp();
|
}
|
|
UdpSocket._BusSocket.Start(port);
|
}
|
/// <summary>
|
/// 关闭udp
|
/// </summary>
|
public void CloseUdp()
|
{
|
if (myUdp != null)
|
{
|
myUdp = null;
|
}
|
UdpSocket._BusSocket.Stop();
|
}
|
|
/// <summary>
|
/// 打开tcp客服端
|
/// </summary>
|
public void OpenTcpClent()
|
{
|
if (myTcpClient == null)
|
{
|
myTcpClient = new Control_TcpClient(reportIp);
|
myTcpClient.Connect();
|
}
|
}
|
|
///// <summary>
|
///// 改变通讯方式
|
///// </summary>
|
//public void ChangeCommunicationMode(CommunicationMode communicationMode)
|
//{
|
// this.communicationMode = communicationMode;
|
//}
|
|
/// <summary>
|
/// 搜索本地网关列表
|
/// </summary>
|
public void SearchLoaclGateway()
|
{
|
OpenUdp(DB_ResidenceData.residenceData.GatewayType == 0 ? 6000 : 8585);
|
new System.Threading.Thread(() =>
|
{
|
for (int i = 0; i < 5; i++)
|
{
|
if (GatewayOnline)
|
break;
|
if (DB_ResidenceData.residenceData.GatewayType == 0)
|
{
|
myUdp.ControlBytesSend(Command.ReadGateway, 255, 255, new byte[] { (byte)new Random().Next(255), (byte)new Random().Next(255) });
|
}
|
else if (DB_ResidenceData.residenceData.GatewayType == 1)
|
{
|
myUdp.SearchLocalGateway();
|
}
|
System.Threading.Thread.Sleep(500);
|
}
|
})
|
{ IsBackground = true }.Start();
|
}
|
|
/// <summary>
|
/// 场景控制入口
|
/// </summary>
|
public void ControlScene(Scene scene)
|
{
|
if(myUdp!=null)
|
{
|
myUdp.ControlBusScenes(scene);
|
}
|
if(myTcpClient!= null)
|
{
|
ControlAProtocolScene(scene);
|
}
|
}
|
|
/// <summary>
|
/// 发送命令
|
/// 自动判断是否为A协议设备，
|
/// 不是A协议，自动转化bus命令数据
|
/// </summary>
|
/// <param name="commandString"></param>
|
/// <param name="function"></param>
|
/// <returns></returns>
|
public void SendWriteCommand(Function function, Dictionary<string, string> commandDictionary)
|
{
|
function.usageCount++;
|
function.refreshTime = DateTime.Now;
|
DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
|
//远程通讯
|
if (Ins.IsRemote)
|
{
|
//ALink控制、Bus控制使用同一个接口控制，由云端负责解析
|
var apiControlData = function.GetApiControlData(commandDictionary);
|
var actionObjs = new List<ApiAlinkControlActionObj>();
|
actionObjs.Add(apiControlData);
|
httpServer.ControlDevice(actionObjs);
|
}
|
//本地通讯
|
else
|
{
|
//ALink控制
|
if (DB_ResidenceData.residenceData.GatewayType == 0)
|
{
|
try
|
{
|
if (myUdp != null)
|
{
|
myUdp.WriteBusData(function, commandDictionary);
|
}
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"发送数据异常: {ex.Message}");
|
}
|
}
|
//Bus控制
|
else
|
{
|
if (myUdp != null)
|
{
|
var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
|
var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
|
var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
|
myUdp.SendLocalHdlLinkData(sendBytes);
|
//MainPage.Log($"发送本地HDL-Link数据{functionControlDataJson}\r\n");
|
}
|
}
|
}
|
}
|
|
/// <summary>
|
/// 发送读取命令
|
/// 自动判断是否为A协议设备
|
/// </summary>
|
public void SendReadCommand(Function function)
|
{
|
function.refreshTime = DateTime.Now;
|
if (function.bus_Data != null)
|
{
|
try
|
{
|
//ReadBusData(function);
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"发送数据异常: {ex.Message}");
|
}
|
}
|
else
|
{
|
//var commandObj = function.GetSendJObject(CommandType_A.read);
|
//var commandString = Newtonsoft.Json.JsonConvert.SerializeObject(commandObj);
|
//var commandBytes = System.Text.Encoding.UTF8.GetBytes(commandString);
|
//MqttCommon.MqttRemoteSend(commandBytes);
|
}
|
}
|
|
/// <summary>
|
/// 控制a协议场景
|
/// </summary>
|
/// <param name="scene"></param>
|
static void ControlAProtocolScene(Scene scene)
|
{
|
var sendSidObj = new AProtocolSendingObject();
|
sendSidObj.time_stamp = "";
|
sendSidObj.type = "device_sid";
|
sendSidObj.command = "get_list_response";
|
}
|
/// <summary>
|
/// 转换通讯数据
|
/// </summary>
|
public byte[] ConvertSendBodyData(string topic, string bodyDataString)
|
{
|
string topicString = "Topic:" + topic + "\r\n";
|
byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
|
string lengthString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";
|
|
string sendDataString = topicString + lengthString + bodyDataString;
|
byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
|
MainPage.Log($"转换HDL-Link数据\r\n{sendDataString}\r\n");
|
|
return sendDataBytes;
|
}
|
/// <summary>
|
/// 转换接收到的数据
|
/// </summary>
|
/// <returns></returns>
|
public void ConvertReceiveData(byte[] receiveBytes)
|
{
|
var reString = Encoding.UTF8.GetString(receiveBytes);
|
AnalysisReceiveData(reString);
|
}
|
/// <summary>
|
/// 转换接收到的数据
|
/// </summary>
|
/// <returns></returns>
|
public LocalCommunicationData AnalysisReceiveData(string receiveString)
|
{
|
LocalCommunicationData receiveObj = new LocalCommunicationData();
|
|
var res = receiveString.Split("\r\n\r\n");
|
|
if (res.Length == 2)
|
{
|
var topics = res[0].Split("\r\n");
|
MainPage.Log(res[1]);
|
foreach (var ts in topics)
|
{
|
var key = ts.Split(":");
|
switch (key[0])
|
{
|
case "Topic":
|
receiveObj.Topic = key[1];
|
break;
|
case "Length":
|
receiveObj.Length = Convert.ToInt32(key[1]);
|
break;
|
}
|
}
|
//验证有效数据长度
|
//if (res[1].Length != receiveObj.Length)
|
//{
|
// MainPage.Log($"收到数据包长度不够");
|
// return receiveObj;
|
//}
|
receiveObj.BodyDataString = res[1];
|
|
var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
|
if (bodyJObj == null)
|
{
|
return receiveObj;
|
}
|
switch (receiveObj.Topic)
|
{
|
case CommunicationTopic.SearchLoaclGatewayReply:
|
var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
|
if (device.device_mac == DB_ResidenceData.residenceData.residenceGatewayMAC)
|
{
|
Ins.GatewayOnline = true;
|
Ins.GatewayId = device.gatewayId;
|
reportIp = "239.0.168.188";// device.ip_address;
|
Ins.IsRemote = false;
|
}
|
break;
|
}
|
}
|
return receiveObj;
|
}
|
}
|
}
|
