$re = '/(?s)(catch[^}]*?){(?:(?!\bthrow|new\b).)+?}/m';
$str = 'package fr.icdc.dei.aej.persistence.service.impl;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeSet;
import org.hibernate.Query;
import org.hibernate.QueryException;
import fr.icdc.dei.aej.metier.AejColonneTriConstant;
import fr.icdc.dei.aej.metier.AejConstant;
import fr.icdc.dei.aej.metier.comparator.InjonctionComparator;
import fr.icdc.dei.aej.metier.entite.lipti.EnTeteFlux;
import fr.icdc.dei.aej.metier.entite.lipti.FichierLIPTI;
import fr.icdc.dei.aej.metier.entite.lipti.InjonctionDePayer;
import fr.icdc.dei.aej.metier.entite.lipti.InjonctionDePayerClose;
import fr.icdc.dei.aej.metier.service.dto.ColonneNombreRenvoisCompetenceDTO;
import fr.icdc.dei.aej.metier.service.dto.ColonneNombreSaisinesDirectesDTO;
import fr.icdc.dei.aej.metier.service.dto.ComptageEnAttenteDecisionDTO;
import fr.icdc.dei.aej.metier.service.dto.InformationTriColonneDTO;
import fr.icdc.dei.aej.metier.service.dto.InformationsListePagineeDTO;
import fr.icdc.dei.aej.metier.service.dto.NombreAffairesParOrigineCreanceDTO;
import fr.icdc.dei.aej.metier.service.dto.NombreAffairesParTimbreDTO;
import fr.icdc.dei.aej.persistence.service.InjonctionDePayerPersistenceService;
import fr.icdc.dei.aej.persistence.util.AejPersistenceUtil;
import fr.icdc.dei.aej.state.StateConstants;
import fr.icdc.dei.fwk.business.exception.PersistenceServiceException;
import fr.icdc.dei.fwk.connection.impl.hibernate.HibernateConnection;
import fr.icdc.dei.fwk.transaction.TransactionException;
/**
* Injonction_de_Payer.<br>
* <!-- begin-user-doc --><br>
* <!-- end-user-doc -->
*
* @generated
*/
@SuppressWarnings("unchecked")
public final class InjonctionDePayerPersistenceServiceImpl
extends
AbstractAejPersistenceService
implements
InjonctionDePayerPersistenceService {
public InjonctionDePayer recupererIPParEnteteFlux(
final EnTeteFlux enteteFlux) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
InjonctionDePayer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("recupererIPParEnteteFlux");
query.setString("numRG", enteteFlux.getNumRG());
query.setString("siret", enteteFlux.getSiretTI());
query.setString("idAffaireHuissier", enteteFlux
.getIdAffaireHuissier());
final List<InjonctionDePayer> listInjonction = query.list();
if (listInjonction.size() > 0) {
result = listInjonction.iterator().next();
}
// end-user-code
return result;
} catch (final TransactionException e) {
PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Recupere une injonction close à partir de l\'en tete Flux en parametre
* @param enteteFlux
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayerClose recupererIPCloseParEnteteFlux(
final EnTeteFlux enteteFlux) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
InjonctionDePayerClose result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("recupererIPCloseParEnteteFlux");
query.setString("numRG", enteteFlux.getNumRG());
query.setString("siret", enteteFlux.getSiretTI());
query.setString("idAffaireHuissier", enteteFlux
.getIdAffaireHuissier());
final List<InjonctionDePayerClose> listInjonction = query.list();
if (listInjonction.size() > 0) {
result = listInjonction.iterator().next();
}
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Mot clef SQL / HQL WHERE
*/
private static final String WHERE = "WHERE";
/**
*
*/
public Integer compterInjonctionsParEtatEtParRegistrePourDecisionnaire(
final String identifiantDecisionnaire, final Integer registre,
final String siretJuridiction, final String etatDemande)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection
.getNamedQuery("compterInjonctionsParEtatEtParRegistrePourDecisionnaire");
if (registre != null) {
queryHibernate.setInteger("registre", registre);
}
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
queryHibernate.setString("etatDemande", etatDemande);
queryHibernate.setParameter("identifiantDecisionnaire",
identifiantDecisionnaire);
result = (Integer) queryHibernate.uniqueResult();
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
*/
public Integer compterInjonctionsParEtatEtParRegistre(
final Integer registre, final String siretJuridiction,
final String etatDemande) throws PersistenceServiceException {
Integer result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection
.getNamedQuery("compterInjonctionsParEtatEtParRegistre");
queryHibernate.setString("etatDemande", etatDemande);
if (registre != null) {
queryHibernate.setInteger("registre", registre);
}
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
result = (Integer) queryHibernate.uniqueResult();
return result;
// end-user-code
} catch (final QueryException e) {
throw new PersistenceServiceException(e);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
*/
public List<ComptageEnAttenteDecisionDTO> genererSyntheseEnAttenteDecision(
final String siretJuridiction) throws PersistenceServiceException {
List<ComptageEnAttenteDecisionDTO> result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection
.getNamedQuery("genererSyntheseEnAttenteDecision");
query.setString("etat", StateConstants.ETAT_ATTENTE_DECISION);
query.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
final List<Object[]> listeInter = query.list();
result = new ArrayList<ComptageEnAttenteDecisionDTO>();
for (final Object[] objects : listeInter) {
final ComptageEnAttenteDecisionDTO comptage =
new ComptageEnAttenteDecisionDTO();
if (objects[0] == null) {
comptage.setNomJuge("");
} else {
comptage.setNomJuge((String) objects[0]);
}
if (objects[1] == null) {
comptage.setPrenomJuge("");
} else {
comptage.setPrenomJuge((String) objects[1]);
}
if (objects[2] == null) {
comptage.setNombreAffaires(0);
} else {
comptage.setNombreAffaires((Integer) objects[2]);
}
result.add(comptage);
}
return result;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
*
*/
public java.util.List<InjonctionDePayer> listerDemandesParEtat(
final InformationsListePagineeDTO informationsListePaginee,
final Integer registre, final String siretJuridiction,
final String etatDemande) throws PersistenceServiceException {
java.util.List<InjonctionDePayer> result = null;
// begin-user-code
try {
Map<String, Object> parametres = getParametresEtatSiretRegistre(siretJuridiction, registre, etatDemande);
String namedQueryId = "listerIdDemandeParEtat";
String namedQuery = "listerDemandesParEtat";
String namedQuery3 = "listerDemandesParEtat3";
if (AejColonneTriConstant.DATE_TRANSMIS.equals(informationsListePaginee.getColonneTri())) {
result = getResultDateTransmis(informationsListePaginee, parametres, namedQueryId, namedQuery);
} else if (AejColonneTriConstant.SOMME.equals(informationsListePaginee.getColonneTri())) {
result = getResultSomme(informationsListePaginee, parametres,namedQueryId, namedQuery);
} else {
getColonneTriDecisionnaire(informationsListePaginee);
result = getListePaginee(namedQueryId, namedQuery3, parametres, informationsListePaginee);
}
} catch (TransactionException e) {
throw new PersistenceServiceException(e);
}
return result;
}
/**
* Recupere le resultat dans le cas des sommes
*
* @param informationsListePaginee
* informations sur la liste paginéee
* @param parametres
* les parametres a positionner
* @return le resultat
* @throws TransactionException
* @throws TransactionException
* exception transactionnelle
*/
private java.util.List<InjonctionDePayer> getResultSomme(
final InformationsListePagineeDTO informationsListePaginee,
final Map<String, Object> parametres, final String pQueryId,
final String pQuery) throws TransactionException {
java.util.List<InjonctionDePayer> result;
final HibernateConnection hConnection =
(HibernateConnection) getConnection();
final List<Integer> listId =
hConnection.findByNamedQuery(pQueryId, parametres);
final Query query = hConnection.getNamedQuery(pQuery);
query.setParameterList("listeId", listId);
result = query.list();
final Set<InjonctionDePayer> setTrie =
new TreeSet<InjonctionDePayer>(new InjonctionComparator(
AejColonneTriConstant.SOMME, informationsListePaginee
.getAscendant()));
setTrie.addAll(result);
result = new ArrayList<InjonctionDePayer>(setTrie);
return getPagination(informationsListePaginee, result);
}
/**
* Pagine la liste passé en parametre
*
* @param informationsListePaginee
* les informations concernant la liste paginé
* @param result
* la liste
* @return
*/
private java.util.List<InjonctionDePayer> getPagination(
final InformationsListePagineeDTO informationsListePaginee,
final List<InjonctionDePayer> result) {
final int fromIndex = informationsListePaginee.getStart();
int toIndex = informationsListePaginee.getNombre() + fromIndex;
if (toIndex > result.size()) {
toIndex = result.size();
}
return result.subList(fromIndex, toIndex);
}
/**
* Recupere la colonne a trier
* <ul>
* <li>injonction de payer : ip</li>
* <li>etats en cours : etatEnCours</li>
* <li>enregistre : enreg</li>
* </ul>
*
* @param colonneTriInfoPaginee
* le nom de la colonne a trié
* @return la colonne a trié + le nom de l\'objet sur lequel on trie
*/
private String getColonneTri(final String colonneTriInfoPaginee) {
final String colTri;
if (AejColonneTriConstant.NUM_RG.equals(colonneTriInfoPaginee)) {
colTri = "enreg." + AejColonneTriConstant.NUM_RG;
} else if (AejColonneTriConstant.DATE_SAISINE.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.DATE_SAISIE.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.FLUX_DEMAT.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.RENVOI_COMP.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.DATE_EXECUTOIRE.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.REQUETE.equals(colonneTriInfoPaginee)) {
colTri = "ip." + colonneTriInfoPaginee;
} else if (AejColonneTriConstant.JOURS_RESTANTS.equals(colonneTriInfoPaginee)) {
colTri = "ip.dateFinLegalDemandeExecutoire";
} else if (AejColonneTriConstant.SIMILARITE.equals(colonneTriInfoPaginee)) {
colTri = "similarites.id";
} else if (AejColonneTriConstant.DECISION.equals(colonneTriInfoPaginee)) {
colTri = "decision." + AejColonneTriConstant.DECISION;
} else if (AejColonneTriConstant.DATE_DECISION.equals(colonneTriInfoPaginee)) {
colTri = "decision." + AejColonneTriConstant.DATE_DECISION;
} else if (AejColonneTriConstant.DATE_DEMANDE.equals(colonneTriInfoPaginee)) {
colTri = "dpo." + AejColonneTriConstant.DATE_DEMANDE;
} else if (AejColonneTriConstant.NATURE_CREANCE.equals(colonneTriInfoPaginee)) {
colTri = "natureCreance." + AejColonneTriConstant.NATURE_CREANCE;
} else if (AejColonneTriConstant.DATE_TRANSMIS.equals(colonneTriInfoPaginee)) {
colTri = "etatsAttente." + AejColonneTriConstant.DATE_TRANSMIS;
} else if (AejColonneTriConstant.SUIVI_PAR.equals(colonneTriInfoPaginee)) {
colTri = "concat(substring(etatEnCours.utilisateur.prenom,1,1),substring(etatEnCours.utilisateur.nom,1,2))";
} else if (AejColonneTriConstant.MANDATAIRE.equals(colonneTriInfoPaginee)) {
colTri = "coalesce(mandaPP.nomDeFamille,mandaPM.denomination)";
} else if (AejColonneTriConstant.DEBITEUR.equals(colonneTriInfoPaginee)) {
colTri = "coalesce(debitPP.nomDeFamille,debitPM.denomination)";
} else if (AejColonneTriConstant.CREANCIER.equals(colonneTriInfoPaginee)) {
colTri = "coalesce(creancPP.nomDeFamille,creancPM.denomination)";
} else if (AejColonneTriConstant.DATE_SIGNIFICATION
.equals(colonneTriInfoPaginee)) {
colTri = "deb." + AejColonneTriConstant.DATE_SIGNIFICATION;
} else if (AejColonneTriConstant.HUISSIER_SIGNIFIANT.equals(colonneTriInfoPaginee)) {
colTri = "deb." + AejColonneTriConstant.HUISSIER_SIGNIFIANT;
} else if (AejColonneTriConstant.DATE_DEMANDE_PIECE.equals(colonneTriInfoPaginee)) {
colTri = "dpo.dateDemande";
} else if (AejColonneTriConstant.RETARD.equals(colonneTriInfoPaginee)) {
colTri = "dpo." + AejColonneTriConstant.RETARD;
} else if (AejColonneTriConstant.DATE_PIECE_ARRIVEE.equals(colonneTriInfoPaginee)) {
colTri = "dpo." + AejColonneTriConstant.DATE_PIECE_ARRIVEE;
} else if (AejColonneTriConstant.NUM_PORTALIS.equals(colonneTriInfoPaginee)) {
colTri = "enreg." + AejColonneTriConstant.NUM_PORTALIS;
}else {
colTri = "";
}
return colTri;
}
/**
* Renvoit la map de parametre contenant etat, siret et registre
*
* @param siretJuridiction
* @param registre
* @param etat
* @return
*/
private Map<String, Object> getParametresEtatSiretRegistre(
final String siretJuridiction, final Integer registre,
final String etat) {
final Map<String, Object> parametres = new HashMap<String, Object>();
parametres.put("registre", registre);
parametres.put(AejConstant.SIRET_JURIDICTION, siretJuridiction);
parametres.put("etat", etat);
return parametres;
}
/**
* Méthode retournant le resultat concernant une liste paginée
*
* @param <E>
* @param namedQueryId
* la query définit dans un hibernate qui remonte la liste des id
* @param namedQuery
* la query definit dans un hibernate qui remonte la liste des
* objets
* @param parametres
* une map de parametre ou la clef est le nom du parametre et la
* valeur la valeur du parametre
* @param colTri
* @param start
* @param nombre
* @param isTriFinal
* @return la liste d\'objet représentant la liste paginée
* @throws TransactionException
*/
private <E> List<E> getListePaginee(final String namedQueryId,
final String namedQuery, final Map<String, Object> parametres,
final InformationsListePagineeDTO informationsListePaginee,
final boolean isTriFinal) throws TransactionException {
final HibernateConnection hConnection = (HibernateConnection) getConnection();
final List<E> listeResult = AejPersistenceUtil.getListePaginee( hConnection,
namedQueryId,
namedQuery,
parametres,
informationsListePaginee,
isTriFinal);
// verification de la connexion
if (hConnection != null) {
// fermeture de la connexion
hConnection.silentClose();
}
return listeResult;
}
/**
*
* @param <E>
* @param queryId
* @param namedQuery
* @param parametres
* @param informationsListePaginee
* @param isTriFinal
* @return
* @throws TransactionException
*/
private <E> List<E> getListePaginee(final Query queryId,
final String namedQuery, final Map<String, Object> parametres,
final InformationsListePagineeDTO informationsListePaginee,
final boolean isTriFinal) throws TransactionException {
final HibernateConnection hConnection =
(HibernateConnection) getConnection();
final List<E> listeResult =
AejPersistenceUtil.getListePaginee(hConnection, queryId,
namedQuery, parametres, informationsListePaginee,
isTriFinal);
// verification de la connexion
if (hConnection != null) {
// fermeture de la connexion
hConnection.silentClose();
}
return listeResult;
}
/**
*
* @param <E>
* @param namedQueryId
* @param namedQuery
* @param parametres
* @param informationsListePaginee
* @return
* @throws TransactionException
*/
private <E> List<E> getListePaginee(final String namedQueryId,
final String namedQuery, final Map<String, Object> parametres,
final InformationsListePagineeDTO informationsListePaginee)
throws TransactionException {
return getListePaginee(namedQueryId, namedQuery, parametres,informationsListePaginee, true);
}
/**
* Retourne le resultat pour une date de transmission
*
* @param informationsListePaginee
* les informations sur la liste paginées
* @param parametres
* les parametres nommées
* @return le resultat pour une date de transmission
* @throws TransactionException
* exception transactionelle
*/
private java.util.List<InjonctionDePayer> getResultDateTransmis(
final InformationsListePagineeDTO informationsListePaginee,
final Map<String, Object> parametres, final String pRequeteId,
final String pRequete) throws TransactionException {
java.util.List<InjonctionDePayer> result;
final HibernateConnection hConnection =(HibernateConnection) getConnection();
getColonneTriDecisionnaire(informationsListePaginee);
final StringBuilder requeteId = new StringBuilder(hConnection.getNamedQuery(pRequeteId).getQueryString());
requeteId.insert(requeteId.indexOf(WHERE), " LEFT JOIN ip.etats etatsAttente ");
requeteId.append(" AND etatsAttente.etat = :etatAttente ");
final Query queryId = hConnection.createQuery(requeteId.toString());
parametres.put("etatAttente", StateConstants.ETAT_ATTENTE_DECISION);
result = getListePaginee(queryId, pRequete, parametres, informationsListePaginee, false);
final Set<InjonctionDePayer> setTrie =
new TreeSet<InjonctionDePayer>(new InjonctionComparator(
AejColonneTriConstant.DATE_TRANSMIS,
informationsListePaginee.getAscendant()));
setTrie.addAll(result);
result = new ArrayList<InjonctionDePayer>(setTrie);
return result;
}
/**
* Le parametre est modifié par cette méthode
*
* @param informationsListePaginee
* les informations concernant la pagination
*/
private void getColonneTriDecisionnaire(
final InformationsListePagineeDTO informationsListePaginee) {
final String colonneTri = informationsListePaginee.getColonneTri();
// Le décisionnaire oblige a faire un tri sur 2 colonnes, c\'est donc
// un cas particulier
if (AejColonneTriConstant.DECISIONNAIRE.equals(colonneTri)) {
final List<InformationTriColonneDTO> listInfoDTO = new ArrayList<InformationTriColonneDTO>();
listInfoDTO.add(new InformationTriColonneDTO("distrib.nom",informationsListePaginee.getAscendant()));
listInfoDTO.add(new InformationTriColonneDTO("distrib.prenom", informationsListePaginee.getAscendant()));
informationsListePaginee.setListeInformationsTriColonnes(listInfoDTO);
} else {
final String colTri = getColonneTri(colonneTri);
informationsListePaginee.setColonneTri(colTri);
}
}
/**
*
*/
public void creerInjonctionPayer(final InjonctionDePayer injonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
hConnection.create(injonctionPayer);
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* creerInjonctionPayerClose
* @param injonctionPayerClose
* @throws PersistenceServiceException
*/
public void creerInjonctionPayerClose(final InjonctionDePayerClose injonctionPayerClose)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
hConnection.create(injonctionPayerClose);
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
public void modifierInjonctionPayer(final InjonctionDePayer injonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
hConnection.update(injonctionPayer);
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
public void modifierInjonctionPayerClose(final InjonctionDePayerClose injonctionPayerClose)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
hConnection.update(injonctionPayerClose);
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
public void supprimer(final InjonctionDePayer injonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
hConnection.delete(injonctionPayer);
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Supprimer l\'IP active
* @param injonctionPayer
* @throws PersistenceServiceException
*/
public void supprimerIPActive(final InjonctionDePayer injonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection
.getNamedQuery("deleteInjonctionDePayerById");
query.setInteger("identifiantIP", injonctionPayer.getId());
query.executeUpdate();
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Supprimer l\'IP close
* @param injonctionPayerClose
* @throws PersistenceServiceException
*/
public void supprimerIPClose(final InjonctionDePayerClose injonctionPayerClose)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection
.getNamedQuery("deleteInjonctionDePayerCloseById");
query.setInteger("identifiantIP", injonctionPayerClose.getId());
query.executeUpdate();
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
public void supprimerIPCloseDemat(final InjonctionDePayerClose injonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection
.getNamedQuery("supprimerIPCloseEtPJ");
query.setInteger("identifiantIP", injonctionPayer.getId());
query.executeUpdate();
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
* @param idTechniqueInjonctionPayer
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererInjonctionParIdentifiant(final String idTechniqueInjonctionPayer)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
hConnection = (HibernateConnection) getConnection();
final Integer idInjonctionPayerInt =Integer.valueOf(idTechniqueInjonctionPayer);
return (InjonctionDePayer) hConnection.get(InjonctionDePayer.class, idInjonctionPayerInt);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
fermertureConnexion(hConnection);
}
}
/**
*
* @param idTechniqueInjonctionPayerClose
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayerClose recupererInjonctionCloseParIdentifiant(final String idTechniqueInjonctionPayerClose)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
hConnection = (HibernateConnection) getConnection();
final Integer idInjonctionPayerInt =Integer.valueOf(idTechniqueInjonctionPayerClose);
return (InjonctionDePayerClose) hConnection.get(InjonctionDePayerClose.class, idInjonctionPayerInt);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
fermertureConnexion(hConnection);
}
}
/**
*
*/
public java.util.List<NombreAffairesParOrigineCreanceDTO> recupererListeNombresAffairesRegroupeesParOrigineCreance(
final Date dateDebut, final Date dateFin, final String registre,
final String juridiction) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<NombreAffairesParOrigineCreanceDTO> result = null;
Map<String, NombreAffairesParOrigineCreanceDTO> map = new HashMap<String, NombreAffairesParOrigineCreanceDTO>();
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
new java.util.ArrayList<NombreAffairesParOrigineCreanceDTO>();
Query query =
hConnection
.getNamedQuery("recupererListeNombresAffairesRegroupeesParOrigineCreance");
// ajout des paramètres
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFin);
List<Object[]> listeObjets = query.list();
// ajout des résultats dans l\'objet retourné
for (final Object[] objet : listeObjets) {
final NombreAffairesParOrigineCreanceDTO dto =
new NombreAffairesParOrigineCreanceDTO();
dto.setNombre((Integer) objet[1]);
dto.setOrigineCreance((String) objet[0]);
//result.add(dto);
//ajout du dto dans la map
map.put(dto.getOrigineCreance(), dto);
}
/* recuperation des affaires clôturées avec les mêmes critères */
query =
hConnection
.getNamedQuery("recupererListeNombresAffairesClotureesRegroupeesParOrigineCreance");
// ajout des paramètres
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFin);
listeObjets = query.list();
// ajout des résultats dans l\'objet retourné
for (final Object[] objet : listeObjets) {
final NombreAffairesParOrigineCreanceDTO dto =
new NombreAffairesParOrigineCreanceDTO();
dto.setNombre((Integer) objet[1]);
dto.setOrigineCreance((String) objet[0]);
//si origine creance deja referencee sur ip ouverte => mise à jour du décompte et suppression de l\'ancien dto
if(map.get(dto.getOrigineCreance())!=null){
dto.setNombre(dto.getNombre() + ((NombreAffairesParOrigineCreanceDTO)map.get(dto.getOrigineCreance())).getNombre());
map.remove(dto.getOrigineCreance());
}
//ajout du dto dans la map
map.put(dto.getOrigineCreance(), dto);
}
result.addAll(map.values());
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* récupère la liste des affaire ouvertes avec timbre non nul et date d\'application dans la période regroupé par libellé de timbre
* @param dateDebut
* @param dateFin
* @param registre
* @param juridiction
* @return
* @throws PersistenceServiceException
*/
public java.util.List<NombreAffairesParTimbreDTO> recupererListeNombresAffairesOuvertesRegroupeesParTimbre(
final Date dateDebut, final Date dateFin, final String registre,
final String juridiction) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<NombreAffairesParTimbreDTO> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
new java.util.ArrayList<NombreAffairesParTimbreDTO>();
final Query query =
hConnection
.getNamedQuery("recupererListeNombresAffairesOuvertesRegroupeesParTimbre");
// ajout des paramètres
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFin);
//sélection des affaires ouvertes (non clôturées)
query.setString("etat", StateConstants.ETAT_CLOTUREE);
final List<Object[]> listeObjets = query.list();
// ajout des résultats de l\'objet retourné
for (final Object[] objet : listeObjets) {
final NombreAffairesParTimbreDTO dto = new NombreAffairesParTimbreDTO();
if(objet[1] instanceof Integer){
dto.setNombreIPEnCours((Integer) objet[1]);
} else if(objet[1] instanceof BigInteger){
dto.setNombreIPEnCours((Integer) ((BigInteger)objet[1]).intValue());
}
dto.setLibelleTimbre((String) objet[0]);
result.add(dto);
}
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* récupère la liste des affaire cloturees avec timbre non nul et date d\'application dans la période regroupé par libellé de timbre
* @param dateDebut
* @param dateFin
* @param registre
* @param juridiction
* @return
* @throws PersistenceServiceException
*/
public java.util.List<NombreAffairesParTimbreDTO> recupererListeNombresAffairesClotureesRegroupeesParTimbre(
final Date dateDebut, final Date dateFin, final String registre,
final String juridiction) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<NombreAffairesParTimbreDTO> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
new java.util.ArrayList<NombreAffairesParTimbreDTO>();
final Query query =
hConnection
.getNamedQuery("recupererListeNombresAffairesClotureesRegroupeesParTimbre");
// ajout des paramètres
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFin);
//sélection des affaires cloturées
query.setString("etat", StateConstants.ETAT_CLOTUREE);
final List<Object[]> listeObjets = query.list();
// ajout des résultats de l\'objet retourné
for (final Object[] objet : listeObjets) {
final NombreAffairesParTimbreDTO dto = new NombreAffairesParTimbreDTO();
if(objet[1] instanceof Integer){
dto.setNombreIPCloses((Integer) objet[1]);
} else if(objet[1] instanceof BigInteger){
dto.setNombreIPCloses((Integer) ((BigInteger)objet[1]).intValue());
}
dto.setLibelleTimbre((String) objet[0]);
result.add(dto);
}
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterAffairesEnOppositionPourDecisionsRendues(
final String registre, final Date dateDebut, final Date dateFin,
final String juridiction) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
// cette méthode récupère le nombre d \'affaires en opposition
// pour le registre sélectionné ayant au mois une date d\'opposition
// incluse
// dans la période choisie
final Query query =
hConnection
.getNamedQuery("compterAffairesEnOppositionPourDecisionsRendues");
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFin);
/* recuperation nombre d\'affaires en opposition dans les ip closes */
final Query queryClos =
hConnection
.getNamedQuery("compterAffairesEnOppositionPourDecisionsRenduesIPClose");
queryClos.setString("registre", registre);
queryClos.setString(AejConstant.SIRET_JURIDICTION, juridiction);
queryClos.setDate("dateDebut", dateDebut);
queryClos.setDate("dateFin", dateFin);
result = (Integer) query.uniqueResult() + (Integer) queryClos.uniqueResult();
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterAffairesEnRenvoiCompetence(final Date dateDebut,
final Date dateFin, final String juridiction)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
/*
* évol 21 il s\'agit du nombre d\'injonctions qui ont une date de
* renvoi de compétence dans la période registre 95 pour la
* juridiction
*/
final Query query =
hConnection
.getNamedQuery("compterAffairesEnRenvoiCompetence");
query.setString("registre", AejConstant.REG_95);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
// modification de la date de fin à passer à la persistance pour
// prendre en compte le dernier jour en entier
final Calendar cal = Calendar.getInstance();
cal.setTime(dateFin);
cal.add(Calendar.DAY_OF_MONTH, 1);
final Date dateFinPersistence = cal.getTime();
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFinPersistence);
/*
* recuperation du nombre d\'injonctions closes qui ont une date de
* renvoi de compétence dans la période registre 95 pour la
* juridiction
*/
final Query queryClos =
hConnection
.getNamedQuery("compterAffairesEnRenvoiCompetenceIPClose");
queryClos.setString("registre", AejConstant.REG_95);
queryClos.setString(AejConstant.SIRET_JURIDICTION, juridiction);
//sur la meme periode
queryClos.setDate("dateDebut", dateDebut);
queryClos.setDate("dateFin", dateFinPersistence);
result = (Integer) query.uniqueResult() + (Integer) queryClos.uniqueResult();
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public java.util.List<InjonctionDePayer> listerAffairesNouvelles(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayer> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
listerAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin,
StateConstants.ETAT_DEMANDE_A_DISTRIBUER, hConnection);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste des ip closes qui ont été distribuées pendant la période
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public java.util.List<InjonctionDePayerClose> listerAffairesNouvellesCloturees(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayerClose> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
listerAffairesClotureesPourStatistiques(registre, juridiction,
dateDebut, dateFin,
StateConstants.ETAT_DEMANDE_A_DISTRIBUER, hConnection);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterAffairesNouvelles(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =
compterAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin,
StateConstants.ETAT_DEMANDE_A_DISTRIBUER, hConnection);
// end-user-code
return (Integer) result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public java.util.List<InjonctionDePayer> listerOrdonnancesRendues(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayer> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("listerOrdonnancesRendues");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_DECISION_RENDUE);
final Set<InjonctionDePayer> injonctions =
new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
result = new ArrayList<InjonctionDePayer>(injonctions);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* liste des ip closes avec une decision rendue dans la période
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public java.util.List<InjonctionDePayerClose> listerOrdonnancesRenduesIPClose(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayerClose> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("listerOrdonnancesRenduesIPClose");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_DECISION_RENDUE);
final Set<InjonctionDePayerClose> injonctions =
new TreeSet<InjonctionDePayerClose>(comparateurIpCloseId);
injonctions.addAll(query.list());
result = new ArrayList<InjonctionDePayerClose>(injonctions);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterOrdonnancesRendues(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("compterOrdonnancesRendues");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_DECISION_RENDUE);
/* recuperation du nombre d\'ip closes avec decision rendue dans la periode */
Query queryClose =
hConnection.getNamedQuery("compterOrdonnancesRenduesIPCloses");
queryClose.setParameter("registre", new Integer(registre));
queryClose.setParameter("juridiction", juridiction);
queryClose.setParameter("dateDebut", dateDebut);
queryClose.setParameter("dateFin", dateFin);
queryClose.setParameter("etat", StateConstants.ETAT_DECISION_RENDUE);
result = (Integer) query.uniqueResult() + (Integer) queryClose.uniqueResult();
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* ip ouverte ayant eu une clôture pour motif opposition ou executoire pendant la periode
*/
public java.util.List<InjonctionDePayer> listerOppositionsEtExecutoires(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayer> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result = new LinkedList<InjonctionDePayer>();
result.addAll(listerAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_OPPOSITION, hConnection));
result.addAll(listerAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_DELIVRANCE_EXECUTOIRE, hConnection));
final Set<InjonctionDePayer> injonctions =
new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(result);
result = new ArrayList<InjonctionDePayer>(injonctions);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* ip cloturees avec motif opposition ou delivrance de l\'exécutoire pendant la periode
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public java.util.List<InjonctionDePayerClose> listerOppositionsEtExecutoiresIPClose(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayerClose> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result = new LinkedList<InjonctionDePayerClose>();
result.addAll(listerAffairesClotureesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_OPPOSITION, hConnection));
result.addAll(listerAffairesClotureesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_DELIVRANCE_EXECUTOIRE, hConnection));
final Set<InjonctionDePayerClose> injonctions =
new TreeSet<InjonctionDePayerClose>(comparateurIpCloseId);
injonctions.addAll(result);
result = new ArrayList<InjonctionDePayerClose>(injonctions);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterAffairesEnOpposition(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result = compterAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_OPPOSITION, hConnection) +
compterAffairesClotureesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_OPPOSITION, hConnection);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public Integer compterAffairesEnExecutoire(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
Integer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result =compterAffairesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_DELIVRANCE_EXECUTOIRE,
hConnection) +
compterAffairesClotureesPourStatistiques(registre, juridiction,
dateDebut, dateFin, StateConstants.ETAT_CLOTUREE,
AejConstant.MOTIF_DELIVRANCE_EXECUTOIRE,
hConnection);
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public java.util.List<InjonctionDePayer> recupererListeInjonctionsParListeIdTechniques(
final java.util.List<String> listeIdTechniques)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<InjonctionDePayer> result = new ArrayList<InjonctionDePayer>();
// begin-user-code
hConnection = (HibernateConnection) getConnection();
if (listeIdTechniques != null && listeIdTechniques.size() > 0) {
Query query = hConnection.getNamedQuery("recupererListeInjonctionsParListeIdTechniques");
List<Integer> listeId = new ArrayList<Integer>();
for (String string : listeIdTechniques) {
listeId.add(Integer.valueOf(string));
}
query.setParameterList("listeId", listeId);
result.addAll(query.list());
}
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
public java.util.List<ColonneNombreSaisinesDirectesDTO> recupererCompteursDecisionsSaisinesDirectes(
final Date dateFin, final Date dateDebut, final String registre,
final Integer idQualiteDecisionnaire, final String juridiction)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<ColonneNombreSaisinesDirectesDTO> result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result = new java.util.ArrayList<ColonneNombreSaisinesDirectesDTO>();
Map<String, ColonneNombreSaisinesDirectesDTO> map = new HashMap<String, ColonneNombreSaisinesDirectesDTO>();
/*
* On construit la requete dynamiquement comme on a 2 cas à traiter
* : -registre 21 : on remonte les injonctions qui ont un boolean
* renvoiCompetence null ou false ; - registre 95 : on ne regarde
* pas ce boolean
*/
StringBuffer queryString = new StringBuffer();
queryString.append("SELECT typeDecision.libelle, count(distinct ip.id) ");
queryString.append("FROM InjonctionDePayer ip ");
queryString.append("LEFT JOIN ip.enregistres enreg ");
queryString.append("LEFT JOIN enreg.registre registre ");
queryString.append("LEFT JOIN registre.juridiction juridiction ");
queryString.append("LEFT JOIN ip.decision as decision ");
queryString.append("LEFT JOIN decision.typeDecision as typeDecision ");
queryString.append("LEFT JOIN ip.distribuerA as utilisateur ");
queryString.append("LEFT JOIN utilisateur.roles as roles ");
queryString.append("LEFT JOIN roles.qualite as qualite ");
queryString.append("LEFT JOIN roles.application as appli ");
/*
* on récupère les ip dans le registre sélectionné et la juridiction
*/
queryString.append(" WHERE registre.registre = :registre ");
queryString.append(" AND juridiction.juridictionSIRET = :siretJuridiction ");
/*
* la date de décision doit être comprise dans la période choisie
*/
queryString.append("AND decision.dateDecision >= :dateDebut AND decision.dateDecision < :dateFin ");
/*
* on récupère les injonctions pour la qualite de décisionnaire
* choisie pour l\'application injonction de payer
*/
queryString.append("AND appli.id = 1 ");
queryString.append("AND qualite.id = :idHab ");
queryString.append("AND roles.juridiction = :siretJuridiction ");
/*
* si on est dans le registre 21 on observe le boolean renvoi de
* compétence
*/
if (AejConstant.REG_21.equals(registre)) {
queryString.append("AND (ip.renvoiCompetence IS NULL ");
queryString.append("OR ip.renvoiCompetence = :isRenvoi )");
}
/*
* groupage selon le libelle du type de decision
*/
queryString.append("GROUP BY typeDecision.libelle ");
Query query = hConnection.createQuery(queryString.toString());
/* ajout des paramètres à la requete */
final Calendar cal = Calendar.getInstance();
cal.setTime(dateFin);
cal.add(Calendar.DAY_OF_MONTH, 1);
final Date dateFinPersistance = cal.getTime();
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFinPersistance);
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setInteger("idHab", idQualiteDecisionnaire);
if (AejConstant.REG_21.equals(registre)) {
query.setBoolean("isRenvoi", false);
}
List<Object[]> listeObjetsRemontes = query.list();
for (final Object[] objet : listeObjetsRemontes) {
final ColonneNombreSaisinesDirectesDTO dto =
new ColonneNombreSaisinesDirectesDTO();
dto.setLibelleTypeDecision((String) objet[0]);
dto.setNombreSaisinesDirectes((Integer) objet[1]);
//result.add(dto);
//ajout du dto une map
map.put(dto.getLibelleTypeDecision(), dto);
}
/* recuperation des decisions sur les injonctions closes pendant la periode */
queryString = new StringBuffer();
queryString.append("SELECT typeDecision.libelle, count(distinct ip.id) ");
queryString.append("FROM InjonctionDePayerClose ip ");
queryString.append("LEFT JOIN ip.enregistres enreg ");
queryString.append("LEFT JOIN enreg.registre registre ");
queryString.append("LEFT JOIN registre.juridiction juridiction ");
queryString.append("LEFT JOIN ip.decision as decision ");
queryString.append("LEFT JOIN decision.typeDecision as typeDecision ");
queryString.append("LEFT JOIN ip.distribuerA as utilisateur ");
queryString.append("LEFT JOIN utilisateur.roles as roles ");
queryString.append("LEFT JOIN roles.qualite as qualite ");
queryString.append("LEFT JOIN roles.application as appli ");
/*
* on récupère les ip dans le registre sélectionné et la juridiction
*/
queryString.append(" WHERE registre.registre = :registre ");
queryString.append(" AND juridiction.juridictionSIRET = :siretJuridiction ");
/*
* la date de décision doit être comprise dans la période choisie
*/
queryString.append("AND decision.dateDecision >= :dateDebut AND decision.dateDecision < :dateFin ");
/*
* on récupère les injonctions pour la qualite de décisionnaire
* choisie pour l\'application injonction de payer
*/
queryString.append("AND appli.id = 1 ");
queryString.append("AND qualite.id = :idHab ");
queryString.append("AND roles.juridiction = :siretJuridiction ");
/*
* si on est dans le registre 21 on observe le boolean renvoi de
* compétence
*/
if (AejConstant.REG_21.equals(registre)) {
queryString.append("AND (ip.renvoiCompetence IS NULL ");
queryString.append("OR ip.renvoiCompetence = :isRenvoi )");
}
/*
* groupage selon le libelle du type de decision
*/
queryString.append("GROUP BY typeDecision.libelle ");
query = hConnection.createQuery(queryString.toString());
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFinPersistance);
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setInteger("idHab", idQualiteDecisionnaire);
if (AejConstant.REG_21.equals(registre)) {
query.setBoolean("isRenvoi", false);
}
listeObjetsRemontes = query.list();
for (final Object[] objet : listeObjetsRemontes) {
final ColonneNombreSaisinesDirectesDTO dto =
new ColonneNombreSaisinesDirectesDTO();
dto.setLibelleTypeDecision((String) objet[0]);
dto.setNombreSaisinesDirectes((Integer) objet[1]);
//si decision referencee au niveau des decisions sur ip ouverte => maj du nombre
if(map.get(dto.getLibelleTypeDecision()) != null){
dto.setNombreSaisinesDirectes(dto.getNombreSaisinesDirectes() +
((ColonneNombreSaisinesDirectesDTO)map.get(dto.getLibelleTypeDecision())).getNombreSaisinesDirectes());
//suppression de l\'element déjà présent puis mis à jour avec le nouveau décompte
map.remove(dto.getLibelleTypeDecision());
}
map.put(dto.getLibelleTypeDecision(), dto);
}
result.addAll(map.values());
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
*/
@SuppressWarnings("static-access")
public java.util.List<ColonneNombreRenvoisCompetenceDTO> recupererCompteursDecisionsRenvoisCompetence(
final Date dateFin, final Date dateDebut, final String registre,
final Integer idQualiteDecisionnaire, final String juridiction)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
java.util.List<ColonneNombreRenvoisCompetenceDTO> result = null;
Map<String, ColonneNombreRenvoisCompetenceDTO> map = new HashMap<String, ColonneNombreRenvoisCompetenceDTO>();
// begin-user-code
hConnection = (HibernateConnection) getConnection();
result = new java.util.ArrayList<ColonneNombreRenvoisCompetenceDTO>();
Query query = hConnection.getNamedQuery("recupererCompteursDecisionRenvois");
/* ajout des paramètres à la requete */
final Calendar cal = Calendar.getInstance();
cal.setTime(dateFin);
cal.add(cal.DAY_OF_MONTH, 1);
final Date dateFinPersistance = cal.getTime();
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFinPersistance);
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setInteger("idHab", idQualiteDecisionnaire);
query.setBoolean("isRenvoi", true);
final List<Object[]> listeObjetsRemontes = query.list();
for (final Object[] objet : listeObjetsRemontes)
{
final ColonneNombreRenvoisCompetenceDTO dto = new ColonneNombreRenvoisCompetenceDTO();
dto.setLibelleTypeDecision((String) objet[0]);
dto.setNombreRenvoisCompetence((Integer) objet[1]);
//result.add(dto);
//ajout dans la map
map.put(dto.getLibelleTypeDecision(), dto);
}
/* recuperation des renvois sur ip close pendant la meme periode */
query = hConnection.getNamedQuery("recupererCompteursDecisionRenvoisIPClose");
/* ajout des paramètres à la requete */
query.setDate("dateDebut", dateDebut);
query.setDate("dateFin", dateFinPersistance);
query.setString("registre", registre);
query.setString(AejConstant.SIRET_JURIDICTION, juridiction);
query.setInteger("idHab", idQualiteDecisionnaire);
query.setBoolean("isRenvoi", true);
final List<Object[]> listeObjetsRemontesClos = query.list();
for (final Object[] objet : listeObjetsRemontesClos)
{
final ColonneNombreRenvoisCompetenceDTO dto = new ColonneNombreRenvoisCompetenceDTO();
dto.setLibelleTypeDecision((String) objet[0]);
dto.setNombreRenvoisCompetence((Integer) objet[1]);
//si decision deja presente dans les ip ouverte => mise à jour du décompte + suppression de l\'ancien objet
if(map.get(dto.getLibelleTypeDecision()) != null){
dto.setNombreRenvoisCompetence(dto.getNombreRenvoisCompetence() +
((ColonneNombreRenvoisCompetenceDTO) map.get(dto.getLibelleTypeDecision())).getNombreRenvoisCompetence());
map.remove(dto.getLibelleTypeDecision());
}
//ajout dans la map
map.put(dto.getLibelleTypeDecision(), dto);
}
result.addAll(map.values());
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
*/
public List<InjonctionDePayer> listerDemandesParEtatPourDecisionnaire(
final String identifiantDecisionnaire,
final InformationsListePagineeDTO informationsListePaginee,
final Integer registre, final String siretJuridiction,
final String etatDemande) throws PersistenceServiceException {
java.util.List<InjonctionDePayer> result = null;
// begin-user-code
try {
final Map<String, Object> parametres = getParametresEtatSiretRegistre(siretJuridiction, registre, etatDemande);
parametres.put("identifiantDecisionnaire", identifiantDecisionnaire);
final String requeteId = "listerIdDemandesParEtatPourDecisionnaire";
final String requete = "listerDemandesParEtat";
if (AejColonneTriConstant.DATE_TRANSMIS.equals(informationsListePaginee.getColonneTri())) {
result = getResultDateTransmis(informationsListePaginee, parametres, requeteId, requete);
} else if (AejColonneTriConstant.SOMME.equals(informationsListePaginee.getColonneTri())) {
result = getResultSomme(informationsListePaginee, parametres, requeteId, requete);
} else {
getColonneTriDecisionnaire(informationsListePaginee);
result = getListePaginee(requeteId, requete, parametres,informationsListePaginee);
}
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
}
return result;
// end-user-code
}
private final Comparator<InjonctionDePayer> comparateurIpId =
new Comparator<InjonctionDePayer>() {
public int compare(final InjonctionDePayer o1,
final InjonctionDePayer o2) {
if (o1.getId() == null) {
return -1;
}
if (o2.getId() == null) {
return +1;
}
return o1.getId().compareTo(o2.getId());
}
};
private final Comparator<InjonctionDePayerClose> comparateurIpCloseId = new Comparator<InjonctionDePayerClose>() {
public int compare(final InjonctionDePayerClose o1,
final InjonctionDePayerClose o2) {
if (o1.getId() == null) {
return -1;
}
if (o2.getId() == null) {
return +1;
}
return o1.getId().compareTo(o2.getId());
}
};
private Integer compterAffairesPourStatistiques(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin,
final String etat, final HibernateConnection hConnection)
throws TransactionException {
final Query query =
hConnection.getNamedQuery("compterAffairesPourStatistiques");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Query queryClos =
hConnection.getNamedQuery("compterAffairesClotureesPourStatistiques");
queryClos.setParameter("registre", Integer.valueOf(registre));
queryClos.setParameter("juridiction", juridiction);
queryClos.setParameter("dateDebut", dateDebut);
queryClos.setParameter("dateFin", dateFin);
queryClos.setParameter("etat", etat);
return (Integer) query.uniqueResult() + (Integer) queryClos.uniqueResult();
}
private List<InjonctionDePayer> listerAffairesPourStatistiques(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin, final String etat,
final HibernateConnection hConnection) throws TransactionException {
final Query query =
hConnection.getNamedQuery("listerAffairesPourStatistiques");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Set<InjonctionDePayer> injonctions =
new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
}
private List<InjonctionDePayerClose> listerAffairesClotureesPourStatistiques(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin, final String etat,
final HibernateConnection hConnection) throws TransactionException {
final Query query =
hConnection.getNamedQuery("listerAffairesClotureesPourStatistiques");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Set<InjonctionDePayerClose> injonctions =
new TreeSet<InjonctionDePayerClose>(comparateurIpCloseId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayerClose>(injonctions);
}
private Integer compterAffairesPourStatistiques(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin,
final String etat, final String motif,
final HibernateConnection hConnection) throws TransactionException {
final Query query =
hConnection
.getNamedQuery("compterAffairesPourStatistiquesAvecMotif");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
query.setParameter("motif", motif);
return (Integer) query.uniqueResult();
}
private Integer compterAffairesClotureesPourStatistiques(final String registre,
final String juridiction, final Date dateDebut, final Date dateFin,
final String etat, final String motif,
final HibernateConnection hConnection) throws TransactionException {
final Query query =
hConnection
.getNamedQuery("compterAffairesClotureesPourStatistiquesAvecMotif");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
query.setParameter("motif", motif);
return (Integer) query.uniqueResult();
}
/**
*
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @param etat
* @param motif
* @param hConnection
* @return
* @throws TransactionException
*/
private List<InjonctionDePayer> listerAffairesPourStatistiques(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin, final String etat,
final String motif, final HibernateConnection hConnection)
throws TransactionException {
final Query query = hConnection.getNamedQuery("listerAffairesPourStatistiquesAvecMotif");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
query.setParameter("motif", motif);
final Set<InjonctionDePayer> injonctions =new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
}
/**
*
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @param etat
* @param motif
* @param hConnection
* @return
* @throws TransactionException
*/
private List<InjonctionDePayerClose> listerAffairesClotureesPourStatistiques(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin, final String etat,
final String motif, final HibernateConnection hConnection)
throws TransactionException {
final Query query = hConnection.getNamedQuery("listerAffairesClotureesPourStatistiquesAvecMotif");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
query.setParameter("motif", motif);
final Set<InjonctionDePayerClose> injonctions =new TreeSet<InjonctionDePayerClose>(comparateurIpCloseId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayerClose>(injonctions);
}
/**
* Retourne le nombre d\'IP clôturées pendant la période dateDebut dateFin avec un timbre renseigné
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public Integer compterInjonctionAvecTimbre(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
//recuperation des ip ouvertes qui ont été cloturées pendant la période (puis décloturées)
final Query query = hConnection.getNamedQuery("compterAffairesPourStatistiquesAvecTimbre");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_CLOTUREE);
//recuperation du nombre d\'ip cloturees pendant la periode avec timbre
final Query queryClos = hConnection.getNamedQuery("compterAffairesClotureesPourStatistiquesAvecTimbre");
queryClos.setParameter("registre", new Integer(registre));
queryClos.setParameter("juridiction", "%" + juridiction);
queryClos.setParameter("dateDebut", dateDebut);
queryClos.setParameter("dateFin", dateFin);
queryClos.setParameter("etat", StateConstants.ETAT_CLOTUREE);
return (Integer) query.uniqueResult() + (Integer) queryClos.uniqueResult();
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerInjonctionAvecTimbre(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerAffairesPourStatistiquesAvecTimbre");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_CLOTUREE);
final Set<InjonctionDePayer> injonctions =new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* liste des affaires cloturees pendant la période avec un timbre fiscal
* @param registre
* @param juridiction
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayerClose> listerInjonctionCloseAvecTimbre(
final String registre, final String juridiction,
final Date dateDebut, final Date dateFin)
throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerAffairesClotureesPourStatistiquesAvecTimbre");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("juridiction", "%" + juridiction);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", StateConstants.ETAT_CLOTUREE);
final Set<InjonctionDePayerClose> injonctions =new TreeSet<InjonctionDePayerClose>(comparateurIpCloseId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayerClose>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/**
* @author ydjouambi-e
*
* Cette méthode permet de récuperer les listes paginés <br>
* En attente de decision <br>
*
* @param idTechniqueInjonctionPayer
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererDetailIPListesDecisionEnAttente(final String idTechniqueInjonctionPayer)
throws PersistenceServiceException {
InjonctionDePayer ip = null;
HibernateConnection hConnection = null;
try {
hConnection = (HibernateConnection) getConnection();
final Integer idInjonctionPayerInt = Integer.valueOf(idTechniqueInjonctionPayer);
Query query = hConnection.getNamedQuery("recupererDetailIPayer");
query.setParameter("idInjonctionPayer", idInjonctionPayerInt);
ip = (InjonctionDePayer) query.uniqueResult();
return ip;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
*
* @author ydjouambi-e
*
* Cette méthode permet de récuperer les listes paginés <br>
* par registre, juridiction et état :<br>
* En cours de saisie ou a distribuer<br>
*
* @param informationsListePaginee
* @param registre
* @param siretJuridiction
* @param isTri
* @return
* @throws PersistenceServiceException
*
*/
public List<InjonctionDePayer> listerDemandesEnCoursSaisiOuADistribuer( InformationsListePagineeDTO informationsListePaginee,
Integer registre, String siretJuridiction, String etatDemande,
Boolean isTri)throws PersistenceServiceException {
List<InjonctionDePayer> result = null;
try {
final HibernateConnection hConnection = (HibernateConnection) getConnection();
String ColTri = informationsListePaginee.getColonneTri();
Map<String, Object> parametres = getParametresEtatSiretRegistre(siretJuridiction, registre, etatDemande);
String namedQueryId = "listerIDIPParEtatJuridictionRegistre";
String namedQuery = "listerDemandesEnCoursSaisiOuADistribuer";
if(!isTri){
getColonneTriDecisionnaire(informationsListePaginee);
}
result = AejPersistenceUtil
.recupererResultatListePaginee(hConnection, namedQueryId, namedQuery, parametres, informationsListePaginee, ColTri,true);
} catch (TransactionException e) {
throw new PersistenceServiceException(e);
}
return result;
}
/**
*
* @author ydjouambi-e
*
* Cette méthode permet de récuperer les listes paginés <br>
* par registre, juridiction :<br>
* des executoires en retard ou en attente <br>
*
* @param informationsListePaginee
* @param registre
* @param siretJuridiction
* @param isTri
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerExecutoires(String namedQueryId, String namedQuery,
InformationsListePagineeDTO informationsListePaginee,
Integer registre, String siretJuridiction, Boolean isTri)
throws PersistenceServiceException {
java.util.List<InjonctionDePayer> result = null;
try {
final HibernateConnection hConnection = (HibernateConnection) getConnection();
final Map<String, Object> parametres = getParametresEtatSiretRegistre(siretJuridiction, registre, StateConstants.ETAT_DECISION_RENDUE);
if(!isTri){
getColonneTriDecisionnaire(informationsListePaginee);
}
result = AejPersistenceUtil
.recupererResultatListeExecutoire(hConnection, namedQueryId, namedQuery, parametres, informationsListePaginee ,true);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
}
return result;
}
/**
* Recuperer l\'IP à laquelle est associée à un fichier
* @param pj
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererIPParPieceJointe(
final FichierLIPTI pj) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
InjonctionDePayer result = null;
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query =
hConnection.getNamedQuery("recupererIPParPieceJointe");
query.setString("idPJ", String.valueOf(pj.getId()));
final List<InjonctionDePayer> listInjonction = query.list();
if (listInjonction.size() > 0) {
result = listInjonction.iterator().next();
}
// end-user-code
return result;
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Récupérer une IP à partir de la decision
* @param idDecision
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererInjonctionParDecision(final Integer idDecision)
throws PersistenceServiceException {
InjonctionDePayer ip = null;
HibernateConnection hConnection = null;
try {
hConnection = (HibernateConnection) getConnection();
Query query = hConnection.getNamedQuery("recupererInjonctionParDecision");
query.setParameter("idDecision", idDecision);
ip = (InjonctionDePayer) query.uniqueResult();
return ip;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Recupere une injonction à partir de numRG, registre et juridiction
* @param registre
* @param siretJuridiction
* @param numeroRG
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererInjonctionParNumRG(final Integer registre,
final String siretJuridiction, final Integer numeroRG) throws PersistenceServiceException {
InjonctionDePayer result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection.getNamedQuery("recupererInjonctionParNumRG");
queryHibernate.setInteger("registre", registre);
queryHibernate.setInteger("numeroRG", numeroRG);
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
result = (InjonctionDePayer) queryHibernate.uniqueResult();
return result;
// end-user-code
} catch (final TransactionException e) {
new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Recupere une injonction à partir de numRG, registre, juridiction et arrondissement
* @param registre
* @param siretJuridiction
* @param numeroRG
* @param arrondissement
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayer recupererInjonctionParNumRGEtArrondissement(final Integer registre,
final String siretJuridiction, final Integer numeroRG, final String arrondissement) throws PersistenceServiceException {
InjonctionDePayer result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection.getNamedQuery("recupererInjonctionParNumRGEtArrondissement");
queryHibernate.setInteger("registre", registre);
queryHibernate.setInteger("numeroRG", numeroRG);
queryHibernate.setString("arrondissement", arrondissement);
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
result = (InjonctionDePayer) queryHibernate.uniqueResult();
return result;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Recupere une injonction close à partir de numRG, registre et juridiction
* @param registre
* @param siretJuridiction
* @param numeroRG
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayerClose recupererInjonctionCloseParNumRG(final Integer registre,
final String siretJuridiction, final Integer numeroRG) throws PersistenceServiceException {
InjonctionDePayerClose result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection.getNamedQuery("recupererInjonctionCloseParNumRG");
queryHibernate.setInteger("registre", registre);
queryHibernate.setInteger("numeroRG", numeroRG);
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
result = (InjonctionDePayerClose) queryHibernate.uniqueResult();
return result;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Recupere une injonction close à partir de numRG, registre, juridiction et arrondissement
* @param registre
* @param siretJuridiction
* @param numeroRG
* @param arrondissement
* @return
* @throws PersistenceServiceException
*/
public InjonctionDePayerClose recupererInjonctionCloseParNumRGEtArrondissement(final Integer registre,
final String siretJuridiction, final Integer numeroRG, final String arrondissement) throws PersistenceServiceException {
InjonctionDePayerClose result = null;
HibernateConnection hConnection = null;
// begin-user-code
try {
hConnection = (HibernateConnection) getConnection();
final Query queryHibernate =
hConnection.getNamedQuery("recupererInjonctionCloseParNumRGEtArrondissement");
queryHibernate.setInteger("registre", registre);
queryHibernate.setInteger("numeroRG", numeroRG);
queryHibernate.setString("arrondissement", arrondissement);
queryHibernate.setString(AejConstant.SIRET_JURIDICTION, siretJuridiction);
result = (InjonctionDePayerClose) queryHibernate.uniqueResult();
return result;
// end-user-code
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// verification de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste toutes les injonctions pour lesquelles il faut prévoir un message de relance de signification
* @param siret
* @param registre
* @param etat
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerInjonctionARelancerSignification(String siret,
Integer registre, String etat, Date dateDebut, Date dateFin ) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerInjonctionARelancerSignification");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("siret", siret);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Set<InjonctionDePayer> injonctions = new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste toutes les injonctions pour lesquelles il faut prévoir un message de relance d\'exécutoire
* @param siret
* @param registre
* @param etat
* @param dateDebut
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerInjonctionARelancerExecutoire(String siret,
Integer registre, String etat, Date dateDebut, Date dateFin ) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerInjonctionARelancerExecutoire");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("siret", siret);
query.setParameter("dateDebut", dateDebut);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Set<InjonctionDePayer> injonctions =new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste toutes les injonctions qui sont restées en Décision rendue alors qu\'une décision provoquant la clôture a été rendue
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerInjonctionDecisionRendueATort() throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerInjonctionDecisionRendueATort");
final Set<InjonctionDePayer> injonctions =new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste toutes les injonctions qui ont le statut cloturée et qui sont toujours avec les IPs ouvertes
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerIPsStatutClotureeTjrsOuvertes() throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerIPsStatutClotureeTjrsOuvertes");
final Set<InjonctionDePayer> injonctions =new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
/**
* Liste toutes les injonctions qu\'il faut clôturer pour désistement
* @param siret
* @param registre
* @param etat
* @param dateFin
* @return
* @throws PersistenceServiceException
*/
public List<InjonctionDePayer> listerInjonctionACloturerPourDesistement(String siret,
Integer registre, String etat, Date dateFin ) throws PersistenceServiceException {
HibernateConnection hConnection = null;
try {
// begin-user-code
hConnection = (HibernateConnection) getConnection();
final Query query = hConnection.getNamedQuery("listerInjonctionACloturerPourDesistement");
query.setParameter("registre", Integer.valueOf(registre));
query.setParameter("siret", siret);
query.setParameter("dateFin", dateFin);
query.setParameter("etat", etat);
final Set<InjonctionDePayer> injonctions = new TreeSet<InjonctionDePayer>(comparateurIpId);
injonctions.addAll(query.list());
return new ArrayList<InjonctionDePayer>(injonctions);
} catch (final TransactionException e) {
throw new PersistenceServiceException(e);
} finally {
// fermeture de la connexion
fermertureConnexion(hConnection);
}
}
}
';
preg_match_all($re, $str, $matches, PREG_SET_ORDER, 0);
// Print the entire match result
var_dump($matches);
Please keep in mind that these code samples are automatically generated and are not guaranteed to work. If you find any syntax errors, feel free to submit a bug report. For a full regex reference for PHP, please visit: http://php.net/manual/en/ref.pcre.php