367 lines
10 KiB
C#
367 lines
10 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Runtime.InteropServices;
|
|
using OpcRcw.Da;
|
|
using OpcRcw.Comn;
|
|
namespace Common
|
|
{
|
|
/// <summary>
|
|
/// 同步读写plc
|
|
/// </summary>
|
|
public class PLClock : IPLCAbstract
|
|
{
|
|
#region 参数值
|
|
public object[] textValue = new object[2];
|
|
/// <summary>
|
|
/// OPCServer
|
|
/// </summary>
|
|
public IOPCServer ServerObj;//OPCServer
|
|
/// <summary>
|
|
/// 同步步读写对象
|
|
/// </summary>
|
|
public IOPCSyncIO IOPCSyncIO2Obj = null;
|
|
|
|
/// <summary>
|
|
/// 组管理对象
|
|
/// </summary>
|
|
public IOPCGroupStateMgt IOPCGroupStateMgtObj = null;
|
|
|
|
|
|
public const int LOCALE_ID = 0x407;
|
|
|
|
public int pSvrGroupHandle = 0;
|
|
/// <summary>
|
|
/// 返回增加的group
|
|
/// </summary>
|
|
public Object MyobjGroup1 = null;
|
|
|
|
public string itemDvalue = "0";
|
|
|
|
|
|
/// <summary>
|
|
/// item的数组句柄
|
|
/// </summary>
|
|
public int[] ItemServerHandle;
|
|
/// <summary>
|
|
/// item的值。
|
|
/// </summary>
|
|
public OPCITEMDEF[] ItemArray;
|
|
#endregion
|
|
|
|
#region plc的链接
|
|
/// <summary>
|
|
/// plc的链接
|
|
/// </summary>
|
|
/// <param name="remoteServerName">链接的名字（）</param>
|
|
/// <param name="remoteServerIP">链接的ip地址</param>
|
|
/// <returns></returns>
|
|
public string ConnectRemoteServer()
|
|
{
|
|
string errText = string.Empty;
|
|
try
|
|
{
|
|
////建议一个连接
|
|
Type svrComponenttyp = Type.GetTypeFromProgID("OPC.SimaticNet", "localhost");
|
|
|
|
ServerObj = (IOPCServer)Activator.CreateInstance(svrComponenttyp);
|
|
}
|
|
|
|
catch (Exception ex)
|
|
{
|
|
|
|
errText = "连接远程服务器出现错误:" + ex.Message.ToString();
|
|
}
|
|
|
|
return errText;
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 增加group
|
|
/// <summary>
|
|
/// 增加group
|
|
/// </summary>
|
|
/// <param name="Form_Main"></param>
|
|
/// <returns></returns>
|
|
public string PLCGroupAdd()
|
|
{
|
|
string errText = string.Empty;
|
|
Int32 dwRequestedUpdateRate = 100;
|
|
//Int32 hClientGroup;
|
|
Int32 pRevUpdateRate;
|
|
|
|
float deadband = 0;
|
|
|
|
int TimeBias = 0;
|
|
GCHandle hTimeBias, hDeadband;
|
|
hTimeBias = GCHandle.Alloc(TimeBias, GCHandleType.Pinned);
|
|
hDeadband = GCHandle.Alloc(deadband, GCHandleType.Pinned);
|
|
Guid iidRequiredInterface = typeof(IOPCItemMgt).GUID;
|
|
try
|
|
{
|
|
ServerObj.AddGroup("MyOPCGroup1",//组对象
|
|
0,
|
|
dwRequestedUpdateRate,
|
|
1,
|
|
hTimeBias.AddrOfPinnedObject(),
|
|
hDeadband.AddrOfPinnedObject(),
|
|
LOCALE_ID,
|
|
out pSvrGroupHandle,
|
|
out pRevUpdateRate,
|
|
ref iidRequiredInterface,
|
|
out MyobjGroup1);
|
|
|
|
IOPCSyncIO2Obj = (IOPCSyncIO)MyobjGroup1;
|
|
//Query interface for Async calls on group object
|
|
|
|
IOPCGroupStateMgtObj = (IOPCGroupStateMgt)MyobjGroup1;
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
errText = ex.Message.ToString();
|
|
}
|
|
return errText;
|
|
}
|
|
#endregion
|
|
|
|
#region 增加item
|
|
/// <summary>
|
|
/// 增加item
|
|
/// </summary>
|
|
/// <param name="items"></param>
|
|
/// <returns></returns>
|
|
public string PLCItemAdd(OPCITEMDEF[] items)
|
|
{
|
|
|
|
string errText = string.Empty;
|
|
IntPtr pResults = IntPtr.Zero;
|
|
IntPtr pErrors = IntPtr.Zero;
|
|
try
|
|
{
|
|
|
|
((IOPCItemMgt)MyobjGroup1).AddItems(items.Length, items, out pResults, out pErrors);
|
|
|
|
int[] errors = new int[items.Length];
|
|
Marshal.Copy(pErrors, errors, 0, items.Length);
|
|
ItemServerHandle = new int[items.Length];
|
|
IntPtr pos = pResults;
|
|
OPCITEMRESULT result;
|
|
|
|
if (errors[0] == 0)
|
|
{
|
|
result = (OPCITEMRESULT)Marshal.PtrToStructure(pos, typeof(OPCITEMRESULT));
|
|
ItemServerHandle[0] = result.hServer;
|
|
}
|
|
|
|
for (int i = 1; i < errors.Length; i++)
|
|
{
|
|
|
|
if (errors[i] == 0)
|
|
{
|
|
|
|
pos = new IntPtr(pos.ToInt32() + Marshal.SizeOf(typeof(OPCITEMRESULT)));
|
|
result = (OPCITEMRESULT)Marshal.PtrToStructure(pos, typeof(OPCITEMRESULT));
|
|
|
|
ItemServerHandle[i] = result.hServer;
|
|
|
|
}
|
|
|
|
}
|
|
return errText;
|
|
|
|
}
|
|
|
|
catch (System.Exception ex) // catch for add item
|
|
{
|
|
|
|
return ex.Message.ToString().Trim();
|
|
|
|
}
|
|
|
|
finally
|
|
{
|
|
|
|
// Free the memory
|
|
|
|
if (pResults != IntPtr.Zero)
|
|
{
|
|
|
|
Marshal.FreeCoTaskMem(pResults);
|
|
|
|
pResults = IntPtr.Zero;
|
|
|
|
}
|
|
|
|
if (pErrors != IntPtr.Zero)
|
|
{
|
|
|
|
Marshal.FreeCoTaskMem(pErrors);
|
|
|
|
pErrors = IntPtr.Zero;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
#endregion
|
|
|
|
|
|
/// <summary>
|
|
/// 读plc
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public List<object> ReadPlc()
|
|
{
|
|
object[] redValue = new object[ItemServerHandle.Length];
|
|
IntPtr pItemValues = IntPtr.Zero; IntPtr pErrors = IntPtr.Zero;
|
|
IOPCSyncIO2Obj.Read(OPCDATASOURCE.OPC_DS_DEVICE, 5, ItemServerHandle, out pItemValues, out pErrors);
|
|
int[] errors = new int[ItemServerHandle.Length];
|
|
|
|
Marshal.Copy(pErrors, errors, 0, ItemServerHandle.Length);
|
|
OPCITEMSTATE[] pItemState = new OPCITEMSTATE[ItemServerHandle.Length];
|
|
List<object> value = new List<object>();
|
|
for (int i = 0; i < ItemServerHandle.Length; i++)
|
|
{
|
|
if (errors[i] == 0)
|
|
{
|
|
pItemState[0] = (OPCITEMSTATE)Marshal.PtrToStructure(pItemValues, typeof(OPCITEMSTATE));
|
|
|
|
pItemValues = new IntPtr(pItemValues.ToInt32() + Marshal.SizeOf(typeof(OPCITEMSTATE)));
|
|
value.Add((object)pItemState[0].vDataValue);
|
|
}
|
|
}
|
|
return value;
|
|
|
|
}
|
|
|
|
#region 写plc
|
|
/// <summary>
|
|
/// 写plc
|
|
/// </summary>
|
|
/// <param name="values"></param>
|
|
/// <returns></returns>
|
|
public string WirtePlc(object[] values)
|
|
{
|
|
string errText = string.Empty;
|
|
//int nCancelid;
|
|
IntPtr pErrors = IntPtr.Zero;
|
|
if (IOPCSyncIO2Obj != null)
|
|
{
|
|
try
|
|
{
|
|
IOPCSyncIO2Obj.Write(ItemServerHandle.Length, ItemServerHandle, values, out pErrors);
|
|
int[] errors = new int[ItemServerHandle.Length];
|
|
Marshal.Copy(pErrors, errors, 0, ItemServerHandle.Length);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
errText = ex.Message.ToString().Trim();
|
|
}
|
|
}
|
|
return errText;
|
|
}
|
|
#endregion
|
|
|
|
#region 断开PLC的连接
|
|
|
|
/// <summary>
|
|
/// 断开PLC的连接
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string DisConnection()
|
|
{
|
|
string errText = string.Empty;
|
|
try
|
|
{
|
|
|
|
if (IOPCSyncIO2Obj != null)
|
|
{
|
|
Marshal.ReleaseComObject(IOPCSyncIO2Obj);
|
|
IOPCSyncIO2Obj = null;
|
|
}
|
|
|
|
ServerObj.RemoveGroup(pSvrGroupHandle, 0);
|
|
if (IOPCGroupStateMgtObj != null)
|
|
{
|
|
Marshal.ReleaseComObject(IOPCGroupStateMgtObj);
|
|
IOPCGroupStateMgtObj = null;
|
|
}
|
|
if (MyobjGroup1 != null)
|
|
{
|
|
Marshal.ReleaseComObject(MyobjGroup1);
|
|
MyobjGroup1 = null;
|
|
}
|
|
if (ServerObj != null)
|
|
{
|
|
Marshal.ReleaseComObject(ServerObj);
|
|
ServerObj = null;
|
|
}
|
|
}
|
|
catch (System.Exception error)
|
|
{
|
|
errText = error.Message.ToString().Trim();
|
|
|
|
}
|
|
return errText;
|
|
|
|
}
|
|
#endregion
|
|
|
|
#region IPLCAbstract 成员
|
|
public object wirteDataValue;
|
|
/// <summary>
|
|
/// 写入的值
|
|
/// </summary>
|
|
public object WriteDataValue
|
|
{
|
|
get
|
|
{
|
|
return wirteDataValue;
|
|
}
|
|
set
|
|
{
|
|
wirteDataValue =value;
|
|
}
|
|
}
|
|
public object readDataValue;
|
|
/// <summary>
|
|
/// 读出的值
|
|
/// </summary>
|
|
public object ReadDataValue
|
|
{
|
|
get { return readDataValue;}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public string DataChange()
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public virtual string ReadWritePlcData()
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
#endregion
|
|
|
|
|
|
public string PLCGroupAdd(object Form_Main)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
string IPLCAbstract.ReadPlc()
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
}
|
|
}
|