161 lines
4.0 KiB
C#
161 lines
4.0 KiB
C#
using Aitex.Core.RT.Log;
|
|
using MECF.Framework.Common.Communications;
|
|
using System.Collections.Generic;
|
|
using System.Text;
|
|
|
|
namespace MECF.Framework.RT.EquipmentLibrary.HardwareUnits.Aligners.HwAligner
|
|
{
|
|
public class HwAlignerGuideMessage : BinaryMessage
|
|
{
|
|
//public bool IsResponse
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsAck
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsError
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsEvent
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsComplete
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsFormatError
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsBusy
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public bool IsNak
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
//public int MutexTag
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
//public byte[] RawMessage
|
|
//{
|
|
// get;
|
|
// set;
|
|
//}
|
|
|
|
public byte DeviceAddress { get; set; }
|
|
public byte FunctionCode { get; set; }
|
|
public byte Length { get; set; }
|
|
public byte[] Data { get; set; }
|
|
|
|
|
|
|
|
}
|
|
public class HwAlignerGuideConnection : SerialPortConnectionBase
|
|
{
|
|
private List<byte> _lstCacheBuffer = new List<byte>();
|
|
private object _lockerActiveHandler = new object();
|
|
public HwAlignerGuideConnection(string portName)
|
|
: base(portName, 115200, 8, System.IO.Ports.Parity.None, System.IO.Ports.StopBits.One, "\r", false)
|
|
{
|
|
}
|
|
public override bool SendMessage(byte[] message)
|
|
{
|
|
_lstCacheBuffer.Clear();
|
|
return base.SendMessage(message);
|
|
}
|
|
protected override MessageBase ParseResponse(byte[] rawMessage)
|
|
{
|
|
|
|
_lstCacheBuffer.AddRange(rawMessage);
|
|
byte[] temps = _lstCacheBuffer.ToArray();
|
|
|
|
HwAlignerGuideMessage msg = new HwAlignerGuideMessage();
|
|
msg.IsResponse = false;
|
|
msg.IsAck = false;
|
|
msg.IsComplete = false;
|
|
msg.RawMessage = _lstCacheBuffer.ToArray();
|
|
|
|
//if (temps.Length < 4) return msg;
|
|
/*
|
|
msg.DeviceAddress = temps[0];
|
|
msg.FunctionCode = temps[1];
|
|
*/
|
|
//if (msg.FunctionCode == 3)
|
|
//{
|
|
// msg.Length = temps[2];
|
|
|
|
// if (temps.Length < msg.Length + 5) return msg;
|
|
|
|
// msg.Data = _lstCacheBuffer.Skip(3).Take(msg.Length).ToArray();
|
|
//}else
|
|
msg.Data = _lstCacheBuffer.ToArray();
|
|
msg.IsResponse = true;
|
|
msg.IsAck = true;
|
|
msg.IsComplete = true;
|
|
//msg.IsEvent = false;
|
|
//msg.IsResponse = false;
|
|
|
|
return msg;
|
|
}
|
|
|
|
private static byte ModRTU_CRC(byte[] buffer)
|
|
{
|
|
//ushort crc = 0xFFFF;
|
|
// var buf = System.Text.Encoding.UTF8.GetBytes(String.Join(Environment.NewLine, buffer));
|
|
var buf = buffer;
|
|
var len = buffer.Length;
|
|
byte temp = buffer[0];
|
|
|
|
for (int i = 1; i < buffer.Length; i++)
|
|
{
|
|
temp = (byte)(temp ^ buffer[i]);
|
|
}
|
|
return (byte)~temp;
|
|
}
|
|
|
|
//public new void Execute(HandlerBase handler)
|
|
//{
|
|
// if (_activeHandler != null || handler == null) //|| !_port.IsOpen())
|
|
// {
|
|
// return;
|
|
// }
|
|
|
|
// lock (_lockerActiveHandler)
|
|
// {
|
|
// retryTime = 0;
|
|
// _activeHandler = handler;
|
|
// _activeHandler.SetState(EnumHandlerState.Sent);
|
|
|
|
// SendMessage(handler.SendBinary);
|
|
// //
|
|
|
|
// }
|
|
//}
|
|
}
|
|
|
|
}
|