mkrieger/Wachalarm-IP-Web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
Robert Richter 2020-06-07 21:31:01 +02:00
parent 8c40ceb98f
commit ffe6f467c9
3 changed files with 33 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
public/js/client_dbrd.js
View File

@ -582,4 +582,6 @@ socket.on('io.new_rmld', function (data) {
}); });
// Text anpassen // Text anpassen
resize_text(); resize_text();
}); });
// TODO Socket.on io.deleted

12
server/sql_qry.js
View File

@ -760,6 +760,17 @@ module.exports = function (db, uuidv4, app_cfg) {
}); });
}; };
function db_rmld_get_by_waipuuid(waip_uuid, callback) {
// alle Rueckmeldungen fuer einen Einsatz ermitteln
db.all(`SELECT * FROM waip_response WHERE waip_uuid like ?`, [waip_uuid], function (err, row) {
if (err == null && row) {
callback && callback(row);
} else {
callback && callback(null);
};
});
};
function db_vmtl_get_list(waip_id, callback) { function db_vmtl_get_list(waip_id, callback) {
// Pruefen ob fuer eine Wache im Einsatz ein Verteilerliste hinterlegt ist // Pruefen ob fuer eine Wache im Einsatz ein Verteilerliste hinterlegt ist
db.get(`select t.waip_wachen_id, t.tw_account_id, t.tw_account_list from waip_vmtl_tw_wachen t db.get(`select t.waip_wachen_id, t.tw_account_id, t.tw_account_list from waip_vmtl_tw_wachen t
@ -814,6 +825,7 @@ module.exports = function (db, uuidv4, app_cfg) {
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_rmld_get_by_waipuuid: db_rmld_get_by_waipuuid,
db_vmtl_get_list: db_vmtl_get_list db_vmtl_get_list: db_vmtl_get_list
}; };

32
server/waip.js
View File

@ -50,7 +50,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
}; };
function waip_verteilen(waip_id, socket, wachen_nr) { function waip_verteilen(waip_id, socket, wachen_nr) {
// Einsatzdaten für eine Wache aus Datenbank laden und an Client verteilen // Einsatzdaten für eine Wache aus Datenbank laden und an Client verteilen
var user_obj = socket.request.user; var user_obj = socket.request.user;
@ -179,7 +179,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}; };
}; };
function dbrd_verteilen(dbrd_uuid, socket) { function dbrd_verteilen(dbrd_uuid, socket) {
sql.db_einsatz_get_by_uuid(dbrd_uuid, function (einsatzdaten) { sql.db_einsatz_get_by_uuid(dbrd_uuid, function (einsatzdaten) {
if (einsatzdaten) { if (einsatzdaten) {
@ -204,10 +204,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
}; };
// TODO WAIP: Funktion um Clients "neuzustarten" (Seite remote neu laden), niedrige Prioritaet
// TODO: Funktion um Clients "neuzustarten" (Seite remote neu laden)
function tts_erstellen(app_cfg, socket_id, einsatzdaten, callback) { function tts_erstellen(app_cfg, socket_id, einsatzdaten, callback) {
// unnoetige Zeichen aus socket_id entfernen, um diese als Dateinamen zu verwenden // unnoetige Zeichen aus socket_id entfernen, um diese als Dateinamen zu verwenden
@ -282,7 +279,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
childD.stdin.end(); childD.stdin.end();
break; break;
// LINUX // LINUX
case 'linux': case 'linux':
// bash // bash
var proc = require('child_process'); var proc = require('child_process');
@ -314,7 +311,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
childD.stdin.end(); childD.stdin.end();
break; break;
// anderes OS // anderes OS
default: default:
sql.db_log('Fehler-TTS', 'TTS für dieses Server-Betriebssystem nicht verfügbar!'); sql.db_log('Fehler-TTS', 'TTS für dieses Server-Betriebssystem nicht verfügbar!');
callback && callback(null); callback && callback(null);
@ -337,7 +334,7 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
}; };
}); });
sql.db_einsatz_get_old(app_cfg.global.time_to_delete_waip, function (waip) { sql.db_einsatz_get_old(app_cfg.global.time_to_delete_waip, function (waip) {
// nach alten Einsaetzen suchen und diese ggf. loeschen // nach alten Einsaetzen suchen und diese ggf. loeschen
if (waip) { if (waip) {
@ -365,21 +362,28 @@ module.exports = function (io, sql, brk, async, app_cfg, api, proof) {
}); });
}; };
}); });
// TODO: an Dashboard senden, das der Einsatz gelöscht wurde waip.uuid
sql.db_socket_get_by_room(waip.uuid, function (socket_ids) { sql.db_socket_get_by_room(waip.uuid, function (socket_ids) {
// Dashboards trennen, deren Einsatz geloescht wurde
// TODO WAIP: testen der Dashboard-Trennen-Funktion
if (socket_ids) { if (socket_ids) {
socket_ids.forEach(function (row) { socket_ids.forEach(function (row) {
var socket = io.of('/dbrd').connected[row.socket_id]; var socket = io.of('/dbrd').connected[row.socket_id];
socket.emit('io.standby', null); socket.emit('io.deleted', null);
sql.db_log('WAIP', 'Standby an Socket ' + socket.id + ' gesendet'); sql.db_log('DBRD', 'Dashboard mit dem Socket ' + socket.id + ' getrennt, da Einsatz gelöscht.');
sql.db_client_update_status(socket, null); sql.db_client_update_status(socket, null);
}); });
}; };
)}; });
// FIXME: Rueckmeldung löschen, und vorher backup // FIXME: Rueckmeldung löschen, und vorher backup
sql.db_rmld_get_by_waipuuid(waip.uuid, function (full_rmld) {
// full_rmld in csv umwandeln
// CSV speichern in bkp-ordner
// Mail-Adressen fuer Wachen zu dieser Einsatz-ID ermitteln, siehe db_vmtl_get_list
// csv an diese Mail-Adressen per Mail senden
});
// Einsatz löschen // Einsatz löschen
sql.db_log('WAIP', 'Einsatz ' + waip.id + ' wird gelöscht');
sql.db_einsatz_loeschen(waip.id); sql.db_einsatz_loeschen(waip.id);
sql.db_log('WAIP', 'Einsatz ' + waip.id + ' gelöscht.');
}; };
}); });