Commit 3a7a9f7d authored by Christian Kniss's avatar Christian Kniss

Merge GradleUmstellung in develop

parents beca98aa 8eda50ca
# Created by .ignore support plugin (hsz.mobi)
.gradle/
build/
de.inovat.kex-ftp-build:
image:
openjdk:8-jdk-alpine
script:
- ./gradlew build
Versionsverlauf
===============
## [Noch nicht veröffentlicht]
## [Version 2.0.2]
- NERZ: Umstellung auf Gradle, Build durch FTB und Bereitstellung auf NERZ-Repositories
## Version 2.0.1
- Übernahme vor Umstellung auf Gradle
- Debug-Ausgabe korrigiert.
## Version 2.0.0
- Zusätzliche Übertragungsprotokoll für SFTP integriert
- Neue Aufrufparamter
- `-istFtp=ja|nein` / Default-Wert = ja
- `-ftpServerPort=ZAHL` / Default-Wert bei `-istFtp=ja` ist 21, bei `-istFtp=nein` ist 22
[Noch nicht veröffentlicht]: https://gitlab.nerz-ev.de/ERZ/SWE_de.inovat.kex.ftp/compare/v2.0.2...HEAD
[Version 2.0.2]: https://gitlab.nerz-ev.de/ERZ/SWE_de.inovat.kex.ftp/compare/v2.0.1...v2.0.2
Hinweise zur Bearbeitung / Beteiligung
======================================
Für Änderungen an dem Projekt ist zuerst ein Eintrag (Issue) mit dem Tag "Feature-Wunsch" oder "Bug"
anzulegen, damit die übernommen Änderungen auch einem Problem und einer potentiell erfolgten Diskussion
zugeordnet werden können. Solange das Fehler- und Änderungsmanagement noch über die bisherigen NERZ-Bugtracker
abgewickelt wird, ist zudem eine Referenz auf den dortigen Eintrag vorzunehmen.
Vor der Bearbeitung sollte man den entsprechenden Eintrag persönlich übernehmen
und einen Bugfix- oder Feature-Branch anlegen.
Feature-Branches werden benannt als "feature/{name}", Bugfix-Branches als "hotfix/{name}".
Der Name sollte beschreiben, was innerhalb des Branches geändert wird und **nicht den Name des Bearbeiters**.
Feature-Wünsche werden auf Basis des "develop"-Branches umgesetzt und führen letztendlich zu einem Release einer
neuen Version auf dem zweiten Level, d.h. 0.1.0 wird mindestens 0.2.0 oder in der Hauptversion, d. h. aus z. B. 1.x.y wird 2.0.0, wenn **keine** Abwärtskompatibilität besteht.
Bugfixes sollten auf dem "master"-Branch beruhen und führen zu einer neuen Version auf dem dritten Level, d.h. aus 0.1.0 wird 0.1.1.
Die Änderungen werden dann natürlich auch in den "develop"-Branch gemerged. Damit können Bugfixes kurzfristig erfolgen
ohne den Zwang gleich alle Änderungen, die sich schon im Develop-Zweig befinden mit zu veröffentlichen.
Werden im Rahmen eines Auftrags mehrere Feature-Wünsche oder Bugfixes bearbeitet, kann auch einheitlich vom "develop"-Branch gemerged werden (konkrete Abstimmung im Zweifelsfall mit der NERZ-FTB).
Branches sollten nur für einen **einzelnen Eintrag** angelegt werden.
Die Branches können nach dem Merge in den Ursprungs-Branch entfernt werden (Das Löschen erfolgt automatisch,
wenn der entsprechende Haken beim Anlegen des Merge-Request gesetzt wird).
Ein Merge-Request sollte folgende Punkte berücksichtigen:
- die Änderungen, die mit dem Request verbunden sind sollten in kurzer prägnanter Form in das CHANGELOG-File eingetragen werden. Der Eintrag erfolgt dabei im Abschnitt "Noch nicht veröffentlicht". Die Versionsnummer wird dort erst beim Release ergänzt (also letztlich bei der Übernahme durch die NERZ-FTB).
- wenn es notwendig ist, neue Features oder Änderungen zu beschreiben muss das README-File angepasst werden
- Änderungen am Code sollten keinen auskommentierten alten Code enthalten, für den Zugriff auf die Historie ist ja GIT vorgesehen
- die bearbeiteten Einträge sollten im Kommentar für den jeweiligen Commit oder für den Merge-Request mit "Fixes #{Eintragsnummer}" um die Zuordnung zu erhalten und das automatische Schließen zu ermöglichen
**Abgelehnte Merge-Request brauchen nicht gelöscht werden!**
Angemerkte und diskutierte Probleme, die eine Übernahme verhindern, sollten stattdessen bearbeitet werden bis der Merge-Request übernommen werden kann. **Ein neuer Request ist nicht erforderlich!**
\ No newline at end of file
This diff is collapsed.
# FTP-Verzeichnisüberwachung
## Übersicht
Die SWE FTP-Verzeichnisüberwachung überwacht zyklisch Ordnerinhalte auf einem externen FTP-Server
auf den Eingang von neuen, durch die SWE BASt-Band weiterzuverarbeitenden (importierenden)
Dateien im BASt-Format (V2004 oder V2007). Sobald die SWE FTP-Verzeichnisüberwachung neue
Dateien im zu überwachenden Verzeichnis erkennt, meldet sie dies der SWE BASt-Band über den
Datenverteiler. Nach erfolgreicher Verarbeitung der Daten durch die SWE BASt-Band verschiebt
die SWE FTP-Verzeichnisüberwachung die Daten in ein weiteres Verzeichnis mit bearbeiteten Dateien
(Miniarchiv zur Nachverfolgbarkeit der Aktivitäten).
Bei den Importdateien handelt es sich um BAST-Daten im Format V2004 bzw. V2007 gemäß
Definition der BASt.
(für die SWE FTP-Verzeichnisüberwachung ist das Format nicht relevant, für die SWE BASt-Band,
welche letztlich die Daten verarbeitet, ist dies aber zwingend notwendig.)
Diese Dateien werden i.d.R. durch externe Ingenieurbüros
geliefert (aus den Zähldaten der Langzeitzählstellen).
Die zu überwachenden Verzeichnisse können über Aufrufparameter festgelegt werden.
Weiterhin unterstützt werden die Überwachung von FTP- und SFTP-Servern sowie der
Passivmodus bei der FTP-Übertragung und natürlich die Übertragung mit Authentifizierung.
Die nachfolgende Abbildung zeigt vereinfacht die Funktionsweise der SWE FTP-Verzeichnisüberwachung.
## Disclaimer
Copyright (C) 2018 inovat - Dipl.-Ing. H. C. Kniß
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
Dieses Programm ist Freie Software: Sie können es unter den Bedingungen
der GNU General Public License, wie von der Free Software Foundation,
Version 3 der Lizenz oder (nach Ihrer Wahl) jeder neueren
veröffentlichten Version, weiterverbreiten und/oder modifizieren.
Dieses Programm wird in der Hoffnung, dass es nützlich sein wird, aber
OHNE JEDE GEWÄHRLEISTUNG, bereitgestellt; sogar ohne die implizite
Gewährleistung der MARKTFÄHIGKEIT oder EIGNUNG FÜR EINEN BESTIMMTEN ZWECK.
Siehe die GNU General Public License für weitere Details.
Sie sollten eine Kopie der GNU General Public License zusammen mit diesem
Programm erhalten haben. Wenn nicht, siehe <http://www.gnu.org/licenses/>.
## Kontakt
inovat, Dipl.-Ing. H. C. Kniß
An der Krautwiese 37
D-53783 Eitorf
+49 (0)2243 8464 193
info@inovat.de
www.inovat.de
//--------------------------------------------------------------------
// NERZ-SWE-Plugin
//--------------------------------------------------------------------
plugins {
id "de.bsvrz.gradle.nerzswe" version "0.7.2"
}
//--------------------------------------------------------------------
// SWE-Eigenschaften
//--------------------------------------------------------------------
description 'FTP-Verzeichnisüberwachung'
group 'de.inovat.kex'
version '2.0.2-SNAPSHOT'
// Properties des NERZ-SWE-Plugins:
nerzswe {
mainClassName = 'de.inovat.kex.ftp.Verzeichnisueberwachung'
sweStatus = 'BETA'
sweDatum = ''
}
//--------------------------------------------------------------------
// Abhängigkeiten
//--------------------------------------------------------------------
String kernsoftware_version = '3.9.7'
dependencies {
compile group: 'de.bsvrz.dav', name: 'de.bsvrz.dav.daf', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.debug', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.commandLineArgs', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.application', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.hexdump', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.dataIdentificationSettings', version: kernsoftware_version
compile group: 'de.bsvrz.sys', name: 'de.bsvrz.sys.funclib.asyncReceiver', version: kernsoftware_version
compile group: 'com.jcraft', name: 'jsch', version: '0.1.50'
compile group: 'commons-net', name: 'commons-net', version: '3.1'
}
<?xml version="1.0" encoding="UTF-8"?>
<FindBugsFilter>
<Match>
<Bug pattern="DE_MIGHT_IGNORE"/>
</Match>
</FindBugsFilter>
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-4.5-bin.zip
#!/usr/bin/env sh
##############################################################################
##
## Gradle start up script for UN*X
##
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
PRG="$0"
# Need this for relative symlinks.
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG=`dirname "$PRG"`"/$link"
fi
done
SAVED="`pwd`"
cd "`dirname \"$PRG\"`/" >/dev/null
APP_HOME="`pwd -P`"
cd "$SAVED" >/dev/null
APP_NAME="Gradle"
APP_BASE_NAME=`basename "$0"`
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS=""
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD="maximum"
warn () {
echo "$*"
}
die () {
echo
echo "$*"
echo
exit 1
}
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "`uname`" in
CYGWIN* )
cygwin=true
;;
Darwin* )
darwin=true
;;
MINGW* )
msys=true
;;
NONSTOP* )
nonstop=true
;;
esac
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD="java"
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
# Increase the maximum file descriptors if we can.
if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
MAX_FD_LIMIT=`ulimit -H -n`
if [ $? -eq 0 ] ; then
if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
MAX_FD="$MAX_FD_LIMIT"
fi
ulimit -n $MAX_FD
if [ $? -ne 0 ] ; then
warn "Could not set maximum file descriptor limit: $MAX_FD"
fi
else
warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
fi
fi
# For Darwin, add options to specify how the application appears in the dock
if $darwin; then
GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
fi
# For Cygwin, switch paths to Windows format before running java
if $cygwin ; then
APP_HOME=`cygpath --path --mixed "$APP_HOME"`
CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
JAVACMD=`cygpath --unix "$JAVACMD"`
# We build the pattern for arguments to be converted via cygpath
ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
SEP=""
for dir in $ROOTDIRSRAW ; do
ROOTDIRS="$ROOTDIRS$SEP$dir"
SEP="|"
done
OURCYGPATTERN="(^($ROOTDIRS))"
# Add a user-defined pattern to the cygpath arguments
if [ "$GRADLE_CYGPATTERN" != "" ] ; then
OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
fi
# Now convert the arguments - kludge to limit ourselves to /bin/sh
i=0
for arg in "$@" ; do
CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option
if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition
eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
else
eval `echo args$i`="\"$arg\""
fi
i=$((i+1))
done
case $i in
(0) set -- ;;
(1) set -- "$args0" ;;
(2) set -- "$args0" "$args1" ;;
(3) set -- "$args0" "$args1" "$args2" ;;
(4) set -- "$args0" "$args1" "$args2" "$args3" ;;
(5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
(6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
(7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
(8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
(9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
esac
fi
# Escape application args
save () {
for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
echo " "
}
APP_ARGS=$(save "$@")
# Collect all arguments for the java command, following the shell quoting and substitution rules
eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
cd "$(dirname "$0")"
fi
exec "$JAVACMD" "$@"
@if "%DEBUG%" == "" @echo off
@rem ##########################################################################
@rem
@rem Gradle startup script for Windows
@rem
@rem ##########################################################################
@rem Set local scope for the variables with windows NT shell
if "%OS%"=="Windows_NT" setlocal
set DIRNAME=%~dp0
if "%DIRNAME%" == "" set DIRNAME=.
set APP_BASE_NAME=%~n0
set APP_HOME=%DIRNAME%
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
set DEFAULT_JVM_OPTS=
@rem Find java.exe
if defined JAVA_HOME goto findJavaFromJavaHome
set JAVA_EXE=java.exe
%JAVA_EXE% -version >NUL 2>&1
if "%ERRORLEVEL%" == "0" goto init
echo.
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
echo.
echo Please set the JAVA_HOME variable in your environment to match the
echo location of your Java installation.
goto fail
:findJavaFromJavaHome
set JAVA_HOME=%JAVA_HOME:"=%
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
if exist "%JAVA_EXE%" goto init
echo.
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
echo.
echo Please set the JAVA_HOME variable in your environment to match the
echo location of your Java installation.
goto fail
:init
@rem Get command-line arguments, handling Windows variants
if not "%OS%" == "Windows_NT" goto win9xME_args
:win9xME_args
@rem Slurp the command line arguments.
set CMD_LINE_ARGS=
set _SKIP=2
:win9xME_args_slurp
if "x%~1" == "x" goto execute
set CMD_LINE_ARGS=%*
:execute
@rem Setup the command line
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
@rem Execute Gradle
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
:end
@rem End local scope for the variables with windows NT shell
if "%ERRORLEVEL%"=="0" goto mainEnd
:fail
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
rem the _cmd.exe /c_ return code!
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
exit /b 1
:mainEnd
if "%OS%"=="Windows_NT" endlocal
:omega
rootProject.name = 'de.inovat.kex.ftp'
/*
* Copyright (c) 2010-2011 by inovat, innovative systeme - verkehr - tunnel - technik, Dipl.-Ing. H. C. Kniss
*
* This file is part of de.inovat.kex.ftp.DavKommunikation
*
* de.inovat.kex.ftp.DavKommunikation is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* de.inovat.kex.ftp.DavKommunikation is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* <p>
* You should have received a copy of the GNU General Public License
* along with de.inovat.kex.ftp.DavKommunikation; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*
* Contact Information:
* inovat, Dipl.-Ing. H. C. Kniss
* Koelner Strasse 30
* D-50859 Koeln
* +49 (0)2234 4301 800
* info@invat.de
* www.inovat.de
*/
package de.inovat.kex.ftp;
//~ NICHT JDK IMPORTE =========================================================
import de.bsvrz.dav.daf.main.*;
import de.bsvrz.dav.daf.main.config.*;
import de.bsvrz.sys.funclib.debug.Debug;
import java.util.Calendar;
//~ JDK IMPORTE ===============================================================
//~ KLASSEN ===================================================================
/**
* Die Klasse dient verwaltet die Datenverteiler Kommunikation. Das Anmelden, Abmelden und Senden der Daten.
* <p>
*
* @author inovat, innovative systeme - verkehr - tunnel - technik
* @author Dagmar Rostek (DR)
* @version $Revision$ / $Date$ / ($Author$)
*/
public class DavKommunikation implements ClientSenderInterface {
/** Aspekt Zustand. */
private static final String ASP_ZUSTAND = "asp.zustand";
/** Attributgruppe bastImportVerzeichnisüberwachung. */
private static final String ATG_VEREICHNISUEBERWACHUNG = "atg.bastImportVerzeichnisUeberwachung";
/** DebugLogger für Debug-Ausgaben. */
private static final Debug debug = Debug.getLogger();
//~ FELDER ================================================================
/** AttributeGroup der Verzeichnisüberwachungsdaten. */
private AttributeGroup _atgVerzeichnisUeberwachung;
/** Datenbeschreibung zum Senden der Verzeichnisüberwachungsdaten. */
private DataDescription _datenbeschreibungVerzeichnisUeberwachung;
/** ClientDavInteface. */
private ClientDavInterface _dav;
/** SystemObjekt Verzeichnisüberwachung. */
private SystemObject _soVerzeichnisUeberwachung;
//~ KONSTRUKTOREN (und vom Konstruktor verwendete Methoden) ==============
/**
* Erstelle Instanz der Klasse.
*
* @param dav ClientDavInterface.
* @param typBAStBand Typ des Systemobjekte für den BASt-Band Import/Export.
*/
public DavKommunikation(ClientDavInterface dav, String typBAStBand) {
_dav = dav;
// Initialisiere DaV-Daten:
_soVerzeichnisUeberwachung = _dav.getDataModel().getObject(typBAStBand);
_atgVerzeichnisUeberwachung = _dav.getDataModel().getAttributeGroup(ATG_VEREICHNISUEBERWACHUNG);
Aspect aspektZustand = _dav.getDataModel().getAspect(ASP_ZUSTAND);
_datenbeschreibungVerzeichnisUeberwachung = new DataDescription(_atgVerzeichnisUeberwachung, aspektZustand);
}
//~ METHODEN ==============================================================
/**
* Abmelden vom Datenverteiler.
*/
private void abmeldenAlsDaVSender() {
_dav.unsubscribeSender(this, _soVerzeichnisUeberwachung, _datenbeschreibungVerzeichnisUeberwachung);
}
/**
* Anmeldung beim Datenverteiler als Sender für den Status bzgl. Senden der BASt-Band Daten.
*
* @param dateiName Dateiname, für den die Anmeldung erfolgt (nur für die Debugausgabe)
*/
private void anmeldenAlsDavSender(String dateiName) {
// Anmelden zum Senden der Daten
subscribe(_soVerzeichnisUeberwachung, _datenbeschreibungVerzeichnisUeberwachung, SenderRole.sender());
//
debug.info("Die Anmeldung beim Datenverteiler zum Senden der Verzeichnisinformationsdaten ist erfolgt fuer die Datei: " + dateiName);
}
/**
* Die Methode bestimmt das BASt-Band Format abhängig vom Überwachungsverzeichnis.
*
* @param ueberwachungsVerezichnis Überwachungsverzeichnis.
*
* @return integer Zahl die das Format repräsentiert. Return Wert von 0 entspricht dem BASt-Band Format 2004,
* Return Wert von 5 entspricht dem BASt-Band Format VerkehrGeschwindigkeit2007. Sollten beide
* Formate nicht mit dem übergebenem übereinstimmten wird -1 retuniert.
*/
private int bestimmeBastFormat(String ueberwachungsVerezichnis) {
if (ueberwachungsVerezichnis.contains("Verkehr_Menge_2004")) {
return 0;
} else if (ueberwachungsVerezichnis.contains("Verkehr_Geschwindigkeit_2007")) {
return 5;
} else {
return -1;
}
}
// @Override
public void dataRequest(SystemObject systemObject, DataDescription dataDescription, byte b) {}
//~ GET METHODEN ==========================================================
// @Override
public boolean isRequestSupported(SystemObject systemObject, DataDescription dataDescription) {
return false;
}
//~ METHODEN ==============================================================
/**
* Die Methode sendet das Verzeichnis samt Datei.
*
* @param dateiName Dateiname mit dem Pfad relativ zum Server-Root-Ordner.
* @param istFtp Definiert den ServerTyp: FTP (true) oder SFTP (false).
* @param url URL.
* @param port Port.
* @param user FTP user.
* @param passwd FTP login.
* @param ftpPassivModus Stellt fest, ob passive FTP-Verbindung aufgebaut werden soll.
* @param bastFormat BASt-Format.
*/
private void sendeDavDaten(String dateiName, boolean istFtp, String url, int port, String user, String passwd, boolean ftpPassivModus, int bastFormat) {
// DaV-Datenformat:
String passivModus = ftpPassivModus ? "ja" : "nein";
String serverTyp = istFtp ? "FTP" : "SFTP";
String allInfosAlsString = String.format("%s@%s@%s@%s@%s@%s@%s@%s@", dateiName, url, port, user, passwd, passivModus, bastFormat, serverTyp);
Data dataVDatenLangZeitIntervall = _dav.createData(_atgVerzeichnisUeberwachung);
long zeitstempel = Calendar.getInstance().getTimeInMillis();
dataVDatenLangZeitIntervall.getTextValue("ImportDatei").setText(allInfosAlsString);
ResultData resultDate = new ResultData(_soVerzeichnisUeberwachung, _datenbeschreibungVerzeichnisUeberwachung, zeitstempel, dataVDatenLangZeitIntervall);
try {
_dav.sendData(resultDate);
}
catch (SendSubscriptionNotConfirmed sendSubscriptionNotConfirmed) {
debug.warning("Die Daten konnten nicht versendet werden! Bitte kontrollieren Sie ob der BASt-Band Prozess läuft! " + sendSubscriptionNotConfirmed);
}
}
/**
* Die Methode sendet das Verzeichnis samt Datei.
*
* @param dateiName Dateiname mit dem Pfad relativ zum Server-Root-Ordner.
* @param ueberwachungsVerezichnis Überwachungsverzeichnis um BastBandFormat zu bestimmen.
* @param istFtp Definiert den ServerTyp: FTP (true) oder SFTP (false).
* @param url URL.
* @param port Port.
* @param user FTP user.
* @param passwd FTP login.
* @param ftpPassivModus Stellt fest, ob passive FTP-Verbindung aufgebaut werden soll.
*/
public void sendeVerzeichnisUeberwachungsDaVDaten(String dateiName, String ueberwachungsVerezichnis, boolean istFtp, String url, int port, String user, String passwd, boolean ftpPassivModus) {
anmeldenAlsDavSender(dateiName);
int bastFormat = bestimmeBastFormat(ueberwachungsVerezichnis);
if (bastFormat == -1) {
String infoText = "Das Überwachungsverzeichnis ist nicht korrekt, bitte überprüfen Sie ihre Angaben.";
debug.error(infoText);
} else {
sendeDavDaten(dateiName, istFtp, url, port, user, passwd, ftpPassivModus, bastFormat);
abmeldenAlsDaVSender();
}
}
/**
* Anmeldung beim Datenverteiler.
* @param systemObjectVerzeichnisUeberwachung SystemObject für die Verzeichnisüberwachung.
* @param datenbeschreibungVerzeichnisUeberwachung Datenbeschreibung.
* @param senderRolle Senderrolle.
*/
private void subscribe(SystemObject systemObjectVerzeichnisUeberwachung, DataDescription datenbeschreibungVerzeichnisUeberwachung, SenderRole senderRolle) {
try {
_dav.subscribeSender(this, systemObjectVerzeichnisUeberwachung, datenbeschreibungVerzeichnisUeberwachung, senderRolle);
}
catch (OneSubscriptionPerSendData oneSubscriptionPerSendData) {
String infoText = "Es konnte keine Anmeldung beim Datenverteiler vollzogen werden." + oneSubscriptionPerSendData;
debug.error(infoText);
}
}
}
//~Formatiert mit 'inovat Kodierkonvention' am 27.06.13
This diff is collapsed.
This diff is collapsed.
/*
* Copyright 2008 by inovat, Dipl.-Ing. H. C. Kniß
* ALL RIGHTS RESERVED.
*
* THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL inovat OR ITS CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
* OR CONSEQUENTIAL DAMAGES (INCL., BUT NOT LIMITED TO, PROCUREMENT
* OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCL.
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
package de.inovat.kex.ftp;
//~ NICHT JDK IMPORTE =========================================================
import com.jcraft.jsch.Session;
import de.bsvrz.dav.daf.main.ClientDavInterface;
import de.bsvrz.sys.funclib.debug.Debug;
import java.util.ArrayList;
import java.util.List;
//~ JDK IMPORTE ===============================================================
//~ KLASSEN ===================================================================
/**
* Die Klasse dient zur Verwaltung der gesamten SFTP Kommunikation.
*
* @author inovat, innovative systeme - verkehr - tunnel - technik
* @author Liliya Givorgizova (LG)
* @version $Revision: 0 $ / $Date: neu $ / ($Author: HCK $)
*/
public class SFTPKommunikation {
/** TODO Fileseparator auf dem Server. */
private final static String FILESEPARATOR_SERVER = "/";
/** DebugLogger für Debug-Ausgaben. */