/*
 * 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.fdxconsultation.dao.impl.log;

import com.megatim.fdxconsultation.dao.ifaces.log.ApiUserActionLogDAO;
import com.megatim.fdxconsultation.dao.impl.log.util.QueryExtendsWithApiUserActionSummarySearch;
import com.megatim.fdxconsultation.model.dto.log.UserActionStatData;
import com.megatim.fdxconsultation.model.dto.log.UserActionStatDto;
import com.megatim.fdxconsultation.model.log.ApiUserActionLog;
import com.megatim.fdxconsultation.model.log.dtos.ApiUserActionSummarySearch;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;
import javax.persistence.TypedQuery;

/**
 *
 * @author ASUS
 */
@Stateless
public class ApiUserActionLogDAOImpl implements ApiUserActionLogDAO {

    @PersistenceContext(unitName = "fdxConsultationPersistenceUnit")
    protected EntityManager em;

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

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

    @Override
    public ApiUserActionLog getById(Long id) {

        Query query = em.createQuery("SELECT u FROM ApiUserActionLog u  WHERE u.id = :id");
        query.setParameter("id", id);

        Optional<ApiUserActionLog> optionalLog = query.getResultList().stream().findFirst();
        return optionalLog.isPresent() ? optionalLog.get() : null;
    }

    @Override
    public List<UserActionStatDto> getByStatut(ApiUserActionSummarySearch apiUserActionSummarySearch) {

        String selectQueryString = "SELECT u.status, COALESCE(COUNT(u.status), 0) FROM ApiUserActionLog u";
        String whereQueryString = "";
        String groupQueryString = "GROUP BY u.status";
        List<Object[]> liste = new QueryExtendsWithApiUserActionSummarySearch(apiUserActionSummarySearch, em, selectQueryString, whereQueryString, groupQueryString).query().getResultList();

        List<UserActionStatDto> scalarResults = new ArrayList<>();
        liste.stream().forEach(tab -> {
            UserActionStatDto scalar = new UserActionStatDto();
            scalar.setLibelle(tab[0].toString());
            scalar.setValue(Long.valueOf(tab[1].toString()));
            scalarResults.add(scalar);
        });
        return scalarResults;
    }

    @Override
    public List<UserActionStatData> getByStatutAndUserName(ApiUserActionSummarySearch apiUserActionSummarySearch) {

        String selectQueryString = "SELECT u.userName, u.status, COALESCE(COUNT(u.status), 0) FROM ApiUserActionLog u";
        String whereQueryString = "WHERE u.userName IS NOT NULL AND u.status IS NOT NULL";
        String groupQueryString = "GROUP BY u.userName, u.status";
        List<Object[]> liste = new QueryExtendsWithApiUserActionSummarySearch(apiUserActionSummarySearch, em, selectQueryString, whereQueryString, groupQueryString).query().getResultList();

        Map<String, List<UserActionStatDto>> userNameToUserActionStatDto = new HashMap<>();

        liste.stream().filter(tab -> tab[0] != null && tab[1] != null).forEach(tab -> {

            String key = tab[0].toString();

            final UserActionStatDto d = new UserActionStatDto();
            d.setLibelle(tab[1].toString());
            d.setValue(Long.valueOf(tab[2].toString()));

            if (!userNameToUserActionStatDto.containsKey(key)) {

                List<UserActionStatDto> data = new ArrayList<>();
                data.add(d);
                userNameToUserActionStatDto.put(key, data);

            } else {

                List<UserActionStatDto> data = userNameToUserActionStatDto.get(key);
                data.add(d);

                userNameToUserActionStatDto.put(key, data);

            }
        });

        return userNameToUserActionStatDto.entrySet().stream().map(e -> {
            final UserActionStatData actionStatData = new UserActionStatData();
            actionStatData.setLibelle(e.getKey());
            actionStatData.setData(e.getValue());
            return actionStatData;
        }).collect(Collectors.toList());
    }

    @Override
    public List<UserActionStatData> getByStatutAndPath(ApiUserActionSummarySearch apiUserActionSummarySearch) {

        String selectQueryString = "SELECT u.relativePath, u.status, COUNT(u.status) FROM ApiUserActionLog u";
        String whereQueryString = "";
        String groupQueryString = "GROUP BY u.relativePath, u.status";
        List<Object[]> liste = new QueryExtendsWithApiUserActionSummarySearch(apiUserActionSummarySearch, em, selectQueryString, whereQueryString, groupQueryString).query().getResultList();

        Map<String, List<UserActionStatDto>> userNameToUserActionStatDto = new HashMap<>();

        liste.stream().forEach(tab -> {

            String key = tab[0].toString();

            UserActionStatDto d = new UserActionStatDto();
            d.setLibelle(tab[1].toString());
            d.setValue(Long.valueOf(tab[2].toString()));

            if (!userNameToUserActionStatDto.containsKey(key)) {

                List<UserActionStatDto> data = new ArrayList<>();
                data.add(d);
                userNameToUserActionStatDto.put(key, data);

            } else {

                List<UserActionStatDto> data = userNameToUserActionStatDto.get(key);
                data.add(d);

                userNameToUserActionStatDto.put(key, data);

            }
        });

        return userNameToUserActionStatDto.entrySet().stream().map(e -> {
            UserActionStatData actionStatData = new UserActionStatData();
            actionStatData.setLibelle(e.getKey());
            actionStatData.setData(e.getValue());
            return actionStatData;
        }).collect(Collectors.toList());
    }
}