Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨

[sigi234]

@oliverio

Hallo, wie kann ich den Abstand verändern?

[OliverIO]

@sigi234
Mit css
Aktuell wird nur eine rohe html Tabelle ausgegeben.
Mit Abstand meinst du padding oder margin?

[Meister Mopper]

@negalein

Habe gerade deinen thread erstmalig gelesen.

Warum stellt ihr diese einsatzsensiblen Daten abrufbar ins Internet? Gibt es keine Intranet-Lösung?

[Negalein]

@meister-mopper sagte in FF-Einsätze OÖ auswerten:

Warum stellt ihr diese einsatzsensiblen Daten abrufbar ins Internet? Gibt es keine Intranet-Lösung?

Doch, aber nur für FF-Mitglieder.

Diese Daten die ich abrufe, sind dank DSGVO nicht einsatzsensibel. Es ist der Einsatzort nicht ersichtlich.

[Meister Mopper]

@negalein sagte in FF-Einsätze OÖ auswerten:

Diese Daten die ich abrufe, sind dank DSGVO nicht einsatzsensibel. Es ist der Einsatzort nicht ersichtlich.

Ja, das schon, aber die Einsatzbelastung ist schon relevant.

Wenn jemand stören möchte, kann er es zu geeigneten Zeiten tun, um den größtmöglichen Schaden anzurichten.

Das sollte aus meiner Sicht bedacht werden.

[Negalein]

@meister-mopper sagte in FF-Einsätze OÖ auswerten:

Das sollte aus meiner Sicht bedacht werden.

gibt bei uns GsD noch normale Menschen.

Wenn jemand stören möchte, kann er es zu geeigneten Zeiten tun, um den größtmöglichen Schaden anzurichten.

dann dürfte auch keine Sirene, usw. losgehn. Ein Einsatz ist normal weiträumig zu hören.
Zumindest bei uns. ;)

[Meister Mopper]

@negalein sagte in FF-Einsätze OÖ auswerten:

dann dürfte auch keine Sirene, usw. losgehn. Ein Einsatz ist normal weiträumig zu hören.
Zumindest bei uns.

Ja, das mag sein, aber bei geplanten Anschlägen von außen hilft die Sirene nüscht :man-shrugging: .

Ich zumindest würde die Thematik mal oben einwerfen.

[OliverIO]

@negalein sagte in FF-Einsätze OÖ auswerten:

Bitte noch Datum, Zeit entfernen & vor einsatz.bezirk_name bitte das Wort Bezirk einfügen

function prepareMessages(einsaetze, kurz, alle) {
    let messages = [];
    const dateOptions = {
        weekday: "long",
    };
    const timeOptions = { hour: "2-digit", minute: "2-digit" };
    einsaetze.map(einsatz => {
        if (!einsaetzeGesendet.includes(einsatz.id) || alle) {
            if (kurz) {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';'].join(''));
            } else {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';', 'Bezirk ', einsatz.bezirk_name, ';Anzahl Feuerwehren ', einsatz.einheiten.length, ';'].join(''));
            }
            einsaetzeGesendet.push(einsatz.id);
        }
    })
    return messages.join(";");
}

[OliverIO]

@sigi234 sagte in FF-Einsätze OÖ auswerten:

EDIT2
Doch nicht

wie weiter oben schon mal gesagt merkt sich das skript
die meldungen nur innerhalb eines starts.
nach dem nächsten start ist das wieder vergessen.
man könnte das gedächtnis in einen datenpunkt verlagern. dann überlebt dies auch den neustart eines skripts

[Negalein]

@meister-mopper sagte in FF-Einsätze OÖ auswerten:

Ja, das mag sein, aber bei geplanten Anschlägen von außen hilft die Sirene nüscht .

das würde jetzt hier zu OT werden.

Aber noch 1x OT ;)
Was meinst du mit "bei geplanten Anschlägen von außen hilft die Sirene nüscht"?
Gerne auch per PN weiter.

[sigi234]

@oliverio

Ich kann mich noch erinnern als ein Sturm war da kamen Einsätze (300) im Minuten Takt rein.
Da stürzte das Blockly dann ab. Kann man das irgendwie abfangen?

[Negalein]

@oliverio sagte in FF-Einsätze OÖ auswerten:

man könnte das gedächtnis in einen datenpunkt verlagern. dann überlebt dies auch den neustart eines skripts

Das wäre sicher eine Überlegung wert. :)

[OliverIO]

@sigi234 sagte in FF-Einsätze OÖ auswerten:

Ich kann mich noch erinnern als ein Sturm war da kamen Einsätze (300) im Minuten Takt rein.
Da stürzte das Blockly dann ab. Kann man das irgendwie abfangen?

du fragst ja eigentlich nur alle 30 sekunden oder größer ab.
auch wenn es 1000 gemeldete einsätze gibt, dürfte es kein problem mit absturz oder speicher geben.
wenn, dann irgendeine code-konstellation, die nicht vorgesehen ist. aber wir haben da gar nicht soviel drin. evtl mal, das sich im quelldatenformat was ändert

einen fehler findest du dann im iobroker log

[OliverIO]

@negalein sagte in FF-Einsätze OÖ auswerten:

speichern der bereits gemeldeten einsätze in einem datenpunkt
Das wäre sicher eine Überlegung wert

ziemlich am anfang (zeile 3) folgendes einfügen

let savedEinsaetzeDP = "0_userdata.a";

die folgende zeile, auch am anfang, bitte löschen

let einsaetzeGesendet ....

folgende funktion bitte tauschen

async function prepareMessages(einsaetze, kurz, alle) {
    let messages = [];
    const dateOptions = {
        weekday: "long",
    };
    const timeOptions = { hour: "2-digit", minute: "2-digit" };
    let data = await getStateAsync(savedEinsaetzeDP);
    let einsaetzeGesendet = JSON.parse(data.val || "[]");
    einsaetze.map(einsatz => {
        if (!einsaetzeGesendet.some(el => el.id == einsatz.id) || alle) {
            //if (!einsaetzeGesendet.includes(einsatz.id) || alle) {
            if (kurz) {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';'].join(''));
            } else {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';', 'Bezirk ', einsatz.bezirk_name, ';Anzahl Feuerwehren ', einsatz.einheiten.length, ';'].join(''));
            }
            einsaetzeGesendet.push({ id: einsatz.id, time: new Date() });
        }
    })
    await setStateAsync(savedEinsaetzeDP, JSON.stringify(einsaetzeGesendet));
    return messages.join(";");
}

da prepareMessage nun eine async funktion ist, muss an jeder stelle wo diese aufgerufen wird nun await hinzugefügt werden. also so wie folgt
vorher

let messages = prepareMessages(einsaetze, false, false);

nachher

let messages = await prepareMessages(einsaetze, false, false);

falls irgendwas nicht funktioniert, bitte dann nochmal deinen kompletten code posten

[Negalein]

@oliverio sagte in FF-Einsätze OÖ auswerten:

nachher

bei mir 1x

so richtig, denke ich

async function main() {
    let xml = await getData()
    let json = await xml2json(xml);
    let einsaetze = normalizeData(json.webext2.einsaetze.einsatz);
    let einsaetze_einheiten = filterEinheiten(einsaetze, [410321, 410327]);
    let einsaetze_bezirk = filterBezirk(einsaetze, 10);
    let html1 = toHtml(einsaetze_einheiten);
    let html2 = toHtml(einsaetze_bezirk);
    let html3 = toHtml(einsaetze);
    let messages = await prepareMessages(einsaetze_bezirk, false, false);
    //messages = await prepareMessages(einsaetze, true, false);
    let nachtruhe=compareTime("01:00", "06:00","between");
    if (!nachtruhe || messages) sendAlexa(messages, 60);
    if (messages) sendTelegram(messages, "");
    if (messages) sendEMail(messages, "christian@nega.at", "Neuer Feuerwehreinsatz");
    console.log(html1);
    console.log(html2);
    console.log(html3);
    //setState("0_userdata.0.testFolder.a", html3);
	setState("0_userdata.0.FF-Einsatz.Bezirk", html2);	

let savedEinsaetzeDP = "0_userdata.a"; --> String?

[OliverIO]

@negalein

ich habe gerade nochmal aktualisiert, bitte den code nochmal von oben kopieren

let savedEinsaetzeDP = "0_userdata.a"; --> String?

ja

bei mir 1x
so richtig, denke ich

ja

[Negalein]

@oliverio sagte in FF-Einsätze OÖ auswerten:

ich habe gerade nochmal aktualisiert, bitte den code nochmal von oben kopieren

Danke, funktioniert.

Der neue DP wird beschrieben. :)

[sigi234]

@negalein sagte in FF-Einsätze OÖ auswerten:

@oliverio sagte in FF-Einsätze OÖ auswerten:

ich habe gerade nochmal aktualisiert, bitte den code nochmal von oben kopieren

Danke, funktioniert.

Der neue DP wird beschrieben. :)

Kannst du den aktuellen Code mal raufladen?

[sigi234]

@oliverio sagte in FF-Einsätze OÖ auswerten:

Aktuell wird nur eine rohe html Tabelle ausgegeben.

Kann man es auch als JSON-Table ausgeben?

Edit:

So wie bei Lebensmittelwarnung

[Negalein]

@sigi234 sagte in FF-Einsätze OÖ auswerten:

Kannst du den aktuellen Code mal raufladen?

Stand 12-09-2024

var xml2js = require('xml2js');
var fetch = require('node-fetch');
const useragent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36";
let savedEinsaetzeDP = "0_userdata.0.FF-Einsatz.Await";
 
async function getData() {
    const response = await fetch("https://cf-einsaetze.ooelfv.at/webext2/rss/webext2_laufend.xml", {
        "headers": {
            "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
            "accept-language": "de-DE,de;q=0.9,en-US;q=0.8,en;q=0.7",
            "cache-control": "no-cache",
            "pragma": "no-cache",
            "sec-ch-ua": "\"Not_A Brand\";v=\"8\", \"Chromium\";v=\"120\", \"Google Chrome\";v=\"120\"",
            "sec-ch-ua-mobile": "?0",
            "sec-ch-ua-platform": "\"Windows\"",
            "sec-fetch-dest": "document",
            "sec-fetch-mode": "navigate",
            "sec-fetch-site": "none",
            "sec-fetch-user": "?1",
            "upgrade-insecure-requests": "1",
            "User-Agent": useragent
        },
        "referrerPolicy": "strict-origin-when-cross-origin",
        "body": null,
        "method": "GET"
    });
    let text = await response.text();
    return text;
}
async function xml2json(xml) {
    return new Promise(function (resolve, reject) {
        var parser = new xml2js.Parser(
            {
                explicitArray: false
            }
        );
        parser.parseString(xml, function (err, result) {
            if (err) {
                reject(err);
            } else {
                resolve(result);
            }
        })
        // xml2js.parseString(xml, function (err, result) {
        // });
    })
    // var parser = new xml2js.Parser();
    // parser.parseString(xml, function (err, result) {
    //     console.dir(result);
    // });
}
function normalizeData(obj) {
    let a = 1;
    let einsaetze = [];
    for (let i = 0; i < obj.length; i++) {
        let einsatz = obj[i];
        let einsatzNeu = {
            id: einsatz.$.id,
            startzeit: einsatz.startzeit,
            status: einsatz.status,
            alarmstufe: einsatz.alarmstufe,
            einsatzart: einsatz.einsatzart,
            einsatzorg: einsatz.einsatzorg,
            einsatztyp: einsatz.einsatztyp._,
            einsatzsubtyp: einsatz.einsatzsubtyp._,
            alarmtext: einsatz.alarmtext,
            earea: einsatz.adresse.earea,
            bezirk_name: einsatz.bezirk._,
            bezirk_id: einsatz.bezirk.$.id,
            lng: einsatz.lng,
            lat: einsatz.lat,
            einheiten: []
        };
        if (Array.isArray(einsatz.einheiten.einheit) == false) {
            einsatz.einheiten.einheit = [einsatz.einheiten.einheit];
        }
        for (let j = 0; j < einsatz.einheiten.einheit.length; j++) {
            let einheit = einsatz.einheiten.einheit[j];
            einsatzNeu.einheiten.push({
                id: einheit.$.id,
                bezeichnung: einheit._
            })
        }
        einsaetze.push(einsatzNeu);
    }
    return einsaetze;
}
function filterEinheiten(einsaetze, einheiten) {
    if (!einheiten) throw Error("Einheiten ids müssen angegeben werden");
    return einsaetze.filter(einsatz => einheiten.some(id => einsatz.einheiten.some(einheit => einheit.id == id)));
}
function filterBezirk(einsaetze, bezirk) {
    if (!bezirk) throw Error("bezirkid muss angegeben werden");
    return einsaetze.filter(einsatz => einsatz.bezirk_id == bezirk);
}
function toHtml(einsaetze) {
    let rows = "";
    einsaetze.forEach(einsatz => {
        let einheiten = einsatz.einheiten.map(einheit => einheit.bezeichnung).join("<br>");
        rows += `
            <tr>
                <td>${einsatz.alarmstufe}</td>
                <td>${einsatz.alarmtext}</td>
                <td>${einheiten}</td>
                <td>${einsatz.earea}</td>
                <td>${einsatz.lat}</td>
                <td>${einsatz.lng}</td>
            </tr>
        `
    })
    let html = `
    <table>
      <tr>
        <th>Alarmstufe</th>
        <th>Alarmtext</th>
        <th>Einheiten</th>
        <th>EAREA</th>
        <th>lat</th>
        <th>lng</th>
      </tr>
      ${rows}
    </table>
    `;
 
    return html;
}
async function prepareMessages(einsaetze, kurz, alle) {
    let messages = [];
    const dateOptions = {
        weekday: "long",
    };
    const timeOptions = { hour: "2-digit", minute: "2-digit" };
    let data = await getStateAsync(savedEinsaetzeDP);
    let einsaetzeGesendet = JSON.parse(data.val || "[]");
    einsaetze.map(einsatz => {
        if (!einsaetzeGesendet.some(el => el.id == einsatz.id) || alle) {
            //if (!einsaetzeGesendet.includes(einsatz.id) || alle) {
            if (kurz) {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';'].join(''));
            } else {
                messages.push(['Achtung;Feuerwehreinsatz in ', einsatz.earea, ';', 'Alarmstufe ', einsatz.alarmstufe, ';', einsatz.einsatzsubtyp, ';', 'Bezirk ', einsatz.bezirk_name, ';Anzahl Feuerwehren ', einsatz.einheiten.length, ';'].join(''));
            }
            einsaetzeGesendet.push({ id: einsatz.id, time: new Date() });
        }
    })
    await setStateAsync(savedEinsaetzeDP, JSON.stringify(einsaetzeGesendet));
    return messages.join(";");
}
function sendTelegram(text, user) {
    sendTo("telegram.0", "send", {
        text: text.replace(/;/gm, "\n"),
        user: user,
    });
}
function sendEMail(text, to, subject) {
    sendTo("email.0", "send", {
        text: text.replace(/;/gm, "\n"),
        to: to,
        subject: subject
    });
}
function sendAlexa(text, lautstaerke) {
    setState('alexa2.0.Echo-Devices.xxxxxxxxxx.Commands.speak-volume', lautstaerke);
    setState('alexa2.0.Echo-Devices.xxxxxxxxxx.Commands.speak', text,);
}

 
async function main() {
    let xml = await getData()
    let json = await xml2json(xml);
    let einsaetze = normalizeData(json.webext2.einsaetze.einsatz);
    let einsaetze_einheiten = filterEinheiten(einsaetze, [410321, 410327]);
    let einsaetze_bezirk = filterBezirk(einsaetze,10);
    let html1 = toHtml(einsaetze_einheiten);
    let html2 = toHtml(einsaetze_bezirk);
    let html3 = toHtml(einsaetze);
    let messages = await prepareMessages(einsaetze_bezirk, false, false);
    //messages = await prepareMessages(einsaetze, true, false);
    let nachtruhe=compareTime("01:00", "06:00","between");
    if (!nachtruhe || messages) sendAlexa(messages, 60);
    if (messages) sendTelegram(messages, "");
    if (messages) sendEMail(messages, "christian@xxxxxxxxx.at", "Neuer Feuerwehreinsatz");
    console.log(html1);
    console.log(html2);
    console.log(html3);
    //setState("0_userdata.0.testFolder.a", html3);
	setState("0_userdata.0.FF-Einsatz.Bezirk", html2);	
}
schedule('*/30 * * * * *',main)

Ausgabe schaut so aus:

Achtung
Feuerwehreinsatz in xxxxxx
Alarmstufe 0
Verkehrsunfall Aufräumarbeiten
Bezirk xxxxxx
Anzahl Feuerwehren 2