Beiträge von feuerloescher

// Script zum Abrufen von Einsatzdaten aus der Öffentlichen Connect-Schnittstelle 
// von Feuersoftware. Infos dazu im Community-Forum. 

// API-Endpunkt-URL und Bearer-Token
const apiUrl = 'https://connectapi.feuersoftware.com/interfaces/public/operation';
const bearerToken = 'DEIN-TOKEN-FUER-DIE-CONNECT-SCHNITTSTELLE'

// Objektpfad für die Speicherung der Daten, test ist das Unterverzeichnis und kann angepasst werden
const objectPath = 'feuersoftware.test';

// Überwachtes Objekt für die Auslösung des Skripts
const triggerObject = 'iot.0.services.custom_id-test';

// Liste der zu leerenden Objekte vor dem Abruf neuer Daten
const objectsToEmpty = [
    `${objectPath}.Facts`,
    `${objectPath}.HouseNumber`,
    `${objectPath}.Keyword`,
    `${objectPath}.Address`,
    `${objectPath}.Ric`,
    `${objectPath}.Properties.Objekt:`,
    `${objectPath}.Properties.weitereFelder1`,
    `${objectPath}.Properties.weitereFelder2`,
    `${objectPath}.Properties.usw`,

    
    // Füge weitere Objekte hinzu, die geleert werden sollen
];

// Platzhalterwert, durch den die Werte der Objekte ersetzt werden sollen
const placeholderValue = '';

// Funktion zum Ersetzen der Werte von bestimmten Objekten
async function replaceValues() {
    try {
        // Werte der spezifizierten Objekte ersetzen
        for (const objId of objectsToEmpty) {
            await setStateAsync(objId, { val: placeholderValue, ack: true });
        }

        console.log(`Die Werte der spezifizierten Objekte wurden durch "${placeholderValue}" ersetzt.`);
    } catch (error) {
        console.error(`Fehler beim Ersetzen der Werte: ${error}`);
    }
}

// Funktion zum Abrufen von Daten von der API und Verarbeiten der Daten
function fetchData() {
    // Holen des Wertes des überwachten Objekts
    const customIdTestValue = getState(triggerObject).val;
    httpGet(apiUrl, {bearerAuth: bearerToken}, async (err, response) =>{
        
    if (!err && response.statusCode === 200) {
            try {
                const data = JSON.parse(response.data);

                // Durchlaufe jedes Element in den Daten
                data.forEach((item) => {
                    // Vergleiche die ID mit dem Wert in custom_id-test
                    if (item.Id == customIdTestValue) {
                        // Erstelle den Objektpfad
                        const objectFullPath = `${objectPath}`;

                        // Erstelle die Objekte unter dem Pfad
                        createState(`${objectFullPath}.Start`, item.Start, true);
                        createState(`${objectFullPath}.CreatedAt`, item.CreatedAt, true);
                        createState(`${objectFullPath}.End`, item.End, true);
                        createState(`${objectFullPath}.Keyword`, item.Keyword, true);
                        createState(`${objectFullPath}.Category`, item.Category, true);
                        createState(`${objectFullPath}.Facts`, item.Facts, true);
                        createState(`${objectFullPath}.Ric`, item.Ric, true);

                        // Adresse
                        const addressData = item.Address || {};
                        createState(`${objectFullPath}.Address`, addressData.Address, true);
                        createState(`${objectFullPath}.Street`, addressData.Street, true);
                        createState(`${objectFullPath}.HouseNumber`, addressData.HouseNumber, true);
                        createState(`${objectFullPath}.ZipCode`, addressData.ZipCode, true);
                        createState(`${objectFullPath}.City`, addressData.City, true);
                        createState(`${objectFullPath}.District`, addressData.District, true);
                        createState(`${objectFullPath}.CityWithDistrict`, addressData.CityWithDistrict, true);
                        createState(`${objectFullPath}.CityWithDistrictAndZipCode`, addressData.CityWithDistrictAndZipCode, true);
                        createState(`${objectFullPath}.StreetWithHouseNumber`, addressData.StreetWithHouseNumber, true);
                        createState(`${objectFullPath}.Lng`, addressData.Lng, true);
                        createState(`${objectFullPath}.Lat`, addressData.Lat, true);

                        // Sonstige Daten
                        createState(`${objectFullPath}.Number`, item.Number, true);
                        createState(`${objectFullPath}.Source`, item.Source, true);

                        // Erstelle die Objekte für Properties
                        const properties = item.Properties || [];
                        properties.forEach((property) => {
                            createState(`${objectFullPath}.Properties.${property.Key}`, property.Value, true);
                        });

                        // Erstelle die Objekte für AdditionalInformation
                        const additionalInformation = item.AdditionalInformation || [];
                        additionalInformation.forEach((info, infoIndex) => {
                            createState(`${objectFullPath}.AdditionalInformation.${infoIndex}`, info, true);
                        });

                        // Info Log
                        log(`Neuen Einsatz unter ${objectFullPath} angelegt.`);
                    }
                });
            } catch (err) {
                log(`Fehler beim Parsen der API-Antwort: ${err}`);
            }
        } else {
            log(`Fehler bei der API-Anfrage. Statuscode: ${response.statusCode}`);
        }

    });
}

// Überwacht das Auslöseobjekt auf Änderungen und führt das Skript aus
on({ id: triggerObject, change: 'any' }, () => {
    // Vor dem Abrufen neuer Daten, leere die alten Daten
    replaceValues();

    // Rufe die neuen Daten ab
    fetchData();
});