RequestManagerClass.php
5.02 KB
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
<?php
/**
* @class RequestManagerClass
* @brief Main class to manage a request that's come from an AMDA client
* @details
*/
Class RequestManagerClass
{
public static $version = "1.6.0";
/*
* @brief Constructor
*/
function __construct()
{
}
/*
* @brief Treat a request that's come from the WebServices
*/
public function runWSRequest($user, $userHost, $function, $service = "", $input)
{
if (isset($service))
WSInputOutputClass::setService($service);
//TODO time table conversions can be made by AMDA_Kernel
if ($function == FunctionTypeEnumClass::PARAMS ) // || $function == FunctionTypeEnumClass::TTCONVERT)
KernelConfigClass::setTimeToBatchMode(WSConfigClass::$timeToBatchMode);
return $this->runGenericRequest(ClientTypeEnumClass::WS, $user, $userHost, $function, $input);
}
/*
* @brief Treat a request that's come from the IHM
*/
public function runIHMRequest($user, $userHost, $function, $input)
{
return $this->runGenericRequest(ClientTypeEnumClass::IHM,$user,$userHost,$function,$input);
}
/*
* @brief Treat a request that's come from a test script
*/
public function runTestRequest($user, $function, $input)
{
$userHost = "";
return $this->runGenericRequest(ClientTypeEnumClass::TEST,$user,$userHost,$function,$input);
}
/*
* @brief Treat a request that's come from AMDA shared objects updater
*/
public function runSharedObjectsUpdaterRequest($function, $input)
{
$user = "";
$userHost = "";
return $this->runGenericRequest(ClientTypeEnumClass::SHAREDOBJECTSUPDATER,$user,$userHost,$function,$input);
}
/*
* @brief Create the request instance in relation with the function type
*/
private function createRequest($user, $userHost, $function)
{
switch ($function)
{
case FunctionTypeEnumClass::PARAMS :
case FunctionTypeEnumClass::PARAMSGEN :
case FunctionTypeEnumClass::PARAMSINFOGEN :
return new ParamsRequestClass($user, $userHost);
case FunctionTypeEnumClass::ACTION :
return new ParamsRequestClass($user, $userHost);
case FunctionTypeEnumClass::PROCESSDELETE :
case FunctionTypeEnumClass::PROCESSRUNNINGINFO :
case FunctionTypeEnumClass::PROCESSGETINFO :
case FunctionTypeEnumClass::PROCESSCLEAN :
case FunctionTypeEnumClass::PROCESSGETREQUEST :
return new ProcessRequestClass($user, $userHost);
case FunctionTypeEnumClass::TTMERGE :
case FunctionTypeEnumClass::TTUNION :
case FunctionTypeEnumClass::TTCONVERT :
return new TTRequestClass($user, $userHost);
case FunctionTypeEnumClass::PARAMINFO :
return new ParamInfoRequestClass($user, $userHost);
case FunctionTypeEnumClass::USERWSINIT :
return new UserRequestClass($user, $userHost);
default :
throw new Exception('Request '.$function.' not implemented.');
}
}
/*
* @brief Create an instance of the InputOutput interface in relation with the client
*/
private function createInputOutput($user,$userHost = null,$client)
{
switch ($client)
{
case ClientTypeEnumClass::IHM :
return new IHMInputOutputClass($user, $userHost);
case ClientTypeEnumClass::WS :
return new WSInputOutputClass($user, $userHost);
case ClientTypeEnumClass::TEST :
return new TestInputOutputClass($user);
case ClientTypeEnumClass::SHAREDOBJECTSUPDATER :
return new SharedObjectsUpdaterInputOutputClass();
default :
throw new Exception('Client '.$client.' not implemented.');
}
}
/*
* @brief Sequence used to run a request
*/
private function runGenericRequest($client,$user,$userHost,$function,$input)
{
//create an instance of the InputOutput interface
$inputOutput = $this->createInputOutput($user, $userHost, $client);
//get the input data from the request input data by using the InputOutput interface
$inputdata = $inputOutput->getInputData($input,$function);
//create an instance of the RequestClass to run the request
$request = $this->createRequest($user, $userHost, $function);
if (is_array($inputdata))
{
$outputdata = array();
foreach ($inputdata as $data)
//execute the request
$outputdata[] = $this->runSingleRequest($request,$data);
}
else
$outputdata = $this->runSingleRequest($request,$inputdata);
//get the request output data from the output data by using the InputOutput interface
return $inputOutput->getOutput($outputdata);
}
/*
* @brief Run a single request
*/
private function runSingleRequest($request,$data)
{
//link the request to the input data
$request->setData($data);
//init the request
if (!$request->init())
{
$crtData = $request->getData();
if (isset($crtData))
throw new Exception('Request initialization error : '.$crtData->getLastErrorMessage());
else
throw new Exception('Cannot init request. Unknown error.');
}
//run the request
if (!$request->run())
{
$crtData = $request->getData();
if ($crtData)
throw new Exception('Request execution error : '.$crtData->getLastErrorMessage());
else
throw new Exception('Cannot run request. Unknown error.');
}
return $request->getData();
}
}
?>