Integry/IntegryManagementSystem
19
0
Fork 0
Code Actions Packages Projects Releases Activity

Inserita storedProcedure in importazione Apulia RifOrd

Browse Source
This commit is contained in:
Mina Ruggiero
2024-02-16 17:46:16 +01:00
parent ab2a1c07e1
commit 77531c46e0
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
ems-engine/src/main/java/it/integry/ems/document/Import/service/DocumentiAcquistoImportService.java
View File

@@ -981,24 +981,12 @@ public class DocumentiAcquistoImportService {
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();
UpdProgOrdini(m, dtbDoct, -1);
entityProcessor.processEntity(e, true, false, requestData.getUsername(), m, false);
entityReturn.add(e);
storedProcedure.setInt(6, 1);
storedProcedure.execute();
storedProcedure.close();
UpdProgOrdini(m, dtbDoct, 1);
}
}catch (Exception e){
m.rollbackAll();
@@ -1009,6 +997,20 @@ public class DocumentiAcquistoImportService {
return entityReturn;
}
private static void UpdProgOrdini(MultiDBTransactionManager m, DtbDoct dtbDoct, Integer segno) throws SQLException, PrimaryDatabaseNotPresentException, IOException {
CallableStatement storedProcedure;
storedProcedure = m.getPrimaryConnection().prepareCall("{call UpdProgOrdini(?,?,?,?,?,?,?)}");
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, segno);
storedProcedure.setString(7, "U");
storedProcedure.execute();
storedProcedure.close();
}
private List<EntityBase> processRifOrdApuliaList (List<RifOrdApuliaDTO> rifOrdApuliaList, List<AnomalieDTO> anomalie, String tipiDoc, Connection connection, String pIva) throws Exception {
List<EntityBase> entityList = new ArrayList<>();
for (RifOrdApuliaDTO rifOrdApulia : rifOrdApuliaList){