package com.megatim.fdxconsultation.core.impl.api.supervision;

import com.bekosoftware.genericdaolayer.dao.ifaces.GenericDAO;
import com.bekosoftware.genericmanagerlayer.core.impl.AbstractGenericManager;
import com.fdx.messaging.common.TransfertDataMessage;
import com.megatim.fdxconsultation.core.ifaces.supervision.TransfertManager;
import com.megatim.fdxconsultation.dao.ifaces.abstracts.PaginationWithSearchEnityDAO;
import com.megatim.fdxconsultation.dao.ifaces.supervision.TransfertDAO;
import com.megatim.fdxconsultation.dao.impl.supervision.TransfertMessageKey;
import com.megatim.fdxconsultation.model.searchentities.TransfertSearch;
import com.megatim.fdxconsultation.model.supervision.SensTransfert;
import com.megatim.fdxconsultation.model.supervision.Transfert;
import com.megatim.fdxconsultation.model.supervision.dto.StandaloneDashboardRequest;
import com.megatim.fdxconsultation.model.supervision.dto.StandaloneDashboardResponse;
import com.megatim.fdxconsultation.model.supervision.dto.SupervisionFilterModalFormRequest;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.annotation.PostConstruct;
import javax.ejb.EJB;
import javax.enterprise.context.ApplicationScoped;

/**
 *
 * @author ASUS
 */
@ApplicationScoped
public class TransfertManagerImpl extends AbstractGenericManager<Transfert, Long> implements TransfertManager {

    @EJB
    private TransfertDAO dao;

    private final Map<String, Transfert> transfertMap = new ConcurrentHashMap<>();

    @PostConstruct
    public void init() {
        findAll().forEach(t -> {
            String key = new TransfertMessageKey(t).key();
            transfertMap.put(key, t);
        });
    }

    @Override
    public GenericDAO<Transfert, Long> getDao() {
        return dao;
    }

    @Override
    public PaginationWithSearchEnityDAO<Transfert, Long, TransfertSearch> getPaginationDao() {
        return dao;
    }

    @Override
    public String getEntityIdName() {
        return "id";
    }

    @Override
    public Transfert persistTransfert(Transfert t) {

        String key = new TransfertMessageKey(t).key();
        Transfert transfert = transfertMap.get(key);

        if (transfert == null) {

            transfertMap.put(key, save(t));

        } else if (!transfert.getEtatTransfert().equals(t.getEtatTransfert())) {

            setFields(transfert, t);
            transfertMap.put(key, update(transfert.getId(), transfert));

        }

        return transfertMap.get(key);
    }

    @Override
    public StandaloneDashboardResponse standaloneDashboardResponse(StandaloneDashboardRequest standaloneDashboardRequest) {

        LocalDateTime dateDebut = standaloneDashboardRequest.getDateDebut();
        LocalDateTime dateFin
                = (standaloneDashboardRequest.getDateFin() != null)
                ? standaloneDashboardRequest.getDateFin().toLocalDate().atTime(LocalTime.MAX)
                : null;
        SensTransfert sens = standaloneDashboardRequest.getSens();

        StandaloneDashboardResponse response = new StandaloneDashboardResponse();

        response.setNombreTypeFichier(dao.getNombreTypeFichier(sens, dateDebut, dateFin));
        response.setTailleTotale(dao.getTailleTotale(sens, dateDebut, dateFin));
        response.setTotalTransfert(dao.getTotalTransfert(sens, dateDebut, dateFin));
        response.setTotalTransfertAutomatique(dao.getTransfertsAutomatique(sens, dateDebut, dateFin));
        response.setTotalTransfertEchec(dao.getTransfertsEchec(sens, dateDebut, dateFin));
        response.setTotalTransfertManuel(dao.getTransfertsManuel(sens, dateDebut, dateFin));
        response.setTransfertAttente(dao.getTransfertsAttente(sens, dateDebut, dateFin));
        response.setTransfertReussie(dao.getTransfertsReussie(sens, dateDebut, dateFin));
        response.setVitesseMoyenne(dao.getVitesseMoyenne(sens, dateDebut, dateFin));

        if (response.getTotalTransfert() > 0) {
            response.setTailleMoyenne(response.getTailleTotale() / response.getTotalTransfert());
        } else {
            response.setTailleMoyenne(0);
        }

        return response;

    }

    @Override
    public List<Transfert> filter(SupervisionFilterModalFormRequest supervisionFilterModalFormRequest) {
        List<Transfert> transferts = dao.filter(supervisionFilterModalFormRequest);
        transferts.sort((t1, t2) -> Long.compare(t2.getId(), t1.getId()));
        return transferts;
    }

    private void setFields(Transfert transfert, Transfert t) {

        transfert.setCodeAgent(t.getCodeAgent());
        transfert.setCodeAgentRecepteur(t.getCodeAgentRecepteur());
        transfert.setEtatTransfert(t.getEtatTransfert());
        transfert.setSensTransfert(t.getSensTransfert());
        transfert.setDateDebut(t.getDateDebut());
        transfert.setDateFin(t.getDateFin());
        transfert.setNomFichier(t.getNomFichier());
        transfert.setSended(t.getSended());
        transfert.setTaille(t.getTaille());
        transfert.setTypeFichier(t.getTypeFichier());
    }

}