Loading CHANGELOG.md +1 −0 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ Versionsverlauf ## [Noch nicht veröffentlicht] - Anpassungen bei JavaDoc und Ergänzung von Stacktraceausgaben im Rahmen der Zertifizierung ## [Version 2.0.4] Loading src/main/java/de/bsvrz/dua/daufd/stufenaesse/MessStelleDaten.java +1 −0 Original line number Diff line number Diff line Loading @@ -34,6 +34,7 @@ import de.bsvrz.dua.daufd.vew.FBZ_Klasse; /** * TBD Dokumentation * Einfache POJO Klasse zur Verwaltung von Daten einer Messstelle * * @author Kappich Systemberatung */ Loading src/main/java/de/bsvrz/dua/daufd/stufenaesse/MessStellenDatenContainer.java +1 −0 Original line number Diff line number Diff line Loading @@ -44,6 +44,7 @@ import java.util.LinkedList; /** * TBD Dokumentation * Container für Daten von Messstellen * * @author Kappich Systemberatung */ Loading src/main/java/de/bsvrz/dua/daufd/stufenaesse/NaesseStufe.java +28 −1 Original line number Diff line number Diff line Loading @@ -134,6 +134,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return tabellenWFDNIzumNS; } /** * Initialisiert Tabelle der Nässestufen */ private static void initTable() { for(FBZ_Klasse klasse : FBZ_Klasse.values()) { Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table = new EnumMap<>(WFD_Stufe.class); Loading Loading @@ -222,6 +225,10 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu "ZeitNass1Trocken", "ZeitNass2Nass1", "ZeitNass3Nass2", "ZeitNass4Nass3" }; /** * Aktualisiert Messstellendaten und publiziert bzw. akualisiert gegebenenfalls Nässestufe. * @param resultate Messresultate */ public void aktualisiereDaten(ResultData[] resultate) { for(ResultData resData : resultate) { Loading @@ -246,7 +253,7 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu } /** * Aktualisiert die NaesseStefe einer MessStelle nach den Regel aus [Afo] * Aktualisiert die NaesseStufe einer MessStelle nach den Regel aus [Afo] * @param msDaten MessStelle * @param vorletzeZeitStempel Vorletze ZeitStempel * @param zeitStempel ZeitStempel Loading Loading @@ -297,6 +304,12 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu aktualisiereNsStufe(msDaten, neueStufe, zeitStempel); } /** * Überprüft Daten der Messstelle und aktualisiert gegebenenfalls ihre Nässestufe * @param msDaten Messstellendaten * @param neueStufe Neue Nässestufe * @param zeitStempel ZeitStempel */ private void aktualisiereNsStufe(final NaesseMessStelleDaten msDaten, NS_Stufe neueStufe, final long zeitStempel) { if(msDaten.minimumStufe != null && neueStufe.ordinal() >= msDaten.minimumStufe.ordinal() || msDaten.abtrockungsZeitStempel < zeitStempel){ Loading Loading @@ -373,8 +386,10 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu verwaltung.getVerbindung().sendData(resultat); } catch (DataNotSubscribedException e) { Debug.getLogger().error("Fehler bei Sendung der Daten fuer " + msDaten.messObject.getPid() + " ATG " + ATG_UFDMS_NS + " :\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e){ Debug.getLogger().error("Fehler bei Sendung der Daten fuer " + msDaten.messObject.getPid() + " ATG " + ATG_UFDMS_NS + " :\n" + e.getMessage()); e.printStackTrace(); } } Loading @@ -382,6 +397,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return null; } /** * Initialisiert eine Nässestufe */ public void initialisiere(IVerwaltung verwaltung) throws DUAInitialisierungsException { this.verwaltung = verwaltung; Loading Loading @@ -434,6 +452,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return new NaesseMessStelleDaten(so); } /** * Liest die Tabelle der Nässestufen-Konfiguration aus der parametrierten Datei ein */ protected void readTable(final IVerwaltung verwaltung, final String argument, final Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table) { String naesseStufenKonfigDatei = verwaltung.getArgument(argument); if(naesseStufenKonfigDatei != null) { Loading Loading @@ -465,6 +486,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu } } /** * Generiert formatierten String der Tabelle von Nässestufen */ private String printTable(final Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table) { StringBuilder stringBuilder = new StringBuilder(); for(NI_Stufe ni_stufe : NI_Stufe.values()) { Loading @@ -480,6 +504,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return stringBuilder.toString(); } /** * Normalisiert gegebenen String zu einer Nässsestufenbezeichnung */ private NS_Stufe stringZuNsStufe(final String string) throws IOException { switch(string.toLowerCase()){ case "trocken" : return NS_Stufe.NS_TROCKEN; Loading src/main/java/de/bsvrz/dua/daufd/tp/Taupunkt.java +4 −0 Original line number Diff line number Diff line Loading @@ -528,12 +528,14 @@ public class Taupunkt implements IBearbeitungsKnoten, ClientSenderInterface { + DD_UFDMS_TT_FB.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e) { LOGGER.error( "Sendung von Datensatz " + DD_UFDMS_TT_FB.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } } Loading Loading @@ -568,12 +570,14 @@ public class Taupunkt implements IBearbeitungsKnoten, ClientSenderInterface { + DD_UFDMS_TT_L.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e) { LOGGER.error( "Sendung von Datensatz " + DD_UFDMS_TT_L.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } } Loading Loading
CHANGELOG.md +1 −0 Original line number Diff line number Diff line Loading @@ -3,6 +3,7 @@ Versionsverlauf ## [Noch nicht veröffentlicht] - Anpassungen bei JavaDoc und Ergänzung von Stacktraceausgaben im Rahmen der Zertifizierung ## [Version 2.0.4] Loading
src/main/java/de/bsvrz/dua/daufd/stufenaesse/MessStelleDaten.java +1 −0 Original line number Diff line number Diff line Loading @@ -34,6 +34,7 @@ import de.bsvrz.dua.daufd.vew.FBZ_Klasse; /** * TBD Dokumentation * Einfache POJO Klasse zur Verwaltung von Daten einer Messstelle * * @author Kappich Systemberatung */ Loading
src/main/java/de/bsvrz/dua/daufd/stufenaesse/MessStellenDatenContainer.java +1 −0 Original line number Diff line number Diff line Loading @@ -44,6 +44,7 @@ import java.util.LinkedList; /** * TBD Dokumentation * Container für Daten von Messstellen * * @author Kappich Systemberatung */ Loading
src/main/java/de/bsvrz/dua/daufd/stufenaesse/NaesseStufe.java +28 −1 Original line number Diff line number Diff line Loading @@ -134,6 +134,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return tabellenWFDNIzumNS; } /** * Initialisiert Tabelle der Nässestufen */ private static void initTable() { for(FBZ_Klasse klasse : FBZ_Klasse.values()) { Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table = new EnumMap<>(WFD_Stufe.class); Loading Loading @@ -222,6 +225,10 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu "ZeitNass1Trocken", "ZeitNass2Nass1", "ZeitNass3Nass2", "ZeitNass4Nass3" }; /** * Aktualisiert Messstellendaten und publiziert bzw. akualisiert gegebenenfalls Nässestufe. * @param resultate Messresultate */ public void aktualisiereDaten(ResultData[] resultate) { for(ResultData resData : resultate) { Loading @@ -246,7 +253,7 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu } /** * Aktualisiert die NaesseStefe einer MessStelle nach den Regel aus [Afo] * Aktualisiert die NaesseStufe einer MessStelle nach den Regel aus [Afo] * @param msDaten MessStelle * @param vorletzeZeitStempel Vorletze ZeitStempel * @param zeitStempel ZeitStempel Loading Loading @@ -297,6 +304,12 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu aktualisiereNsStufe(msDaten, neueStufe, zeitStempel); } /** * Überprüft Daten der Messstelle und aktualisiert gegebenenfalls ihre Nässestufe * @param msDaten Messstellendaten * @param neueStufe Neue Nässestufe * @param zeitStempel ZeitStempel */ private void aktualisiereNsStufe(final NaesseMessStelleDaten msDaten, NS_Stufe neueStufe, final long zeitStempel) { if(msDaten.minimumStufe != null && neueStufe.ordinal() >= msDaten.minimumStufe.ordinal() || msDaten.abtrockungsZeitStempel < zeitStempel){ Loading Loading @@ -373,8 +386,10 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu verwaltung.getVerbindung().sendData(resultat); } catch (DataNotSubscribedException e) { Debug.getLogger().error("Fehler bei Sendung der Daten fuer " + msDaten.messObject.getPid() + " ATG " + ATG_UFDMS_NS + " :\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e){ Debug.getLogger().error("Fehler bei Sendung der Daten fuer " + msDaten.messObject.getPid() + " ATG " + ATG_UFDMS_NS + " :\n" + e.getMessage()); e.printStackTrace(); } } Loading @@ -382,6 +397,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return null; } /** * Initialisiert eine Nässestufe */ public void initialisiere(IVerwaltung verwaltung) throws DUAInitialisierungsException { this.verwaltung = verwaltung; Loading Loading @@ -434,6 +452,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return new NaesseMessStelleDaten(so); } /** * Liest die Tabelle der Nässestufen-Konfiguration aus der parametrierten Datei ein */ protected void readTable(final IVerwaltung verwaltung, final String argument, final Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table) { String naesseStufenKonfigDatei = verwaltung.getArgument(argument); if(naesseStufenKonfigDatei != null) { Loading Loading @@ -465,6 +486,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu } } /** * Generiert formatierten String der Tabelle von Nässestufen */ private String printTable(final Map<WFD_Stufe, Map<NI_Stufe, NS_Stufe>> table) { StringBuilder stringBuilder = new StringBuilder(); for(NI_Stufe ni_stufe : NI_Stufe.values()) { Loading @@ -480,6 +504,9 @@ public class NaesseStufe extends MessStellenDatenContainer implements IBearbeitu return stringBuilder.toString(); } /** * Normalisiert gegebenen String zu einer Nässsestufenbezeichnung */ private NS_Stufe stringZuNsStufe(final String string) throws IOException { switch(string.toLowerCase()){ case "trocken" : return NS_Stufe.NS_TROCKEN; Loading
src/main/java/de/bsvrz/dua/daufd/tp/Taupunkt.java +4 −0 Original line number Diff line number Diff line Loading @@ -528,12 +528,14 @@ public class Taupunkt implements IBearbeitungsKnoten, ClientSenderInterface { + DD_UFDMS_TT_FB.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e) { LOGGER.error( "Sendung von Datensatz " + DD_UFDMS_TT_FB.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } } Loading Loading @@ -568,12 +570,14 @@ public class Taupunkt implements IBearbeitungsKnoten, ClientSenderInterface { + DD_UFDMS_TT_L.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } catch (SendSubscriptionNotConfirmed e) { LOGGER.error( "Sendung von Datensatz " + DD_UFDMS_TT_L.getAttributeGroup().getPid() + " fuer Objekt " + lDaten.messStelle.getPid() + " unerfolgreich:\n" + e.getMessage()); e.printStackTrace(); } } Loading