diff --git a/misc/bkp/0815.csv b/misc/bkp/0815.csv deleted file mode 100644 index ad15351..0000000 --- a/misc/bkp/0815.csv +++ /dev/null @@ -1,2 +0,0 @@ -"einsatznummer","id","waip_uuid","rmld_uuid","alias","einsatzkraft","maschinist","fuehrungskraft","agt","set_time","arrival_time","wache_id","wache_nr","wache_name" -"0815",9,"81696fb7-0d4b-4252-a515-ffed2d179f4d","2311ca2a-2188-4982-9f16-2f9d8040ee4d",,0,1,0,0,"Wed Jun 17 2020 15:17:52 GMT+0200 (Mitteleuropäische Sommerzeit)","Wed Jun 17 2020 15:22:52 GMT+0200 (Mitteleuropäische Sommerzeit)",2,520101,"CB FW Cottbus 1" \ No newline at end of file diff --git a/misc/bkp/0815_export_rmld_Test Export Rückmeldung Robert.csv b/misc/bkp/0815_export_rmld_Test Export Rückmeldung Robert.csv deleted file mode 100644 index aa171a7..0000000 --- a/misc/bkp/0815_export_rmld_Test Export Rückmeldung Robert.csv +++ /dev/null @@ -1,2 +0,0 @@ -"einsatznummer","id","waip_uuid","rmld_uuid","alias","einsatzkraft","maschinist","fuehrungskraft","agt","set_time","arrival_time","wache_id","wache_nr","wache_name" -"0815",10,"a0687454-35fa-4921-b415-d5ae0a6baf7c","daa11d6d-ffb3-437f-abf1-2a30c75d8dfd",,1,0,0,0,"Wed Jun 17 2020 17:15:34 GMT+0200 (Mitteleuropäische Sommerzeit)","Wed Jun 17 2020 17:25:34 GMT+0200 (Mitteleuropäische Sommerzeit)",19,521403,"CB FW Madlow" \ No newline at end of file diff --git a/server/api.js b/server/api.js index 2921a15..c0bc820 100755 --- a/server/api.js +++ b/server/api.js @@ -31,7 +31,11 @@ module.exports = function (io, sql, app_cfg, remote_api, saver) { // nur speichern wenn app_id nicht eigenen globalen app_id entspricht if (app_id != app_cfg.global.app_id) { saver.save_new_waip(data, remote_ip, app_id); - sql.db_log('API', 'Neuer Wachalarm von ' + remote_ip + ': ' + JSON.stringify(data)); + if (app_cfg.global.development) { + sql.db_log('API', 'Neuer Wachalarm von ' + remote_ip + ': ' + JSON.stringify(data)); + } else { + sql.db_log('API', 'Neuer Wachalarm von ' + remote_ip + '. Wird verarbeitet.'); + }; }; }); @@ -87,8 +91,12 @@ module.exports = function (io, sql, app_cfg, remote_api, saver) { // nur speichern wenn app_id nicht eigenen globalen app_id entspricht if (app_id != app_cfg.global.app_id) { // nicht erwuenschte Daten ggf. enfernen (Datenschutzoption) - saver.save_new_waip(data, app_cfg.endpoint.host, app_id); - sql.db_log('API', 'Neuer Wachalarm von ' + app_cfg.endpoint.host + ': ' + JSON.stringify(data)); + saver.save_new_waip(data, app_cfg.endpoint.host, app_id); + if (app_cfg.global.development) { + sql.db_log('API', 'Neuer Wachalarm von ' + app_cfg.endpoint.host + ': ' + JSON.stringify(data)); + } else { + sql.db_log('API', 'Neuer Wachalarm von ' + app_cfg.endpoint.host + '. Wird verarbeitet.'); + }; }; }); diff --git a/server/saver.js b/server/saver.js index 57913d6..be1fa22 100755 --- a/server/saver.js +++ b/server/saver.js @@ -52,7 +52,6 @@ module.exports = function (app_cfg, sql, waip, uuidv4, io, remote_api) { sql.db_log('WAIP', 'Neuer Einsatz von ' + remote_addr + ' wird jetzt verarbeitet: ' + JSON.stringify(data_filtered)); }); // Einsatzdaten per API weiterleiten (entweder zum Server oder zum verbunden Client) - // TODO TEST: Api WAIP api_server_to_client_new_waip(waip_data, app_id); api_client_to_server_new_waip(waip_data, app_id); }); @@ -80,7 +79,6 @@ module.exports = function (app_cfg, sql, waip, uuidv4, io, remote_api) { }; }); // RMLD-Daten per API weiterleiten (entweder zum Server oder zum verbunden Client) - // TODO TEST: Api WAIP api_server_to_client_new_rmld(data, app_id); api_client_to_server_new_rmld(data, app_id); } else { diff --git a/server/waip.js b/server/waip.js index ba35f06..735ab36 100755 --- a/server/waip.js +++ b/server/waip.js @@ -12,7 +12,8 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { sql.db_log('DEBUG', 'Neuen Einsatz mit der ID ' + waip_id + ' gespeichert.'); // nach dem Speichern anhand der waip_id die beteiligten Wachennummern zum Einsatz ermitteln sql.db_einsatz_get_rooms(waip_id, function (socket_rooms) { - if (socket_rooms) { + // socket_rooms muss groesser als 1 sein, da sonst nur der Standard-Raum '0' vorhanden ist + if (socket_rooms.length > 1) { socket_rooms.forEach(function (rooms) { // fuer jede Wache(rooms.room) die verbundenen Sockets(Clients) ermitteln und den Einsatz verteilen var room_sockets = io.nsps['/waip'].adapter.rooms[rooms.room]; @@ -25,8 +26,7 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }; }); } else { - // FIXME löschen klappt nicht - // wenn kein Raum (keine Wache) in der DB hinterlegt ist, dann Einsatz direkt wieder loeschen + // wenn kein Raum (keine Wache) ausser '0' zurueckgeliefert wird, dann Einsatz direkt wieder loeschen weil keine Wachen dazu hinterlegt sql.db_log('Fehler-WAIP', 'Fehler: Keine Wache für den Einsatz mit der ID ' + waip_id + ' vorhanden! Einsatz wird gelöscht!'); sql.db_einsatz_loeschen(waip_id); }; @@ -313,6 +313,7 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { Object.keys(room_sockets.sockets).forEach(function (socket_id) { // Standby senden var socket = io.of('/waip').connected[socket_id]; + // FIXME gelöschter einsatz wird noch als Wachalarm angezeigt sql.db_client_check_waip_id(socket.id, waip.id, function (same_id) { if (same_id) { socket.emit('io.standby', null); @@ -346,6 +347,7 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { if (export_data) { var part_rmld = full_rmld; console.log('bereite export vor'); + console.log(part_rmld); // FIXME full_rmld.filter(obj => obj.wache_id.startsWith(export_data.export_filter)); // CSV-Spalten definieren @@ -356,7 +358,7 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { console.log(csv); // CSV Dateiname und Pfad festlegen //FIXME csv export nochmals prüfen - var csv_filename = part_rmld[0].einsatznummer + '_export_rmld_' + export_data.export_name.replace(/[/\\?%*:|"<>]/g, '') + '.csv'; + var csv_filename = 'einsatz_' + part_rmld[0].einsatznummer + '_export_' + export_data.export_name.replace(/[/\\?%*:|"<>]/g, '') + '.csv'; csv_path = process.cwd() + app_cfg.rmld.backup_path; //+ csv_filename; console.log(csv_filename); @@ -415,7 +417,6 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }); // alten Einsatz loeschen sql.db_einsatz_loeschen(waip.id); - // FIXME gelöschter einsatz wird noch als Wachalarm angezeigt sql.db_log('WAIP', 'Einsatz-Daten zu Einsatz ' + waip.id + ' gelöscht.'); }; }); @@ -424,7 +425,11 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { fs.readdirSync(process.cwd() + app_cfg.global.soundpath).forEach(file => { // nur die mp3s von alten clients loeschen if (file.substring(0, 4) != 'bell' && file.substring(file.length - 3) == 'mp3' && file.substring(file.length - 8) != '_tmp.mp3') { - sql.db_socket_get_by_id(file.substring(0, file.length - 4), function (data) { + // Socket-ID aus Datei-Namen extrahieren + socket_name = file.substring(0, file.length - 4); + // Socket-ID anpassen, damit die SQL-Abfrage ein Ergebnis liefert + socket_name.replace('waip', '/waip#'); + sql.db_socket_get_by_id(socket_name, function (data) { if (!data) { fs.unlink(process.cwd() + app_cfg.global.soundpath + file, function (err) { if (err) return sql.db_log('Fehler-WAIP', err);