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

Aggiunto ritorno errore tramite mail in import colli EURITMO

Browse Source
This commit is contained in:
Fabio Narracci
2024-12-17 18:03:31 +01:00
parent 285f4e68bd
commit 2969b4b510
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
ems-engine/src/main/java/it/integry/ems/logistic/Import/service/EuritmoImportService.java
View File

@@ -12,6 +12,7 @@ import it.integry.ems.logistic.service.LogisticService;
import it.integry.ems.rules.businessLogic.LoadColliService;
import it.integry.ems.rules.businessLogic.dto.LoadColliDTO;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.service.MailService;
import it.integry.ems.service.PrinterService;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems_model.base.EntityBase;
@@ -68,6 +69,9 @@ public class EuritmoImportService {
private Logger logger = LogManager.getLogger();
@Autowired
private MailService mailService;
public List<EntityBase> importFromEdi(String type, String format, List<AnomalieDTO> anomalies) throws Exception {
List<EntityBase> entities = new ArrayList<EntityBase>();
List<String> rifColloImported = new ArrayList<String>();
@@ -196,6 +200,10 @@ public class EuritmoImportService {
message.setFlag(Flags.Flag.SEEN, true);
}
} catch (Exception ex) {
String email = setupGest.getImportSetup(multiDBTransactionManager.getPrimaryConnection(), type, format, "EMAIL_FOR_LOG");
mailService.sendMail(email, null, "ERRORE Importazione " + type + " formato " + format, ex.getMessage());
mtbColt.setException(new EntityException(ex.getMessage()));
entities.add(mtbColt);
logger.error(String.format("Errore durante le operazioni di creazione/versamento colli sul DB %s", profileDBDest), ex);
@@ -277,7 +285,12 @@ public class EuritmoImportService {
switch (qtaType) {
case CT:
mtbColr.setQtaCol(riga.getNumConf().multiply(getQtaCnf(riga.getCodMartAnag(), mtbColt.getCodAnag())));
BigDecimal qtaCnf = getQtaCnf(riga.getCodMartAnag(), mtbColt.getCodAnag());
if (qtaCnf != null) {
mtbColr.setQtaCol(riga.getNumConf().multiply(getQtaCnf(riga.getCodMartAnag(), mtbColt.getCodAnag())));
} else {
throw new Exception("Articolo fornitore " + riga.getCodMartAnag() + " non codificato per " + mtbColt.getCodAnag());
}
break;
default:
mtbColr.setQtaCol(riga.getNumConf());