using System;
|
using System.Collections.Generic;
|
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()
|
{
|
if (myUdp == null)
|
{
|
myUdp = new Control_Udp();
|
}
|
|
UdpSocket._BusSocket.Start();
|
}
|
/// <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();
|
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";
|
}
|
|
}
|
}
|
