package com.megatim.fdxconsultation.core.impl.helper;
|
|
import com.megatim.fdxcommons.core.ifaces.helper.DataInMemoryHandler;
|
import com.megatim.fdxcommons.model.enumeration.CriteriaLogicConnector;
|
import com.megatim.fdxcommons.model.enumeration.Operateur;
|
import com.megatim.fdxcommons.model.enumeration.OrderByType;
|
import com.megatim.fdxcommons.model.referentiel.Referentiel;
|
import com.megatim.fdxcommons.tools.exceptions.CommonRessourceNotFoundException;
|
import com.megatim.fdxconsultation.core.ifaces.helper.RequestHandler;
|
import com.megatim.fdxcommons.model.pojo.CriteriaEntityFromView;
|
import com.megatim.fdxconsultation.model.mappers.MapStructMapper;
|
import com.megatim.fdxconsultation.core.ifaces.stats.TableauBordManager;
|
import com.megatim.fdxcommons.model.pojo.CriteriaFormRequest;
|
import com.megatim.fdxcommons.model.pojo.OrderByDefinition;
|
import com.megatim.fdxconsultation.model.dto.stats.TableauBordSlimDto;
|
import com.megatim.fdxconsultation.model.stats.TableauBord;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import javax.enterprise.context.Dependent;
|
import javax.inject.Inject;
|
import javax.transaction.Transactional;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Dependent
|
public class RequestHandlerImpl implements RequestHandler {
|
|
@Inject
|
MapStructMapper mapper;
|
|
@Inject
|
private TableauBordManager tableauBordManager;
|
|
@Inject
|
private DataInMemoryHandler dataInMemoryHandler;
|
|
@Override
|
public Long countTableauBord(CriteriaFormRequest criteriaFormRequest) throws Exception {
|
return tableauBordManager.count(addCurrentReferentielToCriteria(criteriaFormRequest != null ? criteriaFormRequest.getCriteria() : null));
|
}
|
|
@Override
|
@Transactional
|
public void deleteTableauBord(Long id) {
|
TableauBord tableauBord = tableauBordManager.getById(id);
|
|
if (tableauBord == null) {
|
throw new CommonRessourceNotFoundException("La ressource ayant l'identifiant " + id + " est introuvable");
|
}
|
tableauBordManager.delete(null, tableauBord);
|
}
|
|
@Override
|
public List<TableauBordSlimDto> findTableauBord(CriteriaFormRequest criteriaFormRequest) throws Exception {
|
List<TableauBord> tableauxBords = tableauBordManager.findAll(addCurrentReferentielToCriteria(criteriaFormRequest != null ? criteriaFormRequest.getCriteria() : null),
|
Arrays.asList(),
|
Arrays.asList());
|
List<TableauBordSlimDto> dtos = new ArrayList<>();
|
|
tableauxBords.stream().forEach(t -> {
|
dtos.add(mapper.tableauBordToTableauBordSlimDto(t));
|
});
|
return dtos;
|
}
|
|
@Override
|
public List<TableauBordSlimDto> findTableauBordWithPagination(CriteriaFormRequest criteriaFormRequest, List<String> fetchEagerFields, int pageNumber, int pageSize) throws Exception {
|
|
|
List<TableauBord> tableauxBords = tableauBordManager
|
.findWithPagination(
|
addCurrentReferentielToCriteria(criteriaFormRequest != null ? criteriaFormRequest.getCriteria() : null),
|
fetchEagerFields,
|
Arrays.asList(new OrderByDefinition("dateCreation", OrderByType.DESC)),
|
pageNumber,
|
pageSize);
|
|
List<TableauBordSlimDto> dtos = new ArrayList<>();
|
|
tableauxBords.stream().forEach(t -> {
|
dtos.add(mapper.tableauBordToTableauBordSlimDto(t));
|
});
|
return dtos;
|
}
|
|
private CriteriaEntityFromView addCurrentReferentielToCriteria(CriteriaEntityFromView criterion) {
|
CriteriaEntityFromView finalCriterion = new CriteriaEntityFromView();
|
finalCriterion.setCriteriaLogicConnector(CriteriaLogicConnector.AND);
|
|
finalCriterion.getSubCriterias().add(currentReferentielCriterion());
|
finalCriterion.getSubCriterias().add(criterion);
|
|
return finalCriterion;
|
}
|
|
private CriteriaEntityFromView currentReferentielCriterion() {
|
Referentiel referentiel = dataInMemoryHandler.getDataInMemory().getReferentielEnCours();
|
return new CriteriaEntityFromView("referentiel.version",
|
referentiel != null ? referentiel.getVersion() : "",
|
Operateur.EQUALS);
|
}
|
}
|
