ePAS-ISTI
/
epasmed
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Updated boolean flag baspettative

This commit is contained in:
Giancarlo Panichi 2023-01-18 12:04:26 +01:00
parent 81fcab954c
commit 43f69757a8
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/java/it/cnr/isti/epasmed/sistemainformativo/repository/SIMasterLogRepository.java
View File

@ -42,8 +42,12 @@ public class SIMasterLogRepository {
public void closeFluxReads(String tabelleLette) throws Exception {
logger.info("Chiusura Flusso in lettura");
logger.info("Tabelle Lette: {}", tabelleLette);
if (tabelleLette.isEmpty()) {
if (tabelleLette == null) {
tabelleLette = " ";
} else {
if (tabelleLette.isEmpty()) {
tabelleLette = " ";
}
}
String query = "SELECT id_flusso FROM master_log"
@ -67,18 +71,16 @@ public class SIMasterLogRepository {
logger.info("Flusso in lettura chiuso");
} else {
logger.error("Flusso da chiudere non trovato: {}", idsFlux);
throw new Exception("Errore chiudendo il flusso di lettura, id: "+idsFlux);
throw new Exception("Errore chiudendo il flusso di lettura, id: " + idsFlux);
}
}
public Long startFluxWrites() throws Exception {
logger.info("Iniziato Flusso in scrittura");
jdbcTemplate.update("INSERT INTO master_log (codice_flusso, tabelle, operazione, data_inizio_oper)"
+ " VALUES ('epas','epas_cartellini, epas_cartellini_rendicontazioni,"
+ " epas_orario,"
+ " epas_lavoro_fuori_sede, epas_aspettative, epas_pers_orario',"
+ " 'S',current_timestamp)");
+ " VALUES ('epas','epas_cartellini, epas_cartellini_rendicontazioni," + " epas_orario,"
+ " epas_lavoro_fuori_sede, epas_aspettative, epas_pers_orario'," + " 'S',current_timestamp)");
logger.info("Flusso in scrittura aperto");
String query = "SELECT id_flusso FROM master_log" + " WHERE codice_flusso='epas' AND operazione='S'"
@ -96,18 +98,22 @@ public class SIMasterLogRepository {
fluxId = fluxIds.get(0);
logger.info("Flusso in scrittura id: {}", fluxId);
} else {
logger.error("Errore inizializando il flusso di scrittura, id: {}",fluxIds);
throw new Exception("Errore inizializando il flusso di scrittura, id: "+fluxIds);
logger.error("Errore inizializando il flusso di scrittura, id: {}", fluxIds);
throw new Exception("Errore inizializando il flusso di scrittura, id: " + fluxIds);
}
return fluxId;
}
public void closeFluxWrites(Long fluxId, String tabelleScritte) {
logger.info("Chiusura Flusso in scrittura");
logger.info("Tabelle Scritte: {}", tabelleScritte);
if (tabelleScritte.isEmpty()) {
if (tabelleScritte == null) {
tabelleScritte = " ";
} else {
if (tabelleScritte.isEmpty()) {
tabelleScritte = " ";
}
}
if (fluxId != null && fluxId.longValue() != 0) {