Skip to content

Commit

Permalink
fusione titoli: inserito diagnostico in caso di legami attivi a titol…
Browse files Browse the repository at this point in the history
…o cancellati.
  • Loading branch information
IstitutoCentraleCatalogoUnicoBiblio committed Aug 27, 2021
1 parent 5f4448b commit ba73026
Show file tree
Hide file tree
Showing 5 changed files with 27 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -96,13 +96,14 @@ public List<Tb_titolo> selectEsistenzaId(HashMap opzioni)
}
}
public Session abilitaRicercaLocalizzazioni(Session session){
/*
Filter filter = session.enableFilter("TB_TITOLO_LOCALIZZAZIONI");
//chiaamo il profiler per leggere il polo
//TODO: INSERIRE LA CHIAMATA AL PROFILER sigla = validator.getCodicePolo();
String PoloBib = ResourceLoader.getPropertyString("SIGLA_INDICE");
filter.setParameter("XXXcd_polo",PoloBib);
filter.setParameter("XXXcd_biblioteca"," FI");

*/
return session;
}
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -530,7 +530,11 @@ protected void fonde(Tb_titolo tit, String user, TimestampHash timeHash)

ttDB.updateCancella(user, tt.getBID_BASE(), fonde.getIdPartenza());
//Devo settare i flag di allineamento del titolo con bid tt.getBid_base()
AllineamentoTitolo allineamentoTitolo = new AllineamentoTitolo(new Titolo().estraiTitoloPerID(tt.getBID_BASE()));
final Tb_titolo titoloBase = new Titolo().estraiTitoloPerID(tt.getBID_BASE());
if (titoloBase == null) {
throw new EccezioneSbnDiagnostico(3233, "Esiste un legame attivo al titolo cancellato (" + tt.getBID_BASE() + ")");
}
AllineamentoTitolo allineamentoTitolo = new AllineamentoTitolo(titoloBase);
allineamentoTitolo.setTr_tit_tit(true);
TitoloGestisceAllineamento titoloG = new TitoloGestisceAllineamento();
titoloG.aggiornaFlagAllineamento(allineamentoTitolo, user);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ License Type: Evaluation
<property name="TS_CONDIVISO" column="TS_CONDIVISO" type="timestamp" not-null="true"/>
<property name="CD_PERIODICITA" column="CD_PERIODICITA" type="it.finsiel.sbn.util.DataTypeCHAR" length="1" not-null="false"/>

<set name="TR_TIT_BIB" lazy="false" inverse="true">
<set name="TR_TIT_BIB" lazy="true" inverse="true">
<key column="BID" not-null="true"/>
<one-to-many class="it.finsiel.sbn.polo.orm.Tr_tit_bib" />
<filter name="TB_TITOLO_LOCALIZZAZIONI" condition="fl_canc !='S' AND cd_biblioteca = :XXXcd_biblioteca AND cd_polo = :XXXcd_polo"/>
Expand Down
4 changes: 2 additions & 2 deletions SbnWebCommon/src/vo/it/iccu/sbn/util/config/sbnweb.conf
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,9 @@ SBNMARC_INDICE_PROXY_USERNAME=\u0020
SBNMARC_INDICE_PROXY_PASSWORD=\u0020

#timeout connessione
HTTP_CONNECTION_TIMEOUT=15000
HTTP_CONNECTION_TIMEOUT=5000
HTTP_REQUEST_TIMEOUT=900000
HTTP_NUMERO_TENTATIVI=3
HTTP_NUMERO_TENTATIVI=5

#timeout indice per allineamento (1 ora)
SBNMARC_INDICE_ALLINEA_REQUEST_TIMEOUT=3600000
Expand Down
29 changes: 17 additions & 12 deletions SbnWebDomainEjb/ejbModule/it/iccu/sbn/util/mail/MailSenderJob.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,31 +16,36 @@

public class MailSenderJob implements StatefulJob {

private static final long SEND_LOOP_WAIT = 250;
private static Logger log = Logger.getLogger(MailSenderJob.class);

public void execute(JobExecutionContext ctx) throws JobExecutionException {
try {
final Queue<MailVO> queue = MailUtil.sendQueue;
int send = 0;
if (queue.isEmpty()) {
final int pending = queue.size();
if (pending < 1) {
// non ci sono mail in coda
return;
}
final Session session = MailUtil.getSession();
final Transport transport = session.getTransport("smtp");
transport.connect();
MailVO mail;
while ((mail = queue.poll()) != null) {
log.debug("inizio invio mail: " + mail.summary());
try {
final MimeMessage msg = MailUtil.preparaMessage(mail, session);
msg.saveChanges();
transport.sendMessage(msg, msg.getAllRecipients() );
send++;
} catch (MessagingException e) {
log.error("errore invio mail: " + e.getMessage());
for (int cnt = 0; cnt < pending; cnt++) {
final MailVO mail = queue.poll();
if (mail != null) {
log.debug("inizio invio mail: " + mail.summary());
try {
final MimeMessage msg = MailUtil.preparaMessage(mail, session);
msg.saveChanges();
transport.sendMessage(msg, msg.getAllRecipients() );
send++;
} catch (MessagingException e) {
log.error("errore invio mail: " + e.getMessage());
}
log.debug("fine invio mail...");
Thread.sleep(SEND_LOOP_WAIT);
}
log.debug("fine invio mail...");
}
if (send > 0)
log.debug("mail inviate: " + send);
Expand Down

0 comments on commit ba73026

Please sign in to comment.