public abstract class AbstraktAggregator extends 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 String[] |
FZ_ATTRIB
Attributnamen für Verkehrsdaten.
|
protected static String |
STR_GUETE
Attributname für "Güte".
|
protected static String |
STR_INDEX
Attributname für "Index".
|
protected static String |
STR_VERFAHREN
Attributname für "Verfahren".
|
protected static String |
STR_WERT
Attributname für "Wert".
|
protected static 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,
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,
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,
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 String TYP_LANGZEITZAEHLSTELLE
protected static final String[] FZ_ATTRIB
protected static final String STR_WERT
protected static final String STR_GUETE
protected static final String STR_INDEX
protected static final 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,
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,
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,
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,
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()
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.