From d4fb233a4ca46e710d388d6aca28a838ef259ad3 Mon Sep 17 00:00:00 2001 From: Robert Richter Date: Sun, 7 Jun 2020 20:31:01 +0200 Subject: [PATCH] update So 7. Jun 20:31:01 CEST 2020 --- server/routing.js | 2 +- server/sql_cfg.js | 13 +++++++------ server/sql_qry.js | 29 ++++++++++++++--------------- server/waip.js | 8 +++++--- 4 files changed, 27 insertions(+), 25 deletions(-) diff --git a/server/routing.js b/server/routing.js index 3e54e1f..e26a92c 100755 --- a/server/routing.js +++ b/server/routing.js @@ -251,7 +251,7 @@ module.exports = function (app, sql, uuidv4, app_cfg, passport, auth, waip, udp, if (valid) { var waip_uuid = req.body.waip_uuid; var rmld_uuid = req.body.rmld_uuid; - waip.rmld_speichern(req.body, null, function (result) { + waip.rmld_speichern(req.body, null, 'web', function (result) { if (result) { req.flash('successMessage', 'Rückmeldung erfolgreich gesendet, auf zum Einsatz!'); res.redirect('/rmld/' + waip_uuid + '/' + rmld_uuid); diff --git a/server/sql_cfg.js b/server/sql_cfg.js index 9692f4f..86d45cf 100644 --- a/server/sql_cfg.js +++ b/server/sql_cfg.js @@ -863,15 +863,16 @@ module.exports = function (fs, bcrypt, app_cfg) { // Benutzer-Tabelle mit Standard-Admin befuellen bcrypt.hash(app_cfg.global.defaultpass, app_cfg.global.saltRounds, function (err, hash) { db.run(`INSERT INTO waip_users ( user, password, permissions, ip_address ) VALUES( ?, ?, 'admin', ? )`, - app_cfg.global.defaultuser, hash, app_cfg.global.defaultuserip, function (err) { - if (err) { - console.error(err.message); - }; - }); + app_cfg.global.defaultuser, hash, app_cfg.global.defaultuserip, + function (err) { + if (err) { + console.error(err.message); + }; + }); }); }); }; return db; -}; +}; \ No newline at end of file diff --git a/server/sql_qry.js b/server/sql_qry.js index 635a03c..e4698c1 100755 --- a/server/sql_qry.js +++ b/server/sql_qry.js @@ -6,7 +6,6 @@ module.exports = function (db, uuidv4, app_cfg) { // SQL-Abfragen function db_einsatz_speichern(content, callback) { - // FIXME Einsatz nur speichern, wenn wachen fuer diesen hinterleget content = JSON.parse(content); // uuid erzeugen und zuweisen falls nicht vorhanden if (!content.einsatzdaten.uuid) { @@ -62,7 +61,7 @@ module.exports = function (db, uuidv4, app_cfg) { // Schleife definieren function loop_done(waip_id) { callback && callback(waip_id); - }; + }; var itemsProcessed = 0; // Einsatzmittel zum Einsatz speichern content.alarmdaten.forEach(function (item, index, array) { @@ -86,7 +85,7 @@ module.exports = function (db, uuidv4, app_cfg) { callback && callback(err); }; }); - }); + }); } else { callback && callback(err); }; @@ -146,7 +145,7 @@ module.exports = function (db, uuidv4, app_cfg) { }; function db_einsatz_get_by_waipid(waip_id, wachen_nr, user_id, callback) { - + // falls waip_id oder wachen_nur keine zahlen sind, abbruch if (isNaN(waip_id) || isNaN(wachen_nr)) { callback && callback(null); @@ -518,7 +517,7 @@ module.exports = function (db, uuidv4, app_cfg) { }); }; - function db_user_set_config(user_id, reset_counter, callback) { + function db_user_set_config(user_id, reset_counter, callback) { // reset_counter validieren, ansonsten default setzen if (!(reset_counter >= 1 && reset_counter <= app_cfg.global.time_to_delete_waip)) { reset_counter = app_cfg.global.default_time_for_standby; @@ -559,7 +558,7 @@ module.exports = function (db, uuidv4, app_cfg) { callback && callback(null); }; }); - }; + }; function db_user_check_permission(user_obj, waip_id, callback) { // Benutzer-Berechtigung pruefen @@ -681,7 +680,7 @@ module.exports = function (db, uuidv4, app_cfg) { callback && callback(all_responses); }; // summiertes JSON-Rueckmeldeobjekt für die angeforderte Wachennummer erstellen - rows.forEach(function (item, index, array) { + rows.forEach(function (item, index, array) { var tmp = JSON.stringify(item.wache_nr); if (tmp.startsWith(wachen_nr) || wachen_nr == 0) { if (item.einsatzkraft == 1) { @@ -781,27 +780,27 @@ module.exports = function (db, uuidv4, app_cfg) { db_einsatz_get_by_waipid: db_einsatz_get_by_waipid, db_einsatz_get_by_uuid: db_einsatz_get_by_uuid, db_einsatz_get_waipid_by_uuid: db_einsatz_get_waipid_by_uuid, - db_einsatz_get_active: db_einsatz_get_active, - db_einsatz_get_rooms: db_einsatz_get_rooms, + db_einsatz_get_active: db_einsatz_get_active, + db_einsatz_get_rooms: db_einsatz_get_rooms, db_einsatz_get_old: db_einsatz_get_old, db_einsatz_loeschen: db_einsatz_loeschen, - db_wache_get_all: db_wache_get_all, - db_wache_vorhanden: db_wache_vorhanden, - db_tts_einsatzmittel: db_tts_einsatzmittel, + db_wache_get_all: db_wache_get_all, + db_wache_vorhanden: db_wache_vorhanden, + db_tts_einsatzmittel: db_tts_einsatzmittel, db_client_update_status: db_client_update_status, db_client_get_connected: db_client_get_connected, db_client_delete: db_client_delete, db_client_check_waip_id: db_client_check_waip_id, db_log: db_log, - db_log_get_5000: db_log_get_5000, + db_log_get_5000: db_log_get_5000, db_socket_get_by_id: db_socket_get_by_id, - db_socket_get_all_to_standby: db_socket_get_all_to_standby, + db_socket_get_all_to_standby: db_socket_get_all_to_standby, db_user_set_config: db_user_set_config, db_user_get_config: db_user_get_config, db_user_get_all: db_user_get_all, db_user_check_permission: db_user_check_permission, db_rmld_save: db_rmld_save, - db_rmld_get_fuer_wache: db_rmld_get_fuer_wache, + db_rmld_get_fuer_wache: db_rmld_get_fuer_wache, db_rmld_get_by_rmlduuid: db_rmld_get_by_rmlduuid, db_vmtl_get_list: db_vmtl_get_list }; diff --git a/server/waip.js b/server/waip.js index a8aff74..ed5834d 100755 --- a/server/waip.js +++ b/server/waip.js @@ -24,7 +24,8 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) { }; }); } else { - sql.db_log('Fehler-WAIP', 'Fehler: Keine Wache für den Einsatz mit der ID ' + waip_id + ' vorhanden!'); + sql.db_log('Fehler-WAIP', 'Fehler: Keine Wache für den Einsatz mit der ID ' + waip_id + ' vorhanden! Einsatz wird gelöscht!'); + sql.db_einsatz_loeschen(waip_id); }; }); // pruefen ob für die beteiligten Wachen eine Verteiler-Liste hinterlegt ist, falls ja, Rueckmeldungs-Link senden @@ -88,8 +89,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) { }; - function rmld_speichern(rueckmeldung, host, callback) { - // TODO an api senden + function rmld_speichern(rueckmeldung, host, app_id, callback) { if (!host == null) { host = ' von ' + host; }; @@ -103,6 +103,8 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) { callback && callback(result); }; }); + api.server_to_client_new_rmld(rueckmeldung, app_id); + api.client_to_server_new_rmld(rueckmeldung, app_id); }; function rmld_verteilen_by_uuid(waip_uuid, rmld_uuid) {