using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Net;
|
using System.Net.Sockets;
|
using System.Windows.Forms;
|
using System.Threading;
|
using System.Net.NetworkInformation;
|
using DevComponents.DotNetBar;
|
using System.Runtime.InteropServices;
|
using System.Data;
|
using com.force.json;
|
//using Sharp7;
|
|
namespace WCS
|
{
|
/// <summary>
|
/// PLCB线程
|
/// </summary>
|
class PlcBThread
|
{
|
//NetworkStream myNetworkStream;
|
//Thread thr = null;
|
delegate void displayresponse(string text);
|
//delegate void displayinseresponse(int val);
|
string recvStr = "";
|
string plcip = "";
|
int plcno = 0;
|
Thread trd = null;
|
int i_plc_step = 0;
|
int plcport = 0;
|
main form1;
|
public static string plc_cmd = "";
|
//delegate void SetTextCallback(string text);
|
delegate void DisplayData(int type, int i);
|
//delegate void DisplayQuereData(int count);
|
delegate void DisplaySendTxtInfo(string info);
|
//delegate void DisplayErrData(int i);
|
//delegate void DisplayDataBuffer(int k);
|
|
#region 画面上同步显示控件
|
public ListView plclist;
|
//public ListView plcbuflist;
|
//public DevComponents.DotNetBar.SuperGrid.SuperGridControl plcbuflist;
|
public ListBox tb;
|
//public LabelX lb_backMsg;
|
//public DevComponents.DotNetBar.LabelX querecount;
|
//public ListView errlist;
|
public LabelX sendtoplc;
|
//public DevComponents.DotNetBar.PanelEx os;
|
//public Panel os;
|
//public Microsoft.VisualBasic.PowerPacks.OvalShape mvpo;
|
#endregion
|
|
private int rack = 0, slot = 1;
|
//S7Client client = new S7Client();
|
|
public PlcBThread(int plc_no, string plc_ip, int port, main f)
|
{
|
try
|
{
|
plcno = plc_no;
|
plcip = plc_ip;
|
plcport = port;
|
form1 = f;
|
|
trd = new Thread(new ThreadStart(this.ThreadTask));
|
trd.IsBackground = true;
|
trd.Start();
|
}
|
catch (Exception em)
|
{
|
Common.WriteLogFile("WcsError", "PlcThread/PlcThread--PLC线程启动出错:" + em.Message);
|
}
|
}
|
|
///// <summary>
|
///// 根据命令字符串判断作业类型
|
///// </summary>
|
//private void CommandStr_nkindstep()
|
//{
|
// int i = 0;
|
// try
|
// {
|
// if (plc_cmd == null || plc_cmd == "")
|
// {
|
// i = 1;
|
// }
|
// else
|
// {
|
// i = Convert.ToInt32(plc_cmd.Substring(0, 2));
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcThread/CommandStr_nkindstep--根据命令字符串判断作业类型出错:" + em.Message);
|
// return;
|
// }
|
// switch (i)
|
// {
|
// case 1:
|
// i_plc_step = 1;
|
// break;
|
// case 2:
|
// i_plc_step = 2;
|
// break;
|
// case 3:
|
// i_plc_step = 3;
|
// break;
|
// case 4:
|
// i_plc_step = 4;
|
// break;
|
// case 5://清buffer
|
// i_plc_step = 5;
|
// break;
|
// case 6://插单
|
// i_plc_step = 6;
|
// break;
|
// default:
|
// i_plc_step = 1;
|
// break;
|
// }
|
//}
|
|
///////////////////////////////////////---------------------------------------读plc中字-----------------------------
|
///// <summary>
|
///// 读PLC id
|
///// </summary>
|
//private void GetStaIdArea()
|
//{
|
// recvStr = "";
|
// var client = new S7Client();
|
// int result = 0;
|
// try
|
// {
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaIdArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// InitStn();
|
// return;
|
// }
|
|
// byte[] dbBuffer = new byte[66];
|
// result = client.DBRead(540, 0, 66, dbBuffer);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】读取PLCB站点ID错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaIdArea--读取站点状态错误：" + client.ErrorText(result));
|
// client.Disconnect();
|
// return;
|
// }
|
// for (int i = 0; i < 33; i++)
|
// {
|
// Common.plc_i_Wrk_no[plcno - 1, i + 30] = S7.GetIntAt(dbBuffer, i * 2);
|
// recvStr = recvStr + Common.plc_i_Wrk_no[plcno - 1, i + 30];
|
// DisplayPLCDataInfo(1, i + 30);
|
// }
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】扫描PLCB ID--" + recvStr);//同步显示
|
// }
|
// catch (Exception em)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】" + plcno + "#读取站点状态失败: " + em.Message);//同步显示
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaIdArea--读取站点状态失败:" + em.Message);
|
// return;
|
// }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
//}
|
|
///// <summary>
|
///// 读取PLC设备状态地址值
|
///// </summary>
|
//private void GetStaStsArea()
|
//{
|
// recvStr = "";
|
// var client = new S7Client();
|
// int result = 0;
|
// try
|
// {
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaStsArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// InitStn();
|
// return;
|
// }
|
|
// byte[] dbBuffer = new byte[66];
|
// result = client.DBRead(540, 200, dbBuffer.Length, dbBuffer);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】读取PLCB站点状态错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaStsArea--读取站点状态错误：" + client.ErrorText(result));
|
// client.Disconnect();
|
// return;
|
// }
|
// for (int i = 0; i < 33; i++)
|
// {
|
// Common.plc_s_autoing[plcno - 1, i + 30] = (S7.GetBitAt(dbBuffer, i * 2, 0) == true) ? "Y" : "N";
|
// Common.plc_s_loading[plcno - 1, i + 30] = (S7.GetBitAt(dbBuffer, i * 2, 1) == true) ? "Y" : "N";
|
// Common.plc_s_inreq1[plcno - 1, i + 30] = (S7.GetBitAt(dbBuffer, i * 2, 2) == true) ? "Y" : "N";
|
// Common.plc_s_inreq2[plcno - 1, i + 30] = (S7.GetBitAt(dbBuffer, i * 2, 3) == true) ? "Y" : "N";
|
// if (S7.GetBitAt(dbBuffer, i * 2, 4) == true) //高库位
|
// {
|
// Common.plc_s_loctype[plcno - 1, i + 30] = "Y";
|
// }
|
// else if (S7.GetBitAt(dbBuffer, i * 2, 5) == true) //低库位
|
// {
|
// Common.plc_s_loctype[plcno - 1, i + 30] = "N";
|
// }
|
// else
|
// {
|
// Common.plc_s_loctype[plcno - 1, i + 30] = "0";
|
// }
|
|
// if (Common.plc_s_loading[plcno - 1, i + 30] == "N" && Common.plc_i_Wrk_no[plcno - 1, i + 30] == 0)
|
// {
|
// Common.plc_i_pakmk[plcno - 1, i + 30] = 0;
|
// }
|
|
// recvStr = recvStr + Common.plc_s_autoing[plcno - 1, i + 30] + Common.plc_s_loading[plcno - 1, i + 30]
|
// + Common.plc_s_inreq1[plcno - 1, i + 30];// +Common.plc_s_inreq2[plcno - 1, i + 30];// +Common.plc_s_loctype[plcno - 1, i + 30];
|
// DisplayPLCDataInfo(2, i + 30);
|
// }
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】扫描PLCB 状态--" + recvStr);
|
// }
|
// catch (Exception em)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】" + plcno + "#读取站点状态失败: " + em.Message);//同步显示
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaStsArea--读取站点状态失败:" + em.Message);
|
// return;
|
// }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
//}
|
|
///// <summary>
|
///// 分析站点各状态
|
///// </summary>
|
///// <param name="i">站点序列</param>
|
///// <param name="num">状态值</param>
|
//private void AnalyseStaStatus1(int i, int num)
|
//{
|
// try
|
// {
|
// if (Common.fun_ChkAndByte(num, Common.ch_d1) == true)
|
// {
|
// Common.plc_s_autoing[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_autoing[plcno - 1, i] = "N";
|
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d2) == true)
|
// {
|
// Common.plc_s_loading[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_loading[plcno - 1, i] = "N";
|
// //出现过无物情况清除plc_i_pakmk标记，通过判断plc_i_pakmk标记，防止重复下指令
|
// Common.plc_i_pakmk[plcno - 1, i] = 0;
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d3) == true)
|
// {
|
// Common.plc_s_canining[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_canining[plcno - 1, i] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d4) == true)
|
// {
|
// Common.plc_s_canouting[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_canouting[plcno - 1, i] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d5) == true)
|
// {
|
// Common.plc_s_inreq1[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_inreq1[plcno - 1, i] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d6) == true)
|
// {
|
// Common.plc_s_inreq2[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_inreq2[plcno - 1, i] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d7) == true)
|
// {
|
// Common.plc_s_loctype[plcno - 1, i] = "Y";
|
// }
|
// else
|
// {
|
// Common.plc_s_loctype[plcno - 1, i] = "N";
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcThread/AnalyseStaStatus1--扫描站点状态字失败:" + em.Message);
|
// }
|
//}
|
|
//#region 站点异常
|
///// <summary>
|
///// 得到设备异常
|
///// </summary>
|
//private void GetStaErrArea1()
|
//{
|
// recvStr = "";
|
// var client = new S7Client();
|
// int result = 0;
|
// try
|
// {
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaStsArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// InitStn();
|
// return;
|
// }
|
|
// byte[] dbBuffer = new byte[68];
|
// result = client.DBRead(53, 0, dbBuffer.Length, dbBuffer);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】读取PLCA设备异常失败：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcAThread/GetStaErrArea1--读取设备异常失败：" + client.ErrorText(result));
|
// return;
|
// }
|
|
// for (int i = 0; i < 35; i++)
|
// {
|
// if (i == 0)
|
// {
|
// Common.plcerr[i + 128] = (S7.GetBitAt(dbBuffer, i, 0) == true) ? "Y" : "N";
|
// Common.plcerr[i + 129] = (S7.GetBitAt(dbBuffer, i, 1) == true) ? "Y" : "N";
|
// Common.plcerr[i + 130] = (S7.GetBitAt(dbBuffer, i, 2) == true) ? "Y" : "N";
|
// Common.plcerr[i + 131] = (S7.GetBitAt(dbBuffer, i, 3) == true) ? "Y" : "N";
|
// Common.plcerr[i + 132] = (S7.GetBitAt(dbBuffer, i, 4) == true) ? "Y" : "N";
|
// Common.plcerr[i + 133] = (S7.GetBitAt(dbBuffer, i, 7) == true) ? "Y" : "N";
|
// }
|
// if (i == 1)
|
// {
|
// Common.plcerr[134] = (S7.GetBitAt(dbBuffer, i, 0) == true) ? "Y" : "N";
|
// }
|
// if (i > 1)
|
// {
|
// Common.plcerr[i * 4 + 127] = (S7.GetBitAt(dbBuffer, i * 2 - 2, 0) == true) ? "Y" : "N";
|
// Common.plcerr[i * 4 + 128] = (S7.GetBitAt(dbBuffer, i * 2 - 2, 1) == true) ? "Y" : "N";
|
// Common.plcerr[i * 4 + 129] = (S7.GetBitAt(dbBuffer, i * 2 - 2, 2) == true) ? "Y" : "N";
|
// Common.plcerr[i * 4 + 130] = (S7.GetBitAt(dbBuffer, i * 2 - 2, 3) == true) ? "Y" : "N";
|
// }
|
// }
|
// //DisplayInfo("【" + DateTime.Now.ToString() + "】扫描PLCA 状态--" + recvStr);
|
// }
|
// catch (Exception em)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】" + plcno + "#读取设备异常失败: " + em.Message);//同步显示
|
// Common.WriteLogFile("WcsError", "PlcAThread/GetStaStsArea--读取设备异常失败:" + em.Message);
|
// return;
|
// }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
//}
|
|
///// <summary>
|
///// 分析站点异常
|
///// </summary>
|
///// <param name="i">站点序列</param>
|
///// <param name="num">异常值</param>
|
//private void AnalyseStaErr1(int i, int num)
|
//{
|
// try
|
// {
|
// if (Common.fun_ChkAndByte(num, Common.ch_d1) == true)
|
// {
|
// Common.plcerr[i * 16 + 0] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 0] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d2) == true)
|
// {
|
// Common.plcerr[i * 16 + 1] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 1] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d3) == true)
|
// {
|
// Common.plcerr[i * 16 + 2] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 2] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d4) == true)
|
// {
|
// Common.plcerr[i * 16 + 3] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 3] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d5) == true)
|
// {
|
// Common.plcerr[i * 16 + 4] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 4] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d6) == true)
|
// {
|
// Common.plcerr[i * 16 + 5] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 5] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d7) == true)
|
// {
|
// Common.plcerr[i * 16 + 6] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 6] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d8) == true)
|
// {
|
// Common.plcerr[i * 16 + 7] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 7] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d9) == true)
|
// {
|
// Common.plcerr[i * 16 + 8] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 8] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d10) == true)
|
// {
|
// Common.plcerr[i * 16 + 9] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 9] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d11) == true)
|
// {
|
// Common.plcerr[i * 16 + 10] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 10] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d12) == true)
|
// {
|
// Common.plcerr[i * 16 + 11] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 11] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d13) == true)
|
// {
|
// Common.plcerr[i * 16 + 12] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 12] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d14) == true)
|
// {
|
// Common.plcerr[i * 16 + 13] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 13] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d15) == true)
|
// {
|
// Common.plcerr[i * 16 + 14] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 14] = "N";
|
// }
|
// if (Common.fun_ChkAndByte(num, Common.ch_d16) == true)
|
// {
|
// Common.plcerr[i * 16 + 15] = "Y";
|
// }
|
// else
|
// {
|
// Common.plcerr[i * 16 + 15] = "N";
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcThread/AnalyseStaErr1--分析站点字异常失败:" + em.Message);
|
// }
|
//}
|
//#endregion
|
|
///// <summary>
|
///// 读取PLC目标站地址值
|
///// </summary>
|
//private void GetStaDestArea()
|
//{
|
// recvStr = "";
|
// var client = new S7Client();
|
// int result = 0;
|
// try
|
// {
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaDestArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// InitStn();
|
// return;
|
// }
|
|
// byte[] dbBuffer = new byte[66];
|
// result = client.DBRead(540, 100, 66, dbBuffer);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】读取PLCB目标站错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaDestArea--读取目标站错误：" + client.ErrorText(result));
|
// client.Disconnect();
|
// return;
|
// }
|
// for (int i = 0; i < 33; i++)
|
// {
|
// Common.plc_s_next_stn[plcno - 1, i + 30] = S7.GetIntAt(dbBuffer, i * 2).ToString();
|
// recvStr = recvStr + Common.plc_s_next_stn[plcno - 1, i + 30];
|
// DisplayPLCDataInfo(3, i + 30);
|
// }
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】扫描PLCB 目标站--" + recvStr);//同步显示
|
|
// ///////////////////PLC读取托盘条码/////////////////////////////
|
// recvStr = "";
|
// byte[] dbBuffer1 = new byte[4];
|
// result = client.DBRead(540, 300, dbBuffer1.Length, dbBuffer1);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】读取PLCB条码数据错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetBarcodeData--读取条码数据错误：" + client.ErrorText(result));
|
// client.Disconnect();
|
// return;
|
// }
|
// for (int i = 0; i < 1; i++)
|
// {
|
// //long kk = ;
|
// Common.gs_barcode_data[2] = S7.GetDIntAt(dbBuffer1, i * 4).ToString();
|
// //Common.plc_s_next_stn[plcno - 1, i] = S7.GetIntAt(dbBuffer, i * 2).ToString();
|
// recvStr = recvStr + (i + 1) + "站:" + Common.gs_barcode_data[2] + "; ";
|
// DisplayPLCDataInfo(3, i + 30);
|
// }
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】扫描PLCB 条码数据--" + recvStr);//同步显示
|
// //////////////////////////////////////////////////////////////
|
// }
|
// catch (Exception em)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】" + plcno + "#读取目标站失败: " + em.Message);//同步显示
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStaDestArea--读取目标站失败:" + em.Message);
|
// return;
|
// }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
//}
|
|
///// <summary>
|
///// 根据命令判断写PLC类型
|
///// </summary>
|
///// <param name="cmd"></param>
|
//private void WriteStaArea(string cmd)
|
//{
|
// int type = 0, stn = 0, dest = 0, id = 0, i_startadd = 0;
|
// bool bl = false;
|
// try
|
// {
|
// type = Int32.Parse(cmd.Substring(0, 2));
|
// id = Int32.Parse(cmd.Substring(2, 4));
|
// stn = Int32.Parse(cmd.Substring(6, 4));
|
// dest = Int32.Parse(cmd.Substring(10, 4));
|
// //p_TcpClient_plc.Active:=true;
|
// ////20100810修改统一格式
|
// //类型
|
// switch (type)
|
// {
|
// case 2:
|
// //写ID
|
// i_startadd = Common.g_ari_station_idaddr[Common.GetStnSeq(stn)];
|
// //bl = WriteAddr(i_startadd, id, dest, 2);
|
// bl = WriteAddr(Common.GetStnSeq(stn), id, dest, 2);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (bl)
|
// {
|
// plc_cmd = "";
|
// }
|
// break;
|
// case 3:
|
// //写目标
|
// i_startadd = Common.g_ari_station_destaddr[Common.GetStnSeq(stn)];
|
// //bl = WriteAddr(i_startadd, id, dest, 3);
|
// bl = WriteAddr(Common.GetStnSeq(stn), id, dest, 3);
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
// if (bl)
|
// {
|
// plc_cmd = "";
|
// }
|
// break;
|
// case 4:
|
// //写ID
|
// i_startadd = Common.g_ari_station_idaddr[Common.GetStnSeq(stn)];
|
// //bl = WriteAddr(i_startadd, id, dest, 4);
|
// bl = WriteAddr(Common.GetStnSeq(stn), id, dest, 4);
|
|
// //Thread.Sleep(Common.ci_PLCtimeInterval);
|
|
// if (bl)
|
// {
|
// ////写目标
|
// //i_startadd = Common.g_ari_station_destaddr[Common.GetStnSeq(stn)];
|
// //bool bl1 = WriteAddr(i_startadd, dest);
|
// ////Thread.Sleep(200);
|
// //if (bl1)
|
// //{
|
// plc_cmd = "";
|
// //}
|
// }
|
// break;
|
// case 5:
|
// //清除空栈板出库需求信号
|
// var client = new S7Client();
|
// int result = 0;
|
// try
|
// {
|
// int pos = 0;
|
// if (id == 1) //需求出信号
|
// {
|
// i_startadd = 216;
|
// pos = 3;
|
// }
|
// else //需求入信号
|
// {
|
// i_startadd = 208;
|
// pos = 2;
|
// }
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/WriteAddr--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// return;
|
// }
|
|
// byte[] dbBuffer = new byte[2];
|
// S7.SetBitAt(ref dbBuffer, 0, pos, false);
|
// //S7.SetIntAt(dbBuffer, 0, 0);
|
// result = client.DBWrite(540, i_startadd, dbBuffer.Length, dbBuffer);
|
// if (result == 0)
|
// {
|
// plc_cmd = "";
|
// }
|
// else
|
// {
|
// client.Disconnect();
|
// }
|
// }
|
// catch (Exception)
|
// { }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
// //Thread.Sleep(200);
|
|
// break;
|
// case 6:
|
// //清空信号
|
// //Thread.Sleep(200);
|
// plc_cmd = "";
|
// break;
|
// default:
|
// break;
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/WriteStaArea--写PLC错误:" + em.Message);
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】写PLC错误:" + em.Message);//同步显示
|
// return;
|
// }
|
//}
|
|
///// <summary>
|
///// 写PLC地址值
|
///// </summary>
|
///// <param name="pos"></param>
|
///// <param name="id"></param>
|
//private bool WriteAddr(int pos, int id, int dest, int type)
|
//{
|
// bool bl = false;
|
// var client = new S7Client();
|
// bool ok = false;
|
// int icount = 0;
|
// try
|
// {
|
// int result = -1;
|
// result = client.ConnectTo(plcip, rack, slot);
|
// if (result != 0)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// Common.WriteLogFile("WcsError", "PlcBThread/WriteAddr--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// return bl;
|
// }
|
|
// byte[] dbBuffer = new byte[2];
|
// byte[] dbBuffer1 = new byte[2];
|
// if (type == 2 || type == 4)
|
// {
|
// S7.SetIntAt(dbBuffer, 0, (short)id);
|
// }
|
// if (type == 3 || type == 4)
|
// {
|
// S7.SetIntAt(dbBuffer1, 0, (short)dest);
|
// }
|
|
// var s7MultiVar = new S7MultiVar(client);
|
// //s7MultiVar.Add(S7Consts.S7AreaDB, S7Consts.S7WLByte, 540, Common.g_ari_station_idaddr[pos], dbBuffer.Length, ref dbBuffer);
|
// //s7MultiVar.Add(S7Consts.S7AreaDB, S7Consts.S7WLByte, 540, Common.g_ari_station_destaddr[pos], dbBuffer1.Length, ref dbBuffer1);
|
// do //如果失败，尝试下发3次
|
// {
|
// if (type == 2 || type == 4)
|
// {
|
// s7MultiVar.Add(S7Consts.S7AreaDB, S7Consts.S7WLByte, 540, Common.g_ari_station_idaddr[pos], dbBuffer.Length, ref dbBuffer);
|
// //result = client.DBWrite(540, Common.g_ari_station_idaddr[pos], dbBuffer.Length, dbBuffer);
|
// }
|
// if (type == 3 || type == 4)
|
// {
|
// s7MultiVar.Add(S7Consts.S7AreaDB, S7Consts.S7WLByte, 540, Common.g_ari_station_destaddr[pos], dbBuffer1.Length, ref dbBuffer1);
|
// //result = client.DBWrite(540, Common.g_ari_station_destaddr[pos], dbBuffer1.Length, dbBuffer1);
|
// }
|
// result = -1;
|
// if (Common.writeFlag)
|
// {
|
// Common.writeFlag = false;
|
// result = s7MultiVar.Write();
|
// Thread.Sleep(100);
|
// //result = s7MultiVar.Write();
|
// Common.WriteLogFile("PLCBCmd", "PlcBThread/PLC命令:" + plc_cmd + ";结果：" + result);
|
// Common.writeFlag = true;
|
// }
|
// if (result == 0)
|
// {
|
// bl = true;
|
// ok = true;
|
// }
|
// else
|
// {
|
// icount++;
|
// if (icount >= 5)
|
// {
|
// ok = true;
|
// }
|
// else
|
// {
|
// Thread.Sleep(Common.ci_PLCtimeInterval);
|
// }
|
// }
|
// } while (ok == false);
|
// }
|
// catch (Exception em)
|
// {
|
// DisplayInfo("【" + DateTime.Now.ToString() + "】" + plcno + "#写PLCB地址失败: " + em.Message);//同步显示
|
// Common.WriteLogFile("WcsError", "PlcBThread/WriteAddr--写PLCB地址失败:" + em.Message);
|
// return bl;
|
// }
|
// finally
|
// {
|
// client.Disconnect();
|
// }
|
// return bl;
|
//}
|
|
///// <summary>
|
///// 根据ascii码值得到对应字符
|
///// </summary>
|
///// <param name="asciiCode">ascii码</param>
|
///// <returns>返回对应字符</returns>
|
//public string GetStringByASCII(int asciiCode)
|
//{
|
// try
|
// {
|
// if (asciiCode >= 0 && asciiCode <= 127)
|
// {
|
// System.Text.ASCIIEncoding asciiEncoding = new System.Text.ASCIIEncoding();
|
// byte[] byteArray = new byte[] { (byte)asciiCode };
|
// string strCharacter = asciiEncoding.GetString(byteArray);
|
// return (strCharacter);
|
// }
|
// else if (asciiCode >= 128 && asciiCode <= 255)
|
// {
|
// System.Text.ASCIIEncoding asciiEncoding = new System.Text.ASCIIEncoding();
|
// byte[] byteArray = new byte[] { (byte)(asciiCode + 65536) };
|
// string strCharacter = Encoding.Default.GetString(byteArray);
|
// return (strCharacter);
|
// }
|
// else
|
// {
|
// throw new Exception("无效的ASCII码!");
|
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/GetStringByASCII--ASCII转字符串错误:" + em.Message);
|
// return "";
|
// }
|
//}
|
|
//#region 画面同步显示
|
///// <summary>
|
///// 同步显示plc通讯信息
|
///// </summary>
|
///// <param name="text">扫描信息</param>
|
///// <param name="memo">备注信息</param>
|
//private void DisplayInfo(string text)
|
//{
|
// if (tb.InvokeRequired)
|
// {
|
// try
|
// {
|
// displayresponse d = new displayresponse(DisplayInfo);
|
// tb.Invoke(d, new object[] { text });
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/DisplayInfo--同步显示plc通讯信息错误:" + em.Message);
|
// }
|
// }
|
// else
|
// {
|
// if (tb.Items.Count > 50)
|
// {
|
// tb.Items.Clear();
|
// }
|
// tb.Items.Add(text);
|
// tb.TopIndex = tb.Items.Count - (int)(tb.Height / tb.ItemHeight);
|
// }
|
|
//}
|
|
///// <summary>
|
///// 同步显示站点的状态
|
///// </summary>
|
///// <param name="type">类别</param>
|
///// <param name="k">序号</param>
|
//private void DisplayPLCDataInfo(int type, int k)
|
//{
|
// if (plclist.InvokeRequired)
|
// {
|
// try
|
// {
|
// DisplayData d = new DisplayData(DisplayPLCDataInfo);
|
// plclist.Invoke(d, new object[] { type, k });
|
// plclist.Focus();
|
// //plclist.Update();
|
// //plclist.Refresh();
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/DisplayPLCDataInfo--同步显示站点状态错误:" + em.Message);
|
// }
|
// }
|
// else
|
// {
|
// if (type == 1)
|
// {
|
// this.plclist.Items[k].SubItems[1].Text = Common.plc_i_Wrk_no[plcno - 1, k].ToString();
|
// }
|
// else if (type == 2)
|
// {
|
// //if (k == 8 || k == 11) return;
|
// this.plclist.Items[k].SubItems[2].Text = Common.plc_s_autoing[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[3].Text = Common.plc_s_loading[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[4].Text = Common.plc_s_canining[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[5].Text = Common.plc_s_canouting[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[6].Text = Common.plc_s_inreq1[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[7].Text = Common.plc_s_inreq2[plcno - 1, k].ToString();
|
// this.plclist.Items[k].SubItems[8].Text = Common.plc_s_loctype[plcno - 1, k].ToString();
|
// //this.plclist.Items[k].SubItems[9].Text = Class1.plc_s_loctype[plcno - 1, k].ToString();
|
// }
|
// else if (type == 3)
|
// {
|
// this.plclist.Items[k].SubItems[9].Text = Common.plc_s_next_stn[plcno - 1, k].ToString();
|
// }
|
|
// }
|
//}
|
|
///// <summary>
|
///// 更新PLC命令信息到界面显示
|
///// </summary>
|
///// <param name="count">队列数</param>
|
//private void DisplayQuerecmd(string info)
|
//{
|
// try
|
// {
|
// if (sendtoplc.InvokeRequired)
|
// {
|
// DisplaySendTxtInfo d = new DisplaySendTxtInfo(DisplayQuerecmd);
|
// sendtoplc.Invoke(d, new object[] { info });
|
// }
|
// else
|
// {
|
// sendtoplc.Text = info.ToString();
|
// }
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/DisplayQuerecmd--更新PLC命令信息到界面错误:" + em.Message);
|
// }
|
//}
|
//#endregion
|
|
///// <summary>
|
///// 通讯失败后初始化站点状态
|
///// </summary>
|
//private void InitStn()
|
//{
|
// try
|
// {
|
// for (int i = 0; i < 33; i++)
|
// {
|
// Common.plc_s_autoing[1, i + 30] = "N";
|
// Common.plc_s_loading[1, i + 30] = "N";
|
// Common.plc_s_canining[1, i + 30] = "N";
|
// Common.plc_s_canouting[1, i + 30] = "N";
|
// Common.plc_s_inreq1[1, i + 30] = "N";
|
// Common.plc_s_inreq2[1, i + 30] = "N";
|
// Common.plc_s_loctype[1, i + 30] = "0";
|
// Common.plc_s_error[1, i + 30] = "N";
|
// Common.plc_i_buff_count[1, i + 30] = 0;
|
// Common.plc_i_Wrk_no[1, i + 30] = 0;
|
// Common.plc_s_stn_status[1, i + 30] = "N";
|
// Common.plc_s_next_stn[1, i + 30] = "0";
|
// //Common.plc_i_pakmk[1, i + 30] = 0;
|
// }
|
// }
|
// catch (Exception)
|
// { }
|
//}
|
|
//#region 注释
|
/////// <summary>
|
/////// 同步显示站点buffer
|
/////// </summary>
|
/////// <param name="type">类别</param>
|
/////// <param name="k">序号</param>
|
////private void DisplayBuffer(int k)
|
////{
|
//// if (plcbuflist.InvokeRequired)
|
//// {
|
//// try
|
//// {
|
//// DisplayDataBuffer d = new DisplayDataBuffer(DisplayBuffer);
|
//// plcbuflist.Invoke(d, new object[] { k});
|
//// }
|
//// catch (Exception r)
|
//// {
|
|
//// }
|
//// }
|
//// else
|
//// {
|
//// this.plcbuflist.Items[0].SubItems[k].Text = Common.gi_stabuffer[k].ToString();
|
//// }
|
|
////}
|
|
///// <summary>
|
///// 同步显示站点的状态
|
///// </summary>
|
///// <param name="type">类别</param>
|
///// <param name="k">序号</param>
|
|
/////// <summary>
|
/////// 同步显示队列数
|
/////// </summary>
|
/////// <param name="count">队列数</param>
|
////private void DisplayQuereCount(int count)
|
////{
|
//// try
|
//// {
|
//// if (querecount.InvokeRequired)
|
//// {
|
//// DisplayQuereData d = new DisplayQuereData(DisplayQuereCount);
|
//// querecount.Invoke(d, new object[] { count });
|
//// }
|
//// else
|
//// {
|
//// querecount.Text = count.ToString();
|
//// }
|
//// }
|
//// catch (Exception t)
|
//// {
|
|
//// }
|
////}
|
//#endregion
|
|
/// <summary>
|
/// PLC主线程
|
/// </summary>
|
private void ThreadTask()
|
{
|
////int result = client.ConnectTo(plcip, rack, slot);
|
////if (result != 0)
|
////{
|
//// DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
//// Common.WriteLogFile("WcsError", "PlcBThread/GetStaIdArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
//// InitStn();
|
//// //return;
|
////}
|
|
//while (true)
|
//{
|
// //if (client.Connected)
|
// //{
|
// try
|
// {
|
// //DisplayQuereCount(Common.GetPlcQuereCount(plcno - 1));
|
// //if (Common.PlcBQueue.Count > 0 && plc_cmd == "")
|
// //{
|
// // plc_cmd = Common.PlcBQueue.Dequeue();
|
// //}
|
// if (Common.GetPlcQuereCount(plcno - 1) > 0 && plc_cmd == "")
|
// {
|
// plc_cmd = Common.GetPlcQuereCmd(plcno - 1);
|
// }
|
// DisplayQuerecmd(plc_cmd);
|
// CommandStr_nkindstep();
|
// switch (i_plc_step)
|
// {
|
// case 1:
|
// GetStaIdArea(); //读ID
|
// GetStaStsArea(); //读状态
|
// GetStaDestArea(); //读目标站
|
// GetStaErrArea1(); //读设备异常
|
// break;
|
// case 2://写id
|
// WriteStaArea(plc_cmd);
|
// break;
|
// case 3://写目标
|
// WriteStaArea(plc_cmd);
|
// break;
|
// case 4://写iD和目标
|
// WriteStaArea(plc_cmd);
|
// break;
|
// case 5://清buffer
|
// WriteStaArea(plc_cmd);
|
// break;
|
// case 6://插单
|
// WriteStaArea(plc_cmd);
|
// //WriteStaBuffer();
|
// break;
|
// }
|
// i_plc_step = 1;
|
// Thread.Sleep(Common.ci_PLCtimeInterval);
|
// }
|
// catch (Exception em)
|
// {
|
// Common.WriteLogFile("WcsError", "PlcBThread/ThreadTask--PLC主线程循环错误:" + em.Message);
|
// }
|
// //}
|
// //else
|
// //{
|
// // client.Disconnect();
|
// // result = client.ConnectTo(plcip, rack, slot);
|
// // if (result != 0)
|
// // {
|
// // DisplayInfo("【" + DateTime.Now.ToString() + "】连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// // Common.WriteLogFile("WcsError", "PlcBThread/GetStaIdArea--连接PLC " + plcip + "错误：" + client.ErrorText(result));
|
// // InitStn();
|
// // }
|
// //}
|
//}
|
|
}
|
|
}
|
|
}
|
