using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.IO.Ports;
|
using System.Windows.Forms;
|
using System.Net;
|
using System.Net.Sockets;
|
|
namespace WCS
|
{
|
/// <summary>
|
/// 磅秤TCP通讯线程
|
/// </summary>
|
class ScaleTcpThread
|
{
|
SerialPort sp;
|
#region 画面上同步显示控件
|
public ListBox scaledisplay;
|
#endregion
|
Thread trd = null;
|
delegate void displayresponse(string text);
|
int scaleno = 0, portno = 0;
|
private string scaleIp;
|
//int sum = 0;
|
|
private IPEndPoint ServerInfo;
|
private Socket socket;
|
private Byte[] MsgBuffer;
|
private Byte[] MsgSend;
|
|
main form1;
|
bool threadFlag = true, spFlag = true;
|
|
public ScaleTcpThread(int scale_no, string scale_ip, int port, main m)
|
{
|
this.scaleno = scale_no;
|
this.scaleIp = scale_ip;
|
this.portno = port;
|
this.form1 = m;
|
|
MsgBuffer = new Byte[65535];
|
MsgSend = new Byte[65535];
|
//sp = new SerialPort();
|
//sp.PortName = "COM" + port.ToString();
|
//sp.BaudRate = 9600;
|
//sp.DataBits = 8;
|
//sp.Parity = Parity.None;
|
//sp.StopBits = StopBits.One;
|
|
//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();
|
}
|
|
#region socket连接
|
/// <summary>
|
/// socket连接WMS服务器
|
/// </summary>
|
private void SocketConnect()
|
{
|
ServerInfo = new IPEndPoint(IPAddress.Parse(scaleIp), portno);
|
try
|
{
|
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
socket.Connect(ServerInfo);
|
//Int32 bytes = socket.Receive(MsgBuffer, MsgBuffer.Length, SocketFlags.None);
|
//StringBuilder buff = new StringBuilder();
|
//String receiveData = Encoding.UTF8.GetString(MsgBuffer, 0, bytes);
|
//socket.Send(Encoding.Unicode.GetBytes("socket connect！"));
|
//RecevieData = "s";
|
//socket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);
|
|
DisplayInfo("【" + DateTime.Now.ToString() + "】磅秤连接成功");
|
|
}
|
catch (Exception em)
|
{
|
DisplayInfo("【" + DateTime.Now.ToString() + "】磅秤连接失败！" + em.Message);
|
}
|
}
|
|
/// <summary>
|
/// socket重新连接WMS服务器
|
/// </summary>
|
private void SocketReConnect()
|
{
|
if (socket.Connected)
|
{
|
socket.Close();
|
}
|
Thread.Sleep(10000);
|
SocketConnect();
|
}
|
|
/// <summary>
|
/// 判断socket是否已连接
|
/// </summary>
|
/// <returns></returns>
|
private bool checkSocket()
|
{
|
bool ret = true;
|
bool isConnected = false;
|
bool isRead = false;
|
bool isWrite = false;
|
bool isError = false;
|
int avalSize = 0;
|
try
|
{
|
isConnected = socket.Connected;
|
isRead = socket.Poll(50, SelectMode.SelectRead);
|
avalSize = socket.Available;
|
isWrite = socket.Poll(50, SelectMode.SelectWrite);
|
isError = socket.Poll(50, SelectMode.SelectError);
|
if (isConnected == false || isError == true || (isRead == true && avalSize == 0))
|
{
|
ret = false;
|
}
|
}
|
catch (Exception e)
|
{
|
ret = false;
|
}
|
return ret;
|
}
|
#endregion
|
|
/// <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;
|
string dataValue = "P", s_RecStr = "";
|
double d_RecStr = 0;
|
try
|
{
|
if (checkSocket() == false)
|
{
|
//调用重连
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
DisplayInfo("【" + DateTime.Now.ToString() + "】磅秤连接已断开，重连...");
|
SocketReConnect();
|
return;
|
}
|
|
MsgSend = Encoding.UTF8.GetBytes(dataValue);
|
if (socket.Connected)
|
{
|
// 向主机发送数据.
|
socket.Send(MsgSend, MsgSend.Length, SocketFlags.None);
|
//socket.Send(MsgSend);
|
//DisplayInfo("发送信息：" + dataValue);
|
//RecevieData = "";
|
// 接收主机应答
|
Int32 bytes = socket.Receive(MsgBuffer, MsgBuffer.Length, SocketFlags.None);
|
StringBuilder buff = new StringBuilder();
|
if (bytes > 0)
|
{
|
// 将缓冲的字节数组，装换为字符串.
|
// String receiveData = Encoding.ASCII.GetString(MsgBuffer, 0, bytes);
|
s_RecStr = Encoding.ASCII.GetString(MsgBuffer, 0, bytes);
|
if (s_RecStr.Length < 16)
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
DisplayInfo("【" + DateTime.Now.ToString() + "】无称重数据或者数据异常");
|
return;
|
}
|
s_RecStr = s_RecStr.Substring(1, 7);
|
//for (int i = 0; i < s_RecStr.Length; i++)
|
//{
|
// string s_nPos = s_RecStr.Substring(i, 1);
|
// if (Common.ChkStrtoInt(s_nPos) && i != 5)
|
// {
|
// s_wt_Str += s_nPos;
|
// }
|
// else if (i == 5)
|
// {
|
// if (s_nPos == ".")
|
// {
|
// s_wt_Str += s_nPos;
|
// }
|
// else
|
// {
|
// Common.gd_gross_wt[scaleno - 1] = 0;
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】无称重数据或者数据异常");
|
// return;
|
// }
|
// }
|
//}
|
try
|
{
|
d_RecStr = Convert.ToDouble(s_RecStr);
|
Common.gd_gross_wt[scaleno - 1] = d_RecStr;
|
DisplayInfo("【" + DateTime.Now.ToString() + "】" + Common.gd_gross_wt[scaleno - 1] + " KG");
|
}
|
catch
|
{
|
return;
|
}
|
//DisplayInfo("收到消息：" + receiveData);
|
// AnalysisReceive(receiveData); //解析收到的数据
|
// 加入字符串缓存
|
//buff.Append(str);
|
// 再次接受，看看后面还有没有数据.
|
}
|
}
|
else
|
{
|
Common.gd_gross_wt[scaleno - 1] = 0;
|
DisplayInfo("【" + DateTime.Now.ToString() + "】磅秤连接已断开，无法读取数据！");
|
}
|
return;
|
}
|
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()
|
{
|
SocketConnect();
|
while (threadFlag)
|
{
|
//if (spFlag)
|
//{
|
GetScaleData();
|
//}
|
//else
|
//{
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】打开串口" + portno + "失败，请检查");
|
// threadFlag = false;
|
//}
|
Thread.Sleep(400);
|
|
}
|
}
|
}
|
}
|
