public abstract class AbstraktAggregator extends java.lang.Object implements de.bsvrz.dav.daf.main.ClientSenderInterface, SBArchivAnfrageBearbeiter
Modifier and Type | Class and Description |
---|---|
protected class |
AbstraktAggregator.LZZDaten
Einfache Struktur um die ergaenzenden Daten zu eine LZZ speichern.
|
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String[] |
FZ_ATTRIB
Attributnamen für Verkehrsdaten.
|
protected static java.lang.String |
STR_GUETE
Attributname für "Güte".
|
protected static java.lang.String |
STR_INDEX
Attributname für "Index".
|
protected static java.lang.String |
STR_VERFAHREN
Attributname für "Verfahren".
|
protected static java.lang.String |
STR_WERT
Attributname für "Wert".
|
protected static java.lang.String |
TYP_LANGZEITZAEHLSTELLE
Stringkonstanten.
|
Constructor and Description |
---|
AbstraktAggregator() |
Modifier and Type | Method and Description |
---|---|
void |
abmeldeAlsSender()
Meldet sich als Sender fuer die Aggregierte Daten ab.
|
protected AbstraktAggregator.LZZDaten |
addLzzDaten(de.bsvrz.dav.daf.main.config.SystemObject object,
AbstraktAggregator.LZZDaten daten) |
void |
anmeldeUndSende(de.bsvrz.dav.daf.main.ResultData resultData)
Meldet sich als Sender fuer die Aggregierte Daten an und gleich schickt
einen DatenSatz ab.
|
void |
bearbeiteArchivDaten(de.bsvrz.dav.daf.main.config.SystemObject objekt,
de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
de.bsvrz.dav.daf.main.DataState status,
de.bsvrz.dav.daf.main.Data daten,
long zeitStempel)
Bearbeitet die Daten aus der StreamBasierten Archivanfrage, wird benutzt
um den Letzten ZeitStempel der Aggregierten Daten aus dem Archiv
auslesen.
|
abstract void |
bearbeiteDatenSatz(de.bsvrz.dav.daf.main.config.SystemObject objekt,
de.bsvrz.dav.daf.main.Data datensatz,
long zeitStempel)
Wird beim jeden einkommenden Datensatz gerufen.
|
void |
bearbeiteGeloeschteEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID,
de.bsvrz.dav.daf.main.Data alteDatei)
Ein Datensatz mit geloeschten Einstellungen gekommen ist - Nicht mehr
parametriert.
|
void |
bearbeiteNeueEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID,
de.bsvrz.dav.daf.main.Data neueDatei)
Ein Datensatz mit neuen Einstellungen gekommen ist - Neue Parametrierung.
|
void |
bearbeiteVeraenderteEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID,
de.bsvrz.dav.daf.main.Data neueDatei)
Ein Datensatz mit veraenderten Einstellungen gekommen ist -
Umparametrierung.
|
void |
copyAttribute(de.bsvrz.dav.daf.main.Data quelle,
de.bsvrz.dav.daf.main.Data ziel)
Copiert dem Wert und die Guete aus dem Quelle-DatenSatz ins Ziel.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
abstract void |
erzeugeErgebniss(de.bsvrz.dav.daf.main.config.SystemObject objekt,
long zeitStempelVon,
long zeitStempelBis,
boolean ermittelbar)
Erzeugt einen Datensatz zum abschicken.
|
protected de.bsvrz.dav.daf.main.DataDescription |
getDdAggregierteLzd() |
long |
getLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz)
Ergibt den Zeitpunkt der Letzten Aggregierten Daten.
|
protected AbstraktAggregator.LZZDaten |
getLzzDatenForSystemObject(de.bsvrz.dav.daf.main.config.SystemObject object) |
static long |
getTagesBeginnVonZeitStempel(long zeitStempel)
Aufrundet den ZeitStempel so, dass man dem Beginn des Tages bekommt in
dem der Zeitstepel liegt.
|
abstract de.bsvrz.dav.daf.main.DataDescription |
init(de.bsvrz.dav.daf.main.config.Aspect asp,
de.bsvrz.dav.daf.main.ClientDavInterface initialDav,
java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekteLZZ)
In dieser Methode soll jeder konkreter Aggregator Beschreibung seiner
Daten erzeugen und die Map von SystemObjekt LZZ zum eigenen
DatenStrukturen.
|
void |
initialisiere(de.bsvrz.dav.daf.main.config.Aspect asp,
de.bsvrz.dav.daf.main.ClientDavInterface initialDav,
java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekteLZZ,
long zeitpunktJetzt)
Initialisation, unter anderen stellt den Erfassungsintervall ein, liest
aus dem Archiv ab, zu welcher Zeitpunkt wurden die letzten Daten im
Archiv eingeschrieben.
|
void |
initLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz,
long zeitPunkt)
Setzt den Zeitpunkt der Daten ein, die als Startpunkt benutzt werden,
wenn es noch keine Aggregierte Daten im Archiv gibt.
|
static boolean |
isKeinArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz,
java.util.Collection<AbstraktAggregator> aggMenge)
Bsetimmt, ob fuer eine LZZ die aggregierte Daten archiviert werden.
|
boolean |
isLZZArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz)
Ergibt dem Archivierunsparameter der LZZ.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
protected void |
resetLzzDaten() |
void |
sendeDatenSatz(de.bsvrz.dav.daf.main.config.SystemObject objekt,
de.bsvrz.dav.daf.main.ResultData resDaten)
Sendet einen Datensatz, wenn noch nicht angemeldet ist fuer die Sendung,
dann meldet sich erst an.
|
void |
setAttributNichtErmittelbar(de.bsvrz.dav.daf.main.Data subData)
Setzt nur einen Attribut (Wert + Guete) als nich ermittelbar.
|
void |
setLeer(de.bsvrz.dav.daf.main.Data data)
Initialsiert einen Datensatz.
|
void |
setLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz,
long zeitPunkt)
Setzt den Zeitpunkt der letzten Aggregierten Daten ein.
|
void |
setLZZArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz,
boolean archiviert)
Setzt dem Archiviertunsparameter der LZZ.
|
void |
setNichtErmittelbar(de.bsvrz.dav.daf.main.Data data)
Setzt ein DatenSatz als nicht ermittelbar.
|
protected static final java.lang.String TYP_LANGZEITZAEHLSTELLE
protected static final java.lang.String[] FZ_ATTRIB
protected static final java.lang.String STR_WERT
protected static final java.lang.String STR_GUETE
protected static final java.lang.String STR_INDEX
protected static final java.lang.String STR_VERFAHREN
public abstract void bearbeiteDatenSatz(de.bsvrz.dav.daf.main.config.SystemObject objekt, de.bsvrz.dav.daf.main.Data datensatz, long zeitStempel)
objekt
- LZZdatensatz
- DatenzeitStempel
- zeitStempelpublic abstract de.bsvrz.dav.daf.main.DataDescription init(de.bsvrz.dav.daf.main.config.Aspect asp, de.bsvrz.dav.daf.main.ClientDavInterface initialDav, java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekteLZZ)
asp
- Aspekt der erzeugenden DateninitialDav
- DatenVerteilerverbindungobjekteLZZ
- Menge aller LZZpublic void initialisiere(de.bsvrz.dav.daf.main.config.Aspect asp, de.bsvrz.dav.daf.main.ClientDavInterface initialDav, java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekteLZZ, long zeitpunktJetzt)
asp
- Aspekt der erzeugenden DateninitialDav
- DatenVerteilerverbindungobjekteLZZ
- Menge aller LZZzeitpunktJetzt
- der initiale Startzeitpunktpublic abstract void erzeugeErgebniss(de.bsvrz.dav.daf.main.config.SystemObject objekt, long zeitStempelVon, long zeitStempelBis, boolean ermittelbar)
objekt
- LZZ fuer die der DatenSatz gehoertzeitStempelVon
- Intervall AnfangzeitStempelBis
- Intervall Endeermittelbar
- false, wenn alle Datensaetze nicht gekommen sind, sonst truepublic void sendeDatenSatz(de.bsvrz.dav.daf.main.config.SystemObject objekt, de.bsvrz.dav.daf.main.ResultData resDaten)
objekt
- Die LZZresDaten
- Datensatz zum sendenpublic void anmeldeUndSende(de.bsvrz.dav.daf.main.ResultData resultData)
resultData
- der zu versendende Datensatzpublic void abmeldeAlsSender()
public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription, byte state)
dataRequest
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription)
isRequestSupported
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public void bearbeiteArchivDaten(de.bsvrz.dav.daf.main.config.SystemObject objekt, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, de.bsvrz.dav.daf.main.DataState status, de.bsvrz.dav.daf.main.Data daten, long zeitStempel)
bearbeiteArchivDaten
in interface SBArchivAnfrageBearbeiter
objekt
- Das objekt, dass die Daten geliefert hatdatenBeschreibung
- Beschreibung der Datenstatus
- Typ der Datendaten
- Der DatensatzzeitStempel
- Zeitstempel des datensatzespublic void initLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz, long zeitPunkt)
lzz
- LZZzeitPunkt
- ZeitStempelpublic void setLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz, long zeitPunkt)
lzz
- LZZzeitPunkt
- ZeitStempelpublic long getLetzteAggregierteDatenZS(de.bsvrz.dav.daf.main.config.SystemObject lzz)
lzz
- LZZpublic void setLZZArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz, boolean archiviert)
lzz
- System Objekt LZZarchiviert
- true wenn daten archiviert werdenpublic boolean isLZZArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz)
lzz
- System Objekt LZZpublic void bearbeiteGeloeschteEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID, de.bsvrz.dav.daf.main.Data alteDatei)
dateiID
- Datenbeschreibung der EinstellungalteDatei
- Datensatz mit Werten der Einstellungpublic void bearbeiteNeueEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID, de.bsvrz.dav.daf.main.Data neueDatei)
dateiID
- Datenbeschreibung der EinstellungneueDatei
- Datensatz mit Werten der Einstellungpublic void bearbeiteVeraenderteEinstellung(de.bsvrz.sys.funclib.dataIdentificationSettings.DataIdentification dateiID, de.bsvrz.dav.daf.main.Data neueDatei)
dateiID
- Datenbeschreibung der EinstellungneueDatei
- Datensatz mit Werten der Einstellungpublic static long getTagesBeginnVonZeitStempel(long zeitStempel)
zeitStempel
- Ein Zeitstempelpublic void setAttributNichtErmittelbar(de.bsvrz.dav.daf.main.Data subData)
subData
- Der Datensatz der nur ein Wert enthaeltpublic void setLeer(de.bsvrz.dav.daf.main.Data data)
data
- DatenSatzpublic void setNichtErmittelbar(de.bsvrz.dav.daf.main.Data data)
data
- DatenSatzpublic static boolean isKeinArchiviert(de.bsvrz.dav.daf.main.config.SystemObject lzz, java.util.Collection<AbstraktAggregator> aggMenge)
lzz
- SystemObjekt LangZeitZaehlstelleaggMenge
- Menge der Aggregatorenpublic void copyAttribute(de.bsvrz.dav.daf.main.Data quelle, de.bsvrz.dav.daf.main.Data ziel)
quelle
- Quelle-Datebsatzziel
- Ziel-Datensatzprotected AbstraktAggregator.LZZDaten getLzzDatenForSystemObject(de.bsvrz.dav.daf.main.config.SystemObject object)
protected void resetLzzDaten()
protected AbstraktAggregator.LZZDaten addLzzDaten(de.bsvrz.dav.daf.main.config.SystemObject object, AbstraktAggregator.LZZDaten daten)
protected de.bsvrz.dav.daf.main.DataDescription getDdAggregierteLzd()