-
Notifications
You must be signed in to change notification settings - Fork 5
/
Copy pathonvif_ptz.c
193 lines (162 loc) · 7.68 KB
/
onvif_ptz.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
#include <stdlib.h>
#include <string.h>
#include <stdint.h>
#include "soapH.h"
#include "soapStub.h"
#include "wsdd.h"
#include <uuid/uuid.h>
#define ONVIF_USER "admin"
#define ONVIF_PASSWORD "bq111111"
// 通过capa 或者probeMatches 获取，此例不再重复
#define SERVICE_ENDPOINT "http://192.168.0.236/onvif/device_service"
//SOAP_NAMESPACE_OF_tptz
struct soap* NewSoap(struct soap* soap)
{
soap = soap_new();
if(NULL == soap ) {
printf("[%d][%s][Soap New Error]\n", __LINE__, __func__);
return NULL;
}
soap->recv_timeout = 50;
soap_set_namespaces(soap, namespaces);
return soap ;
}
char* GetDeviceServices(struct soap* soap, struct _tds__GetServices *getServices, struct _tds__GetServicesResponse *getServicesResponse)
{
char* mediaEndPoint = "";
getServices->IncludeCapability = xsd__boolean__false_;
printf("[%d][%s][---- Getting Device Services ----]\n", __LINE__, __func__);
soap_wsse_add_UsernameTokenDigest(soap,"user", ONVIF_USER, ONVIF_PASSWORD);
int result = soap_call___tds__GetServices(soap, SERVICE_ENDPOINT, NULL, getServices, getServicesResponse);
printf("[%d][%s<%s!>][result = %d][soap_error = %d]\n", __LINE__, __func__, result ? "失败":"成功", result, soap->error);
int i;
if (getServicesResponse->Service != NULL) {
for(i = 0; i < getServicesResponse->__sizeService; i++) {
if (!strcmp(getServicesResponse->Service[i].Namespace, SOAP_NAMESPACE_OF_trt)) {
mediaEndPoint = getServicesResponse->Service[i].XAddr;
printf("[%d][%s][MediaServiceAddress:%s]\n",__LINE__, __func__, mediaEndPoint);
break;
}
}
}
return mediaEndPoint;
}
char* GetPTZServier(struct _tds__GetServicesResponse *getServicesResponse)
{
char *ep = "";
int i;
if (getServicesResponse->Service != NULL) {
for(i = 0; i < getServicesResponse->__sizeService; i++) {
//SOAP_NAMESPACE_OF_tptz
if (!strcmp(getServicesResponse->Service[i].Namespace, "http://www.onvif.org/ver20/ptz/wsdl")) {
ep = getServicesResponse->Service[i].XAddr;
printf("[%d][%s][MediaServiceAddress:%s]\n",__LINE__, __func__, ep);
break;
}
}
}
return ep;
}
int GetProfiles(struct soap* soap, struct _trt__GetProfiles *trt__GetProfiles,
struct _trt__GetProfilesResponse *trt__GetProfilesResponse, char* media_ep)
{
int result=0;
printf("[%d][%s][---- Getting Profiles ----]\n", __LINE__, __func__);
soap_wsse_add_UsernameTokenDigest(soap,"user", ONVIF_USER, ONVIF_PASSWORD);
result = soap_call___trt__GetProfiles(soap, media_ep, NULL, trt__GetProfiles, trt__GetProfilesResponse);
printf("[%d][%s<%s!>][result = %d][soap_error = %d]\n", __LINE__, __func__, result ? "失败":"成功", result, soap->error);
if (result == SOAP_EOF) {
printf("[%d][%s][Error Number:%d] [Falut Code:%s] [Falut Reason:%s]\n", __LINE__, __func__, soap->error, *soap_faultcode(soap), *soap_faultstring(soap));
return;
}
if(trt__GetProfilesResponse->Profiles != NULL) {
if(trt__GetProfilesResponse->Profiles->Name != NULL)
printf("[%d][%s][Profiles Name:%s]\n",__LINE__, __func__, trt__GetProfilesResponse->Profiles->Name);
if(trt__GetProfilesResponse->Profiles->VideoEncoderConfiguration != NULL)
printf("[%d][%s][Profiles Token:%s]\n",__LINE__, __func__, trt__GetProfilesResponse->Profiles->VideoEncoderConfiguration->Name);
}
return result;
}
int ContinuousMove(struct soap* soap, struct _trt__GetProfilesResponse *profiles, char* ptz_ep)
{
struct _tptz__ContinuousMove *move = (struct _tptz__ContinuousMove*)soap_malloc(soap, sizeof(struct _tptz__ContinuousMove));
soap_default__tptz__ContinuousMove(soap, move);
struct _tptz__ContinuousMoveResponse *moveResp = (struct _tptz__ContinuousMoveResponse*)soap_malloc(soap, sizeof(struct _tptz__ContinuousMoveResponse));
printf("[%d][%s] setprofiles\n", __LINE__, __func__);
move->ProfileToken = profiles->Profiles[0].token;
struct tt__PTZSpeed *speed = (struct tt__PTZSpeed*)soap_malloc(soap, sizeof(struct tt__PTZSpeed));
struct tt__Vector2D pantilt;
struct tt__Vector1D zoom;
pantilt.x = 0.2;
pantilt.y = 0.2;
pantilt.space = profiles[0].Profiles->PTZConfiguration->DefaultContinuousPanTiltVelocitySpace;
zoom.x = 0.2;
zoom.space = profiles[0].Profiles->PTZConfiguration->DefaultContinuousZoomVelocitySpace;
speed->PanTilt = &pantilt;
speed->Zoom = &zoom;
printf("[%d][%s] setArg speed\n", __LINE__, __func__);
move->Velocity = speed;
printf("[%d][%s] setArg timeout\n", __LINE__, __func__);
printf("[%d][%s] tokendigest\n", __LINE__, __func__);
soap_wsse_add_UsernameTokenDigest(soap, "user", ONVIF_USER, ONVIF_PASSWORD);
printf("[%d][%s] [endpoint : %s]\n", __LINE__, __func__, ptz_ep);
int result = soap_call___tptz__ContinuousMove(soap, ptz_ep, NULL, move, moveResp);
printf("[%d][%s<%s!>][result = %d][soap_error = %d]\n", __LINE__, __func__, result ? "失败":"成功", result, soap->error);
if (result == SOAP_EOF) {
printf("[%d][%s][Error Number:%d] [Falut Code:%s] [Falut Reason:%s]\n", __LINE__, __func__, soap->error, *soap_faultcode(soap), *soap_faultstring(soap));
return SOAP_ERR;
}
return result;
}
int GotoHomePos(struct soap* soap, struct _trt__GetProfilesResponse *profiles, char* ep)
{
// get/set/goto 3setp;
struct _tptz__GotoHomePosition *gohome = (struct _tptz__GotoHomePosition*)soap_malloc(soap, sizeof(struct _tptz__GotoHomePosition));
struct _tptz__GotoHomePositionResponse *gohomeresp = (struct _tptz__GotoHomePositionResponse*)soap_malloc(soap, sizeof(struct _tptz__GotoHomePositionResponse));
gohome->ProfileToken = profiles->Profiles[0].token;
gohome->Speed = profiles[0].Profiles->PTZConfiguration->DefaultPTZSpeed;
int result = soap_call___tptz__GotoHomePosition(soap, ep, NULL, gohome, gohomeresp);
printf("[%d][%s<%s!>][result = %d][soap_error = %d]\n", __LINE__, __func__, result ? "失败":"成功", result, soap->error);
if (result == SOAP_EOF) {
printf("[%d][%s][Error Number:%d][Falut Code:%s] [Falut Reason:%s]\n", __LINE__, __func__, soap->error, *soap_faultcode(soap), *soap_faultstring(soap));
return SOAP_ERR;
}
return result;
}
#if 0 // TODO
int GotoPreset(struct soap* soap, struct _trt__GetProfilesResponse *profiles, char* ptz_ep)
{
// get/set/goto 3setp;
struct _tptz__GotoPreset *gopreset;
struct _tptz__GotoPresetResponse *gopresetresp;
int result = soap_call___tptz__GotoPreset(soap, ep, NULL, gopreset, gopresetresp);
}
#endif
void FollowStepsToPerform(struct soap *soap)
{
struct _trt__GetProfiles trt__GetProfiles;
struct _trt__GetProfilesResponse profiles;
struct _tds__GetServices getServices;
soap_default__tds__GetServices(soap, &getServices);
struct _tds__GetServicesResponse getServicesResponse;
char *ptz_ep;
char *media_ep = GetDeviceServices(soap, &getServices, &getServicesResponse);
if (media_ep != "") {
ptz_ep = GetPTZServier(&getServicesResponse);
GetProfiles(soap, &trt__GetProfiles, &profiles, media_ep);
// ContinuousMove(soap, &profiles, ptz_ep);
GotoHomePos(soap, &profiles, ptz_ep);
}
}
int main()
{
printf("[%s][%d][%s][%s][---- ONVIF Device Test Started ----]\n", __FILE__, __LINE__, __TIME__, __func__);
struct soap *soap;
soap = NewSoap(soap);
FollowStepsToPerform(soap);
soap_destroy(soap);
soap_end(soap);
soap_free(soap);
printf("[%s][%d][%s][%s][---- ONVIF Device Test Complete ----]\n", __FILE__, __LINE__, __TIME__, __func__);
return 0;
}