【正文】 E6C32641,0XF1CF,0X11D0,{0XB0,0Xe4,0X08,0X00,0X09,0Xcc,0Xd3,0X84}}。ifndef __ON_ERROR_OPC__define __ON_ERROR_OPC__ \if(result!=S_OK){\thisReleaseResources()。\return result。\}/*USED FOR DETECT MEMORY LEAK*/endififdef _DEBUGdefine SET_CRT_DEBUG_FIELD(a) \_CrtSetDbgFlag((a) | _CrtSetDbgFlag(_CRTDBG_REPORT_FLAG))define CLEAR_CRT_DEBUG_FIELD(a) \_CrtSetDbgFlag(~(a) amp。 _CrtSetDbgFlag(_CRTDBG_REPORT_FLAG))elsedefine SET_CRT_DEBUG_FIELD(a) ((void) 0)define CLEAR_CRT_DEBUG_FIELD(a) ((void) 0)endif/*USED FOR DETECT MEMORY LEAK*/long __stdcall OPCDCSConnector::Initialize(){HRESULT r1。r1 = CoInitialize(NULL)。if(r1!=S_OK){return r1。}return r1。}Long __stdcall OPCDCSConnector::Connect(IN ConnectStr * pConnectStr ){long result=S_OK。CLSID CLSID_OPCServer。COSERVERINFO csi, *pcsi=NULL。WCHAR wsz [MAX_PATH]。if (pConnectStrparam2!=NULLamp。amp。strlen(pConnectStrparam2)0) {MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED,pConnectStrparam2 , 1,wsz, MAX_PATH)。//MessageBox(NULL,wsz,wsz,MB_OK)。memset(amp。csi, 0, sizeof(COSERVERINFO))。 = wsz。pcsi = amp。csi。}if(pConnectStr==NULL||pConnectStrparam1==NULL){result=1。return result。}thism_szOPCServer=(char *)pConnectStrparam1。// get the CLSID from the OPC Server Name:int iBuffLength=MultiByteToWideChar(CP_ACP,0,thism_szOPCServer,1,NULL,0)。WCHAR * BUFF=(WCHAR *)HeapAlloc(GetProcessHeap(),0,iBuffLength*sizeof(WCHAR))。MultiByteToWideChar(CP_ACP,0,thism_szOPCServer,1,BUFF,iBuffLength)。//MessageBox(NULL,BUFF,NULL,0)。 @@@result = CLSIDFromString(BUFF, amp。CLSID_OPCServer)。//coutresult : result CLSIDFromString:BUFFendl。 @@@if (result!=S_OK) {// coutCan not get the remote server CLSIDendl。 @@@}__ON_ERROR_OPC__。//queue of the class instances to createLONG cmq = 1。 // nbr of class instance to create.MULTI_QI queue[1] ={{amp。IID_IOPCServer,NULL,0}}。// create an instance of the IOPCServerresult = CoCreateInstanceEx(CLSID_OPCServer, NULL, CLSCTX_ALL,/*amp。CoServerInfo*/pcsi, cmq, queue)。//printf(CoCreateInstanceEx : %0x \n,result)。 @@@!=S_OK) {//coutCan not CoCreateInstanceEx()endl。 @@@}__ON_ERROR_OPC__。// return a pointer to the IOPCServer interface:thism_pIOPCServer=(IOPCServer*) queue[0].pItf。//取得IOPServer接口//add groupresult=AddTheGroup(thism_pIOPCServer,thism_pIOPCItemMgt,thism_hServerGroup)。__ON_ERROR_OPC__。return result。}long __stdcall OPCDCSConnector::read(OUT Item * pItem){OPCHANDLE hServerItem=0。long result=S_OK。//do not try to abstract these codes into one method ,because u should not return thre reference which is allocated in it39。s selfint iwbuffLength=MultiByteToWideChar(CP_ACP,0,pItemszItemName,1,NULL,0)。WCHAR * wbuff= new WCHAR[iwbuffLength]。memset(wbuff,0,sizeof(WCHAR)*iwbuffLength)。MultiByteToWideChar(CP_ACP,0,pItemszItemName,1,wbuff,iwbuffLength)。//mapWCHAR *,OPCHANDLE::iterator it=(wbuff)。//if(it!=()){// hServerItem=(*it).second。//}else{result=AddTheItem(thism_pIOPCItemMgt,hServerItem,wbuff,pItem)。// ( mapWCHAR *,OPCHANDLE::value_type(wbuff,hServerItem))。//insertCount++。//this should be never happened//if(insertCount10){// couterrorendl。//}//}if(result!=S_OK){return result。}VariantInit(amp。(pItemvalue))。result=ReadItem(thism_pIOPCItemMgt,hServerItem,pItemvalue,amp。(pItemtimestamp))。// if(result!=S_OK){// RemoveItem(thism_pIOPCItemMgt,hServerItem)。// //(wbuff)。// }RemoveItem(thism_pIOPCItemMgt,hServerItem)。delete [] wbuff。return result。}long __stdcall OPCDCSConnector::ReleaseResources(){long result=S_OK。if(thism_hGroupHandle!=NULL){RemoveGroup(thism_pIOPCServer,thism_hGroupHandle)。}if(thism_pIOPCItemMgt!=NULL){thism_pIOPCItemMgtRelease()。}if(thism_pIOPCServer!=NULL){thism_pIOPCServerRelease()。}CoUninitialize()。return result。}long OPCDCSConnector::getLastError(OUT char * buff){long result=S_OK。return result。}long OPCDCSConnector::read(OUT Item * pItemArray,IN const int iLength){long result=S_OK。if(iLength0||pItemArray==NULL){return 1。}for(int i=0。iiLength。i++){pItem _pItem=(pItemArray+i)。result=thisread(_pItem)。if(result!=S_OK){break。}}return result。}long OPCDCSConnector::Write(IN const Item * pItemArray,IN const int iLength){long result=S_OK。return result。}long OPCDCSConnector::Write(IN const Item *){long result=S_OK。return result。}long AddTheGroup(IOPCServer* pIOPCServer, IOPCItemMgt* amp。pIOPCItemMgt,OPCHANDLEamp。 hServerGroup){DWORD dwUpdateRate = 100。OPCHANDLE hClientGroup = 0。// Add an OPC group and get a pointer to the IUnknown I/F:HRESULT hr = pIOPCServerAddGroup(/*szName*/ Ltest,/*bActive*/ FALSE,/*dwRequestedUpdateRate*/ dwUpdateRate,/*hClientGroup*/ hClientGroup,/*pTimeBias*/ 0,/*pPercentDeadband*/ 0,/*dwLCID*/0,/*phServerGroup*/amp。hServerGroup,amp。dwUpdateRate,/*riid*/ IID_IOPCItemMgt,/*ppUnk*/ (IUnknown**) amp。pIOPCItemMgt)。return hr。}long AddTheItem(IOPCItemMgt* pIOPCItemMgt, OPCHANDLEamp。 hServerItem, WCHAR * ITEM_ID, unsigned short VT){HRESULT hr。// Array of items to add:OPCITEMDEF ItemArray[1] ={{/*szAccessPath*/ L,/*szItemID*/ ITEM_ID,/*bActive*/ FALSE,/*hClient*/ 1,/*dwBlobSize*/ 0,/*pBlob*/ NULL,/*vtRequestedDataType*/ VT,/*wReserved*/0}}。//Add Result:OPCITEMRESULT* pAddResult=NULL。HRESULT* pErrors = NULL。if (pIOPCItemMgt==NULL) {return 1。}// Add an Item to the previous Group:hr = pIOPCItemMgtAddItems(1, ItemArray, amp。pAddResult, amp。pErrors)。if (hr!=S_OK) {return 1。}// Server handle for the added item:hServerItem = pAddResult[0].hServer。// release memory allocated by the server:CoTaskMemFree(pAddResultpBlob)。CoTaskMemFree(pAddResult)。pAddResult = NULL。CoTaskMemFree(pErrors)。pErrors = NULL。return hr。}long writeItem(IUnknown* pGroupIUnknown, OPCHANDLE hServerItem, VARIANTamp。 varValue){//get a p