update Di 16. Jun 22:01:02 CEST 2020

This commit is contained in:
Robert Richter 2020-06-16 22:01:02 +02:00
parent b45f838267
commit 604a95a190
4 changed files with 11 additions and 27 deletions

View File

@ -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;

View File

@ -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 (

View File

@ -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 + `\',

View File

@ -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) {