diff --git a/server/app_cfg.js b/server/app_cfg.js index e3c198a..93abd27 100644 --- a/server/app_cfg.js +++ b/server/app_cfg.js @@ -59,11 +59,7 @@ app_cfg.endpoint = { app_cfg.filter = { enabled: true, on_message_from: ['192.168.2.20', 'https://192.168.1.25:8090/api'], - remove_data: ['besonderheiten', 'strasse', 'objekt', 'objektnr', 'wachfolge', 'wgs84_x', 'wgs84_y'], - block_data: { - einsatztyp: ['Rettungseinsatz', 'Krankentransport'], - wachen_nr: [520101, 520102, 520103] - } + remove_data: ['besonderheiten', 'strasse', 'objekt', 'objektnr', 'wachfolge', 'wgs84_x', 'wgs84_y'] }; module.exports = app_cfg; \ No newline at end of file diff --git a/server/sql_cfg.js b/server/sql_cfg.js index 8d74f6a..b9c8d60 100644 --- a/server/sql_cfg.js +++ b/server/sql_cfg.js @@ -74,12 +74,11 @@ module.exports = function (fs, bcrypt, app_cfg) { // History-Tabelle erstellen db.run(`CREATE TABLE waip_history ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, - waip_id INTEGER NOT NULL, + waip_uuid TEXT, socket_id TEXT, uuid_einsatz_grunddaten TEXT, uuid_em_alarmiert TEXT, - uuid_em_weitere TEXT, - FOREIGN KEY (waip_id) REFERENCES waip_einsaetze(id) ON DELETE CASCADE ON UPDATE CASCADE)`); + uuid_em_weitere TEXT)`); // Client-Tabelle erstellen db.run(`CREATE TABLE waip_clients ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, @@ -132,8 +131,8 @@ module.exports = function (fs, bcrypt, app_cfg) { id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, waip_wachen_id INTEGER, vmtl_typ TEXT, - vmlt_account_name TEXT, - vmlt_account_group TEXT, + vmtl_account_name TEXT, + vmtl_account_group TEXT, FOREIGN KEY(waip_wachen_id) REFERENCES waip_wachen(id))`); // Twitter-Account-Tabelle erstellen db.run(`CREATE TABLE waip_tw_accounts ( diff --git a/server/sql_qry.js b/server/sql_qry.js index f8557bb..3ed19e1 100755 --- a/server/sql_qry.js +++ b/server/sql_qry.js @@ -133,19 +133,11 @@ module.exports = function (db, app_cfg) { delete missiondata.wgs84_x; delete missiondata.wgs84_y; delete missiondata.wgs84_area; - var uuid_einsatzdaten = uuidv5(JSON.stringify(missiondata), custom_namespace); - console.log(waip_id); - console.log(socket_id); + var uuid_einsatzdaten = uuidv5(JSON.stringify(missiondata), custom_namespace); // Abfrage ob zu Socket und Waip-ID bereits History-Daten hinterlegt sind - db.get(`select uuid_einsatz_grunddaten, uuid_em_alarmiert, uuid_em_weitere from waip_history where waip_id = 79`, - function (err, row) { //\'` + waip_id + `\' and socket_id like \'` + socket_id + `\'`, function (err, row) { - // FIXME Testen - console.log(err); - - console.log(JSON.stringify(row)); + db.get('select * from waip_history where waip_uuid like (select uuid from waip_einsaetze where id = ?) and socket_id like ?', [waip_id, socket_id], function (err, row) { + // uuid_einsatz_grunddaten, uuid_em_alarmiert, uuid_em_weitere if (err == null && row) { - console.log('schon hinterlegt'); - // wenn History-Daten hinterlegt sind, dann pruefen sich etwas verändert hat if (uuid_einsatzdaten !== row.uuid_einsatz_grunddaten || uuid_em_alarmiert !== row.uuid_em_alarmiert) { // Grunddaten oder alarmierte Einsatzmittel haben sich verändert, somit History veraltet und neue Alarmierung notwendig @@ -160,12 +152,12 @@ module.exports = function (db, app_cfg) { uuid_einsatz_grunddaten=\'` + uuid_einsatzdaten + `\', uuid_em_alarmiert=\'` + uuid_em_alarmiert + `\', uuid_em_weitere=\'` + uuid_em_weitere + `\' - WHERE waip_id like \'` + waip_id + `\' and socket_id like \'` + socket_id + `\'`); + WHERE waip_uuid like (select uuid from waip_einsaetze where id = \'` + waip_id + `\') and socket_id like \'` + socket_id + `\'`); } else { // wenn keine History-Daten hinterlegt sind, diese speichern - db.run(`INSERT INTO waip_history (waip_id, socket_id, uuid_einsatz_grunddaten, uuid_em_alarmiert, uuid_em_weitere) + db.run(`INSERT INTO waip_history (waip_uuid, socket_id, uuid_einsatz_grunddaten, uuid_em_alarmiert, uuid_em_weitere) VALUES ( - \'` + waip_id + `\', + (select uuid from waip_einsaetze where id = \'` + waip_id + `\'), \'` + socket_id + `\', \'` + uuid_einsatzdaten + `\', \'` + uuid_em_alarmiert + `\', diff --git a/server/waip.js b/server/waip.js index eb9c958..e800665 100755 --- a/server/waip.js +++ b/server/waip.js @@ -10,9 +10,6 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { // Einsatzmeldung in Datenbank speichern und verteilen sql.db_einsatz_speichern(einsatz_daten, function (waip_id) { sql.db_log('DEBUG', 'Neuen Einsatz mit der ID ' + waip_id + ' gespeichert.'); - - // FIXME hier ungewollte Einsaetze ggf. wieder loeschen - // nach dem Speichern anhand der waip_id die beteiligten Wachennummern zum Einsatz ermitteln sql.db_einsatz_get_rooms(waip_id, function (socket_rooms) { if (socket_rooms) {