ms jobs und interfaces
This commit is contained in:
@@ -51,7 +51,9 @@ Public Class GraphQLJob
|
||||
End Using
|
||||
End Using
|
||||
|
||||
HandleResponse(oResult, oCurrentQuery, oDatabase)
|
||||
If IsNothing(HandleResponse(oResult, oCurrentQuery, oDatabase)) Then
|
||||
Continue For
|
||||
End If
|
||||
Next
|
||||
|
||||
' logout
|
||||
@@ -69,7 +71,8 @@ Public Class GraphQLJob
|
||||
Dim oMappings = QueryData.MappingFields
|
||||
|
||||
If oResultList Is Nothing Then
|
||||
_Logger.Warn("HandleResponse: Could not find BasePath: {0}", QueryData.MappingBasePath)
|
||||
_Logger.Warn("HandleResponse: Could not find BasePath: [{0}] for query [{1}]", QueryData.MappingBasePath, QueryData.Name)
|
||||
Return Nothing
|
||||
End If
|
||||
|
||||
_Logger.Info("Processing Queue [{0}] with [{1}] Items", QueryData.Name, oResultList.Count)
|
||||
|
||||
@@ -420,6 +420,19 @@ Public Class ImportZUGFeRDFiles
|
||||
If oCheckResult.MissingProperties.Count > 0 Then
|
||||
Throw New MissingValueException(oFile)
|
||||
End If
|
||||
Dim oDelSQL = $"DELETE FROM TBEDMI_ITEM_VALUE where REFERENCE_GUID = '{oMessageId}'"
|
||||
Dim oStep As String
|
||||
Try
|
||||
oStep = "Firebird TBEDMI_ITEM_VALUE Delete messageID Items"
|
||||
_firebird.ExecuteNonQueryWithConnection(oDelSQL, oConnection, Firebird.TransactionMode.ExternalTransaction, oTransaction)
|
||||
If oArgs.InsertIntoSQLServer = True Then
|
||||
oStep = "MSSQL TBEDMI_ITEM_VALUE Delete messageID Items"
|
||||
_mssql.ExecuteNonQuery(oDelSQL)
|
||||
End If
|
||||
Catch ex As Exception
|
||||
_logger.Warn($"Delete Command [{oDelSQL}] was not successful.")
|
||||
End Try
|
||||
|
||||
|
||||
For Each oProperty In oCheckResult.ValidProperties
|
||||
Dim oGroupCounterValue = oProperty.GroupCounter
|
||||
@@ -431,8 +444,8 @@ Public Class ImportZUGFeRDFiles
|
||||
End If
|
||||
|
||||
Dim oCommand = $"INSERT INTO {oProperty.TableName} (REFERENCE_GUID, ITEM_DESCRIPTION, ITEM_VALUE, GROUP_COUNTER,SPEC_NAME,IS_REQUIRED) VALUES
|
||||
('{oMessageId}', '{oProperty.Description}', '{oProperty.Value}', {oGroupCounterValue},'{oProperty.TableColumn}','{oProperty.ISRequired}')"
|
||||
_logger.Debug("Mapping Property [{0}] with value [{1}], Will be inserted into table [{2}]", oProperty.TableColumn, oProperty.Value, oProperty.TableName)
|
||||
('{oMessageId}', '{oProperty.Description}', '{oProperty.Value.Replace("'", "''")}', {oGroupCounterValue},'{oProperty.TableColumn}','{oProperty.ISRequired}')"
|
||||
_logger.Debug("Mapping Property [{0}] with value [{1}], Will be inserted into table [{2}]", oProperty.TableColumn, oProperty.Value.Replace("'", "''"), oProperty.TableName)
|
||||
' Insert into SQL Server
|
||||
If oArgs.InsertIntoSQLServer = True Then
|
||||
Dim oResult = _mssql.ExecuteNonQuery(oCommand)
|
||||
|
||||
@@ -30,5 +30,5 @@ Imports System.Runtime.InteropServices
|
||||
' Sie können alle Werte angeben oder die standardmäßigen Build- und Revisionsnummern
|
||||
' übernehmen, indem Sie "*" eingeben:
|
||||
|
||||
<Assembly: AssemblyVersion("1.3.0.2")>
|
||||
<Assembly: AssemblyFileVersion("1.3.0.2")>
|
||||
<Assembly: AssemblyVersion("1.3.0.4")>
|
||||
<Assembly: AssemblyFileVersion("1.3.0.4")>
|
||||
|
||||
Reference in New Issue
Block a user