using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Windows.Forms;
|
using System.Net;
|
using System.Net.Sockets;
|
using DevComponents.DotNetBar;
|
|
namespace WCS
|
{
|
/// <summary>
|
/// 条码线程
|
/// </summary>
|
class BarcodeThread
|
{
|
#region 画面上同步显示控件
|
public ListBox barcodedisplay;
|
public LabelX lb_barcode;
|
delegate void displayresponse(string text);
|
delegate void SetTextCallback(string barcode);
|
#endregion
|
|
Thread trd = null;
|
string barcodeip = "";
|
int barcodeno = 0;
|
int portno = 0;
|
|
//int i = 1;
|
//int scaleno = 0;
|
main form1;
|
|
private IPEndPoint ServerInfo;
|
private Socket socket;
|
private Byte[] MsgBuffer = new Byte[65535];
|
private Byte[] MsgSend = new Byte[65535];
|
|
public BarcodeThread(int barcode_no, string barcode_ip, int port, main f)
|
{
|
try
|
{
|
barcodeno = barcode_no;
|
barcodeip = barcode_ip;
|
this.portno = port;
|
form1 = f;
|
//MsgBuffer = new Byte[65535];
|
//MsgSend = new Byte[65535];
|
|
trd = new Thread(new ThreadStart(this.ThreadTask));
|
trd.IsBackground = true;
|
trd.Start();
|
}
|
catch (Exception em)
|
{
|
Common.WriteLogFile("WcsError", "BarcodeThread/BarcodeThread--条码线程启动出错:" + em.Message);
|
}
|
}
|
|
#region socket连接
|
/// <summary>
|
/// socket连接WMS服务器
|
/// </summary>
|
private void SocketConnect()
|
{
|
ServerInfo = new IPEndPoint(IPAddress.Parse(barcodeip), 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);
|
Common.WriteLogFile("WcsError", "BarcodeThread/SocketConnect--条码连接失败:" + em.Message);
|
}
|
}
|
|
/// <summary>
|
/// socket重新连接WMS服务器
|
/// </summary>
|
private void SocketReConnect()
|
{
|
if (socket.Connected)
|
{
|
socket.Close();
|
}
|
Thread.Sleep(100);
|
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 em)
|
{
|
Common.WriteLogFile("WcsError", "BarcodeThread/checkSocket--判断条码是否连接失败:" + em.Message);
|
ret = false;
|
}
|
return ret;
|
}
|
#endregion
|
|
/// <summary>
|
/// 获取条码扫描器数据并解析
|
/// </summary>
|
private void GetBarcodeData()
|
{
|
string dataValue = "P", s_RecStr = "";
|
double d_RecStr = 0;
|
try
|
{
|
if (checkSocket() == false)
|
{
|
//调用重连
|
//Common.gs_barcode_data[barcodeno - 1] = "";
|
//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 = "";
|
// 接收主机应答
|
socket.ReceiveTimeout = 60000;
|
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);
|
s_RecStr = s_RecStr.Trim('');
|
if (s_RecStr.IndexOf("NOREAD") >= 0)// || (s_RecStr.Length < 7 && s_RecStr.Length > 0))
|
{
|
//Common.gs_barcode_data[barcodeno - 1] = "";
|
DisplayInfo("【" + DateTime.Now.ToString() + "】条码返回信息：" + s_RecStr);
|
return;
|
}
|
if (s_RecStr.Length < 7)
|
{
|
return;
|
}
|
s_RecStr = s_RecStr.Substring(0, 7);
|
Common.gs_barcode_data[barcodeno - 1] = s_RecStr;
|
//DisplayBarcode(Common.gs_barcode_data[barcodeno - 1]);
|
DisplayInfo("【" + DateTime.Now.ToString() + "】" + Common.gs_barcode_data[barcodeno - 1]);
|
//DisplayInfo("收到消息：" + receiveData);
|
// AnalysisReceive(receiveData); //解析收到的数据
|
// 加入字符串缓存
|
//buff.Append(str);
|
// 再次接受，看看后面还有没有数据.
|
}
|
}
|
else
|
{
|
//Common.gs_barcode_data[barcodeno - 1] = "";
|
DisplayInfo("【" + DateTime.Now.ToString() + "】条码连接已断开，无法读取数据！");
|
}
|
return;
|
}
|
catch(Exception em)
|
{
|
Common.WriteLogFile("WcsError", "BarcodeThread/GetBarcodeData--读取条码数据失败:" + em.Message);
|
//Common.gs_barcode_data[barcodeno - 1] = "";
|
//DisplayInfo("【" + DateTime.Now.ToString() + "】扫描超时:" + t.Message);
|
//Thread.Sleep(400);
|
return;
|
}
|
}
|
|
#region 通讯反馈同步显示
|
/// <summary>
|
/// 显示条码通讯信息
|
/// </summary>
|
/// <param name="text"></param>
|
private void DisplayInfo(string text)
|
{
|
if (barcodedisplay == null)
|
{
|
return;
|
}
|
if (barcodedisplay.InvokeRequired)
|
{
|
try
|
{
|
displayresponse d = new displayresponse(DisplayInfo);
|
barcodedisplay.Invoke(d, new object[] { text });
|
}
|
catch (Exception em)
|
{
|
Common.WriteLogFile("WcsError", "BarcodeThread/DisplayInfo--同步显示条码通讯信息失败:" + em.Message);
|
}
|
}
|
else
|
{
|
if (barcodedisplay.Items.Count > 12)
|
{
|
barcodedisplay.Items.Clear();
|
}
|
barcodedisplay.Items.Add(text);
|
}
|
|
}
|
|
/// <summary>
|
/// 显示条码号
|
/// </summary>
|
/// <param name="text"></param>
|
private void DisplayBarcode(string barcode)
|
{
|
if (lb_barcode == null)
|
{
|
return;
|
}
|
if (lb_barcode.InvokeRequired)
|
{
|
try
|
{
|
SetTextCallback d = new SetTextCallback(DisplayBarcode);
|
lb_barcode.Invoke(d, new object[] { barcode });
|
}
|
catch (Exception em)
|
{
|
Common.WriteLogFile("WcsError", "BarcodeThread/DisplayBarcode--同步显示条码号失败:" + em.Message);
|
}
|
}
|
else
|
{
|
lb_barcode.Text = barcode;
|
}
|
|
}
|
#endregion
|
|
/// <summary>
|
/// 条码主线程
|
/// </summary>
|
private void ThreadTask()
|
{
|
SocketConnect();
|
while (true)
|
{
|
GetBarcodeData();
|
Thread.Sleep(Common.ci_BarcodetimeInterval);
|
}
|
}
|
|
}
|
}
|
