using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
namespace SA_LTT.Module
|
{
|
public class GR200 : ComPort
|
{
|
private char STX = Convert.ToChar(2);
|
private char EXT = '\n';
|
private Dictionary<int, float> _measuredValues;
|
|
public float MainCDAPressure
|
{
|
get
|
{
|
return _measuredValues[1];
|
}
|
}
|
|
public float MainVacuumPressure
|
{
|
get
|
{
|
return _measuredValues[2];
|
}
|
}
|
|
public float N2PTPressure
|
{
|
get
|
{
|
return _measuredValues[3];
|
}
|
}
|
|
public float MainCDAFlow
|
{
|
get
|
{
|
return _measuredValues[4];
|
}
|
}
|
|
public float ChamberVacuumPressure
|
{
|
get
|
{
|
return _measuredValues[5];
|
}
|
}
|
|
private Equipment _equipment;
|
private Thread t_statusUpdate;
|
|
public GR200(Equipment equipment)
|
{
|
serialPort.PortName = "COM7";
|
serialPort.BaudRate = 57600;
|
serialPort.Parity = System.IO.Ports.Parity.None;
|
serialPort.DataBits = 7;
|
serialPort.StopBits = System.IO.Ports.StopBits.One;
|
serialPort.Handshake = System.IO.Ports.Handshake.RequestToSend;
|
Terminator = "\r\n";
|
|
_measuredValues = new Dictionary<int, float>();
|
|
for (int i = 1; i <= 12; i++)
|
{
|
_measuredValues.Add(i, 0f);
|
}
|
|
_equipment = equipment;
|
|
t_statusUpdate = new Thread(statusUpdate);
|
t_statusUpdate.Start();
|
}
|
|
public void statusUpdate()
|
{
|
while (_equipment.IsDisposed == false)
|
{
|
try
|
{
|
Thread.Sleep(100);
|
|
if (IsOpen)
|
{
|
ReadMeasuredValue(1);
|
}
|
else
|
{
|
if (_equipment.alarmManager.OccurredAlarms.Exists(x => x.Code == AlarmCode.AL_0058_GR200_DISCONNECTED))
|
{
|
|
}
|
else
|
{
|
if (Open() == false)
|
{
|
_equipment.alarmManager.Occur(AlarmCode.AL_0058_GR200_DISCONNECTED);
|
}
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
EquipmentLogManager.Instance.WriteExceptionLog(e.StackTrace);
|
}
|
}
|
}
|
|
private string GetCommand(int channel, int bitsCount, int registerNumber)
|
{
|
return $"{channel:D2}DRS,{(bitsCount):D2},{registerNumber:D4}";
|
}
|
|
public void ReadMeasuredValue(int channel)
|
{
|
string command = GetCommand(channel, 24, 16);
|
string receivedData = string.Empty;
|
|
if(WriteRead(command, out receivedData))
|
{
|
string[] datas = receivedData.Split(',');
|
|
int register = 1;
|
|
if (!datas[0].Contains("NG") && datas[0].Contains("DRS"))
|
{
|
for (int i = 2; i < datas.Length; i = i + 2)
|
{
|
float fl = BitConverter.ToSingle(BitConverter.GetBytes(Convert.ToInt64(datas[i] + datas[i + 1], 16)), 0);
|
|
if (_measuredValues.ContainsKey(register))
|
{
|
_measuredValues[register] = fl;
|
}
|
else
|
{
|
_measuredValues.Add(register, fl);
|
}
|
|
register++;
|
}
|
}
|
else if (datas[0].Contains("NG"))
|
throw new Exception($"Command NG, Address : {channel}, Command : DRS , Recv Data =");
|
else
|
throw new Exception($"Error, Address : {channel}, Command : DRS , Recv Data =");
|
}
|
}
|
|
public bool WriteRead(string command, out string receivedData)
|
{
|
string data = base.WriteRead($"{STX}{command}\r{EXT}");
|
|
if (data.StartsWith($"{STX}"))
|
{
|
receivedData = data.Replace(STX, ' ').Replace("\r\n", "");
|
return true;
|
}
|
else
|
{
|
receivedData = string.Empty;
|
return false;
|
}
|
}
|
}
|
}
|
