public class AbfragePufferdaten extends Object implements de.bsvrz.sys.funclib.application.StandardApplication, de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface
Modifier and Type | Field and Description |
---|---|
protected static String |
P_ABFRAGE_MODUL
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static String |
P_ALLE_ONLINE
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static String |
P_SM
Parameter dem man erkennen soll SteuerModule und Konfigurationsbereiche
die verwaltet werden sollen.
|
protected static long |
ZEIT_TOLERANZ
Wenn Zwei Zeitstempel fuer Abrufe innerhalb dieses Intervalls sind, dann
koennen wir sie als gleich betrachten, vermeidet 2 Abrufe in der selben
Zeit.
|
Constructor and Description |
---|
AbfragePufferdaten() |
Modifier and Type | Method and Description |
---|---|
void |
abmeldeGloFehler()
Meldet sich von GloFehler Meldungen ab.
|
void |
aggregationStart()
Startet die Aggregation von LZD.
|
void |
aggregiere()
Stellt dem Wecker fuer die naechste Aggregation fest.
|
void |
anmeldeAbfrageModulParametrierung()
Meldet sich online fuer die AbfrageModul Parametrierung an.
|
void |
anmeldeGloFehler()
Anmeldung fuer Empfang von Globalen FehlerMeldungen.
|
void |
axlAlarm()
Startet eine regelmaesige Axl Abfrage.
|
long |
convertAbsoluteEchtZeit(long zeit)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertAbsoluteVirtuelleZeit(long zeit)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertTimeoutIntervall(long intervall)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertZeitIntervall(long zeitIntervall)
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
currentTimeMillis()
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
de.bsvrz.dav.daf.main.DataDescription |
erzeugeDatenBeschreibung(String atg,
String asp,
short var)
Erzeugt eine DatenBeschreibung mit gegebenen Parameter als Strings.
|
static String |
getAbfrageModul()
Erfragt die PID des assoziierten Abfragemoduls.
|
long |
getAbrufIntervallAxl()
Erfargt nach dem Abrufintervall fuer Axl Daten.
|
long |
getAbrufIntervallLve()
Erfraget nach den Abrufintervall fuer Lve Daten.
|
static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager |
getArchivSettingsManager()
liefert den aktiven Settingsmanager für den Archivdatensatz.
|
protected AbstraktDeVerwaltung |
getAxlDeVerwaltung() |
de.bsvrz.dav.daf.main.ClientDavInterface |
getDatenVerteiler()
Erfragt eine Instanz des DAVs.
|
protected de.bsvrz.dav.daf.main.ClientDavInterface |
getDav() |
protected AbstraktDeVerwaltung |
getLveDeVerwaltung() |
de.bsvrz.sys.funclib.operatingMessage.MessageSender |
getnachrichtenSender()
Liefert dem Nachrichtensender.
|
protected long |
getNaechsteAbfrageAxl() |
protected long |
getNaechsteAbfrageAxlNeu() |
protected long |
getNaechsteAbfrageLve() |
protected long |
getNaechsteAbfrageLveNeu() |
protected List<Station> |
getStationen() |
de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp |
getSWETyp()
Typ der SWE.
|
void |
initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) |
void |
initLveAxlVerwaltung()
Wegen Testzwecken wird es ueberschrieben.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
void |
lveAlarm()
Startet eine regelmaesige Lve Abfrage.
|
static void |
main(String[] args)
Wird zum Start der Applikation aufgerufen.
|
void |
parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) |
static void |
printVerwendung()
Anwendungsparameter.
|
void |
setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei)
Stellt die Abrufperiode fest, wird bei Aenderung der Parametrierung
gerufen.
|
protected void |
setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung) |
void |
setGloFehler(de.bsvrz.dav.daf.main.ResultData datei)
Stelt den Status des Objektes aus einer GloFehlermeldung fest.
|
protected void |
setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung) |
protected void |
setLzdAggregation(AggregatorVerwaltung lzdAggregation) |
void |
streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter,
Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte,
de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
boolean relative,
long intervalBeginnOderAnzahl,
long intervalEnde)
Macht eine StreamAbfrage.
|
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
protected static final String P_SM
protected static final String P_ALLE_ONLINE
protected static final String P_ABFRAGE_MODUL
protected static final long ZEIT_TOLERANZ
public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) throws Exception
parseArguments
in interface de.bsvrz.sys.funclib.application.StandardApplication
Exception
public static void printVerwendung()
public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) throws Exception
initialize
in interface de.bsvrz.sys.funclib.application.StandardApplication
Exception
public static final String getAbfrageModul()
null
,
wenn keines angegeben wurdepublic void initLveAxlVerwaltung()
public de.bsvrz.dav.daf.main.DataDescription erzeugeDatenBeschreibung(String atg, String asp, short var)
atg
- Atributgruppeasp
- Aspektvar
- Simulation Variantpublic void anmeldeAbfrageModulParametrierung()
public void anmeldeGloFehler()
public de.bsvrz.sys.funclib.operatingMessage.MessageSender getnachrichtenSender()
public void abmeldeGloFehler()
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 update(de.bsvrz.dav.daf.main.ResultData[] results)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public void streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter, Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, boolean relative, long intervalBeginnOderAnzahl, long intervalEnde)
bearbeiter
- Der Objekt, der die Antwort bearbeiten wird, muss
SBArchivAnfrageBearbeiter implementierenobjekte
- Die Objekte, an deren Daten wir nachfragen wollendatenBeschreibung
- Die DatenBeschreibung fuer die Datenrelative
- true, wenn die Abfrage relativ istintervalBeginnOderAnzahl
- Beginn des abfragenden Intervalls oder Anzahl der Datensaetze
bei relativen AbfragenintervalEnde
- Ende des abfrafenden Intervallspublic void setGloFehler(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.tlsGloFehler, die empfangen wurdepublic void setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.abfrageModul, die empfangen wurdepublic void axlAlarm()
public void lveAlarm()
public static void main(String[] args)
args
- Aufrufargumente der Applikationpublic de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp getSWETyp()
public de.bsvrz.dav.daf.main.ClientDavInterface getDatenVerteiler()
public void aggregiere()
public void aggregationStart()
public long getAbrufIntervallAxl()
public long getAbrufIntervallLve()
public long currentTimeMillis()
public long convertZeitIntervall(long zeitIntervall)
zeitIntervall
- Virtueller ZeitIntervallpublic long convertTimeoutIntervall(long intervall)
intervall
- Virtueller Timeout Intervallpublic long convertAbsoluteEchtZeit(long zeit)
zeit
- Echter Zeitpunktpublic long convertAbsoluteVirtuelleZeit(long zeit)
zeit
- Virtueller Zeitpunktpublic static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager getArchivSettingsManager()
protected AbstraktDeVerwaltung getLveDeVerwaltung()
protected AbstraktDeVerwaltung getAxlDeVerwaltung()
protected void setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung)
protected void setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung)
protected long getNaechsteAbfrageLveNeu()
protected long getNaechsteAbfrageLve()
protected long getNaechsteAbfrageAxlNeu()
protected long getNaechsteAbfrageAxl()
protected void setLzdAggregation(AggregatorVerwaltung lzdAggregation)
protected de.bsvrz.dav.daf.main.ClientDavInterface getDav()
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.