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

sistemati errori

Browse Source
This commit is contained in:
Mina Ruggiero
2025-03-31 14:11:03 +02:00
parent 044f2d96bf
commit 159f19d7fe
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.UtilityDB;
import it.integry.ems_model.utility.UtilityHashMap; import it.integry.ems_model.utility.UtilityHashMap;
import it.integry.ems_model.utility.UtilityString; 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.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope; import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -40,6 +42,9 @@ public class OrdiniDialogoImportService {
@Autowired @Autowired
private SetupGest setupGest; private SetupGest setupGest;
private final Logger logger = LogManager.getLogger();
public List<EntityBase> importOrdiniDialogoFromCSV(String type, String format, String rawContentInput) throws Exception { public List<EntityBase> importOrdiniDialogoFromCSV(String type, String format, String rawContentInput) throws Exception {
List<EntityBase> entityList = new ArrayList<EntityBase>(); List<EntityBase> entityList = new ArrayList<EntityBase>();
final String partIvaInfagruppo = "00000000000"; final String partIvaInfagruppo = "00000000000";
@@ -49,8 +54,10 @@ public class OrdiniDialogoImportService {
String csvDialogo = rawContentInput.toUpperCase(); String csvDialogo = rawContentInput.toUpperCase();
CsvMapper<OrdiniDialogoDTO.Import> mapper = new CsvMapper<OrdiniDialogoDTO.Import>(); CsvMapper<OrdiniDialogoDTO.Import> mapper = new CsvMapper<OrdiniDialogoDTO.Import>();
List<OrdiniDialogoDTO.Import> dialogoList = mapper.deserialize(csvDialogo, OrdiniDialogoDTO.Import.class, "\t"); List<OrdiniDialogoDTO.Import> dialogoList = mapper.deserialize(csvDialogo, OrdiniDialogoDTO.Import.class, "\t");
if (dialogoList == null) if (dialogoList == null) {
throw new Exception("Nessuno ordine da importare"); logger.error("Nessuno ordine da importare");
return null;
}
String sql = "SELECT part_iva FROM azienda"; String sql = "SELECT part_iva FROM azienda";
HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), sql); HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), sql);
@@ -266,15 +273,17 @@ public class OrdiniDialogoImportService {
} }
testata.setOperation(OperationType.INSERT); testata.setOperation(OperationType.INSERT);
entityList.add(testata);
HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), query); HashMap<String, Object> queryResult = UtilityDB.executeSimpleQueryOnlyFirstRow(multiDBTransactionManager.getPrimaryDatasource().getConnection(), query);
if (queryResult != null) { 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")) + ")"); " del " + new SimpleDateFormat(CommonConstants.DATE_FORMAT_DMY).format(queryResult.get("data_ord")) + ")");
break;
} }
entityList.add(testata);
Date dataOrd = rigaDialogo.getDataOrd(); Date dataOrd = rigaDialogo.getDataOrd();
termCons = rigaDialogo.getTermCons(); termCons = rigaDialogo.getTermCons();