You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
260 lines
6.0 KiB
260 lines
6.0 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Drawing;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using System.Windows.Forms;
|
|
using System.IO.Ports;
|
|
using System.Threading;
|
|
using System.Collections.Concurrent;
|
|
using BWP.WinFormControl.WeightDataFormat;
|
|
using System.Windows.Forms;
|
|
|
|
namespace BWP.WinFormControl
|
|
{
|
|
public enum WeightType
|
|
{
|
|
IND560,
|
|
Xk3124,
|
|
Xk3190A9,
|
|
Xk3190D10
|
|
}
|
|
|
|
public partial class WeightControl : UserControl
|
|
{
|
|
#region weight Need
|
|
|
|
private IDataFormat _dataFormat;
|
|
private Thread _inQueryThread, _outQueryThread;
|
|
readonly StringBuilder _dataStrBuilder = new StringBuilder();
|
|
readonly ConcurrentQueue<string> _dataQueue = new ConcurrentQueue<string>();
|
|
Form mainForm;
|
|
#endregion
|
|
|
|
bool inited = false;
|
|
public void InitSerialPort(string comPort, int baudRate, int dataBits)
|
|
{
|
|
weightSerialPort.PortName = comPort;
|
|
weightSerialPort.BaudRate = baudRate;
|
|
weightSerialPort.DataBits = dataBits;
|
|
weightSerialPort.ReadBufferSize = 4096 * 100;
|
|
inited = true;
|
|
}
|
|
|
|
//public SerialPort WeightSerialPort { get { return this.weightSerialPort; } }
|
|
|
|
private string _valueFormat = @"0.00";
|
|
public string ValueFormat { get { return _valueFormat; } set { _valueFormat = value; } }
|
|
|
|
private WeightType _weightType = WeightType.Xk3190A9;
|
|
/// <summary>
|
|
/// 称类型
|
|
/// </summary>
|
|
public WeightType TypeOfWeight
|
|
{
|
|
get { return _weightType; }
|
|
set { _weightType = value; }
|
|
}
|
|
string format
|
|
{
|
|
get
|
|
{
|
|
if (string.IsNullOrEmpty(_valueFormat))
|
|
_valueFormat = @"0.00";
|
|
return "{0:" + _valueFormat + "}";
|
|
}
|
|
}
|
|
public decimal? Value
|
|
{
|
|
get
|
|
{
|
|
if (string.IsNullOrEmpty(weightLabel.Text)) return null;
|
|
return decimal.Parse(string.Format(format, weightLabel.Text));
|
|
}
|
|
private set { weightLabel.Text = string.Format(format, value); }
|
|
}
|
|
|
|
public void Clear()
|
|
{
|
|
Value = 0;
|
|
}
|
|
|
|
public CheckBox EnableCheckBox { get { return enableWeightBox; } }
|
|
|
|
public WeightControl()
|
|
{
|
|
InitializeComponent();
|
|
}
|
|
|
|
private void OpenSerialPort()
|
|
{
|
|
if (!inited)
|
|
throw new Exception("Com口没有实例化，请先调用InitSerialPort");
|
|
|
|
// 打开串口
|
|
if (!weightSerialPort.IsOpen)
|
|
{
|
|
try
|
|
{
|
|
weightSerialPort.Open();
|
|
if (mainForm == null)
|
|
mainForm = ComponentUtil.GetParentFormm(this);
|
|
mainForm.FormClosing += MainFrom_FormClosing;
|
|
}
|
|
catch (InvalidOperationException)
|
|
{
|
|
MessageBox.Show(@"指定的端口已打开");
|
|
}
|
|
catch (UnauthorizedAccessException)
|
|
{
|
|
MessageBox.Show(@"对端口的访问被拒绝");
|
|
}
|
|
}
|
|
}
|
|
|
|
void ReadData()
|
|
{
|
|
_inQueryThread = new Thread(InQuery);
|
|
_inQueryThread.Start();
|
|
|
|
_outQueryThread = new Thread(OutQuery);
|
|
_outQueryThread.Start();
|
|
}
|
|
|
|
private void InQuery()
|
|
{
|
|
while (enableWeightBox.Checked)
|
|
{
|
|
int availableCount = weightSerialPort.BytesToRead;
|
|
if (availableCount == 0)
|
|
{
|
|
Thread.Sleep(1);
|
|
}
|
|
char[] buffer = new char[availableCount];
|
|
if (!weightSerialPort.IsOpen)
|
|
{
|
|
continue;
|
|
}
|
|
weightSerialPort.Read(buffer, 0, availableCount);
|
|
foreach (var c in buffer)
|
|
{
|
|
if (c == _dataFormat.Beginchar)
|
|
{
|
|
_dataStrBuilder.Clear();
|
|
_dataStrBuilder.Append(c);
|
|
}
|
|
else if (c == _dataFormat.Endchar || _dataStrBuilder.Length > _dataFormat.Bufsize)
|
|
{
|
|
_dataStrBuilder.Append(c);
|
|
_dataQueue.Enqueue(_dataStrBuilder.ToString());
|
|
_dataStrBuilder.Clear();
|
|
}
|
|
else
|
|
{
|
|
_dataStrBuilder.Append(c);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private void OutQuery()
|
|
{
|
|
while (enableWeightBox.Checked)
|
|
{
|
|
try
|
|
{
|
|
bool isStatic;
|
|
string str;
|
|
|
|
string subStr;
|
|
|
|
if (!_dataQueue.TryDequeue(out subStr))
|
|
{
|
|
Thread.Sleep(1);
|
|
continue;
|
|
}
|
|
// 解析接受的端口数据
|
|
if (_dataFormat.ParseAscii(subStr, out str, out isStatic))
|
|
{
|
|
Value = decimal.Parse(str);
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
Thread.Sleep(1000);
|
|
continue;
|
|
}
|
|
Thread.Sleep(1);
|
|
}
|
|
}
|
|
|
|
void InitWeightType()
|
|
{
|
|
switch (_weightType)
|
|
{
|
|
case WeightType.IND560:
|
|
_dataFormat = new IND560DataFormat();
|
|
break;
|
|
case WeightType.Xk3124:
|
|
_dataFormat = new Xk3124DataFormat();
|
|
break;
|
|
case WeightType.Xk3190A9:
|
|
_dataFormat = new Xk3190A9DataFormat();
|
|
break;
|
|
case WeightType.Xk3190D10:
|
|
_dataFormat = new Xk3190D10DataFormat();
|
|
break;
|
|
default:
|
|
throw new Exception("未知称类型");
|
|
}
|
|
}
|
|
|
|
void DisableWeight()
|
|
{
|
|
mainForm.FormClosing -= MainFrom_FormClosing;
|
|
Thread.Sleep(10);
|
|
|
|
if (weightSerialPort.IsOpen)
|
|
{
|
|
weightSerialPort.Close();
|
|
}
|
|
|
|
if (_inQueryThread.IsAlive)
|
|
{
|
|
_inQueryThread.Abort();
|
|
}
|
|
if (_outQueryThread.IsAlive)
|
|
{
|
|
_outQueryThread.Abort();
|
|
}
|
|
Value = 0;
|
|
}
|
|
|
|
private void MainFrom_FormClosing(object sender, FormClosingEventArgs e)
|
|
{
|
|
if (!enableWeightBox.Checked)
|
|
return;
|
|
DisableWeight();
|
|
}
|
|
|
|
private void enableWeightBox_CheckedChanged(object sender, EventArgs e)
|
|
{
|
|
if (!inited)
|
|
{
|
|
enableWeightBox.Checked = false;
|
|
throw new Exception("Com口没有实例化，请先调用InitSerialPort");
|
|
}
|
|
if (enableWeightBox.Checked)
|
|
{
|
|
InitWeightType();
|
|
OpenSerialPort();
|
|
ReadData();
|
|
}
|
|
else
|
|
DisableWeight();
|
|
}
|
|
}
|
|
}
|