update Mi 17. Jun 21:31:01 CEST 2020

misc/bkp/0815.csv

@@ -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"

misc/bkp/0815_export_rmld_Test Export Rückmeldung Robert.csv

@@ -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"

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);
+          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.');
+          };          
         };
       });
 
@@ -88,7 +92,11 @@ module.exports = function (io, sql, app_cfg, remote_api, saver) {
       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);        
+        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.');
+        };  
       };
     });
 

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 {

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) ausser '0' zurueckgeliefert wird, dann Einsatz direkt wieder loeschen weil keine Wachen dazu hinterlegt
-          // wenn kein Raum (keine Wache) in der DB hinterlegt ist, dann Einsatz direkt wieder loeschen
           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);