From 87ecb26117332e0743152fdcd59d24bca1e54d08 Mon Sep 17 00:00:00 2001 From: Robert Richter Date: Wed, 17 Jun 2020 23:01:01 +0200 Subject: [PATCH] update Mi 17. Jun 23:01:01 CEST 2020 --- server/sql_qry.js | 8 +++++--- server/waip.js | 18 +++++------------- 2 files changed, 10 insertions(+), 16 deletions(-) diff --git a/server/sql_qry.js b/server/sql_qry.js index 598e27e..c607fa3 100755 --- a/server/sql_qry.js +++ b/server/sql_qry.js @@ -798,9 +798,11 @@ module.exports = function (db, app_cfg) { }); }; - function db_rmld_get_by_waipuuid(waip_uuid, callback) { + function db_rmld_get_for_export(waip_uuid, callback) { // alle Rueckmeldungen fuer einen Einsatz ermitteln - db.all(`SELECT we.einsatznummer, wr.* FROM waip_response wr, waip_einsaetze we WHERE wr. waip_uuid like ? AND we.uuid like ?`, [waip_uuid, waip_uuid], function (err, rows) { + db.all(`SELECT we.einsatznummer, wr.id, wr.waip_uuid, wr.rmld_uuid, + wr.einsatzkraft, wr.maschinist, wr.fuehrungskraft, wr.agt, wr.set_time, wr.arrival_time, wr.wache_id, wr.wache_nr, wr.wache_name + FROM waip_response wr, waip_einsaetze we WHERE wr. waip_uuid like ? AND we.uuid like ?`, [waip_uuid, waip_uuid], function (err, rows) { if (err == null && rows) { callback && callback(rows); } else { @@ -928,7 +930,7 @@ module.exports = function (db, app_cfg) { db_rmld_save: db_rmld_save, db_rmld_get_fuer_wache: db_rmld_get_fuer_wache, db_rmld_get_by_rmlduuid: db_rmld_get_by_rmlduuid, - db_rmld_get_by_waipuuid: db_rmld_get_by_waipuuid, + db_rmld_get_for_export: db_rmld_get_for_export, db_rmld_loeschen: db_rmld_loeschen, db_vmtl_get_list: db_vmtl_get_list, db_vmtl_check_history: db_vmtl_check_history, diff --git a/server/waip.js b/server/waip.js index 5cff944..fa08619 100755 --- a/server/waip.js +++ b/server/waip.js @@ -342,20 +342,15 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }); }; }); - sql.db_rmld_get_by_waipuuid(waip.uuid, function (full_rmld) { + sql.db_rmld_get_for_export(waip.uuid, function (full_rmld) { // beteiligte Wachen aus den Einsatz-Rueckmeldungen filtern var arry_wachen = full_rmld.map(a => a.wache_nr); - // FIXME - console.log(arry_wachen) sql.db_export_get_for_rmld(arry_wachen, function (export_data) { - // FIXME + console.log(arry_wachen) // SQL gibt ist eine Schliefe (db.each), fuer jedes Ergebnis wird eine CSV/Mail erstellt 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 var csv_col = ['id', 'einsatznummer', 'waip_uuid', 'rmld_uuid', 'alias', 'einsatzkraft', 'maschinist', 'fuehrungskraft', 'agt', 'set_time', 'arrival_time', 'wache_id', 'wache_nr', 'wache_name']; @@ -364,9 +359,7 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }; try { var csv = parse(part_rmld, opts); - console.log(csv); // CSV Dateiname und Pfad festlegen - //TODO csv export nochmals prüfen 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; @@ -389,7 +382,6 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }); }); }; - //FIXME anderen Email-Dienst // CSV per Mail versenden, falls aktiviert if (app_cfg.rmld.backup_to_mail) { // pruefen ob Mail plausibel ist @@ -417,13 +409,13 @@ module.exports = function (io, sql, fs, brk, async, app_cfg) { }; transport.sendMail(mail_message, function (err, info) { if (err) { - sql.db_log('EXPORT', 'Fehler beim senden der Export-Mail an ' + export_data.mail_subject + ': ' + err); + sql.db_log('EXPORT', 'Fehler beim senden der Export-Mail an ' + export_data.export_recipient + ': ' + err); } else { - sql.db_log('EXPORT', 'Mail an ' + export_data.mail_subject + ' gesendet: ' + info); + sql.db_log('EXPORT', 'Mail an ' + export_data.export_recipient + ' gesendet: ' + JSON.stringify(info)); } }); } else { - sql.db_log('EXPORT', 'Fehler beim versenden der Export-Mail an ' + export_data.mail_subject + ' - keine richtige Mail-Adresse!'); + sql.db_log('EXPORT', 'Fehler beim versenden der Export-Mail an ' + export_data.export_recipient + ' - keine richtige Mail-Adresse!'); }; }; } catch (err) {