|
1
|
|
|
<?php |
|
2
|
|
|
/** |
|
3
|
|
|
Copyright (C) 2018-2020 KANOUN Salim |
|
4
|
|
|
This program is free software; you can redistribute it and/or modify |
|
5
|
|
|
it under the terms of the Affero GNU General Public v.3 License as published by |
|
6
|
|
|
the Free Software Foundation; |
|
7
|
|
|
This program is distributed in the hope that it will be useful, |
|
8
|
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
9
|
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
10
|
|
|
Affero GNU General Public Public for more details. |
|
11
|
|
|
You should have received a copy of the Affero GNU General Public Public along |
|
12
|
|
|
with this program; if not, write to the Free Software Foundation, Inc., |
|
13
|
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
|
14
|
|
|
*/ |
|
15
|
|
|
|
|
16
|
|
|
/** |
|
17
|
|
|
* Import patient in study (import data from Json structured file) |
|
18
|
|
|
*/ |
|
19
|
|
|
|
|
20
|
|
|
class Import_Patient { |
|
21
|
|
|
|
|
22
|
|
|
private $originalJson; |
|
23
|
|
|
private $linkpdo; |
|
24
|
|
|
public $sucessList; |
|
25
|
|
|
public $failList; |
|
26
|
|
|
private $study; |
|
27
|
|
|
private $studyObject; |
|
28
|
|
|
|
|
29
|
|
|
public function __construct($originalJson, $study, $linkpdo) { |
|
30
|
|
|
$this->linkpdo=$linkpdo; |
|
31
|
|
|
//Store the JSON file and the target study |
|
32
|
|
|
$this->originalJson=$originalJson; |
|
33
|
|
|
$this->study=$study; |
|
34
|
|
|
$this->studyObject=new Study($study, $linkpdo); |
|
35
|
|
|
} |
|
36
|
|
|
|
|
37
|
|
|
public function readJson() { |
|
38
|
|
|
$jsonImport=json_decode($this->originalJson, true); |
|
39
|
|
|
|
|
40
|
|
|
//For each patient from the array list |
|
41
|
|
|
foreach ($jsonImport as $patient) { |
|
42
|
|
|
//Get patient info |
|
43
|
|
|
$patientNumber=$patient['patientNumber']; |
|
44
|
|
|
$patientLastName=$patient['lastName']; |
|
45
|
|
|
$patientFirstName=$patient['firstName']; |
|
46
|
|
|
$patientGender=$patient['gender']; |
|
47
|
|
|
$patientInvestigatorNumCenter=$patient['investigatorNumCenter']; |
|
48
|
|
|
$patientDateOfBirth=$patient['dateOfBirth']; |
|
49
|
|
|
$patientInvestigatorName=$patient['investigatorName']; |
|
50
|
|
|
$patientRegistrationDate=$this->parseRegistrationDate($patient['registrationDate']); |
|
51
|
|
|
|
|
52
|
|
|
//Check condition before import |
|
53
|
|
|
$isNewPatient=$this->isNewPatient($patientNumber); |
|
54
|
|
|
$isCorrectPatientNumberLenght=$this->isCorrectPatientNumberLenght($patientNumber); |
|
55
|
|
|
$isExistingCenter=$this->isExistingCenter($patientInvestigatorNumCenter); |
|
56
|
|
|
$isPrefixCorrect=$this->isCorrectPrefix($patientNumber); |
|
57
|
|
|
|
|
58
|
|
|
if ($isNewPatient && $isCorrectPatientNumberLenght && $isPrefixCorrect && $isExistingCenter && !empty($patientRegistrationDate)) { |
|
59
|
|
|
//Store in DB |
|
60
|
|
|
$birthDateArray=explode("/", $patientDateOfBirth); |
|
61
|
|
|
if (GAELO_DATE_FORMAT == 'm.d.Y') { |
|
62
|
|
|
$birthDay=intval($birthDateArray[1]); |
|
63
|
|
|
$birthMonth=intval($birthDateArray[0]); |
|
64
|
|
|
}else if (GAELO_DATE_FORMAT == 'd.m.Y') { |
|
65
|
|
|
$birthDay=intval($birthDateArray[0]); |
|
66
|
|
|
$birthMonth=intval($birthDateArray[1]); |
|
67
|
|
|
} |
|
68
|
|
|
$birthYear=intval($birthDateArray[2]); |
|
69
|
|
|
|
|
70
|
|
|
$insertddb=$this->addPatientToDatabase($patientNumber, $patientLastName, $patientFirstName, $patientGender, |
|
71
|
|
|
$patientInvestigatorNumCenter, $patientRegistrationDate, $birthDay, $birthMonth, $birthYear, $patientInvestigatorName); |
|
|
|
|
|
|
72
|
|
|
|
|
73
|
|
|
//Store the patient result import process in this object |
|
74
|
|
|
if ($insertddb) { |
|
75
|
|
|
$this->sucessList[]=$patientNumber; |
|
76
|
|
|
}else { |
|
77
|
|
|
$patientFailed['PatientNumber']=$patientNumber; |
|
78
|
|
|
$patientFailed['Reason']="Can't write to DB, wrong date or other wrong input"; |
|
79
|
|
|
$this->failList[]=$patientFailed; |
|
80
|
|
|
} |
|
81
|
|
|
|
|
82
|
|
|
//If conditions not met, add to the fail list with the respective error reason |
|
83
|
|
|
}else { |
|
84
|
|
|
|
|
85
|
|
|
if (!$isExistingCenter) { |
|
86
|
|
|
if (empty($patientInvestigatorNumCenter)) { |
|
87
|
|
|
$this->failList['Missing Num Center'][]=$patientNumber; |
|
88
|
|
|
}else { |
|
89
|
|
|
$this->failList['Unknown Center'][]=$patientNumber; |
|
90
|
|
|
} |
|
91
|
|
|
|
|
92
|
|
|
}else if (!$isCorrectPatientNumberLenght) { |
|
93
|
|
|
$this->failList['Wrong PatientNumber length'][]=$patientNumber; |
|
94
|
|
|
|
|
95
|
|
|
}else if (!$isNewPatient) { |
|
96
|
|
|
if( !empty($patientRegistrationDate) ){ |
|
97
|
|
|
$updated = $this->tryUpdateRegistrationDate($patientNumber, $patientRegistrationDate->format('Y-m-d')); |
|
98
|
|
|
if($updated){ |
|
99
|
|
|
$this->sucessList[]=$patientNumber.' - Updated Registration Date'; |
|
100
|
|
|
}else{ |
|
101
|
|
|
$this->failList['Patient already in Database'][]=$patientNumber; |
|
102
|
|
|
} |
|
103
|
|
|
}else{ |
|
104
|
|
|
$this->failList['Patient already in Database'][]=$patientNumber; |
|
105
|
|
|
} |
|
106
|
|
|
|
|
107
|
|
|
|
|
108
|
|
|
}else if (empty($patientRegistrationDate)) { |
|
109
|
|
|
$this->failList['Empty Registration Date'][]=$patientNumber; |
|
110
|
|
|
}else if (!$isPrefixCorrect) { |
|
111
|
|
|
$this->failList['Wrong Patient Code Prefix'][]=$patientNumber; |
|
112
|
|
|
} |
|
113
|
|
|
|
|
114
|
|
|
|
|
115
|
|
|
} |
|
116
|
|
|
|
|
117
|
|
|
} |
|
118
|
|
|
|
|
119
|
|
|
} |
|
120
|
|
|
|
|
121
|
|
|
private function tryUpdateRegistrationDate($patientNumber, $patientRegistrationDate){ |
|
122
|
|
|
$patientObject = new Patient($patientNumber, $this->linkpdo); |
|
123
|
|
|
//If patient with default registration date, update to the new one |
|
124
|
|
|
if($patientObject->patientRegistrationDate == '1900-01-01' && $patientRegistrationDate !== $patientObject->patientRegistrationDate ) { |
|
125
|
|
|
$patientObject->editPatientRegistrationDate($patientRegistrationDate); |
|
126
|
|
|
return true; |
|
127
|
|
|
} |
|
128
|
|
|
|
|
129
|
|
|
return false; |
|
130
|
|
|
|
|
131
|
|
|
} |
|
132
|
|
|
|
|
133
|
|
|
/** |
|
134
|
|
|
* Parse registration date according to plateform preference (french or US format) |
|
135
|
|
|
* @param string $registrationDate |
|
136
|
|
|
* @return NULL|DateTime |
|
137
|
|
|
*/ |
|
138
|
|
|
private function parseRegistrationDate(?string $registrationDate) { |
|
139
|
|
|
$dateNbArray=explode('/', $registrationDate); |
|
|
|
|
|
|
140
|
|
|
|
|
141
|
|
|
if (GAELO_DATE_FORMAT == 'm.d.Y') { |
|
142
|
|
|
$registrationDay=intval($dateNbArray[1]); |
|
143
|
|
|
$registrationMonth=intval($dateNbArray[0]); |
|
144
|
|
|
}else if (GAELO_DATE_FORMAT == 'd.m.Y') { |
|
145
|
|
|
$registrationDay=intval($dateNbArray[0]); |
|
146
|
|
|
$registrationMonth=intval($dateNbArray[1]); |
|
147
|
|
|
} |
|
148
|
|
|
|
|
149
|
|
|
$registrationYear=intval($dateNbArray[2]); |
|
150
|
|
|
|
|
151
|
|
|
if ($registrationDay == 0 || $registrationMonth == 0 || $registrationYear == 0) { |
|
|
|
|
|
|
152
|
|
|
return null; |
|
153
|
|
|
} |
|
154
|
|
|
|
|
155
|
|
|
try { |
|
156
|
|
|
$dateResult=new DateTime($registrationYear.'-'.$registrationMonth.'-'.$registrationDay); |
|
157
|
|
|
}catch (Exception $e) { |
|
158
|
|
|
return null; |
|
159
|
|
|
} |
|
160
|
|
|
return $dateResult; |
|
161
|
|
|
|
|
162
|
|
|
} |
|
163
|
|
|
|
|
164
|
|
|
/** |
|
165
|
|
|
* Check that the importing patient is not already known in the system |
|
166
|
|
|
* NB : Each patient code should be unique (across study), patient number should include a study identifier |
|
167
|
|
|
* @param $patientCode |
|
168
|
|
|
* @return boolean |
|
169
|
|
|
*/ |
|
170
|
|
|
private function isNewPatient($patientCode) { |
|
171
|
|
|
try { |
|
172
|
|
|
new Patient($patientCode, $this->linkpdo); |
|
173
|
|
|
}catch (Exception $e1) { |
|
174
|
|
|
return true; |
|
175
|
|
|
} |
|
176
|
|
|
|
|
177
|
|
|
return false; |
|
178
|
|
|
} |
|
179
|
|
|
|
|
180
|
|
|
/** |
|
181
|
|
|
* Check that patient number has the correct lenght |
|
182
|
|
|
* @param $patientNumber |
|
183
|
|
|
* @return boolean |
|
184
|
|
|
*/ |
|
185
|
|
|
private function isCorrectPatientNumberLenght($patientNumber) { |
|
186
|
|
|
$lenghtImport=strlen($patientNumber); |
|
187
|
|
|
|
|
188
|
|
|
if ($lenghtImport == GAELO_PATIENT_CODE_LENGHT) { |
|
189
|
|
|
return true; |
|
190
|
|
|
}else { |
|
191
|
|
|
return false; |
|
192
|
|
|
} |
|
193
|
|
|
} |
|
194
|
|
|
|
|
195
|
|
|
private function isCorrectPrefix($patientNumber) { |
|
196
|
|
|
//If no prefix return true |
|
197
|
|
|
if (empty($this->studyObject->patientCodePrefix)) { |
|
198
|
|
|
return true; |
|
199
|
|
|
} |
|
200
|
|
|
//test that patient code start with study prefix |
|
201
|
|
|
$patientNumberString=strval($patientNumber); |
|
202
|
|
|
$studyPrefixString=strval($this->studyObject->patientCodePrefix); |
|
203
|
|
|
return $this->startsWith($patientNumberString, $studyPrefixString); |
|
204
|
|
|
|
|
205
|
|
|
} |
|
206
|
|
|
|
|
207
|
|
|
private function startsWith(string $string, string $startString) { |
|
208
|
|
|
$len=strlen($startString); |
|
209
|
|
|
return (substr($string, 0, $len) === $startString); |
|
210
|
|
|
} |
|
211
|
|
|
|
|
212
|
|
|
/** |
|
213
|
|
|
* Check that patient's center is one of known center in the plateform |
|
214
|
|
|
* @param $patientNumCenter |
|
215
|
|
|
* @return boolean |
|
216
|
|
|
*/ |
|
217
|
|
|
private function isExistingCenter($patientNumCenter) { |
|
218
|
|
|
if (is_null($patientNumCenter) || strlen($patientNumCenter) == 0) { |
|
219
|
|
|
return false; |
|
220
|
|
|
} |
|
221
|
|
|
|
|
222
|
|
|
try { |
|
223
|
|
|
new Center($this->linkpdo, $patientNumCenter); |
|
224
|
|
|
}catch (Exception $e1) { |
|
225
|
|
|
return false; |
|
226
|
|
|
} |
|
227
|
|
|
|
|
228
|
|
|
return true; |
|
229
|
|
|
} |
|
230
|
|
|
|
|
231
|
|
|
/** |
|
232
|
|
|
* Write the patient in the database |
|
233
|
|
|
* @param $patientNumber |
|
234
|
|
|
* @param $patientLastName |
|
235
|
|
|
* @param $patientFirstName |
|
236
|
|
|
* @param $patientGender |
|
237
|
|
|
* @param $patientInvestigatorCenter |
|
238
|
|
|
* @param $patientInvestigatorNumCenter |
|
239
|
|
|
* @param $dateRegistration |
|
240
|
|
|
* @param $patientDateOfBirth |
|
241
|
|
|
* @param $patientInvestigatorName |
|
242
|
|
|
* @return boolean |
|
243
|
|
|
*/ |
|
244
|
|
|
private function addPatientToDatabase($patientNumber, string $patientLastName, string $patientFirstName, string $patientGender |
|
245
|
|
|
, $patientInvestigatorNumCenter, $dateRegistration, $patientBirthDay, $patientBirthMonth, $patientBirthYear, string $patientInvestigatorName) { |
|
246
|
|
|
|
|
247
|
|
|
try { |
|
248
|
|
|
$insert_bdd=$this->linkpdo->prepare('INSERT INTO patients(study, code, first_name, last_name, gender, birth_day, birth_month, birth_year, registration_date, investigator_name, center) |
|
249
|
|
|
VALUES(:study, :code, :first_name, :last_name, :gender, :birth_day, :birth_month, :birth_year, :registration_date, :investigator_name, :center)'); |
|
250
|
|
|
|
|
251
|
|
|
$insert_bdd->execute(array('code' => $patientNumber, |
|
252
|
|
|
'first_name' => @strtoupper($patientFirstName[0]), |
|
253
|
|
|
'last_name' => @strtoupper($patientLastName[0]), |
|
254
|
|
|
'gender' => @strtoupper($patientGender[0]), |
|
255
|
|
|
'birth_day' => $patientBirthDay, |
|
256
|
|
|
'birth_month' => $patientBirthMonth, |
|
257
|
|
|
'birth_year' => $patientBirthYear, |
|
258
|
|
|
'registration_date' => $dateRegistration->format('Y-m-d'), |
|
259
|
|
|
'investigator_name' => $patientInvestigatorName, |
|
260
|
|
|
'center' => $patientInvestigatorNumCenter, |
|
261
|
|
|
'study' => $this->study)); |
|
262
|
|
|
$success=true; |
|
263
|
|
|
}catch (Exception $e) { |
|
264
|
|
|
$success=false; |
|
265
|
|
|
} |
|
266
|
|
|
|
|
267
|
|
|
return $success; |
|
268
|
|
|
|
|
269
|
|
|
} |
|
270
|
|
|
|
|
271
|
|
|
public function getHTMLImportAnswer() { |
|
272
|
|
|
return $this->buildSuccessAnswer().$this->buildErrorAnswer(); |
|
273
|
|
|
} |
|
274
|
|
|
|
|
275
|
|
|
public function getTextImportAnswer() { |
|
276
|
|
|
//Prepare Html2PlainText for email validity (both version to enhance spam validation) |
|
277
|
|
|
$htmlMessageObject=new \Html2Text\Html2Text($this->getHTMLImportAnswer()); |
|
|
|
|
|
|
278
|
|
|
return $htmlMessageObject->getText(); |
|
279
|
|
|
|
|
280
|
|
|
} |
|
281
|
|
|
|
|
282
|
|
|
/** |
|
283
|
|
|
* Build HTML for error answer |
|
284
|
|
|
* @return string |
|
285
|
|
|
*/ |
|
286
|
|
|
private function buildErrorAnswer() { |
|
287
|
|
|
//List of failed patients |
|
288
|
|
|
$failReport='Failed Patients: <br>'; |
|
289
|
|
|
if (!empty($this->failList)) { |
|
290
|
|
|
foreach ($this->failList as $key=>$value) { |
|
291
|
|
|
if (!empty($value)) { |
|
292
|
|
|
$failReport=$failReport.$key.':<br>'; |
|
293
|
|
|
if (is_array($value)) { |
|
294
|
|
|
$failReport=$failReport.implode('<br>', $value).'<br>'; |
|
295
|
|
|
}else { |
|
296
|
|
|
$failReport=$failReport.$value.'<br>'; |
|
297
|
|
|
} |
|
298
|
|
|
} |
|
299
|
|
|
} |
|
300
|
|
|
}else { |
|
301
|
|
|
$failReport=$failReport.' None <br>'; |
|
302
|
|
|
} |
|
303
|
|
|
|
|
304
|
|
|
return $failReport; |
|
305
|
|
|
} |
|
306
|
|
|
|
|
307
|
|
|
/** |
|
308
|
|
|
* Generate HTML for sucess answer |
|
309
|
|
|
* @return string |
|
310
|
|
|
*/ |
|
311
|
|
|
private function buildSuccessAnswer() { |
|
312
|
|
|
//List of succeded patients |
|
313
|
|
|
$successReport='Success Patients: <br>'; |
|
314
|
|
|
if (!empty($this->sucessList)) { |
|
315
|
|
|
foreach ($this->sucessList as $value) { |
|
316
|
|
|
$success=$value; |
|
317
|
|
|
$successReport=$successReport.$success.'<br>'; |
|
318
|
|
|
} |
|
319
|
|
|
}else { |
|
320
|
|
|
$successReport=$successReport.' None <br>'; |
|
321
|
|
|
} |
|
322
|
|
|
|
|
323
|
|
|
return $successReport; |
|
324
|
|
|
} |
|
325
|
|
|
|
|
326
|
|
|
} |
|
327
|
|
|
|