|
@@ -17,33 +17,33 @@ discard block |
|
|
block discarded – undo |
|
17
|
17
|
* @param Array $filter the filter |
|
18
|
18
|
* @return Array the SQL part |
|
19
|
19
|
*/ |
|
20
|
|
- public function getFilter($filter = array(),$where = false,$and = false) { |
|
|
20
|
+ public function getFilter($filter = array(), $where = false, $and = false) { |
|
21
|
21
|
global $globalFilter, $globalStatsFilters, $globalFilterName, $globalDBdriver; |
|
22
|
22
|
$filters = array(); |
|
23
|
23
|
if (is_array($globalStatsFilters) && isset($globalStatsFilters[$globalFilterName])) { |
|
24
|
24
|
if (isset($globalStatsFilters[$globalFilterName][0]['source'])) { |
|
25
|
25
|
$filters = $globalStatsFilters[$globalFilterName]; |
|
26
|
26
|
} else { |
|
27
|
|
- $filter = array_merge($filter,$globalStatsFilters[$globalFilterName]); |
|
|
27
|
+ $filter = array_merge($filter, $globalStatsFilters[$globalFilterName]); |
|
28
|
28
|
} |
|
29
|
29
|
} |
|
30
|
30
|
if (isset($filter[0]['source'])) { |
|
31
|
|
- $filters = array_merge($filters,$filter); |
|
|
31
|
+ $filters = array_merge($filters, $filter); |
|
32
|
32
|
} |
|
33
|
|
- if (is_array($globalFilter)) $filter = array_merge($filter,$globalFilter); |
|
|
33
|
+ if (is_array($globalFilter)) $filter = array_merge($filter, $globalFilter); |
|
34
|
34
|
$filter_query_join = ''; |
|
35
|
35
|
$filter_query_where = ''; |
|
36
|
|
- foreach($filters as $flt) { |
|
|
36
|
+ foreach ($filters as $flt) { |
|
37
|
37
|
if (isset($flt['idents']) && !empty($flt['idents'])) { |
|
38
|
38
|
if (isset($flt['source'])) { |
|
39
|
|
- $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output WHERE marine_output.ident IN ('".implode("','",$flt['idents'])."') AND marine_output.format_source IN ('".implode("','",$flt['source'])."')) spid ON spid.fammarine_id = marine_live.fammarine_id"; |
|
|
39
|
+ $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output WHERE marine_output.ident IN ('".implode("','", $flt['idents'])."') AND marine_output.format_source IN ('".implode("','", $flt['source'])."')) spid ON spid.fammarine_id = marine_live.fammarine_id"; |
|
40
|
40
|
} else { |
|
41
|
|
- $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output WHERE marine_output.ident IN ('".implode("','",$flt['idents'])."')) spid ON spid.fammarine_id = marine_live.fammarine_id"; |
|
|
41
|
+ $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output WHERE marine_output.ident IN ('".implode("','", $flt['idents'])."')) spid ON spid.fammarine_id = marine_live.fammarine_id"; |
|
42
|
42
|
} |
|
43
|
43
|
} |
|
44
|
44
|
} |
|
45
|
45
|
if (isset($filter['source']) && !empty($filter['source'])) { |
|
46
|
|
- $filter_query_where .= " AND format_source IN ('".implode("','",$filter['source'])."')"; |
|
|
46
|
+ $filter_query_where .= " AND format_source IN ('".implode("','", $filter['source'])."')"; |
|
47
|
47
|
} |
|
48
|
48
|
if (isset($filter['ident']) && !empty($filter['ident'])) { |
|
49
|
49
|
$filter_query_where .= " AND ident = '".$filter['ident']."'"; |
|
@@ -72,15 +72,15 @@ discard block |
|
|
block discarded – undo |
|
72
|
72
|
$filter_query_date .= " AND EXTRACT(DAY FROM marine_output.date) = '".$filter['day']."'"; |
|
73
|
73
|
} |
|
74
|
74
|
} |
|
75
|
|
- $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output".preg_replace('/^ AND/',' WHERE',$filter_query_date).") sd ON sd.fammarine_id = marine_live.fammarine_id"; |
|
|
75
|
+ $filter_query_join .= " INNER JOIN (SELECT fammarine_id FROM marine_output".preg_replace('/^ AND/', ' WHERE', $filter_query_date).") sd ON sd.fammarine_id = marine_live.fammarine_id"; |
|
76
|
76
|
} |
|
77
|
77
|
if (isset($filter['source_aprs']) && !empty($filter['source_aprs'])) { |
|
78
|
|
- $filter_query_where .= " AND format_source = 'aprs' AND source_name IN ('".implode("','",$filter['source_aprs'])."')"; |
|
|
78
|
+ $filter_query_where .= " AND format_source = 'aprs' AND source_name IN ('".implode("','", $filter['source_aprs'])."')"; |
|
79
|
79
|
} |
|
80
|
80
|
if ($filter_query_where == '' && $where) $filter_query_where = ' WHERE'; |
|
81
|
81
|
elseif ($filter_query_where != '' && $and) $filter_query_where .= ' AND'; |
|
82
|
82
|
if ($filter_query_where != '') { |
|
83
|
|
- $filter_query_where = preg_replace('/^ AND/',' WHERE',$filter_query_where); |
|
|
83
|
+ $filter_query_where = preg_replace('/^ AND/', ' WHERE', $filter_query_where); |
|
84
|
84
|
} |
|
85
|
85
|
$filter_query = $filter_query_join.$filter_query_where; |
|
86
|
86
|
return $filter_query; |
|
@@ -103,8 +103,8 @@ discard block |
|
|
block discarded – undo |
|
103
|
103
|
if ($limit != '') |
|
104
|
104
|
{ |
|
105
|
105
|
$limit_array = explode(',', $limit); |
|
106
|
|
- $limit_array[0] = filter_var($limit_array[0],FILTER_SANITIZE_NUMBER_INT); |
|
107
|
|
- $limit_array[1] = filter_var($limit_array[1],FILTER_SANITIZE_NUMBER_INT); |
|
|
106
|
+ $limit_array[0] = filter_var($limit_array[0], FILTER_SANITIZE_NUMBER_INT); |
|
|
107
|
+ $limit_array[1] = filter_var($limit_array[1], FILTER_SANITIZE_NUMBER_INT); |
|
108
|
108
|
if ($limit_array[0] >= 0 && $limit_array[1] >= 0) |
|
109
|
109
|
{ |
|
110
|
110
|
$limit_query = ' LIMIT '.$limit_array[1].' OFFSET '.$limit_array[0]; |
|
@@ -119,7 +119,7 @@ discard block |
|
|
block discarded – undo |
|
119
|
119
|
$orderby_query = ' '.$search_orderby_array[$sort]['sql']; |
|
120
|
120
|
} |
|
121
|
121
|
} |
|
122
|
|
- if ($orderby_query == '') $orderby_query= ' ORDER BY date DESC'; |
|
|
122
|
+ if ($orderby_query == '') $orderby_query = ' ORDER BY date DESC'; |
|
123
|
123
|
|
|
124
|
124
|
if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
125
|
125
|
if ($globalDBdriver == 'mysql') { |
|
@@ -128,7 +128,7 @@ discard block |
|
|
block discarded – undo |
|
128
|
128
|
} else { |
|
129
|
129
|
$query = "SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= l.date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate".$filter_query.$orderby_query; |
|
130
|
130
|
} |
|
131
|
|
- $spotter_array = $Marine->getDataFromDB($query.$limit_query,array(),'',true); |
|
|
131
|
+ $spotter_array = $Marine->getDataFromDB($query.$limit_query, array(), '', true); |
|
132
|
132
|
|
|
133
|
133
|
return $spotter_array; |
|
134
|
134
|
} |
|
@@ -144,7 +144,7 @@ discard block |
|
|
block discarded – undo |
|
144
|
144
|
global $globalDBdriver, $globalLiveInterval; |
|
145
|
145
|
date_default_timezone_set('UTC'); |
|
146
|
146
|
|
|
147
|
|
- $filter_query = $this->getFilter($filter,true,true); |
|
|
147
|
+ $filter_query = $this->getFilter($filter, true, true); |
|
148
|
148
|
|
|
149
|
149
|
if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
150
|
150
|
if ($globalDBdriver == 'mysql') { |
|
@@ -158,7 +158,7 @@ discard block |
|
|
block discarded – undo |
|
158
|
158
|
try { |
|
159
|
159
|
$sth = $this->db->prepare($query); |
|
160
|
160
|
$sth->execute(); |
|
161
|
|
- } catch(PDOException $e) { |
|
|
161
|
+ } catch (PDOException $e) { |
|
162
|
162
|
echo $e->getMessage(); |
|
163
|
163
|
die; |
|
164
|
164
|
} |
|
@@ -173,19 +173,19 @@ discard block |
|
|
block discarded – undo |
|
173
|
173
|
* @return Array the spotter information |
|
174
|
174
|
* |
|
175
|
175
|
*/ |
|
176
|
|
- public function getMinLastLiveMarineData($coord = array(),$filter = array(), $limit = false) |
|
|
176
|
+ public function getMinLastLiveMarineData($coord = array(), $filter = array(), $limit = false) |
|
177
|
177
|
{ |
|
178
|
178
|
global $globalDBdriver, $globalLiveInterval, $globalMap3DMarinesLimit, $globalArchive; |
|
179
|
179
|
date_default_timezone_set('UTC'); |
|
180
|
180
|
$usecoord = false; |
|
181
|
181
|
if (is_array($coord) && !empty($coord)) { |
|
182
|
|
- $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
183
|
|
- $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
184
|
|
- $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
185
|
|
- $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
|
182
|
+ $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
183
|
+ $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
184
|
+ $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
185
|
+ $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
186
|
186
|
$usecoord = true; |
|
187
|
187
|
} |
|
188
|
|
- $filter_query = $this->getFilter($filter,true,true); |
|
|
188
|
+ $filter_query = $this->getFilter($filter, true, true); |
|
189
|
189
|
|
|
190
|
190
|
if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
191
|
191
|
if (!isset($globalMap3DMarinesLimit) || $globalMap3DMarinesLimit == '') $globalMap3DMarinesLimit = '300'; |
|
@@ -234,7 +234,7 @@ discard block |
|
|
block discarded – undo |
|
234
|
234
|
try { |
|
235
|
235
|
$sth = $this->db->prepare($query); |
|
236
|
236
|
$sth->execute(); |
|
237
|
|
- } catch(PDOException $e) { |
|
|
237
|
+ } catch (PDOException $e) { |
|
238
|
238
|
echo $e->getMessage(); |
|
239
|
239
|
die; |
|
240
|
240
|
} |
|
@@ -251,7 +251,7 @@ discard block |
|
|
block discarded – undo |
|
251
|
251
|
public function getLiveMarineCount($filter = array()) |
|
252
|
252
|
{ |
|
253
|
253
|
global $globalDBdriver, $globalLiveInterval; |
|
254
|
|
- $filter_query = $this->getFilter($filter,true,true); |
|
|
254
|
+ $filter_query = $this->getFilter($filter, true, true); |
|
255
|
255
|
|
|
256
|
256
|
if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
257
|
257
|
if ($globalDBdriver == 'mysql') { |
|
@@ -262,7 +262,7 @@ discard block |
|
|
block discarded – undo |
|
262
|
262
|
try { |
|
263
|
263
|
$sth = $this->db->prepare($query); |
|
264
|
264
|
$sth->execute(); |
|
265
|
|
- } catch(PDOException $e) { |
|
|
265
|
+ } catch (PDOException $e) { |
|
266
|
266
|
echo $e->getMessage(); |
|
267
|
267
|
die; |
|
268
|
268
|
} |
|
@@ -285,10 +285,10 @@ discard block |
|
|
block discarded – undo |
|
285
|
285
|
$filter_query = $this->getFilter($filter); |
|
286
|
286
|
|
|
287
|
287
|
if (is_array($coord)) { |
|
288
|
|
- $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
289
|
|
- $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
290
|
|
- $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
291
|
|
- $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
|
288
|
+ $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
289
|
+ $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
290
|
+ $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
291
|
+ $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
292
|
292
|
} else return array(); |
|
293
|
293
|
if ($globalDBdriver == 'mysql') { |
|
294
|
294
|
$query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= l.date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate AND marine_live.latitude BETWEEN '.$minlat.' AND '.$maxlat.' AND marine_live.longitude BETWEEN '.$minlong.' AND '.$maxlong.' GROUP BY marine_live.fammarine_id'.$filter_query; |
|
@@ -313,10 +313,10 @@ discard block |
|
|
block discarded – undo |
|
313
|
313
|
$filter_query = $this->getFilter($filter); |
|
314
|
314
|
|
|
315
|
315
|
if (is_array($coord)) { |
|
316
|
|
- $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
317
|
|
- $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
318
|
|
- $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
319
|
|
- $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
|
316
|
+ $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
317
|
+ $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
318
|
+ $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
319
|
+ $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
320
|
320
|
} else return array(); |
|
321
|
321
|
/* |
|
322
|
322
|
if ($globalDBdriver == 'mysql') { |
|
@@ -331,13 +331,13 @@ discard block |
|
|
block discarded – undo |
|
331
|
331
|
*/ |
|
332
|
332
|
if ($globalDBdriver == 'mysql') { |
|
333
|
333
|
if (isset($globalArchive) && $globalArchive === TRUE) { |
|
334
|
|
- $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
|
334
|
+ $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
335
|
335
|
FROM marine_live |
|
336
|
336
|
'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= marine_live.date |
|
337
|
337
|
AND marine_live.latitude BETWEEN '.$minlat.' AND '.$maxlat.' AND marine_live.longitude BETWEEN '.$minlong.' AND '.$maxlong.' |
|
338
|
338
|
AND marine_live.latitude <> 0 AND marine_live.longitude <> 0'; |
|
339
|
339
|
} else { |
|
340
|
|
- $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
|
340
|
+ $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
341
|
341
|
FROM marine_live |
|
342
|
342
|
INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate |
|
343
|
343
|
FROM marine_live l |
|
@@ -349,14 +349,14 @@ discard block |
|
|
block discarded – undo |
|
349
|
349
|
} |
|
350
|
350
|
} else { |
|
351
|
351
|
if (isset($globalArchive) && $globalArchive === TRUE) { |
|
352
|
|
- $query = "SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
|
352
|
+ $query = "SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
353
|
353
|
FROM marine_live |
|
354
|
354
|
".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date |
|
355
|
355
|
AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." |
|
356
|
356
|
AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong." |
|
357
|
357
|
AND marine_live.latitude <> '0' AND marine_live.longitude <> '0'"; |
|
358
|
358
|
} else { |
|
359
|
|
- $query = "SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
|
359
|
+ $query = "SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source |
|
360
|
360
|
FROM marine_live |
|
361
|
361
|
INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate |
|
362
|
362
|
FROM marine_live l |
|
@@ -413,7 +413,7 @@ discard block |
|
|
block discarded – undo |
|
413
|
413
|
if ($interval == '1m') |
|
414
|
414
|
{ |
|
415
|
415
|
$additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 MINUTE) <= marine_live.date '; |
|
416
|
|
- } else if ($interval == '15m'){ |
|
|
416
|
+ } else if ($interval == '15m') { |
|
417
|
417
|
$additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 15 MINUTE) <= marine_live.date '; |
|
418
|
418
|
} |
|
419
|
419
|
} |
|
@@ -421,14 +421,14 @@ discard block |
|
|
block discarded – undo |
|
421
|
421
|
$additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 MINUTE) <= marine_live.date '; |
|
422
|
422
|
} |
|
423
|
423
|
|
|
424
|
|
- $query = "SELECT marine_live.*, ( 6371 * acos( cos( radians(:lat) ) * cos( radians( latitude ) ) * cos( radians( longitude ) - radians(:lng) ) + sin( radians(:lat) ) * sin( radians( latitude ) ) ) ) AS distance FROM marine_live |
|
|
424
|
+ $query = "SELECT marine_live.*, ( 6371 * acos( cos( radians(:lat) ) * cos( radians( latitude ) ) * cos( radians( longitude ) - radians(:lng) ) + sin( radians(:lat) ) * sin( radians( latitude ) ) ) ) AS distance FROM marine_live |
|
425
|
425
|
WHERE marine_live.latitude <> '' |
|
426
|
426
|
AND marine_live.longitude <> '' |
|
427
|
427
|
".$additional_query." |
|
428
|
428
|
HAVING distance < :radius |
|
429
|
429
|
ORDER BY distance"; |
|
430
|
430
|
|
|
431
|
|
- $spotter_array = $Marine->getDataFromDB($query, array(':lat' => $lat, ':lng' => $lng,':radius' => $radius)); |
|
|
431
|
+ $spotter_array = $Marine->getDataFromDB($query, array(':lat' => $lat, ':lng' => $lng, ':radius' => $radius)); |
|
432
|
432
|
|
|
433
|
433
|
return $spotter_array; |
|
434
|
434
|
} |
|
@@ -446,9 +446,9 @@ discard block |
|
|
block discarded – undo |
|
446
|
446
|
date_default_timezone_set('UTC'); |
|
447
|
447
|
|
|
448
|
448
|
$ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
449
|
|
- $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.ident = :ident GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
|
449
|
+ $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.ident = :ident GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
450
|
450
|
|
|
451
|
|
- $spotter_array = $Marine->getDataFromDB($query,array(':ident' => $ident),'',true); |
|
|
451
|
+ $spotter_array = $Marine->getDataFromDB($query, array(':ident' => $ident), '', true); |
|
452
|
452
|
|
|
453
|
453
|
return $spotter_array; |
|
454
|
454
|
} |
|
@@ -459,16 +459,16 @@ discard block |
|
|
block discarded – undo |
|
459
|
459
|
* @return Array the spotter information |
|
460
|
460
|
* |
|
461
|
461
|
*/ |
|
462
|
|
- public function getDateLiveMarineDataByIdent($ident,$date) |
|
|
462
|
+ public function getDateLiveMarineDataByIdent($ident, $date) |
|
463
|
463
|
{ |
|
464
|
464
|
$Marine = new Marine($this->db); |
|
465
|
465
|
date_default_timezone_set('UTC'); |
|
466
|
466
|
|
|
467
|
467
|
$ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
468
|
|
- $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.ident = :ident AND l.date <= :date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
|
468
|
+ $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.ident = :ident AND l.date <= :date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
469
|
469
|
|
|
470
|
|
- $date = date('c',$date); |
|
471
|
|
- $spotter_array = $Marine->getDataFromDB($query,array(':ident' => $ident,':date' => $date)); |
|
|
470
|
+ $date = date('c', $date); |
|
|
471
|
+ $spotter_array = $Marine->getDataFromDB($query, array(':ident' => $ident, ':date' => $date)); |
|
472
|
472
|
|
|
473
|
473
|
return $spotter_array; |
|
474
|
474
|
} |
|
@@ -485,9 +485,9 @@ discard block |
|
|
block discarded – undo |
|
485
|
485
|
date_default_timezone_set('UTC'); |
|
486
|
486
|
|
|
487
|
487
|
$id = filter_var($id, FILTER_SANITIZE_STRING); |
|
488
|
|
- $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.fammarine_id = :id GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
|
488
|
+ $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.fammarine_id = :id GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
489
|
489
|
|
|
490
|
|
- $spotter_array = $Marine->getDataFromDB($query,array(':id' => $id),'',true); |
|
|
490
|
+ $spotter_array = $Marine->getDataFromDB($query, array(':id' => $id), '', true); |
|
491
|
491
|
|
|
492
|
492
|
return $spotter_array; |
|
493
|
493
|
} |
|
@@ -498,15 +498,15 @@ discard block |
|
|
block discarded – undo |
|
498
|
498
|
* @return Array the spotter information |
|
499
|
499
|
* |
|
500
|
500
|
*/ |
|
501
|
|
- public function getDateLiveMarineDataById($id,$date) |
|
|
501
|
+ public function getDateLiveMarineDataById($id, $date) |
|
502
|
502
|
{ |
|
503
|
503
|
$Marine = new Marine($this->db); |
|
504
|
504
|
date_default_timezone_set('UTC'); |
|
505
|
505
|
|
|
506
|
506
|
$id = filter_var($id, FILTER_SANITIZE_STRING); |
|
507
|
|
- $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.fammarine_id = :id AND l.date <= :date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
508
|
|
- $date = date('c',$date); |
|
509
|
|
- $spotter_array = $Marine->getDataFromDB($query,array(':id' => $id,':date' => $date),'',true); |
|
|
507
|
+ $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.fammarine_id = :id AND l.date <= :date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate ORDER BY marine_live.date DESC'; |
|
|
508
|
+ $date = date('c', $date); |
|
|
509
|
+ $spotter_array = $Marine->getDataFromDB($query, array(':id' => $id, ':date' => $date), '', true); |
|
510
|
510
|
|
|
511
|
511
|
return $spotter_array; |
|
512
|
512
|
} |
|
@@ -518,7 +518,7 @@ discard block |
|
|
block discarded – undo |
|
518
|
518
|
* @return Array the spotter information |
|
519
|
519
|
* |
|
520
|
520
|
*/ |
|
521
|
|
- public function getAllLiveMarineDataById($id,$liveinterval = false) |
|
|
521
|
+ public function getAllLiveMarineDataById($id, $liveinterval = false) |
|
522
|
522
|
{ |
|
523
|
523
|
global $globalDBdriver, $globalLiveInterval; |
|
524
|
524
|
date_default_timezone_set('UTC'); |
|
@@ -537,7 +537,7 @@ discard block |
|
|
block discarded – undo |
|
537
|
537
|
try { |
|
538
|
538
|
$sth = $this->db->prepare($query); |
|
539
|
539
|
$sth->execute(array(':id' => $id)); |
|
540
|
|
- } catch(PDOException $e) { |
|
|
540
|
+ } catch (PDOException $e) { |
|
541
|
541
|
echo $e->getMessage(); |
|
542
|
542
|
die; |
|
543
|
543
|
} |
|
@@ -555,12 +555,12 @@ discard block |
|
|
block discarded – undo |
|
555
|
555
|
{ |
|
556
|
556
|
date_default_timezone_set('UTC'); |
|
557
|
557
|
$ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
558
|
|
- $query = self::$global_query.' WHERE marine_live.ident = :ident'; |
|
|
558
|
+ $query = self::$global_query.' WHERE marine_live.ident = :ident'; |
|
559
|
559
|
try { |
|
560
|
560
|
|
|
561
|
561
|
$sth = $this->db->prepare($query); |
|
562
|
562
|
$sth->execute(array(':ident' => $ident)); |
|
563
|
|
- } catch(PDOException $e) { |
|
|
563
|
+ } catch (PDOException $e) { |
|
564
|
564
|
echo $e->getMessage(); |
|
565
|
565
|
die; |
|
566
|
566
|
} |
|
@@ -590,7 +590,7 @@ discard block |
|
|
block discarded – undo |
|
590
|
590
|
|
|
591
|
591
|
$sth = $this->db->prepare($query); |
|
592
|
592
|
$sth->execute(); |
|
593
|
|
- } catch(PDOException $e) { |
|
|
593
|
+ } catch (PDOException $e) { |
|
594
|
594
|
return "error"; |
|
595
|
595
|
} |
|
596
|
596
|
|
|
@@ -613,14 +613,14 @@ discard block |
|
|
block discarded – undo |
|
613
|
613
|
|
|
614
|
614
|
$sth = $this->db->prepare($query); |
|
615
|
615
|
$sth->execute(); |
|
616
|
|
- } catch(PDOException $e) { |
|
|
616
|
+ } catch (PDOException $e) { |
|
617
|
617
|
return "error"; |
|
618
|
618
|
} |
|
619
|
619
|
$query_delete = 'DELETE FROM marine_live WHERE fammarine_id IN ('; |
|
620
|
620
|
$i = 0; |
|
621
|
|
- $j =0; |
|
|
621
|
+ $j = 0; |
|
622
|
622
|
$all = $sth->fetchAll(PDO::FETCH_ASSOC); |
|
623
|
|
- foreach($all as $row) |
|
|
623
|
+ foreach ($all as $row) |
|
624
|
624
|
{ |
|
625
|
625
|
$i++; |
|
626
|
626
|
$j++; |
|
@@ -628,9 +628,9 @@ discard block |
|
|
block discarded – undo |
|
628
|
628
|
if ($globalDebug) echo "."; |
|
629
|
629
|
try { |
|
630
|
630
|
|
|
631
|
|
- $sth = $this->db->prepare(substr($query_delete,0,-1).")"); |
|
|
631
|
+ $sth = $this->db->prepare(substr($query_delete, 0, -1).")"); |
|
632
|
632
|
$sth->execute(); |
|
633
|
|
- } catch(PDOException $e) { |
|
|
633
|
+ } catch (PDOException $e) { |
|
634
|
634
|
return "error"; |
|
635
|
635
|
} |
|
636
|
636
|
$query_delete = 'DELETE FROM marine_live WHERE fammarine_id IN ('; |
|
@@ -641,9 +641,9 @@ discard block |
|
|
block discarded – undo |
|
641
|
641
|
if ($i > 0) { |
|
642
|
642
|
try { |
|
643
|
643
|
|
|
644
|
|
- $sth = $this->db->prepare(substr($query_delete,0,-1).")"); |
|
|
644
|
+ $sth = $this->db->prepare(substr($query_delete, 0, -1).")"); |
|
645
|
645
|
$sth->execute(); |
|
646
|
|
- } catch(PDOException $e) { |
|
|
646
|
+ } catch (PDOException $e) { |
|
647
|
647
|
return "error"; |
|
648
|
648
|
} |
|
649
|
649
|
} |
|
@@ -656,7 +656,7 @@ discard block |
|
|
block discarded – undo |
|
656
|
656
|
|
|
657
|
657
|
$sth = $this->db->prepare($query); |
|
658
|
658
|
$sth->execute(); |
|
659
|
|
- } catch(PDOException $e) { |
|
|
659
|
+ } catch (PDOException $e) { |
|
660
|
660
|
return "error"; |
|
661
|
661
|
} |
|
662
|
662
|
/* $query_delete = "DELETE FROM marine_live WHERE fammarine_id IN ("; |
|
@@ -704,13 +704,13 @@ discard block |
|
|
block discarded – undo |
|
704
|
704
|
public function deleteLiveMarineDataByIdent($ident) |
|
705
|
705
|
{ |
|
706
|
706
|
$ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
707
|
|
- $query = 'DELETE FROM marine_live WHERE ident = :ident'; |
|
|
707
|
+ $query = 'DELETE FROM marine_live WHERE ident = :ident'; |
|
708
|
708
|
|
|
709
|
709
|
try { |
|
710
|
710
|
|
|
711
|
711
|
$sth = $this->db->prepare($query); |
|
712
|
712
|
$sth->execute(array(':ident' => $ident)); |
|
713
|
|
- } catch(PDOException $e) { |
|
|
713
|
+ } catch (PDOException $e) { |
|
714
|
714
|
return "error"; |
|
715
|
715
|
} |
|
716
|
716
|
|
|
@@ -726,13 +726,13 @@ discard block |
|
|
block discarded – undo |
|
726
|
726
|
public function deleteLiveMarineDataById($id) |
|
727
|
727
|
{ |
|
728
|
728
|
$id = filter_var($id, FILTER_SANITIZE_STRING); |
|
729
|
|
- $query = 'DELETE FROM marine_live WHERE fammarine_id = :id'; |
|
|
729
|
+ $query = 'DELETE FROM marine_live WHERE fammarine_id = :id'; |
|
730
|
730
|
|
|
731
|
731
|
try { |
|
732
|
732
|
|
|
733
|
733
|
$sth = $this->db->prepare($query); |
|
734
|
734
|
$sth->execute(array(':id' => $id)); |
|
735
|
|
- } catch(PDOException $e) { |
|
|
735
|
+ } catch (PDOException $e) { |
|
736
|
736
|
return "error"; |
|
737
|
737
|
} |
|
738
|
738
|
|
|
@@ -750,13 +750,13 @@ discard block |
|
|
block discarded – undo |
|
750
|
750
|
{ |
|
751
|
751
|
global $globalDBdriver, $globalTimezone; |
|
752
|
752
|
if ($globalDBdriver == 'mysql') { |
|
753
|
|
- $query = 'SELECT marine_live.ident FROM marine_live |
|
|
753
|
+ $query = 'SELECT marine_live.ident FROM marine_live |
|
754
|
754
|
WHERE marine_live.ident = :ident |
|
755
|
755
|
AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 HOUR) |
|
756
|
756
|
AND marine_live.date < UTC_TIMESTAMP()'; |
|
757
|
757
|
$query_data = array(':ident' => $ident); |
|
758
|
758
|
} else { |
|
759
|
|
- $query = "SELECT marine_live.ident FROM marine_live |
|
|
759
|
+ $query = "SELECT marine_live.ident FROM marine_live |
|
760
|
760
|
WHERE marine_live.ident = :ident |
|
761
|
761
|
AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '1 HOURS' |
|
762
|
762
|
AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
|
@@ -765,8 +765,8 @@ discard block |
|
|
block discarded – undo |
|
765
|
765
|
|
|
766
|
766
|
$sth = $this->db->prepare($query); |
|
767
|
767
|
$sth->execute($query_data); |
|
768
|
|
- $ident_result=''; |
|
769
|
|
- while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
|
768
|
+ $ident_result = ''; |
|
|
769
|
+ while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
770
|
770
|
{ |
|
771
|
771
|
$ident_result = $row['ident']; |
|
772
|
772
|
} |
|
@@ -783,13 +783,13 @@ discard block |
|
|
block discarded – undo |
|
783
|
783
|
{ |
|
784
|
784
|
global $globalDBdriver, $globalTimezone; |
|
785
|
785
|
if ($globalDBdriver == 'mysql') { |
|
786
|
|
- $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
|
786
|
+ $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
787
|
787
|
WHERE marine_live.ident = :ident |
|
788
|
788
|
AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 30 MINUTE)'; |
|
789
|
789
|
// AND marine_live.date < UTC_TIMESTAMP()"; |
|
790
|
790
|
$query_data = array(':ident' => $ident); |
|
791
|
791
|
} else { |
|
792
|
|
- $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
|
792
|
+ $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
793
|
793
|
WHERE marine_live.ident = :ident |
|
794
|
794
|
AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '30 MINUTES'"; |
|
795
|
795
|
// AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
|
@@ -798,8 +798,8 @@ discard block |
|
|
block discarded – undo |
|
798
|
798
|
|
|
799
|
799
|
$sth = $this->db->prepare($query); |
|
800
|
800
|
$sth->execute($query_data); |
|
801
|
|
- $ident_result=''; |
|
802
|
|
- while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
|
801
|
+ $ident_result = ''; |
|
|
802
|
+ while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
803
|
803
|
{ |
|
804
|
804
|
$ident_result = $row['fammarine_id']; |
|
805
|
805
|
} |
|
@@ -816,13 +816,13 @@ discard block |
|
|
block discarded – undo |
|
816
|
816
|
{ |
|
817
|
817
|
global $globalDBdriver, $globalTimezone; |
|
818
|
818
|
if ($globalDBdriver == 'mysql') { |
|
819
|
|
- $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
|
819
|
+ $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
820
|
820
|
WHERE marine_live.fammarine_id = :id |
|
821
|
821
|
AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 10 HOUR)'; |
|
822
|
822
|
// AND marine_live.date < UTC_TIMESTAMP()"; |
|
823
|
823
|
$query_data = array(':id' => $id); |
|
824
|
824
|
} else { |
|
825
|
|
- $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
|
825
|
+ $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
826
|
826
|
WHERE marine_live.fammarine_id = :id |
|
827
|
827
|
AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '10 HOUR'"; |
|
828
|
828
|
// AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
|
@@ -831,8 +831,8 @@ discard block |
|
|
block discarded – undo |
|
831
|
831
|
|
|
832
|
832
|
$sth = $this->db->prepare($query); |
|
833
|
833
|
$sth->execute($query_data); |
|
834
|
|
- $ident_result=''; |
|
835
|
|
- while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
|
834
|
+ $ident_result = ''; |
|
|
835
|
+ while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
836
|
836
|
{ |
|
837
|
837
|
$ident_result = $row['fammarine_id']; |
|
838
|
838
|
} |
|
@@ -849,13 +849,13 @@ discard block |
|
|
block discarded – undo |
|
849
|
849
|
{ |
|
850
|
850
|
global $globalDBdriver, $globalTimezone; |
|
851
|
851
|
if ($globalDBdriver == 'mysql') { |
|
852
|
|
- $query = 'SELECT marine_live.fammarine_id FROM marine_live |
|
|
852
|
+ $query = 'SELECT marine_live.fammarine_id FROM marine_live |
|
853
|
853
|
WHERE marine_live.mmsi = :mmsi |
|
854
|
854
|
AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 10 HOUR)'; |
|
855
|
855
|
// AND marine_live.date < UTC_TIMESTAMP()"; |
|
856
|
856
|
$query_data = array(':mmsi' => $mmsi); |
|
857
|
857
|
} else { |
|
858
|
|
- $query = "SELECT marine_live.fammarine_id FROM marine_live |
|
|
858
|
+ $query = "SELECT marine_live.fammarine_id FROM marine_live |
|
859
|
859
|
WHERE marine_live.mmsi = :mmsi |
|
860
|
860
|
AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '10 HOUR'"; |
|
861
|
861
|
// AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
|
@@ -864,8 +864,8 @@ discard block |
|
|
block discarded – undo |
|
864
|
864
|
|
|
865
|
865
|
$sth = $this->db->prepare($query); |
|
866
|
866
|
$sth->execute($query_data); |
|
867
|
|
- $ident_result=''; |
|
868
|
|
- while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
|
867
|
+ $ident_result = ''; |
|
|
868
|
+ while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
869
|
869
|
{ |
|
870
|
870
|
$ident_result = $row['fammarine_id']; |
|
871
|
871
|
} |
|
@@ -883,7 +883,7 @@ discard block |
|
|
block discarded – undo |
|
883
|
883
|
* @return String success or false |
|
884
|
884
|
* |
|
885
|
885
|
*/ |
|
886
|
|
- public function addLiveMarineData($fammarine_id = '', $ident = '', $latitude = '', $longitude = '', $heading = '', $groundspeed = '', $date = '', $putinarchive = false, $mmsi = '',$type = '',$typeid = '',$imo = '', $callsign = '',$arrival_code = '',$arrival_date = '',$status = '',$statusid = '',$noarchive = false,$format_source = '', $source_name = '', $over_country = '') |
|
|
886
|
+ public function addLiveMarineData($fammarine_id = '', $ident = '', $latitude = '', $longitude = '', $heading = '', $groundspeed = '', $date = '', $putinarchive = false, $mmsi = '', $type = '', $typeid = '', $imo = '', $callsign = '', $arrival_code = '', $arrival_date = '', $status = '', $statusid = '', $noarchive = false, $format_source = '', $source_name = '', $over_country = '') |
|
887
|
887
|
{ |
|
888
|
888
|
global $globalURL, $globalArchive, $globalDebug; |
|
889
|
889
|
$Common = new Common(); |
|
@@ -935,26 +935,26 @@ discard block |
|
|
block discarded – undo |
|
935
|
935
|
if ($date == '') $date = date("Y-m-d H:i:s", time()); |
|
936
|
936
|
|
|
937
|
937
|
|
|
938
|
|
- $fammarine_id = filter_var($fammarine_id,FILTER_SANITIZE_STRING); |
|
939
|
|
- $ident = filter_var($ident,FILTER_SANITIZE_STRING); |
|
940
|
|
- $latitude = filter_var($latitude,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
941
|
|
- $longitude = filter_var($longitude,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
942
|
|
- $heading = filter_var($heading,FILTER_SANITIZE_NUMBER_INT); |
|
943
|
|
- $groundspeed = filter_var($groundspeed,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
944
|
|
- $format_source = filter_var($format_source,FILTER_SANITIZE_STRING); |
|
945
|
|
- $source_name = filter_var($source_name,FILTER_SANITIZE_STRING); |
|
946
|
|
- $over_country = filter_var($over_country,FILTER_SANITIZE_STRING); |
|
947
|
|
- $type = filter_var($type,FILTER_SANITIZE_STRING); |
|
948
|
|
- $mmsi = filter_var($mmsi,FILTER_SANITIZE_NUMBER_INT); |
|
949
|
|
- $status = filter_var($status,FILTER_SANITIZE_STRING); |
|
950
|
|
- $imo = filter_var($imo,FILTER_SANITIZE_STRING); |
|
951
|
|
- $callsign = filter_var($callsign,FILTER_SANITIZE_STRING); |
|
952
|
|
- $arrival_code = filter_var($arrival_code,FILTER_SANITIZE_STRING); |
|
953
|
|
- $arrival_date = filter_var($arrival_date,FILTER_SANITIZE_STRING); |
|
|
938
|
+ $fammarine_id = filter_var($fammarine_id, FILTER_SANITIZE_STRING); |
|
|
939
|
+ $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
|
940
|
+ $latitude = filter_var($latitude, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
941
|
+ $longitude = filter_var($longitude, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
942
|
+ $heading = filter_var($heading, FILTER_SANITIZE_NUMBER_INT); |
|
|
943
|
+ $groundspeed = filter_var($groundspeed, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
|
944
|
+ $format_source = filter_var($format_source, FILTER_SANITIZE_STRING); |
|
|
945
|
+ $source_name = filter_var($source_name, FILTER_SANITIZE_STRING); |
|
|
946
|
+ $over_country = filter_var($over_country, FILTER_SANITIZE_STRING); |
|
|
947
|
+ $type = filter_var($type, FILTER_SANITIZE_STRING); |
|
|
948
|
+ $mmsi = filter_var($mmsi, FILTER_SANITIZE_NUMBER_INT); |
|
|
949
|
+ $status = filter_var($status, FILTER_SANITIZE_STRING); |
|
|
950
|
+ $imo = filter_var($imo, FILTER_SANITIZE_STRING); |
|
|
951
|
+ $callsign = filter_var($callsign, FILTER_SANITIZE_STRING); |
|
|
952
|
+ $arrival_code = filter_var($arrival_code, FILTER_SANITIZE_STRING); |
|
|
953
|
+ $arrival_date = filter_var($arrival_date, FILTER_SANITIZE_STRING); |
|
954
|
954
|
|
|
955
|
955
|
|
|
956
|
|
- if ($groundspeed == '' || $Common->isInteger($groundspeed) === false ) $groundspeed = 0; |
|
957
|
|
- if ($heading == '' || $Common->isInteger($heading) === false ) $heading = 0; |
|
|
956
|
+ if ($groundspeed == '' || $Common->isInteger($groundspeed) === false) $groundspeed = 0; |
|
|
957
|
+ if ($heading == '' || $Common->isInteger($heading) === false) $heading = 0; |
|
958
|
958
|
if ($arrival_date == '') $arrival_date = NULL; |
|
959
|
959
|
$query = ''; |
|
960
|
960
|
if ($globalArchive) { |
|
@@ -964,19 +964,19 @@ discard block |
|
|
block discarded – undo |
|
964
|
964
|
$query .= 'INSERT INTO marine_live (fammarine_id, ident, latitude, longitude, heading, ground_speed, date, format_source, source_name, over_country, mmsi, type,status,imo,arrival_port_name,arrival_port_date) |
|
965
|
965
|
VALUES (:fammarine_id,:ident,:latitude,:longitude,:heading,:groundspeed,:date,:format_source, :source_name, :over_country,:mmsi,:type,:status,:imo,:arrival_port_name,:arrival_port_date)'; |
|
966
|
966
|
|
|
967
|
|
- $query_values = array(':fammarine_id' => $fammarine_id,':ident' => $ident,':latitude' => $latitude,':longitude' => $longitude,':heading' => $heading,':groundspeed' => $groundspeed,':date' => $date, ':format_source' => $format_source, ':source_name' => $source_name, ':over_country' => $over_country,':mmsi' => $mmsi,':type' => $type,':status' => $status,':imo' => $imo,':arrival_port_name' => $arrival_code,':arrival_port_date' => $arrival_date); |
|
|
967
|
+ $query_values = array(':fammarine_id' => $fammarine_id, ':ident' => $ident, ':latitude' => $latitude, ':longitude' => $longitude, ':heading' => $heading, ':groundspeed' => $groundspeed, ':date' => $date, ':format_source' => $format_source, ':source_name' => $source_name, ':over_country' => $over_country, ':mmsi' => $mmsi, ':type' => $type, ':status' => $status, ':imo' => $imo, ':arrival_port_name' => $arrival_code, ':arrival_port_date' => $arrival_date); |
|
968
|
968
|
try { |
|
969
|
969
|
$sth = $this->db->prepare($query); |
|
970
|
970
|
$sth->execute($query_values); |
|
971
|
971
|
$sth->closeCursor(); |
|
972
|
|
- } catch(PDOException $e) { |
|
|
972
|
+ } catch (PDOException $e) { |
|
973
|
973
|
return "error : ".$e->getMessage(); |
|
974
|
974
|
} |
|
975
|
975
|
|
|
976
|
976
|
if (isset($globalArchive) && $globalArchive && $putinarchive && $noarchive !== true) { |
|
977
|
977
|
if ($globalDebug) echo '(Add to Marine archive : '; |
|
978
|
978
|
$MarineArchive = new MarineArchive($this->db); |
|
979
|
|
- $result = $MarineArchive->addMarineArchiveData($fammarine_id, $ident, $latitude, $longitude, $heading, $groundspeed, $date, $putinarchive, $mmsi,$type,$typeid,$imo, $callsign,$arrival_code,$arrival_date,$status,$noarchive,$format_source, $source_name, $over_country); |
|
|
979
|
+ $result = $MarineArchive->addMarineArchiveData($fammarine_id, $ident, $latitude, $longitude, $heading, $groundspeed, $date, $putinarchive, $mmsi, $type, $typeid, $imo, $callsign, $arrival_code, $arrival_date, $status, $noarchive, $format_source, $source_name, $over_country); |
|
980
|
980
|
if ($globalDebug) echo $result.')'; |
|
981
|
981
|
} |
|
982
|
982
|
return "success"; |
|
@@ -984,7 +984,7 @@ discard block |
|
|
block discarded – undo |
|
984
|
984
|
|
|
985
|
985
|
public function getOrderBy() |
|
986
|
986
|
{ |
|
987
|
|
- $orderby = array("aircraft_asc" => array("key" => "aircraft_asc", "value" => "Aircraft Type - ASC", "sql" => "ORDER BY marine_live.aircraft_icao ASC"), "aircraft_desc" => array("key" => "aircraft_desc", "value" => "Aircraft Type - DESC", "sql" => "ORDER BY marine_live.aircraft_icao DESC"),"manufacturer_asc" => array("key" => "manufacturer_asc", "value" => "Aircraft Manufacturer - ASC", "sql" => "ORDER BY marine_live.aircraft_manufacturer ASC"), "manufacturer_desc" => array("key" => "manufacturer_desc", "value" => "Aircraft Manufacturer - DESC", "sql" => "ORDER BY marine_live.aircraft_manufacturer DESC"),"airline_name_asc" => array("key" => "airline_name_asc", "value" => "Airline Name - ASC", "sql" => "ORDER BY marine_live.airline_name ASC"), "airline_name_desc" => array("key" => "airline_name_desc", "value" => "Airline Name - DESC", "sql" => "ORDER BY marine_live.airline_name DESC"), "ident_asc" => array("key" => "ident_asc", "value" => "Ident - ASC", "sql" => "ORDER BY marine_live.ident ASC"), "ident_desc" => array("key" => "ident_desc", "value" => "Ident - DESC", "sql" => "ORDER BY marine_live.ident DESC"), "airport_departure_asc" => array("key" => "airport_departure_asc", "value" => "Departure Airport - ASC", "sql" => "ORDER BY marine_live.departure_airport_city ASC"), "airport_departure_desc" => array("key" => "airport_departure_desc", "value" => "Departure Airport - DESC", "sql" => "ORDER BY marine_live.departure_airport_city DESC"), "airport_arrival_asc" => array("key" => "airport_arrival_asc", "value" => "Arrival Airport - ASC", "sql" => "ORDER BY marine_live.arrival_airport_city ASC"), "airport_arrival_desc" => array("key" => "airport_arrival_desc", "value" => "Arrival Airport - DESC", "sql" => "ORDER BY marine_live.arrival_airport_city DESC"), "date_asc" => array("key" => "date_asc", "value" => "Date - ASC", "sql" => "ORDER BY marine_live.date ASC"), "date_desc" => array("key" => "date_desc", "value" => "Date - DESC", "sql" => "ORDER BY marine_live.date DESC")); |
|
|
987
|
+ $orderby = array("aircraft_asc" => array("key" => "aircraft_asc", "value" => "Aircraft Type - ASC", "sql" => "ORDER BY marine_live.aircraft_icao ASC"), "aircraft_desc" => array("key" => "aircraft_desc", "value" => "Aircraft Type - DESC", "sql" => "ORDER BY marine_live.aircraft_icao DESC"), "manufacturer_asc" => array("key" => "manufacturer_asc", "value" => "Aircraft Manufacturer - ASC", "sql" => "ORDER BY marine_live.aircraft_manufacturer ASC"), "manufacturer_desc" => array("key" => "manufacturer_desc", "value" => "Aircraft Manufacturer - DESC", "sql" => "ORDER BY marine_live.aircraft_manufacturer DESC"), "airline_name_asc" => array("key" => "airline_name_asc", "value" => "Airline Name - ASC", "sql" => "ORDER BY marine_live.airline_name ASC"), "airline_name_desc" => array("key" => "airline_name_desc", "value" => "Airline Name - DESC", "sql" => "ORDER BY marine_live.airline_name DESC"), "ident_asc" => array("key" => "ident_asc", "value" => "Ident - ASC", "sql" => "ORDER BY marine_live.ident ASC"), "ident_desc" => array("key" => "ident_desc", "value" => "Ident - DESC", "sql" => "ORDER BY marine_live.ident DESC"), "airport_departure_asc" => array("key" => "airport_departure_asc", "value" => "Departure Airport - ASC", "sql" => "ORDER BY marine_live.departure_airport_city ASC"), "airport_departure_desc" => array("key" => "airport_departure_desc", "value" => "Departure Airport - DESC", "sql" => "ORDER BY marine_live.departure_airport_city DESC"), "airport_arrival_asc" => array("key" => "airport_arrival_asc", "value" => "Arrival Airport - ASC", "sql" => "ORDER BY marine_live.arrival_airport_city ASC"), "airport_arrival_desc" => array("key" => "airport_arrival_desc", "value" => "Arrival Airport - DESC", "sql" => "ORDER BY marine_live.arrival_airport_city DESC"), "date_asc" => array("key" => "date_asc", "value" => "Date - ASC", "sql" => "ORDER BY marine_live.date ASC"), "date_desc" => array("key" => "date_desc", "value" => "Date - DESC", "sql" => "ORDER BY marine_live.date DESC")); |
|
988
|
988
|
return $orderby; |
|
989
|
989
|
} |
|
990
|
990
|
|