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

Fix consolidamento griglie acquisto

Browse Source
This commit is contained in:
Marco Elefante
2024-03-07 16:13:41 +01:00
parent b35d51f0ad
commit ab761d0ac9
1 changed files with 18 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
ems-engine/src/main/java/it/integry/ems/retail/service/GrigliaAcquistoService.java
View File

@@ -32,9 +32,10 @@ public class GrigliaAcquistoService {
public List<AtbGriglie> consolidaGriglieAcquisto(Date dataVar, String whereCondDepo) throws Exception { public List<AtbGriglie> consolidaGriglieAcquisto(Date dataVar, String whereCondDepo) throws Exception {
String sql = "SELECT DISTINCT cod_mdep, cod_alis\n" + String sql = "SELECT DISTINCT cod_mdep, cod_alis\n" +
"FROM atb_griglie\n" + "FROM atb_griglie\n" +
"WHERE data_validita < " + UtilityDB.valueDateToString(dataVar, CommonConstants.DATE_FORMAT_YMD); "WHERE data_validita < " + UtilityDB.valueDateToString(dataVar, CommonConstants.DATE_FORMAT_YMD) + " \n" +
"ORDER BY cod_mdep, cod_alis";
if (!UtilityString.isNullOrEmpty(whereCondDepo)){ if (!UtilityString.isNullOrEmpty(whereCondDepo)) {
sql += " " + whereCondDepo; sql += " " + whereCondDepo;
} }
@@ -47,24 +48,27 @@ public class GrigliaAcquistoService {
try { try {
sql = String.format( sql = String.format(
"SELECT * \n" + "SELECT * \n" +
"FROM dbo.getGrigliaAcquisto(%s, %s, %s, NULL, NULL)", "FROM dbo.getGrigliaAcquisto(%s, %s, %s, NULL, NULL) \n" +
"WHERE tipo_variazione <> 'D'",
UtilityDB.valueDateToString(dataVar, CommonConstants.DATE_FORMAT_YMD), UtilityDB.valueDateToString(dataVar, CommonConstants.DATE_FORMAT_YMD),
UtilityDB.valueToString(codAlis), UtilityDB.valueToString(codAlis),
UtilityDB.valueToString(codMdep) UtilityDB.valueToString(codMdep)
); );
List<AtbGriglieArt> atbGriglieArt = UtilityDB.executeSimpleQueryDTO(multiDBTransactionManager.getPrimaryConnection(), sql, AtbGriglieArt.class); List<AtbGriglieArt> atbGriglieArt = new ResultSetMapper().mapQuerySetToList(multiDBTransactionManager.getPrimaryConnection(), sql, AtbGriglieArt.class, OperationType.INSERT_OR_UPDATE);
AtbGriglie atbGriglie = new AtbGriglie(); if (atbGriglieArt != null && !atbGriglieArt.isEmpty()) {
atbGriglie.setCodAlis(codAlis); AtbGriglie atbGriglie = new AtbGriglie();
atbGriglie.setCodMdep(codMdep); atbGriglie.setCodAlis(codAlis);
atbGriglie.setDataValidita(dataVar); atbGriglie.setCodMdep(codMdep);
atbGriglie.setAtbGriglieArt(atbGriglieArt); atbGriglie.setDataValidita(dataVar);
atbGriglie.setNote("Generato automaticamente"); atbGriglie.setAtbGriglieArt(atbGriglieArt);
atbGriglie.setOperation(OperationType.INSERT_OR_UPDATE); atbGriglie.setNote("Generato automaticamente");
atbGriglie.setOperation(OperationType.INSERT_OR_UPDATE);
entityProcessor.processEntity(atbGriglie, true, multiDBTransactionManager); entityProcessor.processEntity(atbGriglie, true, multiDBTransactionManager);
UtilityEntity.throwEntityException(atbGriglie); UtilityEntity.throwEntityException(atbGriglie);
}
sql = String.format( sql = String.format(
"SELECT *\n" + "SELECT *\n" +
@@ -77,7 +81,7 @@ public class GrigliaAcquistoService {
List<AtbGriglie> atbGriglieDelete = new ResultSetMapper().mapQuerySetToList(multiDBTransactionManager.getPrimaryConnection(), sql, AtbGriglie.class, OperationType.DELETE); List<AtbGriglie> atbGriglieDelete = new ResultSetMapper().mapQuerySetToList(multiDBTransactionManager.getPrimaryConnection(), sql, AtbGriglie.class, OperationType.DELETE);
for (AtbGriglie atbDelete : atbGriglieDelete){ for (AtbGriglie atbDelete : atbGriglieDelete) {
entityProcessor.processEntity(atbDelete, true, multiDBTransactionManager); entityProcessor.processEntity(atbDelete, true, multiDBTransactionManager);
UtilityEntity.throwEntityException(atbDelete); UtilityEntity.throwEntityException(atbDelete);
} }