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

Finish Hotfix-100
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Mina Ruggiero
2025-03-31 14:11:50 +02:00
parent d7d1da21f7 159f19d7fe
commit 38991a4327
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
ems-engine/src/main/java/it/integry/ems/order/Import/service/OrdiniDialogoImportService.java
View File

@@ -17,6 +17,8 @@ import it.integry.ems_model.utility.Query;
import it.integry.ems_model.utility.UtilityDB;
import it.integry.ems_model.utility.UtilityHashMap;
import it.integry.ems_model.utility.UtilityString;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
@@ -40,6 +42,9 @@ public class OrdiniDialogoImportService {
@Autowired
private SetupGest setupGest;
private final Logger logger = LogManager.getLogger();
public List<EntityBase> importOrdiniDialogoFromCSV(String type, String format, String rawContentInput) throws Exception {
List<EntityBase> entityList = new ArrayList<EntityBase>();
final String partIvaInfagruppo = "00000000000";
@@ -49,8 +54,10 @@ public class OrdiniDialogoImportService {
String csvDialogo = rawContentInput.toUpperCase();
CsvMapper<OrdiniDialogoDTO.Import> mapper = new CsvMapper<OrdiniDialogoDTO.Import>();
List<OrdiniDialogoDTO.Import> dialogoList = mapper.deserialize(csvDialogo, OrdiniDialogoDTO.Import.class, "\t");
if (dialogoList == null)
throw new Exception("Nessuno ordine da importare");
if (dialogoList == null) {
logger.error("Nessuno ordine da importare");
return null;
}
String sql = "SELECT part_iva FROM azienda";
HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), sql);
@@ -266,15 +273,17 @@ public class OrdiniDialogoImportService {
}
testata.setOperation(OperationType.INSERT);
entityList.add(testata);
HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), query);
if (queryResult != null) {
throw new Exception("Ordine già importato (Ordine N° " + queryResult.get("num_ord").toString() +
logger.error("Ordine già importato (Ordine N° " + queryResult.get("num_ord").toString() +
" del " + new SimpleDateFormat(CommonConstants.DATE_FORMAT_DMY).format(queryResult.get("data_ord")) + ")");
break;
}
entityList.add(testata);
Date dataOrd = rigaDialogo.getDataOrd();
termCons = rigaDialogo.getTermCons();