diff --git a/server/socket.js b/server/socket.js index 0db9cdd..6467b3c 100755 --- a/server/socket.js +++ b/server/socket.js @@ -41,12 +41,7 @@ socket_api.emit('CH01', 'me', 'test msg'); 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); //vorhanden Rückmeldungen verteilen - sql.db_get_response_for_wache(result_einsatz[0].waip_einsaetze_ID, wachen_id, function(rmld){ - console.log('vorhandene reuckmeldungen fuer die wache: ' + rmld); - if (rmld) { - waip.reuckmeldung_senden(socket.id, rmld); - }; - }); + waip.rueckmeldung_verteilen_for_client(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id); } else { sql.db_log('WAIP', 'Kein Einsatz fuer Wache ' + wachen_id + ' vorhanden, Standby'); //oder falls kein Einsatz vorhanden ist, dann diff --git a/server/waip.js b/server/waip.js index 583fb08..0338541 100755 --- a/server/waip.js +++ b/server/waip.js @@ -99,6 +99,7 @@ module.exports = function (io, sql, tw, async, app_cfg) { socket_rooms.forEach(function (rooms) { io.to(rooms.room).emit('io.response', rmld); sql.db_log('RMLD', 'Rückmeldung ' + rmld_uuid + ' für den Einsatz mit der ID ' + waip_id + ' an Raum ' + rooms.room + ' gesendet.'); + sql.db_log('RMLD', 'DEBUG: ' + JSON.stringify(rmld)); }); }; }); @@ -107,24 +108,19 @@ module.exports = function (io, sql, tw, async, app_cfg) { }); }; - function reuckmeldung_senden(socketid, rmld) { - //console.log('rueckmeldung alt: '+waip_id + ' ' + result); - //sql.db_get_einsatz_rooms(waip_id, function(data) { - // if (data) { - //data.forEach(function(row) { - // fuer jede Wache(row.room) die verbundenen Sockets(Clients) ermitteln und Einsatz verteilen - //var room_stockets = io.sockets.adapter.rooms[socketid]; - if (typeof socketid !== 'undefined') { - //Object.keys(room_stockets.sockets).forEach(function(socket_id) { - io.sockets.to(socketid).emit('io.response', rmld) - sql.db_log('WAIP', 'Rückmeldung ' + rmld + ' an Socket ' + socketid + ' gesendet'); - //}); + function rueckmeldung_verteilen_for_client(waip_id, socket_id, wachen_id) { + if (typeof socket_id !== '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.'); + 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.'); + }; + }); }; - //}); - //} else { - //sql.db_log('Fehler-WAIP', 'Fehler: Wache für waip_id ' + waip_id + ' nicht vorhanden, Rückmeldung konnte nicht verteilt werden!'); - //}; - //}); }; function tts_erstellen(app_cfg, socket_id, einsatzdaten, callback) { @@ -304,7 +300,7 @@ module.exports = function (io, sql, tw, async, app_cfg) { return { einsatz_speichern: einsatz_speichern, einsatz_verteilen: einsatz_verteilen, - reuckmeldung_senden: reuckmeldung_senden, + rueckmeldung_verteilen_for_client: rueckmeldung_verteilen_for_client, reuckmeldung_verteilen_by_uuid: reuckmeldung_verteilen_by_uuid }; }; \ No newline at end of file