Completed
Push — master ( 9091ef...3a8aa2 )
by Yannick
30:36
created

MarineImport::checkAll()   B

Complexity

Conditions 6
Paths 7

Size

Total Lines 13
Code Lines 8

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 6
eloc 8
nc 7
nop 0
dl 0
loc 13
rs 8.8571
c 0
b 0
f 0
1
<?php
2
require_once(dirname(__FILE__).'/class.Connection.php');
3
require_once(dirname(__FILE__).'/class.AIS.php');
4
require_once(dirname(__FILE__).'/class.Marine.php');
5
require_once(dirname(__FILE__).'/class.MarineLive.php');
6
require_once(dirname(__FILE__).'/class.MarineArchive.php');
7
require_once(dirname(__FILE__).'/class.Scheduler.php');
8
require_once(dirname(__FILE__).'/class.Translation.php');
9
require_once(dirname(__FILE__).'/class.Stats.php');
10
require_once(dirname(__FILE__).'/class.Source.php');
11
if (isset($globalServerAPRS) && $globalServerAPRS) {
12
    require_once(dirname(__FILE__).'/class.APRS.php');
13
}
14
15
class MarineImport {
16
    private $all_tracked = array();
17
    private $last_delete_hourly = 0;
18
    private $last_delete = 0;
19
    private $stats = array();
20
    private $tmd = 0;
21
    private $source_location = array();
22
    public $db = null;
23
    public $nb = 0;
24
25
    public function __construct($dbc = null) {
26
	global $globalBeta, $globalServerAPRS, $APRSMarine, $globalNoDB;
27
	if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
28
	    $Connection = new Connection($dbc);
29
	    $this->db = $Connection->db();
30
	    date_default_timezone_set('UTC');
31
	}
32
	// Get previous source stats
33
	/*
34
	$Stats = new Stats($dbc);
35
	$currentdate = date('Y-m-d');
36
	$sourcestat = $Stats->getStatsSource($currentdate);
37
	if (!empty($sourcestat)) {
38
	    foreach($sourcestat as $srcst) {
39
	    	$type = $srcst['stats_type'];
40
		if ($type == 'polar' || $type == 'hist') {
41
		    $source = $srcst['source_name'];
42
		    $data = $srcst['source_data'];
43
		    $this->stats[$currentdate][$source][$type] = json_decode($data,true);
44
	        }
45
	    }
46
	}
47
	*/
48
	if (isset($globalServerAPRS) && $globalServerAPRS) {
49
	    $APRSMarine = new APRSMarine();
50
	    //$APRSSpotter->connect();
51
	}
52
    }
53
54
    public function checkAll() {
55
	global $globalDebug, $globalNoDB;
56
	if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
57
	    if ($globalDebug) echo "Update last seen tracked data...\n";
58
	    foreach ($this->all_tracked as $key => $flight) {
59
		if (isset($this->all_tracked[$key]['id'])) {
60
		    //echo $this->all_tracked[$key]['id'].' - '.$this->all_tracked[$key]['latitude'].'  '.$this->all_tracked[$key]['longitude']."\n";
61
    		    $Marine = new Marine($this->db);
62
    		    $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']);
63
		}
64
	    }
65
	}
66
    }
67
68
    public function del() {
69
	global $globalDebug, $globalNoDB, $globalNoImport;
70
	// Delete old infos
71
	if ($globalDebug) echo 'Delete old values and update latest data...'."\n";
72
	foreach ($this->all_tracked as $key => $flight) {
73
    	    if (isset($flight['lastupdate'])) {
74
        	if ($flight['lastupdate'] < (time()-3000)) {
75
            	    if ((!isset($globalNoImport) || $globalNoImport !== TRUE) && (!isset($globalNoDB) || $globalNoDB !== TRUE)) {
76
            		if (isset($this->all_tracked[$key]['id'])) {
77
            		    if ($globalDebug) echo "--- Delete old values with id ".$this->all_tracked[$key]['id']."\n";
78
			    /*
79
			    $MarineLive = new MarineLive();
80
            		    $MarineLive->deleteLiveMarineDataById($this->all_tracked[$key]['id']);
81
			    $MarineLive->db = null;
82
			    */
83
            		    //$real_arrival = $this->arrival($key);
84
            		    $Marine = new Marine($this->db);
85
            		    if ($this->all_tracked[$key]['latitude'] != '' && $this->all_tracked[$key]['longitude'] != '') {
86
				$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']);
87
				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
88
			    }
89
			    // Put in archive
90
//				$Marine->db = null;
91
			}
92
            	    }
93
            	    unset($this->all_tracked[$key]);
94
    	        }
95
	    }
96
        }
97
    }
98
99
    public function add($line) {
100
	global $globalFork, $globalDistanceIgnore, $globalDaemon, $globalDebug, $globalCoordMinChange, $globalDebugTimeElapsed, $globalCenterLatitude, $globalCenterLongitude, $globalBeta, $globalSourcesupdate, $globalAllTracked, $globalNoImport, $globalNoDB, $globalServerAPRS,$APRSMarine;
101
	if (!isset($globalCoordMinChange) || $globalCoordMinChange == '') $globalCoordMinChange = '0.02';
102
	date_default_timezone_set('UTC');
103
	$dataFound = false;
104
	$send = false;
105
	
106
	// SBS format is CSV format
107
	if(is_array($line) && isset($line['mmsi'])) {
108
	    //print_r($line);
109
  	    if (isset($line['mmsi'])) {
110
111
		
112
		// Increment message number
113
		if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE) {
114
		    $current_date = date('Y-m-d');
115
		    if (isset($line['source_name'])) $source = $line['source_name'];
116
		    else $source = '';
117
		    if ($source == '' || $line['format_source'] == 'aprs') $source = $line['format_source'];
118
		    if (!isset($this->stats[$current_date][$source]['msg'])) {
119
		    	$this->stats[$current_date][$source]['msg']['date'] = time();
120
		    	$this->stats[$current_date][$source]['msg']['nb'] = 1;
121
		    } else $this->stats[$current_date][$source]['msg']['nb'] += 1;
122
		}
123
		
124
		
125
		$Common = new Common();
126
		$AIS = new AIS();
127
	        if (!isset($line['id'])) $id = trim($line['mmsi']);
128
	        else $id = trim($line['id']);
129
		
130
		if (!isset($this->all_tracked[$id])) {
131
		    $this->all_tracked[$id] = array();
132
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('addedMarine' => 0));
133
		    $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' => ''));
134
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('lastupdate' => time()));
135
		    if (!isset($line['id'])) {
136
			if (!isset($globalDaemon)) $globalDaemon = TRUE;
137
			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $id.'-'.date('YmdHi')));
138
		     } else $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $line['id']));
139
		    if ($globalAllTracked !== FALSE) $dataFound = true;
140
		}
141
		
142
		if (isset($line['mmsi']) && $line['mmsi'] != '' && $line['mmsi'] != $this->all_tracked[$id]['mmsi']) {
143
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('mmsi' => $line['mmsi']));
144
		    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
145
			$Marine = new Marine($this->db);
146
			$identity = $Marine->getIdentity($line['mmsi']);
147
			if (!empty($identity)) {
148
			    $this->all_tracked[$id]['ident'] = $identity['ship_name'];
149
			    $this->all_tracked[$id]['type'] = $identity['type'];
150
			}
151
			//print_r($identity);
152
			unset($Marine);
153
			//$dataFound = true;
154
		    }
155
		}
156
		if (isset($line['type_id'])) {
157
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('type' => $AIS->getShipType($line['type_id'])));
158
		}
159
		if (isset($line['type']) && $line['type'] != '') {
160
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('type' => $line['type']));
161
		}
162
		if (isset($line['mmsi_type']) && $line['mmsi_type'] != '') {
163
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('mmsi_type' => $line['mmsi_type']));
164
		}
165
		if (isset($line['imo']) && $line['imo'] != '') {
166
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('imo' => $line['imo']));
167
		}
168
		if (isset($line['callsign']) && $line['callsign'] != '') {
169
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('callsign' => $line['callsign']));
170
		}
171
		if (isset($line['arrival_code']) && $line['arrival_code'] != '') {
172
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('arrival_code' => $line['arrival_code']));
173
		}
174
		if (isset($line['arrival_date']) && $line['arrival_date'] != '') {
175
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('arrival_date' => $line['arrival_date']));
176
		}
177
178
179
		//if (isset($line['ident']) && $line['ident'] != '' && $line['ident'] != '????????' && $line['ident'] != '00000000' && ($this->all_tracked[$id]['ident'] != trim($line['ident'])) && preg_match('/^[a-zA-Z0-9-]+$/', $line['ident'])) {
180
		if (isset($line['ident']) && $line['ident'] != '' && $line['ident'] != '????????' && $line['ident'] != '00000000' && ($this->all_tracked[$id]['ident'] != trim($line['ident']))) {
181
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('ident' => trim($line['ident'])));
182
		    if ($this->all_tracked[$id]['addedMarine'] == 1) {
183
			if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
184
			    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
185
				$timeelapsed = microtime(true);
186
				$Marine = new Marine($this->db);
187
				$fromsource = NULL;
188
				$result = $Marine->updateIdentMarineData($this->all_tracked[$id]['id'],$this->all_tracked[$id]['ident'],$fromsource);
189
				if ($globalDebug && $result != 'success') echo '!!! ERROR : '.$result."\n";
190
				$Marine->db = null;
191
				if ($globalDebugTimeElapsed) echo 'Time elapsed for update identspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
192
			    }
193
			}
194
		    }
195
		    if (!isset($this->all_tracked[$id]['id'])) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('id' => $this->all_tracked[$id]['ident']));
196
		}
197
198
		if (isset($line['datetime']) && strtotime($line['datetime']) > time()-20*60 && strtotime($line['datetime']) < time()+20*60) {
199
		    if (!isset($this->all_tracked[$id]['datetime']) || strtotime($line['datetime']) > strtotime($this->all_tracked[$id]['datetime'])) {
200
			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => $line['datetime']));
201
		    } else {
202
				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";
203
				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";
204
				return '';
205
		    }
206
		} elseif (isset($line['datetime']) && strtotime($line['datetime']) < time()-20*60) {
207
			if ($globalDebug) echo "!!! Date is too old ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
208
			return '';
209
		} elseif (isset($line['datetime']) && strtotime($line['datetime']) > time()+20*60) {
210
			if ($globalDebug) echo "!!! Date is in the future ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
211
			return '';
212
		} elseif (!isset($line['datetime'])) {
213
			date_default_timezone_set('UTC');
214
			$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('datetime' => date('Y-m-d H:i:s')));
215
		} else {
216
			if ($globalDebug) echo "!!! Unknow date error ".$this->all_tracked[$id]['mmsi']." - format : ".$line['format_source']."!!!";
217
			return '';
218
		}
219
220
221
		if (isset($line['speed'])) {
222
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($line['speed'])));
223
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed_fromsrc' => true));
224
		} else if (!isset($this->all_tracked[$id]['speed_fromsrc']) && isset($this->all_tracked[$id]['time_last_coord']) && $this->all_tracked[$id]['time_last_coord'] != time() && isset($line['latitude']) && isset($line['longitude'])) {
225
		    $distance = $Common->distance($line['latitude'],$line['longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],'m');
226
		    if ($distance > 1000 && $distance < 10000) {
227
			$speed = $distance/(time() - $this->all_tracked[$id]['time_last_coord']);
228
			$speed = $speed*3.6;
229
			if ($speed < 1000) $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('speed' => round($speed)));
230
  			if ($globalDebug) echo "ø Calculated Speed for ".$this->all_tracked[$id]['hex']." : ".$speed." - distance : ".$distance."\n";
231
		    }
232
		}
233
234
	        if (isset($line['latitude']) && isset($line['longitude']) && $line['latitude'] != '' && $line['longitude'] != '' && is_numeric($line['latitude']) && is_numeric($line['longitude'])) {
235
	    	    if (isset($this->all_tracked[$id]['time_last_coord'])) $timediff = round(time()-$this->all_tracked[$id]['time_last_coord']);
236
	    	    else unset($timediff);
237
	    	    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')))) {
238
			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'])) {
239
			    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'])) {
240
				$this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
241
				$this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
242
				$this->all_tracked[$id]['putinarchive'] = true;
243
				
244
				if ($globalDebug) echo "\n".' ------- Check Country for '.$this->all_tracked[$id]['ident'].' with latitude : '.$line['latitude'].' and longitude : '.$line['longitude'].'.... ';
245
				$timeelapsed = microtime(true);
246
				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
247
				    $Marine = new Marine($this->db);
248
				    $all_country = $Marine->getCountryFromLatitudeLongitude($line['latitude'],$line['longitude']);
249
				    if (!empty($all_country)) $this->all_tracked[$id]['over_country'] = $all_country['iso2'];
250
				    $Marine->db = null;
251
				    if ($globalDebugTimeElapsed) echo 'Time elapsed for update getCountryFromlatitudeLongitude : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
252
				}
253
				$this->tmd = 0;
254
				if ($globalDebug) echo 'FOUND : '.$this->all_tracked[$id]['over_country'].' ---------------'."\n";
255
			    }
256
			}
257
258
			if (isset($line['latitude']) && $line['latitude'] != '' && $line['latitude'] != 0 && $line['latitude'] < 91 && $line['latitude'] > -90) {
259
				if (!isset($this->all_tracked[$id]['archive_latitude'])) $this->all_tracked[$id]['archive_latitude'] = $line['latitude'];
260
				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') {
261
				    $this->all_tracked[$id]['livedb_latitude'] = $line['latitude'];
262
				    $dataFound = true;
263
				    $this->all_tracked[$id]['time_last_coord'] = time();
264
				}
265
				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('latitude' => $line['latitude']));
266
			}
267
			if (isset($line['longitude']) && $line['longitude'] != '' && $line['longitude'] != 0 && $line['longitude'] < 360 && $line['longitude'] > -180) {
268
			    if ($line['longitude'] > 180) $line['longitude'] = $line['longitude'] - 360;
269
				if (!isset($this->all_tracked[$id]['archive_longitude'])) $this->all_tracked[$id]['archive_longitude'] = $line['longitude'];
270
				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') {
271
				    $this->all_tracked[$id]['livedb_longitude'] = $line['longitude'];
272
				    $dataFound = true;
273
				    $this->all_tracked[$id]['time_last_coord'] = time();
274
				}
275
				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('longitude' => $line['longitude']));
276
			}
277
278
		    } else if ($globalDebug && $timediff > 20) {
279
			$this->tmd = $this->tmd + 1;
280
			echo '!!! Too much distance in short time... for '.$this->all_tracked[$id]['ident']."\n";
281
			echo 'Time : '.$timediff.'s - Distance : '.$Common->distance($line['latitude'],$line['longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],'m')."m -";
282
			echo 'Speed : '.(($Common->distance($line['latitude'],$line['longitude'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],'m')/$timediff)*3.6)." km/h - ";
283
			echo 'Lat : '.$line['latitude'].' - long : '.$line['longitude'].' - prev lat : '.$this->all_tracked[$id]['latitude'].' - prev long : '.$this->all_tracked[$id]['longitude']." \n";
284
		    }
285
		}
286
		if (isset($line['last_update']) && $line['last_update'] != '') {
287
		    if (isset($this->all_tracked[$id]['last_update']) && $this->all_tracked[$id]['last_update'] != $line['last_update']) $dataFound = true;
288
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('last_update' => $line['last_update']));
289
		}
290
		if (isset($line['format_source']) && $line['format_source'] != '') {
291
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('format_source' => $line['format_source']));
292
		}
293
		if (isset($line['source_name']) && $line['source_name'] != '') {
294
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('source_name' => $line['source_name']));
295
		}
296
		if (isset($line['status']) && $line['status'] != '') {
297
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('status' => $line['status']));
298
		}
299
		if (isset($line['status_id']) && (!isset($this->all_tracked[$id]['status_id']) || $this->all_tracked[$id]['status_id'] != $line['status_id'])) {
300
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('status_id' => $line['status_id']));
301
		    if ($this->all_tracked[$id]['addedMarine'] == 1) {
302
			if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
303
			    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
304
				$Marine = new Marine($this->db);
305
				$Marine->updateStatusMarineData($this->all_tracked[$id]['id'],$this->all_tracked[$id]['status_id'],$this->all_tracked[$id]['status']);
306
				unset($Marine);
307
			    }
308
			}
309
		    }
310
		}
311
312
		if (isset($line['noarchive']) && $line['noarchive'] === true) {
313
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('noarchive' => true));
314
		}
315
		
316
		if (isset($line['heading']) && $line['heading'] != '') {
317
		    if (is_int($this->all_tracked[$id]['heading']) && abs($this->all_tracked[$id]['heading']-round($line['heading'])) > 10) $this->all_tracked[$id]['putinarchive'] = true;
318
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($line['heading'])));
319
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading_fromsrc' => true));
320
		    //$dataFound = true;
321
  		} 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']) {
322
  		    $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']);
323
		    $this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('heading' => round($heading)));
324
		    if (abs($this->all_tracked[$id]['heading']-round($heading)) > 10) $this->all_tracked[$id]['putinarchive'] = true;
325
  		    if ($globalDebug) echo "ø Calculated Heading for ".$this->all_tracked[$id]['ident']." : ".$heading."\n";
326
  		}
327
		//if (isset($globalSourcesupdate) && $globalSourcesupdate != '' && isset($this->all_tracked[$id]['lastupdate']) && time()-$this->all_tracked[$id]['lastupdate'] < $globalSourcesupdate) $dataFound = false;
328
329
330
331
		if ($dataFound === true && isset($this->all_tracked[$id]['mmsi'])) {
332
		    $this->all_tracked[$id]['lastupdate'] = time();
333
		    if ($this->all_tracked[$id]['addedMarine'] == 0) {
334
		        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'])) {
335
			    if (!isset($this->all_tracked[$id]['forcenew']) || $this->all_tracked[$id]['forcenew'] == 0) {
336
				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
337
				    if ($globalDebug) echo "Check if aircraft is already in DB...";
338
				    $timeelapsed = microtime(true);
339
				    $MarineLive = new MarineLive($this->db);
340
				    if (isset($line['id'])) {
341
					$recent_ident = $MarineLive->checkIdRecent($line['id']);
342
					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
343
				    } elseif (isset($this->all_tracked[$id]['mmsi']) && $this->all_tracked[$id]['mmsi'] != '') {
344
					$recent_ident = $MarineLive->checkMMSIRecent($this->all_tracked[$id]['mmsi']);
345
					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
346
				    } elseif (isset($this->all_tracked[$id]['ident']) && $this->all_tracked[$id]['ident'] != '') {
347
					$recent_ident = $MarineLive->checkIdentRecent($this->all_tracked[$id]['ident']);
348
					if ($globalDebugTimeElapsed) echo 'Time elapsed for update checkIdentRecent : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
349
				    } else $recent_ident = '';
350
				    $MarineLive->db=null;
351
				    if ($globalDebug && $recent_ident == '') echo " Not in DB.\n";
352
				    elseif ($globalDebug && $recent_ident != '') echo " Already in DB.\n";
353
				} else $recent_ident = '';
354
			    } else {
355
				$recent_ident = '';
356
				$this->all_tracked[$id] = array_merge($this->all_tracked[$id],array('forcenew' => 0));
357
			    }
358
			    //if there was no aircraft with the same callsign within the last hour and go post it into the archive
359
			    if($recent_ident == "" && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '')
360
			    {
361
				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['mmsi']." in archive DB : ";
362
				//adds the spotter data for the archive
363
				    $highlight = '';
0 ignored issues
show
Unused Code introduced by
$highlight is not used, you could remove the assignment.

This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently.

$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

Both the $myVar assignment in line 1 and the $higher assignment in line 2 are dead. The first because $myVar is never used and the second because $higher is always overwritten for every possible time line.

Loading history...
364
				    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')));
365
				    if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
366
					if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
367
					    $timeelapsed = microtime(true);
368
					    $Marine = new Marine($this->db);
369
					    $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']);
370
					    $Marine->db = null;
371
					    if ($globalDebug && isset($result)) echo $result."\n";
372
					    if ($globalDebugTimeElapsed) echo 'Time elapsed for update addspotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
373
					}
374
				    }
375
				    if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '') {
376
					// Add source stat in DB
377
					$Stats = new Stats($this->db);
378
					if (!empty($this->stats)) {
379
					    if ($globalDebug) echo 'Add source stats : ';
380
				    	    foreach($this->stats as $date => $data) {
381
						foreach($data as $source => $sourced) {
382
					    	    //print_r($sourced);
383
				    	    	    if (isset($sourced['polar'])) echo $Stats->addStatSource(json_encode($sourced['polar']),$source,'polar_marine',$date);
384
				    	    	    if (isset($sourced['hist'])) echo $Stats->addStatSource(json_encode($sourced['hist']),$source,'hist_marine',$date);
385
				    		    if (isset($sourced['msg'])) {
386
				    			if (time() - $sourced['msg']['date'] > 10) {
387
				    		    	    $nbmsg = round($sourced['msg']['nb']/(time() - $sourced['msg']['date']));
388
				    		    	    echo $Stats->addStatSource($nbmsg,$source,'msg_marine',$date);
389
			    			    	    unset($this->stats[$date][$source]['msg']);
390
			    				}
391
			    			    }
392
			    			}
393
			    			if ($date != date('Y-m-d')) {
394
			    			    unset($this->stats[$date]);
395
			    			}
396
				    	    }
397
				    	    if ($globalDebug) echo 'Done'."\n";
398
					}
399
					$Stats->db = null;
400
				    }
401
				    
402
				    $this->del();
403
				//$ignoreImport = false;
404
				$this->all_tracked[$id]['addedMarine'] = 1;
405
				//print_r($this->all_tracked[$id]);
406
				if ($this->last_delete == 0 || time() - $this->last_delete > 1800) {
407
				    if ($globalDebug) echo "---- Deleting Live Marine data older than 9 hours...";
408
				    //MarineLive->deleteLiveMarineDataNotUpdated();
409
				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
410
					$MarineLive = new MarineLive($this->db);
411
					$MarineLive->deleteLiveMarineData();
412
					$MarineLive->db=null;
413
					if ($globalDebug) echo " Done\n";
414
				    }
415
				    $this->last_delete = time();
416
				}
417
			    } elseif ($recent_ident != '') {
418
				$this->all_tracked[$id]['id'] = $recent_ident;
419
				$this->all_tracked[$id]['addedMarine'] = 1;
420
				if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
421
				    if (isset($globalDaemon) && !$globalDaemon) {
422
					$Marine = new Marine($this->db);
423
					$Marine->updateLatestMarineData($this->all_tracked[$id]['id'],$this->all_tracked[$id]['ident'],$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude'],$this->all_tracked[$id]['speed'],$this->all_tracked[$id]['datetime']);
424
					$Marine->db = null;
425
				    }
426
				}
427
				
428
			    }
429
			}
430
		    }
431
		    //adds the spotter LIVE data
432
		    if ($globalDebug) {
433
			echo 'DATA : ident : '.$this->all_tracked[$id]['ident'].' - type : '.$this->all_tracked[$id]['type'].' - Latitude : '.$this->all_tracked[$id]['latitude'].' - Longitude : '.$this->all_tracked[$id]['longitude'].' - Heading : '.$this->all_tracked[$id]['heading'].' - Speed : '.$this->all_tracked[$id]['speed']."\n";
434
		    }
435
		    $ignoreImport = false;
436
437
		    if (!$ignoreImport) {
438
			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'])) {
439
				if ($globalDebug) echo "\o/ Add ".$this->all_tracked[$id]['ident']." from ".$this->all_tracked[$id]['format_source']." in Live DB : ";
440
				if (!isset($globalNoImport) || $globalNoImport !== TRUE) {
441
				    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
442
					$timeelapsed = microtime(true);
443
					$MarineLive = new MarineLive($this->db);
444
					$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']);
445
					$MarineLive->db = null;
446
					if ($globalDebug) echo $result."\n";
447
					if ($globalDebugTimeElapsed) echo 'Time elapsed for update addlivespotterdata : '.round(microtime(true)-$timeelapsed,2).'s'."\n";
448
				    }
449
				}
450
				if (isset($globalServerAPRS) && $globalServerAPRS && $this->all_tracked[$id]['putinarchive']) {
451
				    $APRSMarine->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']);
452
				}
453
				$this->all_tracked[$id]['putinarchive'] = false;
454
455
				// Put statistics in $this->stats variable
456
				
457
				if (isset($line['sourcestats']) && $line['sourcestats'] == TRUE && $line['format_source'] != 'aprs' && $this->all_tracked[$id]['latitude'] != '' && $this->all_tracked[$id]['longitude'] != '') {
458
					$source = $this->all_tracked[$id]['source_name'];
459
					if ($source == '') $source = $this->all_tracked[$id]['format_source'];
460
					if (!isset($this->source_location[$source])) {
461
						$Location = new Source($this->db);
462
						$coord = $Location->getLocationInfobySourceName($source);
463
						if (count($coord) > 0) {
464
							$latitude = $coord[0]['latitude'];
465
							$longitude = $coord[0]['longitude'];
466
						} else {
467
							$latitude = $globalCenterLatitude;
468
							$longitude = $globalCenterLongitude;
469
						}
470
						$this->source_location[$source] = array('latitude' => $latitude,'longitude' => $longitude);
471
					} else {
472
						$latitude = $this->source_location[$source]['latitude'];
473
						$longitude = $this->source_location[$source]['longitude'];
474
					}
475
					$stats_heading = $Common->getHeading($latitude,$longitude,$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
476
					//$stats_heading = $stats_heading%22.5;
477
					$stats_heading = round($stats_heading/22.5);
478
					$stats_distance = $Common->distance($latitude,$longitude,$this->all_tracked[$id]['latitude'],$this->all_tracked[$id]['longitude']);
479
					$current_date = date('Y-m-d');
480
					if ($stats_heading == 16) $stats_heading = 0;
481
					if (!isset($this->stats[$current_date][$source]['polar'][1])) {
482
						for ($i=0;$i<=15;$i++) {
483
						    $this->stats[$current_date][$source]['polar'][$i] = 0;
484
						}
485
						$this->stats[$current_date][$source]['polar'][$stats_heading] = $stats_distance;
486
					} else {
487
						if ($this->stats[$current_date][$source]['polar'][$stats_heading] < $stats_distance) {
488
							$this->stats[$current_date][$source]['polar'][$stats_heading] = $stats_distance;
489
						}
490
					}
491
					$distance = (round($stats_distance/10)*10);
492
					//echo '$$$$$$$$$$ DISTANCE : '.$distance.' - '.$source."\n";
493
					//var_dump($this->stats);
494
					if (!isset($this->stats[$current_date][$source]['hist'][$distance])) {
495
						if (isset($this->stats[$current_date][$source]['hist'][0])) {
496
						    end($this->stats[$current_date][$source]['hist']);
497
						    $mini = key($this->stats[$current_date][$source]['hist'])+10;
498
						} else $mini = 0;
499
						for ($i=$mini;$i<=$distance;$i+=10) {
500
						    $this->stats[$current_date][$source]['hist'][$i] = 0;
501
						}
502
						$this->stats[$current_date][$source]['hist'][$distance] = 1;
503
					} else {
504
						$this->stats[$current_date][$source]['hist'][$distance] += 1;
505
					}
506
				}
507
				
508
509
				$this->all_tracked[$id]['lastupdate'] = time();
510
				if ($this->all_tracked[$id]['putinarchive']) $send = true;
511
			} 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";
512
			//$this->del();
513
			
514
			
515
			if ($this->last_delete_hourly == 0 || time() - $this->last_delete_hourly > 900) {
516
			    if (!isset($globalNoDB) || $globalNoDB !== TRUE) {
517
				if ($globalDebug) echo "---- Deleting Live Marine data Not updated since 2 hour...";
518
				$MarineLive = new MarineLive($this->db);
519
				$MarineLive->deleteLiveMarineDataNotUpdated();
520
				$MarineLive->db = null;
521
				//MarineLive->deleteLiveMarineData();
522
				if ($globalDebug) echo " Done\n";
523
			    }
524
			    $this->last_delete_hourly = time();
525
			}
526
			
527
		    }
528
		    //$ignoreImport = false;
529
		}
530
		//if (function_exists('pcntl_fork') && $globalFork) pcntl_signal(SIGCHLD, SIG_IGN);
531
		if ($send) return $this->all_tracked[$id];
532
	    }
533
	}
534
    }
535
}
536
?>
537