mkrieger/Wachalarm-IP-Web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update So 14. Jun 19:01:01 CEST 2020

Browse Source
This commit is contained in:
Robert Richter 2020-06-14 19:01:01 +02:00
parent c8e052d35d
commit 31f9216933
2 changed files with 9 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/sql_qry.js
View File

@ -146,17 +146,17 @@ module.exports = function (db, uuidv4, app_cfg) {
}); });
}; };
function db_einsatz_check_history(waip_id, missiondata, socket_id, callback) { function db_einsatz_check_history(waip_id, einsatzdaten, socket_id, callback) {
//console.log(missiondata);
// Prüfen ob Wachalarm bereits in dieser Form an diesen Socket gesendet wurde (Doppelalarmierung vermeiden) // Prüfen ob Wachalarm bereits in dieser Form an diesen Socket gesendet wurde (Doppelalarmierung vermeiden)
const custom_namespace = '59cc72ec-4ff5-499d-81e2-ec49c1d01252' const custom_namespace = '59cc72ec-4ff5-499d-81e2-ec49c1d01252'
// neues Object mit Einsatzdaten erstellen
var missiondata = Object.assign({}, einsatzdaten);
// Einsatzdaten in kuzre UUID-Strings umwandeln, diese UUIDs werden dann verglichen // Einsatzdaten in kuzre UUID-Strings umwandeln, diese UUIDs werden dann verglichen
var uuid_em_alarmiert = uuidv5(JSON.stringify(missiondata.em_alarmiert), custom_namespace); var uuid_em_alarmiert = uuidv5(JSON.stringify(missiondata.em_alarmiert), custom_namespace);
//delete missiondata.em_alarmiert; delete missiondata.em_alarmiert;
var uuid_em_weitere = uuidv5(JSON.stringify(missiondata.em_weitere), custom_namespace); var uuid_em_weitere = uuidv5(JSON.stringify(missiondata.em_weitere), custom_namespace);
//delete missiondata.em_weitere; delete missiondata.em_weitere;
var uuid_einsatzdaten = uuidv5(JSON.stringify(missiondata), custom_namespace); var uuid_einsatzdaten = uuidv5(JSON.stringify(missiondata), custom_namespace);
//console.log(missiondata);
// Abfrage ob zu Socket und Waip-ID bereits History-Daten hinterlegt sind // Abfrage ob zu Socket und Waip-ID bereits History-Daten hinterlegt sind
db.get('select * from waip_history where waip_id like ? and socket_id like ?', [waip_id, socket_id], function (err, row) { db.get('select * from waip_history where waip_id like ? and socket_id like ?', [waip_id, socket_id], function (err, row) {
if (err == null && row) { if (err == null && row) {

11
server/waip.js
View File

@ -67,12 +67,9 @@ module.exports = function (io, sql, fs, brk, async, app_cfg, proof) {
einsatzdaten.wgs84_x = ''; einsatzdaten.wgs84_x = '';
einsatzdaten.wgs84_y = ''; einsatzdaten.wgs84_y = '';
}; };
console.log(einsatzdaten, waip_id);
// pruefen ob Einsatz bereits genau so beim Client angezeigt wurde (Doppelalarmierung) // pruefen ob Einsatz bereits genau so beim Client angezeigt wurde (Doppelalarmierung)
sql.db_einsatz_check_history(waip_id, einsatzdaten, socket.id, function (result) { sql.db_einsatz_check_history(waip_id, einsatzdaten, socket.id, function (result) {
if (!result) { if (!result) {
console.log(einsatzdaten);
// Einsatz an Client senden // Einsatz an Client senden
socket.emit('io.new_waip', einsatzdaten); socket.emit('io.new_waip', einsatzdaten);
sql.db_log('WAIP', 'Einsatz ' + waip_id + ' fuer Wache ' + wachen_nr + ' an Socket ' + socket.id + ' gesendet.'); sql.db_log('WAIP', 'Einsatz ' + waip_id + ' fuer Wache ' + wachen_nr + ' an Socket ' + socket.id + ' gesendet.');
@ -427,15 +424,15 @@ console.log(einsatzdaten);
}); });
}); });
// alte Rueckmeldungen loeschen // alte Rueckmeldungen loeschen
sql.db_rmld_loeschen(waip_uuid); sql.db_rmld_loeschen(waip.uuid);
}); });
// alten Einsatz loeschen // alten Einsatz loeschen
sql.db_einsatz_loeschen(waip.id); sql.db_einsatz_loeschen(waip.id);
sql.db_log('WAIP', 'Einsatz-Daten zu Einsatz ' + waip.id + ' gelöscht.'); sql.db_log('WAIP', 'Einsatz-Daten zu Einsatz ' + waip.id + ' gelöscht.');
}; };
}); });
// FIXME beraltete hispry löschen // FIXME beraltete hispry löschen
// loeschen alter Sounddaten nach alter (15min) und socket-id (nicht mehr verbunden) // loeschen alter Sounddaten nach alter (15min) und socket-id (nicht mehr verbunden)
fs.readdirSync(process.cwd() + app_cfg.global.soundpath).forEach(file => { fs.readdirSync(process.cwd() + app_cfg.global.soundpath).forEach(file => {
@ -462,4 +459,4 @@ console.log(einsatzdaten);
rmld_verteilen_by_uuid: rmld_verteilen_by_uuid, rmld_verteilen_by_uuid: rmld_verteilen_by_uuid,
dbrd_verteilen: dbrd_verteilen dbrd_verteilen: dbrd_verteilen
}; };
}; };