import { useEffect, useState } from "react"; import { SERVER_URL } from "../config/urls"; const useLineData = (webserviceGisLinesStatusUrl, setLineStatusData) => { const [lineColors, setLineColors] = useState({}); const [tooltipContents, setTooltipContents] = useState({}); useEffect(() => { const fetchData = async () => { try { console.log("Daten werden abgerufen..."); const response1 = await fetch(webserviceGisLinesStatusUrl); const data1 = await response1.json(); const response2 = await fetch(`${SERVER_URL}:3000/api/talas_v5_DB/gisLines/readGisLines`); const data2 = await response2.json(); const response3 = await fetch(`${SERVER_URL}:3000/api/talas_v5_DB/station/getAllStationsNames`); const namesData = await response3.json(); const colorsByModule = {}; const newTooltipContents = {}; const valueMap = {}; // Logik zur Gruppierung der Daten logGroupedData(data1.Statis); // Sortiere die Meldungen nach Level, damit die höchste Priorität (kleinster Level) zuerst kommt const sortedStatis = [...data1.Statis].sort((a, b) => a.Level - b.Level); //console.log("Sortierte Daten:", sortedStatis); // Filtere Objekte mit gleichem IdLD und Modul, und Level > 0, und entferne die Objekte mit dem höchsten Level const filteredStatis = []; const seenKeys = new Set(); sortedStatis.forEach((statis) => { const key = `${statis.IdLD}-${statis.Modul}`; if (statis.Level > 0) { if (!seenKeys.has(key)) { seenKeys.add(key); filteredStatis.push(statis); // Behalte das Objekt mit dem niedrigsten Level (höchste Priorität) } } else { // Für Level -1 oder nicht relevante Meldungen einfach hinzufügen filteredStatis.push(statis); } }); //console.log("Gefilterte Daten (Objekte mit höchstem Level entfernt):", filteredStatis); filteredStatis.forEach((statis) => { const key = `${statis.IdLD}-${statis.Modul}`; if (!valueMap[key]) { valueMap[key] = { messages: [], messwert: undefined, schleifenwert: undefined, }; } // Sammle Messwert und Schleifenwert if (statis.DpName.endsWith("_Messwert") && statis.Value !== "True" && !valueMap[key].messwert) { valueMap[key].messwert = statis.Value; } if (statis.DpName.endsWith("_Schleifenwert") && !valueMap[key].schleifenwert) { valueMap[key].schleifenwert = statis.Value; } if (statis.Message && statis.Message !== "?") { valueMap[key].messages.push(statis.Message); } }); // Jetzt durch alle Prioritätslevel gehen und die Farben sowie Meldungen korrekt setzen filteredStatis.forEach((statis) => { const key = `${statis.IdLD}-${statis.Modul}`; const matchingLine = data2.find((item) => item.idLD === statis.IdLD && item.idModul === statis.Modul); if (matchingLine) { const prioColor = statis.PrioColor === "#ffffff" ? "green" : statis.PrioColor; const values = valueMap[key]; if (!values) { console.error(`Keine Werte gefunden für Key: ${key}`); return; } // Nachrichtenanzeige const messageDisplay = values.messages.map((msg) => (msg ? `${msg}
` : "")).join(""); const prioNameDisplay = statis.PrioName && statis.PrioName !== "?" ? `(${statis.PrioName})` : ""; // Setze die Farbe und Tooltip für jede Linie (für alle Prioritätslevel) colorsByModule[key] = prioColor; newTooltipContents[key] = `
${statis.ModulName || "Unknown"}
${statis.ModulTyp || "N/A"}
Slot: ${statis.Modul || "N/A"}
Station: ${namesData[matchingLine.idLD] || "N/A"}
${messageDisplay}
${prioNameDisplay}
${values.messwert ? `Messwert: ${values.messwert}
` : ""} ${values.schleifenwert ? `Schleifenwert: ${values.schleifenwert}` : ""}
`; } }); // Setze die Farben und Tooltip-Inhalte setLineColors(colorsByModule); setTooltipContents(newTooltipContents); setLineStatusData(data1.Statis); } catch (error) { console.error("Fehler beim Abrufen der Daten:", error); } }; fetchData(); // Setze ein Intervall, um die Daten alle 20 Sekunden erneut abzurufen const intervalId = setInterval(fetchData, 20000); // Räumt das Intervall auf, wenn die Komponente entladen wird return () => clearInterval(intervalId); }, [webserviceGisLinesStatusUrl, setLineStatusData]); return { lineColors, tooltipContents }; }; // Funktion zur Gruppierung der Daten function logGroupedData(statisList) { const grouped = statisList.reduce((acc, item) => { const { IdLD, Modul, Level, PrioColor, PrioName, ModulName, ModulTyp, Message, DpName, Value } = item; if (!acc[IdLD]) { acc[IdLD] = {}; } if (!acc[IdLD][Modul]) { acc[IdLD][Modul] = { ModulName: ModulName || "Unknown", ModulTyp: ModulTyp || "N/A", TotalLevel: Level, PrioColors: new Set(), PrioNames: new Set(), Messages: [], Messwert: undefined, Schleifenwert: undefined, }; } acc[IdLD][Modul].PrioColors.add(PrioColor); acc[IdLD][Modul].PrioNames.add(PrioName); if (Message && Message !== "?") { acc[IdLD][Modul].Messages.push(Message); } if (DpName.endsWith("_Messwert") && !acc[IdLD][Modul].Messwert) { acc[IdLD][Modul].Messwert = Value; } if (DpName.endsWith("_Schleifenwert") && !acc[IdLD][Modul].Schleifenwert) { acc[IdLD][Modul].Schleifenwert = Value; } return acc; }, {}); const formattedData = {}; Object.entries(grouped).forEach(([stationId, modules]) => { const filteredModules = Object.entries(modules) .filter(([modulId, data]) => data.ModulName !== "?") .map(([modulId, data]) => ({ Modul: modulId, ModulName: data.ModulName, ModulTyp: data.ModulTyp, TotalLevel: data.TotalLevel, PrioColors: Array.from(data.PrioColors).join(", "), PrioNames: Array.from(data.PrioNames).join(", "), Messages: data.Messages.join(" | "), Messwert: data.Messwert, Schleifenwert: data.Schleifenwert, })); if (filteredModules.length > 0) { formattedData[stationId] = filteredModules; } }); console.log("Aggregierte und gruppierte Daten (gefiltert):", formattedData); } export default useLineData;