de.bsvrz.dav.daf.main.ClientSenderInterface, SBArchivAnfrageBearbeiterAggregatorDTV, AggregatorFahrzeugAnzahl, AggregatorGeschwindigkeit, AggregatorMitHistorie, AggregatorSpizenStunde, AggregatorSpizenTagpublic abstract class AbstraktAggregator extends java.lang.Object implements de.bsvrz.dav.daf.main.ClientSenderInterface, SBArchivAnfrageBearbeiter
| Modifier and Type | Class | Description |
|---|---|---|
protected class |
AbstraktAggregator.LZZDaten |
Einfache Struktur um die ergaenzenden Daten zu eine LZZ speichern.
|
| Modifier and Type | Field | 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 | Description |
|---|---|
AbstraktAggregator() |
| Modifier and Type | Method | 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) |
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.ClientSenderInterfacepublic 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.ClientSenderInterfacepublic 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 SBArchivAnfrageBearbeiterobjekt - 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)
dateiID - Datenbeschreibung 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()