Completed
Push — master ( cf0b6f...6e68de )
by Yannick
14:21 queued 01:24
created
require/class.SpotterImport.php 1 patch
Braces   +360 added lines, -127 removed lines patch added patch discarded remove patch
@@ -63,7 +63,9 @@  discard block
 block discarded – undo
63 63
 	$dbc = $this->db;
64 64
 	$this->all_flights[$id]['schedule_check'] = true;
65 65
 	if ($globalSchedulesFetch) {
66
-	if ($globalDebug) echo 'Getting schedule info...'."\n";
66
+	if ($globalDebug) {
67
+		echo 'Getting schedule info...'."\n";
68
+	}
67 69
 	$Spotter = new Spotter($dbc);
68 70
 	$Schedule = new Schedule($dbc);
69 71
 	$Translation = new Translation($dbc);
@@ -74,7 +76,9 @@  discard block
 block discarded – undo
74 76
 	    if ($Schedule->checkSchedule($operator) == 0) {
75 77
 		$schedule = $Schedule->fetchSchedule($operator);
76 78
 		if (count($schedule) > 0 && isset($schedule['DepartureTime']) && isset($schedule['ArrivalTime'])) {
77
-		    if ($globalDebug) echo "-> Schedule info for ".$operator." (".$ident.")\n";
79
+		    if ($globalDebug) {
80
+		    	echo "-> Schedule info for ".$operator." (".$ident.")\n";
81
+		    }
78 82
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('departure_airport_time' => $schedule['DepartureTime']));
79 83
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('arrival_airport_time' => $schedule['ArrivalTime']));
80 84
 		    // Should also check if route schedule = route from DB
@@ -83,7 +87,9 @@  discard block
 block discarded – undo
83 87
 			    $airport_icao = $Spotter->getAirportIcao($schedule['DepartureAirportIATA']);
84 88
 			    if (trim($airport_icao) != '') {
85 89
 				$this->all_flights[$id]['departure_airport'] = $airport_icao;
86
-				if ($globalDebug) echo "-> Change departure airport to ".$airport_icao." for ".$ident."\n";
90
+				if ($globalDebug) {
91
+					echo "-> Change departure airport to ".$airport_icao." for ".$ident."\n";
92
+				}
87 93
 			    }
88 94
 			}
89 95
 		    }
@@ -92,17 +98,25 @@  discard block
 block discarded – undo
92 98
 			    $airport_icao = $Spotter->getAirportIcao($schedule['ArrivalAirportIATA']);
93 99
 			    if (trim($airport_icao) != '') {
94 100
 				$this->all_flights[$id]['arrival_airport'] = $airport_icao;
95
-				if ($globalDebug) echo "-> Change arrival airport to ".$airport_icao." for ".$ident."\n";
101
+				if ($globalDebug) {
102
+					echo "-> Change arrival airport to ".$airport_icao." for ".$ident."\n";
103
+				}
96 104
 			    }
97 105
 			}
98 106
 		    }
99 107
 		    $Schedule->addSchedule($operator,$this->all_flights[$id]['departure_airport'],$this->all_flights[$id]['departure_airport_time'],$this->all_flights[$id]['arrival_airport'],$this->all_flights[$id]['arrival_airport_time'],$schedule['Source']);
100 108
 		}
101
-	    } else $scheduleexist = true;
102
-	} else $scheduleexist = true;
109
+	    } else {
110
+	    	$scheduleexist = true;
111
+	    }
112
+	} else {
113
+		$scheduleexist = true;
114
+	}
103 115
 	// close connection, at least one way will work ?
104 116
        if ($scheduleexist) {
105
-		if ($globalDebug) echo "-> get arrival/departure airport info for ".$ident."\n";
117
+		if ($globalDebug) {
118
+			echo "-> get arrival/departure airport info for ".$ident."\n";
119
+		}
106 120
     		$sch = $Schedule->getSchedule($operator);
107 121
 		$this->all_flights[$id] = array_merge($this->all_flights[$id],array('arrival_airport' => $sch['arrival_airport_icao'],'departure_airport' => $sch['departure_airport_icao'],'departure_airport_time' => $sch['departure_airport_time'],'arrival_airport_time' => $sch['arrival_airport_time']));
108 122
        }
@@ -124,14 +138,18 @@  discard block
 block discarded – undo
124 138
 
125 139
     public function checkAll() {
126 140
 	global $globalDebug, $globalNoImport;
127
-	if ($globalDebug) echo "Update last seen flights data...\n";
141
+	if ($globalDebug) {
142
+		echo "Update last seen flights data...\n";
143
+	}
128 144
 	if (!isset($globalNoImport) || $globalNoImport === FALSE) {
129 145
 	    foreach ($this->all_flights as $key => $flight) {
130 146
 		if (isset($this->all_flights[$key]['id'])) {
131 147
 		    //echo $this->all_flights[$key]['id'].' - '.$this->all_flights[$key]['latitude'].'  '.$this->all_flights[$key]['longitude']."\n";
132 148
     		    $Spotter = new Spotter($this->db);
133 149
         	    $real_arrival = $this->arrival($key);
134
-        	    if (isset($this->all_flights[$key]['altitude'])) $Spotter->updateLatestSpotterData($this->all_flights[$key]['id'],$this->all_flights[$key]['ident'],$this->all_flights[$key]['latitude'],$this->all_flights[$key]['longitude'],$this->all_flights[$key]['altitude'],$this->all_flights[$key]['ground'],$this->all_flights[$key]['speed'],$this->all_flights[$key]['datetime'],$real_arrival['airport_icao'],$real_arrival['airport_time']);
150
+        	    if (isset($this->all_flights[$key]['altitude'])) {
151
+        	    	$Spotter->updateLatestSpotterData($this->all_flights[$key]['id'],$this->all_flights[$key]['ident'],$this->all_flights[$key]['latitude'],$this->all_flights[$key]['longitude'],$this->all_flights[$key]['altitude'],$this->all_flights[$key]['ground'],$this->all_flights[$key]['speed'],$this->all_flights[$key]['datetime'],$real_arrival['airport_icao'],$real_arrival['airport_time']);
152
+        	    }
135 153
         	}
136 154
 	    }
137 155
 	}
@@ -139,24 +157,32 @@  discard block
 block discarded – undo
139 157
 
140 158
     public function arrival($key) {
141 159
 	global $globalClosestMinDist, $globalDebug;
142
-	if ($globalDebug) echo 'Update arrival...'."\n";
160
+	if ($globalDebug) {
161
+		echo 'Update arrival...'."\n";
162
+	}
143 163
 	$Spotter = new Spotter($this->db);
144 164
         $airport_icao = '';
145 165
         $airport_time = '';
146
-        if (!isset($globalClosestMinDist) || $globalClosestMinDist == '') $globalClosestMinDist = 50;
166
+        if (!isset($globalClosestMinDist) || $globalClosestMinDist == '') {
167
+        	$globalClosestMinDist = 50;
168
+        }
147 169
 	if ($this->all_flights[$key]['latitude'] != '' && $this->all_flights[$key]['longitude'] != '') {
148 170
 	    $closestAirports = $Spotter->closestAirports($this->all_flights[$key]['latitude'],$this->all_flights[$key]['longitude'],$globalClosestMinDist);
149 171
     	    if (isset($closestAirports[0])) {
150 172
         	if (isset($this->all_flights[$key]['arrival_airport']) && $this->all_flights[$key]['arrival_airport'] == $closestAirports[0]['icao']) {
151 173
         	    $airport_icao = $closestAirports[0]['icao'];
152 174
         	    $airport_time = $this->all_flights[$key]['datetime'];
153
-        	    if ($globalDebug) echo "---++ Find arrival airport. airport_icao : ".$airport_icao."\n";
175
+        	    if ($globalDebug) {
176
+        	    	echo "---++ Find arrival airport. airport_icao : ".$airport_icao."\n";
177
+        	    }
154 178
         	} elseif (count($closestAirports > 1) && isset($this->all_flights[$key]['arrival_airport']) && $this->all_flights[$key]['arrival_airport'] != '') {
155 179
         	    foreach ($closestAirports as $airport) {
156 180
         		if ($this->all_flights[$key]['arrival_airport'] == $airport['icao']) {
157 181
         		    $airport_icao = $airport['icao'];
158 182
         		    $airport_time = $this->all_flights[$key]['datetime'];
159
-        		    if ($globalDebug) echo "---++ Find arrival airport. airport_icao : ".$airport_icao."\n";
183
+        		    if ($globalDebug) {
184
+        		    	echo "---++ Find arrival airport. airport_icao : ".$airport_icao."\n";
185
+        		    }
160 186
         		    break;
161 187
         		}
162 188
         	    }
@@ -164,14 +190,20 @@  discard block
 block discarded – undo
164 190
         		$airport_icao = $closestAirports[0]['icao'];
165 191
         		$airport_time = $this->all_flights[$key]['datetime'];
166 192
         	} else {
167
-        		if ($globalDebug) echo "----- Can't find arrival airport. Airport altitude : ".$closestAirports[0]['altitude'].' - flight altitude : '.$this->all_flights[$key]['altitude_real']."\n";
193
+        		if ($globalDebug) {
194
+        			echo "----- Can't find arrival airport. Airport altitude : ".$closestAirports[0]['altitude'].' - flight altitude : '.$this->all_flights[$key]['altitude_real']."\n";
195
+        		}
168 196
         	}
169 197
     	    } else {
170
-    		    if ($globalDebug) echo "----- No Airport near last coord. Latitude : ".$this->all_flights[$key]['latitude'].' - Longitude : '.$this->all_flights[$key]['longitude'].' - MinDist : '.$globalClosestMinDist."\n";
198
+    		    if ($globalDebug) {
199
+    		    	echo "----- No Airport near last coord. Latitude : ".$this->all_flights[$key]['latitude'].' - Longitude : '.$this->all_flights[$key]['longitude'].' - MinDist : '.$globalClosestMinDist."\n";
200
+    		    }
171 201
     	    }
172 202
 
173 203
         } else {
174
-        	if ($globalDebug) echo "---- No latitude or longitude. Ident : ".$this->all_flights[$key]['ident']."\n";
204
+        	if ($globalDebug) {
205
+        		echo "---- No latitude or longitude. Ident : ".$this->all_flights[$key]['ident']."\n";
206
+        	}
175 207
         }
176 208
         return array('airport_icao' => $airport_icao,'airport_time' => $airport_time);
177 209
     }
@@ -181,12 +213,16 @@  discard block
 block discarded – undo
181 213
     public function del() {
182 214
 	global $globalDebug, $globalNoImport, $globalNoDB;
183 215
 	// Delete old infos
184
-	if ($globalDebug) echo 'Delete old values and update latest data...'."\n";
216
+	if ($globalDebug) {
217
+		echo 'Delete old values and update latest data...'."\n";
218
+	}
185 219
 	foreach ($this->all_flights as $key => $flight) {
186 220
     	    if (isset($flight['lastupdate'])) {
187 221
         	if ($flight['lastupdate'] < (time()-3000)) {
188 222
             	    if (isset($this->all_flights[$key]['id'])) {
189
-            		if ($globalDebug) echo "--- Delete old values with id ".$this->all_flights[$key]['id']."\n";
223
+            		if ($globalDebug) {
224
+            			echo "--- Delete old values with id ".$this->all_flights[$key]['id']."\n";
225
+            		}
190 226
 			/*
191 227
 			$SpotterLive = new SpotterLive();
192 228
             		$SpotterLive->deleteLiveSpotterDataById($this->all_flights[$key]['id']);
@@ -197,7 +233,9 @@  discard block
 block discarded – undo
197 233
             		    $Spotter = new Spotter($this->db);
198 234
             	    	    if ($this->all_flights[$key]['latitude'] != '' && $this->all_flights[$key]['longitude'] != '') {
199 235
 				$result = $Spotter->updateLatestSpotterData($this->all_flights[$key]['id'],$this->all_flights[$key]['ident'],$this->all_flights[$key]['latitude'],$this->all_flights[$key]['longitude'],$this->all_flights[$key]['altitude'],$this->all_flights[$key]['ground'],$this->all_flights[$key]['speed'],$this->all_flights[$key]['datetime'],$real_arrival['airport_icao'],$real_arrival['airport_time']);
200
-				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
236
+				if ($globalDebug && $result != 'success') {
237
+					echo '!!! ERROR : '.$result."\n";
238
+				}
201 239
 			    }
202 240
 			// Put in archive
203 241
 //				$Spotter->db = null;
@@ -212,8 +250,10 @@  discard block
 block discarded – undo
212 250
     public function add($line) {
213 251
 	global $globalPilotIdAccept, $globalAirportAccept, $globalAirlineAccept, $globalAirlineIgnore, $globalAirportIgnore, $globalFork, $globalDistanceIgnore, $globalDaemon, $globalSBS1update, $globalDebug, $globalIVAO, $globalVATSIM, $globalphpVMS, $globalCoordMinChange, $globalDebugTimeElapsed, $globalCenterLatitude, $globalCenterLongitude, $globalBeta, $globalSourcesupdate, $globalAirlinesSource, $globalVAM, $globalAllFlights, $globalServerAPRS, $APRSSpotter, $globalNoImport, $globalNoDB, $globalVA;
214 252
 	//if (!isset($globalDebugTimeElapsed) || $globalDebugTimeElapsed == '') $globalDebugTimeElapsed = FALSE;
215
-	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') $globalCoordMinChange = '0.02';
216
-/*
253
+	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') {
254
+		$globalCoordMinChange = '0.02';
255
+	}
256
+	/*
217 257
 	$Spotter = new Spotter();
218 258
 	$dbc = $Spotter->db;
219 259
 	$SpotterLive = new SpotterLive($dbc);
@@ -240,13 +280,20 @@  discard block
 block discarded – undo
240 280
 		// Increment message number
241 281
 		if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE) {
242 282
 		    $current_date = date('Y-m-d');
243
-		    if (isset($line['source_name'])) $source = $line['source_name'];
244
-		    else $source = '';
245
-		    if ($source == '' || $line['format_source'] == 'aprs') $source = $line['format_source'];
283
+		    if (isset($line['source_name'])) {
284
+		    	$source = $line['source_name'];
285
+		    } else {
286
+		    	$source = '';
287
+		    }
288
+		    if ($source == '' || $line['format_source'] == 'aprs') {
289
+		    	$source = $line['format_source'];
290
+		    }
246 291
 		    if (!isset($this->stats[$current_date][$source]['msg'])) {
247 292
 		    	$this->stats[$current_date][$source]['msg']['date'] = time();
248 293
 		    	$this->stats[$current_date][$source]['msg']['nb'] = 1;
249
-		    } else $this->stats[$current_date][$source]['msg']['nb'] += 1;
294
+		    } else {
295
+		    	$this->stats[$current_date][$source]['msg']['nb'] += 1;
296
+		    }
250 297
 		}
251 298
 		
252 299
 		/*
@@ -262,22 +309,35 @@  discard block
 block discarded – undo
262 309
 		//$this->db = $dbc;
263 310
 
264 311
 		//$hex = trim($line['hex']);
265
-	        if (!isset($line['id'])) $id = trim($line['hex']);
266
-	        else $id = trim($line['id']);
312
+	        if (!isset($line['id'])) {
313
+	        	$id = trim($line['hex']);
314
+	        } else {
315
+	        	$id = trim($line['id']);
316
+	        }
267 317
 		
268 318
 		if (!isset($this->all_flights[$id])) {
269 319
 		    $this->all_flights[$id] = array();
270 320
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('addedSpotter' => 0));
271 321
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('ident' => '','departure_airport' => '', 'arrival_airport' => '','latitude' => '', 'longitude' => '', 'speed' => '', 'altitude' => '','altitude_real' => '', 'heading' => '','departure_airport_time' => '','arrival_airport_time' => '','squawk' => '','route_stop' => '','registration' => '','pilot_id' => '','pilot_name' => '','waypoints' => '','ground' => '0', 'format_source' => '','source_name' => '','over_country' => '','verticalrate' => '','noarchive' => false,'putinarchive' => true,'source_type' => ''));
272
-		    if (isset($globalDaemon) && $globalDaemon === FALSE) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('lastupdate' => time()));
322
+		    if (isset($globalDaemon) && $globalDaemon === FALSE) {
323
+		    	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('lastupdate' => time()));
324
+		    }
273 325
 		    if (!isset($line['id'])) {
274
-			if (!isset($globalDaemon)) $globalDaemon = TRUE;
275
-//			if (isset($line['format_source']) && ($line['format_source'] == 'sbs' || $line['format_source'] == 'tsv' || $line['format_source'] == 'raw') && $globalDaemon) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident'].'-'.date('YmdGi')));
326
+			if (!isset($globalDaemon)) {
327
+				$globalDaemon = TRUE;
328
+			}
329
+			//			if (isset($line['format_source']) && ($line['format_source'] == 'sbs' || $line['format_source'] == 'tsv' || $line['format_source'] == 'raw') && $globalDaemon) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident'].'-'.date('YmdGi')));
276 330
 //			if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw' || $line['format_source'] === 'deltadbtxt' || $line['format_source'] === 'planeupdatefaa' || $line['format_source'] === 'aprs') && $globalDaemon) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdHi')));
277
-			if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw' || $line['format_source'] === 'deltadbtxt' || $line['format_source'] === 'planeupdatefaa' || $line['format_source'] === 'aprs' || $line['format_source'] === 'aircraftlistjson' || $line['format_source'] === 'radarvirtueljson' || $line['format_source'] === 'famaprs')) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $id.'-'.date('YmdHi')));
331
+			if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw' || $line['format_source'] === 'deltadbtxt' || $line['format_source'] === 'planeupdatefaa' || $line['format_source'] === 'aprs' || $line['format_source'] === 'aircraftlistjson' || $line['format_source'] === 'radarvirtueljson' || $line['format_source'] === 'famaprs')) {
332
+				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $id.'-'.date('YmdHi')));
333
+			}
278 334
 		        //else $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
279
-		     } else $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $line['id']));
280
-		    if ($globalAllFlights !== FALSE) $dataFound = true;
335
+		     } else {
336
+		     	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $line['id']));
337
+		     }
338
+		    if ($globalAllFlights !== FALSE) {
339
+		    	$dataFound = true;
340
+		    }
281 341
 		}
282 342
 		if (isset($line['source_type']) && $line['source_type'] != '') {
283 343
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('source_type' => $line['source_type']));
@@ -299,17 +359,27 @@  discard block
 block discarded – undo
299 359
 				$aircraft_icao = $Spotter->getAllAircraftType(trim($line['hex']));
300 360
 			    }
301 361
 			    $Spotter->db = null;
302
-			    if ($globalDebugTimeElapsed) echo 'Time elapsed for update getallaircrattype : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
303
-			    if ($aircraft_icao != '') $this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
362
+			    if ($globalDebugTimeElapsed) {
363
+			    	echo 'Time elapsed for update getallaircrattype : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
364
+			    }
365
+			    if ($aircraft_icao != '') {
366
+			    	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
367
+			    }
304 368
 			}
305 369
 		    }
306
-		    if ($globalAllFlights !== FALSE) $dataFound = true;
307
-		    if ($globalDebug) echo "*********** New aircraft hex : ".$line['hex']." ***********\n";
370
+		    if ($globalAllFlights !== FALSE) {
371
+		    	$dataFound = true;
372
+		    }
373
+		    if ($globalDebug) {
374
+		    	echo "*********** New aircraft hex : ".$line['hex']." ***********\n";
375
+		    }
308 376
 		}
309 377
 		if (isset($line['aircraft_icao']) && $line['aircraft_icao'] != '') {
310 378
 			$icao = $line['aircraft_icao'];
311 379
 			$Spotter = new Spotter($this->db);
312
-			if (isset($Spotter->aircraft_correct_icaotype[$icao])) $icao = $Spotter->aircraft_correct_icaotype[$icao];
380
+			if (isset($Spotter->aircraft_correct_icaotype[$icao])) {
381
+				$icao = $Spotter->aircraft_correct_icaotype[$icao];
382
+			}
313 383
 			$Spotter->db = null;
314 384
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $icao));
315 385
 		}
@@ -319,15 +389,24 @@  discard block
 block discarded – undo
319 389
 				$Spotter = new Spotter($this->db);
320 390
 				$aircraft_icao = $Spotter->getAircraftIcao($line['aircraft_name']);
321 391
 				$Spotter->db = null;
322
-				if ($aircraft_icao != '') $this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
392
+				if ($aircraft_icao != '') {
393
+					$this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
394
+				}
323 395
 			}
324 396
 		}
325 397
 		if (!isset($this->all_flights[$id]['aircraft_icao']) && isset($line['aircraft_type'])) {
326
-			if ($line['aircraft_type'] == 'PARA_GLIDER') $aircraft_icao = 'GLID';
327
-			elseif ($line['aircraft_type'] == 'HELICOPTER_ROTORCRAFT') $aircraft_icao = 'UHEL';
328
-			elseif ($line['aircraft_type'] == 'TOW_PLANE') $aircraft_icao = 'TOWPLANE';
329
-			elseif ($line['aircraft_type'] == 'POWERED_AIRCRAFT') $aircraft_icao = 'POWAIRC';
330
-			if (isset($aircraft_icao)) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
398
+			if ($line['aircraft_type'] == 'PARA_GLIDER') {
399
+				$aircraft_icao = 'GLID';
400
+			} elseif ($line['aircraft_type'] == 'HELICOPTER_ROTORCRAFT') {
401
+				$aircraft_icao = 'UHEL';
402
+			} elseif ($line['aircraft_type'] == 'TOW_PLANE') {
403
+				$aircraft_icao = 'TOWPLANE';
404
+			} elseif ($line['aircraft_type'] == 'POWERED_AIRCRAFT') {
405
+				$aircraft_icao = 'POWAIRC';
406
+			}
407
+			if (isset($aircraft_icao)) {
408
+				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => $aircraft_icao));
409
+			}
331 410
 		}
332 411
 		if (!isset($this->all_flights[$id]['aircraft_icao'])) {
333 412
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('aircraft_icao' => 'NA'));
@@ -337,8 +416,11 @@  discard block
 block discarded – undo
337 416
 		    if (!isset($this->all_flights[$id]['datetime']) || strtotime($line['datetime']) >= strtotime($this->all_flights[$id]['datetime'])) {
338 417
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('datetime' => $line['datetime']));
339 418
 		    } else {
340
-				if (strtotime($line['datetime']) == strtotime($this->all_flights[$id]['datetime']) && $globalDebug) echo "!!! Date is the same as previous data for ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."\n";
341
-				elseif (strtotime($line['datetime']) > strtotime($this->all_flights[$id]['datetime']) && $globalDebug) echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_flights[$id]['datetime'].") !!! for ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."\n";
419
+				if (strtotime($line['datetime']) == strtotime($this->all_flights[$id]['datetime']) && $globalDebug) {
420
+					echo "!!! Date is the same as previous data for ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."\n";
421
+				} elseif (strtotime($line['datetime']) > strtotime($this->all_flights[$id]['datetime']) && $globalDebug) {
422
+					echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_flights[$id]['datetime'].") !!! for ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."\n";
423
+				}
342 424
 				/*
343 425
 				echo strtotime($line['datetime']).' > '.strtotime($this->all_flights[$id]['datetime']);
344 426
 				print_r($this->all_flights[$id]);
@@ -347,16 +429,22 @@  discard block
 block discarded – undo
347 429
 				return '';
348 430
 		    }
349 431
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) < time()-20*60) {
350
-			if ($globalDebug) echo "!!! Date is too old ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
432
+			if ($globalDebug) {
433
+				echo "!!! Date is too old ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
434
+			}
351 435
 			return '';
352 436
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) > time()+20*60) {
353
-			if ($globalDebug) echo "!!! Date is in the future ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
437
+			if ($globalDebug) {
438
+				echo "!!! Date is in the future ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
439
+			}
354 440
 			return '';
355 441
 		} elseif (!isset($line['datetime'])) {
356 442
 			date_default_timezone_set('UTC');
357 443
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('datetime' => date('Y-m-d H:i:s')));
358 444
 		} else {
359
-			if ($globalDebug) echo "!!! Unknow date error ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
445
+			if ($globalDebug) {
446
+				echo "!!! Unknow date error ".$this->all_flights[$id]['hex']." - format : ".$line['format_source']."!!!";
447
+			}
360 448
 			return '';
361 449
 		}
362 450
 
@@ -380,15 +468,25 @@  discard block
 block discarded – undo
380 468
 			    $timeelapsed = microtime(true);
381 469
             		    $Spotter = new Spotter($this->db);
382 470
             		    $fromsource = NULL;
383
-            		    if (isset($globalAirlinesSource) && $globalAirlinesSource != '') $fromsource = $globalAirlinesSource;
384
-            		    elseif (isset($line['format_source']) && $line['format_source'] == 'vatsimtxt') $fromsource = 'vatsim';
385
-			    elseif (isset($line['format_source']) && $line['format_source'] == 'whazzup') $fromsource = 'ivao';
386
-			    elseif (isset($globalVATSIM) && $globalVATSIM) $fromsource = 'vatsim';
387
-			    elseif (isset($globalIVAO) && $globalIVAO) $fromsource = 'ivao';
471
+            		    if (isset($globalAirlinesSource) && $globalAirlinesSource != '') {
472
+            		    	$fromsource = $globalAirlinesSource;
473
+            		    } elseif (isset($line['format_source']) && $line['format_source'] == 'vatsimtxt') {
474
+            		    	$fromsource = 'vatsim';
475
+            		    } elseif (isset($line['format_source']) && $line['format_source'] == 'whazzup') {
476
+			    	$fromsource = 'ivao';
477
+			    } elseif (isset($globalVATSIM) && $globalVATSIM) {
478
+			    	$fromsource = 'vatsim';
479
+			    } elseif (isset($globalIVAO) && $globalIVAO) {
480
+			    	$fromsource = 'ivao';
481
+			    }
388 482
             		    $result = $Spotter->updateIdentSpotterData($this->all_flights[$id]['id'],$this->all_flights[$id]['ident'],$fromsource);
389
-			    if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
483
+			    if ($globalDebug && $result != 'success') {
484
+			    	echo '!!! ERROR : '.$result."\n";
485
+			    }
390 486
 			    $Spotter->db = null;
391
-			    if ($globalDebugTimeElapsed) echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
487
+			    if ($globalDebugTimeElapsed) {
488
+			    	echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
489
+			    }
392 490
 			}
393 491
 		    }
394 492
 
@@ -400,7 +498,9 @@  discard block
 block discarded – undo
400 498
 		        else $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
401 499
 		     } else $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $line['id']));
402 500
   */
403
-		    if (!isset($this->all_flights[$id]['id'])) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
501
+		    if (!isset($this->all_flights[$id]['id'])) {
502
+		    	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
503
+		    }
404 504
 
405 505
 		    //$putinarchive = true;
406 506
 		    if (isset($line['departure_airport_time']) && $line['departure_airport_time'] != 0) {
@@ -418,7 +518,9 @@  discard block
 block discarded – undo
418 518
 				$line['departure_airport_icao'] = $Spotter->getAirportIcao($line['departure_airport_iata']);
419 519
 				$line['arrival_airport_icao'] = $Spotter->getAirportIcao($line['arrival_airport_iata']);
420 520
 		    		$this->all_flights[$id] = array_merge($this->all_flights[$id],array('departure_airport' => $line['departure_airport_icao'],'arrival_airport' => $line['arrival_airport_icao'],'route_stop' => ''));
421
-				if ($globalDebugTimeElapsed) echo 'Time elapsed for update getAirportICAO : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
521
+				if ($globalDebugTimeElapsed) {
522
+					echo 'Time elapsed for update getAirportICAO : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
523
+				}
422 524
                         }
423 525
 		    } elseif (!isset($line['format_source']) || $line['format_source'] != 'aprs') {
424 526
 			$timeelapsed = microtime(true);
@@ -432,7 +534,9 @@  discard block
 block discarded – undo
432 534
 				$Translation->db = null;
433 535
 			    }
434 536
 			    $Spotter->db = null;
435
-			    if ($globalDebugTimeElapsed) echo 'Time elapsed for update getrouteinfo : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
537
+			    if ($globalDebugTimeElapsed) {
538
+			    	echo 'Time elapsed for update getrouteinfo : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
539
+			    }
436 540
                     	}
437 541
 			if (isset($route['fromairport_icao']) && isset($route['toairport_icao'])) {
438 542
 			    //if ($route['FromAirport_ICAO'] != $route['ToAirport_ICAO']) {
@@ -441,9 +545,13 @@  discard block
 block discarded – undo
441 545
 		    		$this->all_flights[$id] = array_merge($this->all_flights[$id],array('departure_airport' => $route['fromairport_icao'],'arrival_airport' => $route['toairport_icao'],'route_stop' => $route['routestop']));
442 546
 		    	    }
443 547
 			}
444
-			if (!isset($globalFork)) $globalFork = TRUE;
548
+			if (!isset($globalFork)) {
549
+				$globalFork = TRUE;
550
+			}
445 551
 			if (!$globalVA && !$globalIVAO && !$globalVATSIM && !$globalphpVMS && !$globalVAM && (!isset($line['format_source']) || $line['format_source'] != 'aprs')) {
446
-				if (!isset($this->all_flights[$id]['schedule_check']) || $this->all_flights[$id]['schedule_check'] === false) $this->get_Schedule($id,trim($line['ident']));
552
+				if (!isset($this->all_flights[$id]['schedule_check']) || $this->all_flights[$id]['schedule_check'] === false) {
553
+					$this->get_Schedule($id,trim($line['ident']));
554
+				}
447 555
 			}
448 556
 		    }
449 557
 		}
@@ -459,16 +567,23 @@  discard block
 block discarded – undo
459 567
 		    // use datetime
460 568
 			$speed = $distance/(time() - $this->all_flights[$id]['time_last_coord']);
461 569
 			$speed = $speed*3.6;
462
-			if ($speed < 1000) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('speed' => round($speed)));
463
-  			if ($globalDebug) echo "ø Calculated Speed for ".$this->all_flights[$id]['hex']." : ".round($speed)." - distance : ".$distance."\n";
570
+			if ($speed < 1000) {
571
+				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('speed' => round($speed)));
572
+			}
573
+  			if ($globalDebug) {
574
+  				echo "ø Calculated Speed for ".$this->all_flights[$id]['hex']." : ".round($speed)." - distance : ".$distance."\n";
575
+  			}
464 576
 		    }
465 577
 		}
466 578
 
467 579
 
468 580
 
469 581
 	        if (isset($line['latitude']) && isset($line['longitude']) && $line['latitude'] != '' && $line['longitude'] != '' && is_numeric($line['latitude']) && is_numeric($line['longitude']) && !is_int($line['latitude']) && !is_int($line['longitude'])) {
470
-	    	    if (isset($this->all_flights[$id]['time_last_coord'])) $timediff = round(time()-$this->all_flights[$id]['time_last_coord']);
471
-	    	    else unset($timediff);
582
+	    	    if (isset($this->all_flights[$id]['time_last_coord'])) {
583
+	    	    	$timediff = round(time()-$this->all_flights[$id]['time_last_coord']);
584
+	    	    } else {
585
+	    	    	unset($timediff);
586
+	    	    }
472 587
 	    	    if ($this->tmd > 5 || (isset($globalVA) && $globalVA) || (isset($globalIVAO) && $globalIVAO) || (isset($globalVATSIM) && $globalVATSIM) || (isset($globalphpVMS) && $globalphpVMS) || (isset($globalVAM) && $globalVAM) || !isset($timediff) || $timediff > 2000 || ($timediff > 30 && isset($this->all_flights[$id]['latitude']) && isset($this->all_flights[$id]['longitude']) && $Common->withinThreshold($timediff,$Common->distance($line['latitude'],$line['longitude'],$this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude'],'m')))) {
473 588
 			if (isset($this->all_flights[$id]['archive_latitude']) && isset($this->all_flights[$id]['archive_longitude']) && isset($this->all_flights[$id]['livedb_latitude']) && isset($this->all_flights[$id]['livedb_longitude'])) {
474 589
 			    if (!$Common->checkLine($this->all_flights[$id]['archive_latitude'],$this->all_flights[$id]['archive_longitude'],$this->all_flights[$id]['livedb_latitude'],$this->all_flights[$id]['livedb_longitude'],$line['latitude'],$line['longitude'])) {
@@ -477,15 +592,23 @@  discard block
 block discarded – undo
477 592
 				$this->all_flights[$id]['putinarchive'] = true;
478 593
 				$this->tmd = 0;
479 594
 				if (!isset($globalNoImport) || $globalNoImport === FALSE) {
480
-				    if ($globalDebug) echo "\n".' ------- Check Country for '.$this->all_flights[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
595
+				    if ($globalDebug) {
596
+				    	echo "\n".' ------- Check Country for '.$this->all_flights[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
597
+				    }
481 598
 				    $timeelapsed = microtime(true);
482 599
 				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
483 600
 					$Spotter = new Spotter($this->db);
484 601
 					$all_country = $Spotter->getCountryFromLatitudeLongitude($line['latitude'],$line['longitude']);
485
-					if (!empty($all_country)) $this->all_flights[$id]['over_country'] = $all_country['iso2'];
602
+					if (!empty($all_country)) {
603
+						$this->all_flights[$id]['over_country'] = $all_country['iso2'];
604
+					}
486 605
 					$Spotter->db = null;
487
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
488
-					if ($globalDebug) echo 'FOUND : '.$this->all_flights[$id]['over_country'].' ---------------'."\n";
606
+					if ($globalDebugTimeElapsed) {
607
+						echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
608
+					}
609
+					if ($globalDebug) {
610
+						echo 'FOUND : '.$this->all_flights[$id]['over_country'].' ---------------'."\n";
611
+					}
489 612
 				    }
490 613
 				}
491 614
 			    }
@@ -493,7 +616,9 @@  discard block
 block discarded – undo
493 616
 
494 617
 			if (isset($line['latitude']) && $line['latitude'] != '' && $line['latitude'] != 0 && $line['latitude'] < 91 && $line['latitude'] > -90) {
495 618
 			    //if (!isset($this->all_flights[$id]['latitude']) || $this->all_flights[$id]['latitude'] == '' || abs($this->all_flights[$id]['latitude']-$line['latitude']) < 3 || $line['format_source'] != 'sbs' || time() - $this->all_flights[$id]['lastupdate'] > 30) {
496
-				if (!isset($this->all_flights[$id]['archive_latitude'])) $this->all_flights[$id]['archive_latitude'] = $line['latitude'];
619
+				if (!isset($this->all_flights[$id]['archive_latitude'])) {
620
+					$this->all_flights[$id]['archive_latitude'] = $line['latitude'];
621
+				}
497 622
 				if (!isset($this->all_flights[$id]['livedb_latitude']) || abs($this->all_flights[$id]['livedb_latitude']-$line['latitude']) > $globalCoordMinChange || $this->all_flights[$id]['format_source'] == 'aprs') {
498 623
 				    $this->all_flights[$id]['livedb_latitude'] = $line['latitude'];
499 624
 				    $dataFound = true;
@@ -515,9 +640,13 @@  discard block
 block discarded – undo
515 640
 			    */
516 641
 			}
517 642
 			if (isset($line['longitude']) && $line['longitude'] != '' && $line['longitude'] != 0 && $line['longitude'] < 360 && $line['longitude'] > -180) {
518
-			    if ($line['longitude'] > 180) $line['longitude'] = $line['longitude'] - 360;
643
+			    if ($line['longitude'] > 180) {
644
+			    	$line['longitude'] = $line['longitude'] - 360;
645
+			    }
519 646
 			    //if (!isset($this->all_flights[$id]['longitude']) || $this->all_flights[$id]['longitude'] == ''  || abs($this->all_flights[$id]['longitude']-$line['longitude']) < 2 || $line['format_source'] != 'sbs' || time() - $this->all_flights[$id]['lastupdate'] > 30) {
520
-				if (!isset($this->all_flights[$id]['archive_longitude'])) $this->all_flights[$id]['archive_longitude'] = $line['longitude'];
647
+				if (!isset($this->all_flights[$id]['archive_longitude'])) {
648
+					$this->all_flights[$id]['archive_longitude'] = $line['longitude'];
649
+				}
521 650
 				if (!isset($this->all_flights[$id]['livedb_longitude']) || abs($this->all_flights[$id]['livedb_longitude']-$line['longitude']) > $globalCoordMinChange || $this->all_flights[$id]['format_source'] == 'aprs') {
522 651
 				    $this->all_flights[$id]['livedb_longitude'] = $line['longitude'];
523 652
 				    $dataFound = true;
@@ -548,7 +677,9 @@  discard block
 block discarded – undo
548 677
 		    }
549 678
 		}
550 679
 		if (isset($line['last_update']) && $line['last_update'] != '') {
551
-		    if (isset($this->all_flights[$id]['last_update']) && $this->all_flights[$id]['last_update'] != $line['last_update']) $dataFound = true;
680
+		    if (isset($this->all_flights[$id]['last_update']) && $this->all_flights[$id]['last_update'] != $line['last_update']) {
681
+		    	$dataFound = true;
682
+		    }
552 683
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('last_update' => $line['last_update']));
553 684
 		}
554 685
 		if (isset($line['verticalrate']) && $line['verticalrate'] != '') {
@@ -570,41 +701,61 @@  discard block
 block discarded – undo
570 701
 			// Here we force archive of flight because after ground it's a new one (or should be)
571 702
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('addedSpotter' => 0));
572 703
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('forcenew' => 1));
573
-			if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw') && $globalDaemon) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdGi')));
574
-		        elseif (isset($line['id'])) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $line['id']));
575
-			elseif (isset($this->all_flights[$id]['ident'])) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
704
+			if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw') && $globalDaemon) {
705
+				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdGi')));
706
+			} elseif (isset($line['id'])) {
707
+		        	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $line['id']));
708
+		        } elseif (isset($this->all_flights[$id]['ident'])) {
709
+				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.$this->all_flights[$id]['ident']));
710
+			}
711
+		    }
712
+		    if ($line['ground'] != 1) {
713
+		    	$line['ground'] = 0;
576 714
 		    }
577
-		    if ($line['ground'] != 1) $line['ground'] = 0;
578 715
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('ground' => $line['ground']));
579 716
 		    //$dataFound = true;
580 717
 		}
581 718
 		if (isset($line['squawk']) && $line['squawk'] != '') {
582 719
 		    if (isset($this->all_flights[$id]['squawk']) && $this->all_flights[$id]['squawk'] != '7500' && $this->all_flights[$id]['squawk'] != '7600' && $this->all_flights[$id]['squawk'] != '7700' && isset($this->all_flights[$id]['id'])) {
583
-			    if ($this->all_flights[$id]['squawk'] != $line['squawk']) $this->all_flights[$id]['putinarchive'] = true;
720
+			    if ($this->all_flights[$id]['squawk'] != $line['squawk']) {
721
+			    	$this->all_flights[$id]['putinarchive'] = true;
722
+			    }
584 723
 			    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('squawk' => $line['squawk']));
585 724
 			    $highlight = '';
586
-			    if ($this->all_flights[$id]['squawk'] == '7500') $highlight = 'Squawk 7500 : Hijack at '.date('Y-m-d G:i').' UTC';
587
-			    if ($this->all_flights[$id]['squawk'] == '7600') $highlight = 'Squawk 7600 : Lost Comm (radio failure) at '.date('Y-m-d G:i').' UTC';
588
-			    if ($this->all_flights[$id]['squawk'] == '7700') $highlight = 'Squawk 7700 : Emergency at '.date('Y-m-d G:i').' UTC';
725
+			    if ($this->all_flights[$id]['squawk'] == '7500') {
726
+			    	$highlight = 'Squawk 7500 : Hijack at '.date('Y-m-d G:i').' UTC';
727
+			    }
728
+			    if ($this->all_flights[$id]['squawk'] == '7600') {
729
+			    	$highlight = 'Squawk 7600 : Lost Comm (radio failure) at '.date('Y-m-d G:i').' UTC';
730
+			    }
731
+			    if ($this->all_flights[$id]['squawk'] == '7700') {
732
+			    	$highlight = 'Squawk 7700 : Emergency at '.date('Y-m-d G:i').' UTC';
733
+			    }
589 734
 			    if ($highlight != '') {
590 735
 				$timeelapsed = microtime(true);
591 736
 				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
592 737
 				    $Spotter = new Spotter($this->db);
593 738
 				    $Spotter->setHighlightFlight($this->all_flights[$id]['id'],$highlight);
594 739
 				    $Spotter->db = null;
595
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update sethighlightflight : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
740
+				    if ($globalDebugTimeElapsed) {
741
+				    	echo 'Time elapsed for update sethighlightflight : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
742
+				    }
596 743
 				}
597 744
 				//$putinarchive = true;
598 745
 				//$highlight = '';
599 746
 			    }
600 747
 			    
601
-		    } else $this->all_flights[$id] = array_merge($this->all_flights[$id],array('squawk' => $line['squawk']));
748
+		    } else {
749
+		    	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('squawk' => $line['squawk']));
750
+		    }
602 751
 		    //$dataFound = true;
603 752
 		}
604 753
 
605 754
 		if (isset($line['altitude']) && $line['altitude'] != '') {
606 755
 		    //if (!isset($this->all_flights[$id]['altitude']) || $this->all_flights[$id]['altitude'] == '' || ($this->all_flights[$id]['altitude'] > 0 && $line['altitude'] != 0)) {
607
-			if (is_int($this->all_flights[$id]['altitude']) && abs(round($line['altitude']/100)-$this->all_flights[$id]['altitude']) > 3) $this->all_flights[$id]['putinarchive'] = true;
756
+			if (is_int($this->all_flights[$id]['altitude']) && abs(round($line['altitude']/100)-$this->all_flights[$id]['altitude']) > 3) {
757
+				$this->all_flights[$id]['putinarchive'] = true;
758
+			}
608 759
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('altitude' => round($line['altitude']/100)));
609 760
 			$this->all_flights[$id] = array_merge($this->all_flights[$id],array('altitude_real' => $line['altitude']));
610 761
 			//$dataFound = true;
@@ -616,21 +767,30 @@  discard block
 block discarded – undo
616 767
 		}
617 768
 		
618 769
 		if (isset($line['heading']) && $line['heading'] != '') {
619
-		    if (is_int($this->all_flights[$id]['heading']) && abs($this->all_flights[$id]['heading']-round($line['heading'])) > 10) $this->all_flights[$id]['putinarchive'] = true;
770
+		    if (is_int($this->all_flights[$id]['heading']) && abs($this->all_flights[$id]['heading']-round($line['heading'])) > 10) {
771
+		    	$this->all_flights[$id]['putinarchive'] = true;
772
+		    }
620 773
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('heading' => round($line['heading'])));
621 774
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('heading_fromsrc' => true));
622 775
 		    //$dataFound = true;
623 776
   		} elseif (!isset($this->all_flights[$id]['heading_fromsrc']) && isset($this->all_flights[$id]['archive_latitude']) && $this->all_flights[$id]['archive_latitude'] != $this->all_flights[$id]['latitude'] && isset($this->all_flights[$id]['archive_longitude']) && $this->all_flights[$id]['archive_longitude'] != $this->all_flights[$id]['longitude']) {
624 777
   		    $heading = $Common->getHeading($this->all_flights[$id]['archive_latitude'],$this->all_flights[$id]['archive_longitude'],$this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude']);
625 778
 		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('heading' => round($heading)));
626
-		    if (abs($this->all_flights[$id]['heading']-round($heading)) > 10) $this->all_flights[$id]['putinarchive'] = true;
627
-  		    if ($globalDebug) echo "ø Calculated Heading for ".$this->all_flights[$id]['hex']." : ".$heading."\n";
779
+		    if (abs($this->all_flights[$id]['heading']-round($heading)) > 10) {
780
+		    	$this->all_flights[$id]['putinarchive'] = true;
781
+		    }
782
+  		    if ($globalDebug) {
783
+  		    	echo "ø Calculated Heading for ".$this->all_flights[$id]['hex']." : ".$heading."\n";
784
+  		    }
628 785
   		} elseif (isset($this->all_flights[$id]['format_source']) && $this->all_flights[$id]['format_source'] == 'ACARS') {
629 786
   		    // If not enough messages and ACARS set heading to 0
630 787
   		    $this->all_flights[$id] = array_merge($this->all_flights[$id],array('heading' => 0));
631 788
   		}
632
-		if ($globalDaemon === TRUE && isset($globalSourcesupdate) && $globalSourcesupdate != '' && isset($this->all_flights[$id]['lastupdate']) && time()-$this->all_flights[$id]['lastupdate'] < $globalSourcesupdate) $dataFound = false;
633
-		elseif ($globalDaemon === TRUE && isset($globalSBS1update) && $globalSBS1update != '' && isset($this->all_flights[$id]['lastupdate']) && time()-$this->all_flights[$id]['lastupdate'] < $globalSBS1update) $dataFound = false;
789
+		if ($globalDaemon === TRUE && isset($globalSourcesupdate) && $globalSourcesupdate != '' && isset($this->all_flights[$id]['lastupdate']) && time()-$this->all_flights[$id]['lastupdate'] < $globalSourcesupdate) {
790
+			$dataFound = false;
791
+		} elseif ($globalDaemon === TRUE && isset($globalSBS1update) && $globalSBS1update != '' && isset($this->all_flights[$id]['lastupdate']) && time()-$this->all_flights[$id]['lastupdate'] < $globalSBS1update) {
792
+			$dataFound = false;
793
+		}
634 794
 
635 795
 //		print_r($this->all_flights[$id]);
636 796
 		//gets the callsign from the last hour
@@ -646,23 +806,38 @@  discard block
 block discarded – undo
646 806
 			    //$last_hour_ident = Spotter->getIdentFromLastHour($this->all_flights[$id]['ident']);
647 807
 			    if (!isset($this->all_flights[$id]['forcenew']) || $this->all_flights[$id]['forcenew'] == 0) {
648 808
 				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
649
-				    if ($globalDebug) echo "Check if aircraft is already in DB...";
809
+				    if ($globalDebug) {
810
+				    	echo "Check if aircraft is already in DB...";
811
+				    }
650 812
 				    $timeelapsed = microtime(true);
651 813
 				    $SpotterLive = new SpotterLive($this->db);
652 814
 				    if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw' || $line['format_source'] === 'deltadbtxt' || $line['format_source'] === 'planeupdatefaa' || $line['format_source'] === 'aprs' || $line['format_source'] === 'aircraftlistjson' || $line['format_source'] === 'radarvirtueljson' || $line['format_source'] === 'famaprs')) {
653 815
 					$recent_ident = $SpotterLive->checkModeSRecent($this->all_flights[$id]['hex']);
654
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkModeSRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
816
+					if ($globalDebugTimeElapsed) {
817
+						echo 'Time elapsed for update checkModeSRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
818
+					}
655 819
 				    } elseif (isset($line['id'])) {
656 820
 					$recent_ident = $SpotterLive->checkIdRecent($line['id']);
657
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
821
+					if ($globalDebugTimeElapsed) {
822
+						echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
823
+					}
658 824
 				    } elseif (isset($this->all_flights[$id]['ident']) && $this->all_flights[$id]['ident'] != '') {
659 825
 					$recent_ident = $SpotterLive->checkIdentRecent($this->all_flights[$id]['ident']);
660
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
661
-				    } else $recent_ident = '';
826
+					if ($globalDebugTimeElapsed) {
827
+						echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
828
+					}
829
+				    } else {
830
+				    	$recent_ident = '';
831
+				    }
662 832
 				    $SpotterLive->db=null;
663
-				    if ($globalDebug && $recent_ident == '') echo " Not in DB.\n";
664
-				    elseif ($globalDebug && $recent_ident != '') echo " Already in DB.\n";
665
-				} else $recent_ident = '';
833
+				    if ($globalDebug && $recent_ident == '') {
834
+				    	echo " Not in DB.\n";
835
+				    } elseif ($globalDebug && $recent_ident != '') {
836
+				    	echo " Already in DB.\n";
837
+				    }
838
+				} else {
839
+					$recent_ident = '';
840
+				}
666 841
 			    } else {
667 842
 				$recent_ident = '';
668 843
 				$this->all_flights[$id] = array_merge($this->all_flights[$id],array('forcenew' => 0));
@@ -670,7 +845,9 @@  discard block
 block discarded – undo
670 845
 			    //if there was no aircraft with the same callsign within the last hour and go post it into the archive
671 846
 			    if($recent_ident == "")
672 847
 			    {
673
-				if ($globalDebug) echo "\o/ Add ".$this->all_flights[$id]['ident']." in archive DB : ";
848
+				if ($globalDebug) {
849
+					echo "\o/ Add ".$this->all_flights[$id]['ident']." in archive DB : ";
850
+				}
674 851
 				if ($this->all_flights[$id]['departure_airport'] == "") { $this->all_flights[$id]['departure_airport'] = "NA"; }
675 852
 				if ($this->all_flights[$id]['arrival_airport'] == "") { $this->all_flights[$id]['arrival_airport'] = "NA"; }
676 853
 				//adds the spotter data for the archive
@@ -714,31 +891,49 @@  discard block
 block discarded – undo
714 891
 				
715 892
 				if (!$ignoreImport) {
716 893
 				    $highlight = '';
717
-				    if ($this->all_flights[$id]['squawk'] == '7500') $highlight = 'Squawk 7500 : Hijack';
718
-				    if ($this->all_flights[$id]['squawk'] == '7600') $highlight = 'Squawk 7600 : Lost Comm (radio failure)';
719
-				    if ($this->all_flights[$id]['squawk'] == '7700') $highlight = 'Squawk 7700 : Emergency';
720
-				    if (!isset($this->all_flights[$id]['id'])) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdHi')));
894
+				    if ($this->all_flights[$id]['squawk'] == '7500') {
895
+				    	$highlight = 'Squawk 7500 : Hijack';
896
+				    }
897
+				    if ($this->all_flights[$id]['squawk'] == '7600') {
898
+				    	$highlight = 'Squawk 7600 : Lost Comm (radio failure)';
899
+				    }
900
+				    if ($this->all_flights[$id]['squawk'] == '7700') {
901
+				    	$highlight = 'Squawk 7700 : Emergency';
902
+				    }
903
+				    if (!isset($this->all_flights[$id]['id'])) {
904
+				    	$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdHi')));
905
+				    }
721 906
 				    $timeelapsed = microtime(true);
722 907
 				    if (!isset($globalNoImport) || $globalNoImport === FALSE) {
723 908
 					if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
724 909
 					    $Spotter = new Spotter($this->db);
725 910
 					    $result = $Spotter->addSpotterData($this->all_flights[$id]['id'], $this->all_flights[$id]['ident'], $this->all_flights[$id]['aircraft_icao'], $this->all_flights[$id]['departure_airport'], $this->all_flights[$id]['arrival_airport'], $this->all_flights[$id]['latitude'], $this->all_flights[$id]['longitude'], $this->all_flights[$id]['waypoints'], $this->all_flights[$id]['altitude'],$this->all_flights[$id]['altitude_real'], $this->all_flights[$id]['heading'], $this->all_flights[$id]['speed'], $this->all_flights[$id]['datetime'], $this->all_flights[$id]['departure_airport_time'], $this->all_flights[$id]['arrival_airport_time'],$this->all_flights[$id]['squawk'],$this->all_flights[$id]['route_stop'],$highlight,$this->all_flights[$id]['hex'],$this->all_flights[$id]['registration'],$this->all_flights[$id]['pilot_id'],$this->all_flights[$id]['pilot_name'],$this->all_flights[$id]['verticalrate'],$this->all_flights[$id]['ground'],$this->all_flights[$id]['format_source'],$this->all_flights[$id]['source_name'],$this->all_flights[$id]['source_type']);
726 911
 					    $Spotter->db = null;
727
-					    if ($globalDebug && isset($result)) echo $result."\n";
912
+					    if ($globalDebug && isset($result)) {
913
+					    	echo $result."\n";
914
+					    }
728 915
 					}
729 916
 				    }
730
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
917
+				    if ($globalDebugTimeElapsed) {
918
+				    	echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
919
+				    }
731 920
 				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
732 921
 
733 922
 				    // Add source stat in DB
734 923
 				    $Stats = new Stats($this->db);
735 924
 				    if (!empty($this->stats)) {
736
-					if ($globalDebug) echo 'Add source stats : ';
925
+					if ($globalDebug) {
926
+						echo 'Add source stats : ';
927
+					}
737 928
 				        foreach($this->stats as $date => $data) {
738 929
 					    foreach($data as $source => $sourced) {
739 930
 					        //print_r($sourced);
740
-				    	        if (isset($sourced['polar'])) echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar',$date);
741
-				    	        if (isset($sourced['hist'])) echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist',$date);
931
+				    	        if (isset($sourced['polar'])) {
932
+				    	        	echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar',$date);
933
+				    	        }
934
+				    	        if (isset($sourced['hist'])) {
935
+				    	        	echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist',$date);
936
+				    	        }
742 937
 				    		if (isset($sourced['msg'])) {
743 938
 				    		    if (time() - $sourced['msg']['date'] > 10) {
744 939
 				    		        $nbmsg = round($sourced['msg']['nb']/(time() - $sourced['msg']['date']));
@@ -751,13 +946,17 @@  discard block
 block discarded – undo
751 946
 			    			unset($this->stats[$date]);
752 947
 			    		    }
753 948
 				    	}
754
-				    	if ($globalDebug) echo 'Done'."\n";
949
+				    	if ($globalDebug) {
950
+				    		echo 'Done'."\n";
951
+				    	}
755 952
 
756 953
 				    }
757 954
 				    $Stats->db = null;
758 955
 				    }
759 956
 				    $this->del();
760
-				} elseif ($globalDebug) echo 'Ignore data'."\n";
957
+				} elseif ($globalDebug) {
958
+					echo 'Ignore data'."\n";
959
+				}
761 960
 				//$ignoreImport = false;
762 961
 				$this->all_flights[$id]['addedSpotter'] = 1;
763 962
 				//print_r($this->all_flights[$id]);
@@ -774,7 +973,9 @@  discard block
 block discarded – undo
774 973
 			*/
775 974
 			//SpotterLive->deleteLiveSpotterDataByIdent($this->all_flights[$id]['ident']);
776 975
 				if ($this->last_delete == 0 || time() - $this->last_delete > 1800) {
777
-				    if ($globalDebug) echo "---- Deleting Live Spotter data older than 9 hours...";
976
+				    if ($globalDebug) {
977
+				    	echo "---- Deleting Live Spotter data older than 9 hours...";
978
+				    }
778 979
 				    //SpotterLive->deleteLiveSpotterDataNotUpdated();
779 980
 				    if (!isset($globalNoImport) || $globalNoImport === FALSE) {
780 981
 					if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
@@ -783,7 +984,9 @@  discard block
 block discarded – undo
783 984
 					    $SpotterLive->db=null;
784 985
 					}
785 986
 				    }
786
-				    if ($globalDebug) echo " Done\n";
987
+				    if ($globalDebug) {
988
+				    	echo " Done\n";
989
+				    }
787 990
 				    $this->last_delete = time();
788 991
 				}
789 992
 			    } else {
@@ -810,11 +1013,17 @@  discard block
 block discarded – undo
810 1013
 		    //echo "{$line[8]} {$line[7]} - MODES:{$line[4]}  CALLSIGN:{$line[10]}   ALT:{$line[11]}   VEL:{$line[12]}   HDG:{$line[13]}   LAT:{$line[14]}   LON:{$line[15]}   VR:{$line[16]}   SQUAWK:{$line[17]}\n";
811 1014
 		    if ($globalDebug) {
812 1015
 			if ((isset($globalVA) && $globalVA) || (isset($globalIVAO) && $globalIVAO) || (isset($globalVATSIM) && $globalVATSIM) || (isset($globalphpVMS) && $globalphpVMS) || (isset($globalVAM) && $globalVAM)) {
813
-				if (isset($this->all_flights[$id]['source_name'])) echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Pilot : '.$this->all_flights[$id]['pilot_name'].' - Source name : '.$this->all_flights[$id]['source_name']."\n";
814
-				else echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Pilot : '.$this->all_flights[$id]['pilot_name']."\n";
1016
+				if (isset($this->all_flights[$id]['source_name'])) {
1017
+					echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Pilot : '.$this->all_flights[$id]['pilot_name'].' - Source name : '.$this->all_flights[$id]['source_name']."\n";
1018
+				} else {
1019
+					echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Pilot : '.$this->all_flights[$id]['pilot_name']."\n";
1020
+				}
815 1021
 			} else {
816
-				if (isset($this->all_flights[$id]['source_name'])) echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Source Name : '.$this->all_flights[$id]['source_name']."\n";
817
-				else echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time']."\n";
1022
+				if (isset($this->all_flights[$id]['source_name'])) {
1023
+					echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time'].' - Source Name : '.$this->all_flights[$id]['source_name']."\n";
1024
+				} else {
1025
+					echo 'DATA : hex : '.$this->all_flights[$id]['hex'].' - ident : '.$this->all_flights[$id]['ident'].' - ICAO : '.$this->all_flights[$id]['aircraft_icao'].' - Departure Airport : '.$this->all_flights[$id]['departure_airport'].' - Arrival Airport : '.$this->all_flights[$id]['arrival_airport'].' - Latitude : '.$this->all_flights[$id]['latitude'].' - Longitude : '.$this->all_flights[$id]['longitude'].' - waypoints : '.$this->all_flights[$id]['waypoints'].' - Altitude : '.$this->all_flights[$id]['altitude'].' - Heading : '.$this->all_flights[$id]['heading'].' - Speed : '.$this->all_flights[$id]['speed'].' - Departure Airport Time : '.$this->all_flights[$id]['departure_airport_time'].' - Arrival Airport time : '.$this->all_flights[$id]['arrival_airport_time']."\n";
1026
+				}
818 1027
 			}
819 1028
 		    }
820 1029
 		    $ignoreImport = false;
@@ -860,22 +1069,30 @@  discard block
 block discarded – undo
860 1069
 
861 1070
 		    if (!$ignoreImport) {
862 1071
 			if (!isset($globalDistanceIgnore['latitude']) || (isset($globalDistanceIgnore['latitude']) && $Common->distance($this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude']) < $globalDistanceIgnore['distance'])) {
863
-				if (!isset($this->all_flights[$id]['id'])) $this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdHi')));
1072
+				if (!isset($this->all_flights[$id]['id'])) {
1073
+					$this->all_flights[$id] = array_merge($this->all_flights[$id],array('id' => $this->all_flights[$id]['hex'].'-'.date('YmdHi')));
1074
+				}
864 1075
 				$timeelapsed = microtime(true);
865 1076
 				if (!isset($globalNoImport) || $globalNoImport === FALSE) {
866 1077
 				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
867
-					if ($globalDebug) echo "\o/ Add ".$this->all_flights[$id]['ident']." from ".$this->all_flights[$id]['format_source']." in Live DB : ";
1078
+					if ($globalDebug) {
1079
+						echo "\o/ Add ".$this->all_flights[$id]['ident']." from ".$this->all_flights[$id]['format_source']." in Live DB : ";
1080
+					}
868 1081
 					$SpotterLive = new SpotterLive($this->db);
869 1082
 					$result = $SpotterLive->addLiveSpotterData($this->all_flights[$id]['id'], $this->all_flights[$id]['ident'], $this->all_flights[$id]['aircraft_icao'], $this->all_flights[$id]['departure_airport'], $this->all_flights[$id]['arrival_airport'], $this->all_flights[$id]['latitude'], $this->all_flights[$id]['longitude'], $this->all_flights[$id]['waypoints'], $this->all_flights[$id]['altitude'],$this->all_flights[$id]['altitude_real'], $this->all_flights[$id]['heading'], $this->all_flights[$id]['speed'],$this->all_flights[$id]['datetime'], $this->all_flights[$id]['departure_airport_time'], $this->all_flights[$id]['arrival_airport_time'], $this->all_flights[$id]['squawk'],$this->all_flights[$id]['route_stop'],$this->all_flights[$id]['hex'],$this->all_flights[$id]['putinarchive'],$this->all_flights[$id]['registration'],$this->all_flights[$id]['pilot_id'],$this->all_flights[$id]['pilot_name'], $this->all_flights[$id]['verticalrate'], $this->all_flights[$id]['noarchive'], $this->all_flights[$id]['ground'],$this->all_flights[$id]['format_source'],$this->all_flights[$id]['source_name'],$this->all_flights[$id]['over_country']);
870 1083
 					$SpotterLive->db = null;
871
-					if ($globalDebug) echo $result."\n";
1084
+					if ($globalDebug) {
1085
+						echo $result."\n";
1086
+					}
872 1087
 				    }
873 1088
 				}
874 1089
 				if (isset($globalServerAPRS) && $globalServerAPRS && $this->all_flights[$id]['putinarchive']) {
875 1090
 					$APRSSpotter->addLiveSpotterData($this->all_flights[$id]['id'], $this->all_flights[$id]['ident'], $this->all_flights[$id]['aircraft_icao'], $this->all_flights[$id]['departure_airport'], $this->all_flights[$id]['arrival_airport'], $this->all_flights[$id]['latitude'], $this->all_flights[$id]['longitude'], $this->all_flights[$id]['waypoints'], $this->all_flights[$id]['altitude'], $this->all_flights[$id]['altitude_real'], $this->all_flights[$id]['heading'], $this->all_flights[$id]['speed'],$this->all_flights[$id]['datetime'], $this->all_flights[$id]['departure_airport_time'], $this->all_flights[$id]['arrival_airport_time'], $this->all_flights[$id]['squawk'],$this->all_flights[$id]['route_stop'],$this->all_flights[$id]['hex'],$this->all_flights[$id]['putinarchive'],$this->all_flights[$id]['registration'],$this->all_flights[$id]['pilot_id'],$this->all_flights[$id]['pilot_name'], $this->all_flights[$id]['verticalrate'], $this->all_flights[$id]['noarchive'], $this->all_flights[$id]['ground'],$this->all_flights[$id]['format_source'],$this->all_flights[$id]['source_name'],$this->all_flights[$id]['over_country']);
876 1091
 				}
877 1092
 				$this->all_flights[$id]['putinarchive'] = false;
878
-				if ($globalDebugTimeElapsed) echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
1093
+				if ($globalDebugTimeElapsed) {
1094
+					echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
1095
+				}
879 1096
 
880 1097
 				// Put statistics in $this->stats variable
881 1098
 				//if ($line['format_source'] != 'aprs') {
@@ -883,7 +1100,9 @@  discard block
 block discarded – undo
883 1100
 				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
884 1101
 				    if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $line['format_source'] != 'aprs' && $this->all_flights[$id]['latitude'] != '' && $this->all_flights[$id]['longitude'] != '') {
885 1102
 					$source = $this->all_flights[$id]['source_name'];
886
-					if ($source == '') $source = $this->all_flights[$id]['format_source'];
1103
+					if ($source == '') {
1104
+						$source = $this->all_flights[$id]['format_source'];
1105
+					}
887 1106
 					if (!isset($this->source_location[$source])) {
888 1107
 						$Location = new Source();
889 1108
 						$coord = $Location->getLocationInfobySourceName($source);
@@ -904,7 +1123,9 @@  discard block
 block discarded – undo
904 1123
 					$stats_heading = round($stats_heading/22.5);
905 1124
 					$stats_distance = $Common->distance($latitude,$longitude,$this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude']);
906 1125
 					$current_date = date('Y-m-d');
907
-					if ($stats_heading == 16) $stats_heading = 0;
1126
+					if ($stats_heading == 16) {
1127
+						$stats_heading = 0;
1128
+					}
908 1129
 					if (!isset($this->stats[$current_date][$source]['polar'][1])) {
909 1130
 						for ($i=0;$i<=15;$i++) {
910 1131
 						    $this->stats[$current_date][$source]['polar'][$i] = 0;
@@ -922,7 +1143,9 @@  discard block
 block discarded – undo
922 1143
 						if (isset($this->stats[$current_date][$source]['hist'][0])) {
923 1144
 						    end($this->stats[$current_date][$source]['hist']);
924 1145
 						    $mini = key($this->stats[$current_date][$source]['hist'])+10;
925
-						} else $mini = 0;
1146
+						} else {
1147
+							$mini = 0;
1148
+						}
926 1149
 						for ($i=$mini;$i<=$distance;$i+=10) {
927 1150
 						    $this->stats[$current_date][$source]['hist'][$i] = 0;
928 1151
 						}
@@ -934,19 +1157,27 @@  discard block
 block discarded – undo
934 1157
 				}
935 1158
 
936 1159
 				$this->all_flights[$id]['lastupdate'] = time();
937
-				if ($this->all_flights[$id]['putinarchive']) $send = true;
1160
+				if ($this->all_flights[$id]['putinarchive']) {
1161
+					$send = true;
1162
+				}
938 1163
 				//if ($globalDebug) echo "Distance : ".Common->distance($this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
939
-			} elseif (isset($this->all_flights[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) echo "!! Too far -> Distance : ".$Common->distance($this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
1164
+			} elseif (isset($this->all_flights[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) {
1165
+				echo "!! Too far -> Distance : ".$Common->distance($this->all_flights[$id]['latitude'],$this->all_flights[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
1166
+			}
940 1167
 			//$this->del();
941 1168
 			
942 1169
 			if ($this->last_delete_hourly == 0 || time() - $this->last_delete_hourly > 900) {
943 1170
 			    if ((!isset($globalNoImport) || $globalNoImport === FALSE) && (!isset($globalNoDB) || $globalNoDB !== TRUE)) {
944
-				if ($globalDebug) echo "---- Deleting Live Spotter data Not updated since 2 hour...";
1171
+				if ($globalDebug) {
1172
+					echo "---- Deleting Live Spotter data Not updated since 2 hour...";
1173
+				}
945 1174
 				$SpotterLive = new SpotterLive($this->db);
946 1175
 				$SpotterLive->deleteLiveSpotterDataNotUpdated();
947 1176
 				$SpotterLive->db = null;
948 1177
 				//SpotterLive->deleteLiveSpotterData();
949
-				if ($globalDebug) echo " Done\n";
1178
+				if ($globalDebug) {
1179
+					echo " Done\n";
1180
+				}
950 1181
 				$this->last_delete_hourly = time();
951 1182
 			    } else {
952 1183
 				$this->del();
@@ -958,7 +1189,9 @@  discard block
 block discarded – undo
958 1189
 		    //$ignoreImport = false;
959 1190
 		}
960 1191
 		//if (function_exists('pcntl_fork') && $globalFork) pcntl_signal(SIGCHLD, SIG_IGN);
961
-		if ($send) return $this->all_flights[$id];
1192
+		if ($send) {
1193
+			return $this->all_flights[$id];
1194
+		}
962 1195
 	    }
963 1196
 	}
964 1197
     }
Please login to merge, or discard this patch.
require/class.TrackerImport.php 1 patch
Braces   +190 added lines, -65 removed lines patch added patch discarded remove patch
@@ -42,7 +42,9 @@  discard block
 block discarded – undo
42 42
 
43 43
     public function checkAll() {
44 44
 	global $globalDebug;
45
-	if ($globalDebug) echo "Update last seen tracked data...\n";
45
+	if ($globalDebug) {
46
+		echo "Update last seen tracked data...\n";
47
+	}
46 48
 	foreach ($this->all_tracked as $key => $flight) {
47 49
 	    if (isset($this->all_tracked[$key]['id'])) {
48 50
 		//echo $this->all_tracked[$key]['id'].' - '.$this->all_tracked[$key]['latitude'].'  '.$this->all_tracked[$key]['longitude']."\n";
@@ -55,12 +57,16 @@  discard block
 block discarded – undo
55 57
     public function del() {
56 58
 	global $globalDebug;
57 59
 	// Delete old infos
58
-	if ($globalDebug) echo 'Delete old values and update latest data...'."\n";
60
+	if ($globalDebug) {
61
+		echo 'Delete old values and update latest data...'."\n";
62
+	}
59 63
 	foreach ($this->all_tracked as $key => $flight) {
60 64
     	    if (isset($flight['lastupdate'])) {
61 65
         	if ($flight['lastupdate'] < (time()-3000)) {
62 66
             	    if (isset($this->all_tracked[$key]['id'])) {
63
-            		if ($globalDebug) echo "--- Delete old values with id ".$this->all_tracked[$key]['id']."\n";
67
+            		if ($globalDebug) {
68
+            			echo "--- Delete old values with id ".$this->all_tracked[$key]['id']."\n";
69
+            		}
64 70
 			/*
65 71
 			$TrackerLive = new TrackerLive();
66 72
             		$TrackerLive->deleteLiveTrackerDataById($this->all_tracked[$key]['id']);
@@ -70,7 +76,9 @@  discard block
 block discarded – undo
70 76
             		$Tracker = new Tracker($this->db);
71 77
             		if ($this->all_tracked[$key]['latitude'] != '' && $this->all_tracked[$key]['longitude'] != '') {
72 78
 				$result = $Tracker->updateLatestTrackerData($this->all_tracked[$key]['id'],$this->all_tracked[$key]['ident'],$this->all_tracked[$key]['latitude'],$this->all_tracked[$key]['longitude'],$this->all_tracked[$key]['altitude'],$this->all_tracked[$key]['speed']);
73
-				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
79
+				if ($globalDebug && $result != 'success') {
80
+					echo '!!! ERROR : '.$result."\n";
81
+				}
74 82
 			}
75 83
 			// Put in archive
76 84
 //			$Tracker->db = null;
@@ -83,7 +91,9 @@  discard block
 block discarded – undo
83 91
 
84 92
     public function add($line) {
85 93
 	global $globalFork, $globalDistanceIgnore, $globalDaemon, $globalDebug, $globalCoordMinChange, $globalDebugTimeElapsed, $globalCenterLatitude, $globalCenterLongitude, $globalBeta, $globalSourcesupdate, $globalAllTracked;
86
-	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') $globalCoordMinChange = '0.02';
94
+	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') {
95
+		$globalCoordMinChange = '0.02';
96
+	}
87 97
 	date_default_timezone_set('UTC');
88 98
 	$dataFound = false;
89 99
 	$send = false;
@@ -97,19 +107,29 @@  discard block
 block discarded – undo
97 107
 		// Increment message number
98 108
 		if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE) {
99 109
 		    $current_date = date('Y-m-d');
100
-		    if (isset($line['source_name'])) $source = $line['source_name'];
101
-		    else $source = '';
102
-		    if ($source == '' || $line['format_source'] == 'aprs') $source = $line['format_source'];
110
+		    if (isset($line['source_name'])) {
111
+		    	$source = $line['source_name'];
112
+		    } else {
113
+		    	$source = '';
114
+		    }
115
+		    if ($source == '' || $line['format_source'] == 'aprs') {
116
+		    	$source = $line['format_source'];
117
+		    }
103 118
 		    if (!isset($this->stats[$current_date][$source]['msg'])) {
104 119
 		    	$this->stats[$current_date][$source]['msg']['date'] = time();
105 120
 		    	$this->stats[$current_date][$source]['msg']['nb'] = 1;
106
-		    } else $this->stats[$current_date][$source]['msg']['nb'] += 1;
121
+		    } else {
122
+		    	$this->stats[$current_date][$source]['msg']['nb'] += 1;
123
+		    }
107 124
 		}
108 125
 		
109 126
 		
110 127
 		$Common = new Common();
111
-	        if (!isset($line['id'])) $id = trim($line['ident']);
112
-	        else $id = trim($line['id']);
128
+	        if (!isset($line['id'])) {
129
+	        	$id = trim($line['ident']);
130
+	        } else {
131
+	        	$id = trim($line['id']);
132
+	        }
113 133
 		
114 134
 		if (!isset($this->all_tracked[$id])) {
115 135
 		    $this->all_tracked[$id] = array();
@@ -117,31 +137,46 @@  discard block
 block discarded – undo
117 137
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('ident' => '','latitude' => '', 'longitude' => '', 'speed' => '', 'altitude' => '', 'heading' => '', 'format_source' => '','source_name' => '','comment'=> '','type' => '','noarchive' => false,'putinarchive' => true,'over_country' => ''));
118 138
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('lastupdate' => time()));
119 139
 		    if (!isset($line['id'])) {
120
-			if (!isset($globalDaemon)) $globalDaemon = TRUE;
140
+			if (!isset($globalDaemon)) {
141
+				$globalDaemon = TRUE;
142
+			}
121 143
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $id.'-'.date('YmdHi')));
122
-		     } else $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $line['id']));
123
-		    if ($globalAllTracked !== FALSE) $dataFound = true;
144
+		     } else {
145
+		     	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $line['id']));
146
+		     }
147
+		    if ($globalAllTracked !== FALSE) {
148
+		    	$dataFound = true;
149
+		    }
124 150
 		}
125 151
 		
126 152
 		if (isset($line['datetime']) && strtotime($line['datetime']) > time()-20*60 && strtotime($line['datetime']) < time()+20*60) {
127 153
 		    if (!isset($this->all_tracked[$id]['datetime']) || strtotime($line['datetime']) >= strtotime($this->all_tracked[$id]['datetime'])) {
128 154
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => $line['datetime']));
129 155
 		    } else {
130
-				if (strtotime($line['datetime']) == strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) echo "!!! Date is the same as previous data for ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."\n";
131
-				elseif (strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_tracked[$id]['datetime'].") !!! for ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."\n";
156
+				if (strtotime($line['datetime']) == strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) {
157
+					echo "!!! Date is the same as previous data for ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."\n";
158
+				} elseif (strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) {
159
+					echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_tracked[$id]['datetime'].") !!! for ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."\n";
160
+				}
132 161
 				return '';
133 162
 		    }
134 163
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) < time()-20*60) {
135
-			if ($globalDebug) echo "!!! Date is too old ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
164
+			if ($globalDebug) {
165
+				echo "!!! Date is too old ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
166
+			}
136 167
 			return '';
137 168
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) > time()+20*60) {
138
-			if ($globalDebug) echo "!!! Date is in the future ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
169
+			if ($globalDebug) {
170
+				echo "!!! Date is in the future ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
171
+			}
139 172
 			return '';
140 173
 		} elseif (!isset($line['datetime'])) {
141 174
 			date_default_timezone_set('UTC');
142 175
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => date('Y-m-d H:i:s')));
143 176
 		} else {
144
-			if ($globalDebug) echo "!!! Unknow date error ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
177
+			if ($globalDebug) {
178
+				echo "!!! Unknow date error ".$this->all_tracked[$id]['ident']." - format : ".$line['format_source']."!!!";
179
+			}
145 180
 			return '';
146 181
 		}
147 182
 		
@@ -153,11 +188,17 @@  discard block
 block discarded – undo
153 188
             		$Tracker = new Tracker($this->db);
154 189
             		$fromsource = NULL;
155 190
             		$result = $Tracker->updateIdentTrackerData($this->all_tracked[$id]['id'],$this->all_tracked[$id]['ident'],$fromsource);
156
-			if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
191
+			if ($globalDebug && $result != 'success') {
192
+				echo '!!! ERROR : '.$result."\n";
193
+			}
157 194
 			$Tracker->db = null;
158
-			if ($globalDebugTimeElapsed) echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
195
+			if ($globalDebugTimeElapsed) {
196
+				echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
197
+			}
198
+		    }
199
+		    if (!isset($this->all_tracked[$id]['id'])) {
200
+		    	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident']));
159 201
 		    }
160
-		    if (!isset($this->all_tracked[$id]['id'])) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident']));
161 202
 		}
162 203
 
163 204
 		if (isset($line['speed']) && $line['speed'] != '') {
@@ -168,14 +209,21 @@  discard block
 block discarded – undo
168 209
 		    if ($distance > 100 && $distance < 10000) {
169 210
 			$speed = $distance/(time() - $this->all_tracked[$id]['time_last_coord']);
170 211
 			$speed = $speed*3.6;
171
-			if ($speed < 1000) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($speed)));
172
-  			if ($globalDebug) echo "ø Calculated Speed for ".$this->all_tracked[$id]['ident']." : ".$speed." - distance : ".$distance."\n";
212
+			if ($speed < 1000) {
213
+				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($speed)));
214
+			}
215
+  			if ($globalDebug) {
216
+  				echo "ø Calculated Speed for ".$this->all_tracked[$id]['ident']." : ".$speed." - distance : ".$distance."\n";
217
+  			}
173 218
 		    }
174 219
 		}
175 220
 
176 221
 	        if (isset($line['latitude']) && isset($line['longitude']) && $line['latitude'] != '' && $line['longitude'] != '' && is_numeric($line['latitude']) && is_numeric($line['longitude'])) {
177
-	    	    if (isset($this->all_tracked[$id]['time_last_coord'])) $timediff = round(time()-$this->all_tracked[$id]['time_last_coord']);
178
-	    	    else unset($timediff);
222
+	    	    if (isset($this->all_tracked[$id]['time_last_coord'])) {
223
+	    	    	$timediff = round(time()-$this->all_tracked[$id]['time_last_coord']);
224
+	    	    } else {
225
+	    	    	unset($timediff);
226
+	    	    }
179 227
 	    	    if ($this->tmd > 5 || !isset($timediff) || $timediff > 100 || ($timediff > 30 && isset($this->all_tracked[$id]['latitude']) && isset($this->all_tracked[$id]['longitude']) && $Common->withinThreshold($timediff,$Common->distance($line['latitude'],$line['longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],'m')))) {
180 228
 			if (isset($this->all_tracked[$id]['archive_latitude']) && isset($this->all_tracked[$id]['archive_longitude']) && isset($this->all_tracked[$id]['livedb_latitude']) && isset($this->all_tracked[$id]['livedb_longitude'])) {
181 229
 			    if (!$Common->checkLine($this->all_tracked[$id]['archive_latitude'],$this->all_tracked[$id]['archive_longitude'],$this->all_tracked[$id]['livedb_latitude'],$this->all_tracked[$id]['livedb_longitude'],$line['latitude'],$line['longitude'])) {
@@ -183,20 +231,30 @@  discard block
 block discarded – undo
183 231
 				$this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
184 232
 				$this->all_tracked[$id]['putinarchive'] = true;
185 233
 				
186
-				if ($globalDebug) echo "\n".' ------- Check Country for '.$this->all_tracked[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
234
+				if ($globalDebug) {
235
+					echo "\n".' ------- Check Country for '.$this->all_tracked[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
236
+				}
187 237
 				$timeelapsed = microtime(true);
188 238
 				$Tracker = new Tracker($this->db);
189 239
 				$all_country = $Tracker->getCountryFromLatitudeLongitude($line['latitude'],$line['longitude']);
190
-				if (!empty($all_country)) $this->all_tracked[$id]['over_country'] = $all_country['iso2'];
240
+				if (!empty($all_country)) {
241
+					$this->all_tracked[$id]['over_country'] = $all_country['iso2'];
242
+				}
191 243
 				$Tracker->db = null;
192
-				if ($globalDebugTimeElapsed) echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
244
+				if ($globalDebugTimeElapsed) {
245
+					echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
246
+				}
193 247
 				$this->tmd = 0;
194
-				if ($globalDebug) echo 'FOUND : '.$this->all_tracked[$id]['over_country'].' ---------------'."\n";
248
+				if ($globalDebug) {
249
+					echo 'FOUND : '.$this->all_tracked[$id]['over_country'].' ---------------'."\n";
250
+				}
195 251
 			    }
196 252
 			}
197 253
 
198 254
 			if (isset($line['latitude']) && $line['latitude'] != '' && $line['latitude'] != 0 && $line['latitude'] < 91 && $line['latitude'] > -90) {
199
-				if (!isset($this->all_tracked[$id]['archive_latitude'])) $this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
255
+				if (!isset($this->all_tracked[$id]['archive_latitude'])) {
256
+					$this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
257
+				}
200 258
 				if (!isset($this->all_tracked[$id]['livedb_latitude']) || abs($this->all_tracked[$id]['livedb_latitude']-$line['latitude']) > $globalCoordMinChange || $this->all_tracked[$id]['format_source'] == 'aprs') {
201 259
 				    $this->all_tracked[$id]['livedb_latitude'] = $line['latitude'];
202 260
 				    $dataFound = true;
@@ -205,8 +263,12 @@  discard block
 block discarded – undo
205 263
 				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('latitude' => $line['latitude']));
206 264
 			}
207 265
 			if (isset($line['longitude']) && $line['longitude'] != '' && $line['longitude'] != 0 && $line['longitude'] < 360 && $line['longitude'] > -180) {
208
-			    if ($line['longitude'] > 180) $line['longitude'] = $line['longitude'] - 360;
209
-				if (!isset($this->all_tracked[$id]['archive_longitude'])) $this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
266
+			    if ($line['longitude'] > 180) {
267
+			    	$line['longitude'] = $line['longitude'] - 360;
268
+			    }
269
+				if (!isset($this->all_tracked[$id]['archive_longitude'])) {
270
+					$this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
271
+				}
210 272
 				if (!isset($this->all_tracked[$id]['livedb_longitude']) || abs($this->all_tracked[$id]['livedb_longitude']-$line['longitude']) > $globalCoordMinChange || $this->all_tracked[$id]['format_source'] == 'aprs') {
211 273
 				    $this->all_tracked[$id]['livedb_longitude'] = $line['longitude'];
212 274
 				    $dataFound = true;
@@ -224,7 +286,9 @@  discard block
 block discarded – undo
224 286
 		    }
225 287
 		}
226 288
 		if (isset($line['last_update']) && $line['last_update'] != '') {
227
-		    if (isset($this->all_tracked[$id]['last_update']) && $this->all_tracked[$id]['last_update'] != $line['last_update']) $dataFound = true;
289
+		    if (isset($this->all_tracked[$id]['last_update']) && $this->all_tracked[$id]['last_update'] != $line['last_update']) {
290
+		    	$dataFound = true;
291
+		    }
228 292
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('last_update' => $line['last_update']));
229 293
 		}
230 294
 		if (isset($line['format_source']) && $line['format_source'] != '') {
@@ -244,7 +308,9 @@  discard block
 block discarded – undo
244 308
 
245 309
 		if (isset($line['altitude']) && $line['altitude'] != '') {
246 310
 		    //if (!isset($this->all_tracked[$id]['altitude']) || $this->all_tracked[$id]['altitude'] == '' || ($this->all_tracked[$id]['altitude'] > 0 && $line['altitude'] != 0)) {
247
-			if (is_int($this->all_tracked[$id]['altitude']) && abs(round($line['altitude']/100)-$this->all_tracked[$id]['altitude']) > 3) $this->all_tracked[$id]['putinarchive'] = true;
311
+			if (is_int($this->all_tracked[$id]['altitude']) && abs(round($line['altitude']/100)-$this->all_tracked[$id]['altitude']) > 3) {
312
+				$this->all_tracked[$id]['putinarchive'] = true;
313
+			}
248 314
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('altitude' => round($line['altitude']/100)));
249 315
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('altitude_real' => $line['altitude']));
250 316
 			//$dataFound = true;
@@ -256,15 +322,21 @@  discard block
 block discarded – undo
256 322
 		}
257 323
 		
258 324
 		if (isset($line['heading']) && $line['heading'] != '') {
259
-		    if (is_int($this->all_tracked[$id]['heading']) && abs($this->all_tracked[$id]['heading']-round($line['heading'])) > 10) $this->all_tracked[$id]['putinarchive'] = true;
325
+		    if (is_int($this->all_tracked[$id]['heading']) && abs($this->all_tracked[$id]['heading']-round($line['heading'])) > 10) {
326
+		    	$this->all_tracked[$id]['putinarchive'] = true;
327
+		    }
260 328
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($line['heading'])));
261 329
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading_fromsrc' => true));
262 330
 		    //$dataFound = true;
263 331
   		} elseif (!isset($this->all_tracked[$id]['heading_fromsrc']) && isset($this->all_tracked[$id]['archive_latitude']) && $this->all_tracked[$id]['archive_latitude'] != $this->all_tracked[$id]['latitude'] && isset($this->all_tracked[$id]['archive_longitude']) && $this->all_tracked[$id]['archive_longitude'] != $this->all_tracked[$id]['longitude']) {
264 332
   		    $heading = $Common->getHeading($this->all_tracked[$id]['archive_latitude'],$this->all_tracked[$id]['archive_longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
265 333
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($heading)));
266
-		    if (abs($this->all_tracked[$id]['heading']-round($heading)) > 10) $this->all_tracked[$id]['putinarchive'] = true;
267
-  		    if ($globalDebug) echo "ø Calculated Heading for ".$this->all_tracked[$id]['ident']." : ".$heading."\n";
334
+		    if (abs($this->all_tracked[$id]['heading']-round($heading)) > 10) {
335
+		    	$this->all_tracked[$id]['putinarchive'] = true;
336
+		    }
337
+  		    if ($globalDebug) {
338
+  		    	echo "ø Calculated Heading for ".$this->all_tracked[$id]['ident']." : ".$heading."\n";
339
+  		    }
268 340
   		}
269 341
 		//if (isset($globalSourcesupdate) && $globalSourcesupdate != '' && isset($this->all_tracked[$id]['lastupdate']) && time()-$this->all_tracked[$id]['lastupdate'] < $globalSourcesupdate) $dataFound = false;
270 342
 
@@ -273,20 +345,31 @@  discard block
 block discarded – undo
273 345
 		    if ($this->all_tracked[$id]['addedTracker'] == 0) {
274 346
 		        if (!isset($globalDistanceIgnore['latitude']) || $this->all_tracked[$id]['longitude'] == ''  || $this->all_tracked[$id]['latitude'] == '' || (isset($globalDistanceIgnore['latitude']) && $Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude']) < $globalDistanceIgnore['distance'])) {
275 347
 			    if (!isset($this->all_tracked[$id]['forcenew']) || $this->all_tracked[$id]['forcenew'] == 0) {
276
-				if ($globalDebug) echo "Check if aircraft is already in DB...";
348
+				if ($globalDebug) {
349
+					echo "Check if aircraft is already in DB...";
350
+				}
277 351
 				$timeelapsed = microtime(true);
278 352
 				$TrackerLive = new TrackerLive($this->db);
279 353
 				if (isset($line['id'])) {
280 354
 				    $recent_ident = $TrackerLive->checkIdRecent($line['id']);
281
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
355
+				    if ($globalDebugTimeElapsed) {
356
+				    	echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
357
+				    }
282 358
 				} elseif (isset($this->all_tracked[$id]['ident']) && $this->all_tracked[$id]['ident'] != '') {
283 359
 				    $recent_ident = $TrackerLive->checkIdentRecent($this->all_tracked[$id]['ident']);
284
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
285
-				} else $recent_ident = '';
360
+				    if ($globalDebugTimeElapsed) {
361
+				    	echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
362
+				    }
363
+				} else {
364
+					$recent_ident = '';
365
+				}
286 366
 				$TrackerLive->db=null;
287 367
 
288
-				if ($globalDebug && $recent_ident == '') echo " Not in DB.\n";
289
-				elseif ($globalDebug && $recent_ident != '') echo " Already in DB.\n";
368
+				if ($globalDebug && $recent_ident == '') {
369
+					echo " Not in DB.\n";
370
+				} elseif ($globalDebug && $recent_ident != '') {
371
+					echo " Already in DB.\n";
372
+				}
290 373
 			    } else {
291 374
 				$recent_ident = '';
292 375
 				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('forcenew' => 0));
@@ -294,27 +377,41 @@  discard block
 block discarded – undo
294 377
 			    //if there was no aircraft with the same callsign within the last hour and go post it into the archive
295 378
 			    if($recent_ident == "")
296 379
 			    {
297
-				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['ident']." in archive DB : ";
380
+				if ($globalDebug) {
381
+					echo "\o/ Add ".$this->all_tracked[$id]['ident']." in archive DB : ";
382
+				}
298 383
 				//adds the spotter data for the archive
299 384
 				    $highlight = '';
300
-				    if (!isset($this->all_tracked[$id]['id'])) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident'].'-'.date('YmdHi')));
385
+				    if (!isset($this->all_tracked[$id]['id'])) {
386
+				    	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident'].'-'.date('YmdHi')));
387
+				    }
301 388
 				    $timeelapsed = microtime(true);
302 389
 				    $Tracker = new Tracker($this->db);
303 390
 				    $result = $Tracker->addTrackerData($this->all_tracked[$id]['id'], $this->all_tracked[$id]['ident'], $this->all_tracked[$id]['latitude'], $this->all_tracked[$id]['longitude'], $this->all_tracked[$id]['altitude'], $this->all_tracked[$id]['heading'], $this->all_tracked[$id]['speed'], $this->all_tracked[$id]['datetime'], $this->all_tracked[$id]['comment'],$this->all_tracked[$id]['type'],$this->all_tracked[$id]['format_source'],$this->all_tracked[$id]['source_name']);
304 391
 				    $Tracker->db = null;
305
-				    if ($globalDebug && isset($result)) echo $result."\n";
306
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
392
+				    if ($globalDebug && isset($result)) {
393
+				    	echo $result."\n";
394
+				    }
395
+				    if ($globalDebugTimeElapsed) {
396
+				    	echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
397
+				    }
307 398
 				    
308 399
 				    
309 400
 				    // Add source stat in DB
310 401
 				    $Stats = new Stats($this->db);
311 402
 				    if (!empty($this->stats)) {
312
-					if ($globalDebug) echo 'Add source stats : ';
403
+					if ($globalDebug) {
404
+						echo 'Add source stats : ';
405
+					}
313 406
 				        foreach($this->stats as $date => $data) {
314 407
 					    foreach($data as $source => $sourced) {
315 408
 					        //print_r($sourced);
316
-				    	        if (isset($sourced['polar'])) echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar_tracker',$date);
317
-				    	        if (isset($sourced['hist'])) echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist_tracker',$date);
409
+				    	        if (isset($sourced['polar'])) {
410
+				    	        	echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar_tracker',$date);
411
+				    	        }
412
+				    	        if (isset($sourced['hist'])) {
413
+				    	        	echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist_tracker',$date);
414
+				    	        }
318 415
 				    		if (isset($sourced['msg'])) {
319 416
 				    		    if (time() - $sourced['msg']['date'] > 10) {
320 417
 				    		        $nbmsg = round($sourced['msg']['nb']/(time() - $sourced['msg']['date']));
@@ -327,7 +424,9 @@  discard block
 block discarded – undo
327 424
 			    			unset($this->stats[$date]);
328 425
 			    		    }
329 426
 				    	}
330
-				    	if ($globalDebug) echo 'Done'."\n";
427
+				    	if ($globalDebug) {
428
+				    		echo 'Done'."\n";
429
+				    	}
331 430
 
332 431
 				    }
333 432
 				    $Stats->db = null;
@@ -337,12 +436,16 @@  discard block
 block discarded – undo
337 436
 				$this->all_tracked[$id]['addedTracker'] = 1;
338 437
 				//print_r($this->all_tracked[$id]);
339 438
 				if ($this->last_delete == 0 || time() - $this->last_delete > 1800) {
340
-				    if ($globalDebug) echo "---- Deleting Live Tracker data older than 9 hours...";
439
+				    if ($globalDebug) {
440
+				    	echo "---- Deleting Live Tracker data older than 9 hours...";
441
+				    }
341 442
 				    //TrackerLive->deleteLiveTrackerDataNotUpdated();
342 443
 				    $TrackerLive = new TrackerLive($this->db);
343 444
 				    $TrackerLive->deleteLiveTrackerData();
344 445
 				    $TrackerLive->db=null;
345
-				    if ($globalDebug) echo " Done\n";
446
+				    if ($globalDebug) {
447
+				    	echo " Done\n";
448
+				    }
346 449
 				    $this->last_delete = time();
347 450
 				}
348 451
 			    } else {
@@ -365,19 +468,25 @@  discard block
 block discarded – undo
365 468
 
366 469
 		    if (!$ignoreImport) {
367 470
 			if (!isset($globalDistanceIgnore['latitude']) || (isset($globalDistanceIgnore['latitude']) && $Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude']) < $globalDistanceIgnore['distance'])) {
368
-				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['ident']." from ".$this->all_tracked[$id]['format_source']." in Live DB : ";
471
+				if ($globalDebug) {
472
+					echo "\o/ Add ".$this->all_tracked[$id]['ident']." from ".$this->all_tracked[$id]['format_source']." in Live DB : ";
473
+				}
369 474
 				$timeelapsed = microtime(true);
370 475
 				$TrackerLive = new TrackerLive($this->db);
371 476
 				$result = $TrackerLive->addLiveTrackerData($this->all_tracked[$id]['id'], $this->all_tracked[$id]['ident'], $this->all_tracked[$id]['latitude'], $this->all_tracked[$id]['longitude'], $this->all_tracked[$id]['altitude'], $this->all_tracked[$id]['heading'], $this->all_tracked[$id]['speed'],$this->all_tracked[$id]['datetime'], $this->all_tracked[$id]['putinarchive'],$this->all_tracked[$id]['comment'],$this->all_tracked[$id]['type'],$this->all_tracked[$id]['noarchive'],$this->all_tracked[$id]['format_source'],$this->all_tracked[$id]['source_name'],$this->all_tracked[$id]['over_country']);
372 477
 				$TrackerLive->db = null;
373 478
 				$this->all_tracked[$id]['putinarchive'] = false;
374
-				if ($globalDebugTimeElapsed) echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
479
+				if ($globalDebugTimeElapsed) {
480
+					echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
481
+				}
375 482
 
376 483
 				// Put statistics in $this->stats variable
377 484
 				
378 485
 				if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '') {
379 486
 					$source = $this->all_tracked[$id]['source_name'];
380
-					if ($source == '') $source = $this->all_tracked[$id]['format_source'];
487
+					if ($source == '') {
488
+						$source = $this->all_tracked[$id]['format_source'];
489
+					}
381 490
 					if (!isset($this->source_location[$source])) {
382 491
 						$Location = new Source();
383 492
 						$coord = $Location->getLocationInfobySourceName($source);
@@ -398,7 +507,9 @@  discard block
 block discarded – undo
398 507
 					$stats_heading = round($stats_heading/22.5);
399 508
 					$stats_distance = $Common->distance($latitude,$longitude,$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
400 509
 					$current_date = date('Y-m-d');
401
-					if ($stats_heading == 16) $stats_heading = 0;
510
+					if ($stats_heading == 16) {
511
+						$stats_heading = 0;
512
+					}
402 513
 					if (!isset($this->stats[$current_date][$source]['polar'][1])) {
403 514
 						for ($i=0;$i<=15;$i++) {
404 515
 						    $this->stats[$current_date][$source]['polar'][$i] = 0;
@@ -416,7 +527,9 @@  discard block
 block discarded – undo
416 527
 						if (isset($this->stats[$current_date][$source]['hist'][0])) {
417 528
 						    end($this->stats[$current_date][$source]['hist']);
418 529
 						    $mini = key($this->stats[$current_date][$source]['hist'])+10;
419
-						} else $mini = 0;
530
+						} else {
531
+							$mini = 0;
532
+						}
420 533
 						for ($i=$mini;$i<=$distance;$i+=10) {
421 534
 						    $this->stats[$current_date][$source]['hist'][$i] = 0;
422 535
 						}
@@ -427,19 +540,29 @@  discard block
 block discarded – undo
427 540
 				}
428 541
 
429 542
 				$this->all_tracked[$id]['lastupdate'] = time();
430
-				if ($this->all_tracked[$id]['putinarchive']) $send = true;
431
-				if ($globalDebug) echo $result."\n";
432
-			} elseif (isset($this->all_tracked[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) echo "!! Too far -> Distance : ".$Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
543
+				if ($this->all_tracked[$id]['putinarchive']) {
544
+					$send = true;
545
+				}
546
+				if ($globalDebug) {
547
+					echo $result."\n";
548
+				}
549
+			} elseif (isset($this->all_tracked[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) {
550
+				echo "!! Too far -> Distance : ".$Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
551
+			}
433 552
 			//$this->del();
434 553
 			
435 554
 			
436 555
 			if ($this->last_delete_hourly == 0 || time() - $this->last_delete_hourly > 900) {
437
-			    if ($globalDebug) echo "---- Deleting Live Tracker data Not updated since 2 hour...";
556
+			    if ($globalDebug) {
557
+			    	echo "---- Deleting Live Tracker data Not updated since 2 hour...";
558
+			    }
438 559
 			    $TrackerLive = new TrackerLive($this->db);
439 560
 			    $TrackerLive->deleteLiveTrackerDataNotUpdated();
440 561
 			    $TrackerLive->db = null;
441 562
 			    //TrackerLive->deleteLiveTrackerData();
442
-			    if ($globalDebug) echo " Done\n";
563
+			    if ($globalDebug) {
564
+			    	echo " Done\n";
565
+			    }
443 566
 			    $this->last_delete_hourly = time();
444 567
 			}
445 568
 			
@@ -447,7 +570,9 @@  discard block
 block discarded – undo
447 570
 		    //$ignoreImport = false;
448 571
 		}
449 572
 		//if (function_exists('pcntl_fork') && $globalFork) pcntl_signal(SIGCHLD, SIG_IGN);
450
-		if ($send) return $this->all_tracked[$id];
573
+		if ($send) {
574
+			return $this->all_tracked[$id];
575
+		}
451 576
 	    }
452 577
 	}
453 578
     }
Please login to merge, or discard this patch.
require/class.MarineImport.php 1 patch
Braces   +193 added lines, -66 removed lines patch added patch discarded remove patch
@@ -53,7 +53,9 @@  discard block
 block discarded – undo
53 53
 
54 54
     public function checkAll() {
55 55
 	global $globalDebug;
56
-	if ($globalDebug) echo "Update last seen tracked data...\n";
56
+	if ($globalDebug) {
57
+		echo "Update last seen tracked data...\n";
58
+	}
57 59
 	foreach ($this->all_tracked as $key => $flight) {
58 60
 	    if (isset($this->all_tracked[$key]['id'])) {
59 61
 		//echo $this->all_tracked[$key]['id'].' - '.$this->all_tracked[$key]['latitude'].'  '.$this->all_tracked[$key]['longitude']."\n";
@@ -66,13 +68,17 @@  discard block
 block discarded – undo
66 68
     public function del() {
67 69
 	global $globalDebug, $globalNoDB, $globalNoImport;
68 70
 	// Delete old infos
69
-	if ($globalDebug) echo 'Delete old values and update latest data...'."\n";
71
+	if ($globalDebug) {
72
+		echo 'Delete old values and update latest data...'."\n";
73
+	}
70 74
 	foreach ($this->all_tracked as $key => $flight) {
71 75
     	    if (isset($flight['lastupdate'])) {
72 76
         	if ($flight['lastupdate'] < (time()-3000)) {
73 77
             	    if ((!isset($globalNoImport) || $globalNoImport !== TRUE) && (!isset($globalNoDB) || $globalNoDB !== TRUE)) {
74 78
             		if (isset($this->all_tracked[$key]['id'])) {
75
-            		    if ($globalDebug) echo "--- Delete old values with id ".$this->all_tracked[$key]['id']."\n";
79
+            		    if ($globalDebug) {
80
+            		    	echo "--- Delete old values with id ".$this->all_tracked[$key]['id']."\n";
81
+            		    }
76 82
 			    /*
77 83
 			    $MarineLive = new MarineLive();
78 84
             		    $MarineLive->deleteLiveMarineDataById($this->all_tracked[$key]['id']);
@@ -82,7 +88,9 @@  discard block
 block discarded – undo
82 88
             		    $Marine = new Marine($this->db);
83 89
             		    if ($this->all_tracked[$key]['latitude'] != '' && $this->all_tracked[$key]['longitude'] != '') {
84 90
 				$result = $Marine->updateLatestMarineData($this->all_tracked[$key]['id'],$this->all_tracked[$key]['ident'],$this->all_tracked[$key]['latitude'],$this->all_tracked[$key]['longitude'],$this->all_tracked[$key]['speed'],$this->all_tracked[$key]['datetime']);
85
-				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
91
+				if ($globalDebug && $result != 'success') {
92
+					echo '!!! ERROR : '.$result."\n";
93
+				}
86 94
 			    }
87 95
 			    // Put in archive
88 96
 //				$Marine->db = null;
@@ -96,7 +104,9 @@  discard block
 block discarded – undo
96 104
 
97 105
     public function add($line) {
98 106
 	global $globalFork, $globalDistanceIgnore, $globalDaemon, $globalDebug, $globalCoordMinChange, $globalDebugTimeElapsed, $globalCenterLatitude, $globalCenterLongitude, $globalBeta, $globalSourcesupdate, $globalAllTracked, $globalNoImport, $globalNoDB, $globalServerAPRS,$APRSMarine;
99
-	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') $globalCoordMinChange = '0.02';
107
+	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') {
108
+		$globalCoordMinChange = '0.02';
109
+	}
100 110
 	date_default_timezone_set('UTC');
101 111
 	$dataFound = false;
102 112
 	$send = false;
@@ -110,20 +120,30 @@  discard block
 block discarded – undo
110 120
 		// Increment message number
111 121
 		if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE) {
112 122
 		    $current_date = date('Y-m-d');
113
-		    if (isset($line['source_name'])) $source = $line['source_name'];
114
-		    else $source = '';
115
-		    if ($source == '' || $line['format_source'] == 'aprs') $source = $line['format_source'];
123
+		    if (isset($line['source_name'])) {
124
+		    	$source = $line['source_name'];
125
+		    } else {
126
+		    	$source = '';
127
+		    }
128
+		    if ($source == '' || $line['format_source'] == 'aprs') {
129
+		    	$source = $line['format_source'];
130
+		    }
116 131
 		    if (!isset($this->stats[$current_date][$source]['msg'])) {
117 132
 		    	$this->stats[$current_date][$source]['msg']['date'] = time();
118 133
 		    	$this->stats[$current_date][$source]['msg']['nb'] = 1;
119
-		    } else $this->stats[$current_date][$source]['msg']['nb'] += 1;
134
+		    } else {
135
+		    	$this->stats[$current_date][$source]['msg']['nb'] += 1;
136
+		    }
120 137
 		}
121 138
 		
122 139
 		
123 140
 		$Common = new Common();
124 141
 		$AIS = new AIS();
125
-	        if (!isset($line['id'])) $id = trim($line['mmsi']);
126
-	        else $id = trim($line['id']);
142
+	        if (!isset($line['id'])) {
143
+	        	$id = trim($line['mmsi']);
144
+	        } else {
145
+	        	$id = trim($line['id']);
146
+	        }
127 147
 		
128 148
 		if (!isset($this->all_tracked[$id])) {
129 149
 		    $this->all_tracked[$id] = array();
@@ -131,10 +151,16 @@  discard block
 block discarded – undo
131 151
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('ident' => '','latitude' => '', 'longitude' => '', 'speed' => '0', 'heading' => '', 'format_source' => '','source_name' => '','comment'=> '','type' => '','typeid' => '','noarchive' => false,'putinarchive' => true,'over_country' => '','mmsi' => '','status' => '','status_id' => '','imo' => '','callsign' => '','arrival_code' => '','arrival_date' => '','mmsi_type' => ''));
132 152
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('lastupdate' => time()));
133 153
 		    if (!isset($line['id'])) {
134
-			if (!isset($globalDaemon)) $globalDaemon = TRUE;
154
+			if (!isset($globalDaemon)) {
155
+				$globalDaemon = TRUE;
156
+			}
135 157
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $id.'-'.date('YmdHi')));
136
-		     } else $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $line['id']));
137
-		    if ($globalAllTracked !== FALSE) $dataFound = true;
158
+		     } else {
159
+		     	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $line['id']));
160
+		     }
161
+		    if ($globalAllTracked !== FALSE) {
162
+		    	$dataFound = true;
163
+		    }
138 164
 		}
139 165
 		
140 166
 		if (isset($line['mmsi']) && $line['mmsi'] != '' && $line['mmsi'] != $this->all_tracked[$id]['mmsi']) {
@@ -184,34 +210,49 @@  discard block
 block discarded – undo
184 210
 				$Marine = new Marine($this->db);
185 211
 				$fromsource = NULL;
186 212
 				$result = $Marine->updateIdentMarineData($this->all_tracked[$id]['id'],$this->all_tracked[$id]['ident'],$fromsource);
187
-				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
213
+				if ($globalDebug && $result != 'success') {
214
+					echo '!!! ERROR : '.$result."\n";
215
+				}
188 216
 				$Marine->db = null;
189
-				if ($globalDebugTimeElapsed) echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
217
+				if ($globalDebugTimeElapsed) {
218
+					echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
219
+				}
190 220
 			    }
191 221
 			}
192 222
 		    }
193
-		    if (!isset($this->all_tracked[$id]['id'])) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident']));
223
+		    if (!isset($this->all_tracked[$id]['id'])) {
224
+		    	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident']));
225
+		    }
194 226
 		}
195 227
 
196 228
 		if (isset($line['datetime']) && strtotime($line['datetime']) > time()-20*60 && strtotime($line['datetime']) < time()+20*60) {
197 229
 		    if (!isset($this->all_tracked[$id]['datetime']) || strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime'])) {
198 230
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => $line['datetime']));
199 231
 		    } else {
200
-				if (strtotime($line['datetime']) == strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) echo "!!! Date is the same as previous data for ".$this->all_tracked[$id]['mmsi']."\n";
201
-				elseif (strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_tracked[$id]['datetime'].") !!! for ".$this->all_tracked[$id]['hex']." - format : ".$line['format_source']."\n";
232
+				if (strtotime($line['datetime']) == strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) {
233
+					echo "!!! Date is the same as previous data for ".$this->all_tracked[$id]['mmsi']."\n";
234
+				} elseif (strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime']) && $globalDebug) {
235
+					echo "!!! Date previous latest data (".$line['datetime']." > ".$this->all_tracked[$id]['datetime'].") !!! for ".$this->all_tracked[$id]['hex']." - format : ".$line['format_source']."\n";
236
+				}
202 237
 				return '';
203 238
 		    }
204 239
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) < time()-20*60) {
205
-			if ($globalDebug) echo "!!! Date is too old ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
240
+			if ($globalDebug) {
241
+				echo "!!! Date is too old ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
242
+			}
206 243
 			return '';
207 244
 		} elseif (isset($line['datetime']) && strtotime($line['datetime']) > time()+20*60) {
208
-			if ($globalDebug) echo "!!! Date is in the future ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
245
+			if ($globalDebug) {
246
+				echo "!!! Date is in the future ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
247
+			}
209 248
 			return '';
210 249
 		} elseif (!isset($line['datetime'])) {
211 250
 			date_default_timezone_set('UTC');
212 251
 			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => date('Y-m-d H:i:s')));
213 252
 		} else {
214
-			if ($globalDebug) echo "!!! Unknow date error ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
253
+			if ($globalDebug) {
254
+				echo "!!! Unknow date error ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
255
+			}
215 256
 			return '';
216 257
 		}
217 258
 
@@ -224,14 +265,21 @@  discard block
 block discarded – undo
224 265
 		    if ($distance > 1000 && $distance < 10000) {
225 266
 			$speed = $distance/(time() - $this->all_tracked[$id]['time_last_coord']);
226 267
 			$speed = $speed*3.6;
227
-			if ($speed < 1000) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($speed)));
228
-  			if ($globalDebug) echo "ø Calculated Speed for ".$this->all_tracked[$id]['hex']." : ".$speed." - distance : ".$distance."\n";
268
+			if ($speed < 1000) {
269
+				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($speed)));
270
+			}
271
+  			if ($globalDebug) {
272
+  				echo "ø Calculated Speed for ".$this->all_tracked[$id]['hex']." : ".$speed." - distance : ".$distance."\n";
273
+  			}
229 274
 		    }
230 275
 		}
231 276
 
232 277
 	        if (isset($line['latitude']) && isset($line['longitude']) && $line['latitude'] != '' && $line['longitude'] != '' && is_numeric($line['latitude']) && is_numeric($line['longitude'])) {
233
-	    	    if (isset($this->all_tracked[$id]['time_last_coord'])) $timediff = round(time()-$this->all_tracked[$id]['time_last_coord']);
234
-	    	    else unset($timediff);
278
+	    	    if (isset($this->all_tracked[$id]['time_last_coord'])) {
279
+	    	    	$timediff = round(time()-$this->all_tracked[$id]['time_last_coord']);
280
+	    	    } else {
281
+	    	    	unset($timediff);
282
+	    	    }
235 283
 	    	    if ($this->tmd > 5 || !isset($timediff) || $timediff > 2000 || ($timediff > 30 && isset($this->all_tracked[$id]['latitude']) && isset($this->all_tracked[$id]['longitude']) && $Common->withinThreshold($timediff,$Common->distance($line['latitude'],$line['longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],'m')))) {
236 284
 			if (isset($this->all_tracked[$id]['archive_latitude']) && isset($this->all_tracked[$id]['archive_longitude']) && isset($this->all_tracked[$id]['livedb_latitude']) && isset($this->all_tracked[$id]['livedb_longitude'])) {
237 285
 			    if (!$Common->checkLine($this->all_tracked[$id]['archive_latitude'],$this->all_tracked[$id]['archive_longitude'],$this->all_tracked[$id]['livedb_latitude'],$this->all_tracked[$id]['livedb_longitude'],$line['latitude'],$line['longitude'])) {
@@ -239,22 +287,32 @@  discard block
 block discarded – undo
239 287
 				$this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
240 288
 				$this->all_tracked[$id]['putinarchive'] = true;
241 289
 				
242
-				if ($globalDebug) echo "\n".' ------- Check Country for '.$this->all_tracked[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
290
+				if ($globalDebug) {
291
+					echo "\n".' ------- Check Country for '.$this->all_tracked[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
292
+				}
243 293
 				$timeelapsed = microtime(true);
244 294
 				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
245 295
 				    $Marine = new Marine($this->db);
246 296
 				    $all_country = $Marine->getCountryFromLatitudeLongitude($line['latitude'],$line['longitude']);
247
-				    if (!empty($all_country)) $this->all_tracked[$id]['over_country'] = $all_country['iso2'];
297
+				    if (!empty($all_country)) {
298
+				    	$this->all_tracked[$id]['over_country'] = $all_country['iso2'];
299
+				    }
248 300
 				    $Marine->db = null;
249
-				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
301
+				    if ($globalDebugTimeElapsed) {
302
+				    	echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
303
+				    }
250 304
 				}
251 305
 				$this->tmd = 0;
252
-				if ($globalDebug) echo 'FOUND : '.$this->all_tracked[$id]['over_country'].' ---------------'."\n";
306
+				if ($globalDebug) {
307
+					echo 'FOUND : '.$this->all_tracked[$id]['over_country'].' ---------------'."\n";
308
+				}
253 309
 			    }
254 310
 			}
255 311
 
256 312
 			if (isset($line['latitude']) && $line['latitude'] != '' && $line['latitude'] != 0 && $line['latitude'] < 91 && $line['latitude'] > -90) {
257
-				if (!isset($this->all_tracked[$id]['archive_latitude'])) $this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
313
+				if (!isset($this->all_tracked[$id]['archive_latitude'])) {
314
+					$this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
315
+				}
258 316
 				if (!isset($this->all_tracked[$id]['livedb_latitude']) || abs($this->all_tracked[$id]['livedb_latitude']-$line['latitude']) > $globalCoordMinChange || $this->all_tracked[$id]['format_source'] == 'aprs') {
259 317
 				    $this->all_tracked[$id]['livedb_latitude'] = $line['latitude'];
260 318
 				    $dataFound = true;
@@ -263,8 +321,12 @@  discard block
 block discarded – undo
263 321
 				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('latitude' => $line['latitude']));
264 322
 			}
265 323
 			if (isset($line['longitude']) && $line['longitude'] != '' && $line['longitude'] != 0 && $line['longitude'] < 360 && $line['longitude'] > -180) {
266
-			    if ($line['longitude'] > 180) $line['longitude'] = $line['longitude'] - 360;
267
-				if (!isset($this->all_tracked[$id]['archive_longitude'])) $this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
324
+			    if ($line['longitude'] > 180) {
325
+			    	$line['longitude'] = $line['longitude'] - 360;
326
+			    }
327
+				if (!isset($this->all_tracked[$id]['archive_longitude'])) {
328
+					$this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
329
+				}
268 330
 				if (!isset($this->all_tracked[$id]['livedb_longitude']) || abs($this->all_tracked[$id]['livedb_longitude']-$line['longitude']) > $globalCoordMinChange || $this->all_tracked[$id]['format_source'] == 'aprs') {
269 331
 				    $this->all_tracked[$id]['livedb_longitude'] = $line['longitude'];
270 332
 				    $dataFound = true;
@@ -282,7 +344,9 @@  discard block
 block discarded – undo
282 344
 		    }
283 345
 		}
284 346
 		if (isset($line['last_update']) && $line['last_update'] != '') {
285
-		    if (isset($this->all_tracked[$id]['last_update']) && $this->all_tracked[$id]['last_update'] != $line['last_update']) $dataFound = true;
347
+		    if (isset($this->all_tracked[$id]['last_update']) && $this->all_tracked[$id]['last_update'] != $line['last_update']) {
348
+		    	$dataFound = true;
349
+		    }
286 350
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('last_update' => $line['last_update']));
287 351
 		}
288 352
 		if (isset($line['format_source']) && $line['format_source'] != '') {
@@ -312,15 +376,21 @@  discard block
 block discarded – undo
312 376
 		}
313 377
 		
314 378
 		if (isset($line['heading']) && $line['heading'] != '') {
315
-		    if (is_int($this->all_tracked[$id]['heading']) && abs($this->all_tracked[$id]['heading']-round($line['heading'])) > 10) $this->all_tracked[$id]['putinarchive'] = true;
379
+		    if (is_int($this->all_tracked[$id]['heading']) && abs($this->all_tracked[$id]['heading']-round($line['heading'])) > 10) {
380
+		    	$this->all_tracked[$id]['putinarchive'] = true;
381
+		    }
316 382
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($line['heading'])));
317 383
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading_fromsrc' => true));
318 384
 		    //$dataFound = true;
319 385
   		} elseif (!isset($this->all_tracked[$id]['heading_fromsrc']) && isset($this->all_tracked[$id]['archive_latitude']) && $this->all_tracked[$id]['archive_latitude'] != $this->all_tracked[$id]['latitude'] && isset($this->all_tracked[$id]['archive_longitude']) && $this->all_tracked[$id]['archive_longitude'] != $this->all_tracked[$id]['longitude']) {
320 386
   		    $heading = $Common->getHeading($this->all_tracked[$id]['archive_latitude'],$this->all_tracked[$id]['archive_longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
321 387
 		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($heading)));
322
-		    if (abs($this->all_tracked[$id]['heading']-round($heading)) > 10) $this->all_tracked[$id]['putinarchive'] = true;
323
-  		    if ($globalDebug) echo "ø Calculated Heading for ".$this->all_tracked[$id]['ident']." : ".$heading."\n";
388
+		    if (abs($this->all_tracked[$id]['heading']-round($heading)) > 10) {
389
+		    	$this->all_tracked[$id]['putinarchive'] = true;
390
+		    }
391
+  		    if ($globalDebug) {
392
+  		    	echo "ø Calculated Heading for ".$this->all_tracked[$id]['ident']." : ".$heading."\n";
393
+  		    }
324 394
   		}
325 395
 		//if (isset($globalSourcesupdate) && $globalSourcesupdate != '' && isset($this->all_tracked[$id]['lastupdate']) && time()-$this->all_tracked[$id]['lastupdate'] < $globalSourcesupdate) $dataFound = false;
326 396
 
@@ -332,23 +402,38 @@  discard block
 block discarded – undo
332 402
 		        if (!isset($globalDistanceIgnore['latitude']) || $this->all_tracked[$id]['longitude'] == ''  || $this->all_tracked[$id]['latitude'] == '' || (isset($globalDistanceIgnore['latitude']) && $Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude']) < $globalDistanceIgnore['distance'])) {
333 403
 			    if (!isset($this->all_tracked[$id]['forcenew']) || $this->all_tracked[$id]['forcenew'] == 0) {
334 404
 				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
335
-				    if ($globalDebug) echo "Check if aircraft is already in DB...";
405
+				    if ($globalDebug) {
406
+				    	echo "Check if aircraft is already in DB...";
407
+				    }
336 408
 				    $timeelapsed = microtime(true);
337 409
 				    $MarineLive = new MarineLive($this->db);
338 410
 				    if (isset($line['id'])) {
339 411
 					$recent_ident = $MarineLive->checkIdRecent($line['id']);
340
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
412
+					if ($globalDebugTimeElapsed) {
413
+						echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
414
+					}
341 415
 				    } elseif (isset($this->all_tracked[$id]['mmsi']) && $this->all_tracked[$id]['mmsi'] != '') {
342 416
 					$recent_ident = $MarineLive->checkMMSIRecent($this->all_tracked[$id]['mmsi']);
343
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
417
+					if ($globalDebugTimeElapsed) {
418
+						echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
419
+					}
344 420
 				    } elseif (isset($this->all_tracked[$id]['ident']) && $this->all_tracked[$id]['ident'] != '') {
345 421
 					$recent_ident = $MarineLive->checkIdentRecent($this->all_tracked[$id]['ident']);
346
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
347
-				    } else $recent_ident = '';
422
+					if ($globalDebugTimeElapsed) {
423
+						echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
424
+					}
425
+				    } else {
426
+				    	$recent_ident = '';
427
+				    }
348 428
 				    $MarineLive->db=null;
349
-				    if ($globalDebug && $recent_ident == '') echo " Not in DB.\n";
350
-				    elseif ($globalDebug && $recent_ident != '') echo " Already in DB.\n";
351
-				} else $recent_ident = '';
429
+				    if ($globalDebug && $recent_ident == '') {
430
+				    	echo " Not in DB.\n";
431
+				    } elseif ($globalDebug && $recent_ident != '') {
432
+				    	echo " Already in DB.\n";
433
+				    }
434
+				} else {
435
+					$recent_ident = '';
436
+				}
352 437
 			    } else {
353 438
 				$recent_ident = '';
354 439
 				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('forcenew' => 0));
@@ -356,30 +441,44 @@  discard block
 block discarded – undo
356 441
 			    //if there was no aircraft with the same callsign within the last hour and go post it into the archive
357 442
 			    if($recent_ident == "" && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '')
358 443
 			    {
359
-				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['mmsi']." in archive DB : ";
444
+				if ($globalDebug) {
445
+					echo "\o/ Add ".$this->all_tracked[$id]['mmsi']." in archive DB : ";
446
+				}
360 447
 				//adds the spotter data for the archive
361 448
 				    $highlight = '';
362
-				    if (!isset($this->all_tracked[$id]['id'])) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['mmsi'].'-'.date('YmdHi')));
449
+				    if (!isset($this->all_tracked[$id]['id'])) {
450
+				    	$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['mmsi'].'-'.date('YmdHi')));
451
+				    }
363 452
 				    if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
364 453
 					if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
365 454
 					    $timeelapsed = microtime(true);
366 455
 					    $Marine = new Marine($this->db);
367 456
 					    $result = $Marine->addMarineData($this->all_tracked[$id]['id'], $this->all_tracked[$id]['ident'], $this->all_tracked[$id]['latitude'], $this->all_tracked[$id]['longitude'], $this->all_tracked[$id]['heading'], $this->all_tracked[$id]['speed'], $this->all_tracked[$id]['datetime'], $this->all_tracked[$id]['mmsi'], $this->all_tracked[$id]['type'],$this->all_tracked[$id]['typeid'],$this->all_tracked[$id]['imo'],$this->all_tracked[$id]['callsign'],$this->all_tracked[$id]['arrival_code'],$this->all_tracked[$id]['arrival_date'], $this->all_tracked[$id]['status'], $this->all_tracked[$id]['status_id'],$this->all_tracked[$id]['format_source'],$this->all_tracked[$id]['source_name']);
368 457
 					    $Marine->db = null;
369
-					    if ($globalDebug && isset($result)) echo $result."\n";
370
-					    if ($globalDebugTimeElapsed) echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
458
+					    if ($globalDebug && isset($result)) {
459
+					    	echo $result."\n";
460
+					    }
461
+					    if ($globalDebugTimeElapsed) {
462
+					    	echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
463
+					    }
371 464
 					}
372 465
 				    }
373 466
 				    if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '') {
374 467
 					// Add source stat in DB
375 468
 					$Stats = new Stats($this->db);
376 469
 					if (!empty($this->stats)) {
377
-					    if ($globalDebug) echo 'Add source stats : ';
470
+					    if ($globalDebug) {
471
+					    	echo 'Add source stats : ';
472
+					    }
378 473
 				    	    foreach($this->stats as $date => $data) {
379 474
 						foreach($data as $source => $sourced) {
380 475
 					    	    //print_r($sourced);
381
-				    	    	    if (isset($sourced['polar'])) echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar_marine',$date);
382
-				    	    	    if (isset($sourced['hist'])) echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist_marine',$date);
476
+				    	    	    if (isset($sourced['polar'])) {
477
+				    	    	    	echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar_marine',$date);
478
+				    	    	    }
479
+				    	    	    if (isset($sourced['hist'])) {
480
+				    	    	    	echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist_marine',$date);
481
+				    	    	    }
383 482
 				    		    if (isset($sourced['msg'])) {
384 483
 				    			if (time() - $sourced['msg']['date'] > 10) {
385 484
 				    		    	    $nbmsg = round($sourced['msg']['nb']/(time() - $sourced['msg']['date']));
@@ -392,7 +491,9 @@  discard block
 block discarded – undo
392 491
 			    			    unset($this->stats[$date]);
393 492
 			    			}
394 493
 				    	    }
395
-				    	    if ($globalDebug) echo 'Done'."\n";
494
+				    	    if ($globalDebug) {
495
+				    	    	echo 'Done'."\n";
496
+				    	    }
396 497
 					}
397 498
 					$Stats->db = null;
398 499
 				    }
@@ -402,13 +503,17 @@  discard block
 block discarded – undo
402 503
 				$this->all_tracked[$id]['addedMarine'] = 1;
403 504
 				//print_r($this->all_tracked[$id]);
404 505
 				if ($this->last_delete == 0 || time() - $this->last_delete > 1800) {
405
-				    if ($globalDebug) echo "---- Deleting Live Marine data older than 9 hours...";
506
+				    if ($globalDebug) {
507
+				    	echo "---- Deleting Live Marine data older than 9 hours...";
508
+				    }
406 509
 				    //MarineLive->deleteLiveMarineDataNotUpdated();
407 510
 				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
408 511
 					$MarineLive = new MarineLive($this->db);
409 512
 					$MarineLive->deleteLiveMarineData();
410 513
 					$MarineLive->db=null;
411
-					if ($globalDebug) echo " Done\n";
514
+					if ($globalDebug) {
515
+						echo " Done\n";
516
+					}
412 517
 				    }
413 518
 				    $this->last_delete = time();
414 519
 				}
@@ -434,15 +539,21 @@  discard block
 block discarded – undo
434 539
 
435 540
 		    if (!$ignoreImport) {
436 541
 			if (!isset($globalDistanceIgnore['latitude']) || (isset($globalDistanceIgnore['latitude']) && $Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude']) < $globalDistanceIgnore['distance'])) {
437
-				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['ident']." from ".$this->all_tracked[$id]['format_source']." in Live DB : ";
542
+				if ($globalDebug) {
543
+					echo "\o/ Add ".$this->all_tracked[$id]['ident']." from ".$this->all_tracked[$id]['format_source']." in Live DB : ";
544
+				}
438 545
 				if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
439 546
 				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
440 547
 					$timeelapsed = microtime(true);
441 548
 					$MarineLive = new MarineLive($this->db);
442 549
 					$result = $MarineLive->addLiveMarineData($this->all_tracked[$id]['id'], $this->all_tracked[$id]['ident'], $this->all_tracked[$id]['latitude'], $this->all_tracked[$id]['longitude'], $this->all_tracked[$id]['heading'], $this->all_tracked[$id]['speed'],$this->all_tracked[$id]['datetime'], $this->all_tracked[$id]['putinarchive'],$this->all_tracked[$id]['mmsi'],$this->all_tracked[$id]['type'],$this->all_tracked[$id]['typeid'],$this->all_tracked[$id]['imo'],$this->all_tracked[$id]['callsign'],$this->all_tracked[$id]['arrival_code'],$this->all_tracked[$id]['arrival_date'],$this->all_tracked[$id]['status'],$this->all_tracked[$id]['status_id'],$this->all_tracked[$id]['noarchive'],$this->all_tracked[$id]['format_source'],$this->all_tracked[$id]['source_name'],$this->all_tracked[$id]['over_country']);
443 550
 					$MarineLive->db = null;
444
-					if ($globalDebug) echo $result."\n";
445
-					if ($globalDebugTimeElapsed) echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
551
+					if ($globalDebug) {
552
+						echo $result."\n";
553
+					}
554
+					if ($globalDebugTimeElapsed) {
555
+						echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
556
+					}
446 557
 				    }
447 558
 				}
448 559
 				if (isset($globalServerAPRS) && $globalServerAPRS && $this->all_tracked[$id]['putinarchive']) {
@@ -454,7 +565,9 @@  discard block
 block discarded – undo
454 565
 				
455 566
 				if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $line['format_source'] != 'aprs' && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '') {
456 567
 					$source = $this->all_tracked[$id]['source_name'];
457
-					if ($source == '') $source = $this->all_tracked[$id]['format_source'];
568
+					if ($source == '') {
569
+						$source = $this->all_tracked[$id]['format_source'];
570
+					}
458 571
 					if (!isset($this->source_location[$source])) {
459 572
 						$Location = new Source();
460 573
 						$coord = $Location->getLocationInfobySourceName($source);
@@ -475,7 +588,9 @@  discard block
 block discarded – undo
475 588
 					$stats_heading = round($stats_heading/22.5);
476 589
 					$stats_distance = $Common->distance($latitude,$longitude,$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
477 590
 					$current_date = date('Y-m-d');
478
-					if ($stats_heading == 16) $stats_heading = 0;
591
+					if ($stats_heading == 16) {
592
+						$stats_heading = 0;
593
+					}
479 594
 					if (!isset($this->stats[$current_date][$source]['polar'][1])) {
480 595
 						for ($i=0;$i<=15;$i++) {
481 596
 						    $this->stats[$current_date][$source]['polar'][$i] = 0;
@@ -493,7 +608,9 @@  discard block
 block discarded – undo
493 608
 						if (isset($this->stats[$current_date][$source]['hist'][0])) {
494 609
 						    end($this->stats[$current_date][$source]['hist']);
495 610
 						    $mini = key($this->stats[$current_date][$source]['hist'])+10;
496
-						} else $mini = 0;
611
+						} else {
612
+							$mini = 0;
613
+						}
497 614
 						for ($i=$mini;$i<=$distance;$i+=10) {
498 615
 						    $this->stats[$current_date][$source]['hist'][$i] = 0;
499 616
 						}
@@ -505,19 +622,27 @@  discard block
 block discarded – undo
505 622
 				
506 623
 
507 624
 				$this->all_tracked[$id]['lastupdate'] = time();
508
-				if ($this->all_tracked[$id]['putinarchive']) $send = true;
509
-			} elseif (isset($this->all_tracked[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) echo "!! Too far -> Distance : ".$Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
625
+				if ($this->all_tracked[$id]['putinarchive']) {
626
+					$send = true;
627
+				}
628
+			} elseif (isset($this->all_tracked[$id]['latitude']) && isset($globalDistanceIgnore['latitude']) && $globalDebug) {
629
+				echo "!! Too far -> Distance : ".$Common->distance($this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$globalDistanceIgnore['latitude'],$globalDistanceIgnore['longitude'])."\n";
630
+			}
510 631
 			//$this->del();
511 632
 			
512 633
 			
513 634
 			if ($this->last_delete_hourly == 0 || time() - $this->last_delete_hourly > 900) {
514 635
 			    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
515
-				if ($globalDebug) echo "---- Deleting Live Marine data Not updated since 2 hour...";
636
+				if ($globalDebug) {
637
+					echo "---- Deleting Live Marine data Not updated since 2 hour...";
638
+				}
516 639
 				$MarineLive = new MarineLive($this->db);
517 640
 				$MarineLive->deleteLiveMarineDataNotUpdated();
518 641
 				$MarineLive->db = null;
519 642
 				//MarineLive->deleteLiveMarineData();
520
-				if ($globalDebug) echo " Done\n";
643
+				if ($globalDebug) {
644
+					echo " Done\n";
645
+				}
521 646
 			    }
522 647
 			    $this->last_delete_hourly = time();
523 648
 			}
@@ -526,7 +651,9 @@  discard block
 block discarded – undo
526 651
 		    //$ignoreImport = false;
527 652
 		}
528 653
 		//if (function_exists('pcntl_fork') && $globalFork) pcntl_signal(SIGCHLD, SIG_IGN);
529
-		if ($send) return $this->all_tracked[$id];
654
+		if ($send) {
655
+			return $this->all_tracked[$id];
656
+		}
530 657
 	    }
531 658
 	}
532 659
     }
Please login to merge, or discard this patch.