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

update Di 28. Apr 13:01:01 CEST 2020

Browse Source
This commit is contained in:
Robert Richter 2020-04-28 13:01:01 +02:00
parent 1366949043
commit 059c04a7c9
1 changed files with 68 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
server/socket.js
View File

@ -13,63 +13,108 @@ module.exports = function (io, sql, app_cfg, waip) {
}); });
socket_api.emit('CH01', 'me', 'test msg'); socket_api.emit('CH01', 'me', 'test msg');
// Socket.IO Server // Socket.IO Alarmmonitor
var nsp_waip = io.of('/waip'); var nsp_waip = io.of('/waip');
nsp_waip.on('connection', function (socket) { nsp_waip.on('connection', function (socket) {
// versuche Client-IP zu ermitteln
var client_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress; var client_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress;
//zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu lädt //zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu laedt
//io.sockets.to(socket.id).emit('io.version', app_cfg.global.app_id);
socket.emit('io.version', app_cfg.global.app_id); socket.emit('io.version', app_cfg.global.app_id);
// Aufruf des Alarmmonitors einer bestimmten Wache verarbeiten // Aufruf des Alarmmonitors einer bestimmten Wache verarbeiten
socket.on('WAIP', function (wachen_id) { socket.on('WAIP', function (wachen_id) {
sql.db_log('DEBUG', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + client_ip + ' (' + socket.id + ') aufgerufen.');
sql.db_log('WAIP', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + client_ip + ' (' + socket.id + ') aufgerufen');
// prüfen ob Wachenummer in der Datenbank hinterlegt ist // prüfen ob Wachenummer in der Datenbank hinterlegt ist
sql.db_wache_vorhanden(wachen_id, function (result) { sql.db_wache_vorhanden(wachen_id, function (result) {
// wenn die Wachennummer vorhanden/plausibel dann weiter // wenn die Wachennummer vorhanden/plausibel dann weiter
if (result) { if (result) {
// Socket-Room beitreiten // Socket-Room beitreiten
socket.join(wachen_id, function () { socket.join(wachen_id, function () {
// Socket-ID und Client-IP in der Datenbank speichern
//sql.db_client_save(socket.id, client_ip, wachen_id);
//sql.db_update_client_status(socket, null);
// prüfen ob für diese Wache Einsätze vorhanden sind // prüfen ob für diese Wache Einsätze vorhanden sind
sql.db_einsatz_ermitteln(wachen_id, socket.request.user.id, function (result_einsatz) { var user_id = socket.request.user.id;
sql.db_einsatz_ermitteln(wachen_id, user_id, function (result_einsatz) {
if (result_einsatz) { if (result_einsatz) {
// nur den ersten Einsatz senden, falls mehrere vorhanden sind // nur den ersten Einsatz senden, falls mehrere vorhanden sind
var waip_id = result_einsatz[0].waip_einsaetze_ID; 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.'); sql.db_log('WAIP', 'Einsatz ' + waip_id + ' für Wache ' + wachen_id + ' vorhanden, wird jetzt an Client ' + socket.id + ' gesendet.');
//letzten Einsatz verteilen //letzten Einsatz verteilen
// zuvor: socket.id
waip.einsatz_verteilen(waip_id, socket, wachen_id); waip.einsatz_verteilen(waip_id, socket, wachen_id);
//vorhanden Rückmeldungen verteilen //vorhandene Rückmeldungen verteilen
// zuvor: socket.id
waip.rueckmeldung_verteilen_for_client(waip_id, socket, wachen_id); waip.rueckmeldung_verteilen_for_client(waip_id, socket, wachen_id);
// in Statusüberischt speichern
sql.db_update_client_status(socket, waip_id);
} else { } else {
sql.db_log('WAIP', 'Kein Einsatz für Wache ' + wachen_id + ' vorhanden, gehe in Standby'); sql.db_log('WAIP', 'Kein Einsatz für Wache ' + wachen_id + ' vorhanden, gehe in Standby');
// falls kein Einsatz vorhanden ist, dann Standby senden // falls kein Einsatz vorhanden ist, dann Standby senden
//io.sockets.to(socket.id).emit('io.standby', null);
socket.emit('io.standby', null); socket.emit('io.standby', null);
// in Statusüberischt speichern
sql.db_update_client_status(socket, null);
}; };
}); });
// in Statusüberischt speichern
sql.db_update_client_status(socket, null);
}); });
} else { } else {
sql.db_log('Fehler-WAIP', 'Fehler: Wachnnummer ' + wachen_id + 'nicht vorhanden'); sql.db_log('ERROR', 'Fehler: Wachnnummer ' + wachen_id + 'nicht vorhanden!');
// io.sockets.to(socket.id).emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!');
socket.emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!'); socket.emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!');
}; };
}); });
}); });
// disconnect verarbeiten // Disconnect
socket.on('disconnect', function () { socket.on('disconnect', function () {
sql.db_log('WAIP', 'Alarmmonitor von ' + client_ip + ' (' + socket.id + ') geschlossen'); sql.db_log('DEBUG', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + client_ip + ' (' + socket.id + ') geschlossen.');
sql.db_client_delete(socket); sql.db_client_delete(socket);
}); });
}); });
// Socket.IO Dashboard
var nsp_dbrd = io.of('/dbrd');
nsp_dbrd.on('connection', function (socket) {
// versuche Client-IP zu ermitteln
var client_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress;
//zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu laedt
socket.emit('io.version', app_cfg.global.app_id);
// Aufruf des Dashboards eines bestimmten Einsatzes verarbeiten
socket.on('dbrd', function (uuid) {
sql.db_log('DEBUG', 'Dashboard ' + uuid + ' von ' + client_ip + ' (' + socket.id + ') aufgerufen.');
// prüfen ob Dashboard/Einsatz vorhanden
sql.db_einsatz_uuid_vorhanden(uuid, function(dbrd_uuid) {
// wenn die Wachennummer vorhanden/plausibel dann weiter
if (result) {
// Socket-Room beitreiten
socket.join(wachen_id, function () {
// prüfen ob für diese Wache Einsätze vorhanden sind
var user_id = socket.request.user.id;
sql.db_einsatz_ermitteln(wachen_id, user_id, function (result_einsatz) {
if (result_einsatz) {
// 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 ' + socket.id + ' gesendet.');
//letzten Einsatz verteilen
waip.einsatz_verteilen(waip_id, socket, wachen_id);
//vorhandene Rückmeldungen verteilen
waip.rueckmeldung_verteilen_for_client(waip_id, socket, wachen_id);
} else {
sql.db_log('WAIP', 'Kein Einsatz für Wache ' + wachen_id + ' vorhanden, gehe in Standby');
// falls kein Einsatz vorhanden ist, dann Standby senden
socket.emit('io.standby', null);
};
});
// in Statusüberischt speichern
sql.db_update_client_status(socket, null);
});
} else {
sql.db_log('ERROR', 'Fehler: Dashboard ' + dbrd_uuid + 'nicht (mehr) vorhanden!');
socket.emit('io.error', 'Fehler: Dashboard \'' + dbrd_uuid + '\' nicht (mehr) vorhanden!');
};
});
});
// Disconnect
socket.on('disconnect', function () {
sql.db_log('DEBUG', 'Dashboard ' + uuid + ' von ' + client_ip + ' (' + socket.id + ') geschlossen.');
sql.db_client_delete(socket);
});
});
}; };