using System;
|
using System.Collections.Generic;
|
using System.IO.Ports;
|
using System.Linq;
|
using System.Net;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
using HslCommunication;
|
using HslCommunication.LogNet;
|
|
namespace WIDESEAWCS_Communicator
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class SerialPortCommunicator : BaseSerialPortCommunicator
|
{
|
/// <summary>
|
/// 当前通讯器是否已连接到PLC。
|
/// </summary>
|
private bool _connected;
|
|
/// <summary>
|
/// PLC名称
|
/// </summary>
|
private string _name;
|
|
private ILogNet _logNet;
|
|
private List<byte> _buffers = new List<byte>();
|
|
private string _serialPortName;
|
|
private SerialPort _serialPort;
|
|
private int _readCount;
|
|
private bool _isReadToEnd;
|
|
|
/// <summary>
|
/// 日志记录器
|
/// </summary>
|
public override ILogNet LogNet => _logNet;
|
|
/// <summary>
|
/// 通讯器名称
|
/// </summary>
|
public override string Name => _name;
|
|
/// <summary>
|
/// 当前通讯器是否已连接到PLC。
|
/// </summary>
|
public override bool IsConnected => _connected;
|
|
/// <summary>
|
/// 缓冲区
|
/// </summary>
|
public override List<byte> Buffers => _buffers;
|
|
/// <summary>
|
/// 串口名称
|
/// </summary>
|
public override string SerialPortName => _serialPortName;
|
|
/// <summary>
|
/// 读取数据的长度。
|
/// </summary>
|
public override int ReadCount => _readCount;
|
|
/// <summary>
|
/// 读取数据时是否读取到数据末尾。
|
/// </summary>
|
public override bool IsReadToEnd => _isReadToEnd;
|
|
/// <summary>
|
///
|
/// </summary>
|
public override SerialPort SerialPort { get { return _serialPort; } set { _serialPort = value; } }
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public SerialPortCommunicator(string serialPortName, int port, string name)
|
{
|
string path = AppDomain.CurrentDomain.BaseDirectory + $"Log_PLCReadWrite\\{name}";
|
_logNet = new LogNetFileSize(path, 10 * 1024 * 1024, 100);
|
_serialPortName = serialPortName;
|
_name = name;
|
_serialPort = new SerialPort(serialPortName);
|
_serialPort.DataReceived += DataReceived;
|
}
|
|
private void DataReceived(object sender, SerialDataReceivedEventArgs e)
|
{
|
try
|
{
|
_buffers.Clear();
|
_buffers = new List<byte>();
|
byte[] data = new byte[1024];
|
while (true)
|
{
|
if (_serialPort.BytesToRead < 1)
|
break;
|
|
if (_serialPort.BytesToRead > data.Length)
|
{
|
_isReadToEnd = false;
|
}
|
else
|
{
|
_isReadToEnd = true;
|
}
|
|
_readCount = _serialPort.Read(data, 0, Math.Min(_serialPort.BytesToRead, data.Length));
|
|
_buffers.AddRange(data.SelectBegin(_readCount));
|
}
|
}
|
catch (Exception ex)
|
{
|
|
}
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
public override bool Connect()
|
{
|
try
|
{
|
_serialPort.Open();
|
return true;
|
}
|
catch (Exception ex)
|
{
|
LogNet.WriteException(Name, $"串口打开失败，串口号:{_serialPortName}", ex);
|
//连接异常时抛出自定义异常类
|
throw new CommunicationException(ex.Message, CommunicationErrorType.ConnectionFailed, innerException: ex);
|
}
|
}
|
|
/// <summary>
|
/// 断开与工业设备的连接。
|
/// </summary>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
public override bool Disconnect()
|
{
|
try
|
{
|
_serialPort.Close();
|
return true;
|
}
|
catch (Exception ex)
|
{
|
LogNet.WriteException(Name, $"串口关闭失败，串口号:{_serialPortName}", ex);
|
//连接异常时抛出自定义异常类
|
throw new CommunicationException(ex.Message, CommunicationErrorType.ConnectionFailed, innerException: ex);
|
}
|
}
|
|
/// <summary>
|
/// 释放资源。
|
/// </summary>
|
/// <exception cref="NotImplementedException"></exception>
|
public override void Dispose()
|
{
|
Disconnect();
|
GC.SuppressFinalize(this);
|
}
|
|
/// <summary>
|
/// 将缓冲区中的数据转换为字符串
|
/// </summary>
|
/// <param name="encoding"></param>
|
/// <returns></returns>
|
public override string ToString(Encoding encoding)
|
{
|
try
|
{
|
return encoding.GetString(Buffers.ToArray());
|
}
|
catch (Exception ex)
|
{
|
return "";
|
}
|
}
|
|
/// <summary>
|
/// 发送数据
|
/// </summary>
|
public override void Write(byte[] data)
|
{
|
_serialPort.Write(data, 0, data.Length);
|
}
|
|
/// <summary>
|
/// 发送数据
|
/// </summary>
|
/// <param name="data"></param>
|
public override void Write(string data)
|
{
|
byte[] bytes = Encoding.UTF8.GetBytes(data);
|
|
_serialPort.Write(bytes, 0, bytes.Length);
|
}
|
|
/// <summary>
|
/// 发送数据
|
/// </summary>
|
/// <param name="data"></param>
|
/// <param name="endStr"></param>
|
public override void Write(string data, string endStr)
|
{
|
byte[] bytes = Encoding.UTF8.GetBytes(data + endStr);
|
|
_serialPort.Write(bytes, 0, bytes.Length);
|
}
|
}
|
}
|
