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

update Mi 25. Mär 12:01:01 CET 2020

Browse Source
This commit is contained in:
Robert Richter 2020-03-25 12:01:01 +01:00
parent 146aea4d21
commit 2de1cd0f15
3 changed files with 25 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
server/socket.js
View File

@ -17,10 +17,10 @@ module.exports = function (io, sql, app_cfg, waip) {
io.on('connection', function (socket) {
sql.db_log('WAIP', 'Wachalarm von ' + socket.request.connection.remoteAddress + ' (' + socket.id + ') geoeffnet');
//zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu lädt
io.sockets.to(socket.id).emit('io.version', app_cfg.global.app_id);
//io.sockets.to(socket.id).emit('io.version', app_cfg.global.app_id);
socket.emit('io.version', app_cfg.global.app_id);
// Aufruf des Alarmmonitors einer bestimmten Wache verarbeiten
socket.on('wachen_id', function (wachen_id) {
socket.on('WAIP', function (wachen_id) {
sql.db_log('WAIP', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + socket.request.connection.remoteAddress + ' (' + socket.id + ') aufgerufen');
// prüfen ob Wachenummer in der Datenbank hinterlegt ist
sql.db_wache_vorhanden(wachen_id, function (result) {
@ -30,20 +30,26 @@ module.exports = function (io, sql, app_cfg, waip) {
socket.join(wachen_id, function () {
// Socket-ID und Client-IP in der Datenbank speichern
sql.db_client_save(socket.id, socket.request.connection.remoteAddress, wachen_id);
// prüfen ob für diese Wache ein Einsatz vorhanden ist
sql.db_einsatz_vorhanden(wachen_id, socket.request.user.id, function (result_einsatz) {
// prüfen ob für diese Wache Einsätze vorhanden sind
sql.db_einsatz_ermitteln(wachen_id, socket.request.user.id, function (result_einsatz) {
if (result_einsatz) {
console.log(result_einsatz[0].waip_einsaetze_ID);
sql.db_log('WAIP', 'Einsatz ' + result_einsatz[0].waip_einsaetze_ID + ' fuer Wache ' + wachen_id + ' vorhanden');
// nur den ersten Einsatz senden, falls mehrere vorhanden sind
var waip_id = result_einsatz[0].waip_einsaetze_ID;
sql.db_log('WAIP', 'Einsatz ' + waip_id + ' für Wache ' + wachen_id + ' vorhanden, wird jetzt an Client gesendet.');
//letzten Einsatz verteilen
waip.einsatz_verteilen(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id);
sql.db_update_client_status(socket, result_einsatz[0].waip_einsaetze_ID);
// zuvor: socket.id
waip.einsatz_verteilen(waip_id, socket.id, wachen_id);
//vorhanden Rückmeldungen verteilen
waip.rueckmeldung_verteilen_for_client(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id);
// zuvor: socket.id
waip.rueckmeldung_verteilen_for_client(waip_id, socket, wachen_id);
// in Statusüberischt speichern
sql.db_update_client_status(socket, waip_id);
} else {
sql.db_log('WAIP', 'Kein Einsatz fuer Wache ' + wachen_id + ' vorhanden, Standby');
//oder falls kein Einsatz vorhanden ist, dann
io.sockets.to(socket.id).emit('io.standby', null);
sql.db_log('WAIP', 'Kein Einsatz für Wache ' + wachen_id + ' vorhanden, gehe in Standby');
// falls kein Einsatz vorhanden ist, dann Standby senden
//io.sockets.to(socket.id).emit('io.standby', null);
socket.emit('io.standby', null);
// in Statusüberischt speichern
sql.db_update_client_status(socket, null);
};
});

4
server/sql_qry.js
View File

@ -1,7 +1,7 @@
module.exports = function(db, uuidv4, turf, app_cfg) {
// ermittelt den letzten vorhanden Einsatz zu einer Wache
function db_einsatz_vorhanden(wachen_id, user_id, callback) {
function db_einsatz_ermitteln(wachen_id, user_id, callback) {
var select_reset_counter;
var dts = app_cfg.global.default_time_for_standby;
// wenn Wachen-ID 0 ist, dann % setzen
@ -878,7 +878,7 @@ module.exports = function(db, uuidv4, turf, app_cfg) {
return {
db_einsatz_speichern: db_einsatz_speichern,
db_einsatz_laden: db_einsatz_laden,
db_einsatz_vorhanden: db_einsatz_vorhanden,
db_einsatz_ermitteln: db_einsatz_ermitteln,
db_wache_vorhanden: db_wache_vorhanden,
db_wache_id_ermitteln: db_wache_id_ermitteln,
db_wache_nr_ermitteln: db_wache_nr_ermitteln,

8
server/waip.js
View File

@ -108,13 +108,13 @@ module.exports = function (io, sql, tw, async, app_cfg) {
});
};
function rueckmeldung_verteilen_for_client(waip_id, socket_id, wachen_id) {
if (typeof socket_id !== 'undefined') {
function rueckmeldung_verteilen_for_client(waip_id, socket, wachen_id) {
if (typeof socket !== 'undefined') {
sql.db_get_response_for_wache(waip_id, wachen_id, function (rmld) {
if (rmld) {
// Rueckmeldung nur an den einen Socket senden
io.sockets.to(socket_id).emit('io.response', rmld)
sql.db_log('RMLD', 'Vorhandene Rückmeldungen an Socket ' + socket_id + ' gesendet.');
socket.emit('io.response', rmld);
sql.db_log('RMLD', 'Vorhandene Rückmeldungen an Socket ' + socket.id + ' gesendet.');
sql.db_log('RMLD', 'DEBUG: ' + JSON.stringify(rmld));
} else {
sql.db_log('RMLD', 'Keine Rückmeldungen für Einsatz-ID' + waip_id + ' und Wachen-ID ' + wachen_id + ' vorhanden.');