using LB_VisionProcesses;
|
using LB_VisionProcesses.Communicators;
|
using System.IO.Ports;
|
|
namespace LB_VisionProcesses.Communicators.Modbus
|
{
|
public class ModbusRTUMaster : BaseCommunicator
|
{
|
public SerialPort SerialPort = new SerialPort();
|
|
// 构造函数
|
public ModbusRTUMaster(string name = "ModbusRTU主站")
|
{
|
CommunicatorConnections.Add("地址", "COM1");
|
CommunicatorConnections.Add("端口", "115200");
|
CommunicatorBrand = CommunicatorBrand.ModbusRTUMaster;
|
CommunicatorName = name;
|
}
|
|
public void SetConfigure(string portName, int baudRate = 115200, Parity parity = Parity.None,
|
int dataBits = 8, StopBits stopBits = StopBits.One)
|
{
|
SerialPort.PortName = portName;
|
SerialPort.BaudRate = baudRate;
|
SerialPort.Parity = parity;
|
SerialPort.DataBits = dataBits;
|
SerialPort.StopBits = stopBits;
|
SerialPort.NewLine = "\r\n"; // 设置行结束符
|
SerialPort.ReadTimeout = 500; // 设置读取超时
|
SerialPort.WriteTimeout = 500; // 设置写入超时
|
}
|
|
public override bool Connect()
|
{
|
try
|
{
|
Disconnect();
|
|
//波特率
|
int PORT = 0;
|
if (!int.TryParse(this.CommunicatorConnections["端口"].ToString(), out PORT))
|
{
|
Msg = string.Format("端口未设置");
|
return false;
|
}
|
if (!CommunicatorConnections.Contains("地址"))
|
{
|
Msg = string.Format("地址未设置");
|
return false;
|
}
|
//串口号
|
string IP = CommunicatorConnections["地址"].ToString();
|
|
if (!SerialPort.IsOpen)
|
{
|
SerialPort = new SerialPort();
|
SetConfigure(IP, PORT);
|
SerialPort.Open();
|
bConnected = true;
|
//SerialPort.DataReceived += SerialPort_DataReceived;
|
|
// 启动心跳线程
|
bHeart = true;
|
//heartbeatThread = new Thread(SendHeartbeat);
|
//heartbeatThread.IsBackground = true;
|
//heartbeatThread.Start();
|
|
IProcess.lstCommunicators.Add(this);
|
return true;
|
}
|
else
|
{
|
Msg = $"原串口关闭失败无法重新打开";
|
return false;
|
}
|
}
|
catch (Exception ex)
|
{
|
Msg = $"失败,串口已经启动: {ex.Message}";
|
return false;
|
}
|
}
|
|
public override bool Disconnect()
|
{
|
try
|
{
|
bConnected = false;
|
if (SerialPort == null)
|
{
|
SerialPort = new SerialPort();
|
return true;
|
}
|
|
if (SerialPort.IsOpen)
|
{
|
//SerialPort.DataReceived -= SerialPort_DataReceived;
|
SerialPort.Close(); // 关闭串口
|
}
|
|
SerialPort = new SerialPort();
|
IProcess.lstCommunicators.Remove(this);
|
return true;
|
}
|
catch (Exception ex)
|
{
|
bConnected = false;
|
Msg = $"断开串口时出错: {ex.Message}";
|
return true;
|
}
|
}
|
|
public override bool SendMessage(byte[] sBytes)
|
{
|
bool bret = false;
|
if (SerialPort == null || !SerialPort.IsOpen) return bret;
|
try
|
{
|
SerialPort.Write(sBytes, 0, sBytes.Length);
|
bret = true;
|
}
|
catch { }
|
return bret;
|
}
|
|
public override bool SendMessage(string message)
|
{
|
if (bConnected)
|
{
|
try
|
{
|
//空消息不发送
|
if (string.IsNullOrEmpty(message) || message.Trim() == "")
|
return true;
|
|
//发送前清空接收消息
|
strReceiveMsg = string.Empty;
|
SerialPort.Write(message); // 发送消息
|
return true;
|
}
|
catch (Exception ex)
|
{
|
Msg = $"发送消息时出错: {ex.Message}";
|
return false;
|
}
|
}
|
else
|
{
|
Msg = "串口未打开";
|
return false;
|
}
|
}
|
|
public override string ReceiveMsg()
|
{
|
string msg = string.Empty;
|
for (int i = 0; i <= 3; i++)
|
{
|
if (string.IsNullOrEmpty(strReceiveMsg))
|
Thread.Sleep(50);
|
else
|
{
|
lock (strReceiveMsg)
|
{
|
msg += strReceiveMsg;
|
strReceiveMsg = string.Empty;
|
}
|
//串口数据需要使用累加方式
|
//return msg;
|
}
|
}
|
return msg;
|
}
|
}
|
}
|
