update Di 24. Mär 15:31:01 CET 2020
This commit is contained in:
parent
c92f74cab6
commit
272bddb3cc
@ -41,12 +41,7 @@ socket_api.emit('CH01', 'me', 'test msg');
|
|||||||
waip.einsatz_verteilen(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id);
|
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);
|
sql.db_update_client_status(socket, result_einsatz[0].waip_einsaetze_ID);
|
||||||
//vorhanden Rückmeldungen verteilen
|
//vorhanden Rückmeldungen verteilen
|
||||||
sql.db_get_response_for_wache(result_einsatz[0].waip_einsaetze_ID, wachen_id, function(rmld){
|
waip.rueckmeldung_verteilen_for_client(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id);
|
||||||
console.log('vorhandene reuckmeldungen fuer die wache: ' + rmld);
|
|
||||||
if (rmld) {
|
|
||||||
waip.reuckmeldung_senden(socket.id, rmld);
|
|
||||||
};
|
|
||||||
});
|
|
||||||
} else {
|
} else {
|
||||||
sql.db_log('WAIP', 'Kein Einsatz fuer Wache ' + wachen_id + ' vorhanden, Standby');
|
sql.db_log('WAIP', 'Kein Einsatz fuer Wache ' + wachen_id + ' vorhanden, Standby');
|
||||||
//oder falls kein Einsatz vorhanden ist, dann
|
//oder falls kein Einsatz vorhanden ist, dann
|
||||||
|
|||||||
@ -99,6 +99,7 @@ module.exports = function (io, sql, tw, async, app_cfg) {
|
|||||||
socket_rooms.forEach(function (rooms) {
|
socket_rooms.forEach(function (rooms) {
|
||||||
io.to(rooms.room).emit('io.response', rmld);
|
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', '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) {
|
function rueckmeldung_verteilen_for_client(waip_id, socket_id, wachen_id) {
|
||||||
//console.log('rueckmeldung alt: '+waip_id + ' ' + result);
|
if (typeof socket_id !== 'undefined') {
|
||||||
//sql.db_get_einsatz_rooms(waip_id, function(data) {
|
sql.db_get_response_for_wache(waip_id, wachen_id, function (rmld) {
|
||||||
// if (data) {
|
if (rmld) {
|
||||||
//data.forEach(function(row) {
|
// Rueckmeldung nur an den einen Socket senden
|
||||||
// fuer jede Wache(row.room) die verbundenen Sockets(Clients) ermitteln und Einsatz verteilen
|
io.sockets.to(socket_id).emit('io.response', rmld)
|
||||||
//var room_stockets = io.sockets.adapter.rooms[socketid];
|
sql.db_log('RMLD', 'Vorhandene Rückmeldungen an Socket ' + socket_id + ' gesendet.');
|
||||||
if (typeof socketid !== 'undefined') {
|
sql.db_log('RMLD', 'DEBUG: ' + JSON.stringify(rmld));
|
||||||
//Object.keys(room_stockets.sockets).forEach(function(socket_id) {
|
} else {
|
||||||
io.sockets.to(socketid).emit('io.response', rmld)
|
sql.db_log('RMLD', 'Keine Rückmeldungen für Einsatz-ID' + waip_id + ' und Wachen-ID ' + wachen_id + ' vorhanden.');
|
||||||
sql.db_log('WAIP', 'Rückmeldung ' + rmld + ' an Socket ' + socketid + ' gesendet');
|
};
|
||||||
//});
|
});
|
||||||
};
|
};
|
||||||
//});
|
|
||||||
//} 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) {
|
function tts_erstellen(app_cfg, socket_id, einsatzdaten, callback) {
|
||||||
@ -304,7 +300,7 @@ module.exports = function (io, sql, tw, async, app_cfg) {
|
|||||||
return {
|
return {
|
||||||
einsatz_speichern: einsatz_speichern,
|
einsatz_speichern: einsatz_speichern,
|
||||||
einsatz_verteilen: einsatz_verteilen,
|
einsatz_verteilen: einsatz_verteilen,
|
||||||
reuckmeldung_senden: reuckmeldung_senden,
|
rueckmeldung_verteilen_for_client: rueckmeldung_verteilen_for_client,
|
||||||
reuckmeldung_verteilen_by_uuid: reuckmeldung_verteilen_by_uuid
|
reuckmeldung_verteilen_by_uuid: reuckmeldung_verteilen_by_uuid
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
Loading…
Reference in New Issue
Block a user