CBAM/VERAG Zollanmeldungen

DAKOSY_Worker/DAKOSY/ATLAS/EZA/cDakosyEZA_Greenpulse.vb

@@ -208,6 +208,30 @@ Public Class cDakosyEZA_Greenpulse
         Return dest
     End Function
 
+    Public Shared Sub INSERT_KAFKA(za As cVERAG_CustomsDeclarations)
+        Try
+            If VERAG_PROG_ALLGEMEIN.cAllgemein.PARAMS Is Nothing Then
+                VERAG_PROG_ALLGEMEIN.cAllgemein.PARAMS = New cParameterList(VERAG_PROG_ALLGEMEIN.cAllgemein.PROGID)
+            End If
+            If VERAG_PROG_ALLGEMEIN.cAllgemein.PARAMS.GET_PARAMETER_VALUE_BOOL("CBAM_INSERT_KAFKA") Then
+                Dim key = cATEZ_Greenpulse_KafkaDecs.GetUniqueKey_Pipe_FromVERAG_CustomsDec(za, za.za_MRN)
+                Dim rec = cDakosyEZA_Greenpulse.BuildByMrn(za)
+                Dim dr = cATEZ_Greenpulse_KafkaDecs.InsertOrUpdateToKafkaSync_Bool(rec, key, 30000)
+                'Unlerlagen
+                If za.za_SendungsId IsNot Nothing AndAlso za.za_SendungsId > 0 Then
+                    Dim rec_inv = cDakosyEZA_Greenpulse.BuildInvoices(za.za_SendungsId)
+                    Dim dr_inv = cATEZ_Greenpulse_KafkaInvoices.InsertOrUpdateToKafkaSync_Bool(rec_inv, key, 30000)
+                End If
+            End If
+
+        Catch ex As Exception
+            Try
+                cErrorHandler.ERR(ex.Message, ex.StackTrace & vbNewLine & vbNewLine & za.za_MRN, Reflection.MethodInfo.GetCurrentMethod.Name)
+            Catch ex2 As Exception
+                cErrorHandler.ERR(ex.Message, ex.StackTrace, Reflection.MethodInfo.GetCurrentMethod.Name)
+            End Try
+        End Try
+    End Sub
     Public Shared Function BuildByMrn(za As cVERAG_CustomsDeclarations) As cATEZ_Greenpulse_KafkaDecs
         If za Is Nothing Then Throw New ArgumentNullException(NameOf(za))