Skip to content

S
SWE_de.bsvrz.ste.tmcvew
Commit 8d574dd9 authored by Steffen Gieseler's avatar Steffen Gieseler
Browse files
Options

Version 1.0.0 

git-svn-id: svn://ntoserver/Datenverteiler/VRZ3/trunk/de.bsvrz.ste.tmcvew@64125 40c0be50-5d29-0410-901d-fb59edb5cafc
parent fba7d29b
Hide whitespace changes
Inline Side-by-side
Showing with 11 additions and 105 deletions
pom.xml
View file @ 8d574dd9
......@@ -2,7 +2,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>de.bsvrz.ste</groupId>
<artifactId>de.bsvrz.ste.tmcvew</artifactId>
<version>0.9.2-SNAPSHOT</version>
<version>1.0.0-SNAPSHOT</version>
<name>Segment STE, SWE TMC-Meldungsverwaltung</name>
<url>http://www.bitctrl.de</url>
......@@ -14,7 +14,7 @@
<licenses>
<license>
<name>GNU General Public License, Version 2</name>
<name>GNU General Public License, Version 3</name>
<url>LICENSE.txt</url>
</license>
</licenses>
......@@ -24,7 +24,7 @@
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>8</java.version>
<project.status>BETA</project.status>
<project.standDatum>2016-09-16</project.standDatum>
<project.standDatum>2016-10-24</project.standDatum>
</properties>
<repositories>
......@@ -229,5 +229,5 @@
<name>BitCtrl Nexus Snapshots Repository</name>
<url>http://bitctrlbuildserver:8081/nexus/content/repositories/snapshots/</url>
</repository>
</distributionManagement>
</distributionManagement>
</project>
\ No newline at end of file
src/main/java/de/bsvrz/ste/tmcvew/TMCVerwaltung.java
View file @ 8d574dd9
......@@ -58,7 +58,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
* @version $Id$
*/
public class TMCVerwaltung implements MutableSetChangeListener, InvalidationListener, ClientReceiverInterface {
/**
......@@ -188,14 +188,6 @@ public class TMCVerwaltung implements MutableSetChangeListener, InvalidationList
return lmsObjekt;
}
// /**
// * .
// * @return true, falls die Korrektur unterdrückt wird, wenn ein Zeitstempel
// * einer Meldung in der Vergangenheit liegt, false sonst
// */
// public boolean getOhneZeitstempelKorrektur() {
// return ohneZeitstempelKorrektur;
// }
@Override
public void update(final MutableSet set, final SystemObject[] addedObjects, final SystemObject[] removedObjects) {
......
src/main/java/de/bsvrz/ste/tmcvew/TMCVerwaltungApp.java
View file @ 8d574dd9
......@@ -46,7 +46,7 @@ import de.bsvrz.sys.funclib.operatingMessage.MessageSender;
* Erstellt auf Basis der SWE RDS/TMC-Verwaltung von: Dambach Werke GmbH, Stefan Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
* @version $Id$
*/
public class TMCVerwaltungApp implements StandardApplication {
/**
......@@ -69,8 +69,6 @@ public class TMCVerwaltungApp implements StandardApplication {
*/
private int ohneZeitstempelKorrektur;
// public static final int OPTION_OHNE_ZEITSTEMPEL_KORREKTUR = 4;
// public static final int MASKE_OHNE_ZEITSTEMPEL_KORREKTUR = 4;
private static final String LMS_TYP = "typ.tmcLandesMeldeStelle";
......@@ -141,13 +139,6 @@ public class TMCVerwaltungApp implements StandardApplication {
lmsPid = argumentList.fetchArgument("-lms=").asNonEmptyString();
// if (argumentList.hasArgument("-ohneZeitstempelKorrektur")) {
// final String text = argumentList.fetchArgument("-ohneZeitstempelKorrektur=").asString();
// if ("1".equals(text) || "true".equalsIgnoreCase(text) || "wahr".equalsIgnoreCase(text)) {
// ohneZeitstempelKorrektur = OPTION_OHNE_ZEITSTEMPEL_KORREKTUR;
// }
// }
argumentList.fetchUnusedArguments();
}
......
src/main/java/de/bsvrz/ste/tmcvew/TMCVewMeldung.java
View file @ 8d574dd9
......@@ -51,7 +51,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
* @version $Id$
*/
public class TMCVewMeldung implements ClientReceiverInterface {
/**
......@@ -180,12 +180,6 @@ public class TMCVewMeldung implements ClientReceiverInterface {
/** Gel&ouml;scht. */
Geloescht("Gelöscht", 3);
// @Deprecated
// Aufhebung("Aufhebung", 300),
//
// @Deprecated
// Loeschung("Loeschung", 301);
/**
* textueller Wert.
*/
......@@ -249,25 +243,6 @@ public class TMCVewMeldung implements ClientReceiverInterface {
}
}
// /**
// * Der Status einer Meldung.
// */
// public enum Status {
// // Unbekannt, Modifikation, Aufhebung, Loeschung, Erweiterung;
// Unbekannt, Neu, Geändert, Gelöscht;
//
// /**
// * Bestimmt den Status zu einem Text.
// *
// * @param text
// * der Text, zu dem der Status bestimmt werde soll
// * @return den Status zum übergebenen Text
// */
// public static Status get(final String text) {
// return Status.valueOf(text);
// }
// }
/**
* Der Zustand einer Meldung.
*/
......@@ -403,14 +378,6 @@ public class TMCVewMeldung implements ClientReceiverInterface {
sender = new TMCVewSender(this);
/*
* Restauriere unter dem Aspekt TMCBearbeitet empfangene Daten aus den
* Parametern - da diese Daten als Senke empfangen wurden
*/
// _datenBearbeitet = new ParameterEmpfaenger(getConnection(),
// getDavObjekt(), "atg.rdsMeldungBearbeitet",
// "atg.rdsMeldung").getData();
datenBearbeitet = new ParameterEmpfaenger(getConnection(), getDavObjekt(), "atg.tmcVerkehrsMeldung",
datenBeschreibungBearbeitet).getData();
......@@ -710,16 +677,6 @@ public class TMCVewMeldung implements ClientReceiverInterface {
*/
if (datenSenden != null) {
final TMCStatus sendeStatus = getStatus(datenSenden);
// if (sendeStatus == TMCStatus.Aufhebung) {
// if (status != TMCStatus.Loeschung || true) {
// DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit
// Status " + sendeStatus
// + " vor - nur Aktualisierungen mit Status " + TMCStatus.Loeschung
// + " werden weitergeleitet"
// + suffixFehler);
// return;
// }
// } else
if (sendeStatus == TMCStatus.Geloescht) {
DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit Status " + sendeStatus + " vor"
+ suffixFehler);
......@@ -737,9 +694,6 @@ public class TMCVewMeldung implements ClientReceiverInterface {
? datenBearbeitet.getData() : null;
final Zustand zustandBearbeitet = datenBearbeitetData != null ? getZustand(datenBearbeitetData) : null;
if ((zustandBearbeitet == Zustand.Editiert || zustandBearbeitet == Zustand.Verworfen)) {
// Gieseler, angepasst für Test 15
// && (datenSenden == null || !(getZustand(datenSenden) ==
// Zustand.Verworfen))) {
DEBUG.config(
text + "\nEs liegen bearbeitete Daten im Zustand " + zustandBearbeitet + " vor" + suffixFehler);
return;
......@@ -786,15 +740,8 @@ public class TMCVewMeldung implements ClientReceiverInterface {
* nach unten korrigiert, wenn der Zeitstempel in der Vergangenheit
* liegt.
*/
final long aktuelleZeit = getConnection().getTime();
long verzoegerung = getRDSMeldungsRueckhaltung() * 1000;
// if (!verwaltung.getOhneZeitstempelKorrektur() && zeitStempel < aktuelleZeit) {
// verzoegerung -= (aktuelleZeit - zeitStempel);
// if (verzoegerung < 0) {
// verzoegerung = 0;
// }
// }
final long verzoegerung = getRDSMeldungsRueckhaltung() * 1000;
text += "\nEmpfangene generierte Daten werden zur Weiterleitung gemäß RDSMeldungsAktion in "
+ Math.round(verzoegerung / 1000) + "s freigegeben";
DEBUG.config(text);
......@@ -827,5 +774,4 @@ public class TMCVewMeldung implements ClientReceiverInterface {
public String getRDSMeldungsAktion() {
return verwaltung.getRDSMeldungsAktion();
}
}
src/main/java/de/bsvrz/ste/tmcvew/TMCVewSender.java
View file @ 8d574dd9
......@@ -50,7 +50,7 @@ import de.bsvrz.sys.funclib.debug.Debug;
* Sans
*
* @author BitCtrl Systems GmbH, Gieseler
* @version $Id: $
* @version $Id$
*/
public class TMCVewSender implements ClientSenderInterface {
/**
......@@ -130,14 +130,6 @@ public class TMCVewSender implements ClientSenderInterface {
final Aspect asp = getConnection().getDataModel().getAspect("asp.tmcSenden");
datenBeschreibung = new DataDescription(atg, asp);
// /*
// * Restauriere unter dem Aspekt RDSSenden gesendete Daten aus den
// * Parametern - da diese Daten als Quelle versendet wurden
// */
// _datenSenden = new ParameterEmpfaenger(getConnection(),
// getDavObjekt(), "atg.rdsMeldungSenden",
// "atg.rdsMeldung").getData();
try {
getConnection().subscribeSender(this, getDavObjekt(), datenBeschreibung, ROLLE);
DEBUG.fine(datenBeschreibung + " zum Senden angemeldet für " + getDavObjekt());
......@@ -193,10 +185,6 @@ public class TMCVewSender implements ClientSenderInterface {
return false;
}
return true;
// } else {
// DEBUG.warning("Keine Sendesteuerung für " +
// getDavObjekt().getPid(), e);
// return false;
}
} catch (final DataNotSubscribedException e) {
DEBUG.error("Keine Sendeanmeldung bzw. Sendeanmeldung ungültig für " + getDavObjekt().getPid(), e);
......@@ -420,5 +408,4 @@ public class TMCVewSender implements ClientSenderInterface {
}
}
}
}
src/main/java/de/bsvrz/ste/tmcvew/parameter/ParameterEmpfaenger.java
View file @ 8d574dd9
......@@ -140,14 +140,6 @@ public class ParameterEmpfaenger implements ClientReceiverInterface {
DEBUG.finest("Empfang abgemeldet von " + datenBeschreibungQuell + " für " + davObjekt);
}
// /**
// * @deprecated Nur zur Rückwartskompatibilität erhalten, Ziel-Aspekt wird
// * hier (fälschlicherweise?) auf asp.parameterSoll gesetzt
// */
// public ParameterEmpfaenger(final ClientDavInterface con, final SystemObject obj, final String atgQuellPid, final String atgZielPid) {
// this(con, obj, atgQuellPid, new DataDescription(con.getDataModel().getAttributeGroup(atgZielPid),
// con.getDataModel().getAspect("asp.parameterSoll")));
// }
/**
* Gibt die empfangenen Daten zur&uuml;ck.
......
src/main/java/de/bsvrz/ste/tmcvew/parameter/ParameterSender.java
View file @ 8d574dd9
......@@ -153,9 +153,7 @@ public class ParameterSender extends Thread implements ClientSenderInterface {
} catch (final SendSubscriptionNotConfirmed ex) {
DEBUG.warning("Keine Sendesteuerung für " + davObjekt.getPid(), ex);
}
} else {
DEBUG.warning("Keine Sendesteuerung für " + davObjekt.getPid(), e);
}
}
} catch (final DataNotSubscribedException e) {
DEBUG.error("Keine Sendeanmeldung bzw. Sendeanmeldung ungültig für " + davObjekt.getPid(), e);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment