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

update Mo 15. Jun 23:01:01 CEST 2020

Browse Source
This commit is contained in:
Robert Richter 2020-06-15 23:01:01 +02:00
parent 7ccbf0a7ac
commit 2a7a201dfe
3 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server.js
View File

@ -38,9 +38,9 @@ app.use(bodyParser.urlencoded({
var sql_cfg = require('./server/sql_cfg')(fs, bcrypt, app_cfg); var sql_cfg = require('./server/sql_cfg')(fs, bcrypt, app_cfg);
var sql = require('./server/sql_qry')(sql_cfg, app_cfg); var sql = require('./server/sql_qry')(sql_cfg, app_cfg);
var brk = require('./server/broker')(app_cfg, sql, uuidv4); var brk = require('./server/broker')(app_cfg, sql, uuidv4);
var waip = require('./server/waip')(io, sql, fs, brk, async, app_cfg, api);
var saver = require('./server/saver')(app_cfg, sql, waip, uuidv4); var saver = require('./server/saver')(app_cfg, sql, waip, uuidv4);
var api = require('./server/api')(io, sql, app_cfg, saver); var api = require('./server/api')(io, sql, app_cfg, saver);
var waip = require('./server/waip')(io, sql, fs, brk, async, app_cfg, api);
var socket = require('./server/socket')(io, sql, app_cfg, waip); var socket = require('./server/socket')(io, sql, app_cfg, waip);
var udp = require('./server/udp')(app_cfg, sql, saver); var udp = require('./server/udp')(app_cfg, sql, saver);
var auth = require('./server/auth')(app, app_cfg, sql_cfg, async, bcrypt, passport, io); var auth = require('./server/auth')(app, app_cfg, sql_cfg, async, bcrypt, passport, io);

10
server/saver.js
View File

@ -35,14 +35,14 @@ module.exports = function (app_cfg, sql, waip, uuidv4) {
waip_data.ortsdaten.wgs84_area = JSON.stringify(new_buffer); waip_data.ortsdaten.wgs84_area = JSON.stringify(new_buffer);
}; };
// pruefen, ob vielleicht schon ein Einsatz mit einer UUID gespeichert ist // pruefen, ob vielleicht schon ein Einsatz mit einer UUID gespeichert ist
db.get('select uuid from waip_einsaetze where einsatznummer like ?', [content.einsatzdaten.nummer], function (err, row) { sql.db_einsatz_get_uuid_by_enr(waip_data.einsatzdaten.nummer, function(waip_uuid) {
if (err == null && row) { if (waip_uuid) {
// wenn ein Einsatz mit UUID schon vorhanden ist, dann diese setzten / ueberschreiben // wenn ein Einsatz mit UUID schon vorhanden ist, dann diese setzten / ueberschreiben
content.einsatzdaten.uuid = row.uuid; waip_data.einsatzdaten.uuid = waip_uuid;
} else { } else {
// uuid erzeugen und zuweisen falls nicht bereits in JSON vorhanden, oder falls keine korrekte uuid // uuid erzeugen und zuweisen falls nicht bereits in JSON vorhanden, oder falls keine korrekte uuid
if (!content.einsatzdaten.uuid || !uuid_pattern.test(content.einsatzdaten.uuid) { if (!waip_data.einsatzdaten.uuid || !uuid_pattern.test(waip_data.einsatzdaten.uuid)) {
content.einsatzdaten.uuid = uuidv4(); waip_data.einsatzdaten.uuid = uuidv4();
}; };
}; };
// Einsatz in DB Speichern // Einsatz in DB Speichern

12
server/sql_qry.js
View File

@ -256,6 +256,17 @@ module.exports = function (db, app_cfg) {
}); });
}; };
function db_einsatz_get_uuid_by_enr(einsatz_nr, callback) {
// mit uuid die zugehoerige id des Einsatzes finden
db.get(`select uuid from waip_einsaetze where einsatznummer like ?`, [einsatz_nr], function (err, row) {
if (err == null && row) {
callback && callback(row.uuid);
} else {
callback && callback(null);
};
});
};
function db_einsatz_get_waipid_by_uuid(waip_uuid, callback) { function db_einsatz_get_waipid_by_uuid(waip_uuid, callback) {
// mit uuid die zugehoerige id des Einsatzes finden // mit uuid die zugehoerige id des Einsatzes finden
db.get(`SELECT id FROM WAIP_EINSAETZE WHERE uuid like ?`, [waip_uuid], function (err, row) { db.get(`SELECT id FROM WAIP_EINSAETZE WHERE uuid like ?`, [waip_uuid], function (err, row) {
@ -868,6 +879,7 @@ module.exports = function (db, app_cfg) {
db_einsatz_check_history: db_einsatz_check_history, db_einsatz_check_history: db_einsatz_check_history,
db_einsatz_get_by_waipid: db_einsatz_get_by_waipid, db_einsatz_get_by_waipid: db_einsatz_get_by_waipid,
db_einsatz_get_by_uuid: db_einsatz_get_by_uuid, db_einsatz_get_by_uuid: db_einsatz_get_by_uuid,
db_einsatz_get_uuid_by_enr: db_einsatz_get_uuid_by_enr,
db_einsatz_get_waipid_by_uuid: db_einsatz_get_waipid_by_uuid, db_einsatz_get_waipid_by_uuid: db_einsatz_get_waipid_by_uuid,
db_einsatz_get_active: db_einsatz_get_active, db_einsatz_get_active: db_einsatz_get_active,
db_einsatz_get_rooms: db_einsatz_get_rooms, db_einsatz_get_rooms: db_einsatz_get_rooms,