bianzhi
/
DTJA_WCS_PRODUCT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
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.
2 Commits
1 Branch
0 Tags
7.0 MiB
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
DTJA_WCS_PRODUCT/OPCClient/CCommonOPCClient.cs

1808 lines
100 KiB
Raw Permalink Normal View History

添加项目文件。
3 months ago
using System;
using System.Collections.Generic;
using System.Text;
using Opc.Ua;
using Opc.Ua.Client;
using System.Data;
using DBFactory;
using CommonLib;
using Siemens.OpcUA;
using CommLayerFactory;
using ICommLayer;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
using System.Text.RegularExpressions;
namespace OPCClient
{
public class WorkItem
{
public object Parameter1 { get; set; }
public DataValue Parameter2 { get; set; }
// �������Ӹ��������ԺͲ���
public WorkItem(object param1, DataValue param2)
{
Parameter1 = param1;
Parameter2 = param2;
}
}
public static class CCommonOPCClient
{
static Model.MDevice _device = null;
private static ushort S7NameSpace = 2;//20151120��Ĭ��ֵ��32λϵͳ��ֵ2��64λϵͳ��ֵ��3
private static Model.MDevice devinfo;
private static Object thisLock = new Object();
static ISendDeviceOrder sdo;
static Model.MDevice modifypathdevinfo;
static Model.MDevice askDevinfo;
static StringBuilder[] wv = { new StringBuilder("2") };
static StringBuilder[] witemnames = { new StringBuilder("") };
/// <summary>
/// һ��������һ�������鷢�����б�ǩ�ĸ���
/// </summary>
static Dictionary<string, int> _opcSubsTagCount = new Dictionary<string, int>();
/// <summary>
/// ÿ������������Ӧ�豸���ͱ�ǩ���Ƽ���
/// </summary>
static Dictionary<string, Dictionary<int, StringBuilder[]>> _opcItemNamesDicInfo = new Dictionary<string, Dictionary<int, StringBuilder[]>>();
/// <summary>
/// ÿ������������Ӧ�豸���ͱ�ǩ��ֵ����
/// </summary>
static Dictionary<string, Dictionary<int, StringBuilder[]>> _opcItemValuesDicInfo = new Dictionary<string, Dictionary<int, StringBuilder[]>>();
public static event RefreshMonitorEventHandler RefreshMonitor;
public static void OnRefreshMonitor(RefreshMonitorEventArgs e)
{
if (RefreshMonitor != null)
{
RefreshMonitor(e);
}
}
public static event CUpdateDBEventHandler DealSQLExe;
public static void OnDealSQLExe(object sender, CUpdateDBChangeEventArgs e)
{
DealSQLExe?.Invoke(sender, e);
}
public static event CUpdateDBEventHandler PublishDeviceState;
public static void OnPublishDeviceState(object sender,CUpdateDBChangeEventArgs e)
{
PublishDeviceState?.Invoke(sender, e);
}
public static DBOperator dbo =new DBOperator(); //20130510
//20110726
private static Dictionary<string, int> _connectCount = new Dictionary<string, int>();
//20110726
public static Dictionary<string, int> ConnectCount
{
get { return CCommonOPCClient._connectCount; }
set { CCommonOPCClient._connectCount = value; }
}
private static int[] _plcStates=null ;
public static int[] PlcStates
{
get { return CCommonOPCClient._plcStates; }
//set { CCommonOPCClient._plcStates = value; }
}
private static Server m_Server = null;
private static Siemens.OpcUA.Subscription m_Subscription;
public static BlockingCollection<WorkItem> buffer = new BlockingCollection<WorkItem>();
private static Task pollingTask = Task.Run(() => PollMethod());
/// <summary>
/// 20110309���ĵ����ڱ�ǩ���ݱ仯�¼�
/// </summary>
/// <param name="subscriptionHandle">�ͻ��˾���</param>
/// <param name="requestHandle">��������</param>
/// <param name="values">��ǩֵ����</param>
public static void OnDataChange(object clientHandle, DataValue value)
{
buffer.Add(new WorkItem(clientHandle, value));
}
public static void kkkk()
{
if (buffer.Count > 0)
{
foreach (WorkItem item in buffer.GetConsumingEnumerable())
{
lock (thisLock)
{
//����subscriptionHandle��Ӧ�豸�����������豸���ࣨ��ͬ�����豸ͨѶ����֡��ͬ��
//�ֱ����������ɣ����������翪�أ�PLC����������
int deviceindex = 0;
try
{
if (item.Parameter1.ToString().IndexOf("split") >= 0)
{
deviceindex = System.Convert.ToInt32(item.Parameter1.ToString().Substring(5));
}
else
{
deviceindex = System.Convert.ToInt32(item.Parameter1);
}
devinfo = Model.CGetInfo.GetDeviceInfo(deviceindex);
if (StatusCode.IsNotGood(item.Parameter2.StatusCode))
{
if (devinfo == null)
{
OpcError = string.Format("�豸����{0}�����ݿⲻ���ڣ�", item.Parameter1);
return;
}
//����һ�������¼���ʾPLC�Ͽ�����
if (ConnectCount.ContainsKey(devinfo.S7Connection) == false)//20110726
{
ConnectCount.Add(devinfo.S7Connection, 0);
}
OpcError = string.Format("{0}���ڵ�PLC�Ѿ����ߣ����ı�ǩ״̬��" + item.Parameter2.StatusCode.ToString(), item.Parameter1);
if (ConnectCount[devinfo.S7Connection] > 3)//20150204
{
_opcError = "���ķ�������ʱ��OPC Serverû���ӵ�PLC:" + devinfo.S7Connection.ToString() + "���˹�ȷ�Ϻ����С�PLC��ʼ����";//20150204
return;
}
ConnectCount[devinfo.S7Connection]++;//20150204
return;
}
ConnectCount[devinfo.S7Connection] = 0;
if (item.Parameter1.ToString().IndexOf("split") >= 0)
{
Array arr = (Array)item.Parameter2.Value;
byte[] GDKG = null;
GDKG = new byte[arr.GetLength(0)];
Array.Copy(arr, GDKG, arr.GetLength(0));
#region �������ķ��ع��翪������
DealWithDeviceState(out string errText, deviceindex, GDKG, null);
#endregion
}
else
{
Array arr = (Array)item.Parameter2.Value;
byte[] itemnamevalue = new byte[arr.GetLength(0)];
Array.Copy(arr, itemnamevalue, arr.GetLength(0));
int head = 0;
head = itemnamevalue[0];//��д��־
#region �������ķ���״̬���ݣ����������߳̿ɶ��ĵ��¼�
DealWithDeviceState(out string errText, deviceindex, null, itemnamevalue);
#endregion
}
}
catch (Exception ex)
{//20120420
OpcError = string.Format("OPC�����������¼��쳣��{0},{1}", ex.Message, ex.StackTrace);
}
}
}
}
}
static void PollMethod()
{
while (true) // ����ѭ����ģ����ѯ
{
// ��������������ѯ�߼�
kkkk();
// ����һ��ʱ�䣬����1��
Thread.Sleep(1000);
}
}
static bool DealWithDeviceState(out string errtext, int deviceindex, byte[] splitbyteValue, byte[] devicestates)
{//deviceindex�豸�������Ķ��ģ����Ȱ��豸�鰴��F_DBW2Address��С�������򣬲��ֵ�����ÿ���豸
//20230811richard.liu�����ڰ�S7�����������ͣ��ع�CControl.cs��CCommonOPCClient.cs\DealWithDeviceState;�ļ���Communication��Common��ͨѶCSendDeviceOrder: ISendDeviceOrder�����ļ�
lock (thisLock)
{
_opcSubsTagCount.Clear();
_opcItemNamesDicInfo.Clear();
_opcItemValuesDicInfo.Clear();
Dictionary<int, StringBuilder> DeviceStateInfos=new Dictionary<int, StringBuilder>();
errtext = string.Empty;
DataView dvDevice = new DataView();//device�����豸��Ϣ
DataView dvPLCASK = new DataView();//PLCASK�����ݲ��ܸ���
DataView dvbc = new DataView();//��ʱ����������
int devicebegin = 0; int DBW2Addressbegin = 0; string S7Connection = string.Empty;//int SplitBytebegin = 0;
int SplitByteLength = 0;
try
{
StringBuilder sql = new StringBuilder(string.Format("SELECT F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_SplitByte,F_S7Connection FROM T_Base_Device WHERE f_controldevice='1' and (F_DeviceKindIndex !=33) AND (F_ReadSubscription = '{0}') AND (F_DBW2Address IS NOT NULL) ORDER BY F_DBW2Address", deviceindex));//20151120�������ֶ��Ƿ���Ҫ�����˴����豸�Ķ���
dvDevice = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
if (dvDevice.Count > 0)
{//��������һ���豸���豸�����Ƕ�����ID
devicebegin = Convert.ToInt32(dvDevice[0]["F_DeviceIndex"]);
DBW2Addressbegin = Convert.ToInt32(dvDevice[0]["F_DBW2Address"]);
//SplitBytebegin = Convert.ToInt32(dvDevice[0]["F_SplitByte"]);
S7Connection = dvDevice[0]["F_S7Connection"].ToString();
//sql.Clear();
//sql.Append(string.Format("SELECT F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_SplitByte,F_S7Connection FROM T_Base_Device WHERE (F_DeviceKindIndex =33) AND (F_ReadSubscription = '{0}') ORDER BY F_DBW2Address", deviceindex));
//dvPLCASK = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
//if (dvPLCASK.Count > 0)
//{
// SplitByteLength = Convert.ToInt32(dvPLCASK[0]["F_DBWGetLength"]);
//}
}
else
{//�Ƕ�������һ���豸
sql = new StringBuilder(string.Format("SELECT F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_SplitByte,F_S7Connection FROM T_Base_Device WHERE (F_DeviceIndex = '{0}') AND (F_DBW2Address IS NOT NULL) ORDER BY F_DBW2Address", deviceindex));
dvDevice = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
if (dvDevice.Count > 0)
{
devicebegin = Convert.ToInt32(dvDevice[0]["F_DeviceIndex"]);
DBW2Addressbegin = Convert.ToInt32(dvDevice[0]["F_DBW2Address"]);
//SplitBytebegin = Convert.ToInt32(dvDevice[0]["F_SplitByte"]);
S7Connection = dvDevice[0]["F_S7Connection"].ToString();
sql = new StringBuilder(string.Format("SELECT F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_SplitByte,F_S7Connection FROM T_Base_Device WHERE (F_DeviceKindIndex =33) AND (F_ReadSubscription = '{0}') ORDER BY F_DBW2Address", deviceindex));
dvPLCASK = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
if (dvPLCASK.Count > 0)
{
SplitByteLength = Convert.ToInt32(dvPLCASK[0]["F_DBWGetLength"]);
}
}
else
{//20120420
RefreshMonitorEventArgs rmea = new RefreshMonitorEventArgs("tsStatus", string.Format("CCommonOPCClient.DealWithDeviceStateʱ��������:{0}��Ӧ���豸���������ڣ�", deviceindex));
OnRefreshMonitor(rmea);
errtext = string.Format("CCommonOPCClient.DealWithDeviceStateʱ��������:{0}��Ӧ���豸���������ڣ�", deviceindex);
return false;
}
}
#region �豸״̬�ɼ��ֽ�
int tempdb2addr = 0; StringBuilder sss = new StringBuilder(); StringBuilder barcode = new StringBuilder();
if (devicestates != null)
{
//���������������豸
for (int di = 0; di < dvDevice.Count; di++)
{
int devidx = Convert.ToInt32(dvDevice[di]["F_DeviceIndex"]);
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
if (DeviceStateInfos.ContainsKey(devidx) == false)
{
DeviceStateInfos.Add(devidx, new StringBuilder(devidx.ToString() + "#"));
}
witemnames[0].Clear();
witemnames[0].Append(Model.CGeneralFunction.DBGet).Append(".").Append(Convert.ToString(devinfo.Dbw2Address + 0)).Append(",b");//20141201���ڷ�����дΪDbw1Address
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
int taskindex = 0; int state = 0;
int xc = 0; int yc = 0;
int devkind = devinfo.DeviceKind;
//���´������¿���CStaticClass.MutiS7ConnReturns��Ϊ����F_ReadSubscription
tempdb2addr = Convert.ToInt32(dvDevice[di]["F_DBW2Address"]) - DBW2Addressbegin;
if (3 < devinfo.Dbw2Getlength&&devkind!=5&& devkind != 13)
{
//state = devicestates[tempdb2addr + 1];
taskindex = (devicestates[tempdb2addr + 2] << 8) + devicestates[tempdb2addr + 3];
}
if (1 < devinfo.Dbw2Getlength&&devkind!=7)
{
state = devicestates[tempdb2addr + 1];
}
if (1 == devinfo.Dbw2Getlength )
{
state = devicestates[tempdb2addr];
}
if (devkind == 13 && devinfo.UnControl!="1")
{//richard.liu20230718�谲����0-1�������������ģ�2�ǿ�������״̬0�����������1����������
state = devicestates[tempdb2addr + 1] == 0 ? 1 : 0;//��������״̬
taskindex = (devicestates[tempdb2addr + 2] << 8) + devicestates[tempdb2addr + 3];
}
#region ͨ�������豸״̬
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
if (devinfo.RunState != 4)//20121203
{
string errText = string.Empty;
if (state >= 30)
{
#region 20160501������Ϣ�仯����һ���Ͻ������¹��Ͽ�ʼ
Model.MError errs;
if (devinfo.ErrorCode != state && devinfo.ErrorCode >= 30)
{
if (taskindex == 0 || taskindex >= 30000)
{
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
}
#region ��һ�α������߹���ʱ���ֱ�ͳ�Ƽ�¼
errs = Model.CGetInfo.GetErrorInfo(Convert.ToInt32(devkind.ToString() + devinfo.ErrorCode.ToString()));
if (errs != null)
{
DataView dverr = dbo.ExceSQL(string.Format("SELECT F_ManageTaskNo,F_DeviceIndex,F_ErrorIndex,F_DateTime FROM T_Base_Device_Error_Log where F_DeviceIndex={0} and F_ErrorIndex={1} order by F_DateTime desc", devidx, errs.ErrorIndex)).Tables[0].DefaultView;
if (dverr.Count > 0)
{//richard.liu20181212�Ա�����¼��������һ�����޸�ʱ��
sql.Remove(0, sql.Length);
sql.Append("UPDATE T_Base_Device_Error_Log SET F_FixDateTime ='").Append(DateTime.Now.ToString("u")).Append("' Where F_DeviceIndex=")
.Append(devidx).Append(" and F_ErrorIndex=").Append(errs.ErrorIndex).Append(" and F_ManageTaskNo=").Append(Convert.ToInt32(dverr[0]["F_ManageTaskNo"]));
//dbo.ExceSQL(sql.ToString());
StringBuilder[] dboArrary = new StringBuilder[1] { new StringBuilder("DBFactory") };
StringBuilder[] sqlArrary = new StringBuilder[1] { sql };
CUpdateDBChangeEventArgs exeSql = new CUpdateDBChangeEventArgs(dboArrary, sqlArrary);
OnDealSQLExe("OPCClient.CCommonOPCClient.OnDataChange", exeSql);
}
if (errs.IfAlarm == '1')
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, 0
//, 0, ccf.GetAlarmTimeSpan(devidx),errs.ErrorKind, 0, out errText);//ͳ���ϴα���
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_AlarmStartTime='-' where F_DeviceIndex ={0}", devidx));
}
else
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, 0
//, ccf.GetErrorTimeSpan(devidx), 0,errs.ErrorKind, 0, out errText);//ͳ���ϴι���
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ErrorStartTime='-' where F_DeviceIndex ={0}", devidx));
}
}
#endregion
//�µı��������Ͽ�ʼ��ʱ
errs = Model.CGetInfo.GetErrorInfo(Convert.ToInt32(devkind.ToString() + state.ToString()));
if (errs != null)
{
if (errs.IfAlarm == '1')
{
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_AlarmStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
//CStaticClass.UpdateDeviceOEE(devinfo.DeviceIndex, DateTime.Now.Date, 0, 0, 1,
// 0, 0, 0, 'O', 0, out errText);//richard.liu20181212������������1
}
else
{
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ErrorStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
//CStaticClass.UpdateDeviceOEE(devinfo.DeviceIndex, DateTime.Now.Date, 0, 1, 0,
// 0, 0, 0, 'O', 0, out errText);//richard.liu20181212������������1
}
}
}
else if (devinfo.ErrorCode != state && devinfo.ErrorCode < 30)
{
if (taskindex == 0 || taskindex >= 30000)
{
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
}
//����һ������ʱ��
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, ccf.GetConveyorRunTimeSpan(devidx)
// ,0,0,'O',0, out errText);//ͳ���ϴ�����ʱ��
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ConveyorRunStartTime='-' where F_DeviceIndex ={0}", devidx));
//�µı��������Ͽ�ʼ��ʱ
errs = Model.CGetInfo.GetErrorInfo(Convert.ToInt32(devkind.ToString() + state.ToString()));
if (errs != null)
{
if (errs.IfAlarm == '1')
{
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_AlarmStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
//CStaticClass.UpdateDeviceOEE(devinfo.DeviceIndex, DateTime.Now.Date, 0, 0, 1,
// 0, 0, 0, 'O', 0, out errText);//richard.liu20181212������������1
}
else
{
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ErrorStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
//CStaticClass.UpdateDeviceOEE(devinfo.DeviceIndex, DateTime.Now.Date, 0, 1, 0,
// 0, 0, 0, 'O', 0, out errText);//richard.liu20181212������������1
}
}
}
#endregion
devinfo.ErrorCode = state;
devinfo.RunState = 2;
}
else
{//0,1,2
#region 20160501��һ���Ͻ��������ͻ������仯������������1
//���ͻ�״̬�仯��0->1��ʼ���У�1->0���н���������ʱ������
if (devinfo.ErrorCode >= 30)
{
#region ������һ�α������߹��Ͻ���������ʱ�䣬��Ϊ����ʱ��
Model.MError errs = Model.CGetInfo.GetErrorInfo(Convert.ToInt32(devkind.ToString() + devinfo.ErrorCode.ToString()));
if (errs != null)
{
DataView dverr = dbo.ExceSQL(string.Format("SELECT F_ManageTaskNo,F_DeviceIndex,F_ErrorIndex,F_DateTime FROM T_Base_Device_Error_Log where F_DeviceIndex={0} and F_ErrorIndex={1} order by F_DateTime desc", devidx, errs.ErrorIndex)).Tables[0].DefaultView;
if (dverr.Count > 0)
{//richard.liu20181212�Ա�����¼��������һ�����޸�ʱ��
sql.Remove(0, sql.Length);
sql.Append("UPDATE T_Base_Device_Error_Log SET F_FixDateTime ='").Append(DateTime.Now.ToString("u")).Append("' Where F_DeviceIndex=")
.Append(devidx).Append(" and F_ErrorIndex=").Append(errs.ErrorIndex).Append(" and F_ManageTaskNo=").Append(Convert.ToInt32(dverr[0]["F_ManageTaskNo"]));
//dbo.ExceSQL(sql.ToString());
StringBuilder[] dboArrary = new StringBuilder[1] { new StringBuilder("DBFactory") };
StringBuilder[] sqlArrary = new StringBuilder[1] { sql };
CUpdateDBChangeEventArgs exeSql = new CUpdateDBChangeEventArgs(dboArrary, sqlArrary);
OnDealSQLExe("OPCClient.CCommonOPCClient.OnDataChange", exeSql);
}
if (errs.IfAlarm == '1')
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, 0
//, 0, ccf.GetAlarmTimeSpan(devidx),errs.ErrorKind, 0, out errText);
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_AlarmStartTime='-' where F_DeviceIndex ={0}", devidx));
}
else
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, 0
//, ccf.GetErrorTimeSpan(devidx), 0,errs.ErrorKind, 0, out errText);
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ErrorStartTime='-' where F_DeviceIndex ={0}", devidx));
}
//��ʼ��¼����ʱ��
if (devkind == 2)
{
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ConveyorRunStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
}
}
#endregion
}
else
{//״̬�仯��0->1��ʼ���У�1->0()���н���������ʱ������
if (devinfo.ErrorCode == 0 && state == 1 && devkind == 2)
{
//��ʼ��¼����ʱ��
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ConveyorRunStartTime='{1}' where F_DeviceIndex ={0}", devidx, DateTime.Now.ToString("u").Substring(0, 19)));
}
else if (devinfo.ErrorCode == 1 && (state == 0 || state == 2) && devkind == 2)
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date, 0, 0, 0, ccf.GetConveyorRunTimeSpan(devidx)
//, 0, 0,'O', 0, out errText);//ͳ���ϴ�����ʱ��
//dbo.ExecuteSql(string.Format("update T_Base_Device set F_ConveyorRunStartTime='-' where F_DeviceIndex ={0}", devidx));
}
}
//�����仯
if (devinfo.TaskNo != taskindex && devkind == 2 && taskindex > 0)
{
//CStaticClass.UpdateDeviceOEE(devidx, DateTime.Now.Date,1, 0, 0, 0
// ,0, 0,'O', 0, out errText);
}
#endregion
if (state == 2)
{
devinfo.RunState = 5;
}
else
{
devinfo.RunState = state;
}
devinfo.ErrorCode = state;
}
}
devinfo.TaskNo = taskindex;
if ((devinfo.DeviceKind == 1) || (devinfo.DeviceKind == 4) || (devinfo.DeviceKind == 14))
{
devinfo.XCoor = devicestates[tempdb2addr + 7] + (devicestates[tempdb2addr + 6] << 8) + (devicestates[tempdb2addr + 5] << 16) + (devicestates[tempdb2addr + 4] << 32);//X����
if (devinfo.DeviceKind == 1)
{
devinfo.YCoor = devicestates[tempdb2addr + 11] + (devicestates[tempdb2addr + 10] << 8) + (devicestates[tempdb2addr + 9] << 16) + (devicestates[tempdb2addr + 8] << 32);//Y����
devinfo.ZCoor = devicestates[tempdb2addr + 12];//Z�������꣨1��2\3��
}
}
Model.CGetInfo.SetDeviceInfo(devinfo);
modifypathdevinfo = Model.CGetInfo.GetModifyPathDeviceInfo(devidx);
if (modifypathdevinfo != null)
{
modifypathdevinfo.RunState = devinfo.RunState;
modifypathdevinfo.ErrorCode = devinfo.ErrorCode;
modifypathdevinfo.TaskNo = devinfo.TaskNo;
Model.CGetInfo.SetModifyPathDeviceInfo(modifypathdevinfo);
}
#endregion
#region �����豸���ɡ�����������״̬;������Ϣ
string bc = string.Empty;
int[] states = new int[(int)devinfo.Dbw2Getlength];
Array.Copy(devicestates, tempdb2addr, states, 0, (int)devinfo.Dbw2Getlength);
switch (devkind)
{
#region �Ѷ���
case 1:
if (devicestates[tempdb2addr + 0] != 1) continue;
#region ���¶Ѷ������翪��״̬
devinfo.SplitByte_0 = (devicestates[tempdb2addr + 13] & 1) == 1 ? 1 : 0;
devinfo.SplitByte_1 = (devicestates[tempdb2addr + 13] & 2) == 2 ? 1 : 0;
devinfo.SplitByte_2 = (devicestates[tempdb2addr + 13] & 4) == 4 ? 1 : 0;
devinfo.SplitByte_3 = (devicestates[tempdb2addr + 13] & 8) == 8 ? 1 : 0;
devinfo.SplitByte_4 = (devicestates[tempdb2addr + 13] & 16) == 16 ? 1 : 0;
devinfo.SplitByte_5 = (devicestates[tempdb2addr + 13] & 32) == 32 ? 1 : 0;
devinfo.SplitByte_6 = (devicestates[tempdb2addr + 13] & 64) == 64 ? 1 : 0;
devinfo.SplitByte_7 = (devicestates[tempdb2addr + 13] & 128) == 128 ? 1 : 0;
Model.CGetInfo.SetDeviceInfo(devinfo);
#endregion
if (IsEquals(devinfo.ReturnMessage, states, 4) == false)
{
bc = GetBarcodeFromMonitorIndex(taskindex);
xc = devicestates[tempdb2addr + 7] + (devicestates[tempdb2addr + 6] << 8) + (devicestates[tempdb2addr + 5] << 16) + (devicestates[tempdb2addr + 4] << 32);//X����
yc = devicestates[tempdb2addr + 11] + (devicestates[tempdb2addr + 10] << 8) + (devicestates[tempdb2addr + 9] << 16) + (devicestates[tempdb2addr + 8] << 32);//Y����
devinfo.ReturnMessage = states;
Model.CGetInfo.SetDeviceMessage(devinfo);
sss.Remove(0, sss.Length);
sss.Append("**���룺").Append(bc).Append("**����־" + devicestates[tempdb2addr + 0]).Append("**״̬" + state).Append("**������" + taskindex)
.Append("**������" + xc).Append("**������" + yc);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "�յ��Ѷ���״̬", devidx.ToString(), sss.ToString());
if (devicestates[tempdb2addr + 0] != 1) continue;
if ((state <= 0) || (taskindex <= 0))
{
continue;
}
AddBatchReponse(Model.CGeneralFunction.DBSend, taskindex, devidx, state);
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
//cgs.GetKindDeviceState(taskindex, devidx, state);
}
break;
#endregion
#region �����ͻ�
case 2:
#region �������ͻ����翪��״̬
devinfo.SplitByte_0 = (devicestates[tempdb2addr + 4] & 1) == 1 ? 1 : 0;
devinfo.SplitByte_1 = (devicestates[tempdb2addr + 4] & 2) == 2 ? 1 : 0;
devinfo.SplitByte_2 = (devicestates[tempdb2addr + 4] & 4) == 4 ? 1 : 0;
devinfo.SplitByte_3 = (devicestates[tempdb2addr + 4] & 8) == 8 ? 1 : 0;
devinfo.SplitByte_4 = (devicestates[tempdb2addr + 4] & 16) == 16 ? 1 : 0;
devinfo.SplitByte_5 = (devicestates[tempdb2addr + 4] & 32) == 32 ? 1 : 0;
devinfo.SplitByte_6 = (devicestates[tempdb2addr + 4] & 64) == 64 ? 1 : 0;
devinfo.SplitByte_7 = (devicestates[tempdb2addr + 4] & 128) == 128 ? 1 : 0;
Model.CGetInfo.SetDeviceInfo(devinfo);
#endregion
if (IsEquals(devinfo.ReturnMessage, states, 4) == false)
{
bc = GetBarcodeFromMonitorIndex(taskindex);
devinfo.ReturnMessage = states;
Model.CGetInfo.SetDeviceMessage(devinfo);
sss.Remove(0, sss.Length);
sss.Append("**���룺").Append(bc).Append("**����־" + devicestates[tempdb2addr + 0]).Append("**״̬" + state).Append("**������:" + taskindex);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "�յ����ͻ���״̬", devidx.ToString(), sss.ToString());
//if (devicestates[tempdb2addr + 0] != 1) continue;
if (state <= 0 || taskindex <= 0)//20140305
{
continue;
}
if (taskindex > 0)
{
AddBatchReponse(Model.CGeneralFunction.DBSend, taskindex, devidx, state);
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
//cgs.GetKindDeviceState(taskindex, devidx, state);
}
}
break;
#endregion
#region ������RGV
case 4:
if (devicestates[tempdb2addr + 0] != 1) continue;
#region ���´��󳵹��翪��״̬
devinfo.SplitByte_0 = (devicestates[tempdb2addr + 8] & 1) == 1 ? 1 : 0;
devinfo.SplitByte_1 = (devicestates[tempdb2addr + 8] & 2) == 2 ? 1 : 0;
devinfo.SplitByte_2 = (devicestates[tempdb2addr + 8] & 4) == 4 ? 1 : 0;
devinfo.SplitByte_3 = (devicestates[tempdb2addr + 8] & 8) == 8 ? 1 : 0;
devinfo.SplitByte_4 = (devicestates[tempdb2addr + 8] & 16) == 16 ? 1 : 0;
devinfo.SplitByte_5 = (devicestates[tempdb2addr + 8] & 32) == 32 ? 1 : 0;
devinfo.SplitByte_6 = (devicestates[tempdb2addr + 8] & 64) == 64 ? 1 : 0;
devinfo.SplitByte_7 = (devicestates[tempdb2addr + 8] & 128) == 128 ? 1 : 0;
#endregion
Model.CGetInfo.SetDeviceInfo(devinfo);
if (IsEquals(devinfo.ReturnMessage, states, 4) == false)
{
bc = GetBarcodeFromMonitorIndex(taskindex);
xc = devicestates[tempdb2addr + 7] + (devicestates[tempdb2addr + 6] << 8) + (devicestates[tempdb2addr + 5] << 16) + (devicestates[tempdb2addr + 4] << 32);//X����
devinfo.ReturnMessage = states;
devinfo.XCoor = xc;
Model.CGetInfo.SetDeviceMessage(devinfo);
sss.Remove(0, sss.Length);
sss.Append("**���룺").Append(bc).Append("**����־" + devicestates[tempdb2addr + 0]).Append("**״̬" + state).Append("**������" + taskindex)
.Append("**������" + xc);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "�յ�RGV״̬", devidx.ToString(), sss.ToString());
if (devicestates[tempdb2addr + 0] != 1) continue;
if ((state <= 0) || (taskindex <= 0))
{
continue;
}
AddBatchReponse(Model.CGeneralFunction.DBSend, taskindex, devidx, state);
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
//cgs.GetKindDeviceState(taskindex, devidx, state);
}
break;
#endregion
#region �������ַ�����Ϣ
case 7:
if (devicestates[tempdb2addr + 0] != 1) continue;
int BoxInspection = devicestates[tempdb2addr + 1]; //�ߴ�����/����
//20140109��������(���񲻴���)���������ȶԣ������Ѿ����ڣ�
dvPLCASK = dbo.ExceSQL(string.Format("select F_BarCode,F_Time, F_PalletBarcodeLength,F_PalletBarcodeReservedLength,F_BarcodeReservedLength,F_WareHouse,F_ManageAskkind,F_BarcodeForkAmount,F_BarcodeLength,F_BindingDevice,F_Askkind,F_Remark from T_Base_PLC_Ask WHERE (F_DeviceIndex = {0}) ", devidx)).Tables[0].DefaultView; //20130510F_ManageAskkind
if (dvPLCASK.Count > 0)
{
StringBuilder warehouse = new StringBuilder(dvPLCASK[0]["F_WareHouse"].ToString());
int dcode = Convert.ToInt32(dvPLCASK[0]["F_BindingDevice"]);
int apptype = Convert.ToInt32(dvPLCASK[0]["F_ManageAskkind"]);//20130510
int BarcodeForkAmount = Convert.ToInt32(dvPLCASK[0]["F_BarcodeForkAmount"]); //�����Ѷ�����������������������
byte[] weightbyte = new byte[4] { devicestates[tempdb2addr + 2], devicestates[tempdb2addr + 3], devicestates[tempdb2addr + 4], devicestates[tempdb2addr + 5] };
float weights = CommonClassLib.CCarryConvert.ByteToFloat(weightbyte);//������Ϣ
int BarcodeLength = Convert.ToInt32(dvPLCASK[0]["F_BarcodeLength"]);//�����Ѷ���ȡ��վ̨�ϱ����롢��ת�����䡢��������
int BarcodeReservedLength = Convert.ToInt32(dvPLCASK[0]["F_BarcodeReservedLength"]);//�����Ѷ���ȡ��վ̨�ϱ����롢��ת�����䡢��������
if (BarcodeReservedLength < BarcodeLength)
{
BarcodeReservedLength = BarcodeLength;
}
//int BarcodeTotalLength = BarcodeReservedLength * BoxInspection;
int PalletBarcodeLength = Convert.ToInt32(dvPLCASK[0]["F_PalletBarcodeLength"]);//��������
int PalletBarcodeReservedLength = Convert.ToInt32(dvPLCASK[0]["F_PalletBarcodeReservedLength"]);
if (PalletBarcodeReservedLength < PalletBarcodeLength)
{
PalletBarcodeReservedLength = PalletBarcodeLength;
}
StringBuilder incompleteBarcode = new StringBuilder();// 1111111111111111.......
StringBuilder noneBarcode = new StringBuilder();// \0\0\0\0..........
StringBuilder appbarcode = new StringBuilder();
StringBuilder[] appbarArray = new StringBuilder[BarcodeForkAmount];
StringBuilder parameter = new StringBuilder();//���Ÿ������ϱ���ֽ��������
#region ��ʼ����������
//for (int j = 1; j <= BarcodeLength; j++)
//{
// incompleteBarcode.Append("1");//PLCɨ�����룬�����л��ת��Ϊ�ַ�'1'
// noneBarcode.Append("0");//PLCûɨ�裬û��������Ŀ�ֵ0,ת��Ϊ�ַ�'\0'
//}
//for (int j = 0; j < BarcodeForkAmount; j++)
//{//�����Ѷ�������ȡ��ǰ�ϱ�������ʽ��ͷ+����+����//20140218
// appbarArray[j] = new StringBuilder(ASCIIEncoding.ASCII.GetString(devicestates, tempdb2addr + 2 + j * BarcodeReservedLength, BarcodeReservedLength).Substring(0, BarcodeLength));
//}
barcode.Clear();
if (PalletBarcodeLength > 0)
{//��ͨɨ�赥������������\��������������������
incompleteBarcode.Clear();//20150103
noneBarcode.Clear();//20150103
for (int j = 1; j <= PalletBarcodeLength; j++)
{//20150103
incompleteBarcode.Append("1");//PLCɨ�����룬�����л��ת��Ϊ�ַ�'1'
noneBarcode.Append("0");//PLCûɨ�裬û��������Ŀ�ֵ0,ת��Ϊ�ַ�'\0'
}
for (int j = 4; j < PalletBarcodeLength + 4; j++)
{
barcode.Append(Convert.ToChar(devicestates[tempdb2addr + j]).ToString().ToUpper());
}
}
if (IsEquals(devinfo.ReturnMessage, states, states.Length) == false)
{
devinfo.ReturnMessage = states;
Model.CGetInfo.SetDeviceMessage(devinfo);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "��PLC����", devidx.ToString(), "����־1**���룺" + barcode.ToString().Trim('\0').ToUpper()+"�߶ȣ�"+ BoxInspection.ToString()+"�����ţ�"+taskindex);
}
#endregion
//20130831richard
DateTime appdt = new DateTime();
if (dvPLCASK[0]["F_Time"] == DBNull.Value)
{
appdt = DateTime.Now.AddSeconds(-10);
}
else
{
DateTime.TryParse(dvPLCASK[0]["F_Time"].ToString(), out appdt);
}
if (dvPLCASK[0]["F_BarCode"] != DBNull.Value)
{
if ((appdt.AddSeconds(15) > DateTime.Now) && (dvPLCASK[0]["F_BarCode"].ToString() == barcode.ToString()))
{
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "PLC�ظ��ϱ�����:", devidx.ToString(), ",վ̨��" + dcode + "�����룺" + barcode.ToString().ToUpper());
break;
}
}
switch (dvPLCASK[0]["F_Askkind"].ToString())
{
case "4":
//��ͨ������������
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", 0, 0, 4, barcode.ToString().Trim('\0'), BoxInspection));
break;
case "6":
//103�����������
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", taskindex, 0, 6, barcode.ToString().Trim('\0'), BoxInspection));
break;
case "8":
//����һ
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", taskindex, 0, 8, barcode.ToString().Trim('\0'), BoxInspection));
break;
case "5":
//�ȶ����������ɣ���������
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", taskindex, 0, 5, barcode.ToString().Trim('\0'), BoxInspection));
break;
case "7":
//����ɨ����Ʒ����
#region ����������������
barcode.Clear();
for (int j = 2; j < PalletBarcodeLength; j++)
{
if (devicestates[tempdb2addr + j] == 13)
{
break;
}
barcode.Append(Convert.ToChar(devicestates[tempdb2addr + j]).ToString().ToUpper());
}
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", 0, 0, 7, barcode.ToString().Trim('\0'), BoxInspection));
#endregion
break;
case "9":
//�����л������뿪
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", 0, 0, 5, barcode.ToString().Trim('\0'), BoxInspection));
break;
case "13":
//���뱨�����ɣ����ǵ�һ��ɨ����ûɨ�������ǵڶ���ɨ����ȴɨ��
//ûɨ�����������޶�Ӧ�����ĸĵ��쳣��
#region ���뱨������
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", 0, 0, 13, barcode.ToString(), BoxInspection));
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "д����Ӧ��", devidx.ToString(), "д��־:2" + "**Դ���룺" + barcode.ToString().ToUpper());
#endregion
break;
case "17":
#region �������ϱ�������������
if (parameter.ToString().Length > 0)
{
#region ������������������������
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "����������������������", devidx.ToString(), dcode + "����" + barcode.ToString().ToUpper() + "�����룺" + parameter.ToString());
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}#{3}#{4}", 0, 0, 17, barcode.ToString(), BoxInspection));
#endregion
}
#endregion
break;
default:
//�����ͣ������ȶԻ��߼�¼����
break;
}
AddBatchReponse(Model.CGeneralFunction.DBGet, 0, devidx, 2);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "д����Ӧ��", devidx.ToString(), "д��־2" + "**Դ���룺" + barcode.ToString().ToUpper());
}
break;
#endregion
#region ���ػ���ť������ĸ�ж�Ӧ�豸
case 36:
if (devicestates[tempdb2addr + 0] != 1) continue;
//0�ֽڴ��������֣�1��ʾPLC�ϱ���2��ʾPCӦ��
//1�ֽڣ�1������ĸ��
AddBatchReponse(Model.CGeneralFunction.DBGet, 0, devidx, 2);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "д���ػ���ť������ĸ��Ӧ��", devidx.ToString(), "д��־2**������ĸ�б�ʶ��" + devicestates[tempdb2addr + 1].ToString() + ";" + witemnames[0].ToString());
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}", 0, 0, devicestates[tempdb2addr + 1]));
break;
#endregion
#region �����̻�������������Ӧ�豸
case 38:
if (devicestates[tempdb2addr + 0] != 1) continue;
//0�ֽڴ��������֣�1��ʾPLC�ϱ���2��ʾPCӦ��
//1�ֽڣ�1�������⣻2��������
AddBatchReponse(Model.CGeneralFunction.DBGet, 0, devidx, 2);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "д�����̻�����������Ӧ��", devidx.ToString(), "д��־2**�������������ͣ�" + devicestates[tempdb2addr + 1].ToString() + ";" + witemnames[0].ToString());
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}#{2}", 0, 0, devicestates[tempdb2addr + 1]));
break;
#endregion
#region �����ⷽ��������������
case 39:
if (devicestates[tempdb2addr + 0] != 1) continue;
break;
#endregion
#region �谲������վ
case 13:
//if (devicestates[tempdb2addr + 0] != 1) continue;
if (devinfo.UnControl == "1")
{//��վ����
#region �����������жϣ��ѵ���ֵ+1
int xt = (devicestates[tempdb2addr + 0] << 8) + devicestates[tempdb2addr + 1];
//��������
if (xt >= 30000) xt = 0;
devinfo.SendInterval = xt;
StringBuilder[] itemname; StringBuilder[] itemvalue;
itemname = new StringBuilder[1] { new StringBuilder("") };
itemname[0].Append(Model.CGeneralFunction.DBSend).Append(".").Append(devinfo.Dbw1Address).Append(",i");
itemvalue = new StringBuilder[1] { new StringBuilder("") };
itemvalue[0].Append(xt + 1);
CCommonOPCClient.Hostname = CommonClassLib.AppSettings.GetValue("HostName");
CCommonOPCClient.ProgID = CommonClassLib.AppSettings.GetValue("OPCProgID");
AsyncWriteAllItemValue(devinfo.S7Connection, itemname, itemvalue);
//AddBatchReponse(Model.CGeneralFunction.DBSend, 0, devidx, xt+1);
//CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "���ͻ�����վ����", devidx.ToString(), string.Format("�յ�������{0}������������{1}",xt,xt+1));
#endregion
}
else
{
if (IsEquals(devinfo.ReturnMessage, states, states.Length) == false)
{//��վ
#region ������վ���ϱ���״̬
int ies = (devicestates[tempdb2addr + 4] << 8) + devicestates[tempdb2addr + 5];
int isd = (devicestates[tempdb2addr + 6] << 8) + devicestates[tempdb2addr + 7];
int islg = (devicestates[tempdb2addr + 8] << 8) + devicestates[tempdb2addr + 9];
for (int hi = 0; hi <= 15; hi++)
{
devinfo.EmergencyStop[hi] = (ies & Convert.ToUInt16(Math.Pow(2, hi))) == Math.Pow(2, hi);//BIT0--BIT15����#1..#16����ֹͣ״̬BIT=0��ʾ������BIT=1��ʾ�쳣
devinfo.SafetyDoor[hi] = (isd & Convert.ToUInt16(Math.Pow(2, hi))) == Math.Pow(2, hi);//BIT0--BIT15����#1..#16��ȫ��״̬BIT=0��ʾ������BIT=1��ʾ�쳣
devinfo.SafetyLightGrid[hi] = (islg & Convert.ToUInt16(Math.Pow(2, hi))) == Math.Pow(2, hi);// BIT0--BIT15����#1..#16��ȫ��դ״̬BIT=0��ʾ������BIT=1��ʾ�쳣
}
#endregion
bc = GetBarcodeFromMonitorIndex(taskindex);
devinfo.ReturnMessage = states;
Model.CGetInfo.SetDeviceMessage(devinfo);
sss.Remove(0, sss.Length);
sss.Append("**���룺").Append(bc).Append("**����־" + devicestates[tempdb2addr + 0]).Append("**״̬" + state).Append("**������" + taskindex).Append("���ս�����").Append(devicestates[tempdb2addr + 3])
.Append("**������" + xc);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "�յ�������վ״̬", devidx.ToString(), sss.ToString());
//if (devicestates[tempdb2addr + 0] != 1) continue;//WCS��������
if ((devicestates[tempdb2addr + 1] <= 0) || (taskindex <= 0))
{//1����������,������վ��������һ�����2�������쳣
continue;
}
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, devicestates[tempdb2addr + 1]));
//����Ҫ�ظ�����AddBatchReponse("DB1", taskindex, devidx, state);
//cgs.GetKindDeviceState(taskindex, devidx, devicestates[tempdb2addr + 3]);
}
}
break;
#endregion
#region �谲���δ�����RGV
case 14:
if (devicestates[tempdb2addr + 0] != 1) continue;
#region ���»��δ��󳵹��翪��״̬
devinfo.SplitByte_0 = (devicestates[tempdb2addr + 8] & 1) == 1 ? 1 : 0;
devinfo.SplitByte_1 = (devicestates[tempdb2addr + 8] & 2) == 2 ? 1 : 0;
devinfo.SplitByte_2 = (devicestates[tempdb2addr + 8] & 4) == 4 ? 1 : 0;
devinfo.SplitByte_3 = (devicestates[tempdb2addr + 8] & 8) == 8 ? 1 : 0;
devinfo.SplitByte_4 = (devicestates[tempdb2addr + 8] & 16) == 16 ? 1 : 0;
devinfo.SplitByte_5 = (devicestates[tempdb2addr + 8] & 32) == 32 ? 1 : 0;
devinfo.SplitByte_6 = (devicestates[tempdb2addr + 8] & 64) == 64 ? 1 : 0;
devinfo.SplitByte_7 = (devicestates[tempdb2addr + 8] & 128) == 128 ? 1 : 0;
#endregion
Model.CGetInfo.SetDeviceInfo(devinfo);
if (IsEquals(devinfo.ReturnMessage, states, 4) == false)
{
bc = GetBarcodeFromMonitorIndex(taskindex);
xc = devicestates[tempdb2addr + 7] + (devicestates[tempdb2addr + 6] << 8) + (devicestates[tempdb2addr + 5] << 16) + (devicestates[tempdb2addr + 4] << 32);//X����
devinfo.ReturnMessage = states;
Model.CGetInfo.SetDeviceMessage(devinfo);
sss.Remove(0, sss.Length);
sss.Append("**���룺").Append(bc).Append("**����־" + devicestates[tempdb2addr + 0]).Append("**״̬" + state).Append("**������" + taskindex)
.Append("**������" + xc);
CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "�յ�����RGV״̬", devidx.ToString(), sss.ToString());
if (devicestates[tempdb2addr + 0] != 1) continue;
if ((state <= 0) || (taskindex <= 0))
{
continue;
}
AddBatchReponse(Model.CGeneralFunction.DBSend, taskindex, devidx, state);
DeviceStateInfos[devidx].Append(string.Format("{0}#{1}", taskindex, state));
//cgs.GetKindDeviceState(taskindex, devidx, state);
}
break;
#endregion
}
#endregion
}
#region һ�����������豸������ID deviceindexһ������Ӧ��20230811richard.liu
StringBuilder[] itmenames = null; StringBuilder[] itmevalues = null;
StringBuilder[] sbDdeviceStateInfos = new StringBuilder[DeviceStateInfos.Count];
if (_opcSubsTagCount.ContainsKey(deviceindex.ToString()) == true)
{
itmenames = new StringBuilder[_opcSubsTagCount[deviceindex.ToString()]];
itmevalues = new StringBuilder[_opcSubsTagCount[deviceindex.ToString()]];
int deviceTagCount = 0;
if (_opcItemNamesDicInfo.Count > 0)
{
foreach (int devidx in _opcItemNamesDicInfo[deviceindex.ToString()].Keys)
{
Array.Copy(_opcItemNamesDicInfo[deviceindex.ToString()][devidx], 0, itmenames, deviceTagCount, _opcItemNamesDicInfo[deviceindex.ToString()][devidx].Length);
Array.Copy(_opcItemValuesDicInfo[deviceindex.ToString()][devidx], 0, itmevalues, deviceTagCount, _opcItemValuesDicInfo[deviceindex.ToString()][devidx].Length);
deviceTagCount += _opcItemNamesDicInfo[deviceindex.ToString()][devidx].Length;
}
}
}
int i = 0;
foreach (int devidx in DeviceStateInfos.Keys)
{
if (DeviceStateInfos[devidx].ToString().Split('#').Length > 2)
{
sbDdeviceStateInfos[i] = DeviceStateInfos[devidx];
i++;
}
}
if (i > 0 || itmenames != null)
{
StringBuilder[] sbDdeviceStateInfosNew = new StringBuilder[i];
Array.Copy(sbDdeviceStateInfos, sbDdeviceStateInfosNew, i);
CUpdateDBChangeEventArgs udbe = new CUpdateDBChangeEventArgs(deviceindex, sbDdeviceStateInfosNew, itmenames, itmevalues);
string ss = "";
for (int kk = 0; kk < sbDdeviceStateInfosNew.Length; kk++)
{
ss += sbDdeviceStateInfosNew[kk].ToString();
}
//CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "����on", deviceindex.ToString(), ss);
OnPublishDeviceState("OPCClient.CCommonOPCClient.OnDataChange", udbe);
}
#endregion
}
#endregion
return true;
}
catch (Exception ex)
{
RefreshMonitorEventArgs rmea = new RefreshMonitorEventArgs("tsStatus", "CCommonOPCClient.DealWithDeviceStateʱ" + ex.Message + ex.StackTrace);
OnRefreshMonitor(rmea);
errtext = ex.Message + ex.StackTrace;
return false;
}
finally
{
dvDevice.Dispose();
dvbc.Dispose();
dvPLCASK.Dispose();
}
}
}
#region �Զ��巽��
static string _stockCodeCheck = "^[B|D|G|P][A-Z][0-9]{4}$";
/// <summary>
/// ������ʽ����
/// </summary>
public static string StockCodeCheck
{
get { return _stockCodeCheck; }
set
{
int aa;
if (int.TryParse(_stockCodeCheck, out aa) == true)
{
_stockCodeCheck = value;
}
else
{
_stockCodeCheck = "^[B|D|G|P][A-Z][0-9]{4}$";
}
}
}
private static void AddBatchReponse(string DBBlock, int taskindex, int devidx, int state)
{
StringBuilder[] itemnames = new StringBuilder[0]; StringBuilder[] itemvalues = new StringBuilder[0];
try
{
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
int devKind = devinfo.DeviceKind;
if (DBBlock == "DB1")
{//����devidx���ͺ�state�жϷ���Ӧ��
if (state == 1)
{//����
if ((devKind == 1)) //�Ѷ���
{
int[] sendmes = new int[10] { 0, 0, 0, devidx, 0, 0, 0, 0, 0, 0 };
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
if (IsEquals(devinfo.SendMessage, sendmes, 10) == false)
{
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(0, 0, 0, devidx, 0, 0, 0, 0, 0, 0, out itemnames, out itemvalues);
}
}
else if (devKind == 4 || devKind == 2)
{//���ͻ���RGV��������
int[] sendmes = new int[5] { 0, 0, 0, devidx, 0 };
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
if (devinfo.IfClearDB1 == "1" && IsEquals(devinfo.SendMessage, sendmes, 5) == false)
{
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(0, 0, 0, devidx, 0, out itemnames, out itemvalues);
}
}
}
else if (state == 2)
{//����
if ((devKind == 1)) //�Ѷ���
{
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(2, 0, 0, devidx, 0, 0, 0, 0, 0, 0, out itemnames, out itemvalues);
}
else if (devKind == 14)
{//����С��Ӧ��������richard.liu20230718
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(2, taskindex, 99, devidx, 0, 0, 0, 0, 0, 0, out itemnames, out itemvalues);
}
else if (devKind == 4 || devKind == 2)
{//���ͻ���RGV
int taskRGV = 0;
//richard.liu20230718�����Ӹ�ȡ�����ͻ����ͻ���ȡ��ָ������
object obt = dbo.GetSingle(string.Format("select F_CHANNELSINDEX from T_BASE_RGV_GATE, t_base_device where F_CHANNELSINDEX=f_deviceindex and f_devicekindindex=13 and F_RGVGATEDEVICEINDEX={0}", devidx));
if (obt != null)
{
obt = dbo.GetSingle(string.Format("select f_monitorindex from t_monitor_task where f_monitorindex >{0} and f_deviceindex= {1} order by f_monitorindex asc", taskindex, Convert.ToInt32(obt)));
if (obt != null)
{
taskRGV = Convert.ToInt32(obt);
}
}
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(2, taskRGV, 0, devidx, 0, out itemnames, out itemvalues);
}
else
{
//��stateֵ����Ӧ��
itemnames = new StringBuilder[1] { new StringBuilder() };
itemvalues = new StringBuilder[1] { new StringBuilder() };
itemnames[0].Append(DBBlock).Append(".").Append(Convert.ToString(devinfo.Dbw2Address + 0)).Append(",b");
itemvalues[0].Append(state);
}
}
else
{
if (devKind == 1) //�Ѷ���
{//�������Ѷ�������ȥ����������
int[] sendmes = new int[10] { 0, 0, 0, devidx, 0, 0, 0, 0, 0, 0 };
if (IsEquals(devinfo.SendMessage, sendmes, 10) == false)
{
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(0, 0, 0, devidx, 0, 0, 0, 0, 0, 0, out itemnames, out itemvalues);
}
}
else if (devKind == 13)
{//����������ͷ99
sdo = CommModeCreate.CreateSendDeviceOrder(devidx);
sdo.SendDeviceOrder(99, 0, state, devidx, 0, 0, 0, 0, 0, 0, out itemnames, out itemvalues);
}
}
}
else if (DBBlock == "DB2")
{//��stateֵ����Ӧ��
itemnames = new StringBuilder[1] { new StringBuilder()};
itemvalues = new StringBuilder[1] { new StringBuilder() };
itemnames[0].Append(DBBlock).Append(".").Append(Convert.ToString(devinfo.Dbw2Address + 0)).Append(",b");
itemvalues[0].Append(state);
}
else
{
return;
}
//20230811richard.liu�ݴ���ǩ����
if (itemnames.Length > 0)
{
AddOPCSendData(devidx, itemnames, itemvalues);
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
}
}
/// <summary>
/// �ݴ���ǩ����
/// </summary>
/// <param name="deviceIndex">�豸����</param>
/// <param name="itemnames">��ַ����ǩ��������</param>
/// <param name="itemvalues">��ǩֵ����</param>
private static void AddOPCSendData(int deviceIndex, StringBuilder[] itemnames, StringBuilder[] itemvalues)
{//20230811richard.liu�����ڰ�S7�����������ͣ��ع�CControl.cs��CCommonOPCClient.cs\DealWithDeviceState;�ļ���Communication��Common��ͨѶCSendDeviceOrder: ISendDeviceOrder�����ļ�
try
{
devinfo = Model.CGetInfo.GetDeviceInfo(deviceIndex);
if (_opcItemNamesDicInfo.ContainsKey(devinfo.ReadSubscription))
{//����OPC������+dic �豸����+���� ��������
if (_opcItemNamesDicInfo[devinfo.ReadSubscription].ContainsKey(devinfo.DeviceIndex) == false)
{
_opcSubsTagCount[devinfo.ReadSubscription] += itemnames.Length;
_opcItemNamesDicInfo[devinfo.ReadSubscription].Add(devinfo.DeviceIndex, itemnames);
_opcItemValuesDicInfo[devinfo.ReadSubscription].Add(devinfo.DeviceIndex, itemvalues);
}
}
else
{
Dictionary<int, StringBuilder[]> OPCDeviceSendtagNamedic = new Dictionary<int, StringBuilder[]>();
Dictionary<int, StringBuilder[]> OPCDeviceSendtagValuedic = new Dictionary<int, StringBuilder[]>();
OPCDeviceSendtagNamedic.Add(devinfo.DeviceIndex, itemnames);
OPCDeviceSendtagValuedic.Add(devinfo.DeviceIndex, itemvalues);
_opcSubsTagCount.Add(devinfo.ReadSubscription, itemnames.Length);
_opcItemNamesDicInfo.Add(devinfo.ReadSubscription, OPCDeviceSendtagNamedic);
_opcItemValuesDicInfo.Add(devinfo.ReadSubscription, OPCDeviceSendtagValuedic);
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
}
}
/// <summary>
/// �Ƚ�����ֵ��һά���������Ƿ�ֵ����
/// </summary>
/// <param name="array1">ֵ��һά����1</param>
/// <param name="array2">ֵ��һά����2</param>
/// <returns>�ȽϽ�����������true������false</returns>
static public bool IsEquals(Array array1, Array array2, int arraylength)
{//20090902������arraylength
//�Ƚ������Ƿ�һ��
if ((array1 == null) || (array2 == null)) return false;
if (!Object.ReferenceEquals(array1.GetType(), array2.GetType()))
{
return false;
}
//�Ƚϳ����Ƿ�һ��
if (array1.GetLength(0) != array2.GetLength(0))
{
return false;
}
//�Ƚϳ�Ա�Ƿ���Ӧ����
ValueType v1, v2;
for (int i = 0; i < arraylength; i++)
{
v1 = (ValueType)array1.GetValue(i);
v2 = (ValueType)array2.GetValue(i);
if (!v1.Equals(v2))
{
return false;
}
}
return true;
}
static string GetBarcodeFromMonitorIndex(int taskindex)
{
DataView dvb = new DataView(); StringBuilder sss = new StringBuilder("");
try
{
sss.Append("SELECT F_TxtParam FROM T_Monitor_Task WHERE (F_MonitorIndex = ").Append(taskindex).Append(")");
dvb = dbo.ExceSQL(sss.ToString()).Tables[0].DefaultView;
if (dvb.Count > 0)
{
return dvb[0]["F_TxtParam"].ToString();
}
else
{
return "-";
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dvb.Dispose();
}
}
#endregion
static private string _PLCconnectionID = "S7 connection_1";//OPC.UA����д��"ns=2,S7 connection_1.db2.0,b,5"��ʾ��"S7:[S7 connection_1]��db2.DBB0��ʼ5���ֽ�"
/// <summary>
/// ����PLC���ӵ�ID�����磺"S7:[S7 connection_1]"
/// ����"S7:[@LOCALSERVER]"
/// </summary>
public static string PlcConnectionID
{
get { return CCommonOPCClient._PLCconnectionID; }
set { CCommonOPCClient._PLCconnectionID = value; }
}
static private string _opcError;
static private bool _IfConnectOPCServer=false ;
static private string _hostname;
/// <summary>
/// OPC Server�Ļ������ƻ���IP��ַ
/// </summary>
public static string Hostname
{
get { return CCommonOPCClient._hostname; }
set { CCommonOPCClient._hostname = value; }
}
static private string _progID;
/// <summary>
/// OPC Server�ij�����ʶ�����磺OPC.SimaticNET
/// </summary>
public static string ProgID
{
get { return CCommonOPCClient._progID; }
set { CCommonOPCClient._progID = value; }
}
public static string OpcError
{
get { return CCommonOPCClient._opcError; }
set {
CCommonOPCClient._opcError = value;
RefreshMonitorEventArgs rme = new RefreshMonitorEventArgs("tsStatus", _opcError);
OnRefreshMonitor(rme);
}
}
/// <summary>
/// ���豸��������Ӧ�豸���ġ�
/// </summary>
public static SubscriptionCollection SubscriptionGroup = new SubscriptionCollection();//���������󼯺ϣ������߼��ϣ�//20110309
/// <summary>
/// 20110309ÿ���豸����һ�����ĺ�DataChange�¼�
/// </summary>
public static void CreateSubscriptionGroup()
{
if (_IfConnectOPCServer == false)
{
_hostname = CommonClassLib.AppSettings.GetValue("HostName");
_progID = CommonClassLib.AppSettings.GetValue("OPCProgID");
if (ConnectOPCServer(_hostname, _progID) == false) return ;
}
//DataView dv = dbo.ExceSQL("SELECT F_ReadSubscription, F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_S7Connection, F_SplitByte FROM T_Base_Device WHERE (F_ReadSubscription IS NOT NULL) AND (F_ReadSubscription =F_DeviceIndex) and ((f_localport!=3 and f_localport!=4 and f_localport!=7 and f_localport!=10) or f_devicekindindex=2) ORDER BY F_ReadSubscription").Tables[0].DefaultView;
DataView dv = dbo.ExceSQL("SELECT F_ReadSubscription, F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_S7Connection, F_SplitByte FROM T_Base_Device WHERE (F_ReadSubscription IS NOT NULL) AND (F_ReadSubscription =F_DeviceIndex) ORDER BY F_ReadSubscription").Tables[0].DefaultView;
if (dv.Count > 0)
{
if (dv.Count < SubscriptionGroup.Count) return;
}
DataView dvx;
for (int i = 0; i < dv.Count; i++)
{
string dt = DateTime.Now.Minute.ToString() + "-" + DateTime.Now.Second.ToString() + "-" + DateTime.Now.Millisecond.ToString();
dvx = dbo.ExceSQL(string.Format("SELECT (MAX(F_DBW2Address) + F_DBWGetLength) as maxdbw2 FROM T_Base_Device WHERE (F_ReadSubscription = {0}) AND (F_DeviceKindIndex != 33) GROUP BY F_DBWGetLength ORDER BY maxdbw2 DESC", dv[i]["F_ReadSubscription"])).Tables[0].DefaultView;
if (dvx.Count > 0)
{
NodeId nodeId;
if (dv[i]["F_S7Connection"].ToString() == "@localserver"|| (Convert.ToInt32(dv[i]["F_DeviceIndex"])>=34091&& Convert.ToInt32(dv[i]["F_DeviceIndex"]) <= 34100))
{
nodeId = new NodeId(dv[i]["F_S7Connection"].ToString() + "." +
"DB1" + "." +
dv[i]["F_DBW2Address"].ToString() + ",b," +
(System.Convert.ToInt32(System.Convert.ToInt32(dvx[0]["maxdbw2"]) - System.Convert.ToInt32(dv[i]["F_DBW2Address"]))).ToString(), S7NameSpace);
}
else
{
nodeId = new NodeId(dv[i]["F_S7Connection"].ToString() + "." +
Model.CGeneralFunction.DBGet + "." +
dv[i]["F_DBW2Address"].ToString() + ",b," +
(System.Convert.ToInt32(System.Convert.ToInt32(dvx[0]["maxdbw2"]) - System.Convert.ToInt32(dv[i]["F_DBW2Address"]))).ToString(), S7NameSpace);//20151120
}
// Add the attribute name/value to the list view.
object serverHandle = null;
try
{
// Add the item and apply any changes to it.
m_Subscription.AddDataMonitoredItem(nodeId, dv[i]["F_ReadSubscription"].ToString(), OnDataChange, 700, out serverHandle);
}
catch (ServiceResultException monitoredItemResult)
{
OpcError = "����OPC������ʱ��" + monitoredItemResult.Message;
if (ConnectCount.ContainsKey(dv[i]["F_S7Connection"].ToString()) == false)//20110726
{
ConnectCount.Add(dv[i]["F_S7Connection"].ToString(), 1);
}
else
{
ConnectCount[dv[i]["F_S7Connection"].ToString()]++;
}
}
}
}
dv = dbo.ExceSQL("SELECT F_ReadSubscription, F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_S7Connection, F_SplitByte FROM T_Base_Device WHERE (F_ReadSubscription IS NOT NULL) AND (F_DeviceKindIndex=33) ORDER BY F_ReadSubscription").Tables[0].DefaultView;
for (int i = 0; i < dv.Count; i++)
{
NodeId nodeId = new NodeId(dv[i]["F_S7Connection"].ToString() + "." +
Model.CGeneralFunction.DBGet + "." +
dv[i]["F_DBW2Address"].ToString() + ",b," + System.Convert.ToInt32(dv[i]["F_DBWGetLength"]).ToString(), S7NameSpace);//20151120
// Add the attribute name/value to the list view.
object serverHandle = null;
try
{
// Add the item and apply any changes to it.
m_Subscription.AddDataMonitoredItem(nodeId, "split" + dv[i]["F_ReadSubscription"].ToString(), OnDataChange, 100, out serverHandle);
}
catch (ServiceResultException monitoredItemResult)
{
OpcError = "����OPC������ʱ��" + monitoredItemResult.Message;
if (ConnectCount.ContainsKey(dv[i]["F_S7Connection"].ToString()) == false)//20110726
{
ConnectCount.Add(dv[i]["F_S7Connection"].ToString(), 1);
}
else
{
ConnectCount[dv[i]["F_S7Connection"].ToString()]++;
}
}
}
}
/// <summary>
/// ͨ�����ö��ĵļ���ģʽ��ˢ�¶���
/// </summary>
/// <returns></returns>
public static bool RefreshMonitoringMode()
{//20150103���Ӷ����ָ�
if (m_Subscription != null)
{
m_Subscription.RefreshMonitoringMode();
}
return true;
}
/// <summary>
/// ����ָ��������OPC������
/// </summary>
/// <param name="hostname">��������</param>
/// <param name="ProgID">OPC������������ʶ���磺"OPC.SimaticNET"</param>
/// <returns></returns>
public static bool ConnectOPCServer(string hostname, string ProgID)
{
try
{
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
if (ConnectCount[_PLCconnectionID] > 1)//20150204
{
_opcError = "WCSû���ӵ�OPC Server��" + _PLCconnectionID.ToString() + "���˹�ȷ�Ϻ����С�PLC��ʼ����";//20150204
return false ;
}
//Uri discoveryUrl = new Uri("opc.tcp://" + hostname + ":4845");
Uri discoveryUrl = new Uri("opc.tcp://" + hostname + ":55101");
Discovery discovery = new Discovery();
EndpointDescriptionCollection endpoints = null;
string rr = discovery.GetEndpoints(discoveryUrl, ref endpoints);
if(endpoints == null)
{
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
ConnectCount[_PLCconnectionID]++;
OpcError = "����OPC���ݴ�ȡ������ʱ��GetEndpointsû�ҵ�OPC��������";
_IfConnectOPCServer = false;
return false;
}
for (int i = 0; i < endpoints.Count; i++)
{
endpoints[i].EndpointUrl = discoveryUrl.ToString();
if ((endpoints[i].Server.ApplicationName.Text.IndexOf( ProgID)>-1)
&& (endpoints[i].SecurityMode == MessageSecurityMode.None))//20151120
{
m_Server = new Server();
m_Server.CertificateEvent += new certificateValidation(m_Server_CertificateEvent);
m_Server.Connect(endpoints[i]);
_IfConnectOPCServer = true;
if (m_Subscription == null)
{
m_Subscription = m_Server.AddSubscription(100);
}
#region �Զ���ȡ��S7:���������ռ�����//20151120
DataValueCollection m_currentValues;
NodeId nodeId=new NodeId(2255);
NodeIdCollection nodesToRead = new NodeIdCollection(1);
nodesToRead.Add(nodeId);
m_Server.ReadValues(nodesToRead, out m_currentValues);
if (m_currentValues.Count > 0)
{
string[] arr;
arr =(string[]) m_currentValues[0].Value;
S7NameSpace =(ushort) Array.IndexOf(arr, "S7:");
}
#endregion
return true;
}
}
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
ConnectCount[_PLCconnectionID]++;
OpcError = "����OPC���ݴ�ȡ������ʱ��������OPCProgID��HostName��׼ȷ��";
_IfConnectOPCServer = false;
return false;
}
catch (Exception ex)
{
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
ConnectCount[_PLCconnectionID]++;
OpcError = "����OPC���ݴ�ȡ������ʱ��" + ex.Message;
_IfConnectOPCServer = false;
return false;
}
}
public static DataValueCollection SyncReadAllItemValue(StringBuilder[] itemnames)
{
DataValueCollection m_currentValues;
if (_IfConnectOPCServer == false)
{
if (ConnectOPCServer(_hostname, _progID) == false) return null;
}
NodeIdCollection nodesToRead = new NodeIdCollection(itemnames.GetLength(0));
foreach (StringBuilder item in itemnames)
{
// NodeIds.
String sNodeId = _PLCconnectionID + "." + item.ToString();
NodeId nodeId = new NodeId(sNodeId,S7NameSpace);//20151120
nodesToRead.Add(nodeId);
}
// Call to ClientAPI.
m_Server.ReadValues(
nodesToRead,
out m_currentValues);
return m_currentValues;
}
public static bool SyncWriteAllItemValue(StringBuilder[] itemnames, StringBuilder[] itemvalues)
{
try
{
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
if (ConnectCount[_PLCconnectionID] > 1)//20150204
{
return false;
}
if (_IfConnectOPCServer == false)
{
if (ConnectOPCServer(_hostname, _progID) == false) return false;
}
NodeIdCollection nodesToWrite = new NodeIdCollection(itemnames.GetLength(0));
DataValueCollection values = new DataValueCollection(itemnames.GetLength(0));
StatusCodeCollection results = null;
int i = 0;
foreach (StringBuilder item in itemnames)
{
// Values to write.
String sValue = itemvalues[i].ToString();
// Leave current value if write value is empty.
if (sValue.Length == 0)
{
i++;
continue;
}
#region win7��64λ����ϵͳ��Ҫָ��ȷ�е���������//20151120
Type gt = typeof(byte);
if (item.ToString().IndexOf(",b") >= 0)//�޷����ֽ���0--255
{
gt = typeof(byte);
}
else if (item.ToString().IndexOf(",i") >= 0)//short���з��������ֽڵĵ���-32768��32767
{
gt = typeof(short);
}
else if (item.ToString().IndexOf(",w") >= 0)//ushort���޷��������ֽڵĵ���0��65535
{
gt = typeof(ushort);
}
else if (item.ToString().IndexOf(",di") >= 0)//int���з����ĸ��ֽڵ�˫��-2147483648��2147483647
{
gt = typeof(int);
}
else if (item.ToString().IndexOf(",dw") >= 0)//uint���޷����ĸ��ֽڵ�˫��0��4294967295
{
gt = typeof(uint);
}
else if (item.ToString().IndexOf(",dt") >= 0)//DateTime�����ں�ʱ�����ͣ�05/31/2016 08:21:10.123 PM
{
gt = typeof(DateTime);
}
Variant variant = new Variant(Convert.ChangeType(sValue, gt));
#endregion
DataValue value = new DataValue(variant);
values.Add(value);
// NodeIds.
String sNodeId =_PLCconnectionID+"."+ item.ToString();
NodeId nodeId = new NodeId(sNodeId, S7NameSpace); //20151120
nodesToWrite.Add(nodeId);
i++;
}
// Call to ClientAPI.
m_Server.WriteValues(
nodesToWrite,
values,
out results);
int ia = 0;//richard.liu20141110
foreach (StatusCode sc in results)
{//richard.liu20141110
if (sc.Code != StatusCodes.Good)
{
ConnectCount[_PLCconnectionID]++;//20150204
OpcError =string.Format( "��OPC���ݴ�ȡ������д����ʱ,WriteValues:{0},{1}" ,nodesToWrite[ia].ToString() , "�ķ���ֵ�д�����"+sc.ToString());
return false;
}
ia++;
}
ConnectCount[_PLCconnectionID] = 0;//20150204
return true;
}
catch (Exception ex)
{
ConnectCount[_PLCconnectionID]++;//20150204
OpcError =string.Format( "��OPC���ݴ�ȡ������д����ʱ��{0},{1}" , ex.Message,ex.StackTrace);
_IfConnectOPCServer = false;
return false;
}
}
//���첽�ķ�ʽд��OPC����
public static bool AsyncWriteAllItemValue(string _PLCconnectionID,StringBuilder[] itemnames, StringBuilder[] itemvalues)
{
lock (thisLock)////20130306richard.liu
{
try
{
if (_IfConnectOPCServer == false)
{
if (ConnectOPCServer(_hostname, _progID) == false) return false;
}
if (ConnectCount.ContainsKey(_PLCconnectionID) == false)//20110726
{
ConnectCount.Add(_PLCconnectionID, 0);
}
if (ConnectCount[_PLCconnectionID] > 3)//20150204
{
_opcError = "д����ʱ��OPC Serverû���ӵ�PLC:" + _PLCconnectionID.ToString() + "���˹�ȷ�Ϻ����С�PLC��ʼ����";//20150204
return false;
}
NodeIdCollection nodesToWrite = new NodeIdCollection(itemnames.GetLength(0));
DataValueCollection values = new DataValueCollection(itemnames.GetLength(0));
StatusCodeCollection results = null;
int i = 0;
foreach (StringBuilder item in itemnames)
{
// Values to write.
String sValue = itemvalues[i].ToString();
// Leave current value if write value is empty.
if (sValue.Length == 0)
{
i++;
continue;
}
#region win7��64λ����ϵͳ��Ҫָ��ȷ�е���������//20151120
Type gt = typeof(byte);
if (item.ToString().IndexOf(",b") >= 0)//�޷����ֽ���0--255
{
gt = typeof(byte);
}
else if (item.ToString().IndexOf(",i") >= 0)//short���з��������ֽڵĵ���-32768��32767
{
gt = typeof(short);
}
else if (item.ToString().IndexOf(",w") >= 0)//ushort���޷��������ֽڵĵ���0��65535
{
gt = typeof(ushort);
}
else if (item.ToString().IndexOf(",di") >= 0)//int���з����ĸ��ֽڵ�˫��-2147483648��2147483647
{
gt = typeof(int);
}
else if (item.ToString().IndexOf(",dw") >= 0)//uint���޷����ĸ��ֽڵ�˫��0��4294967295
{
gt = typeof(uint);
}
else if (item.ToString().IndexOf(",dt") >= 0)//DateTime�����ں�ʱ�����ͣ�05/31/2016 08:21:10.123 PM
{
gt = typeof(DateTime);
}
Variant variant = new Variant(Convert.ChangeType(sValue, gt));
#endregion
DataValue value = new DataValue(variant);
values.Add(value);
// NodeIds.
String sNodeId = _PLCconnectionID + "." + item.ToString();
NodeId nodeId = new NodeId(sNodeId, S7NameSpace); //20151120
nodesToWrite.Add(nodeId);
i++;
}
// Call to ClientAPI.
m_Server.BeginWriteValues(
nodesToWrite,
values,
out results);
//results����ֵһֱΪnull���쳣��ClientAPI writeCallBack�����󸳸�OpcError
ConnectCount[_PLCconnectionID] = 0;//20150204
return true;
}
catch (Exception ex)
{
ConnectCount[_PLCconnectionID]++;//20150204
OpcError =string.Format( "��OPC���ݴ�ȡ������д����ʱ��{0},{1}", ex.Message,ex.StackTrace);
_IfConnectOPCServer = false;
return false;
}
}
}
/// <summary>
/// �����豸��������
/// </summary>
/// <param name="devIdx">�豸����</param>
/// <returns>�豸��������</returns>
static int GetDeviceKindIdx(int devIdx)
{
System.Object lockThis = new System.Object();
lock (lockThis)
{
try
{
DataView dv= dbo.ExceSQL(string.Format("SELECT F_DeviceKindIndex FROM T_Base_Device WHERE F_DeviceIndex={0}", devIdx)).Tables[0].DefaultView;
if (dv.Count > 0)
{
return System.Convert.ToInt32(dv[0]["F_DeviceKindIndex"]);
}
else
return 0;
}
catch (Exception ex)
{
throw ex;
}
}
}
public static void DisConnectOPCServer()
{
try
{
int result;
if (m_Server == null) return;
result = m_Server.Disconnect();
// Disconnect succeeded.
if (result == 0)
{
m_Subscription.RemoveAllMonitoredItems();//20150103���Ӷ����ָ�
m_Server.RemoveSubscription(m_Subscription);
m_Subscription = null;
}
_IfConnectOPCServer = false;//20140514�Ų���ɽ���������ִ�����
}
catch (Exception ex)
{
OpcError = "�ر�OPC���ݴ�ȡ������ʱ��" + ex.Message;
}
}
static void m_Server_CertificateEvent(CertificateValidator validator, CertificateValidationEventArgs e)
{
e.Accept = true;
}
}
}