@@ -17,33 +17,33 @@ discard block |
||
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']."'"; |
@@ -81,15 +81,15 @@ discard block |
||
81 | 81 | $filter_query_date .= " AND EXTRACT(DAY FROM marine_output.date) = '".$filter['day']."'"; |
82 | 82 | } |
83 | 83 | } |
84 | - $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"; |
|
84 | + $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"; |
|
85 | 85 | } |
86 | 86 | if (isset($filter['source_aprs']) && !empty($filter['source_aprs'])) { |
87 | - $filter_query_where .= " AND format_source = 'aprs' AND source_name IN ('".implode("','",$filter['source_aprs'])."')"; |
|
87 | + $filter_query_where .= " AND format_source = 'aprs' AND source_name IN ('".implode("','", $filter['source_aprs'])."')"; |
|
88 | 88 | } |
89 | 89 | if ($filter_query_where == '' && $where) $filter_query_where = ' WHERE'; |
90 | 90 | elseif ($filter_query_where != '' && $and) $filter_query_where .= ' AND'; |
91 | 91 | if ($filter_query_where != '') { |
92 | - $filter_query_where = preg_replace('/^ AND/',' WHERE',$filter_query_where); |
|
92 | + $filter_query_where = preg_replace('/^ AND/', ' WHERE', $filter_query_where); |
|
93 | 93 | } |
94 | 94 | $filter_query = $filter_query_join.$filter_query_where; |
95 | 95 | return $filter_query; |
@@ -112,8 +112,8 @@ discard block |
||
112 | 112 | if ($limit != '') |
113 | 113 | { |
114 | 114 | $limit_array = explode(',', $limit); |
115 | - $limit_array[0] = filter_var($limit_array[0],FILTER_SANITIZE_NUMBER_INT); |
|
116 | - $limit_array[1] = filter_var($limit_array[1],FILTER_SANITIZE_NUMBER_INT); |
|
115 | + $limit_array[0] = filter_var($limit_array[0], FILTER_SANITIZE_NUMBER_INT); |
|
116 | + $limit_array[1] = filter_var($limit_array[1], FILTER_SANITIZE_NUMBER_INT); |
|
117 | 117 | if ($limit_array[0] >= 0 && $limit_array[1] >= 0) |
118 | 118 | { |
119 | 119 | $limit_query = ' LIMIT '.$limit_array[1].' OFFSET '.$limit_array[0]; |
@@ -128,7 +128,7 @@ discard block |
||
128 | 128 | $orderby_query = ' '.$search_orderby_array[$sort]['sql']; |
129 | 129 | } |
130 | 130 | } |
131 | - if ($orderby_query == '') $orderby_query= ' ORDER BY date DESC'; |
|
131 | + if ($orderby_query == '') $orderby_query = ' ORDER BY date DESC'; |
|
132 | 132 | |
133 | 133 | if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
134 | 134 | if ($globalDBdriver == 'mysql') { |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | } else { |
138 | 138 | $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; |
139 | 139 | } |
140 | - $spotter_array = $Marine->getDataFromDB($query.$limit_query,array(),'',true); |
|
140 | + $spotter_array = $Marine->getDataFromDB($query.$limit_query, array(), '', true); |
|
141 | 141 | |
142 | 142 | return $spotter_array; |
143 | 143 | } |
@@ -153,7 +153,7 @@ discard block |
||
153 | 153 | global $globalDBdriver, $globalLiveInterval; |
154 | 154 | date_default_timezone_set('UTC'); |
155 | 155 | |
156 | - $filter_query = $this->getFilter($filter,true,true); |
|
156 | + $filter_query = $this->getFilter($filter, true, true); |
|
157 | 157 | |
158 | 158 | if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
159 | 159 | if ($globalDBdriver == 'mysql') { |
@@ -167,7 +167,7 @@ discard block |
||
167 | 167 | try { |
168 | 168 | $sth = $this->db->prepare($query); |
169 | 169 | $sth->execute(); |
170 | - } catch(PDOException $e) { |
|
170 | + } catch (PDOException $e) { |
|
171 | 171 | echo $e->getMessage(); |
172 | 172 | die; |
173 | 173 | } |
@@ -182,26 +182,26 @@ discard block |
||
182 | 182 | * @return Array the spotter information |
183 | 183 | * |
184 | 184 | */ |
185 | - public function getMinLastLiveMarineData($coord = array(),$filter = array(), $limit = false, $id = '') |
|
185 | + public function getMinLastLiveMarineData($coord = array(), $filter = array(), $limit = false, $id = '') |
|
186 | 186 | { |
187 | 187 | global $globalDBdriver, $globalLiveInterval, $globalMap3DMarinesLimit, $globalArchive; |
188 | 188 | date_default_timezone_set('UTC'); |
189 | 189 | $usecoord = false; |
190 | 190 | if (is_array($coord) && !empty($coord)) { |
191 | - $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
192 | - $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
193 | - $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
194 | - $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
191 | + $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
192 | + $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
193 | + $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
194 | + $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
195 | 195 | $usecoord = true; |
196 | 196 | } |
197 | - $id = filter_var($id,FILTER_SANITIZE_STRING); |
|
198 | - $filter_query = $this->getFilter($filter,true,true); |
|
197 | + $id = filter_var($id, FILTER_SANITIZE_STRING); |
|
198 | + $filter_query = $this->getFilter($filter, true, true); |
|
199 | 199 | |
200 | 200 | if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
201 | 201 | if (!isset($globalMap3DMarinesLimit) || $globalMap3DMarinesLimit == '') $globalMap3DMarinesLimit = '300'; |
202 | 202 | if ($globalDBdriver == 'mysql') { |
203 | 203 | if (isset($globalArchive) && $globalArchive === TRUE) { |
204 | - $query = 'SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id,marine_archive.type_id,marine_archive.type, marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
|
204 | + $query = 'SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id,marine_archive.type_id,marine_archive.type, marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
|
205 | 205 | FROM marine_archive INNER JOIN (SELECT fammarine_id FROM marine_live'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval." SECOND) <= marine_live.date) l ON l.fammarine_id = marine_archive.fammarine_id "; |
206 | 206 | if ($usecoord) $query .= "AND marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
207 | 207 | if ($id != '') $query .= "OR marine_archive.fammarine_id = :id "; |
@@ -215,7 +215,7 @@ discard block |
||
215 | 215 | ORDER BY fammarine_id, date"; |
216 | 216 | if ($limit) $query .= " LIMIT ".$globalMap3DMarinesLimit; |
217 | 217 | } else { |
218 | - $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
218 | + $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
219 | 219 | FROM marine_live'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval." SECOND) <= marine_live.date "; |
220 | 220 | if ($usecoord) $query .= "AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
221 | 221 | if ($id != '') $query .= "OR marine_live.fammarine_id = :id "; |
@@ -225,7 +225,7 @@ discard block |
||
225 | 225 | } |
226 | 226 | } else { |
227 | 227 | if (isset($globalArchive) && $globalArchive === TRUE) { |
228 | - $query = "SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id, marine_archive.type_id, marine_archive.type,marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
|
228 | + $query = "SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id, marine_archive.type_id, marine_archive.type,marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
|
229 | 229 | FROM marine_archive INNER JOIN (SELECT fammarine_id FROM marine_live".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date) l ON l.fammarine_id = marine_archive.fammarine_id "; |
230 | 230 | if ($usecoord) $query .= "AND (marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong.") "; |
231 | 231 | if ($id != '') $query .= "OR marine_archive.fammarine_id = :id "; |
@@ -252,7 +252,7 @@ discard block |
||
252 | 252 | try { |
253 | 253 | $sth = $this->db->prepare($query); |
254 | 254 | $sth->execute($query_values); |
255 | - } catch(PDOException $e) { |
|
255 | + } catch (PDOException $e) { |
|
256 | 256 | echo $e->getMessage(); |
257 | 257 | die; |
258 | 258 | } |
@@ -269,7 +269,7 @@ discard block |
||
269 | 269 | public function getLiveMarineCount($filter = array()) |
270 | 270 | { |
271 | 271 | global $globalDBdriver, $globalLiveInterval; |
272 | - $filter_query = $this->getFilter($filter,true,true); |
|
272 | + $filter_query = $this->getFilter($filter, true, true); |
|
273 | 273 | |
274 | 274 | if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
275 | 275 | if ($globalDBdriver == 'mysql') { |
@@ -280,7 +280,7 @@ discard block |
||
280 | 280 | try { |
281 | 281 | $sth = $this->db->prepare($query); |
282 | 282 | $sth->execute(); |
283 | - } catch(PDOException $e) { |
|
283 | + } catch (PDOException $e) { |
|
284 | 284 | echo $e->getMessage(); |
285 | 285 | die; |
286 | 286 | } |
@@ -303,10 +303,10 @@ discard block |
||
303 | 303 | $filter_query = $this->getFilter($filter); |
304 | 304 | |
305 | 305 | if (is_array($coord)) { |
306 | - $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
307 | - $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
308 | - $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
309 | - $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
306 | + $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
307 | + $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
308 | + $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
309 | + $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
310 | 310 | } else return array(); |
311 | 311 | if ($globalDBdriver == 'mysql') { |
312 | 312 | $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 ORDER BY date DESC'.$filter_query; |
@@ -328,13 +328,13 @@ discard block |
||
328 | 328 | global $globalDBdriver, $globalLiveInterval, $globalArchive; |
329 | 329 | $Marine = new Marine($this->db); |
330 | 330 | if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
331 | - $filter_query = $this->getFilter($filter,true,true); |
|
331 | + $filter_query = $this->getFilter($filter, true, true); |
|
332 | 332 | |
333 | 333 | if (is_array($coord)) { |
334 | - $minlong = filter_var($coord[0],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
335 | - $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
336 | - $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
337 | - $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
334 | + $minlong = filter_var($coord[0], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
335 | + $minlat = filter_var($coord[1], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
336 | + $maxlong = filter_var($coord[2], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
337 | + $maxlat = filter_var($coord[3], FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
338 | 338 | } else return array(); |
339 | 339 | /* |
340 | 340 | if ($globalDBdriver == 'mysql') { |
@@ -349,13 +349,13 @@ discard block |
||
349 | 349 | */ |
350 | 350 | if ($globalDBdriver == 'mysql') { |
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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
353 | 353 | FROM marine_live |
354 | 354 | '.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= marine_live.date |
355 | 355 | AND marine_live.latitude BETWEEN '.$minlat.' AND '.$maxlat.' AND marine_live.longitude BETWEEN '.$minlong.' AND '.$maxlong.' |
356 | 356 | AND marine_live.latitude <> 0 AND marine_live.longitude <> 0 ORDER BY race_rank,date DESC'; |
357 | 357 | } else { |
358 | - $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
358 | + $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
359 | 359 | FROM marine_live |
360 | 360 | INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate |
361 | 361 | FROM marine_live l |
@@ -367,14 +367,14 @@ discard block |
||
367 | 367 | } |
368 | 368 | } else { |
369 | 369 | if (isset($globalArchive) && $globalArchive === TRUE) { |
370 | - $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
370 | + $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
371 | 371 | FROM marine_live |
372 | 372 | ".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date |
373 | 373 | AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." |
374 | 374 | AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong." |
375 | 375 | AND marine_live.latitude <> '0' AND marine_live.longitude <> '0' ORDER BY race_rank, date DESC"; |
376 | 376 | } else { |
377 | - $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
377 | + $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, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
|
378 | 378 | FROM marine_live |
379 | 379 | INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate |
380 | 380 | FROM marine_live l |
@@ -431,7 +431,7 @@ discard block |
||
431 | 431 | if ($interval == '1m') |
432 | 432 | { |
433 | 433 | $additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 MINUTE) <= marine_live.date '; |
434 | - } else if ($interval == '15m'){ |
|
434 | + } else if ($interval == '15m') { |
|
435 | 435 | $additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 15 MINUTE) <= marine_live.date '; |
436 | 436 | } |
437 | 437 | } |
@@ -439,14 +439,14 @@ discard block |
||
439 | 439 | $additional_query = ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 MINUTE) <= marine_live.date '; |
440 | 440 | } |
441 | 441 | |
442 | - $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 |
|
442 | + $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 |
|
443 | 443 | WHERE marine_live.latitude <> '' |
444 | 444 | AND marine_live.longitude <> '' |
445 | 445 | ".$additional_query." |
446 | 446 | HAVING distance < :radius |
447 | 447 | ORDER BY distance"; |
448 | 448 | |
449 | - $spotter_array = $Marine->getDataFromDB($query, array(':lat' => $lat, ':lng' => $lng,':radius' => $radius)); |
|
449 | + $spotter_array = $Marine->getDataFromDB($query, array(':lat' => $lat, ':lng' => $lng, ':radius' => $radius)); |
|
450 | 450 | |
451 | 451 | return $spotter_array; |
452 | 452 | } |
@@ -464,9 +464,9 @@ discard block |
||
464 | 464 | date_default_timezone_set('UTC'); |
465 | 465 | |
466 | 466 | $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
467 | - $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'; |
|
467 | + $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'; |
|
468 | 468 | |
469 | - $spotter_array = $Marine->getDataFromDB($query,array(':ident' => $ident),'',true); |
|
469 | + $spotter_array = $Marine->getDataFromDB($query, array(':ident' => $ident), '', true); |
|
470 | 470 | |
471 | 471 | return $spotter_array; |
472 | 472 | } |
@@ -477,14 +477,14 @@ discard block |
||
477 | 477 | * @return Array the spotter information |
478 | 478 | * |
479 | 479 | */ |
480 | - public function getDateLiveMarineDataByIdent($ident,$date) |
|
480 | + public function getDateLiveMarineDataByIdent($ident, $date) |
|
481 | 481 | { |
482 | 482 | $Marine = new Marine($this->db); |
483 | 483 | date_default_timezone_set('UTC'); |
484 | 484 | $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
485 | 485 | $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'; |
486 | - $date = date('c',$date); |
|
487 | - $spotter_array = $Marine->getDataFromDB($query,array(':ident' => $ident,':date' => $date)); |
|
486 | + $date = date('c', $date); |
|
487 | + $spotter_array = $Marine->getDataFromDB($query, array(':ident' => $ident, ':date' => $date)); |
|
488 | 488 | return $spotter_array; |
489 | 489 | } |
490 | 490 | |
@@ -494,14 +494,14 @@ discard block |
||
494 | 494 | * @return Array the spotter information |
495 | 495 | * |
496 | 496 | */ |
497 | - public function getDateLiveMarineDataByMMSI($mmsi,$date) |
|
497 | + public function getDateLiveMarineDataByMMSI($mmsi, $date) |
|
498 | 498 | { |
499 | 499 | $Marine = new Marine($this->db); |
500 | 500 | date_default_timezone_set('UTC'); |
501 | 501 | $mmsi = filter_var($mmsi, FILTER_SANITIZE_NUMBER_INT); |
502 | 502 | $query = 'SELECT marine_live.* FROM marine_live INNER JOIN (SELECT l.fammarine_id, max(l.date) as maxdate FROM marine_live l WHERE l.mmsi = :mmsi 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'; |
503 | - $date = date('c',$date); |
|
504 | - $spotter_array = $Marine->getDataFromDB($query,array(':mmsi' => $mmsi,':date' => $date)); |
|
503 | + $date = date('c', $date); |
|
504 | + $spotter_array = $Marine->getDataFromDB($query, array(':mmsi' => $mmsi, ':date' => $date)); |
|
505 | 505 | return $spotter_array; |
506 | 506 | } |
507 | 507 | |
@@ -517,9 +517,9 @@ discard block |
||
517 | 517 | date_default_timezone_set('UTC'); |
518 | 518 | |
519 | 519 | $id = filter_var($id, FILTER_SANITIZE_STRING); |
520 | - $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'; |
|
520 | + $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'; |
|
521 | 521 | |
522 | - $spotter_array = $Marine->getDataFromDB($query,array(':id' => $id),'',true); |
|
522 | + $spotter_array = $Marine->getDataFromDB($query, array(':id' => $id), '', true); |
|
523 | 523 | |
524 | 524 | return $spotter_array; |
525 | 525 | } |
@@ -530,15 +530,15 @@ discard block |
||
530 | 530 | * @return Array the spotter information |
531 | 531 | * |
532 | 532 | */ |
533 | - public function getDateLiveMarineDataById($id,$date) |
|
533 | + public function getDateLiveMarineDataById($id, $date) |
|
534 | 534 | { |
535 | 535 | $Marine = new Marine($this->db); |
536 | 536 | date_default_timezone_set('UTC'); |
537 | 537 | |
538 | 538 | $id = filter_var($id, FILTER_SANITIZE_STRING); |
539 | - $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'; |
|
540 | - $date = date('c',$date); |
|
541 | - $spotter_array = $Marine->getDataFromDB($query,array(':id' => $id,':date' => $date),'',true); |
|
539 | + $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'; |
|
540 | + $date = date('c', $date); |
|
541 | + $spotter_array = $Marine->getDataFromDB($query, array(':id' => $id, ':date' => $date), '', true); |
|
542 | 542 | |
543 | 543 | return $spotter_array; |
544 | 544 | } |
@@ -550,7 +550,7 @@ discard block |
||
550 | 550 | * @return Array the spotter information |
551 | 551 | * |
552 | 552 | */ |
553 | - public function getAllLiveMarineDataById($id,$liveinterval = false) |
|
553 | + public function getAllLiveMarineDataById($id, $liveinterval = false) |
|
554 | 554 | { |
555 | 555 | global $globalDBdriver, $globalLiveInterval; |
556 | 556 | date_default_timezone_set('UTC'); |
@@ -569,7 +569,7 @@ discard block |
||
569 | 569 | try { |
570 | 570 | $sth = $this->db->prepare($query); |
571 | 571 | $sth->execute(array(':id' => $id)); |
572 | - } catch(PDOException $e) { |
|
572 | + } catch (PDOException $e) { |
|
573 | 573 | echo $e->getMessage(); |
574 | 574 | die; |
575 | 575 | } |
@@ -587,12 +587,12 @@ discard block |
||
587 | 587 | { |
588 | 588 | date_default_timezone_set('UTC'); |
589 | 589 | $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
590 | - $query = self::$global_query.' WHERE marine_live.ident = :ident'; |
|
590 | + $query = self::$global_query.' WHERE marine_live.ident = :ident'; |
|
591 | 591 | try { |
592 | 592 | |
593 | 593 | $sth = $this->db->prepare($query); |
594 | 594 | $sth->execute(array(':ident' => $ident)); |
595 | - } catch(PDOException $e) { |
|
595 | + } catch (PDOException $e) { |
|
596 | 596 | echo $e->getMessage(); |
597 | 597 | die; |
598 | 598 | } |
@@ -622,7 +622,7 @@ discard block |
||
622 | 622 | |
623 | 623 | $sth = $this->db->prepare($query); |
624 | 624 | $sth->execute(); |
625 | - } catch(PDOException $e) { |
|
625 | + } catch (PDOException $e) { |
|
626 | 626 | return "error"; |
627 | 627 | } |
628 | 628 | |
@@ -645,14 +645,14 @@ discard block |
||
645 | 645 | |
646 | 646 | $sth = $this->db->prepare($query); |
647 | 647 | $sth->execute(); |
648 | - } catch(PDOException $e) { |
|
648 | + } catch (PDOException $e) { |
|
649 | 649 | return "error"; |
650 | 650 | } |
651 | 651 | $query_delete = 'DELETE FROM marine_live WHERE fammarine_id IN ('; |
652 | 652 | $i = 0; |
653 | - $j =0; |
|
653 | + $j = 0; |
|
654 | 654 | $all = $sth->fetchAll(PDO::FETCH_ASSOC); |
655 | - foreach($all as $row) |
|
655 | + foreach ($all as $row) |
|
656 | 656 | { |
657 | 657 | $i++; |
658 | 658 | $j++; |
@@ -660,9 +660,9 @@ discard block |
||
660 | 660 | if ($globalDebug) echo "."; |
661 | 661 | try { |
662 | 662 | |
663 | - $sth = $this->db->prepare(substr($query_delete,0,-1).")"); |
|
663 | + $sth = $this->db->prepare(substr($query_delete, 0, -1).")"); |
|
664 | 664 | $sth->execute(); |
665 | - } catch(PDOException $e) { |
|
665 | + } catch (PDOException $e) { |
|
666 | 666 | return "error"; |
667 | 667 | } |
668 | 668 | $query_delete = 'DELETE FROM marine_live WHERE fammarine_id IN ('; |
@@ -673,9 +673,9 @@ discard block |
||
673 | 673 | if ($i > 0) { |
674 | 674 | try { |
675 | 675 | |
676 | - $sth = $this->db->prepare(substr($query_delete,0,-1).")"); |
|
676 | + $sth = $this->db->prepare(substr($query_delete, 0, -1).")"); |
|
677 | 677 | $sth->execute(); |
678 | - } catch(PDOException $e) { |
|
678 | + } catch (PDOException $e) { |
|
679 | 679 | return "error"; |
680 | 680 | } |
681 | 681 | } |
@@ -688,7 +688,7 @@ discard block |
||
688 | 688 | |
689 | 689 | $sth = $this->db->prepare($query); |
690 | 690 | $sth->execute(); |
691 | - } catch(PDOException $e) { |
|
691 | + } catch (PDOException $e) { |
|
692 | 692 | return "error"; |
693 | 693 | } |
694 | 694 | /* $query_delete = "DELETE FROM marine_live WHERE fammarine_id IN ("; |
@@ -736,13 +736,13 @@ discard block |
||
736 | 736 | public function deleteLiveMarineDataByIdent($ident) |
737 | 737 | { |
738 | 738 | $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
739 | - $query = 'DELETE FROM marine_live WHERE ident = :ident'; |
|
739 | + $query = 'DELETE FROM marine_live WHERE ident = :ident'; |
|
740 | 740 | |
741 | 741 | try { |
742 | 742 | |
743 | 743 | $sth = $this->db->prepare($query); |
744 | 744 | $sth->execute(array(':ident' => $ident)); |
745 | - } catch(PDOException $e) { |
|
745 | + } catch (PDOException $e) { |
|
746 | 746 | return "error"; |
747 | 747 | } |
748 | 748 | |
@@ -758,13 +758,13 @@ discard block |
||
758 | 758 | public function deleteLiveMarineDataById($id) |
759 | 759 | { |
760 | 760 | $id = filter_var($id, FILTER_SANITIZE_STRING); |
761 | - $query = 'DELETE FROM marine_live WHERE fammarine_id = :id'; |
|
761 | + $query = 'DELETE FROM marine_live WHERE fammarine_id = :id'; |
|
762 | 762 | |
763 | 763 | try { |
764 | 764 | |
765 | 765 | $sth = $this->db->prepare($query); |
766 | 766 | $sth->execute(array(':id' => $id)); |
767 | - } catch(PDOException $e) { |
|
767 | + } catch (PDOException $e) { |
|
768 | 768 | return "error"; |
769 | 769 | } |
770 | 770 | |
@@ -780,7 +780,7 @@ discard block |
||
780 | 780 | */ |
781 | 781 | public function getAllRaces() |
782 | 782 | { |
783 | - $query = 'SELECT DISTINCT marine_live.race_id, marine_live.race_name FROM marine_live ORDER BY marine_live.race_name'; |
|
783 | + $query = 'SELECT DISTINCT marine_live.race_id, marine_live.race_name FROM marine_live ORDER BY marine_live.race_name'; |
|
784 | 784 | $sth = $this->db->prepare($query); |
785 | 785 | $sth->execute(); |
786 | 786 | return $sth->fetchAll(PDO::FETCH_ASSOC); |
@@ -796,13 +796,13 @@ discard block |
||
796 | 796 | { |
797 | 797 | global $globalDBdriver, $globalTimezone; |
798 | 798 | if ($globalDBdriver == 'mysql') { |
799 | - $query = 'SELECT marine_live.ident FROM marine_live |
|
799 | + $query = 'SELECT marine_live.ident FROM marine_live |
|
800 | 800 | WHERE marine_live.ident = :ident |
801 | 801 | AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 1 HOUR) |
802 | 802 | AND marine_live.date < UTC_TIMESTAMP()'; |
803 | 803 | $query_data = array(':ident' => $ident); |
804 | 804 | } else { |
805 | - $query = "SELECT marine_live.ident FROM marine_live |
|
805 | + $query = "SELECT marine_live.ident FROM marine_live |
|
806 | 806 | WHERE marine_live.ident = :ident |
807 | 807 | AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '1 HOURS' |
808 | 808 | AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
@@ -811,8 +811,8 @@ discard block |
||
811 | 811 | |
812 | 812 | $sth = $this->db->prepare($query); |
813 | 813 | $sth->execute($query_data); |
814 | - $ident_result=''; |
|
815 | - while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
814 | + $ident_result = ''; |
|
815 | + while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
816 | 816 | { |
817 | 817 | $ident_result = $row['ident']; |
818 | 818 | } |
@@ -829,13 +829,13 @@ discard block |
||
829 | 829 | { |
830 | 830 | global $globalDBdriver, $globalTimezone; |
831 | 831 | if ($globalDBdriver == 'mysql') { |
832 | - $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
832 | + $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
833 | 833 | WHERE marine_live.ident = :ident |
834 | 834 | AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 30 MINUTE)'; |
835 | 835 | // AND marine_live.date < UTC_TIMESTAMP()"; |
836 | 836 | $query_data = array(':ident' => $ident); |
837 | 837 | } else { |
838 | - $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
838 | + $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
839 | 839 | WHERE marine_live.ident = :ident |
840 | 840 | AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '30 MINUTES'"; |
841 | 841 | // AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
@@ -844,8 +844,8 @@ discard block |
||
844 | 844 | |
845 | 845 | $sth = $this->db->prepare($query); |
846 | 846 | $sth->execute($query_data); |
847 | - $ident_result=''; |
|
848 | - while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
847 | + $ident_result = ''; |
|
848 | + while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
849 | 849 | { |
850 | 850 | $ident_result = $row['fammarine_id']; |
851 | 851 | } |
@@ -862,13 +862,13 @@ discard block |
||
862 | 862 | { |
863 | 863 | global $globalDBdriver, $globalTimezone; |
864 | 864 | if ($globalDBdriver == 'mysql') { |
865 | - $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
865 | + $query = 'SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
866 | 866 | WHERE marine_live.fammarine_id = :id |
867 | 867 | AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 10 HOUR)'; |
868 | 868 | // AND marine_live.date < UTC_TIMESTAMP()"; |
869 | 869 | $query_data = array(':id' => $id); |
870 | 870 | } else { |
871 | - $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
871 | + $query = "SELECT marine_live.ident, marine_live.fammarine_id FROM marine_live |
|
872 | 872 | WHERE marine_live.fammarine_id = :id |
873 | 873 | AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '10 HOUR'"; |
874 | 874 | // AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
@@ -877,8 +877,8 @@ discard block |
||
877 | 877 | |
878 | 878 | $sth = $this->db->prepare($query); |
879 | 879 | $sth->execute($query_data); |
880 | - $ident_result=''; |
|
881 | - while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
880 | + $ident_result = ''; |
|
881 | + while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
882 | 882 | { |
883 | 883 | $ident_result = $row['fammarine_id']; |
884 | 884 | } |
@@ -895,13 +895,13 @@ discard block |
||
895 | 895 | { |
896 | 896 | global $globalDBdriver, $globalTimezone; |
897 | 897 | if ($globalDBdriver == 'mysql') { |
898 | - $query = 'SELECT marine_live.fammarine_id FROM marine_live |
|
898 | + $query = 'SELECT marine_live.fammarine_id FROM marine_live |
|
899 | 899 | WHERE marine_live.mmsi = :mmsi |
900 | 900 | AND marine_live.date >= DATE_SUB(UTC_TIMESTAMP(),INTERVAL 10 HOUR)'; |
901 | 901 | // AND marine_live.date < UTC_TIMESTAMP()"; |
902 | 902 | $query_data = array(':mmsi' => $mmsi); |
903 | 903 | } else { |
904 | - $query = "SELECT marine_live.fammarine_id FROM marine_live |
|
904 | + $query = "SELECT marine_live.fammarine_id FROM marine_live |
|
905 | 905 | WHERE marine_live.mmsi = :mmsi |
906 | 906 | AND marine_live.date >= now() AT TIME ZONE 'UTC' - INTERVAL '10 HOUR'"; |
907 | 907 | // AND marine_live.date < now() AT TIME ZONE 'UTC'"; |
@@ -910,8 +910,8 @@ discard block |
||
910 | 910 | |
911 | 911 | $sth = $this->db->prepare($query); |
912 | 912 | $sth->execute($query_data); |
913 | - $ident_result=''; |
|
914 | - while($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
913 | + $ident_result = ''; |
|
914 | + while ($row = $sth->fetch(PDO::FETCH_ASSOC)) |
|
915 | 915 | { |
916 | 916 | $ident_result = $row['fammarine_id']; |
917 | 917 | } |
@@ -929,7 +929,7 @@ discard block |
||
929 | 929 | * @return String success or false |
930 | 930 | * |
931 | 931 | */ |
932 | - 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 = '',$captain_id = '',$captain_name = '',$race_id = '', $race_name = '', $distance = '', $race_rank = '', $race_time = '') |
|
932 | + 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 = '', $captain_id = '', $captain_name = '', $race_id = '', $race_name = '', $distance = '', $race_rank = '', $race_time = '') |
|
933 | 933 | { |
934 | 934 | global $globalURL, $globalArchive, $globalDebug; |
935 | 935 | $Common = new Common(); |
@@ -981,37 +981,37 @@ discard block |
||
981 | 981 | if ($date == '') $date = date("Y-m-d H:i:s", time()); |
982 | 982 | |
983 | 983 | |
984 | - $fammarine_id = filter_var($fammarine_id,FILTER_SANITIZE_STRING); |
|
985 | - $ident = filter_var($ident,FILTER_SANITIZE_STRING); |
|
986 | - $latitude = filter_var($latitude,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
987 | - $longitude = filter_var($longitude,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
988 | - $distance = filter_var($distance,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
989 | - $heading = filter_var($heading,FILTER_SANITIZE_NUMBER_INT); |
|
990 | - $groundspeed = filter_var($groundspeed,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
991 | - $format_source = filter_var($format_source,FILTER_SANITIZE_STRING); |
|
992 | - $source_name = filter_var($source_name,FILTER_SANITIZE_STRING); |
|
993 | - $over_country = filter_var($over_country,FILTER_SANITIZE_STRING); |
|
994 | - $type = filter_var($type,FILTER_SANITIZE_STRING); |
|
995 | - $typeid = filter_var($typeid,FILTER_SANITIZE_NUMBER_INT); |
|
996 | - $mmsi = filter_var($mmsi,FILTER_SANITIZE_NUMBER_INT); |
|
997 | - $status = filter_var($status,FILTER_SANITIZE_STRING); |
|
998 | - $statusid = filter_var($statusid,FILTER_SANITIZE_NUMBER_INT); |
|
999 | - $imo = filter_var($imo,FILTER_SANITIZE_STRING); |
|
1000 | - $callsign = filter_var($callsign,FILTER_SANITIZE_STRING); |
|
1001 | - $arrival_code = filter_var($arrival_code,FILTER_SANITIZE_STRING); |
|
1002 | - $arrival_date = filter_var($arrival_date,FILTER_SANITIZE_STRING); |
|
1003 | - $captain_id = filter_var($captain_id,FILTER_SANITIZE_STRING); |
|
1004 | - $captain_name = filter_var($captain_name,FILTER_SANITIZE_STRING); |
|
1005 | - $race_id = filter_var($race_id,FILTER_SANITIZE_STRING); |
|
1006 | - $race_name = filter_var($race_name,FILTER_SANITIZE_STRING); |
|
1007 | - $race_rank = filter_var($race_rank,FILTER_SANITIZE_NUMBER_INT); |
|
1008 | - $race_time = filter_var($race_time,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
|
984 | + $fammarine_id = filter_var($fammarine_id, FILTER_SANITIZE_STRING); |
|
985 | + $ident = filter_var($ident, FILTER_SANITIZE_STRING); |
|
986 | + $latitude = filter_var($latitude, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
987 | + $longitude = filter_var($longitude, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
988 | + $distance = filter_var($distance, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
989 | + $heading = filter_var($heading, FILTER_SANITIZE_NUMBER_INT); |
|
990 | + $groundspeed = filter_var($groundspeed, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
991 | + $format_source = filter_var($format_source, FILTER_SANITIZE_STRING); |
|
992 | + $source_name = filter_var($source_name, FILTER_SANITIZE_STRING); |
|
993 | + $over_country = filter_var($over_country, FILTER_SANITIZE_STRING); |
|
994 | + $type = filter_var($type, FILTER_SANITIZE_STRING); |
|
995 | + $typeid = filter_var($typeid, FILTER_SANITIZE_NUMBER_INT); |
|
996 | + $mmsi = filter_var($mmsi, FILTER_SANITIZE_NUMBER_INT); |
|
997 | + $status = filter_var($status, FILTER_SANITIZE_STRING); |
|
998 | + $statusid = filter_var($statusid, FILTER_SANITIZE_NUMBER_INT); |
|
999 | + $imo = filter_var($imo, FILTER_SANITIZE_STRING); |
|
1000 | + $callsign = filter_var($callsign, FILTER_SANITIZE_STRING); |
|
1001 | + $arrival_code = filter_var($arrival_code, FILTER_SANITIZE_STRING); |
|
1002 | + $arrival_date = filter_var($arrival_date, FILTER_SANITIZE_STRING); |
|
1003 | + $captain_id = filter_var($captain_id, FILTER_SANITIZE_STRING); |
|
1004 | + $captain_name = filter_var($captain_name, FILTER_SANITIZE_STRING); |
|
1005 | + $race_id = filter_var($race_id, FILTER_SANITIZE_STRING); |
|
1006 | + $race_name = filter_var($race_name, FILTER_SANITIZE_STRING); |
|
1007 | + $race_rank = filter_var($race_rank, FILTER_SANITIZE_NUMBER_INT); |
|
1008 | + $race_time = filter_var($race_time, FILTER_SANITIZE_NUMBER_FLOAT, FILTER_FLAG_ALLOW_FRACTION); |
|
1009 | 1009 | if ($typeid == '') $typeid = NULL; |
1010 | 1010 | if ($statusid == '') $statusid = NULL; |
1011 | 1011 | if ($distance == '') $distance = NULL; |
1012 | 1012 | |
1013 | 1013 | //if ($groundspeed == '' || $Common->isInteger($groundspeed) === false ) $groundspeed = 0; |
1014 | - if ($heading == '' || $Common->isInteger($heading) === false ) $heading = 0; |
|
1014 | + if ($heading == '' || $Common->isInteger($heading) === false) $heading = 0; |
|
1015 | 1015 | if ($arrival_date == '') $arrival_date = NULL; |
1016 | 1016 | $query = ''; |
1017 | 1017 | if ($globalArchive) { |
@@ -1020,19 +1020,19 @@ discard block |
||
1020 | 1020 | } |
1021 | 1021 | $query .= 'INSERT INTO marine_live (fammarine_id, ident, latitude, longitude, heading, ground_speed, date, format_source, source_name, over_country, mmsi, type,type_id,status,status_id,imo,arrival_port_name,arrival_port_date,captain_id,captain_name,race_id,race_name,distance,race_rank,race_time) |
1022 | 1022 | VALUES (:fammarine_id,:ident,:latitude,:longitude,:heading,:groundspeed,:date,:format_source, :source_name, :over_country,:mmsi,:type,:typeid,:status,:statusid,:imo,:arrival_port_name,:arrival_port_date,:captain_id,:captain_name,:race_id,:race_name,:distance,:race_rank,:race_time)'; |
1023 | - $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,':typeid' => $typeid,':status' => $status,':statusid' => $statusid,':imo' => $imo,':arrival_port_name' => $arrival_code,':arrival_port_date' => $arrival_date,':captain_id' => $captain_id,':captain_name' => $captain_name,':race_id' => $race_id,':race_name' => $race_name,':distance' => $distance,':race_time' => $race_time,':race_rank' => $race_rank); |
|
1023 | + $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, ':typeid' => $typeid, ':status' => $status, ':statusid' => $statusid, ':imo' => $imo, ':arrival_port_name' => $arrival_code, ':arrival_port_date' => $arrival_date, ':captain_id' => $captain_id, ':captain_name' => $captain_name, ':race_id' => $race_id, ':race_name' => $race_name, ':distance' => $distance, ':race_time' => $race_time, ':race_rank' => $race_rank); |
|
1024 | 1024 | try { |
1025 | 1025 | $sth = $this->db->prepare($query); |
1026 | 1026 | $sth->execute($query_values); |
1027 | 1027 | $sth->closeCursor(); |
1028 | - } catch(PDOException $e) { |
|
1028 | + } catch (PDOException $e) { |
|
1029 | 1029 | return "error : ".$e->getMessage(); |
1030 | 1030 | } |
1031 | 1031 | |
1032 | 1032 | if (isset($globalArchive) && $globalArchive && $putinarchive && $noarchive !== true) { |
1033 | 1033 | if ($globalDebug) echo '(Add to Marine archive : '; |
1034 | 1034 | $MarineArchive = new MarineArchive($this->db); |
1035 | - $result = $MarineArchive->addMarineArchiveData($fammarine_id, $ident, $latitude, $longitude, $heading, $groundspeed, $date, $putinarchive, $mmsi,$type,$typeid,$imo, $callsign,$arrival_code,$arrival_date,$status,$statusid,$noarchive,$format_source, $source_name, $over_country,$captain_id,$captain_name,$race_id,$race_name,$distance,$race_rank,$race_time); |
|
1035 | + $result = $MarineArchive->addMarineArchiveData($fammarine_id, $ident, $latitude, $longitude, $heading, $groundspeed, $date, $putinarchive, $mmsi, $type, $typeid, $imo, $callsign, $arrival_code, $arrival_date, $status, $statusid, $noarchive, $format_source, $source_name, $over_country, $captain_id, $captain_name, $race_id, $race_name, $distance, $race_rank, $race_time); |
|
1036 | 1036 | if ($globalDebug) echo $result.')'; |
1037 | 1037 | } |
1038 | 1038 | return "success"; |
@@ -1040,7 +1040,7 @@ discard block |
||
1040 | 1040 | |
1041 | 1041 | public function getOrderBy() |
1042 | 1042 | { |
1043 | - $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")); |
|
1043 | + $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")); |
|
1044 | 1044 | return $orderby; |
1045 | 1045 | } |
1046 | 1046 |
@@ -8,7 +8,9 @@ discard block |
||
8 | 8 | public function __construct($dbc = null) { |
9 | 9 | $Connection = new Connection($dbc); |
10 | 10 | $this->db = $Connection->db(); |
11 | - if ($this->db === null) die('Error: No DB connection. (MarineLive)'); |
|
11 | + if ($this->db === null) { |
|
12 | + die('Error: No DB connection. (MarineLive)'); |
|
13 | + } |
|
12 | 14 | } |
13 | 15 | |
14 | 16 | |
@@ -30,7 +32,9 @@ discard block |
||
30 | 32 | if (isset($filter[0]['source'])) { |
31 | 33 | $filters = array_merge($filters,$filter); |
32 | 34 | } |
33 | - if (is_array($globalFilter)) $filter = array_merge($filter,$globalFilter); |
|
35 | + if (is_array($globalFilter)) { |
|
36 | + $filter = array_merge($filter,$globalFilter); |
|
37 | + } |
|
34 | 38 | $filter_query_join = ''; |
35 | 39 | $filter_query_where = ''; |
36 | 40 | foreach($filters as $flt) { |
@@ -86,8 +90,11 @@ discard block |
||
86 | 90 | if (isset($filter['source_aprs']) && !empty($filter['source_aprs'])) { |
87 | 91 | $filter_query_where .= " AND format_source = 'aprs' AND source_name IN ('".implode("','",$filter['source_aprs'])."')"; |
88 | 92 | } |
89 | - if ($filter_query_where == '' && $where) $filter_query_where = ' WHERE'; |
|
90 | - elseif ($filter_query_where != '' && $and) $filter_query_where .= ' AND'; |
|
93 | + if ($filter_query_where == '' && $where) { |
|
94 | + $filter_query_where = ' WHERE'; |
|
95 | + } elseif ($filter_query_where != '' && $and) { |
|
96 | + $filter_query_where .= ' AND'; |
|
97 | + } |
|
91 | 98 | if ($filter_query_where != '') { |
92 | 99 | $filter_query_where = preg_replace('/^ AND/',' WHERE',$filter_query_where); |
93 | 100 | } |
@@ -128,9 +135,13 @@ discard block |
||
128 | 135 | $orderby_query = ' '.$search_orderby_array[$sort]['sql']; |
129 | 136 | } |
130 | 137 | } |
131 | - if ($orderby_query == '') $orderby_query= ' ORDER BY date DESC'; |
|
138 | + if ($orderby_query == '') { |
|
139 | + $orderby_query= ' ORDER BY date DESC'; |
|
140 | + } |
|
132 | 141 | |
133 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
142 | + if (!isset($globalLiveInterval)) { |
|
143 | + $globalLiveInterval = '200'; |
|
144 | + } |
|
134 | 145 | if ($globalDBdriver == 'mysql') { |
135 | 146 | //$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 30 SECOND) <= l.date GROUP BY l.fammarine_id) s on marine_live.fammarine_id = s.fammarine_id AND marine_live.date = s.maxdate"; |
136 | 147 | $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'.$filter_query.$orderby_query; |
@@ -155,7 +166,9 @@ discard block |
||
155 | 166 | |
156 | 167 | $filter_query = $this->getFilter($filter,true,true); |
157 | 168 | |
158 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
169 | + if (!isset($globalLiveInterval)) { |
|
170 | + $globalLiveInterval = '200'; |
|
171 | + } |
|
159 | 172 | if ($globalDBdriver == 'mysql') { |
160 | 173 | $query = 'SELECT marine_live.mmsi, marine_live.ident, marine_live.type,marine_live.fammarine_id, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
161 | 174 | 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'.$filter_query." marine_live.latitude <> 0 AND marine_live.longitude <> 0 ORDER BY marine_live.race_rank"; |
@@ -197,58 +210,96 @@ discard block |
||
197 | 210 | $id = filter_var($id,FILTER_SANITIZE_STRING); |
198 | 211 | $filter_query = $this->getFilter($filter,true,true); |
199 | 212 | |
200 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
201 | - if (!isset($globalMap3DMarinesLimit) || $globalMap3DMarinesLimit == '') $globalMap3DMarinesLimit = '300'; |
|
213 | + if (!isset($globalLiveInterval)) { |
|
214 | + $globalLiveInterval = '200'; |
|
215 | + } |
|
216 | + if (!isset($globalMap3DMarinesLimit) || $globalMap3DMarinesLimit == '') { |
|
217 | + $globalMap3DMarinesLimit = '300'; |
|
218 | + } |
|
202 | 219 | if ($globalDBdriver == 'mysql') { |
203 | 220 | if (isset($globalArchive) && $globalArchive === TRUE) { |
204 | 221 | $query = 'SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id,marine_archive.type_id,marine_archive.type, marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
205 | 222 | FROM marine_archive INNER JOIN (SELECT fammarine_id FROM marine_live'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval." SECOND) <= marine_live.date) l ON l.fammarine_id = marine_archive.fammarine_id "; |
206 | - if ($usecoord) $query .= "AND marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
|
207 | - if ($id != '') $query .= "OR marine_archive.fammarine_id = :id "; |
|
223 | + if ($usecoord) { |
|
224 | + $query .= "AND marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
|
225 | + } |
|
226 | + if ($id != '') { |
|
227 | + $query .= "OR marine_archive.fammarine_id = :id "; |
|
228 | + } |
|
208 | 229 | $query .= "UNION |
209 | 230 | SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
210 | 231 | FROM marine_live".$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval." SECOND) <= marine_live.date"; |
211 | - if ($usecoord) $query .= " AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong; |
|
212 | - if ($id != '') $query .= "OR marine_live.fammarine_id = :id "; |
|
232 | + if ($usecoord) { |
|
233 | + $query .= " AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong; |
|
234 | + } |
|
235 | + if ($id != '') { |
|
236 | + $query .= "OR marine_live.fammarine_id = :id "; |
|
237 | + } |
|
213 | 238 | $query .= ") AS marine |
214 | 239 | WHERE latitude <> '0' AND longitude <> '0' |
215 | 240 | ORDER BY fammarine_id, date"; |
216 | - if ($limit) $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
241 | + if ($limit) { |
|
242 | + $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
243 | + } |
|
217 | 244 | } else { |
218 | 245 | $query = 'SELECT marine_live.ident, marine_live.fammarine_id,marine_live.type_id,marine_live.type, marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
219 | 246 | FROM marine_live'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval." SECOND) <= marine_live.date "; |
220 | - if ($usecoord) $query .= "AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
|
221 | - if ($id != '') $query .= "OR marine_live.fammarine_id = :id "; |
|
247 | + if ($usecoord) { |
|
248 | + $query .= "AND marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong." "; |
|
249 | + } |
|
250 | + if ($id != '') { |
|
251 | + $query .= "OR marine_live.fammarine_id = :id "; |
|
252 | + } |
|
222 | 253 | $query .= "AND marine_live.latitude <> '0' AND marine_live.longitude <> '0' |
223 | 254 | ORDER BY marine_live.fammarine_id, marine_live.date"; |
224 | - if ($limit) $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
255 | + if ($limit) { |
|
256 | + $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
257 | + } |
|
225 | 258 | } |
226 | 259 | } else { |
227 | 260 | if (isset($globalArchive) && $globalArchive === TRUE) { |
228 | 261 | $query = "SELECT * FROM (SELECT marine_archive.ident, marine_archive.fammarine_id, marine_archive.type_id, marine_archive.type,marine_archive.latitude, marine_archive.longitude, marine_archive.heading, marine_archive.ground_speed, marine_archive.date, marine_archive.format_source, marine_archive.captain_name, marine_archive.race_id, marine_archive.race_rank, marine_archive.race_name |
229 | 262 | FROM marine_archive INNER JOIN (SELECT fammarine_id FROM marine_live".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date) l ON l.fammarine_id = marine_archive.fammarine_id "; |
230 | - if ($usecoord) $query .= "AND (marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong.") "; |
|
231 | - if ($id != '') $query .= "OR marine_archive.fammarine_id = :id "; |
|
263 | + if ($usecoord) { |
|
264 | + $query .= "AND (marine_archive.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_archive.longitude BETWEEN ".$minlong." AND ".$maxlong.") "; |
|
265 | + } |
|
266 | + if ($id != '') { |
|
267 | + $query .= "OR marine_archive.fammarine_id = :id "; |
|
268 | + } |
|
232 | 269 | $query .= "UNION |
233 | 270 | SELECT marine_live.ident, marine_live.fammarine_id, marine_live.type_id, marine_live.type,marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
234 | 271 | FROM marine_live".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date"; |
235 | - if ($usecoord) $query .= " AND (marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong.")"; |
|
236 | - if ($id != '') $query .= " OR marine_live.fammarine_id = :id"; |
|
272 | + if ($usecoord) { |
|
273 | + $query .= " AND (marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong.")"; |
|
274 | + } |
|
275 | + if ($id != '') { |
|
276 | + $query .= " OR marine_live.fammarine_id = :id"; |
|
277 | + } |
|
237 | 278 | $query .= ") AS marine WHERE latitude <> '0' AND longitude <> '0' "; |
238 | 279 | $query .= "ORDER BY fammarine_id, date"; |
239 | - if ($limit) $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
280 | + if ($limit) { |
|
281 | + $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
282 | + } |
|
240 | 283 | } else { |
241 | 284 | $query = "SELECT marine_live.ident, marine_live.fammarine_id, marine_live.type_id, marine_live.type,marine_live.latitude, marine_live.longitude, marine_live.heading, marine_live.ground_speed, marine_live.date, marine_live.format_source, marine_live.captain_name, marine_live.race_id, marine_live.race_rank, marine_live.race_name |
242 | 285 | FROM marine_live".$filter_query." CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= marine_live.date "; |
243 | - if ($usecoord) $query .= "AND (marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong.") "; |
|
244 | - if ($id != '') $query .= "OR marine_live.fammarine_id = :id "; |
|
286 | + if ($usecoord) { |
|
287 | + $query .= "AND (marine_live.latitude BETWEEN ".$minlat." AND ".$maxlat." AND marine_live.longitude BETWEEN ".$minlong." AND ".$maxlong.") "; |
|
288 | + } |
|
289 | + if ($id != '') { |
|
290 | + $query .= "OR marine_live.fammarine_id = :id "; |
|
291 | + } |
|
245 | 292 | $query .= "AND marine_live.latitude <> '0' AND marine_live.longitude <> '0' |
246 | 293 | ORDER BY marine_live.fammarine_id, marine_live.date"; |
247 | - if ($limit) $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
294 | + if ($limit) { |
|
295 | + $query .= " LIMIT ".$globalMap3DMarinesLimit; |
|
296 | + } |
|
248 | 297 | } |
249 | 298 | } |
250 | 299 | $query_values = array(); |
251 | - if ($id != '') $query_values = array(':id' => $id); |
|
300 | + if ($id != '') { |
|
301 | + $query_values = array(':id' => $id); |
|
302 | + } |
|
252 | 303 | try { |
253 | 304 | $sth = $this->db->prepare($query); |
254 | 305 | $sth->execute($query_values); |
@@ -271,7 +322,9 @@ discard block |
||
271 | 322 | global $globalDBdriver, $globalLiveInterval; |
272 | 323 | $filter_query = $this->getFilter($filter,true,true); |
273 | 324 | |
274 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
325 | + if (!isset($globalLiveInterval)) { |
|
326 | + $globalLiveInterval = '200'; |
|
327 | + } |
|
275 | 328 | if ($globalDBdriver == 'mysql') { |
276 | 329 | $query = 'SELECT COUNT(DISTINCT marine_live.fammarine_id) as nb FROM marine_live'.$filter_query.' DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= date'; |
277 | 330 | } else { |
@@ -299,7 +352,9 @@ discard block |
||
299 | 352 | { |
300 | 353 | global $globalDBdriver, $globalLiveInterval; |
301 | 354 | $Marine = new Marine($this->db); |
302 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
355 | + if (!isset($globalLiveInterval)) { |
|
356 | + $globalLiveInterval = '200'; |
|
357 | + } |
|
303 | 358 | $filter_query = $this->getFilter($filter); |
304 | 359 | |
305 | 360 | if (is_array($coord)) { |
@@ -307,7 +362,9 @@ discard block |
||
307 | 362 | $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
308 | 363 | $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
309 | 364 | $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
310 | - } else return array(); |
|
365 | + } else { |
|
366 | + return array(); |
|
367 | + } |
|
311 | 368 | if ($globalDBdriver == 'mysql') { |
312 | 369 | $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 ORDER BY date DESC'.$filter_query; |
313 | 370 | } else { |
@@ -327,7 +384,9 @@ discard block |
||
327 | 384 | { |
328 | 385 | global $globalDBdriver, $globalLiveInterval, $globalArchive; |
329 | 386 | $Marine = new Marine($this->db); |
330 | - if (!isset($globalLiveInterval)) $globalLiveInterval = '200'; |
|
387 | + if (!isset($globalLiveInterval)) { |
|
388 | + $globalLiveInterval = '200'; |
|
389 | + } |
|
331 | 390 | $filter_query = $this->getFilter($filter,true,true); |
332 | 391 | |
333 | 392 | if (is_array($coord)) { |
@@ -335,7 +394,9 @@ discard block |
||
335 | 394 | $minlat = filter_var($coord[1],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
336 | 395 | $maxlong = filter_var($coord[2],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
337 | 396 | $maxlat = filter_var($coord[3],FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
338 | - } else return array(); |
|
397 | + } else { |
|
398 | + return array(); |
|
399 | + } |
|
339 | 400 | /* |
340 | 401 | if ($globalDBdriver == 'mysql') { |
341 | 402 | $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 |
@@ -558,11 +619,15 @@ discard block |
||
558 | 619 | //$query = self::$global_query.' WHERE marine_live.fammarine_id = :id ORDER BY date'; |
559 | 620 | if ($globalDBdriver == 'mysql') { |
560 | 621 | $query = 'SELECT marine_live.* FROM marine_live WHERE marine_live.fammarine_id = :id'; |
561 | - if ($liveinterval) $query .= ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= date'; |
|
622 | + if ($liveinterval) { |
|
623 | + $query .= ' AND DATE_SUB(UTC_TIMESTAMP(),INTERVAL '.$globalLiveInterval.' SECOND) <= date'; |
|
624 | + } |
|
562 | 625 | $query .= ' ORDER BY date'; |
563 | 626 | } else { |
564 | 627 | $query = 'SELECT marine_live.* FROM marine_live WHERE marine_live.fammarine_id = :id'; |
565 | - if ($liveinterval) $query .= " AND CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= date"; |
|
628 | + if ($liveinterval) { |
|
629 | + $query .= " AND CURRENT_TIMESTAMP AT TIME ZONE 'UTC' - INTERVAL '".$globalLiveInterval." SECONDS' <= date"; |
|
630 | + } |
|
566 | 631 | $query .= ' ORDER BY date'; |
567 | 632 | } |
568 | 633 | |
@@ -657,7 +722,9 @@ discard block |
||
657 | 722 | $i++; |
658 | 723 | $j++; |
659 | 724 | if ($j == 30) { |
660 | - if ($globalDebug) echo "."; |
|
725 | + if ($globalDebug) { |
|
726 | + echo "."; |
|
727 | + } |
|
661 | 728 | try { |
662 | 729 | |
663 | 730 | $sth = $this->db->prepare(substr($query_delete,0,-1).")"); |
@@ -951,7 +1018,9 @@ discard block |
||
951 | 1018 | { |
952 | 1019 | return false; |
953 | 1020 | } |
954 | - } else return ''; |
|
1021 | + } else { |
|
1022 | + return ''; |
|
1023 | + } |
|
955 | 1024 | |
956 | 1025 | if ($longitude != '') |
957 | 1026 | { |
@@ -959,7 +1028,9 @@ discard block |
||
959 | 1028 | { |
960 | 1029 | return false; |
961 | 1030 | } |
962 | - } else return ''; |
|
1031 | + } else { |
|
1032 | + return ''; |
|
1033 | + } |
|
963 | 1034 | |
964 | 1035 | |
965 | 1036 | if ($heading != '') |
@@ -968,7 +1039,9 @@ discard block |
||
968 | 1039 | { |
969 | 1040 | return false; |
970 | 1041 | } |
971 | - } else $heading = 0; |
|
1042 | + } else { |
|
1043 | + $heading = 0; |
|
1044 | + } |
|
972 | 1045 | |
973 | 1046 | if ($groundspeed != '') |
974 | 1047 | { |
@@ -976,9 +1049,13 @@ discard block |
||
976 | 1049 | { |
977 | 1050 | return false; |
978 | 1051 | } |
979 | - } else $groundspeed = 0; |
|
1052 | + } else { |
|
1053 | + $groundspeed = 0; |
|
1054 | + } |
|
980 | 1055 | date_default_timezone_set('UTC'); |
981 | - if ($date == '') $date = date("Y-m-d H:i:s", time()); |
|
1056 | + if ($date == '') { |
|
1057 | + $date = date("Y-m-d H:i:s", time()); |
|
1058 | + } |
|
982 | 1059 | |
983 | 1060 | |
984 | 1061 | $fammarine_id = filter_var($fammarine_id,FILTER_SANITIZE_STRING); |
@@ -1006,16 +1083,28 @@ discard block |
||
1006 | 1083 | $race_name = filter_var($race_name,FILTER_SANITIZE_STRING); |
1007 | 1084 | $race_rank = filter_var($race_rank,FILTER_SANITIZE_NUMBER_INT); |
1008 | 1085 | $race_time = filter_var($race_time,FILTER_SANITIZE_NUMBER_FLOAT,FILTER_FLAG_ALLOW_FRACTION); |
1009 | - if ($typeid == '') $typeid = NULL; |
|
1010 | - if ($statusid == '') $statusid = NULL; |
|
1011 | - if ($distance == '') $distance = NULL; |
|
1086 | + if ($typeid == '') { |
|
1087 | + $typeid = NULL; |
|
1088 | + } |
|
1089 | + if ($statusid == '') { |
|
1090 | + $statusid = NULL; |
|
1091 | + } |
|
1092 | + if ($distance == '') { |
|
1093 | + $distance = NULL; |
|
1094 | + } |
|
1012 | 1095 | |
1013 | 1096 | //if ($groundspeed == '' || $Common->isInteger($groundspeed) === false ) $groundspeed = 0; |
1014 | - if ($heading == '' || $Common->isInteger($heading) === false ) $heading = 0; |
|
1015 | - if ($arrival_date == '') $arrival_date = NULL; |
|
1097 | + if ($heading == '' || $Common->isInteger($heading) === false ) { |
|
1098 | + $heading = 0; |
|
1099 | + } |
|
1100 | + if ($arrival_date == '') { |
|
1101 | + $arrival_date = NULL; |
|
1102 | + } |
|
1016 | 1103 | $query = ''; |
1017 | 1104 | if ($globalArchive) { |
1018 | - if ($globalDebug) echo '-- Delete previous data -- '; |
|
1105 | + if ($globalDebug) { |
|
1106 | + echo '-- Delete previous data -- '; |
|
1107 | + } |
|
1019 | 1108 | $query .= 'DELETE FROM marine_live WHERE fammarine_id = :fammarine_id;'; |
1020 | 1109 | } |
1021 | 1110 | $query .= 'INSERT INTO marine_live (fammarine_id, ident, latitude, longitude, heading, ground_speed, date, format_source, source_name, over_country, mmsi, type,type_id,status,status_id,imo,arrival_port_name,arrival_port_date,captain_id,captain_name,race_id,race_name,distance,race_rank,race_time) |
@@ -1030,10 +1119,14 @@ discard block |
||
1030 | 1119 | } |
1031 | 1120 | |
1032 | 1121 | if (isset($globalArchive) && $globalArchive && $putinarchive && $noarchive !== true) { |
1033 | - if ($globalDebug) echo '(Add to Marine archive : '; |
|
1122 | + if ($globalDebug) { |
|
1123 | + echo '(Add to Marine archive : '; |
|
1124 | + } |
|
1034 | 1125 | $MarineArchive = new MarineArchive($this->db); |
1035 | 1126 | $result = $MarineArchive->addMarineArchiveData($fammarine_id, $ident, $latitude, $longitude, $heading, $groundspeed, $date, $putinarchive, $mmsi,$type,$typeid,$imo, $callsign,$arrival_code,$arrival_date,$status,$statusid,$noarchive,$format_source, $source_name, $over_country,$captain_id,$captain_name,$race_id,$race_name,$distance,$race_rank,$race_time); |
1036 | - if ($globalDebug) echo $result.')'; |
|
1127 | + if ($globalDebug) { |
|
1128 | + echo $result.')'; |
|
1129 | + } |
|
1037 | 1130 | } |
1038 | 1131 | return "success"; |
1039 | 1132 | } |
@@ -5,11 +5,18 @@ discard block |
||
5 | 5 | setcookie("MapFormat",'2d'); |
6 | 6 | |
7 | 7 | // Compressed GeoJson is used if true |
8 | -if (!isset($globalJsonCompress)) $compress = true; |
|
9 | -else $compress = $globalJsonCompress; |
|
10 | -if (isset($_COOKIE['MarineIconColor'])) $MarineIconColor = $_COOKIE['MarineIconColor']; |
|
11 | -elseif (isset($globalMarineIconColor)) $MarineIconColor = $globalMarineIconColor; |
|
12 | -else $MarineIconColor = '1a3151'; |
|
8 | +if (!isset($globalJsonCompress)) { |
|
9 | + $compress = true; |
|
10 | +} else { |
|
11 | + $compress = $globalJsonCompress; |
|
12 | +} |
|
13 | +if (isset($_COOKIE['MarineIconColor'])) { |
|
14 | + $MarineIconColor = $_COOKIE['MarineIconColor']; |
|
15 | +} elseif (isset($globalMarineIconColor)) { |
|
16 | + $MarineIconColor = $globalMarineIconColor; |
|
17 | +} else { |
|
18 | + $MarineIconColor = '1a3151'; |
|
19 | +} |
|
13 | 20 | |
14 | 21 | if (isset($globalVM) && $globalVM) { |
15 | 22 | ?> |
@@ -191,7 +198,12 @@ discard block |
||
191 | 198 | <?php |
192 | 199 | } else { |
193 | 200 | ?> |
194 | - var movingtime = Math.round(<?php if (isset($archiveupdatetime)) print $archiveupdatetime*1000; else print $globalMapRefresh*1000+20000; ?>+feature.properties.sqt*1000); |
|
201 | + var movingtime = Math.round(<?php if (isset($archiveupdatetime)) { |
|
202 | + print $archiveupdatetime*1000; |
|
203 | +} else { |
|
204 | + print $globalMapRefresh*1000+20000; |
|
205 | +} |
|
206 | +?>+feature.properties.sqt*1000); |
|
195 | 207 | return new L.Marker.movingMarker([latLng, feature.properties.nextlatlon],[movingtime],{ |
196 | 208 | <?php |
197 | 209 | } |
@@ -248,7 +260,12 @@ discard block |
||
248 | 260 | <?php |
249 | 261 | } else { |
250 | 262 | ?> |
251 | - var movingtime = Math.round(<?php if (isset($archiveupdatetime)) print $archiveupdatetime*1000; else print $globalMapRefresh*1000+20000; ?>+feature.properties.sqt*1000); |
|
263 | + var movingtime = Math.round(<?php if (isset($archiveupdatetime)) { |
|
264 | + print $archiveupdatetime*1000; |
|
265 | +} else { |
|
266 | + print $globalMapRefresh*1000+20000; |
|
267 | +} |
|
268 | +?>+feature.properties.sqt*1000); |
|
252 | 269 | return new L.Marker.movingMarker([latLng, feature.properties.nextlatlon],[movingtime],{ |
253 | 270 | <?php |
254 | 271 | } |
@@ -304,7 +321,12 @@ discard block |
||
304 | 321 | <?php |
305 | 322 | } else { |
306 | 323 | ?> |
307 | - var movingtime = Math.round(<?php if (isset($archiveupdatetime)) print $archiveupdatetime*1000; else print $globalMapRefresh*1000+20000; ?>+feature.properties.sqt*1000); |
|
324 | + var movingtime = Math.round(<?php if (isset($archiveupdatetime)) { |
|
325 | + print $archiveupdatetime*1000; |
|
326 | +} else { |
|
327 | + print $globalMapRefresh*1000+20000; |
|
328 | +} |
|
329 | +?>+feature.properties.sqt*1000); |
|
308 | 330 | return new L.Marker.movingMarker([latLng, feature.properties.nextlatlon],[movingtime],{ |
309 | 331 | <?php |
310 | 332 | } |
@@ -726,7 +748,12 @@ discard block |
||
726 | 748 | } else { |
727 | 749 | //then load it again every 30 seconds |
728 | 750 | reloadMarinePage = setInterval( |
729 | - function(){if (noTimeout) getLiveMarineData(0)},<?php if (isset($globalMapRefresh)) print $globalMapRefresh*1000; else print '30000'; ?>); |
|
751 | + function(){if (noTimeout) getLiveMarineData(0)},<?php if (isset($globalMapRefresh)) { |
|
752 | + print $globalMapRefresh*1000; |
|
753 | +} else { |
|
754 | + print '30000'; |
|
755 | +} |
|
756 | +?>); |
|
730 | 757 | } |
731 | 758 | |
732 | 759 | if (getCookie('openseamap') == 'true') loadOpenSeaMap(getCookie('openseamap')); |