package com.megatim.fdxconsultation.dao.impl.referentiel;
|
|
import com.megatim.fdxcommons.model.referentiel.Referentiel;
|
import com.megatim.fdxcommons.model.referentiel.TypeFichier;
|
import com.megatim.fdxconsultation.dao.ifaces.referentiel.ReferentielDAO;
|
import com.megatim.fdxconsultation.dao.ifaces.referentiel.TypeFichierConsultationDAO;
|
import com.megatim.fdxconsultation.model.dto.ParticipantToFichierDto;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Optional;
|
import java.util.stream.Collectors;
|
import javax.ejb.Stateless;
|
import javax.inject.Inject;
|
import javax.persistence.EntityManager;
|
import javax.persistence.PersistenceContext;
|
import javax.persistence.Query;
|
import javax.persistence.Tuple;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Stateless
|
public class TypeFichierDAOImpl implements TypeFichierConsultationDAO {
|
|
@PersistenceContext(unitName = "fdxConsultationPersistenceUnit")
|
protected EntityManager em;
|
|
@Inject
|
private ReferentielDAO referentielDAO;
|
|
public TypeFichierDAOImpl() {
|
}
|
|
@Override
|
public EntityManager getEntityManager() {
|
return em;
|
}
|
|
@Override
|
public Class<TypeFichier> getManagedEntityClass() {
|
return (TypeFichier.class);
|
}
|
|
@Override
|
public TypeFichier getById(String id) {
|
Query query = em.createQuery("SELECT t from TypeFichier t"
|
+ " LEFT JOIN FETCH t.routages LEFT JOIN FETCH t.validateurFichiers "
|
+ " LEFT JOIN FETCH t.validateurFichierConfigurations"
|
+ " WHERE t.code = :code");
|
query.setParameter("code", id);
|
|
Optional<TypeFichier> optionalTypeFichier = query.getResultList().stream().findFirst();
|
return optionalTypeFichier.isPresent() ? optionalTypeFichier.get() : null;
|
}
|
|
@Override
|
public List<ParticipantToFichierDto> getParticpantToFichierDto(String username) {
|
String referentielVersion = getReferentielVersion();
|
if (referentielVersion == null) {
|
return new ArrayList<>();
|
}
|
|
List<Tuple> results = em.createQuery("SELECT t.participant.code, t.code AS code "
|
+ "FROM TypeFichier t "
|
+ "WHERE code IN (SELECT c.codeTypeFichier FROM ColumnDefinition c WHERE c.referentielVersion = :referentielVersion) "
|
+ "AND t IN (SELECT t1 FROM User u LEFT JOIN u.typeFichiers t1 WHERE u.userName = :username)", Tuple.class)
|
.setParameter("referentielVersion", referentielVersion)
|
.setParameter("username", username)
|
.getResultList();
|
|
return results.stream().map(t -> {
|
ParticipantToFichierDto dto = new ParticipantToFichierDto(t.get(0, String.class), t.get(1, String.class));
|
return dto;
|
}).collect(Collectors.toList());
|
}
|
|
private String getReferentielVersion() {
|
Referentiel refEncours = referentielDAO.getReferentielEnCours();
|
return refEncours != null ? refEncours.getVersion() : null;
|
}
|
}
|
