Commit 852cef08 authored by Steffen Gieseler's avatar Steffen Gieseler
Browse files

Tests erweitert 

git-svn-id: svn://ntoserver/Datenverteiler/VRZ3/trunk/de.bsvrz.kex.lmstic3@63629 40c0be50-5d29-0410-901d-fb59edb5cafc
parent 773bdaf3

src/test/java/de/bsvrz/kex/lmstic3/empfang/dekoder/TestParser.java

+58 −2
Original line number Diff line number Diff line
@@ -48,7 +48,7 @@ public class TestParser { 
	 * Testmethode Einlesen Datei.

	 */

	@Test

	public void testParser() {

	public void testParser1() {

		// URL dateiurl =

		// ClassLoader.getSystemResource("de/bsvrz/kex/lms/empfang/dekoder/TICMeldungen.xml");
@@ -71,6 +71,62 @@ public class TestParser { 


		} catch (final TIC3InfoDateiException e) {

			Assert.fail(e.getMessage());

			e.printStackTrace();

		} catch (final Exception e) {

			Assert.fail(e.getMessage());

		}

	}



	/**

	 * Testmethode Einlesen Datei.

	 */

	@Test

	public void testParser2() {

		// URL dateiurl =

		// ClassLoader.getSystemResource("de/bsvrz/kex/lms/empfang/dekoder/TICMeldungen.xml");



		final String testdatei = "res/TIC3_2_ungueltige_Meldungen.XML";



		try {

			final TIC3InfoDatei datei = new TIC3InfoDatei(new File(testdatei));



			final List<TIC3MeldungsDaten> meldungen = new ArrayList<>(datei.bildeMeldungen(false));

			Assert.assertEquals(2, meldungen.size());



//			final TIC3MeldungsDaten meldung = meldungen.get(0);

//

//			Assert.assertEquals("DatenKennung", "LMS-BW/r_LMS-BW/1266", meldung.getDatenKennung());

//			Assert.assertEquals("DatenProduzent", "D BW LMS-BW", meldung.getDatenProduzent());

//			Assert.assertEquals("Beschreibung",

//					"A5 Karlsruhe Richtung Basel zwischen Dreieck Weil am Rhein und Grenzübergang Weil am Rhein/Basel 1 km Stau für LKW",

//					meldung.getEreignisBeschreibung());

//			Assert.assertEquals("Status", TMCStatusEnum.Geaendert, meldung.getTMCMeldungsStatus());



		} catch (final TIC3InfoDateiException e) {

			Assert.fail(e.getMessage());

			e.printStackTrace();

		} catch (final Exception e) {

			Assert.fail(e.getMessage());

		}

	}

	/**

	 * Testmethode Einlesen Datei.

	 */

	@Test

	public void testParser3() {

		// URL dateiurl =

		// ClassLoader.getSystemResource("de/bsvrz/kex/lms/empfang/dekoder/TICMeldungen.xml");



		final String testdatei = "res/TIC2MeldungTest1.xml";



		try {

			final TIC3InfoDatei datei = new TIC3InfoDatei(new File(testdatei));



			final List<TIC3MeldungsDaten> meldungen = new ArrayList<>(datei.bildeMeldungen(false));

			Assert.assertEquals(0, meldungen.size());

		} catch (final TIC3InfoDateiException e) {

			Assert.fail(e.getMessage());

			e.printStackTrace();

		} catch (final Exception e) {

			Assert.fail(e.getMessage());

		}

src/test/java/de/bsvrz/kex/lmstic3/empfang/dekoder/TestPublizieren.java

+10 −11
Original line number Diff line number Diff line
@@ -46,7 +46,6 @@ import de.bsvrz.kex.lmstic3.vew.daten.tic.TIC3Meldung; 
import de.bsvrz.kex.lmstic3.vew.daten.tic.TIC3MeldungsDaten;

import de.bsvrz.kex.lmstic3.vew.daten.tmc.ExterneMeldungsDaten;

import de.bsvrz.kex.lmstic3.vew.daten.tmc.TmcConverter;

import de.bsvrz.sys.funclib.dynobj.DynamischeObjekte;



/**

 * Testcase f&uuml;r das Einlesen von TIC-Info Dateien.
@@ -58,7 +57,7 @@ public class TestPublizieren { 
	/**

	 * Datenverteiler-Verbindung.

	 */

	TestDav dav = new TestDav();

	private TestDav dav = new TestDav();



	/**

	 * Testmethode Einlesen Datei.
@@ -86,7 +85,7 @@ public class TestPublizieren { 
			final Collection<TIC3MeldungsDaten> meldungen = datei.bildeMeldungen(false);

			Assert.assertEquals(1, meldungen.size());



			DynamischeObjekte doob = DynamischeObjekte.getInstanz(dav.getDav());

			// DynamischeObjekte doob = DynamischeObjekte.getInstanz(dav.getDav());



			for (final TIC3MeldungsDaten md : meldungen) {

				final String pid = md.bildePid();
@@ -94,7 +93,7 @@ public class TestPublizieren { 
				if (so == null) {

					System.out.println("neue Meldung " + pid + " wird angelegt");

					final SystemObjectType type = model.getType("typ.tmcTic3infoMeldung");

					so = area.createDynamicObject((DynamicObjectType) model.getType("typ.tmcTic3infoMeldung"), pid,

					so = area.createDynamicObject((DynamicObjectType) type, pid,

							pid);

					// meldungsmenge.add(so);

					// doob.erzeugeObjektInMenge(typ, name, pid, menge)
@@ -123,7 +122,7 @@ public class TestPublizieren { 


		try {

			Thread.sleep(30000);

		} catch (InterruptedException e) {

		} catch (final InterruptedException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}
@@ -138,24 +137,24 @@ public class TestPublizieren { 
			System.out.println("neue Meldung " + pid + " wird angelegt");

			final SystemObjectType type = model.getType("typ.tmcVerkehrsMeldung");

			try {

				so = area.createDynamicObject((DynamicObjectType) model.getType("typ.tmcVerkehrsMeldung"), pid, pid);

			} catch (ConfigurationChangeException e) {

				so = area.createDynamicObject((DynamicObjectType) type, pid, pid);

			} catch (final ConfigurationChangeException e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}

			// meldungsmenge.add(so);

		}



		AttributeGroup attributeGroup = dav.getDav().getDataModel().getAttributeGroup(TMCMeldung.ATG);

		Data createData = dav.getDav().createData(attributeGroup);

		final AttributeGroup attributeGroup = dav.getDav().getDataModel().getAttributeGroup(TMCMeldung.ATG);

		final Data createData = dav.getDav().createData(attributeGroup);



		TmcConverter conv = new TmcConverter(tic3meldung);

		final TmcConverter conv = new TmcConverter(tic3meldung);

		try {

			conv.toDAV(createData);

			final TMCMeldung tmcmeldung = new TMCMeldung(so);

			tmcmeldung.anmeldenDavEmpfang(dav.getDav());

			tmcmeldung.aktualisieren(dav.getDav(), createData);

		} catch (TIC3Exception e) {

		} catch (final TIC3Exception e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

src/test/java/de/bsvrz/kex/lmstic3/empfang/dekoder/TicDateiIT.java

+4 −20
Original line number Diff line number Diff line 
/*

 * Segment 2 (KEx),  SWE 2.1 LMS

 * Copyright (C) 2007 BitCtrl Systems GmbH

 * Segment 2 (KEx), SWE LMS-TIC3

 * Copyright (C) 2016 BitCtrl Systems GmbH 

 * 

 * This library is free software; you can redistribute it and/or modify it under

 * the terms of the GNU Lesser General Public License as published by the Free
@@ -18,7 +18,7 @@ 
 *

 * Contact Information:

 * BitCtrl Systems GmbH

 * Wei�enfelser Stra�e 67

 * Weißenfelser Straße 67

 * 04229 Leipzig

 * Phone: +49 341-490670

 * mailto: info@bitctrl.de
@@ -32,17 +32,6 @@ import java.util.Collection; 
import org.junit.Assert;

import org.junit.Test;



import de.bsvrz.dav.daf.main.config.ConfigurationArea;

import de.bsvrz.dav.daf.main.config.ConfigurationChangeException;

import de.bsvrz.dav.daf.main.config.ConfigurationObject;

import de.bsvrz.dav.daf.main.config.DataModel;

import de.bsvrz.dav.daf.main.config.DynamicObjectType;

import de.bsvrz.dav.daf.main.config.MutableSet;

import de.bsvrz.dav.daf.main.config.SystemObject;

import de.bsvrz.kex.lmstic3.empfang.dekoder.TIC3InfoDatei;

import de.bsvrz.kex.lmstic3.empfang.dekoder.TIC3InfoDateiException;

import de.bsvrz.kex.lmstic3.vew.TestDav;

import de.bsvrz.kex.lmstic3.vew.daten.tic.TIC3Meldung;

import de.bsvrz.kex.lmstic3.vew.daten.tic.TIC3MeldungsDaten;



/**
@@ -52,11 +41,6 @@ import de.bsvrz.kex.lmstic3.vew.daten.tic.TIC3MeldungsDaten; 
 */

public class TicDateiIT {



	/**

	 * Datenverteiler-Verbindung.

	 */

	TestDav dav = new TestDav();



	/**

	 * Testmethode Einlesen Datei.

	 */

src/test/java/de/bsvrz/kex/lmstic3/vew/VersendeMeldung.java

+3 −12
Original line number Diff line number Diff line
@@ -130,11 +130,6 @@ public class VersendeMeldung implements ClientSenderInterface { 
		}

	}



	/**

	 * Prefix der PID der zu erzeugenden Meldung.

	 */

	private final String meldungsPidPrefix = "tmcmeldungtest.";



	/**

	 * Landesmeldestelle.

	 */
@@ -181,10 +176,6 @@ public class VersendeMeldung implements ClientSenderInterface { 
		final SystemObject lms = VersendeMeldung.verbindung.getDataModel().getObject(landesmeldeStelle);



		try {

			final DataDescription dd = new DataDescription(

					VersendeMeldung.verbindung.getDataModel().getAttributeGroup("atg.tmcVerkehrsMeldung"),

					VersendeMeldung.verbindung.getDataModel().getAspect("asp.tmcSenden"));



			DavDatenModell.getInstanz().setVerbindung(VersendeMeldung.verbindung);



			meldungsmengeTMC = ((ConfigurationObject) lms).getMutableSet("TMCMeldungen");
@@ -269,7 +260,7 @@ public class VersendeMeldung implements ClientSenderInterface { 
		// TMCMeldung found = meldungenTMC.get(pid);

		TMCMeldung found = null;



		DynamicObjectType objektTypTMC = (DynamicObjectType) VersendeMeldung.verbindung.getDataModel()

		final DynamicObjectType objektTypTMC = (DynamicObjectType) VersendeMeldung.verbindung.getDataModel()

				.getType(TMCMeldung.TYP);



		if (found == null) {
@@ -281,8 +272,8 @@ public class VersendeMeldung implements ClientSenderInterface { 
			} catch (final DynObjektException de) {

				throw new TMCException(de.getMessage());

			}

		} else {

			System.out.println("Die Daten der TMC-Meldung '" + pid + "' werden aktualisiert");

//		} else {

//			System.out.println("Die Daten der TMC-Meldung '" + pid + "' werden aktualisiert");

		}



		final AttributeGroup attributeGroup = VersendeMeldung.verbindung.getDataModel()