Merge remote-tracking branch 'origin/develop' into develop
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good

This commit is contained in:
2025-12-02 15:08:49 +01:00
7 changed files with 485 additions and 192 deletions

View File

@@ -17,7 +17,8 @@ import org.kie.api.definition.type.PropertyReactive;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.Date; import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.HashMap; import java.util.HashMap;
@Master @Master
@@ -70,7 +71,7 @@ public class Azienda extends EntityBase {
private Integer annoAttuale; private Integer annoAttuale;
@SqlField(value = "ult_data_gio") @SqlField(value = "ult_data_gio")
private Date ultDataGio; private LocalDate ultDataGio;
@SqlField(value = "ult_num_gio") @SqlField(value = "ult_num_gio")
private Integer ultNumGio; private Integer ultNumGio;
@@ -85,10 +86,10 @@ public class Azienda extends EntityBase {
private String ribaRSocBreve; private String ribaRSocBreve;
@SqlField(value = "data_iniz_msg") @SqlField(value = "data_iniz_msg")
private Date dataInizMsg; private LocalDate dataInizMsg;
@SqlField(value = "data_fine_msg") @SqlField(value = "data_fine_msg")
private Date dataFineMsg; private LocalDate dataFineMsg;
@SqlField(value = "messaggio_doc", maxLength = 130) @SqlField(value = "messaggio_doc", maxLength = 130)
private String messaggioDoc; private String messaggioDoc;
@@ -97,10 +98,10 @@ public class Azienda extends EntityBase {
private String liquidazioniIva; private String liquidazioniIva;
@SqlField(value = "last_upg_db") @SqlField(value = "last_upg_db")
private Date lastUpgDb; private LocalDate lastUpgDb;
@SqlField(value = "data_upd_sw", nullable = false) @SqlField(value = "data_upd_sw", nullable = false)
private Date dataUpdSw; private LocalDateTime dataUpdSw;
@SqlField(value = "logo_file", maxLength = 128) @SqlField(value = "logo_file", maxLength = 128)
private String logoFile; private String logoFile;
@@ -166,7 +167,7 @@ public class Azienda extends EntityBase {
private String persFisicaSesso; private String persFisicaSesso;
@SqlField(value = "pers_fisica_data_nascita") @SqlField(value = "pers_fisica_data_nascita")
private Date persFisicaDataNascita; private LocalDate persFisicaDataNascita;
@SqlField(value = "pers_fisica_comune_nascita", maxLength = 30) @SqlField(value = "pers_fisica_comune_nascita", maxLength = 30)
private String persFisicaComuneNascita; private String persFisicaComuneNascita;
@@ -274,7 +275,7 @@ public class Azienda extends EntityBase {
private String rapprLegaleComuneNascita; private String rapprLegaleComuneNascita;
@SqlField(value = "rappr_legale_data_nascita") @SqlField(value = "rappr_legale_data_nascita")
private Date rapprLegaleDataNascita; private LocalDate rapprLegaleDataNascita;
@SqlField(value = "rappr_legale_prov_nascita", maxLength = 2) @SqlField(value = "rappr_legale_prov_nascita", maxLength = 2)
private String rapprLegaleProvNascita; private String rapprLegaleProvNascita;
@@ -309,261 +310,314 @@ public class Azienda extends EntityBase {
String sql = "SELECT TOP 1 * FROM azienda"; String sql = "SELECT TOP 1 * FROM azienda";
return UtilityDB.executeSimpleQueryOnlyFirstRowDTO(conn, sql, Azienda.class); return UtilityDB.executeSimpleQueryOnlyFirstRowDTO(conn, sql, Azienda.class);
} }
public String getApplicationName() {
return applicationName;
}
public ApplicationName getApplicationNameEnum() {
return ApplicationName.valueOf(getApplicationName());
}
public void setApplicationName(String applicationName) {
this.applicationName = applicationName;
}
public String getNomeDitta() { public String getNomeDitta() {
return nomeDitta; return nomeDitta;
} }
public void setNomeDitta(String nomeDitta) { public Azienda setNomeDitta(String nomeDitta) {
this.nomeDitta = nomeDitta; this.nomeDitta = nomeDitta;
return this;
} }
public String getIndirizzo() { public String getIndirizzo() {
return indirizzo; return indirizzo;
} }
public void setIndirizzo(String indirizzo) { public Azienda setIndirizzo(String indirizzo) {
this.indirizzo = indirizzo; this.indirizzo = indirizzo;
return this;
} }
public String getCap() { public String getCap() {
return cap; return cap;
} }
public void setCap(String cap) { public Azienda setCap(String cap) {
this.cap = cap; this.cap = cap;
return this;
} }
public String getCitta() { public String getCitta() {
return citta; return citta;
} }
public void setCitta(String citta) { public Azienda setCitta(String citta) {
this.citta = citta; this.citta = citta;
return this;
} }
public String getProv() { public String getProv() {
return prov; return prov;
} }
public void setProv(String prov) { public Azienda setProv(String prov) {
this.prov = prov; this.prov = prov;
return this;
} }
public String getPartIva() { public String getPartIva() {
return partIva; return partIva;
} }
public void setPartIva(String partIva) { public Azienda setPartIva(String partIva) {
this.partIva = partIva; this.partIva = partIva;
return this;
} }
public String getNumTel() { public String getNumTel() {
return numTel; return numTel;
} }
public void setNumTel(String numTel) { public Azienda setNumTel(String numTel) {
this.numTel = numTel; this.numTel = numTel;
return this;
} }
public String getNumFax() { public String getNumFax() {
return numFax; return numFax;
} }
public void setNumFax(String numFax) { public Azienda setNumFax(String numFax) {
this.numFax = numFax; this.numFax = numFax;
return this;
} }
public String geteMail() { public String geteMail() {
return eMail; return eMail;
} }
public void seteMail(String eMail) { public Azienda seteMail(String eMail) {
this.eMail = eMail; this.eMail = eMail;
return this;
} }
public Integer getAnnoContab() { public Integer getAnnoContab() {
return annoContab; return annoContab;
} }
public void setAnnoContab(Integer annoContab) { public Azienda setAnnoContab(Integer annoContab) {
this.annoContab = annoContab; this.annoContab = annoContab;
return this;
} }
public Integer getAnnoMagaz() { public Integer getAnnoMagaz() {
return annoMagaz; return annoMagaz;
} }
public void setAnnoMagaz(Integer annoMagaz) { public Azienda setAnnoMagaz(Integer annoMagaz) {
this.annoMagaz = annoMagaz; this.annoMagaz = annoMagaz;
return this;
} }
public Integer getAnnoAttuale() { public Integer getAnnoAttuale() {
return annoAttuale; return annoAttuale;
} }
public void setAnnoAttuale(Integer annoAttuale) { public Azienda setAnnoAttuale(Integer annoAttuale) {
this.annoAttuale = annoAttuale; this.annoAttuale = annoAttuale;
return this;
} }
public Date getUltDataGio() { public LocalDate getUltDataGio() {
return ultDataGio; return ultDataGio;
} }
public void setUltDataGio(Date ultDataGio) { public Azienda setUltDataGio(LocalDate ultDataGio) {
this.ultDataGio = ultDataGio; this.ultDataGio = ultDataGio;
return this;
} }
public Integer getUltNumGio() { public Integer getUltNumGio() {
return ultNumGio; return ultNumGio;
} }
public void setUltNumGio(Integer ultNumGio) { public Azienda setUltNumGio(Integer ultNumGio) {
this.ultNumGio = ultNumGio; this.ultNumGio = ultNumGio;
return this;
} }
public String getRibaRSoc1() { public String getRibaRSoc1() {
return ribaRSoc1; return ribaRSoc1;
} }
public void setRibaRSoc1(String ribaRSoc1) { public Azienda setRibaRSoc1(String ribaRSoc1) {
this.ribaRSoc1 = ribaRSoc1; this.ribaRSoc1 = ribaRSoc1;
return this;
} }
public String getRibaRSoc2() { public String getRibaRSoc2() {
return ribaRSoc2; return ribaRSoc2;
} }
public void setRibaRSoc2(String ribaRSoc2) { public Azienda setRibaRSoc2(String ribaRSoc2) {
this.ribaRSoc2 = ribaRSoc2; this.ribaRSoc2 = ribaRSoc2;
return this;
} }
public String getRibaRSocBreve() { public String getRibaRSocBreve() {
return ribaRSocBreve; return ribaRSocBreve;
} }
public void setRibaRSocBreve(String ribaRSocBreve) { public Azienda setRibaRSocBreve(String ribaRSocBreve) {
this.ribaRSocBreve = ribaRSocBreve; this.ribaRSocBreve = ribaRSocBreve;
return this;
} }
public Date getDataInizMsg() { public LocalDate getDataInizMsg() {
return dataInizMsg; return dataInizMsg;
} }
public void setDataInizMsg(Date dataInizMsg) { public Azienda setDataInizMsg(LocalDate dataInizMsg) {
this.dataInizMsg = dataInizMsg; this.dataInizMsg = dataInizMsg;
return this;
} }
public Date getDataFineMsg() { public LocalDate getDataFineMsg() {
return dataFineMsg; return dataFineMsg;
} }
public void setDataFineMsg(Date dataFineMsg) { public Azienda setDataFineMsg(LocalDate dataFineMsg) {
this.dataFineMsg = dataFineMsg; this.dataFineMsg = dataFineMsg;
return this;
} }
public String getMessaggioDoc() { public String getMessaggioDoc() {
return messaggioDoc; return messaggioDoc;
} }
public void setMessaggioDoc(String messaggioDoc) { public Azienda setMessaggioDoc(String messaggioDoc) {
this.messaggioDoc = messaggioDoc; this.messaggioDoc = messaggioDoc;
return this;
} }
public String getLiquidazioniIva() { public String getLiquidazioniIva() {
return liquidazioniIva; return liquidazioniIva;
} }
public void setLiquidazioniIva(String liquidazioniIva) { public Azienda setLiquidazioniIva(String liquidazioniIva) {
this.liquidazioniIva = liquidazioniIva; this.liquidazioniIva = liquidazioniIva;
return this;
} }
public Date getLastUpgDb() { public LocalDate getLastUpgDb() {
return lastUpgDb; return lastUpgDb;
} }
public void setLastUpgDb(Date lastUpgDb) { public Azienda setLastUpgDb(LocalDate lastUpgDb) {
this.lastUpgDb = lastUpgDb; this.lastUpgDb = lastUpgDb;
return this;
}
public LocalDateTime getDataUpdSw() {
return dataUpdSw;
}
public Azienda setDataUpdSw(LocalDateTime dataUpdSw) {
this.dataUpdSw = dataUpdSw;
return this;
} }
public String getLogoFile() { public String getLogoFile() {
return logoFile; return logoFile;
} }
public void setLogoFile(String logoFile) { public Azienda setLogoFile(String logoFile) {
this.logoFile = logoFile; this.logoFile = logoFile;
return this;
} }
public String getLogoB64() { public String getLogoB64() {
return logoB64; return logoB64;
} }
public void setLogoB64(String logoB64) { public Azienda setLogoB64(String logoB64) {
this.logoB64 = logoB64; this.logoB64 = logoB64;
return this;
} }
public BigDecimal getUltDareAv() { public BigDecimal getUltDareAv() {
return ultDareAv; return ultDareAv;
} }
public void setUltDareAv(BigDecimal ultDareAv) { public Azienda setUltDareAv(BigDecimal ultDareAv) {
this.ultDareAv = ultDareAv; this.ultDareAv = ultDareAv;
return this;
} }
public Integer getSollTop() { public Integer getSollTop() {
return sollTop; return sollTop;
} }
public void setSollTop(Integer sollTop) { public Azienda setSollTop(Integer sollTop) {
this.sollTop = sollTop; this.sollTop = sollTop;
return this;
} }
public Integer getSollLeft() { public Integer getSollLeft() {
return sollLeft; return sollLeft;
} }
public void setSollLeft(Integer sollLeft) { public Azienda setSollLeft(Integer sollLeft) {
this.sollLeft = sollLeft; this.sollLeft = sollLeft;
return this;
} }
public Integer getGgUtili() { public Integer getGgUtili() {
return ggUtili; return ggUtili;
} }
public void setGgUtili(Integer ggUtili) { public Azienda setGgUtili(Integer ggUtili) {
this.ggUtili = ggUtili; this.ggUtili = ggUtili;
return this;
} }
public String getCodSia() { public String getCodSia() {
return codSia; return codSia;
} }
public void setCodSia(String codSia) { public Azienda setCodSia(String codSia) {
this.codSia = codSia; this.codSia = codSia;
return this;
} }
public String getFlagFattDiff() { public String getFlagFattDiff() {
return flagFattDiff; return flagFattDiff;
} }
public void setFlagFattDiff(String flagFattDiff) { public Azienda setFlagFattDiff(String flagFattDiff) {
this.flagFattDiff = flagFattDiff; this.flagFattDiff = flagFattDiff;
return this;
} }
public String getSollHeadPersonal() { public String getSollHeadPersonal() {
return sollHeadPersonal; return sollHeadPersonal;
} }
public void setSollHeadPersonal(String sollHeadPersonal) { public Azienda setSollHeadPersonal(String sollHeadPersonal) {
this.sollHeadPersonal = sollHeadPersonal; this.sollHeadPersonal = sollHeadPersonal;
return this;
} }
public String getLastUpgSp() { public String getLastUpgSp() {
return lastUpgSp; return lastUpgSp;
} }
public void setLastUpgSp(String lastUpgSp) { public Azienda setLastUpgSp(String lastUpgSp) {
this.lastUpgSp = lastUpgSp; this.lastUpgSp = lastUpgSp;
return this;
} }
public String getLastUpgDbMenu() { public String getLastUpgDbMenu() {
@@ -579,352 +633,400 @@ public class Azienda extends EntityBase {
return sitoWeb; return sitoWeb;
} }
public void setSitoWeb(String sitoWeb) { public Azienda setSitoWeb(String sitoWeb) {
this.sitoWeb = sitoWeb; this.sitoWeb = sitoWeb;
return this;
} }
public BigDecimal getCapitaleSoc() { public BigDecimal getCapitaleSoc() {
return capitaleSoc; return capitaleSoc;
} }
public void setCapitaleSoc(BigDecimal capitaleSoc) { public Azienda setCapitaleSoc(BigDecimal capitaleSoc) {
this.capitaleSoc = capitaleSoc; this.capitaleSoc = capitaleSoc;
return this;
} }
public String getCciaa() { public String getCciaa() {
return cciaa; return cciaa;
} }
public void setCciaa(String cciaa) { public Azienda setCciaa(String cciaa) {
this.cciaa = cciaa; this.cciaa = cciaa;
} return this;
public String getCodRuop() {
return codRuop;
}
public void setCodRuop(String codRuop) {
this.codRuop = codRuop;
} }
public String getIscRegImp() { public String getIscRegImp() {
return iscRegImp; return iscRegImp;
} }
public void setIscRegImp(String iscRegImp) { public Azienda setIscRegImp(String iscRegImp) {
this.iscRegImp = iscRegImp; this.iscRegImp = iscRegImp;
return this;
} }
public String getRagSocMod() { public String getRagSocMod() {
return ragSocMod; return ragSocMod;
} }
public void setRagSocMod(String ragSocMod) { public Azienda setRagSocMod(String ragSocMod) {
this.ragSocMod = ragSocMod; this.ragSocMod = ragSocMod;
return this;
} }
public String getPrefissoEan() { public String getPrefissoEan() {
return prefissoEan; return prefissoEan;
} }
public void setPrefissoEan(String prefissoEan) { public Azienda setPrefissoEan(String prefissoEan) {
this.prefissoEan = prefissoEan; this.prefissoEan = prefissoEan;
return this;
} }
public String getCodFiscale() { public String getCodFiscale() {
return codFiscale; return codFiscale;
} }
public void setCodFiscale(String codFiscale) { public Azienda setCodFiscale(String codFiscale) {
this.codFiscale = codFiscale; this.codFiscale = codFiscale;
return this;
} }
public String getPersFisicaCognome() { public String getPersFisicaCognome() {
return persFisicaCognome; return persFisicaCognome;
} }
public void setPersFisicaCognome(String persFisicaCognome) { public Azienda setPersFisicaCognome(String persFisicaCognome) {
this.persFisicaCognome = persFisicaCognome; this.persFisicaCognome = persFisicaCognome;
return this;
} }
public String getPersFisicaNome() { public String getPersFisicaNome() {
return persFisicaNome; return persFisicaNome;
} }
public void setPersFisicaNome(String persFisicaNome) { public Azienda setPersFisicaNome(String persFisicaNome) {
this.persFisicaNome = persFisicaNome; this.persFisicaNome = persFisicaNome;
return this;
} }
public String getPersFisicaSesso() { public String getPersFisicaSesso() {
return persFisicaSesso; return persFisicaSesso;
} }
public void setPersFisicaSesso(String persFisicaSesso) { public Azienda setPersFisicaSesso(String persFisicaSesso) {
this.persFisicaSesso = persFisicaSesso; this.persFisicaSesso = persFisicaSesso;
return this;
} }
public Date getPersFisicaDataNascita() { public LocalDate getPersFisicaDataNascita() {
return persFisicaDataNascita; return persFisicaDataNascita;
} }
public void setPersFisicaDataNascita(Date persFisicaDataNascita) { public Azienda setPersFisicaDataNascita(LocalDate persFisicaDataNascita) {
this.persFisicaDataNascita = persFisicaDataNascita; this.persFisicaDataNascita = persFisicaDataNascita;
return this;
} }
public String getPersFisicaComuneNascita() { public String getPersFisicaComuneNascita() {
return persFisicaComuneNascita; return persFisicaComuneNascita;
} }
public void setPersFisicaComuneNascita(String persFisicaComuneNascita) { public Azienda setPersFisicaComuneNascita(String persFisicaComuneNascita) {
this.persFisicaComuneNascita = persFisicaComuneNascita; this.persFisicaComuneNascita = persFisicaComuneNascita;
return this;
} }
public String getPersFisicaProvNascita() { public String getPersFisicaProvNascita() {
return persFisicaProvNascita; return persFisicaProvNascita;
} }
public void setPersFisicaProvNascita(String persFisicaProvNascita) { public Azienda setPersFisicaProvNascita(String persFisicaProvNascita) {
this.persFisicaProvNascita = persFisicaProvNascita; this.persFisicaProvNascita = persFisicaProvNascita;
return this;
} }
public String getFlagPersFisica() { public String getFlagPersFisica() {
return flagPersFisica; return flagPersFisica;
} }
public void setFlagPersFisica(String flagPersFisica) { public Azienda setFlagPersFisica(String flagPersFisica) {
this.flagPersFisica = flagPersFisica; this.flagPersFisica = flagPersFisica;
return this;
} }
public String getPersFisicaCodFisc() { public String getPersFisicaCodFisc() {
return persFisicaCodFisc; return persFisicaCodFisc;
} }
public void setPersFisicaCodFisc(String persFisicaCodFisc) { public Azienda setPersFisicaCodFisc(String persFisicaCodFisc) {
this.persFisicaCodFisc = persFisicaCodFisc; this.persFisicaCodFisc = persFisicaCodFisc;
return this;
} }
public String getRapprLegaleCodFisc() { public String getRapprLegaleCodFisc() {
return rapprLegaleCodFisc; return rapprLegaleCodFisc;
} }
public void setRapprLegaleCodFisc(String rapprLegaleCodFisc) { public Azienda setRapprLegaleCodFisc(String rapprLegaleCodFisc) {
this.rapprLegaleCodFisc = rapprLegaleCodFisc; this.rapprLegaleCodFisc = rapprLegaleCodFisc;
return this;
} }
public String getSedeAmm() { public String getSedeAmm() {
return sedeAmm; return sedeAmm;
} }
public void setSedeAmm(String sedeAmm) { public Azienda setSedeAmm(String sedeAmm) {
this.sedeAmm = sedeAmm; this.sedeAmm = sedeAmm;
} return this;
public boolean isFlagSetIvaOmaggi() {
return "S".equalsIgnoreCase(flagSetIvaOmaggi);
} }
public String getFlagSetIvaOmaggi() { public String getFlagSetIvaOmaggi() {
return flagSetIvaOmaggi; return flagSetIvaOmaggi;
} }
public void setFlagSetIvaOmaggi(String flagSetIvaOmaggi) { public boolean isFlagSetIvaOmaggi() {
return flagSetIvaOmaggi.equalsIgnoreCase("S");
}
public Azienda setFlagSetIvaOmaggi(String flagSetIvaOmaggi) {
this.flagSetIvaOmaggi = flagSetIvaOmaggi; this.flagSetIvaOmaggi = flagSetIvaOmaggi;
} return this;
public String getApplicationName() {
return applicationName;
}
public ApplicationName getApplicationNameEnum() {
return ApplicationName.valueOf(getApplicationName());
}
public void setApplicationName(String applicationName) {
this.applicationName = applicationName;
} }
public String getFlagTipoFatturazione() { public String getFlagTipoFatturazione() {
return flagTipoFatturazione; return flagTipoFatturazione;
} }
public void setFlagTipoFatturazione(String flagTipoFatturazione) { public Azienda setFlagTipoFatturazione(String flagTipoFatturazione) {
this.flagTipoFatturazione = flagTipoFatturazione; this.flagTipoFatturazione = flagTipoFatturazione;
return this;
} }
public String getTribunale() { public String getTribunale() {
return tribunale; return tribunale;
} }
public void setTribunale(String tribunale) { public Azienda setTribunale(String tribunale) {
this.tribunale = tribunale; this.tribunale = tribunale;
return this;
} }
public Integer getSettRitardoAnno() { public Integer getSettRitardoAnno() {
return settRitardoAnno; return settRitardoAnno;
} }
public void setSettRitardoAnno(Integer settRitardoAnno) { public Azienda setSettRitardoAnno(Integer settRitardoAnno) {
this.settRitardoAnno = settRitardoAnno; this.settRitardoAnno = settRitardoAnno;
return this;
} }
public String getDbDistributore() { public String getDbDistributore() {
return dbDistributore; return dbDistributore;
} }
public void setDbDistributore(String dbDistributore) { public Azienda setDbDistributore(String dbDistributore) {
this.dbDistributore = dbDistributore; this.dbDistributore = dbDistributore;
return this;
} }
public String getCodAteco() { public String getCodAteco() {
return codAteco; return codAteco;
} }
public void setCodAteco(String codAteco) { public Azienda setCodAteco(String codAteco) {
this.codAteco = codAteco; this.codAteco = codAteco;
return this;
} }
public String getLastUpgQc() { public String getLastUpgQc() {
return lastUpgQc; return lastUpgQc;
} }
public void setLastUpgQc(String lastUpgQc) { public Azienda setLastUpgQc(String lastUpgQc) {
this.lastUpgQc = lastUpgQc; this.lastUpgQc = lastUpgQc;
return this;
} }
public String getTipoAzienda() { public String getTipoAzienda() {
return tipoAzienda; return tipoAzienda;
} }
public void setTipoAzienda(String tipoAzienda) { public Azienda setTipoAzienda(String tipoAzienda) {
this.tipoAzienda = tipoAzienda; this.tipoAzienda = tipoAzienda;
return this;
} }
public String getNazione() { public String getNazione() {
return nazione; return nazione;
} }
public void setNazione(String nazione) { public Azienda setNazione(String nazione) {
this.nazione = nazione; this.nazione = nazione;
return this;
} }
public String getCodDiviContab() { public String getCodDiviContab() {
return codDiviContab; return codDiviContab;
} }
public void setCodDiviContab(String codDiviContab) { public Azienda setCodDiviContab(String codDiviContab) {
this.codDiviContab = codDiviContab; this.codDiviContab = codDiviContab;
return this;
} }
public String getCodIvaOmaggi() { public String getCodIvaOmaggi() {
return codIvaOmaggi; return codIvaOmaggi;
} }
public void setCodIvaOmaggi(String codIvaOmaggi) { public Azienda setCodIvaOmaggi(String codIvaOmaggi) {
this.codIvaOmaggi = codIvaOmaggi; this.codIvaOmaggi = codIvaOmaggi;
return this;
} }
public String getCodCconQuadra() { public String getCodCconQuadra() {
return codCconQuadra; return codCconQuadra;
} }
public void setCodCconQuadra(String codCconQuadra) { public Azienda setCodCconQuadra(String codCconQuadra) {
this.codCconQuadra = codCconQuadra; this.codCconQuadra = codCconQuadra;
return this;
}
public String getCodRuop() {
return codRuop;
}
public Azienda setCodRuop(String codRuop) {
this.codRuop = codRuop;
return this;
}
public Long getProgressivoSscc() {
return progressivoSscc;
}
public Azienda setProgressivoSscc(Long progressivoSscc) {
this.progressivoSscc = progressivoSscc;
return this;
}
public String getCodSdiDitta() {
return codSdiDitta;
}
public Azienda setCodSdiDitta(String codSdiDitta) {
this.codSdiDitta = codSdiDitta;
return this;
} }
public String getRegFisc() { public String getRegFisc() {
return regFisc; return regFisc;
} }
public void setRegFisc(String regFisc) { public Azienda setRegFisc(String regFisc) {
this.regFisc = regFisc; this.regFisc = regFisc;
return this;
} }
public String getStatoLiquidazione() { public String getStatoLiquidazione() {
return statoLiquidazione; return statoLiquidazione;
} }
public void setStatoLiquidazione(String statoLiquidazione) { public Azienda setStatoLiquidazione(String statoLiquidazione) {
this.statoLiquidazione = statoLiquidazione; this.statoLiquidazione = statoLiquidazione;
return this;
} }
public String getEmailSdi() { public String getEmailSdi() {
return emailSdi; return emailSdi;
} }
public void setEmailSdi(String emailSdi) { public Azienda setEmailSdi(String emailSdi) {
this.emailSdi = emailSdi; this.emailSdi = emailSdi;
return this;
} }
public String getFromEmailSdi() { public String getFromEmailSdi() {
return fromEmailSdi; return fromEmailSdi;
} }
public void setFromEmailSdi(String fromEmailSdi) { public Azienda setFromEmailSdi(String fromEmailSdi) {
this.fromEmailSdi = fromEmailSdi; this.fromEmailSdi = fromEmailSdi;
return this;
} }
public String getIdCreditoreSepa() { public String getIdCreditoreSepa() {
return idCreditoreSepa; return idCreditoreSepa;
} }
public void setIdCreditoreSepa(String idCreditoreSepa) { public Azienda setIdCreditoreSepa(String idCreditoreSepa) {
this.idCreditoreSepa = idCreditoreSepa; this.idCreditoreSepa = idCreditoreSepa;
return this;
} }
public String getMessaggioPrivacy() { public String getMessaggioPrivacy() {
return messaggioPrivacy; return messaggioPrivacy;
} }
public void setMessaggioPrivacy(String messaggioPrivacy) { public Azienda setMessaggioPrivacy(String messaggioPrivacy) {
this.messaggioPrivacy = messaggioPrivacy; this.messaggioPrivacy = messaggioPrivacy;
return this;
} }
public String getRapprLegaleNome() { public String getRapprLegaleNome() {
return rapprLegaleNome; return rapprLegaleNome;
} }
public void setRapprLegaleNome(String rapprLegaleNome) { public Azienda setRapprLegaleNome(String rapprLegaleNome) {
this.rapprLegaleNome = rapprLegaleNome; this.rapprLegaleNome = rapprLegaleNome;
return this;
} }
public String getRapprLegaleCognome() { public String getRapprLegaleCognome() {
return rapprLegaleCognome; return rapprLegaleCognome;
} }
public void setRapprLegaleCognome(String rapprLegaleCognome) { public Azienda setRapprLegaleCognome(String rapprLegaleCognome) {
this.rapprLegaleCognome = rapprLegaleCognome; this.rapprLegaleCognome = rapprLegaleCognome;
return this;
} }
public String getRapprLegaleSesso() { public String getRapprLegaleSesso() {
return rapprLegaleSesso; return rapprLegaleSesso;
} }
public void setRapprLegaleSesso(String rapprLegaleSesso) { public Azienda setRapprLegaleSesso(String rapprLegaleSesso) {
this.rapprLegaleSesso = rapprLegaleSesso; this.rapprLegaleSesso = rapprLegaleSesso;
return this;
} }
public String getRapprLegaleComuneNascita() { public String getRapprLegaleComuneNascita() {
return rapprLegaleComuneNascita; return rapprLegaleComuneNascita;
} }
public void setRapprLegaleComuneNascita(String rapprLegaleComuneNascita) { public Azienda setRapprLegaleComuneNascita(String rapprLegaleComuneNascita) {
this.rapprLegaleComuneNascita = rapprLegaleComuneNascita; this.rapprLegaleComuneNascita = rapprLegaleComuneNascita;
return this;
} }
public Date getRapprLegaleDataNascita() { public LocalDate getRapprLegaleDataNascita() {
return rapprLegaleDataNascita; return rapprLegaleDataNascita;
} }
public void setRapprLegaleDataNascita(Date rapprLegaleDataNascita) { public Azienda setRapprLegaleDataNascita(LocalDate rapprLegaleDataNascita) {
this.rapprLegaleDataNascita = rapprLegaleDataNascita; this.rapprLegaleDataNascita = rapprLegaleDataNascita;
return this;
} }
public String getRapprLegaleProvNascita() { public String getRapprLegaleProvNascita() {
return rapprLegaleProvNascita; return rapprLegaleProvNascita;
} }
public void setRapprLegaleProvNascita(String rapprLegaleProvNascita) { public Azienda setRapprLegaleProvNascita(String rapprLegaleProvNascita) {
this.rapprLegaleProvNascita = rapprLegaleProvNascita; this.rapprLegaleProvNascita = rapprLegaleProvNascita;
return this;
} }
public Integer getGiornoInizAnnoFisc() { public Integer getGiornoInizAnnoFisc() {
@@ -962,31 +1064,4 @@ public class Azienda extends EntityBase {
this.jwtSecretKey = jwtSecretKey; this.jwtSecretKey = jwtSecretKey;
return this; return this;
} }
public Date getDataUpdSw() {
return dataUpdSw;
}
public Azienda setDataUpdSw(Date dataUpdSw) {
this.dataUpdSw = dataUpdSw;
return this;
}
public Long getProgressivoSscc() {
return progressivoSscc;
}
public Azienda setProgressivoSscc(Long progressivoSscc) {
this.progressivoSscc = progressivoSscc;
return this;
}
public String getCodSdiDitta() {
return codSdiDitta;
}
public Azienda setCodSdiDitta(String codSdiDitta) {
this.codSdiDitta = codSdiDitta;
return this;
}
} }

View File

@@ -10,8 +10,8 @@ import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.kie.api.definition.type.PropertyReactive; import org.kie.api.definition.type.PropertyReactive;
import java.time.LocalDate;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
@Master @Master
@@ -190,10 +190,10 @@ public class DtbTipi extends EntityBase {
private String pathBanner; private String pathBanner;
@SqlField(value = "data_iniz_banner") @SqlField(value = "data_iniz_banner")
private Date dataInizBanner; private LocalDate dataInizBanner;
@SqlField(value = "data_fine_banner") @SqlField(value = "data_fine_banner")
private Date dataFineBanner; private LocalDate dataFineBanner;
@SqlField(value = "flag_dest_obb", maxLength = 1, nullable = false, defaultObjectValue = "N") @SqlField(value = "flag_dest_obb", maxLength = 1, nullable = false, defaultObjectValue = "N")
private String flagDestObb; private String flagDestObb;
@@ -747,20 +747,20 @@ public class DtbTipi extends EntityBase {
return this; return this;
} }
public Date getDataInizBanner() { public LocalDate getDataInizBanner() {
return dataInizBanner; return dataInizBanner;
} }
public DtbTipi setDataInizBanner(Date dataInizBanner) { public DtbTipi setDataInizBanner(LocalDate dataInizBanner) {
this.dataInizBanner = dataInizBanner; this.dataInizBanner = dataInizBanner;
return this; return this;
} }
public Date getDataFineBanner() { public LocalDate getDataFineBanner() {
return dataFineBanner; return dataFineBanner;
} }
public DtbTipi setDataFineBanner(Date dataFineBanner) { public DtbTipi setDataFineBanner(LocalDate dataFineBanner) {
this.dataFineBanner = dataFineBanner; this.dataFineBanner = dataFineBanner;
return this; return this;
} }

View File

@@ -5,16 +5,18 @@ import it.integry.ems_model.annotation.PK;
import it.integry.ems_model.annotation.SqlField; import it.integry.ems_model.annotation.SqlField;
import it.integry.ems_model.annotation.Table; import it.integry.ems_model.annotation.Table;
import it.integry.ems_model.base.EntityBase; import it.integry.ems_model.base.EntityBase;
import it.integry.ems_model.base.EquatableEntityInterface;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.kie.api.definition.type.PropertyReactive; import org.kie.api.definition.type.PropertyReactive;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Objects;
@PropertyReactive @PropertyReactive
@Table(MtbAartBarCode.ENTITY) @Table(MtbAartBarCode.ENTITY)
@JsonTypeName(MtbAartBarCode.ENTITY) @JsonTypeName(MtbAartBarCode.ENTITY)
public class MtbAartBarCode extends EntityBase { public class MtbAartBarCode extends EntityBase implements EquatableEntityInterface<MtbAartBarCode> {
private final static Logger logger = LogManager.getLogger(); private final static Logger logger = LogManager.getLogger();
@@ -86,4 +88,31 @@ public class MtbAartBarCode extends EntityBase {
this.tipoCodBarre = tipoCodBarre; this.tipoCodBarre = tipoCodBarre;
return this; return this;
} }
@Override
public boolean equals(Object o) {
if (!(o instanceof MtbAartBarCode)) return false;
MtbAartBarCode that = (MtbAartBarCode) o;
return Objects.equals(getCodBarre(), that.getCodBarre()) && Objects.equals(getCodMart(), that.getCodMart()) && Objects.equals(getQtaCnf(), that.getQtaCnf()) && Objects.equals(getFlagPrimario(), that.getFlagPrimario()) && Objects.equals(getTipoCodBarre(), that.getTipoCodBarre());
}
@Override
public int hashCode() {
return Objects.hash(getCodBarre(), getCodMart(), getQtaCnf(), getFlagPrimario(), getTipoCodBarre());
}
@Override
public int hashCodeKey() {
return Objects.hash(getCodBarre(), getCodMart());
}
@Override
public boolean equalsKey(MtbAartBarCode other) {
if (this == other) return true;
if (!(other instanceof MtbAartBarCode)) return false;
MtbAartBarCode mtbAartBarCode = other;
return Objects.equals(getCodBarre(), mtbAartBarCode.getCodBarre()) &&
Objects.equals(getCodMart(), mtbAartBarCode.getCodMart());
}
} }

View File

@@ -6,14 +6,17 @@ import it.integry.ems_model.annotation.PK;
import it.integry.ems_model.annotation.SqlField; import it.integry.ems_model.annotation.SqlField;
import it.integry.ems_model.annotation.Table; import it.integry.ems_model.annotation.Table;
import it.integry.ems_model.base.EntityBase; import it.integry.ems_model.base.EntityBase;
import it.integry.ems_model.base.EquatableEntityInterface;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.kie.api.definition.type.PropertyReactive; import org.kie.api.definition.type.PropertyReactive;
import java.util.Objects;
@PropertyReactive @PropertyReactive
@Table(MtbAartCarat.ENTITY) @Table(MtbAartCarat.ENTITY)
@JsonTypeName(MtbAartCarat.ENTITY) @JsonTypeName(MtbAartCarat.ENTITY)
public class MtbAartCarat extends EntityBase { public class MtbAartCarat extends EntityBase implements EquatableEntityInterface<MtbAartCarat> {
private final static Logger logger = LogManager.getLogger(); private final static Logger logger = LogManager.getLogger();
@@ -82,4 +85,31 @@ public class MtbAartCarat extends EntityBase {
this.chkCompatibilita = chkCompatibilita; this.chkCompatibilita = chkCompatibilita;
return this; return this;
} }
@Override
public boolean equals(Object o) {
if (!(o instanceof MtbAartCarat)) return false;
MtbAartCarat that = (MtbAartCarat) o;
return Objects.equals(getCodMart(), that.getCodMart()) && Objects.equals(getCarat(), that.getCarat()) && Objects.equals(getValCarat(), that.getValCarat()) && Objects.equals(getNote(), that.getNote()) && Objects.equals(getChkCompatibilita(), that.getChkCompatibilita());
}
@Override
public int hashCode() {
return Objects.hash(getCodMart(), getCarat(), getValCarat(), getNote(), getChkCompatibilita());
}
@Override
public int hashCodeKey() {
return Objects.hash(getCodMart(), getCarat());
}
@Override
public boolean equalsKey(MtbAartCarat other) {
if (this == other) return true;
if (!(other instanceof MtbAartCarat)) return false;
MtbAartCarat mtbAartBarCode = other;
return Objects.equals(getCarat(), mtbAartBarCode.getCarat()) &&
Objects.equals(getCodMart(), mtbAartBarCode.getCodMart());
}
} }

View File

@@ -25,6 +25,7 @@ import it.integry.ems.service.exception.EmptyReportException;
import it.integry.ems.settings.Model.AvailableConnectionModel; import it.integry.ems.settings.Model.AvailableConnectionModel;
import it.integry.ems.settings.Model.SettingsModel; import it.integry.ems.settings.Model.SettingsModel;
import it.integry.ems.status.ServiceChecker; import it.integry.ems.status.ServiceChecker;
import it.integry.ems.sync.MultiDBTransaction.Connection;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager; import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.system.dto.ChangeLogDTO; import it.integry.ems.system.dto.ChangeLogDTO;
import it.integry.ems.system.dto.GestNameDTO; import it.integry.ems.system.dto.GestNameDTO;
@@ -69,6 +70,8 @@ import java.lang.reflect.Method;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@@ -1755,4 +1758,124 @@ public class SystemController {
return ServiceRestResponse.createPositiveResponse(); return ServiceRestResponse.createPositiveResponse();
} }
@PostMapping(value = "system/svuotaNuovoDb")
public ServiceRestResponse svuotaNuovoDb(
HttpServletRequest request,
@RequestParam(CommonConstants.PROFILE_DB) String configuration,
@RequestParam String nomeDitta,
@RequestParam String partitaIva,
@RequestBody(required = false) List<String> tabelleDaEscludere
) throws Exception {
List<String> systemTable = new ArrayList<>();
systemTable.add("azienda");
systemTable.add("ctb_tipo_azienda");
systemTable.add("ctb_tipo_riep");
systemTable.add("dtb_intracee_natura");
systemTable.add("dtb_mod_stampa");
systemTable.add("dtb_tipi_fe");
systemTable.add("dtb_transaz_intracee");
systemTable.add("gtb_aliq_natura");
systemTable.add("gtb_anni_divi");
systemTable.add("gtb_divi");
systemTable.add("gtb_divi_iso");
systemTable.add("gtb_lingue");
systemTable.add("gtb_nazi_iso");
systemTable.add("gtb_paesi_esteri");
systemTable.add("gtb_paga_fe");
systemTable.add("gtb_periodo_fisc");
systemTable.add("gtb_porto");
systemTable.add("gtb_reg_fisc");
systemTable.add("gtb_tipi_paga");
systemTable.add("jtb_ricorrenze");
systemTable.add("mtb_movn");
systemTable.add("stb_activity_num");
systemTable.add("stb_calt");
systemTable.add("stb_counter");
systemTable.add("stb_dates");
systemTable.add("stb_datetimes");
systemTable.add("stb_gest_setup");
systemTable.add("stb_gest_setup_query");
systemTable.add("stb_gest_sync");
systemTable.add("stb_lookup_query");
systemTable.add("stb_menu");
systemTable.add("stb_menu_opz");
systemTable.add("stb_migration_status");
systemTable.add("stb_multiplier");
systemTable.add("stb_tipo_azienda");
systemTable.add("stb_user");
systemTable.add("Wtb_languages_det");
systemTable.add("Wtb_user_groups");
if (tabelleDaEscludere == null) tabelleDaEscludere = new ArrayList<>();
String sql =
"SELECT DISTINCT t.name AS table_name\n" +
"FROM \n" +
" sys.tables t\n" +
" INNER JOIN sys.schemas s ON t.schema_id = s.schema_id\n" +
" INNER JOIN sys.indexes i ON t.object_id = i.object_id\n" +
" INNER JOIN sys.partitions p ON i.object_id = p.object_id AND i.index_id = p.index_id\n" +
"WHERE \n" +
" t.is_ms_shipped = 0\n" +
"\tand s.name = 'dbo'\n" +
"\tand p.rows > 0\n";
List<String> tabelleDaSvuotare = UtilityDB.executeSimpleQueryOnlyFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
List<String> finalTabelleDaEscludere = tabelleDaEscludere;
tabelleDaSvuotare = tabelleDaSvuotare
.stream()
.filter(x -> !systemTable.contains(x) && !finalTabelleDaEscludere.contains(x))
.collect(Collectors.toList());
while (!tabelleDaSvuotare.isEmpty()) {
Iterator<String> it = tabelleDaSvuotare.iterator();
while (it.hasNext()) {
String tableName = it.next();
sql = Query.format("SELECT CAST(SUM(p.rows) AS BIT)\n" +
"FROM sys.foreign_keys fk\n" +
" INNER JOIN sys.indexes i ON fk.parent_object_id = i.object_id\n" +
" INNER JOIN sys.partitions p ON i.object_id = p.object_id AND i.index_id = p.index_id\n" +
"WHERE OBJECT_NAME(fk.referenced_object_id) = %s", tableName);
boolean existFk = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
if (existFk) continue;
if (tableName.equalsIgnoreCase("stb_user")) {
String delete = String.format("DELETE FROM dbo.%s WHERE user_name not in ('DBA','SA') ",
tableName);
UtilityDB.executeStatement(multiDBTransactionManager.getPrimaryConnection(), delete);
} else {
int row = 1;
while (row > 0) {
UtilityDB.executeStatement(multiDBTransactionManager.getPrimaryConnection(), "EXEC dbo.sp_triggerSwitch '" + tableName + "', 'DISABLE'");
String delete = String.format("DELETE TOP (10000) FROM dbo.%s",
tableName);
UtilityDB.executeStatement(multiDBTransactionManager.getPrimaryConnection(), delete);
row = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(multiDBTransactionManager.getPrimaryConnection(),
String.format("SELECT count(*) FROM dbo.%s", tableName));
}
UtilityDB.executeStatement(multiDBTransactionManager.getPrimaryConnection(), "EXEC dbo.sp_triggerSwitch '" + tableName + "', 'ENABLE'");
}
it.remove();
}
}
// Azienda azienda = new Azienda();
// HashMap<String, Object> oldPK = new HashMap<>();
// oldPK.put("nomeDitta", azienda.getNomeDitta());
// azienda.setOldPk(oldPK);
// azienda.setNomeDitta(nomeDitta);
// azienda.setPartIva(partitaIva);
// azienda.setOperation(OperationType.SUBSTITUTE);
// entityProcessor.processEntity(azienda, multiDBTransactionManager);
return ServiceRestResponse.createPositiveResponse();
}
} }

View File

@@ -8,17 +8,17 @@ import it.integry.ems.system.exchange.service.structure.ExchangeImportDataManage
import it.integry.ems.system.exchange.service.structure.ExchangeImportSchemaManagerService; import it.integry.ems.system.exchange.service.structure.ExchangeImportSchemaManagerService;
import it.integry.ems_model.base.EquatableEntityInterface; import it.integry.ems_model.base.EquatableEntityInterface;
import it.integry.ems_model.entity.*; import it.integry.ems_model.entity.*;
import it.integry.ems_model.entity.key.MtbColtKey;
import it.integry.ems_model.types.OperationType; import it.integry.ems_model.types.OperationType;
import it.integry.ems_model.types.TypeDbObject; import it.integry.ems_model.types.TypeDbObject;
import it.integry.ems_model.utility.Query;
import it.integry.ems_model.utility.UtilityDB; import it.integry.ems_model.utility.UtilityDB;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Arrays; import java.util.*;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -52,7 +52,7 @@ public class ExchangeArticoliImportService {
importColori(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE); importColori(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE);
importLinee (internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE); importLinee(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE);
importGruppiMerceologici(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE); importGruppiMerceologici(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.INSERT, OperationType.INSERT_OR_UPDATE, OperationType.UPDATE);
@@ -62,7 +62,7 @@ public class ExchangeArticoliImportService {
importColori(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE); importColori(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE);
importLinee (internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE); importLinee(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE);
importTipi(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE); importTipi(internalMultiDb, exchangeMultiDb, useTempTable, requestDataDTO, OperationType.DELETE);
@@ -80,50 +80,29 @@ public class ExchangeArticoliImportService {
exchangeDb.getPrimaryConnection(), exchangeDb.getPrimaryConnection(),
true, false); true, false);
final List<MtbAartColori> exchangeImportedMtbAartColori = retrieveMtbAartColori(
exchangeDb.getPrimaryConnection(),
true, false);
final List<MtbAart> exchangeUpdatedData = retrieveArticoli( final List<MtbAart> exchangeUpdatedData = retrieveArticoli(
exchangeDb.getPrimaryConnection(), exchangeDb.getPrimaryConnection(),
false, useTempTable); false, useTempTable);
final List<MtbAartColori> exchangeUpdatedMtbAartColori = retrieveMtbAartColori(
exchangeDb.getPrimaryConnection(),
false, useTempTable);
List<EquatableEntityInterface> allData = exchangeImportDataManagerService List<EquatableEntityInterface> allData = exchangeImportDataManagerService
.runSync(MtbAart.class, exchangeImportedData, exchangeUpdatedData); .runSync(MtbAart.class, exchangeImportedData, exchangeUpdatedData);
List<EquatableEntityInterface> allDataColori = exchangeImportDataManagerService
.runSync(MtbAartColori.class, exchangeImportedMtbAartColori, exchangeUpdatedMtbAartColori);
allData.stream()
.filter(x -> x.getOperation() == OperationType.INSERT)
.map(x -> (MtbAart) x)
.forEach(x -> x
.setFlagStato("A")
.setOperation(OperationType.INSERT_OR_UPDATE));
allDataColori.forEach(x -> x.setOperation(x.getOperation() == OperationType.INSERT ? OperationType.INSERT_OR_UPDATE : x.getOperation()));
allData.parallelStream() allData.parallelStream()
.filter(x -> x.getOperation() == OperationType.DELETE)
.map(x -> (MtbAart) x) .map(x -> (MtbAart) x)
.forEach(x -> x.setFlagStato("I") .forEach(x -> {
.setOperation(OperationType.UPDATE)); OperationType o = OperationType.INSERT_OR_UPDATE;
String flagStato = "A";
if (x.getOperation() == OperationType.DELETE) {
allDataColori = allDataColori.stream().filter(x -> x.getOperation() != OperationType.DELETE).collect(Collectors.toList()); o = OperationType.UPDATE;
flagStato = "I";
List<EquatableEntityInterface> finalAllDataColori = allDataColori; }
allData.stream() x
.map(x -> (MtbAart) x) .setFlagStato(flagStato)
.forEach(x -> x.setMtbAartColori(finalAllDataColori.stream() .setOperation(o);
.map(y -> (MtbAartColori) y) x.getMtbAartBarCode().forEach(y -> y.setOperation(y.getOperation() == OperationType.INSERT ? OperationType.INSERT_OR_UPDATE : y.getOperation()));
.filter(y -> y.getCodMart().equalsIgnoreCase(x.getCodMart())) x.getMtbAartCarat().forEach(y -> y.setOperation(y.getOperation() == OperationType.INSERT ? OperationType.INSERT_OR_UPDATE : y.getOperation()));
.collect(Collectors.toList()))); x.getMtbAartColori().forEach(y -> y.setOperation(y.getOperation() == OperationType.INSERT ? OperationType.INSERT_OR_UPDATE : y.getOperation()));
});
final Exception[] firstExceptionToThrow = {null}; final Exception[] firstExceptionToThrow = {null};
@@ -154,7 +133,6 @@ public class ExchangeArticoliImportService {
String originalTableName = "mtb_aart"; String originalTableName = "mtb_aart";
String tableName = originalTableName + (useTempTable ? "_tmp" : ""); String tableName = originalTableName + (useTempTable ? "_tmp" : "");
if (useTempTable) { if (useTempTable) {
UtilityDB.executeStatement(connection, UtilityDB.executeStatement(connection,
"INSERT INTO " + tableName + "INSERT INTO " + tableName +
@@ -162,8 +140,30 @@ public class ExchangeArticoliImportService {
); );
} }
return exchangeImportDataManagerService.retrieveDataFromExchange(connection, MtbAart.class, List<MtbAart> mtbAart = exchangeImportDataManagerService.retrieveDataFromExchange(connection, MtbAart.class,
tableName, null, retrieveAlreadyImported); tableName, null, retrieveAlreadyImported);
final List<MtbAartBarCode> mtbAartBarCode = retrieveMtbAartBarcode(connection, retrieveAlreadyImported, useTempTable);
final List<MtbAartColori> mtbAartColori = retrieveMtbAartColori(connection, retrieveAlreadyImported, useTempTable);
final List<MtbAartCarat> mtbAartCarat = retrieveMtbAartCarat(connection, retrieveAlreadyImported, useTempTable);
mtbAart
.parallelStream()
.forEach(x -> x.setMtbAartColori(mtbAartColori.stream()
.map(y -> y)
.filter(y -> y.getCodMart().equalsIgnoreCase(x.getCodMart()))
.collect(Collectors.toList()))
.setMtbAartBarCode(mtbAartBarCode.stream()
.map(y -> y)
.filter(y -> y.getCodMart().equalsIgnoreCase(x.getCodMart()))
.collect(Collectors.toList()))
.setMtbAartCarat(mtbAartCarat.stream()
.map(y -> y)
.filter(y -> y.getCodMart().equalsIgnoreCase(x.getCodMart()))
.collect(Collectors.toList())));
return mtbAart;
} }
@@ -265,7 +265,7 @@ public class ExchangeArticoliImportService {
.map(y -> (MtbSfam) y) .map(y -> (MtbSfam) y)
.noneMatch(y -> x.getCodMgrp().equalsIgnoreCase(y.getCodMgrp()) && .noneMatch(y -> x.getCodMgrp().equalsIgnoreCase(y.getCodMgrp()) &&
x.getCodMsgr().equalsIgnoreCase(y.getCodMsgr()) && x.getCodMsgr().equalsIgnoreCase(y.getCodMsgr()) &&
x.getCodMsfa().equalsIgnoreCase(y.getCodMsfa()))) x.getCodMsfa().equalsIgnoreCase(y.getCodMsfa())))
.forEach(x -> { .forEach(x -> {
MtbSfam testata = new MtbSfam() MtbSfam testata = new MtbSfam()
.setCodMgrp(x.getCodMgrp()) .setCodMgrp(x.getCodMgrp())
@@ -514,7 +514,7 @@ public class ExchangeArticoliImportService {
} }
private void importColori(MultiDBTransactionManager internalMultiDb, MultiDBTransactionManager exchangeDb, boolean useTempTable, RequestDataDTO requestDataDTO, OperationType... operationsToProcess) throws Exception { private void importColori(MultiDBTransactionManager internalMultiDb, MultiDBTransactionManager exchangeDb, boolean useTempTable, RequestDataDTO requestDataDTO, OperationType... operationsToProcess) throws Exception {
if ( !UtilityDB.existDatabaseObject(exchangeDb.getPrimaryConnection(), "mtb_colori", TypeDbObject.VIEW)) return; if (!UtilityDB.existDatabaseObject(exchangeDb.getPrimaryConnection(), "mtb_colori", TypeDbObject.VIEW)) return;
final List<MtbColori> exchangeImportedDataMtbColori = retrieveMtbColori( final List<MtbColori> exchangeImportedDataMtbColori = retrieveMtbColori(
exchangeDb.getPrimaryConnection(), exchangeDb.getPrimaryConnection(),
@@ -593,7 +593,7 @@ public class ExchangeArticoliImportService {
} }
private void importTipi(MultiDBTransactionManager internalMultiDb, MultiDBTransactionManager exchangeDb, boolean useTempTable, RequestDataDTO requestDataDTO, OperationType... operationsToProcess) throws Exception { private void importTipi(MultiDBTransactionManager internalMultiDb, MultiDBTransactionManager exchangeDb, boolean useTempTable, RequestDataDTO requestDataDTO, OperationType... operationsToProcess) throws Exception {
if ( !UtilityDB.existDatabaseObject(exchangeDb.getPrimaryConnection(), "mtb_tipi", TypeDbObject.VIEW)) return; if (!UtilityDB.existDatabaseObject(exchangeDb.getPrimaryConnection(), "mtb_tipi", TypeDbObject.VIEW)) return;
final List<MtbTipi> exchangeImportedData = retrieveMtbAartTipi( final List<MtbTipi> exchangeImportedData = retrieveMtbAartTipi(
exchangeDb.getPrimaryConnection(), exchangeDb.getPrimaryConnection(),
@@ -886,5 +886,39 @@ public class ExchangeArticoliImportService {
tableName, null, retrieveAlreadyImported); tableName, null, retrieveAlreadyImported);
} }
private List<MtbAartBarCode> retrieveMtbAartBarcode(Connection connection, boolean retrieveAlreadyImported, boolean useTempTable) throws Exception {
String originalTableName = "mtb_aart_bar_code";
String tableName = originalTableName + (useTempTable ? "_tmp" : "");
if (useTempTable) {
UtilityDB.executeStatement(connection,
"INSERT INTO " + tableName +
" SELECT * FROM " + originalTableName
);
}
return exchangeImportDataManagerService.retrieveDataFromExchange(connection, MtbAartBarCode.class,
tableName, null, retrieveAlreadyImported);
}
private List<MtbAartCarat> retrieveMtbAartCarat(Connection connection, boolean retrieveAlreadyImported, boolean useTempTable) throws Exception {
String originalTableName = "mtb_aart_carat";
String tableName = originalTableName + (useTempTable ? "_tmp" : "");
if (useTempTable) {
UtilityDB.executeStatement(connection,
"INSERT INTO " + tableName +
" SELECT * FROM " + originalTableName
);
}
return exchangeImportDataManagerService.retrieveDataFromExchange(connection, MtbAartCarat.class,
tableName, null, retrieveAlreadyImported);
}
} }

View File

@@ -105,6 +105,8 @@ public class ExchangeImportSchemaManagerService {
put("mtb_aart_slinea", MtbAartSlinea.class); put("mtb_aart_slinea", MtbAartSlinea.class);
put("mtb_aart_sslinea", MtbAartSslinea.class); put("mtb_aart_sslinea", MtbAartSslinea.class);
put("mtb_aart_colori", MtbAartColori.class); put("mtb_aart_colori", MtbAartColori.class);
put("mtb_aart_bar_code", MtbAartBarCode.class);
put("mtb_aart_carat", MtbAartCarat.class);
}}); }});
put(SchemaType.PartiteMagazzinoLavorazione, new HashMap<String, Class<? extends EntityInterface>>() {{ put(SchemaType.PartiteMagazzinoLavorazione, new HashMap<String, Class<? extends EntityInterface>>() {{
put("mtb_partita_mag_lav", MtbPartitaMag.class); put("mtb_partita_mag_lav", MtbPartitaMag.class);