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;
|
}
|
}
|
bool _gatewayOnline = false;
|
/// <summary>
|
/// 网关是否在线
|
/// </summary>
|
public bool GatewayOnline {
|
get
|
{
|
return _gatewayOnline;
|
}
|
set
|
{
|
_gatewayOnline = value;
|
//修改主页连接状态
|
UI.HomePage.LoadEvent_CheckLinkStatus();
|
}
|
}
|
/// <summary>
|
/// 是否为远程连接
|
/// </summary>
|
public bool IsRemote = false;
|
/// <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>
|
/// 打开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()
|
{
|
|
#if DEBUG
|
DB_ResidenceData.residenceData.GatewayType = 1;
|
#endif
|
OpenUdp(DB_ResidenceData.residenceData.GatewayType == 0 ? 6000 : 8585);
|
|
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();
|
}
|
}
|
|
/// <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;
|
if (DB_ResidenceData.residenceData.GatewayType == 0)
|
{
|
try
|
{
|
if(myUdp != null)
|
{
|
myUdp.WriteBusData(function, commandDictionary);
|
}
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"发送数据异常: {ex.Message}");
|
}
|
}
|
else
|
{
|
if (myTcpClient != null)
|
{
|
var sendDataObj = function.GetControlSendData(commandDictionary);
|
var sendJson = Newtonsoft.Json.JsonConvert.SerializeObject(sendDataObj);
|
var sendBytes = System.Text.Encoding.UTF8.GetBytes(sendJson);
|
myTcpClient.SendMessage(sendBytes);
|
}
|
}
|
}
|
|
/// <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 lenghtString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";
|
|
string sendDataString = topicString + lenghtString + bodyDataString;
|
byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
|
|
return sendDataBytes;
|
}
|
/// <summary>
|
/// 转换接收到的数据
|
/// </summary>
|
/// <returns></returns>
|
public string ConvertReceiveData(byte[] bytes)
|
{
|
string receiveString = "";
|
|
string topic = "";
|
int lenght = 0;
|
|
var reString = Encoding.UTF8.GetString(bytes);
|
var res = reString.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":
|
topic = key[1];
|
break;
|
case "Lenght":
|
lenght = Convert.ToInt32(key[1]);
|
break;
|
}
|
}
|
|
switch (topic)
|
{
|
case CommunicationTopic.SearchLoaclGateway:
|
var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
|
if (jt != null)
|
{
|
var device = Newtonsoft.Json.JsonConvert.DeserializeObject<Entity.DeviceModule>(jt.objects.ToString());
|
//Newtonsoft.Json.Linq.JObject.FromObject(jt.objects);
|
}
|
break;
|
}
|
|
}
|
return receiveString;
|
}
|
|
|
}
|
}
|
