/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.apifdxweb.dao.impl.camel.historique;

import com.megatim.apifdxweb.model.camel.historique.ConsumedFilesHistory;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import com.megatim.apifdxweb.model.camel.historique.ConsumedFileType;
import java.util.List;
import java.util.Optional;
import com.megatim.apifdxweb.dao.ifaces.camel.historique.ConsumedFilesHistoryDAO;

/**
 *
 * @author ASUS
 */
@Stateless
public class ConsumedFilesHistoryDAOImpl implements ConsumedFilesHistoryDAO {

    @PersistenceContext(name = "fdxPU")
    EntityManager em;

    @Override
    public Class<ConsumedFilesHistory> getManagedEntityClass() {
        return ConsumedFilesHistory.class;
    }

    @Override
    public EntityManager getEntityManager() {
        return em;
    }

    @Override
    public ConsumedFilesHistory getById(Long id) {
        throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody
    }

    @Override
    public List<ConsumedFilesHistory> notDeleted() {
        return em.createQuery("SELECT cfh FROM ConsumedFilesHistory cfh where cfh.deletedInFolder = :param")
                .setParameter("param", false)
                .getResultList();
    }

    @Override
    public ConsumedFilesHistory findByTypeFileName(ConsumedFileType consumedFileType, String fileName) {
        Optional<ConsumedFilesHistory> optDonnee = em.createQuery("SELECT cfh FROM ConsumedFilesHistory cfh WHERE cfh.fileName = :fileName AND cfh.consumedFileType = :consumedFileType")
                .setParameter("fileName", fileName)
                .setParameter("consumedFileType", consumedFileType)
                .getResultList()
                .stream()
                .findFirst();

        return optDonnee.isPresent() ? optDonnee.get() : null;
    }
}