de.inovat.kex.bast.importer
Class BAStImportSteuerung

java.lang.Object
  extended by de.inovat.kex.bast.importer.BAStImportSteuerung
All Implemented Interfaces:
de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface, de.bsvrz.sys.funclib.application.StandardApplication, java.lang.Runnable

public class BAStImportSteuerung
extends java.lang.Object
implements de.bsvrz.sys.funclib.application.StandardApplication, de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface, java.lang.Runnable

Die Klasse dient der Importsteuerung der BASt-Band Daten.

Version:
$Revision: 642 $ / $Date: 2011-11-25 13:40:40 +0100 (Fr, 25 Nov 2011) $ / ($Author: HCK $)
Author:
inovat, innovative systeme - verkehr - tunnel - technik, Dagmar Rostek (DR)

Field Summary
 
Fields inherited from interface de.bsvrz.dav.daf.main.ClientSenderInterface
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION
 
Constructor Summary
BAStImportSteuerung()
           
 
Method Summary
protected  void anmeldenDavEmpfaengerBAStImport()
          Anmeldung beim Datenverteiler als Empfänger für die Attribute bzgl.
 void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject so, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, byte status)
           
 void initialize(de.bsvrz.dav.daf.main.ClientDavInterface dav)
           
 boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject systemObject, de.bsvrz.dav.daf.main.DataDescription dataDescription)
           
static void main(java.lang.String[] args)
           
 void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumentList)
           
 void run()
          In der run Methode des Threads BAStBandImport wird der Import der Datei durchgeführt.
 void update(de.bsvrz.dav.daf.main.ResultData[] resultDatas)
          Update-Methode wird vom Datenverteiler aufgerufen.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BAStImportSteuerung

public BAStImportSteuerung()
Method Detail

anmeldenDavEmpfaengerBAStImport

protected void anmeldenDavEmpfaengerBAStImport()
Anmeldung beim Datenverteiler als Empfänger für die Attribute bzgl. BASt-Band Import und Verzeichnisüberwachung.


dataRequest

public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject so,
                        de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
                        byte status)
Specified by:
dataRequest in interface de.bsvrz.dav.daf.main.ClientSenderInterface

initialize

public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface dav)
                throws java.lang.Exception
Specified by:
initialize in interface de.bsvrz.sys.funclib.application.StandardApplication
Throws:
java.lang.Exception

isRequestSupported

public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject systemObject,
                                  de.bsvrz.dav.daf.main.DataDescription dataDescription)
Specified by:
isRequestSupported in interface de.bsvrz.dav.daf.main.ClientSenderInterface

main

public static void main(java.lang.String[] args)

parseArguments

public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumentList)
                    throws java.lang.Exception
Specified by:
parseArguments in interface de.bsvrz.sys.funclib.application.StandardApplication
Throws:
java.lang.Exception

run

public void run()
In der run Methode des Threads BAStBandImport wird der Import der Datei durchgeführt. Folgende Schritte sind dabei zu vollziehen, nachdem eine erfolgreiche Verbindung zum FTP-Server statt gefunden hat. Sollte dies nicht möglich sein, wird eine Statusmeldung versendet. Für alle Dateien die importiert werden sollen:
  • 0. Sperren der Datei via .lock Endung
  • 1. Lese Datei vom FTP-Server ein
  • 2. Konvertiere die Zeilen in das interne DaV-Format.
  • 3. Schreibe Datensatz in DaV.
  • 4. Bestätige Import der Datei via Statusmeldung.
  • 5. Benenne Datei in bearbeitet um.
  • Specified by:
    run in interface java.lang.Runnable

    update

    public void update(de.bsvrz.dav.daf.main.ResultData[] resultDatas)
    Update-Methode wird vom Datenverteiler aufgerufen. Die übergebenen Datensätze werden verarbeitet.

    Specified by:
    update in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
    Parameters:
    resultDatas - Resultdata, entspricht den Attributen eines BASt-Band importes, d.h. Referenz auf Langzeitzählstellen username passwort url zum FTP-Server auf dem die Importierten Daten abgelegt werden.