using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.IO.Ports;
|
using System.Windows.Forms;
|
|
namespace WCS
|
{
|
/// <summary>
|
/// 磅秤串口通讯线程
|
/// </summary>
|
class ScaleComThread
|
{
|
SerialPort sp;
|
#region 画面上同步显示控件
|
public ListBox scaledisplay;
|
#endregion
|
Thread trd = null;
|
delegate void displayresponse(string text);
|
int i = 1;
|
int scaleno = 0, portno = 0;
|
//int sum = 0;
|
main form1;
|
bool threadFlag = true, spFlag = true;
|
|
public ScaleComThread(int scale, int port_no, main m)
|
{
|
scaleno = scale;
|
portno = port_no;
|
sp = new SerialPort();
|
sp.PortName = "COM" + port_no.ToString();
|
sp.BaudRate = 9600;
|
sp.DataBits = 8;
|
sp.Parity = Parity.None;
|
sp.StopBits = StopBits.One;
|
form1 = m;
|
|
if (sp.IsOpen) return;
|
try
|
{
|
sp.Open();
|
}
|
catch (Exception r)
|
{
|
spFlag = false;
|
//DisplayInfo("【" + DateTime.Now.ToString() + "】打开串口" + portno + "失败，请检查");
|
//return;
|
}
|
trd = new Thread(new ThreadStart(this.ThreadTask));
|
trd.IsBackground = true;
|
trd.Start();
|
}
|
|
/// <summary>
|
/// 获取磅秤称重重量并解析
|
/// </summary>
|
private void GetScaleData()
|
{
|
string s_SendString = "", s_RecStr = "", s_wt = "", s_part1 = "", s_part2 = "", s_part3 = "", s_part4 = "", s_part5 = "", s_part6 = "", s_part7 = "", s_imp = "";
|
int pos = 0, pos1 = 0, pos2 = 0;
|
try
|
{
|
//s_SendString = "P";
|
//sp.DiscardInBuffer();
|
//sp.DiscardOutBuffer();
|
//sp.WriteLine(s_SendString);
|
//Thread.Sleep(400);
|
s_RecStr = "";
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
s_RecStr = sp.ReadExisting();
|
// DisplayInfo(s_RecStr);
|
if (s_RecStr.Length <= 0)
|
{
|
DisplayInfo("【" + DateTime.Now.ToString() + "】未能得到磅称重量，请检查");
|
return;
|
}
|
if (scaleno == 1)
|
{
|
pos = s_RecStr.IndexOf("NT,");
|
if (pos > 0)
|
{
|
s_RecStr = s_RecStr.Substring(pos + 3, s_RecStr.Length - pos - 3);
|
pos1 = s_RecStr.IndexOf("kg");
|
if (pos1 > 0)
|
{
|
s_RecStr = s_RecStr.Substring(0, pos1).Trim().Replace(" ", "");
|
try
|
{
|
Common.gd_gross_wt[scaleno - 1] = double.Parse(s_RecStr);
|
}
|
catch (Exception r)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
}
|
DisplayInfo("【" + DateTime.Now.ToString() + "】称重：" + s_RecStr + "KG");
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
else
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
//DisplayInfo("Read Data Error!------Date：" + System.DateTime.Now.ToString());
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
}
|
}
|
else if (scaleno == 2)
|
{
|
pos = s_RecStr.IndexOf("NT,");
|
if (pos > 0)
|
{
|
s_RecStr = s_RecStr.Substring(pos + 3, s_RecStr.Length - pos - 3);
|
pos1 = s_RecStr.IndexOf("kg");
|
if (pos1 > 0)
|
{
|
s_RecStr = s_RecStr.Substring(0, pos1).Trim().Replace(" ", "");
|
try
|
{
|
Common.gd_gross_wt[scaleno - 1] = double.Parse(s_RecStr);
|
}
|
catch (Exception r)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
}
|
DisplayInfo("【" + DateTime.Now.ToString() + "】称重：" + s_RecStr + "KG");
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
else
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
//DisplayInfo("Read Data Error!------Date：" + System.DateTime.Now.ToString());
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
}
|
}
|
else if (scaleno == 3)
|
{
|
pos = s_RecStr.IndexOf("NT,");
|
if (pos > 0)
|
{
|
s_RecStr = s_RecStr.Substring(pos + 3, s_RecStr.Length - pos - 3);
|
pos1 = s_RecStr.IndexOf("kg");
|
if (pos1 > 0)
|
{
|
s_RecStr = s_RecStr.Substring(0, pos1).Trim().Replace(" ", "");
|
try
|
{
|
Common.gd_gross_wt[scaleno - 1] = double.Parse(s_RecStr);
|
}
|
catch (Exception r)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
}
|
DisplayInfo("【" + DateTime.Now.ToString() + "】称重：" + s_RecStr + "KG");
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
else
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
//DisplayInfo("Read Data Error!------Date：" + System.DateTime.Now.ToString());
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
}
|
}
|
else if (scaleno == 4)
|
{
|
pos = s_RecStr.IndexOf("NT,");
|
if (pos > 0)
|
{
|
s_RecStr = s_RecStr.Substring(pos + 3, s_RecStr.Length - pos - 3);
|
pos1 = s_RecStr.IndexOf("kg");
|
if (pos1 > 0)
|
{
|
s_RecStr = s_RecStr.Substring(0, pos1).Trim().Replace(" ", "");
|
try
|
{
|
Common.gd_gross_wt[scaleno - 1] = double.Parse(s_RecStr);
|
}
|
catch (Exception r)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
}
|
DisplayInfo("【" + DateTime.Now.ToString() + "】称重：" + s_RecStr + "KG");
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
else
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
//DisplayInfo("Read Data Error!------Date：" + System.DateTime.Now.ToString());
|
sp.DiscardInBuffer();
|
sp.DiscardOutBuffer();
|
}
|
}
|
}
|
|
|
}
|
catch (Exception t)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
DisplayInfo("【" + DateTime.Now.ToString() + "】得到磅秤重量失败:" + t.Message);
|
//DisplayInfo("未能得到磅称重量，请检查！---时间：" + System.DateTime.Now.ToString());
|
//Thread.Sleep(400);
|
return;
|
}
|
|
}
|
#region 通讯反馈同步显示
|
private void DisplayInfo(string text)
|
{
|
if (scaledisplay.InvokeRequired)
|
{
|
try
|
{
|
displayresponse d = new displayresponse(DisplayInfo);
|
scaledisplay.Invoke(d, new object[] { text });
|
}
|
catch (Exception r)
|
{
|
|
}
|
}
|
else
|
{
|
if (scaledisplay.Items.Count > 12)
|
{
|
scaledisplay.Items.Clear();
|
}
|
scaledisplay.Items.Add(text);
|
}
|
|
}
|
#endregion
|
private void ThreadTask()
|
{
|
while (threadFlag)
|
{
|
if (spFlag)
|
{
|
GetScaleData();
|
}
|
else
|
{
|
DisplayInfo("【" + DateTime.Now.ToString() + "】打开串口" + portno + "失败，请检查");
|
threadFlag = false;
|
}
|
Thread.Sleep(400);
|
|
}
|
}
|
}
|
}
|
