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

update Di 3. Mär 15:31:02 CET 2020

Browse Source
This commit is contained in:
Robert Richter 2020-03-03 15:31:02 +01:00
parent ab16ff3452
commit 8f1dc032fe
3 changed files with 44 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/socket.js
View File

@ -41,7 +41,7 @@ socket_api.emit('CH01', 'me', 'test msg');
waip.einsatz_verteilen(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id); waip.einsatz_verteilen(result_einsatz[0].waip_einsaetze_ID, socket.id, wachen_id);
sql.db_update_client_status(socket, result_einsatz[0].waip_einsaetze_ID); sql.db_update_client_status(socket, result_einsatz[0].waip_einsaetze_ID);
//vorhanden Rückmeldungen verteilen //vorhanden Rückmeldungen verteilen
sql.db_get_response_wache(result_einsatz[0].waip_einsaetze_ID, function(result){ sql.db_get_response_wache(result_einsatz[0].waip_einsaetze_ID, wachen_id, function(result){
console.log('response_wache: ' + result); console.log('response_wache: ' + result);
if (result) { if (result) {
waip.reuckmeldung_verteilen(result_einsatz[0].waip_einsaetze_ID, result); waip.reuckmeldung_verteilen(result_einsatz[0].waip_einsaetze_ID, result);

10
server/sql_cfg.js
View File

@ -90,7 +90,15 @@ module.exports = function (fs, bcrypt, app_cfg) {
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
waip_uuid TEXT, waip_uuid TEXT,
rmld_uuid TEXT, rmld_uuid TEXT,
response_json TEXT)`); einsatzkraft INTEGER,
maschinist INTEGER,
fuehrungskraft INTEGER,
agt INTEGER,
set_time DATETIME,
arrival_time DATETIME,
wache_id INTEGER,
wache_nr INTEGER,
wache_name TEXT)`);
// Benutzer-Tabelle erstellen // Benutzer-Tabelle erstellen
db.run(`CREATE TABLE waip_users ( db.run(`CREATE TABLE waip_users (
id INTEGER PRIMARY KEY AUTOINCREMENT, id INTEGER PRIMARY KEY AUTOINCREMENT,

57
server/sql_qry.js
View File

@ -614,30 +614,30 @@ module.exports = function(db, async, app_cfg) {
// Typ der Einsatzfunktion festlegen // Typ der Einsatzfunktion festlegen
switch (responseobj.radio_efunction) { switch (responseobj.radio_efunction) {
case 'ek': case 'ek':
reuckmeldung.einsatzkraft = true; reuckmeldung.einsatzkraft = 1;
reuckmeldung.maschinist = false; reuckmeldung.maschinist = 0;
reuckmeldung.fuehrungskraft = false; reuckmeldung.fuehrungskraft = 0;
break; break;
case 'ma': case 'ma':
reuckmeldung.einsatzkraft = false; reuckmeldung.einsatzkraft = 0;
reuckmeldung.maschinist = true; reuckmeldung.maschinist = 1;
reuckmeldung.fuehrungskraft = false; reuckmeldung.fuehrungskraft = 0;
break; break;
case 'fk': case 'fk':
reuckmeldung.einsatzkraft = false; reuckmeldung.einsatzkraft = 0;
reuckmeldung.maschinist = false; reuckmeldung.maschinist = 0;
reuckmeldung.fuehrungskraft = true; reuckmeldung.fuehrungskraft = 1;
break; break;
default: default:
reuckmeldung.einsatzkraft = false; reuckmeldung.einsatzkraft = 0;
reuckmeldung.maschinist = false; reuckmeldung.maschinist = 0;
reuckmeldung.fuehrungskraft = false; reuckmeldung.fuehrungskraft = 0;
}; };
// ist AGT ja / nein // ist AGT ja / nein
if (responseobj.cb_agt) { if (responseobj.cb_agt) {
reuckmeldung.agt = true; reuckmeldung.agt = 1;
} else { } else {
reuckmeldung.agt = false; reuckmeldung.agt = 0;
}; };
// Zeitpunkt der Rueckmeldung festlegen // Zeitpunkt der Rueckmeldung festlegen
reuckmeldung.set_time = new Date(); reuckmeldung.set_time = new Date();
@ -653,16 +653,25 @@ module.exports = function(db, async, app_cfg) {
}; };
//console.log(JSON.stringify(reuckmeldung)); //console.log(JSON.stringify(reuckmeldung));
db.get(`select name_wache from waip_wachen where id = ?;`, [reuckmeldung.wache_id], function(err, row) { db.get(`select name_wache, nr_wache from waip_wachen where id = ?;`, [reuckmeldung.wache_id], function(err, row) {
if (err == null && row) { if (err == null && row) {
reuckmeldung.wache_name = row.name_wache; reuckmeldung.wache_name = row.name_wache;
reuckmeldung.wache_nr = row.nr_wache;
db.run((`insert or replace into waip_response (id, waip_uuid, rmld_uuid, response_json) db.run((`insert or replace into waip_response (id, waip_uuid, rmld_uuid, einsatzkraft, maschinist, fuehrungskraft, agt, set_time, arrival_time, wache_id, wache_nr, wache_name)
values values
((select id from waip_response where rmld_uuid = \'` + reuckmeldung.rmld_uuid + `\'), ((select id from waip_response where rmld_uuid = \'` + reuckmeldung.rmld_uuid + `\'),
\'` + reuckmeldung.waip_uuid + `\', \'` + reuckmeldung.waip_uuid + `\',
\'` + reuckmeldung.rmld_uuid + `\', \'` + reuckmeldung.rmld_uuid + `\',
\'` + JSON.stringify(reuckmeldung) + `\')`), function(err) { \'` + reuckmeldung.einsatzkraft + `\',
\'` + reuckmeldung.maschinist + `\',
\'` + reuckmeldung.fuehrungskraft + `\',
\'` + reuckmeldung.agt + `\',
\'` + reuckmeldung.set_time + `\',
\'` + reuckmeldung.arrival_time + `\',
\'` + reuckmeldung.wache_id + `\',
\'` + reuckmeldung.wache_nr + `\',
\'` + reuckmeldung.wache_name + `\')`), function(err) {
//console.log(err); //console.log(err);
if (err == null) { if (err == null) {
callback && callback('OK'); callback && callback('OK');
@ -693,7 +702,7 @@ module.exports = function(db, async, app_cfg) {
}; };
function db_get_response_wache(waip_einsaetze_id, wachen_nr, callback) { function db_get_response_wache(waip_einsaetze_id, wachen_nr, callback) {
db.all(`SELECT response_json FROM waip_response WHERE waip_uuid = (select uuid from waip_einsaetze where id = ?)`, [waip_einsaetze_id], function (err, rows) { db.all(`SELECT * FROM waip_response WHERE waip_uuid = (select uuid from waip_einsaetze where id = ?)`, [waip_einsaetze_id], function (err, rows) {
if (err == null && rows) { if (err == null && rows) {
// temporaere Variablen // temporaere Variablen
@ -707,13 +716,15 @@ module.exports = function(db, async, app_cfg) {
console.log('rows: '+JSON.stringify(rows)); console.log('rows: '+JSON.stringify(rows));
rows.forEach(function (item, index, array) { rows.forEach(function (item, index, array) {
// summiertes JSON-Rueckmeldeobjekt für die angeforderte Wachennummer erstellen // summiertes JSON-Rueckmeldeobjekt für die angeforderte Wachennummer erstellen
console.log('item.response_json.wache_id '+JSON.parse(item.response_json.wache_id)); var tmp = JSON.stringify(item.wache_nr);
db_wache_nr_ermitteln(item.response_json.wache_id, function(response_wachen_nr) { console.log('item. '+tmp );
if (response_wachen_nr.startsWith(wachen_nr)) { console.log(wachen_nr);
console.log(tmp.startsWith(wachen_nr));
if (tmp.startsWith(wachen_nr)) {
// response_wache aufsummieren // response_wache aufsummieren
all_responses.push(item.response_json) all_responses.push(item)
}; };
});