update So 7. Jun 20:31:01 CEST 2020

This commit is contained in:
Robert Richter 2020-06-07 20:31:01 +02:00
parent 9ea7e220ee
commit d4fb233a4c
4 changed files with 27 additions and 25 deletions

View File

@ -251,7 +251,7 @@ module.exports = function (app, sql, uuidv4, app_cfg, passport, auth, waip, udp,
if (valid) { if (valid) {
var waip_uuid = req.body.waip_uuid; var waip_uuid = req.body.waip_uuid;
var rmld_uuid = req.body.rmld_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) { if (result) {
req.flash('successMessage', 'Rückmeldung erfolgreich gesendet, auf zum Einsatz!'); req.flash('successMessage', 'Rückmeldung erfolgreich gesendet, auf zum Einsatz!');
res.redirect('/rmld/' + waip_uuid + '/' + rmld_uuid); res.redirect('/rmld/' + waip_uuid + '/' + rmld_uuid);

View File

@ -863,15 +863,16 @@ module.exports = function (fs, bcrypt, app_cfg) {
// Benutzer-Tabelle mit Standard-Admin befuellen // Benutzer-Tabelle mit Standard-Admin befuellen
bcrypt.hash(app_cfg.global.defaultpass, app_cfg.global.saltRounds, function (err, hash) { 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', ? )`, db.run(`INSERT INTO waip_users ( user, password, permissions, ip_address ) VALUES( ?, ?, 'admin', ? )`,
app_cfg.global.defaultuser, hash, app_cfg.global.defaultuserip, function (err) { app_cfg.global.defaultuser, hash, app_cfg.global.defaultuserip,
if (err) { function (err) {
console.error(err.message); if (err) {
}; console.error(err.message);
}); };
});
}); });
}); });
}; };
return db; return db;
}; };

View File

@ -6,7 +6,6 @@ module.exports = function (db, uuidv4, app_cfg) {
// SQL-Abfragen // SQL-Abfragen
function db_einsatz_speichern(content, callback) { function db_einsatz_speichern(content, callback) {
// FIXME Einsatz nur speichern, wenn wachen fuer diesen hinterleget
content = JSON.parse(content); content = JSON.parse(content);
// uuid erzeugen und zuweisen falls nicht vorhanden // uuid erzeugen und zuweisen falls nicht vorhanden
if (!content.einsatzdaten.uuid) { if (!content.einsatzdaten.uuid) {
@ -62,7 +61,7 @@ module.exports = function (db, uuidv4, app_cfg) {
// Schleife definieren // Schleife definieren
function loop_done(waip_id) { function loop_done(waip_id) {
callback && callback(waip_id); callback && callback(waip_id);
}; };
var itemsProcessed = 0; var itemsProcessed = 0;
// Einsatzmittel zum Einsatz speichern // Einsatzmittel zum Einsatz speichern
content.alarmdaten.forEach(function (item, index, array) { content.alarmdaten.forEach(function (item, index, array) {
@ -86,7 +85,7 @@ module.exports = function (db, uuidv4, app_cfg) {
callback && callback(err); callback && callback(err);
}; };
}); });
}); });
} else { } else {
callback && callback(err); 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) { function db_einsatz_get_by_waipid(waip_id, wachen_nr, user_id, callback) {
// falls waip_id oder wachen_nur keine zahlen sind, abbruch // falls waip_id oder wachen_nur keine zahlen sind, abbruch
if (isNaN(waip_id) || isNaN(wachen_nr)) { if (isNaN(waip_id) || isNaN(wachen_nr)) {
callback && callback(null); 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 // reset_counter validieren, ansonsten default setzen
if (!(reset_counter >= 1 && reset_counter <= app_cfg.global.time_to_delete_waip)) { if (!(reset_counter >= 1 && reset_counter <= app_cfg.global.time_to_delete_waip)) {
reset_counter = app_cfg.global.default_time_for_standby; reset_counter = app_cfg.global.default_time_for_standby;
@ -559,7 +558,7 @@ module.exports = function (db, uuidv4, app_cfg) {
callback && callback(null); callback && callback(null);
}; };
}); });
}; };
function db_user_check_permission(user_obj, waip_id, callback) { function db_user_check_permission(user_obj, waip_id, callback) {
// Benutzer-Berechtigung pruefen // Benutzer-Berechtigung pruefen
@ -681,7 +680,7 @@ module.exports = function (db, uuidv4, app_cfg) {
callback && callback(all_responses); callback && callback(all_responses);
}; };
// summiertes JSON-Rueckmeldeobjekt für die angeforderte Wachennummer erstellen // 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); var tmp = JSON.stringify(item.wache_nr);
if (tmp.startsWith(wachen_nr) || wachen_nr == 0) { if (tmp.startsWith(wachen_nr) || wachen_nr == 0) {
if (item.einsatzkraft == 1) { 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_waipid: db_einsatz_get_by_waipid,
db_einsatz_get_by_uuid: db_einsatz_get_by_uuid, 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_waipid_by_uuid: db_einsatz_get_waipid_by_uuid,
db_einsatz_get_active: db_einsatz_get_active, db_einsatz_get_active: db_einsatz_get_active,
db_einsatz_get_rooms: db_einsatz_get_rooms, db_einsatz_get_rooms: db_einsatz_get_rooms,
db_einsatz_get_old: db_einsatz_get_old, db_einsatz_get_old: db_einsatz_get_old,
db_einsatz_loeschen: db_einsatz_loeschen, db_einsatz_loeschen: db_einsatz_loeschen,
db_wache_get_all: db_wache_get_all, db_wache_get_all: db_wache_get_all,
db_wache_vorhanden: db_wache_vorhanden, db_wache_vorhanden: db_wache_vorhanden,
db_tts_einsatzmittel: db_tts_einsatzmittel, db_tts_einsatzmittel: db_tts_einsatzmittel,
db_client_update_status: db_client_update_status, db_client_update_status: db_client_update_status,
db_client_get_connected: db_client_get_connected, db_client_get_connected: db_client_get_connected,
db_client_delete: db_client_delete, db_client_delete: db_client_delete,
db_client_check_waip_id: db_client_check_waip_id, db_client_check_waip_id: db_client_check_waip_id,
db_log: db_log, 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_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_set_config: db_user_set_config,
db_user_get_config: db_user_get_config, db_user_get_config: db_user_get_config,
db_user_get_all: db_user_get_all, db_user_get_all: db_user_get_all,
db_user_check_permission: db_user_check_permission, db_user_check_permission: db_user_check_permission,
db_rmld_save: db_rmld_save, 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_rmld_get_by_rmlduuid: db_rmld_get_by_rmlduuid,
db_vmtl_get_list: db_vmtl_get_list db_vmtl_get_list: db_vmtl_get_list
}; };

View File

@ -24,7 +24,8 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}; };
}); });
} else { } 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 // 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) { function rmld_speichern(rueckmeldung, host, app_id, callback) {
// TODO an api senden
if (!host == null) { if (!host == null) {
host = ' von ' + host; host = ' von ' + host;
}; };
@ -103,6 +103,8 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
callback && callback(result); 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) { function rmld_verteilen_by_uuid(waip_uuid, rmld_uuid) {