package com.megatim.fdxconsultation.service.impl.searchs; import com.megatim.fdxconsultation.model.mappers.MapStructMapper; import com.megatim.fdxconsultation.core.ifaces.stats.TableauBordUserSpecificSearchManager; import com.megatim.fdxconsultation.core.impl.stats.ConvertedTableauBordResponse; import com.megatim.fdxconsultation.model.searchentities.TableauBordSpecificSearch; import com.megatim.fdxconsultation.model.stats.dto.TableauBordFlatResponse; import com.megatim.fdxconsultation.service.ifaces.searchs.TableauBordSearchRS; import com.mgt.rs.security.core.common.AuthenticatedUser; import com.mgt.rs.security.core.common.SecuredClass; import java.util.List; import java.util.stream.Collectors; import javax.enterprise.event.Observes; import javax.inject.Inject; import javax.ws.rs.Path; import javax.ws.rs.core.HttpHeaders; import javax.ws.rs.core.Response; /** * * @author Gabuntu */ @SecuredClass(module = "", path = "", description = "") @Path("tableau-bord-search") public class TableauBordSearchRSImpl implements TableauBordSearchRS { @Inject private TableauBordUserSpecificSearchManager manager; private String username; public void handleAuthenticationEvent(@Observes @AuthenticatedUser String username) { this.username = username; } @Override public Response formData(HttpHeaders headers) { throw new UnsupportedOperationException("Not supported yet."); } @Override public Response formDataWithPagination(HttpHeaders headers, Integer pageNumber, Integer pagesize, TableauBordSpecificSearch searchEntity) { searchEntity.setUserName(username); List response = manager.findWithPagination(pageNumber, pagesize, searchEntity) .stream() .map(tableauBord -> new ConvertedTableauBordResponse(tableauBord).tableauBordFlatResponse()) .collect(Collectors.toList()); return Response.ok(response).build(); } @Override public Long countFormData(HttpHeaders headers, TableauBordSpecificSearch searchEntity) { searchEntity.setUserName(username); return manager.count(searchEntity); } }