package com.megatim.apifdxweb.dao.impl.audit;
|
|
import com.megatim.apifdxweb.model.audit.AuditActionsParticipant;
|
import java.util.List;
|
import java.util.Optional;
|
import javax.ejb.Stateless;
|
import javax.persistence.EntityManager;
|
import javax.persistence.PersistenceContext;
|
import javax.persistence.Query;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Stateless
|
public class AuditActionsParticipantRepository {
|
|
@PersistenceContext(name = "fdxPU")
|
EntityManager em;
|
|
public Optional<AuditActionsParticipant> findByParticipantDemandeurAndTypeFichierConsulte(String connectedParticipant, String typeFichierConsulte) {
|
Query query = em.createQuery("SELECT a FROM AuditActionsParticipant a WHERE a.participantDemandeur = :participantDemandeur"
|
+ " AND a.typeFichierConsulte = :typeFichierConsulte");
|
|
query.setParameter("participantDemandeur", connectedParticipant);
|
query.setParameter("typeFichierConsulte", typeFichierConsulte);
|
|
List<AuditActionsParticipant> liste = (List<AuditActionsParticipant>) query.getResultList();
|
|
return liste.stream().findFirst();
|
}
|
|
public void save(AuditActionsParticipant auditActionsParticipant) {
|
em.persist(auditActionsParticipant);
|
}
|
|
public void update(AuditActionsParticipant auditActionsParticipant) {
|
em.merge(auditActionsParticipant);
|
}
|
|
public AuditActionsParticipant lastAudit(String codeParticipant, String codeTypeFichier) {
|
Optional<AuditActionsParticipant> optAudit = findByParticipantDemandeurAndTypeFichierConsulte(codeParticipant, codeTypeFichier);
|
if (optAudit.isPresent()) {
|
return optAudit.get();
|
} else {
|
return null;
|
}
|
}
|
|
}
|
