RequestManagerClass.php
4.2 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
<?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, $service, $input)
{
WSInputOutputClass::setService($service);
KernelConfigClass::setTimeToBatchMode(WSConfigClass::$timeToBatchMode);
return $this->runGenericRequest(ClientTypeEnumClass::WS,$user,$userHost, FunctionTypeEnumClass::PARAMS, $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 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::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);
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);
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();
}
}
?>