mode444/opcuaClient
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

12.24

Browse Source
This commit is contained in:
ubiboy 2024-12-24 20:13:57 +08:00
parent c9370e53db
commit 9e7793ea5f
1 changed files with 52 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
myClient.c
View File

@ -343,6 +343,58 @@ u32 UA_SubscriptionDelete(long ConnectionHdl,long SubscriptionHdl){
return retval;
}
u32 SubscriptionHdlzu2[100];
u32 MonItemHdlzu[100];
UAMonitoredVariables MonVlaue[100];
int MontNum=0;
static void handler_DataChanged(UA_Client *client, UA_UInt32 subId,
void *subContext, UA_UInt32 monId,
void *monContext, UA_DataValue *value)
{
UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_CLIENT, "Received Notification");
UA_NodeId *ptr = (UA_NodeId*)monContext;
SubscriptionHdlzu2[MontNum]=subId;
MonItemHdlzu[MontNum]=monId;
MonVlaue[MontNum].Values.data=value->value.data;
MonVlaue[MontNum].Values.type=value->value.type->typeId.identifier.numeric;
UA_DateTime now = UA_DateTime_nowMonotonic();
MonVlaue[MontNum].TimeStamps=now;
MonVlaue[MontNum].NewValuesCount=1;
//MonVlaue[MontNum].NodeQualityIDs[0]=0;
//UA_Int32 currentValue = *(UA_Int32*)(value->value.data);
MontNum++;
}
u32 MonitoredItemAddList(long ConnectionHdl,long SubscriptionHdl,u16 NodeHdlCount,
long *NodeHdls,UAMonitoringSyncMode SyncMode,
UANodeAdditionalInfo *NodeAddInfos,u32 *MonitoredItemHdls,u32 ErrorIDs[]){
UA_Client *c = (UA_Client*)ConnectionHdl;
u32 retval=0;
if(NodeHdlCount>MAX_ELEMENTS_MONITORLIST){
retval=0xA0000002;
return retval;
}
if(SyncMode==UAMS_ControllerSync){
for(int i=0;i<NodeHdlCount;i++){
UA_NodeId *NodeID=(UA_NodeId*)NodeHdls[i];
UA_MonitoredItemCreateRequest monRequest=UA_MonitoredItemCreateRequest_default(*NodeID);
monRequest.itemToMonitor.attributeId = NodeAddInfos[i].AttributeID;
UA_MonitoredItemCreateResult monResponse=
UA_Client_MonitoredItems_createDataChange(c,SubscriptionHdl,UA_TIMESTAMPSTORETURN_BOTH,
monRequest,NodeID,handler_DataChanged,NULL);
if(monResponse.statusCode!=UA_STATUSCODE_GOOD){
retval=monResponse.statusCode;
}
ErrorIDs[i]=monResponse.statusCode;
MonitoredItemHdls[i]=monResponse.monitoredItemId;
}
}
return retval;
}
int main(int argc, char *argv[]) {
// long connecthdl;