IDS, Fix zzAktivitaet, etc.
This commit is contained in:
@@ -19,6 +19,7 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
Dim renameFilesAfterDownload = False
|
||||
Dim rmc As New cRMC
|
||||
Dim uta As New cUTA
|
||||
Dim ids As New cIDS
|
||||
Dim programName As String
|
||||
Dim Dateiname = ""
|
||||
|
||||
@@ -63,6 +64,12 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
ListBox3.Items.Add(frmStartOptions.cut_file(d))
|
||||
Me.Refresh()
|
||||
Next
|
||||
ElseIf programName.Contains("IDS") Then
|
||||
ids.initImportPfade(programName)
|
||||
For Each d In System.IO.Directory.GetFiles(ids.VERARBEITUNG_PFAD)
|
||||
ListBox3.Items.Add(frmStartOptions.cut_file(d))
|
||||
Me.Refresh()
|
||||
Next
|
||||
End If
|
||||
|
||||
End Sub
|
||||
@@ -107,7 +114,7 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
ElseIf programName.Contains("UTA") Then
|
||||
DownloadSFtpDirectory(uta.API_STRING, New NetworkCredential(uta.API.Rows(0).Item("api_user").ToString, uta.API.Rows(0).Item("api_password").ToString), "", cnt, deleteFilesAfterDownload, "/TRX/" & Now.Year, renameFilesAfterDownload)
|
||||
ElseIf programName.Contains("IDS") Then
|
||||
'DownloadSFtpDirectory(uta.API_STRING, New NetworkCredential(uta.API.Rows(0).Item("api_user").ToString, uta.API.Rows(0).Item("api_password").ToString), "", cnt, False, "/TRX/" & Now.Year)
|
||||
'keinFTP (NOCH NICHT)!
|
||||
End If
|
||||
|
||||
|
||||
@@ -224,7 +231,7 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
Using client = New SftpClient(ConnectionInfo)
|
||||
client.Connect()
|
||||
|
||||
Dim files = client.ListDirectory(Path)
|
||||
Dim files = client.ListDirectory(Path).OrderBy(Function(file) file.LastAccessTime).Reverse
|
||||
|
||||
Dim targetFile As SftpFile
|
||||
|
||||
@@ -235,27 +242,37 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
If file.IsRegularFile AndAlso file.Name.ToLower.EndsWith(".uta") AndAlso file.Length > 0 AndAlso IIf(renameAfterDownload, Not file.Name.ToLower.StartsWith("_"), Not file.Name.ToLower.StartsWith("_")) Then
|
||||
|
||||
Dim remoteFileName = "/" & file.Name
|
||||
Dim filePath = uta.VERARBEITUNG_PFAD & If(System.IO.File.Exists(uta.VERARBEITUNG_PFAD & file.Name), Name.Replace(".UTA", "_") & Now.ToString("yyMMdd_HHmmss.fff") & ".UTA", file.Name)
|
||||
Dim filePath = uta.VERARBEITUNG_PFAD & IIf(System.IO.File.Exists(uta.VERARBEITUNG_PFAD & file.Name), file.Name.Replace(".UTA", "_") & Now.ToString("yyMMdd_HHmmss.fff") & ".UTA", file.Name)
|
||||
|
||||
Dim downloadedFile As Stream = System.IO.File.Create(filePath)
|
||||
|
||||
client.DownloadFile(Path + remoteFileName, downloadedFile)
|
||||
|
||||
If System.IO.File.Exists(filePath) AndAlso deleteAfterDownload Then client.DeleteFile(Path + remoteFileName) 'Datei nach erfolgreichem Herunterladen vom Server löschen
|
||||
If System.IO.File.Exists(filePath) AndAlso deleteAfterDownload Then
|
||||
|
||||
client.DeleteFile(Path + remoteFileName) 'Datei nach erfolgreichem Herunterladen vom Server löschen
|
||||
|
||||
End If
|
||||
|
||||
If System.IO.File.Exists(filePath) AndAlso Not deleteAfterDownload And renameAfterDownload Then
|
||||
|
||||
Dim remoteFileNameRenamed = "/_" & file.Name
|
||||
client.RenameFile(Path + remoteFileName, Path + remoteFileNameRenamed) 'verarbeitete Datei kennzeichnen mit beginnenden "_"
|
||||
Try
|
||||
|
||||
Dim remoteFileNameRenamed = "/_" & file.Name
|
||||
client.RenameFile(Path + remoteFileName, Path + remoteFileNameRenamed) 'verarbeitete Datei kennzeichnen mit beginnenden "_"
|
||||
|
||||
Catch ex As Exception
|
||||
End Try
|
||||
|
||||
End If
|
||||
|
||||
downloadedFile.Dispose()
|
||||
|
||||
|
||||
Dim fi As FileInfo = New FileInfo(filePath)
|
||||
ListBox3.Items.Add(frmStartOptions.cut_file(fi.Name)) 'zur Liste hinzufügen
|
||||
cnt += 1
|
||||
|
||||
If fi.Extension = ".uta" Then
|
||||
ListBox3.Items.Add(frmStartOptions.cut_file(fi.Name)) 'zur Liste hinzufügen
|
||||
cnt += 1
|
||||
End If
|
||||
End If
|
||||
Next
|
||||
|
||||
@@ -303,6 +320,9 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
ElseIf programName.Contains("UTA") Then
|
||||
verarbeitungspfad = uta.VERARBEITUNG_PFAD
|
||||
zielpfad = uta.ZIEL_PFAD
|
||||
ElseIf programName.Contains("IDS") Then
|
||||
verarbeitungspfad = ids.VERARBEITUNG_PFAD
|
||||
zielpfad = ids.ZIEL_PFAD
|
||||
End If
|
||||
|
||||
For i = 1 To 2
|
||||
@@ -411,7 +431,7 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
|
||||
If True Then 'Not System.IO.Directory.Exists(zielpfad & "Invoice_PDF\" & Now.Year & "\" & Now.ToString("yyyyMMdd") & "\") Then System.IO.Directory.CreateDirectory(zielpfad & Now.Year & "\" & Now.ToString("yyyyMMdd") & "\")
|
||||
|
||||
If fi.Name.ToString.StartsWith("invoice_") Then
|
||||
If fi.Name.ToString.StartsWith("AP") Then
|
||||
|
||||
Dim DS As New VERAG_PROG_ALLGEMEIN.cDATENSERVER("MDM", "MDM_DATEN", "UTA", Now.Year, Now.ToString("yyyyMMdd"), frmStartOptions.getFileName(d))
|
||||
|
||||
@@ -467,7 +487,9 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
|
||||
If UTA_Beleg_ID <> "" Then
|
||||
'TO DO -> ÄNDERN----------------------
|
||||
SQL.doSQL("Update [tblUTAImportNew] SET [daId]='" & DS.da_id & "' where [UTA_Beleg_ID] = '" & UTA_Beleg_ID & "' and [rmc_importDatum] > DATEADD(DAY,-4,getdate()) ", "FMZOLL")
|
||||
If SQL.doSQL("Update [tblUTAImportNew] SET [daId]='" & DS.da_id & "' where [UTA_Beleg_ID] = '" & UTA_Beleg_ID & "' ", "FMZOLL") Then
|
||||
frmStartOptions.moveFile_DateBack(d, zielpfad & "Invoice_PDF\" & Now.Year & "\" & Now.ToString("yyyyMMdd") & "\")
|
||||
End If
|
||||
'TO DO -> ÄNDERN----------------------
|
||||
End If
|
||||
|
||||
@@ -480,14 +502,71 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
End If
|
||||
End If
|
||||
|
||||
'frmStartOptions.moveFile_DateBack(d, zielpfad & "Invoice_PDF\" & Now.Year & "\" & Now.ToString("yyyyMMdd") & "\")
|
||||
If fi.Name.ToLower.Contains("pdf") Then addDGVEinarbeitung("PDF", fi.Name)
|
||||
dgvEinarbeitung.Refresh()
|
||||
|
||||
End Select
|
||||
|
||||
|
||||
ElseIf programName.Contains("IDS") Then
|
||||
|
||||
Select Case i
|
||||
|
||||
Case 1
|
||||
'------------------------------------------
|
||||
'------------------ .CSV ------------------
|
||||
'------------------------------------------
|
||||
|
||||
'If Not deleteTable Then
|
||||
' deleteTable = uta.clearimporttable()
|
||||
'End If
|
||||
|
||||
If fi.Extension.ToLower = ".csv" Then
|
||||
|
||||
If Not found Then
|
||||
|
||||
If readIDS(d) <> "" Then found = True
|
||||
|
||||
End If
|
||||
|
||||
If found Then cntDatenEingelesen += 1
|
||||
End If
|
||||
|
||||
Case 2
|
||||
'------------------------------------------
|
||||
'------------------ .PDF ------------------
|
||||
'------------------------------------------
|
||||
|
||||
If fi.Extension.ToLower = ".pdf" Then
|
||||
|
||||
If True Then
|
||||
|
||||
|
||||
|
||||
|
||||
Dim DS As New VERAG_PROG_ALLGEMEIN.cDATENSERVER("MDM", "MDM_DATEN", "IDS", Now.Year, Now.ToString("yyyyMMdd"), frmStartOptions.getFileName(d))
|
||||
|
||||
DS.uploadDataToDATENSERVER(d,,,,,, True)
|
||||
|
||||
Try
|
||||
|
||||
|
||||
|
||||
Catch ex As System.Exception
|
||||
End Try
|
||||
|
||||
End If
|
||||
|
||||
End If
|
||||
|
||||
|
||||
If fi.Name.ToLower.Contains("pdf") Then addDGVEinarbeitung("PDF", fi.Name)
|
||||
dgvEinarbeitung.Refresh()
|
||||
|
||||
End Select
|
||||
|
||||
|
||||
|
||||
End If
|
||||
If True Then
|
||||
If Not alreadyMoved Then
|
||||
@@ -626,6 +705,30 @@ Public Class frmNachrichtenVerarbeitung_MDM_divers
|
||||
End Try
|
||||
|
||||
|
||||
End Function
|
||||
|
||||
Function readIDS(d As String) As String
|
||||
Try
|
||||
|
||||
Dim fi As FileInfo = New FileInfo(d)
|
||||
Dim cnt = 0
|
||||
Dim objFileRead As StreamReader = New StreamReader(d)
|
||||
|
||||
|
||||
If ids.readAndSaveIDS(objFileRead, fi, cnt) Then
|
||||
addDGVEinarbeitung(fi.Name, "OK")
|
||||
Else
|
||||
addDGVEinarbeitung(fi.Name, "Fehler")
|
||||
End If
|
||||
|
||||
readIDS = "Zeilen: " & cnt
|
||||
|
||||
Catch ex As System.Exception
|
||||
VERAG_PROG_ALLGEMEIN.cErrorHandler.ERR(ex.Message, ex.StackTrace & vbNewLine & "Datei: " & Dateiname, System.Reflection.MethodInfo.GetCurrentMethod.Name)
|
||||
MsgBox(ex.StackTrace & ex.Message)
|
||||
End Try
|
||||
|
||||
|
||||
End Function
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user