1
|
|
|
<?php |
2
|
|
|
require_once(dirname(__FILE__).'/class.Connection.php'); |
3
|
|
|
require_once(dirname(__FILE__).'/class.Spotter.php'); |
4
|
|
|
require_once(dirname(__FILE__).'/class.SpotterLive.php'); |
5
|
|
|
require_once(dirname(__FILE__).'/class.SpotterArchive.php'); |
6
|
|
|
require_once(dirname(__FILE__).'/class.Scheduler.php'); |
7
|
|
|
require_once(dirname(__FILE__).'/class.Translation.php'); |
8
|
|
|
|
9
|
|
|
class SpotterServer { |
10
|
|
|
public $dbs = null; |
11
|
|
|
|
12
|
|
|
function __construct($dbs = null) { |
|
|
|
|
13
|
|
|
if ($dbs === null) { |
14
|
|
|
$Connection = new Connection(null,'server'); |
15
|
|
|
$this->dbs = $Connection->dbs; |
16
|
|
|
$query = "CREATE TABLE IF NOT EXISTS `spotter_temp` ( `id_data` INT NOT NULL AUTO_INCREMENT , `id_user` INT NOT NULL , `datetime` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP , `hex` VARCHAR(20) NOT NULL , `ident` VARCHAR(20) NULL , `latitude` FLOAT NULL , `longitude` FLOAT NULL , `verticalrate` INT NULL , `speed` INT NULL , `squawk` INT NULL , `altitude` INT NULL , `heading` INT NULL , `registration` VARCHAR(10) NULL , `aircraft_icao` VARCHAR(10) NULL , `waypoints` VARCHAR(255) NULL , `noarchive` BOOLEAN NOT NULL DEFAULT FALSE, `id_source` INT NOT NULL DEFAULT '1', `format_source` VARCHAR(25) NULL, `source_name` VARCHAR(25) NULL, `over_country` VARCHAR(255) NULL, PRIMARY KEY (`id_data`) ) ENGINE = MEMORY;"; |
17
|
|
|
try { |
18
|
|
|
$sth = $this->dbs['server']->exec($query); |
|
|
|
|
19
|
|
|
} catch(PDOException $e) { |
20
|
|
|
return "error : ".$e->getMessage(); |
|
|
|
|
21
|
|
|
} |
22
|
|
|
} |
23
|
|
|
} |
24
|
|
|
|
25
|
|
|
function checkAll() { |
|
|
|
|
26
|
|
|
return true; |
27
|
|
|
} |
28
|
|
|
|
29
|
|
|
function add($line) { |
|
|
|
|
30
|
|
|
global $globalDebug, $globalServerUserID; |
31
|
|
|
date_default_timezone_set('UTC'); |
32
|
|
|
//if (isset($line['format_source']) && ($line['format_source'] === 'sbs' || $line['format_source'] === 'tsv' || $line['format_source'] === 'raw' || $line['format_source'] === 'deltadbtxt' || $line['format_source'] === 'aprs')) { |
33
|
|
|
if (isset($line['format_source'])) { |
34
|
|
|
if(is_array($line) && isset($line['hex'])) { |
35
|
|
|
if ($line['hex'] != '' && $line['hex'] != '00000' && $line['hex'] != '000000' && $line['hex'] != '111111' && ctype_xdigit($line['hex']) && strlen($line['hex']) === 6) { |
36
|
|
|
$data['hex'] = trim($line['hex']); |
|
|
|
|
37
|
|
|
if (preg_match('/^(\d{4}(?:\-\d{2}){2} \d{2}(?:\:\d{2}){2})$/',$line['datetime'])) { |
38
|
|
|
$data['datetime'] = $line['datetime']; |
39
|
|
|
} else $data['datetime'] = date('Y-m-d H:i:s'); |
40
|
|
|
if (!isset($line['aircraft_icao'])) { |
41
|
|
|
$Spotter = new Spotter(); |
42
|
|
|
$aircraft_icao = $Spotter->getAllAircraftType($data['hex']); |
43
|
|
|
$Spotter->db = null; |
44
|
|
|
if ($aircraft_icao == '' && isset($line['aircraft_type'])) { |
45
|
|
|
if ($line['aircraft_type'] == 'PARA_GLIDER') $aircraft_icao = 'GLID'; |
46
|
|
|
elseif ($line['aircraft_type'] == 'HELICOPTER_ROTORCRAFT') $aircraft_icao = 'UHEL'; |
47
|
|
|
elseif ($line['aircraft_type'] == 'TOW_PLANE') $aircraft_icao = 'TOWPLANE'; |
48
|
|
|
elseif ($line['aircraft_type'] == 'POWERED_AIRCRAFT') $aircraft_icao = 'POWAIRC'; |
49
|
|
|
} |
50
|
|
|
$data['aircraft_icao'] = $aircraft_icao; |
51
|
|
|
} else $data['aircraft_icao'] = $line['aircraft_icao']; |
52
|
|
|
//if ($globalDebug) echo "*********** New aircraft hex : ".$data['hex']." ***********\n"; |
53
|
|
|
} |
54
|
|
|
if (isset($line['registration']) && $line['registration'] != '') { |
55
|
|
|
$data['registration'] = $line['registration']; |
|
|
|
|
56
|
|
|
} else $data['registration'] = null; |
57
|
|
|
if (isset($line['waypoints']) && $line['waypoints'] != '') { |
58
|
|
|
$data['waypoints'] = $line['waypoints']; |
59
|
|
|
} else $data['waypoints'] = null; |
60
|
|
|
if (isset($line['ident']) && $line['ident'] != '' && $line['ident'] != '????????' && $line['ident'] != '00000000' && preg_match('/^[a-zA-Z0-9]+$/', $line['ident'])) { |
61
|
|
|
$data['ident'] = trim($line['ident']); |
62
|
|
|
} else $data['ident'] = null; |
63
|
|
|
if (isset($line['latitude']) && isset($line['longitude']) && $line['latitude'] != '' && $line['longitude'] != '') { |
64
|
|
|
if (isset($line['latitude']) && $line['latitude'] != '' && $line['latitude'] != 0 && $line['latitude'] < 91 && $line['latitude'] > -90) { |
65
|
|
|
$data['latitude'] = $line['latitude']; |
66
|
|
|
} else $data['latitude'] = null; |
67
|
|
|
if (isset($line['longitude']) && $line['longitude'] != '' && $line['longitude'] != 0 && $line['longitude'] < 360 && $line['longitude'] > -180) { |
68
|
|
|
if ($line['longitude'] > 180) $line['longitude'] = $line['longitude'] - 360; |
69
|
|
|
$data['longitude'] = $line['longitude']; |
70
|
|
|
} else $data['longitude'] = null; |
71
|
|
|
} else { |
72
|
|
|
$data['latitude'] = null; |
73
|
|
|
$data['longitude'] = null; |
74
|
|
|
} |
75
|
|
|
if (isset($line['verticalrate']) && $line['verticalrate'] != '') { |
76
|
|
|
$data['verticalrate'] = $line['verticalrate']; |
77
|
|
|
} else $data['verticalrate'] = null; |
78
|
|
|
if (isset($line['emergency']) && $line['emergency'] != '') { |
79
|
|
|
$data['emergency'] = $line['emergency']; |
80
|
|
|
} else $data['emergency'] = null; |
81
|
|
|
if (isset($line['ground']) && $line['ground'] != '') { |
82
|
|
|
$data['ground'] = $line['ground']; |
83
|
|
|
} else $data['ground'] = null; |
84
|
|
|
if (isset($line['speed']) && $line['speed'] != '') { |
85
|
|
|
$data['speed'] = round($line['speed']); |
86
|
|
|
} else $data['speed'] = null; |
87
|
|
|
if (isset($line['squawk']) && $line['squawk'] != '') { |
88
|
|
|
$data['squawk'] = $line['squawk']; |
89
|
|
|
} else $data['squawk'] = null; |
90
|
|
|
if (isset($line['altitude']) && $line['altitude'] != '') { |
91
|
|
|
$data['altitude'] = round($line['altitude']); |
92
|
|
|
} else $data['altitude'] = null; |
93
|
|
|
if (isset($line['heading']) && $line['heading'] != '') { |
94
|
|
|
$data['heading'] = round($line['heading']); |
95
|
|
|
} else $data['heading'] = null; |
96
|
|
|
if (isset($line['source_name']) && $line['source_name'] != '') { |
97
|
|
|
$data['source_name'] = $line['source_name']; |
98
|
|
|
} else $data['source_name'] = null; |
99
|
|
|
if (isset($line['over_country']) && $line['over_country'] != '') { |
100
|
|
|
$data['over_country'] = $line['over_country']; |
101
|
|
|
} else $data['over_country'] = null; |
102
|
|
|
if (isset($line['noarchive']) && $line['noarchive']) { |
103
|
|
|
$data['noarchive'] = true; |
104
|
|
|
} else $data['noarchive'] = false; |
105
|
|
|
$data['format_source'] = $line['format_source']; |
106
|
|
|
if (isset($line['id_source'])) $id_source = $line['id_source']; |
107
|
|
|
if (isset($data['hex'])) { |
108
|
|
|
echo '.'; |
109
|
|
|
$id_user = $globalServerUserID; |
110
|
|
|
if ($id_user == NULL) $id_user = 1; |
111
|
|
|
if (!isset($id_source)) $id_source = 1; |
112
|
|
|
$query = 'INSERT INTO spotter_temp (id_user,datetime,hex,ident,latitude,longitude,verticalrate,speed,squawk,altitude,heading,registration,aircraft_icao,waypoints,id_source,noarchive,format_source,source_name,over_country) VALUES (:id_user,:datetime,:hex,:ident,:latitude,:longitude,:verticalrate,:speed,:squawk,:altitude,:heading,:registration,:aircraft_icao,:waypoints,:id_source,:noarchive, :format_source, :source_name, :over_country)'; |
113
|
|
|
$query_values = array(':id_user' => $id_user,':datetime' => $data['datetime'],':hex' => $data['hex'],':ident' => $data['ident'],':latitude' => $data['latitude'],':longitude' => $data['longitude'],':verticalrate' => $data['verticalrate'],':speed' => $data['speed'],':squawk' => $data['squawk'],':altitude' => $data['altitude'],':heading' => $data['heading'],':registration' => $data['registration'],':aircraft_icao' => $data['aircraft_icao'],':waypoints' => $data['waypoints'],':id_source' => $id_source,':noarchive' => $data['noarchive'], ':format_source' => $data['format_source'], ':source_name' => $data['source_name'],':over_country' => $data['over_country']); |
114
|
|
|
try { |
115
|
|
|
$sth = $this->dbs['server']->prepare($query); |
116
|
|
|
$sth->execute($query_values); |
117
|
|
|
} catch(PDOException $e) { |
118
|
|
|
return "error : ".$e->getMessage(); |
119
|
|
|
} |
120
|
|
|
} |
121
|
|
|
} |
122
|
|
|
} |
123
|
|
|
} |
124
|
|
|
} |
125
|
|
|
?> |
126
|
|
|
|
Adding explicit visibility (
private
,protected
, orpublic
) is generally recommend to communicate to other developers how, and from where this method is intended to be used.