From ab2a1c07e19e970e23aa4b9fd615f7dc6539cf95 Mon Sep 17 00:00:00 2001
From: MarcoE <m.elefante@integry.it>
Date: Fri, 16 Feb 2024 17:21:17 +0100
Subject: [PATCH] Inserita storedProcedure in importazione Apulia RifOrd

---
 .../DocumentiAcquistoImportService.java       | 24 +++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/ems-engine/src/main/java/it/integry/ems/document/Import/service/DocumentiAcquistoImportService.java b/ems-engine/src/main/java/it/integry/ems/document/Import/service/DocumentiAcquistoImportService.java
index 05a42e4852..2a36f78ab9 100644
--- a/ems-engine/src/main/java/it/integry/ems/document/Import/service/DocumentiAcquistoImportService.java
+++ b/ems-engine/src/main/java/it/integry/ems/document/Import/service/DocumentiAcquistoImportService.java
@@ -36,12 +36,10 @@ import org.springframework.stereotype.Service;
 import java.io.*;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
+import java.sql.*;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.Date;
 import java.util.concurrent.atomic.AtomicReference;
 
 @Service
@@ -981,8 +979,26 @@ public class DocumentiAcquistoImportService {
                 m.setPrimaryDs(ds.getProfileName());
 
                 for (EntityBase e : entityList){
+                    DtbDoct dtbDoct = (DtbDoct) e;
+
+                    CallableStatement storedProcedure = m.getPrimaryConnection().prepareCall("{call UpdProgMaga(?,?,?,?,?,?,?)}");
+                    storedProcedure.setString(1, dtbDoct.getCodAnag());
+                    storedProcedure.setString(2, dtbDoct.getCodDtip());
+                    storedProcedure.setTimestamp(3, new Timestamp(dtbDoct.getDataDoc().getTime()));
+                    storedProcedure.setString(4, dtbDoct.getSerDoc());
+                    storedProcedure.setInt(5, dtbDoct.getNumDoc());
+                    storedProcedure.setInt(6, -1);
+                    storedProcedure.setString(7, "U");
+
+                    storedProcedure.execute();
+                    storedProcedure.close();
+
                     entityProcessor.processEntity(e, true, false, requestData.getUsername(), m, false);
                     entityReturn.add(e);
+
+                    storedProcedure.setInt(6, 1);
+                    storedProcedure.execute();
+                    storedProcedure.close();
                 }
             }catch (Exception e){
                 m.rollbackAll();