DEV Community: aristides villarreal

Dumb Learning Models

aristides villarreal — Fri, 20 Mar 2026 20:16:24 +0000

Dumb Learning Models, (DLM) en una era donde observamos grandes modelos de lenguaje , incursión de agentes de IA, nos encontramos ante una realidad. La demanda de recursos para entrenar, y llevar a producción estos modelos y agentes.
Por el contrario, los humanos desde su nacimiento hasta la vejez usan mecanismos tan variantes y complejos para su aprendizaje. Entre estos, experimentación, visualización, entran en juego sus sentidos.
Mientras su mente adquiere conocimiento, vemos diferencias entre personas con características similares. Que tal si en lugar de adquirir estos grandes modelos pre-entrenados, contaras con un modelo DLM,(un modelo tan tonto que no tiene casi conocimientos de nada), es un simple componente que aprenderá como una persona, basado en eventos que puedan ocurrir, estudiando, equivocándose. Cada etapa marcada por su concepción de vida(libre albedrío).
Estos pequeños modelos podrían coexistir en tu equipo computacional, dispositivo móvil con requerimientos muy básicos. Ellos podrían crear otros modelos, agentes, crear sus comunidades, comunicarse con otras comunidades, compartir experiencias de aprendizaje, equivocare, corregir sus errores y mejorar constantemente, o por el contrario decidir no aprender y actuar de manera aleatoria, el resultado seria impredecible.
A estos conceptos les denominamos Dumb Learning Models, modelos muy tontos que pueden o no llegar a ser inteligentes.

Para ello, hemos empezado a crear los primeros sistemas DLM en un lenguaje altamente eficiente, una de las mejores tecnologías usadas en el mundo empresarial,el lenguaje de programación Java.

La aplicación esta creada con Java 25. Mientras continué la evolución seguiremos con mas detalles.

Error con < p:selectBooleanCheckbox /> en datatable < p:cellEditor />

aristides villarreal — Wed, 04 Sep 2024 13:24:01 +0000

Para corregir el comportamiento de un un selectBooleanCheckBox en un datatable editable mediante p:cellEditor recurrimos a algo muy simple.

Utilizar un elemento hthml de tipo checbox.

Agregar un css para establecer el alto y ancho del componente

 <style type="text/css">
 input.htmlCheckbox {
            width: 20px;
            height: 20px;
        }
</style>

Ahora en el datatable

<p:column headerText="#{msg['field.active']}">
    <p:cellEditor >
         <f:facet name="output">
                                              <p:selectBooleanCheckbox value="#{item.active}" readonly="true"/>
         </f:facet>

         <f:facet name="input">
           <input type="checkbox" jsf:value="#{item.active}"                                                       
                  class="htmlCheckbox"/>                                                                            


         </f:facet>


    </p:cellEditor >
 </p:column>

High Performance with Java: Discover strategies and best practices to develop high performance Java applications

aristides villarreal — Fri, 02 Aug 2024 01:05:59 +0000

Deseo agradecer a los amigos de Packt, por el honor de ser revisor técnico del libro:

High Performance with Java: Discover strategies and best practices to develop high performance Java applications

Indice del libro

Si deseas conocer un poco acerca de técnicas para lograr optimizar tus aplicaciones Java, sin duda es un buen libro para iniciar.

Colecciones y bases de dinámicas en base a campos de tipo fecha

aristides villarreal — Mon, 08 Jul 2024 19:38:13 +0000

En algunas ocasiones deseamos generar bases de datos y colecciones dinámicas en base a una fecha.

Por ejemplo generar una base datos para cada año y las colecciones por mes y por cada empresa. De manera que contamos con una mejor clasificación de los documentos , lo que genera un mejor desempeño de la aplicación al distribuir los documentos en varias bases de datos y colecciones.

En el ejemplo hipotético asuma que cuenta con un modelo como el siguiente:

@Entity 
public class Venta{
  @Id(autogeneratedActive =AutogeneratedActive.ON )
  private Long idventa;

  @Column
  private Long idempresa;

  @Column
  private Double total;


}

Ejemplo:

Bases de dato: ventas_2024db

Colecciones:

      transaccion_1_enero  
      transaccion_2_enero  
      transaccion_1_febrero  
      transaccion_2_febrero

Bases de dato: ventas_2024db

Colecciones:

      transaccion_1_enero  
      transaccion_2_enero  
      transaccion_1_febrero  
      transaccion_2_febrero

Microservicios con colecciones dinámicas en jmoordbcore

aristides villarreal — Sat, 18 May 2024 02:53:08 +0000

Las bases de datos dinámicas y colecciones solo aplican para entidades que no contengan documentos referenciados.

Para implementarlo se permite entidades que contengan o no documentos embebidos.

En el Controller especifique la colección dinámica

  tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);

Observe que el parámetro idproyecto lo recibe el endpoint y con el se genera la nueva colección.


@Path("tarjeta")
@Tag(name = "Información del tarjeta", description = "End-point para entidad Tarjeta")
@RolesAllowed({"admin"})
@RequestScoped
public class TarjetaController implements Serializable{

    private String nameOfCollection = "tarjeta_";

    @Inject
    TarjetaRepository tarjetaRepository;
    @Inject
    HistoryRepository historyRepository;



    @GET
    @RolesAllowed({"admin"})
    @Path("idtarjetaidproyecto")

    public Tarjeta findByIdtarjetaIdproyecto(@QueryParam("idtarjeta") Long idtarjeta, @QueryParam("idproyecto") Long idproyecto) {

        tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
        return tarjetaRepository.findByPk(idtarjeta).orElseThrow(
                () -> new WebApplicationException("No hay tarjeta con idtarjeta " + idtarjeta, Response.Status.NOT_FOUND));

    }

    @POST
    @RolesAllowed({"admin"})

    public Response save(
            @RequestBody(description = "Crea un nuevo tarjeta.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Tarjeta.class))) Tarjeta tarjeta) {
     tarjetaRepository.setDynamicCollection(nameOfCollection + tarjeta.getIdproyecto());
        Optional<Tarjeta> tarjetaOptional = tarjetaRepository.save(tarjeta);
        if (tarjetaOptional.isPresent()) {
            saveHistory(tarjeta);

            return Response.status(201).entity(tarjetaOptional.get()).build();
        } else {
            return Response.status(400).entity("Error " + tarjetaRepository.getJmoordbException().getLocalizedMessage()).build();
        }

    }


    @PUT
    @RolesAllowed({"admin"})

    public Response update(
            @RequestBody(description = "Crea un nuevo tarjeta.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Tarjeta.class))) Tarjeta tarjeta) {
       tarjetaRepository.setDynamicCollection(nameOfCollection + tarjeta.getIdproyecto());
        if (tarjetaRepository.update(tarjeta)) {
            saveHistory(tarjeta);
            return Response.status(201).entity(tarjeta).build();
        } else {
            return Response.status(400).entity("Error " + tarjetaRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }



    @DELETE
    @RolesAllowed({"admin"})
    @Path("idtarjetaidproyecto")

    public Response delete(@QueryParam("idtarjeta") Long idtarjeta, @QueryParam("idproyecto") Long idproyecto) {
        tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
        if (tarjetaRepository.deleteByPk(idtarjeta) == 0L) {
            return Response.status(201).entity(Boolean.TRUE).build();
        } else {
            return Response.status(400).entity("Error " + tarjetaRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }


    @DELETE
    @Path("deletemany")
    @RolesAllowed({"admin"})
     public Response deleteMany(@QueryParam("filter") String filter, @QueryParam("idproyecto") Long idproyecto) {
        tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
        Search search = DocumentUtil.convertForLookup(filter, "", 0, 0);
        if (tarjetaRepository.deleteMany(search) == 0L) {
            return Response.status(201).entity(Boolean.TRUE).build();
        } else {
            return Response.status(400).entity("Error " + tarjetaRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }

    @GET
    @Path("lookup")
    @RolesAllowed({"admin"})

    public List<Tarjeta> lookup(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size, @QueryParam("idproyecto") Long idproyecto) {
        List<Tarjeta> suggestions = new ArrayList<>();
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            Search search = DocumentUtil.convertForLookup(filter, sort, page, size);

            suggestions = tarjetaRepository.lookup(search);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return suggestions;
    }

    @GET
    @Path("count")
    @RolesAllowed({"admin"})
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public Long count(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size, @QueryParam("idproyecto") Long idproyecto) {
        Long result = 0L;
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            Search search = DocumentUtil.convertForLookup(filter, sort, page, size);
            result = tarjetaRepository.count(search);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return result;
    }



    @GET
    @Path("countlikebytarjeta")
    @RolesAllowed({"admin"})
     @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public Long countLikeByTarjeta(@QueryParam("tarjeta") String tarjeta, @QueryParam("idproyecto") Long idproyecto) {
        Long result = 0L;
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            result = tarjetaRepository.countLikeByTarjeta(tarjeta);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return result;
    }


    @GET
    @Path("countlikebydescripcion")
    @RolesAllowed({"admin"})
     @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public Long countLikeByDescripcion(@QueryParam("descripcion") String descripcion, @QueryParam("idproyecto") Long idproyecto) {
        Long result = 0L;
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            result = tarjetaRepository.countLikeByDescripcion(descripcion);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return result;
    }


    @GET
    @Path("likebytarjeta")
    @RolesAllowed({"admin"})
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Tarjeta> likeByName(@QueryParam("tarjeta") String tarjeta, @QueryParam("idproyecto") Long idproyecto) {
        List<Tarjeta> suggestions = new ArrayList<>();
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            suggestions = tarjetaRepository.likeByTarjeta(tarjeta);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return suggestions;
    }


    @GET
    @Path("likebytarjetasearch")
    @RolesAllowed({"admin"})
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
    public List<Tarjeta> searchLikeByTarjeta(@QueryParam("tarjeta") String tarjeta, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size, @QueryParam("idproyecto") Long idproyecto) {
        List<Tarjeta> suggestions = new ArrayList<>();
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            Search search = DocumentUtil.convertForLookup(filter, sort, page, size);
            suggestions = tarjetaRepository.searchLikeByTarjeta(tarjeta, search);
        } catch (Exception e) {
            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }
        return suggestions;
    }


    @GET
    @Path("likebydescripcionsearch")
    @RolesAllowed({"admin"})
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
    public List<Tarjeta> searchLikeByDescripcion(@QueryParam("descripcion") String descripcion, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size, @QueryParam("idproyecto") Long idproyecto) {
        List<Tarjeta> suggestions = new ArrayList<>();
        try {
            tarjetaRepository.setDynamicCollection(nameOfCollection + idproyecto);
            Search search = DocumentUtil.convertForLookup(filter, sort, page, size);
            suggestions = tarjetaRepository.searchLikeByDescripcion(descripcion, search);
        } catch (Exception e) {
            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }
        return suggestions;
    }




}

El repositorio tendría una estructura similar a

@Repository(database = "{mongodb.database1}", entity = Tarjeta.class)
public interface TarjetaRepository extends CrudRepository<Tarjeta, Long> {

    @Lookup
    public List<Tarjeta> lookup(Search search);

    @Count()
    public Long count(Search... search);

    @CountLikeBy(caseSensitive = CaseSensitive.NO, likeByType = LikeByType.ANYWHERE)
    public Long countLikeByTarjeta(String tarjeta);

    @CountLikeBy(caseSensitive = CaseSensitive.NO, likeByType = LikeByType.ANYWHERE)
    public Long countLikeByDescripcion(String descripcion);

    @SearchCountLikeBy(caseSensitive = CaseSensitive.NO, likeByType = LikeByType.ANYWHERE)
    public Long searchCountLikeByTarjeta(String tarjeta, Search search);

    @SearchCountLikeBy(caseSensitive = CaseSensitive.NO, likeByType = LikeByType.ANYWHERE)
    public Long searchCountLikeByDescripcion(String descripcion, Search search);

    @LikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Tarjeta> likeByTarjeta(String tarjeta);

    @LikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Tarjeta> likeByTarjetaPagination(String tarjeta, Pagination pagination);



    @LikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Tarjeta> likeByDescripcion(String descripcion);


   @SearchLikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Tarjeta> searchLikeByTarjeta(String tarjeta, Search search);

    @SearchLikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Tarjeta> searchLikeByDescripcion(String descripcion, Search search);

    @Find
    public List<Tarjeta> findByFechainicialGreaterThanEqualAndFechafinalLessThanEqual(@ExcludeTime Date start, @ExcludeTime Date end);
}

En el cliente utilizamos Microprofile Rest-Client

En el archivo microprofile-config.properties

com.sft.restclient.TarjetaRestClient/mp-rest/url=http://localhost:9002/accreditation/api/

Crear el RestClient


 @RegisterRestClient()
@Path("/tarjeta")

//@ApplicationScoped
public interface TarjetaRestClient {

@GET
    @Path("idtarjetaidproyecto")
    public Tarjeta findByIdtarjetaproyecto(@QueryParam("idtarjeta") Long idtarjeta, @QueryParam("idproyecto") Long idproyecto);

 @GET
    @Path("tarjeta")
    public List<Tarjeta> findByTarjeta(@Parameter(description = "El tarjeta", required = true, example = "1", schema = @Schema(type = SchemaType.STRING)) @QueryParam("tarjeta") final String tarjeta,@QueryParam("idproyecto") Long idproyecto);
//// </editor-fold>



    // <editor-fold defaultstate="collapsed" desc="Response save">
    @POST

    public Response save(@RequestBody(description = "Crea un nuevo tarjeta.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Tarjeta.class))) Tarjeta tarjeta);
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Response update">

    @PUT

    public Response update(@RequestBody(description = "Actualiza la tarjeta.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Tarjeta.class))) Tarjeta tarjeta);

// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Response delete">
    @DELETE
//    @Path("{idtarjeta}")
    @Path("idtarjetaidproyecto")
//    public Response delete(@Parameter(description = "El elemento idtarjeta", required = true, example = "1", schema = @Schema(type = SchemaType.NUMBER)) @PathParam("idtarjeta") Long idtarjeta);
    public Response delete(@QueryParam("idtarjeta") Long idtarjeta, @QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>


    // <editor-fold defaultstate="collapsed" desc="Response deleteMany(@QueryParam("filter") String filter ,@QueryParam("idproyecto") Long idproyecto)">
     @DELETE
     @Path("deletemany")
public Response deleteMany(@QueryParam("filter") String filter ,@QueryParam("idproyecto") Long idproyecto ) ;
  // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> lookup(@QueryParam("filter") String filter, @QueryParam("sort") String sort,  @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto)">
    @GET
    @Path("lookup")
    public List<Tarjeta> lookup(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>    


 // <editor-fold defaultstate="collapsed" desc="public Long count(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);">
    @GET
    @Path("count")
    public Long count(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>    

    // <editor-fold defaultstate="collapsed" desc="Long countLikeByTarjeta(@QueryParam("tarjeta") String tarjeta,@QueryParam("idproyecto") Long idproyecto)">
    @GET
   @Path("countlikebytarjeta")
     public Long countLikeByTarjeta(@QueryParam("tarjeta") String tarjeta,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>    

    // <editor-fold defaultstate="collapsed" desc="Long countLikeByDescripcion(@QueryParam("descripcion") String descripcion,@QueryParam("idproyecto") Long idproyecto)">
    @GET
   @Path("countlikebydescripcion")
     public Long countLikeByDescripcion(@QueryParam("descripcion") String descripcion,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>    


// <editor-fold defaultstate="collapsed" desc="public List<Tarjeta> likeByTarjeta(@QueryParam("tarjeta") String tarjeta,@QueryParam("idproyecto") Long idproyecto)">

    @GET
    @Path("likebytarjeta")
    public List<Tarjeta> likeByTarjeta(@QueryParam("tarjeta") String tarjeta,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>
// <editor-fold defaultstate="collapsed" desc="public List<Tarjeta> likeByTarjetaPagination(@QueryParam("tarjeta") String tarjeta, @QueryParam("pagination") Pagination pagination,@QueryParam("idproyecto") Long idproyecto)">

    @GET
    @Path("likebytarjetapagination")
    public List<Tarjeta> likeByTarjetaPagination(@QueryParam("tarjeta") String tarjeta, @QueryParam("page") Integer page, @QueryParam("size") Integer siz,@QueryParam("idproyecto") Long idproyectoe);
    // </editor-fold>


// <editor-fold defaultstate="collapsed" desc="List<Tarjeta> likeByDescripcion(@QueryParam("descripcion") String descripcion,@QueryParam("idproyecto") Long idproyecto)">

    @GET
    @Path("likebydescripcion")
    public List<Tarjeta> likeByDescripcion(@QueryParam("descripcion") String descripcion,@QueryParam("idproyecto") Long idproyecto);
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> betweenDate(@QueryParam("fechainicial") Date fechainicial, @QueryParam("fechafinal") Date fechafinal,@QueryParam("idproyecto") Long idproyecto)">
      @GET
    @Path("betweendate")
    public List<Tarjeta> betweenDate(@QueryParam("fechainicial") Date fechainicial, @QueryParam("fechafinal") Date fechafinal,@QueryParam("idproyecto") Long idproyecto) ;
    // </editor-fold>



    @GET
    @Path("likebytarjetasearch")
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
    List<Tarjeta> searchLikeByTarjeta(@QueryParam("tarjeta") String tarjeta, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);


    @GET
    @Path("searchcountlikebytarjeta")
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
   public  Long searchCountLikeByTarjeta(@QueryParam("tarjeta") String tarjeta, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);


    @GET
    @Path("likebydescripcionsearch")
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
    List<Tarjeta> searchLikeByDescripcion(@QueryParam("descripcion") String descripcion, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);


    @GET
    @Path("searchcountlikebydescripcion")
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})
   public  Long searchCountLikeByDescripcion(@QueryParam("descripcion") String descripcion, @QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size,@QueryParam("idproyecto") Long idproyecto);
}

Crear TarjetaServices

public interface TarjetaServices {
//     public List<Tarjeta> findAll();
    public Optional<Tarjeta> save(Tarjeta tarjeta);

    public Boolean update(Tarjeta tarjeta);

    public Boolean deleteMany(Bson filter,Long idproyecto);

//    public Optional<Tarjeta> findByIdtarjeta(Long idtarjeta);
    public Optional<Tarjeta> findByIdtarjetaIdproyecto(Long idtarjeta, Long idproyecto);

    public List<Tarjeta> lookup(Bson filter, Document sort, Integer page, Integer size, Long idproyecto);

    public Boolean tarjetaExistInSprint(String tarjetaName, Long idproyecto, Long idsprint);

    public Boolean tarjetaExistInBacklog(String tarjetaName, Long idproyecto, Long idsprint);

    public Optional<Tarjeta> tarjetaConIgualNombreInSprint(String tarjetaName, Long idproyecto, Long idsprint);

    public Long count(Bson filter, Document sort, Integer page, Integer size, Long idproyecto);

    public Long totalPorColumna(Proyecto proyecto, String columna, Boolean storeInBacklog);

    public List<Comentario> ordenarComentarioPorFechaDescendente(Tarjeta tarjeta);

    public List<Tarea> ordenarTareaPorCompletadoDescendente(Tarjeta tarjeta);
    public List<Tarea> ordenarTareaPorOrden(Tarjeta tarjeta);

    public List<Impedimento> ordenarImpedimentoDescendente(Tarjeta tarjeta);

    public Boolean isMiembroAutorizedInTarjetaForanea(Tarjeta tarjeta, User userLogged, UserView userViewForaneo);

    public Boolean equalsExcludedNameOfTarjeta(Tarjeta tarjeta, Tarjeta other);

    public Boolean isEstimacionValida(Tarjeta tarjeta);

    public String colorTarjeta(Tarjeta tarjeta);

    public Long countLikeByTarjeta(String tarjeta, Long idproyecto);

    public Long countLikeByDescripcion(String descripcion, Long idproyecto);

    public List<Tarjeta> likeByTarjeta(String tarjeta, Long idproyecto);

    public List<Tarjeta> likeByTarjetaPagination(String tarjeta, Pagination pagination, Long idproyecto);

    public List<Tarjeta> likeByDescripcion(String descripcion, Long idproyecto);

    public List<Tarjeta> betweenDate(@QueryParam("fechainicial") Date fechainicial, @QueryParam("fechafinal") Date fechafinal, Long idproyecto);

    public List<Tarjeta> searchLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size, Long idproyecto);
    public Long searchCountLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size, Long idproyecto);

    public List<Tarjeta> searchLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto);
        public Long searchCountLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto);


    public List<Tarjeta> validarFechaFinalEsteSprintActual(List<Tarjeta> list, Sprint sprint);
    public List<Tarjeta> validarFechaFinalSprintPlanTrabajo(List<Tarjeta> list, Sprint sprint);

    public List<Tarjeta> orderListForIdTarjetaReserve(List<Tarjeta> list);

    public Integer positionOfTarjeta(Tarjeta tarjeta, List<Tarjeta> tarjetas);

    public TotalesTarjetasEstadistica calcularTotalesTarjetasEstadistica(Long iduser, Long idproyecto);



}

Crear la implementación

@ApplicationScoped
public class TarjetaServicesImpl implements TarjetaServices {
// <editor-fold defaultstate="collapsed" desc="@Inject">

    @Inject
    JmoordbResourcesFiles rf;
    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Microprofile Rest Client">
    @Inject
    TarjetaRestClient tarjetaRestClient;
    @Inject
    TarjetaServices tarjetaServices;
// </editor-fold>

//    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> findAll()">
//    @Override
//    public List<Tarjeta> findAll() {
//        return tarjetaRestClient.findAll();
//    }
//// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Boolean update(Tarjeta tarjeta)">

    @Override
    public Boolean update(Tarjeta tarjeta) {
        Boolean result = Boolean.FALSE;
        try {

            Integer status = tarjetaRestClient.update(tarjeta).getStatus();

            if (status == 201) {
                result = Boolean.TRUE;
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
// </editor-fold>

//    // <editor-fold defaultstate="collapsed" desc="Optional<Tarjeta> findByIdtarjeta(Long idtarjeta)">
//    @Override
//    public Optional<Tarjeta> findByIdtarjeta(Long idtarjeta) {
//
//        try {
//            Tarjeta result = tarjetaRestClient.findByIdtarjeta(idtarjeta);
//            if (result == null || result.getIdtarjeta() == null) {
//
//            } else {
//                return Optional.of(result);
//            }
//        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
//        }
//        return Optional.empty();
//
//    }
//    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Optional<Tarjeta> findByIdtarjetaIdproyecto(Long idtarjeta, Long idproyecto)">
    @Override
    public Optional<Tarjeta> findByIdtarjetaIdproyecto(Long idtarjeta, Long idproyecto) {

        try {
            ConsoleUtil.test("\t >>>>>"+FacesUtil.nameOfClassAndMethod() + " <<<<<");
            ConsoleUtil.test("\t >>> idtarjeta "+idtarjeta + " idproyecto "+idproyecto);
            Tarjeta result = tarjetaRestClient.findByIdtarjetaproyecto(idtarjeta,idproyecto);
            ConsoleUtil.test("\t llego a 2");
            if (result == null || result.getIdtarjeta() == null) {

            } else {
                return Optional.of(result);
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return Optional.empty();

    }
    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> lookup(Bson filter, Document sort, Integer page, Integer size, Long idproyecto)">

    @Override
    public List<Tarjeta> lookup(Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        List<Tarjeta> tarjetaList = new ArrayList<>();
        try {

            tarjetaList = tarjetaRestClient.lookup(
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size, idproyecto);

        } catch (Exception e) {

            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

        return tarjetaList;
    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Boolean deleteMany(Bson filter, Long idproyecto) ">

    @Override
    public Boolean deleteMany(Bson filter, Long idproyecto) {
        Boolean result = Boolean.FALSE;
        try {
            Integer status = tarjetaRestClient.deleteMany(EncodeUtil.encodeBson(filter),idproyecto).getStatus();
            if (status == 201) {
                result = Boolean.TRUE;
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Long count(Bson filter, Document sort, Integer page, Integer size, Long idproyecto)">
    @Override
    public Long count(Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        Long result = 0L;
        try {
            result = tarjetaRestClient.count(
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size,idproyecto);
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Optional<Tarjeta>(Tarjeta tarjeta)">
    @Override
    public Optional<Tarjeta> save(Tarjeta tarjeta) {
        try {

            Response response = tarjetaRestClient.save(tarjeta);

            if (response.getStatus() == 400) {

                String error = (response.readEntity(String.class));

                return Optional.empty();
            }

            Tarjeta result = (Tarjeta) (response.readEntity(Tarjeta.class));

            return Optional.of(result);

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return Optional.empty();
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Boolean tarjetaExist(String tarjetaName, Long idproyecto, Long idsprint)">
    @Override
    public Boolean tarjetaExistInSprint(String tarjetaName, Long idproyecto, Long idsprint) {
        Boolean result = Boolean.FALSE;
        try {
            Integer page = 0;
            Integer size = 0;
            Bson filter = and(
                    eq("idproyecto", idproyecto),
                    eq("idsprint", idsprint),
                    eq("active", true),
                    eq("tarjeta", tarjetaName)
            );

            Document sort = new Document("idtarjeta", 1);
            if (count(filter, sort, page, size,idproyecto) > 0) {
                result = Boolean.TRUE;
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Boolean tarjetaExist(Bson filter, Document sort, Integer page, Integer size)">
    @Override
    public Boolean tarjetaExistInBacklog(String tarjetaName, Long idproyecto, Long idsprint) {
        Boolean result = Boolean.FALSE;
        try {
            Integer page = 0;
            Integer size = 0;
            Bson filter = and(
                    eq("idproyecto", idproyecto),
                    eq("idsprint", 0L),
                    eq("active", true),
                    eq("tarjeta", tarjetaName)
            );

            Document sort = new Document("idtarjeta", 1);
            if (count(filter, sort, page, size,idproyecto) > 0) {
                result = Boolean.TRUE;
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc=" List<Tarjeta> tarjetaConIgualNombreInSprint(String tarjetaName, Long idproyecto, Long idsprint)">
    @Override
    public Optional<Tarjeta> tarjetaConIgualNombreInSprint(String tarjetaName, Long idproyecto, Long idsprint) {
        Optional<Tarjeta> result = Optional.empty();
        try {
            Integer page = 0;
            Integer size = 0;
            Bson filter = and(
                    eq("idproyecto", idproyecto),
                    eq("idsprint", idsprint),
                    eq("active", true),
                    eq("tarjeta", tarjetaName)
            );

            Document sort = new Document("idtarjeta", 1);
            List<Tarjeta> list = lookup(filter, sort, page, size,idproyecto);
            if (list == null || list.isEmpty()) {
                return Optional.empty();
            }
            result = Optional.of(list.get(0));
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Comentario> ordenarComentario(Tarjeta tarjeta) ">
    /**
     * Ordena los comentarios por fecha
     *
     * @param tarjeta
     * @return
     */
    @Override
    public List<Comentario> ordenarComentarioPorFechaDescendente(Tarjeta tarjeta) {
        List<Comentario> result = new ArrayList<>();
        try {

            if (tarjeta.getComentario() == null || tarjeta.getComentario().isEmpty()) {
                return result;
            }
            Comparator<Comentario> comparator
                    = (c1, c2) -> c1.getFecha().compareTo(c2.getFecha());

            tarjeta.getComentario().sort(comparator.reversed());

        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjeta.getComentario();
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Boolean isMiembroAutorizedInTarjetaForanea(Tarjeta tarjeta, User userLogged, UserView userViewForaneo)">
    @Override
    public Boolean isMiembroAutorizedInTarjetaForanea(Tarjeta tarjeta, User userLogged, UserView userViewForaneo) {
        Boolean result = Boolean.FALSE;
        try {
            if (tarjeta.getForeaneo()) {
                if (userViewForaneo.getIduser().equals(userLogged.getIduser())) {

                } else {
                    result = Boolean.TRUE;
                }
            } else {
                result = Boolean.TRUE;
            }
        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Comentario> ordenarTareaPorCompletadoDescendente(Tarjeta tarjeta) ">
    @Override
    public List<Tarea> ordenarTareaPorCompletadoDescendente(Tarjeta tarjeta) {
        List<Tarea> result = new ArrayList<>();
        try {

            if (tarjeta.getTarea() == null || tarjeta.getTarea().isEmpty()) {
                return result;
            }
            Comparator<Tarea> comparator
                    = (c1, c2) -> c1.getCompletado().compareTo(c2.getCompletado());

            tarjeta.getTarea().sort(comparator);
//           tarjeta.getTarea().sort(comparator.reversed());

        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjeta.getTarea();
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Tarea> ordenarTareaPorOrden(Tarjeta tarjeta)">
    @Override
    public List<Tarea> ordenarTareaPorOrden(Tarjeta tarjeta) {
        List<Tarea> result = new ArrayList<>();
        try {
            if (tarjeta.getTarea() == null || tarjeta.getTarea().isEmpty()) {
                return result;
            }
            Comparator<Tarea> comparator
                    = (c1, c2) -> c1.getOrden().compareTo(c2.getOrden());

            tarjeta.getTarea().sort(comparator);

        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjeta.getTarea();
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Impedimento> ordenarImpedimentoDescendente(Tarjeta tarjeta) ">
    @Override
    public List<Impedimento> ordenarImpedimentoDescendente(Tarjeta tarjeta) {
        List<Impedimento> result = new ArrayList<>();
        try {

            if (tarjeta.getImpedimento() == null || tarjeta.getImpedimento().isEmpty()) {
                return result;
            }
            Comparator<Impedimento> comparator
                    = (c1, c2) -> c1.getImpedimento().compareTo(c2.getImpedimento());

            tarjeta.getImpedimento().sort(comparator.reversed());

        } catch (Exception e) {
//            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjeta.getImpedimento();
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Long totalPorColumna(Proyecto proyecto, String columna,Boolean storeInBacklog) ">
    /**
     * *
     *
     * @param proyecto
     * @param columna
     * @param storeInBacklog
     * @return devuelve el total de columnas
     */
    @Override
    public Long totalPorColumna(Proyecto proyecto, String columna, Boolean storeInBacklog) {
        Long result = 0L;

        try {
            Integer page = 0;
            Integer size = 0;
            Document sortTarjeta = new Document("idtarjeta", 1);
            /**
             * CargarTarjetas
             */

            if (!storeInBacklog) {
                Bson filter0 = eq("idproyecto", proyecto.getIdproyecto());
                Bson filter = and(filter0, eq("active", Boolean.TRUE),
                        eq("columna", columna));
                result = count(filter, sortTarjeta, page, size,proyecto.getIdproyecto());
            } else {
                Bson filter0 = eq("idproyecto", proyecto.getIdproyecto());
                Bson filter = and(filter0, eq("active", Boolean.TRUE),
                        eq("columna", columna),
                        eq("backlog", storeInBacklog));
                result = count(filter, sortTarjeta, page, size,proyecto.getIdproyecto());
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Boolean equalsExcludedNameOfTarjeta(Tarjeta tarjeta, Tarjeta other) ">
    @Override
    public Boolean equalsExcludedNameOfTarjeta(Tarjeta tarjeta, Tarjeta other) {
        Boolean result = Boolean.FALSE;
        try {
            if (tarjeta == null) {
                return false;
            }

            if (!Objects.equals(tarjeta.getDescripcion(), other.getDescripcion())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getPrioridad(), other.getPrioridad())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getEstimacion(), other.getEstimacion())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getColumna(), other.getColumna())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getIdtarjeta(), other.getIdtarjeta())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getUserView(), other.getUserView())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getFechainicial(), other.getFechainicial())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getFechafinal(), other.getFechafinal())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getIcono(), other.getIcono())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getTipotarjeta(), other.getTipotarjeta())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getIdsprint(), other.getIdsprint())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getIdproyecto(), other.getIdproyecto())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getBacklog(), other.getBacklog())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getActive(), other.getActive())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getTarea(), other.getTarea())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getComentario(), other.getComentario())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getEtiqueta(), other.getEtiqueta())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getArchivo(), other.getArchivo())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getImpedimento(), other.getImpedimento())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getForeaneo(), other.getForeaneo())) {
                return false;
            }
            if (!Objects.equals(tarjeta.getActionHistory(), other.getActionHistory())) {
                return false;
            }
            result = Boolean.TRUE;
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Boolean isEstimacionValida(Tarjeta tarjeta)">
    @Override
    public Boolean isEstimacionValida(Tarjeta tarjeta) {
        Boolean result = Boolean.TRUE;
        try {

            if (tarjeta.getEstimacion() == null || tarjeta.getEstimacion().equals("")) {
                FacesUtil.warningDialog(rf.fromCore("warning.warning"), rf.fromMessage("warning.ingreseestimacionformato"));
                return Boolean.FALSE;
            }

            if (tarjeta.getEstimacion().indexOf(":") == -1) {
                FacesUtil.warningDialog(rf.fromCore("warning.warning"), rf.fromMessage("warning.ingreseestimacionformato"));
                return Boolean.FALSE;
            }

            if (tarjeta.getEstimacion().indexOf("-") != -1) {
                FacesUtil.warningDialog(rf.fromCore("warning.warning"), rf.fromMessage("warning.ingreseestimacionformato"));
                return Boolean.FALSE;
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="String colorTarjeta(Tarjeta tarjeta)">
    /**
     * Listado de colores https://tailwindcss.com/docs/background-color
     *
     * @param tarjeta
     * @return
     */
    @Override
    public String colorTarjeta(Tarjeta tarjeta) {
        String color = "";
        try {
            switch (tarjeta.getPrioridad().toLowerCase()) {

                case "urgente":
                    color = "bg-orange-900";
                    break;

                case "alta":
                    color = "bg-purple-900";
                    break;
                case "baja":
////color ="bg-green-950";
//color ="bg-teal-600";
////color ="bg-green-600";
//                    color = "bg-indigo-900";
//                    color = "bg-indigo-700";
                    color = "bg-teal-900";
                    break;

                case "media":
                    color = "";
                    break;
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return color;
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="public Long countLikeByTarjeta(@QueryParam("tarjeta") String tarjeta, Long idproyecto)">
    @Override
    public Long countLikeByTarjeta(String tarjeta, Long idproyecto) {
        Long result = 0L;
        try {
            result = tarjetaRestClient.countLikeByTarjeta(tarjeta,idproyecto);

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Long countLikeByDescripcion( String descripcion, Long idproyecto)">
    @Override
    public Long countLikeByDescripcion(String descripcion, Long idproyecto) {
        Long result = 0L;
        try {
            result = tarjetaRestClient.countLikeByDescripcion(descripcion, idproyecto);

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="public List<Tarjeta> likeByTarjeta(String tarjeta, Long idproyecto)">
    @Override
    public List<Tarjeta> likeByTarjeta(String tarjeta, Long idproyecto) {
        return tarjetaRestClient.likeByTarjeta(tarjeta,idproyecto);
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="public List<Tarjeta> likeByTarjetaPagination(String tarjeta, Pagination pagination, Long idproyecto)">
    @Override
    public List<Tarjeta> likeByTarjetaPagination(String tarjeta, Pagination pagination, Long idproyecto) {

        return tarjetaRestClient.likeByTarjetaPagination(tarjeta, pagination.getPage(), pagination.getSize(),idproyecto);

    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> likeByDescripcion(String descripcion, Long idproyecto)">
    @Override
    public List<Tarjeta> likeByDescripcion(String descripcion, Long idproyecto) {
        return tarjetaRestClient.likeByDescripcion(descripcion,idproyecto);
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> betweenDate(@QueryParam("fechainicial") Date fechainicial, @QueryParam("fechafinal") Date fechafinal, Long idproyecto) ">
    public List<Tarjeta> betweenDate(@QueryParam("fechainicial") Date fechainicial, @QueryParam("fechafinal") Date fechafinal, Long idproyecto) {
        return tarjetaRestClient.betweenDate(fechainicial, fechafinal,idproyecto);
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> searchLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size, Long idproyecto)">
    @Override
    public List<Tarjeta> searchLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        List<Tarjeta> tarjetaList = new ArrayList<>();
        try {
            tarjetaList = tarjetaRestClient.searchLikeByTarjeta(tarjeta,
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size,idproyecto);
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjetaList;
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Long searchCountLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size,, Long idproyecto)">
    @Override
    public Long searchCountLikeByTarjeta(String tarjeta, Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        Long result = 0L;
        try {
            result = tarjetaRestClient.searchCountLikeByTarjeta(tarjeta,
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size,idproyecto);
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
// </editor-fold>

// <editor-fold defaultstate="collapsed" desc="List<Tarjeta> searchLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto)">
    @Override
    public List<Tarjeta> searchLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        List<Tarjeta> tarjetaList = new ArrayList<>();
        try {
            tarjetaList = tarjetaRestClient.searchLikeByDescripcion(descripcion,
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size,idproyecto);
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return tarjetaList;
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Long searchCountLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto)">
    @Override
    public Long searchCountLikeByDescripcion(String descripcion, Bson filter, Document sort, Integer page, Integer size, Long idproyecto) {
        Long result = 0L;
        try {
            result = tarjetaRestClient.searchCountLikeByDescripcion(descripcion,
                    EncodeUtil.encodeBson(filter),
                    EncodeUtil.encodeBson(sort),
                    page, size,idproyecto);
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> validarFechaFinalEsteSprintActual(List<Tarjeta> list, Sprint sprint)">

    /**
     * Valida y garantiza que la ultima fecha de la tarjeta este en el sprint
     * actual
     *
     * @param list
     * @param sprint
     * @return
     */
    @Override
    public List<Tarjeta> validarFechaFinalEsteSprintActual(List<Tarjeta> list, Sprint sprint) {
        List<Tarjeta> result = new ArrayList<>();
        try {
            if (list == null || list.isEmpty()) {
                return result;
            } else {
                /**
                 * Verifica que la fecha final de la tarjeta no sea menor que la
                 * fecha inicial del sprint si ocurre actualiza con la fecha y
                 * hora actual
                 */
                Integer count = 0;
                for (Tarjeta t : list) {

                    if (DateUtil.fechaMenor(t.getFechafinal(), sprint.getFechainicial())) {
                        t.setFechafinal(sprint.getFechafinal());
                        update(t);
                        list.get(0).setFechafinal(t.getFechafinal());
                    }
                    count++;
                }
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return list;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> validarFechaFinalSprintPlanTrabajo(List<Tarjeta> list, Sprint sprint)">
    /**
     * Valida y garantiza que la ultima fecha de la tarjeta en el sprint del
     * plan de trabajo actual
     *
     * @param list
     * @param sprint
     * @return
     */
    @Override
    public List<Tarjeta> validarFechaFinalSprintPlanTrabajo(List<Tarjeta> list, Sprint sprint) {
        List<Tarjeta> result = new ArrayList<>();
        try {
            if (list == null || list.isEmpty()) {
                return result;
            } else {
                /**
                 * Verifica que la fecha final de la tarjeta no sea menor que la
                 * fecha inicial del sprint si ocurre actualiza con la fecha y
                 * hora actual
                 */
                Integer count = 0;
                for (Tarjeta t : list) {
                    if (t.getIdproyecto().equals(sprint.getProyectoView().getIdproyecto())) {
                        if (DateUtil.fechaMenor(t.getFechafinal(), sprint.getFechainicial())) {
                            t.setFechafinal(sprint.getFechafinal());
                            t.setLastModification(t.getActionHistory().getLast().getFecha());
                            update(t);
                            list.get(count).setFechafinal(t.getFechafinal());
                        }else{
                          //  t.setLastModification(t.getActionHistory().getLast().getFecha());
                         //   list.get(count).setLastModification(t.getActionHistory().getLast().getFecha());
                        }

                    }
                    count++;
                }
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return list;
    }

    // </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<Tarjeta> orderListForIdTarjetaReserve(List<Tarjeta> list)">
    /**
     *
     * @param list
     * @return lista de tarjeta ordenada por idtarjeta en orden inverso
     */
    @Override
    public List<Tarjeta> orderListForIdTarjetaReserve(List<Tarjeta> list) {
        try {
            list = list.stream().sorted(Comparator.comparing(Tarjeta::getIdtarjeta).reversed()).collect(Collectors.toList());

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return list;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Integer positionOfTarjeta(Tarjeta tarjeta, List<Tarjeta> tarjetas)">
    @Override
    public Integer positionOfTarjeta(Tarjeta tarjeta, List<Tarjeta> tarjetas) {
        Integer result = -1;
        try {

            Integer c = 0;
            for (Tarjeta t : tarjetas) {
                if (t.getIdtarjeta().equals(tarjeta.getIdtarjeta())) {
                    result = c;
                    break;
                }
                c++;

            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc=" public TotalesTarjetasEstadistica calcularTotalesTarjetasEstadistica(Long iduser, Long idproyecto)">

    @Override
    public TotalesTarjetasEstadistica calcularTotalesTarjetasEstadistica(Long iduser, Long idproyecto) {
        TotalesTarjetasEstadistica result = new TotalesTarjetasEstadistica(0L, 0L, 0L,0L, iduser);
        try {
            Integer page = 0;
            Integer size = 0;
            Document sortTarjeta = new Document("idtarjeta", 1);
            Document sortSprint = new Document("idtarjeta", 1); 
            /**
             * CargarTarjetas
             */
            Bson filter0 = eq("user.iduser", iduser);
            Bson filter = and(filter0, eq("active", Boolean.TRUE),
                    eq("columna", "pendiente"),
                    ne("idsprint",0L));

            Long pendiente = tarjetaServices.count(filter, sortTarjeta, page, size,idproyecto);

            Bson filterProgreso = and(filter0, eq("active", Boolean.TRUE),
                    eq("columna", "progreso"));

            Long progreso = tarjetaServices.count(filterProgreso, sortTarjeta, page, size,idproyecto);

            Bson filterFinalizado = and(filter0, eq("active", Boolean.TRUE),
                    eq("columna", "finalizado"));

            Long finalizado = tarjetaServices.count(filterFinalizado, sortTarjeta, page, size,idproyecto);

            Bson filterBacklog = and(filter0, eq("active", Boolean.TRUE),
                    eq("backlog", true),
                            eq("idsprint",0L));

            Long backlog = tarjetaServices.count(filterBacklog, sortTarjeta, page, size,idproyecto);

          result.setTotalTarjetasBacklog(backlog);
          result.setTotalTarjetasFinalizado(finalizado);
          result.setTotalTarjetasPendiente(pendiente);
          result.setTotalTarjetasProgreso(progreso);


     } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>





}

En una clase Faces

@Named
@ViewScoped
@Data
public class TarjetasFaces implements Serializable, JmoordbCoreXHTMLUtil, IPaginator, SprintFacesServices, FacesServices {

    @Inject
    TarjetaServices tarjetaServices;

 public void save(Tarjeta tarjeta) {
   Optional<Tarjeta> tarjetaSaved = tarjetaServices.save(tarjeta);
            if (!tarjetaSaved.isPresent()) {

                FacesUtil.warningDialog(rf.fromCore("warning.warning"), rf.fromCore("warning.save"));

            } else {
                tarjeta.setIdtarjeta(tarjetaSaved.get().getIdtarjeta());
}
}

  public String nextProgreso(Tarjeta tarjeta) {
 Tarjeta tarjetaDB = tarjetaServices.findByIdtarjetaIdproyecto(tarjeta.getIdtarjeta(), proyectoSelected.getIdproyecto()).get();
}

Colecciones dinámicas con jmoordbcore y MongoDB solo para embebido

aristides villarreal — Thu, 16 May 2024 17:18:11 +0000

A partir de Jmoordbcore 1.3.0 es posible generar de manera dinámica colecciones en MongoDB.

No aplica para entidades que utilizan referencias.

Sin especificar el nombre de base de datos o colección, se toma la información del archivo microprofile-config.properties.


#-- Database
mongodb.database=accreditation
mongodb.database1=sft
mongodb.database2=practicadb

En el controller se realiza.


@Path("icono")
@RolesAllowed({"admin"})
public class IconoController {

    @Inject
    IconoRepository iconoRepository;


 @POST

 @RolesAllowed({"admin"})
 public Response save(
            @RequestBody(description = "Crea un nuevo icono.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Icono.class))) Icono icono) {
   Optional<Icono> iconoOptional = iconoRepository.save(icono);
        if (iconoOptional.isPresent()) {
            saveHistory(icono);
            return Response.status(201).entity(iconoOptional.get()).build();
        } else {
            return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }

}

Agregando un nombre de base de datos y colección

Solo tiene que utilizar el método setDynamicCollection().


@Path("icono")
@RolesAllowed({"admin"})
public class IconoController {

   @Inject
   IconoRepository iconoRepository;


 @POST

 @RolesAllowed({"admin"})
 public Response save(
            @RequestBody(description = "Crea un nuevo icono.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Icono.class))) Icono icono) {
    iconoRepository.setDynamicDatabase("database2");
    iconoRepository.setDynamicCollection("icono_2");
    Optional<Icono> iconoOptional = iconoRepository.save(icono);
        if (iconoOptional.isPresent()) {
            saveHistory(icono);
            return Response.status(201).entity(iconoOptional.get()).build();
        } else {
            return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }

}

Bases de datos dinámicas con jmoordbcore y MongoDB solo para embebido

aristides villarreal — Thu, 09 May 2024 19:03:22 +0000

La nueva versión de jmoordbcore, soporte especificar el nombre de la base de datos en tiempo de ejecución.

No aplica para entidades que utilizan referencias.

Agregue a su proyecto


 <properties>
   <version.jmoordbcore>1.1.0</version.jmoordbcore> 
 </properties>

<dependency>
  <groupId>com.github.avbravo</groupId>
  <artifactId>jmoordb-core</artifactId>
  <version>${version.jmoordbcore}</version>
</dependency>

<repositories>
 <repository>
    <id>jitpack.io</id>
    <url>https://jitpack.io</url>
  </repository>
</repositories>

Como recordaremos cuando se crea un proyecto que utilice Jmoordbcore se configura en el archivo microprofile-config.properties las propiedades de conexión y bases de datos.

mongodb.uri=mongodb://localhost:27017
#-- Database de configuración
mongodb.jmoordb= configurationjmoordbdb

#-- Database History
mongodb.databasehistory=historydb

#-- Database
mongodb.database=accreditation
mongodb.database1=sft
mongodb.database2=practicadb

Se define una entidad en el paquete model

@Entity
public class Icono {
@Id(autogeneratedActive = AutogeneratedActive.ON)
private Long idicono;
@Column
private String icono;

// set/get constructores
}

Se define un repositorio en el paquete repository

@Repository(entity = Icono.class)
public interface IconoRepository extends CrudRepository<Icono, Long> {

    @Find
    public Optional<Icono> findByIcono(String icono);

    @Lookup
    public List<Icono> lookup(Search search);

    @Count()
    public Long count(Search... search);

       @CountLikeBy(caseSensitive = CaseSensitive.NO, likeByType = LikeByType.ANYWHERE)
    public Long countLikeByIcono(String icono);

    @LikeBy(caseSensitive = CaseSensitive.NO, typeOrder = TypeOrder.ASC, likeByType = LikeByType.ANYWHERE)
    public List<Icono> likeByIcono(String icono);

}

Creamos un endpoint mediante

@Path("icono")
@Tag(name = "Información del icono", description = "End-point para entidad Icono")
@RolesAllowed({"admin"})
public class IconoController {


    // <editor-fold defaultstate="collapsed" desc="Inject">
    @Inject
    IconoRepository iconoRepository;

      @Inject
HistoryRepository historyRepository;


// </editor-fold>


    // <editor-fold defaultstate="collapsed" desc="findAll">
    @GET
    @RolesAllowed({"admin"})
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Icono> findAll() {

        return iconoRepository.findAll();
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Icono findByIdicono">
    @GET
    @RolesAllowed({"admin"})
    @Path("{idicono}")
    public Icono findByIdicono(
            @Parameter(description = "El idicono", required = true, example = "1", schema = @Schema(type = SchemaType.NUMBER)) @PathParam("idicono") Long idicono) {



        return iconoRepository.findByPk(idicono).orElseThrow(
                () -> new WebApplicationException("No hay icono con idicono " + idicono, Response.Status.NOT_FOUND));

    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Icono findByIcononame">
    @GET
    @RolesAllowed({"admin"})
    @Path("icononame")


    public Icono findByIcono(@Parameter(description = "El icononame", required = true, example = "1", schema = @Schema(type = SchemaType.STRING)) @QueryParam("icono") final String icono) {



        return iconoRepository.findByIcono(icono).orElseThrow(
                () -> new WebApplicationException("No hay icono con icono " + icono, Response.Status.NOT_FOUND));

    }
//// </editor-fold>
// <editor-fold defaultstate="collapsed" desc="List<Icono> lookup(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size)">

    @GET
    @Path("lookup")
    @RolesAllowed({"admin"})

    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Icono> lookup(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size) {
        List<Icono> suggestions = new ArrayList<>();
        try {

        Search search = DocumentUtil.convertForLookup(filter, sort, page, size);
        suggestions = iconoRepository.lookup(search);

        } catch (Exception e) {

          MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return suggestions;
    }

    // </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Response save">
    @POST
    @RolesAllowed({"admin"})
    public Response save(
            @RequestBody(description = "Crea un nuevo icono.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Icono.class))) Icono icono) {
iconoRepository.setDynamicDatabase("database1");
  Optional<Icono> iconoOptional=iconoRepository.save(icono);
        if(iconoOptional.isPresent()){
            saveHistory(icono);
               return Response.status(201).entity(iconoOptional.get()).build();
        }else{
              return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="Response update">

    @PUT
    @RolesAllowed({"admin"})
    public Response update(
            @RequestBody(description = "Crea un nuevo icono.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Icono.class))) Icono icono) {


         if(iconoRepository.update(icono)){
             saveHistory(icono);
               return Response.status(201).entity(icono).build();
        }else{
              return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }
// </editor-fold>

    // <editor-fold defaultstate="collapsed" desc="Response delete">
    @DELETE
    @RolesAllowed({"admin"})
    @Path("{idicono}")
    public Response delete(
            @Parameter(description = "El elemento idicono", required = true, example = "1", schema = @Schema(type = SchemaType.NUMBER)) @PathParam("idicono") Long idicono) {
        if(iconoRepository.deleteByPk(idicono) ==0L){
              return Response.status(201).entity(Boolean.TRUE).build();
        }else{
            return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }
    // </editor-fold>

     // <editor-fold defaultstate="collapsed" desc="Long count(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size)">

    @GET
    @Path("count")
    @RolesAllowed({"admin"})


    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public Long count(@QueryParam("filter") String filter, @QueryParam("sort") String sort, @QueryParam("page") Integer page, @QueryParam("size") Integer size) {
       Long result = 0L;
        try {

        Search search = DocumentUtil.convertForLookup(filter, sort, page, size);
        result = iconoRepository.count(search);

        } catch (Exception e) {

          MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return result;
    }

    // </editor-fold>
     // <editor-fold defaultstate="collapsed" desc="private void saveHistory(Icono icono)">

    private void saveHistory(Icono icono){
        try {
                History history = new History.Builder()                 
               .collection("icono")
                    .idcollection(icono.getIdicono().toString())
                                .database("accreditation")
                    .data(icono.toString())
                    .actionHistory(icono.getActionHistory().get(icono.getActionHistory().size()-1)                  )
                     .build();
            historyRepository.save(history);
        } catch (Exception e) {
           ConsoleUtil.error("saveHistory() "+e.getLocalizedMessage());
        }
    }


// </editor-fold>



         // <editor-fold defaultstate="collapsed" desc="Long countLikeByRole(@QueryParam("role") String role)">
    @GET
    @Path("countlikebyicono")
    @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public Long countLikeByIcono(@QueryParam("icono") String icono) {
        Long result = 0L;
        try {


            result = iconoRepository.countLikeByIcono(icono);

        } catch (Exception e) {

            MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return result;
    }

    // </editor-fold>
      // <editor-fold defaultstate="collapsed" desc="List<Role> likeByRole(@QueryParam("role") String role)">

    @GET
    @Path("likebyicono")
    @RolesAllowed({"admin"})
     @Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Icono> likeByIcono(@QueryParam("icono") String icono) {
        List<Icono> suggestions = new ArrayList<>();
        try {


        suggestions = iconoRepository.likeByIcono(icono);

        } catch (Exception e) {

          MessagesUtil.error(MessagesUtil.nameOfClassAndMethod() + "error: " + e.getLocalizedMessage());
        }

        return suggestions;
    }

    // </editor-fold>
}

Cuando se compila la aplicación se genera el código necesario para interactuar desde nuestra aplicación Java con MongoDB.

Cuando deseamos que el nombre de la base de datos no se tome del archivo microprofile-config.properties, podemos definirlo mediante el método .setDynamicDatabase("database"); del repositorio, que asignara el nombre de la base de datos que se pasa como parámetros y tendrá precedencia sobre el archivo de configuración. Tenga presente que se debe asignar a cada método para que sea funcional.

    @POST
    @RolesAllowed({"admin"})
    public Response save(
            @RequestBody(description = "Crea un nuevo icono.", content = @Content(mediaType = "application/json", schema = @Schema(implementation = Icono.class))) Icono icono) {
        iconoRepository.setDynamicDatabase("database1");
        Optional<Icono> iconoOptional = iconoRepository.save(icono);
        if (iconoOptional.isPresent()) {
            saveHistory(icono);
            return Response.status(201).entity(iconoOptional.get()).build();
        } else {
            return Response.status(400).entity("Error " + iconoRepository.getJmoordbException().getLocalizedMessage()).build();
        }
    }

Método para buscar todos los documentos se asigna la base de datos.

@GET
@RolesAllowed({"admin"})
@Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Icono> findAll() {
         iconoRepository.setDynamicDatabase("database1");
        return iconoRepository.findAll();
    }

Por el contrario si no se coloca se tomara la base de datos del archivo de configuración.

@GET
@RolesAllowed({"admin"})
@Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON})

    public List<Icono> findAll() {
       //  iconoRepository.setDynamicDatabase("database1");
        return iconoRepository.findAll();
    }

Utilizar iconos css.gg con Primefaces

aristides villarreal — Thu, 25 Apr 2024 18:52:56 +0000

Iconos CSS gratis

Descargar Iconos

wget https://unpkg.com/css.gg/icons/icons.css

Copiarlo a la carpeta resources/css

resources/css/icons.css

Agregarlo al template.xhtml

  <h:outputStylesheet name="iconos.css" library="css"/>

En las paginas que se desea incluir

        <i class="gg-apple-watch"></i>

Agregarlo a los componentes

  <p:commandButton id="leftMenuCommandButtonProyectos" iconPos="right" value="  " title="#{msg['menubar.proyectos']}"                                       icon="gg-apple-watch"/>

Para revisar como se usa de clic en el icono deseado

https://css.gg/app

Converter de Documentos Embebidos con primefaces+ JmoordbCore

aristides villarreal — Wed, 24 Apr 2024 14:23:26 +0000

En algunas ocasiones necesitamos crear converter para una lista de documentos embebidos.
El documento almacenado en MongoDB contiene la siguiente información:

{
  "_id" : ObjectId("6620299468e7bc6f78711eb8"),
  "actionHistory" : [{
      "fecha" : ISODate("2024-04-18T15:53:56.458Z"),
      "iduser" : NumberLong(8),
      "evento" : "editar",
      "clase" : "ClienteFaces",
      "metodo" : "edit"
    }, {
      "fecha" : ISODate("2024-04-19T17:25:09.473Z"),
      "iduser" : NumberLong(75),
      "evento" : "editar",
      "clase" : "ClienteFaces",
      "metodo" : "edit"
    }, {
      "fecha" : ISODate("2024-04-24T14:28:01.956Z"),
      "iduser" : NumberLong(8),
      "evento" : "editar",
      "clase" : "ClienteFaces",
      "metodo" : "edit"
    }],
  "active" : true,
  "cedularuc" : "14575222222222222222222222",
  "celular" : "8585",
  "direccion" : "La Villa de los Santos",
  "dv" : "85",
  "email" : "avb@gmail.com",
  "fax" : "adad",
  "gobierno" : false,
  "idcliente" : NumberLong(28),
  "name" : "Empresas D",
  "observacion" : "No se que mas hacer",
  "representante" : [{
      "cedula" : "8585",
      "nombre" : "juan perez",
      "dv" : "80",
      "telefono" : "djdjd",
      "email" : "ad@gmail.com",
      "active" : true
    }, {
      "cedula" : "6-9-6",
      "nombre" : "LUISA GONZALEZ",
      "dv" : "14",
      "telefono" : "966-96",
      "email" : "s@gmail.com",
      "active" : true
    }],
  "sede" : [{
      "idsede" : "A91845E7-70EA-40D7-9174-5FEF091D87B4",
      "nombre" : "LS",
      "direccion" : "Los Santos",
      "telefono" : "9685",
      "email" : "ls@gmail.com",
      "active" : true
    }, {
      "idsede" : "90C77A6C-CFAA-4507-95B9-F6800929654F",
      "nombre" : "CHITRE",
      "direccion" : "Barriada x-",
      "telefono" : "7855",
      "email" : "re@gmail.com",
      "active" : true
    }, {
      "idsede" : "634ED82C-4753-4A2A-85D2-03DD6BC80E02",
      "nombre" : "PEDASI",
      "direccion" : "PEDASI, LOS SANTOS",
      "telefono" : "96978555",
      "email" : "a@gmai.com",
      "active" : true
    }],
  "telefono" : "98755",
  "tipocliente" : "Juridico"
}

Por ejemplo contamos con esta entidad

@Entity
public class Cliente {
      @Id(autogeneratedActive = AutogeneratedActive.ON)
    private Long idcliente;
    @Column(generateQuery = true)
    private String cedularuc;

    @Column(commentary = "natural/juridico", generateQuery = true)
    private String tipocliente;
    @Column
    private String dv;
    @Column(generateQuery = true)
    private String name;
    @Embedded
    private List<Sede> sede;

    @Embedded
    private List<Representante> representante;

    @Column
    private String direccion;
    @Column
    private String telefono;
    @Column
    private String celular;

    @Column
    private String fax;


    @Column
    private String email;
    @Column
    private String observacion;


    @Column
    private Boolean gobierno;

    @Column
    private Boolean active;


    @Embedded
    List<ActionHistory> actionHistory;
...
}

Sede

@DocumentEmbeddable
public class Sede {

    @Column
    private String idsede;
    @Column
    private String nombre;
    @Column
    private String direccion;
    @Column
    private String telefono;
    @Column
    private String email;
    @Column
    private Boolean active;
...
}

Representante

@DocumentEmbeddable
public class Representante {

    @Ignore
    private Long id;
    @Column
    private String cedula;
    @Column
    private String nombre;
    @Column
    private String dv;
    @Column
    private String telefono;
    @Column
    private String email;
    @Column
    private Boolean active;
...
}

Imaginemos que contamos con un formulario en el cual se necesita seleccionar de una lista de los embebidos Sede, Representante, mediante selectOneMenu, necesitaremos crear converter para estos elementos.

Para ello debemos almacenar la lista obtenida

En el autocomplete que selecciona el cliente invocamos al método autocompleteSelectedEventCliente.

<p:autoComplete id="autocompletecliente" multiple="false" 
        value="#{proyectoFaces.clienteSelectedAutocomplete}"
        completeMethod="#{proyectoFaces.completeCliente}"
        var="cliente" itemLabel="#{cliente.name}  #{cliente.cedularuc}" 
        itemValue="#{cliente}"
        forceSelection="true"
        title="#{msg['autocomplete.minimo3caracteres']}"
        dropdown="true"
        minQueryLength="3"
        scrollHeight="250"
        converter="#{clienteConverter}"
        >
    <p:column>
        <h:outputText style="vertical-align: middle; margin-left: .5rem" value="#{cliente.name} - #{cliente.cedularuc}"/>
    </p:column>
    <p:ajax event="itemSelect"  
            listener="#{proyectoFaces.autocompleteSelectedEventCliente}"  
            update=":form:growl, autocompletecliente, outputPanelCliente" />  
    <p:ajax event="itemUnselect"  process="@this"
            listener="#{proyectoFaces.autocompleteUnselectListener}" 
            update=":form:growl, autocompletecliente, outputPanelCliente" />
</p:autoComplete>

Este método almacena en JmoordbCoreContext.put("sedeConverter", clienteSelectedAutocomplete.getSede()); la lista de las sedes que serán usadas en el converter.

 public void autocompleteSelectedEventCliente(SelectEvent<Cliente> event) {
        try {

            clienteSelectedAutocomplete.getIdcliente();
            proyectoSelected.setCliente(clienteSelectedAutocomplete);
            /**
             * Alamacena los valores para usar en el converter del valor
             * embebido
             */
            if (isJuridico(clienteSelectedAutocomplete)) {
                JmoordbCoreContext.put("sedeConverter", clienteSelectedAutocomplete.getSede());
                JmoordbCoreContext.put("representanteConverter", clienteSelectedAutocomplete.getRepresentante());
            }

            if (buttonNewPressed) {
                proyectoSelected.setProyecto(rf.fromMessage("label.proyectode") + ": " + clienteSelectedAutocomplete.getName());
                proyectoSelected.setDescripcion(rf.fromMessage("label.descripcionde") + ": " + clienteSelectedAutocomplete.getName());
                proyectoSelected.setDireccion(clienteSelectedAutocomplete.getDireccion());
                proyectoSelected.setTelefono(clienteSelectedAutocomplete.getTelefono());
                proyectoSelected.setEmail(clienteSelectedAutocomplete.getEmail());
                proyectoSelected.setFax(clienteSelectedAutocomplete.getFax());
                proyectoSelected.setTipocliente(clienteSelectedAutocomplete.getTipocliente());
            } else {

            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
    }// </editor-fold>

Defina el converter

import com.avbravo.jmoordbutils.ConsoleUtil;
import com.avbravo.jmoordbutils.FacesUtil;
import com.avbravo.jmoordbutils.JmoordbCoreContext;
import com.nerys.converter.services.IconoConverterServices;
import com.nerys.model.Sede;
import jakarta.faces.application.FacesMessage;
import jakarta.faces.component.UIComponent;
import jakarta.faces.context.FacesContext;
import jakarta.faces.convert.Converter;
import jakarta.faces.convert.ConverterException;
import jakarta.faces.convert.FacesConverter;
import jakarta.inject.Inject;
import jakarta.inject.Named;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

/**
 *
 * @author avbravo
 */

@Named
@FacesConverter(forClass = Sede.class, managed = true)
public class SedeConverter implements Converter<Sede> {

    @Inject
    IconoConverterServices iconoConverterServices;

    @Override
    public String getAsString(FacesContext fc, UIComponent uic, Sede t) {
        try {

            if (t == null) {

                return "";
            }

            if (t.getIdsede()!= null) {

                return t.getIdsede().toString();
            } else {

            }
        } catch (Exception e) {

            new FacesMessage("Error en converter  " + e.getLocalizedMessage());
        }

        return "";
    }

    @Override
    public Sede getAsObject(FacesContext fc, UIComponent uic, String submittedValue) {
      Sede a = new Sede();
        if (submittedValue == null || submittedValue.isEmpty()) {
            return null;
        }

        try {
            Optional<Sede> optional =Optional.empty();
            List<Sede> sedes = (ArrayList<Sede>)JmoordbCoreContext.get("sedeConverter");
            if(sedes == null || sedes.isEmpty()){

            }else{
                for(Sede s:sedes){
                    if(s.getIdsede().equals(submittedValue)){
                       optional = Optional.of(s);
                    }
                }

           }            

            if (!optional.isEmpty()) {

               return optional.get();
            }

        } catch (Exception e) {


            ConsoleUtil.error("\t " + FacesUtil.nameOfClassAndMethod() + " submittedValue " + submittedValue);

            throw new ConverterException(new FacesMessage(submittedValue + " is not a valid selecction from Converter"), e);
        }
        return a;
    }



}

Ahora en el formulario xthtml

<p:selectOneMenu  
       value="#{proyectoFaces.proyectoSelected.sede}"
      var="item" autoWidth="false">
    <f:selectItems 
           value="#{proyectoFaces.clienteSelectedAutocomplete.sede}"  
           var="item" 
           itemLabel="#{item.nombre}"
           itemValue="#{item}" />
    <p:column> #{item.nombre} 
    </p:column>


</p:selectOneMenu>

Con este proceso se realiza la conversión al valor deseado.

Optimizando Converter con Primefaces selectOneMenu y Autocomplete

aristides villarreal — Fri, 12 Jan 2024 14:58:40 +0000

Para optimizar los converter cuando utilizamos componentes como podemos recurrir a crear un services que contenga la lista de objetos a utilizar y hacemos la conversión buscando en esa lista en lugar de realizar una consulta al microservicios que devuelve el resultado, esto mejora el desempeño de la aplicación y reduce la cantidad de peticiones al microservicio.

Converter

El Converter lo usaremos para selectOneMenu y Autocomplete de Primefaces. Por lo tanto recibirá una lista de objetos delimitados por la cantidad máxima que se especifique en la variable de configuración en el archivo microprofile-config.properties denominada: #-- converter

converter.max.number.of.elements =25

Como valor predeterminado serán 25 elementos. Para evitar cargar listas muy grandes.
Cuando se realiza una selección en un selectOneMenu o Autocomplete de un elemento que excede los 25 se buscara en el microservicio, en caso contrario se buscara en la lista almacenada en la memoria.

Crear el Services

@ViewScoped
@Named
public class TipoTarjetaConverterServices implements Serializable {

    @Inject
    TipotarjetaServices tipotarjetaServices;

    List<Tipotarjeta> tipotarjetas = new ArrayList<>();

    public List<Tipotarjeta> getTipotarjetas() {
        return tipotarjetas;
    }

    public void setTipotarjetas(List<Tipotarjeta> tipotarjetas) {
        this.tipotarjetas = tipotarjetas;
    }

    // <editor-fold defaultstate="collapsed" desc="Optional<Tipotarjeta> get(Long id)">
    public Optional<Tipotarjeta> get(Long id) {
        Optional<Tipotarjeta> result;

        try {

            result = tipotarjetas.stream().filter(x -> x.getIdtipotarjeta().equals(id)).findFirst();
            if (!result.isPresent()) {
                Tipotarjeta tipotarjeta = tipotarjetaServices.findByIdtipotarjeta(id);
                if (tipotarjeta != null) {
tipotarjetas.add(tipotarjeta);
                    return Optional.of(tipotarjeta);
                }
                result = Optional.empty();
            }
            return result;
        } catch (Exception e) {

            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return Optional.empty();

    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="void add(List<Tipotarjeta> tipotarjetas)">

    public void add(List<Tipotarjeta> tipotarjetas) {
        try {
            destroyed();
            this.tipotarjetas = tipotarjetas;

        } catch (Exception e) {

            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

    }
// </editor-fold>

// <editor-fold defaultstate="collapsed" desc="void destroyed()">
    public void destroyed() {
        try {
            this.tipotarjetas = new ArrayList<>();
        } catch (Exception e) {

            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

    }
// </editor-fold>

}

Crear el Converter

@Named
@FacesConverter(forClass = Tipotarjeta.class, managed = true)
public class TipotarjetaConverter implements Converter<Tipotarjeta> {

    @Inject
    TipoTarjetaConverterServices tipoTarjetaConverterServices;

    // <editor-fold defaultstate="collapsed" desc="String getAsString(FacesContext fc, UIComponent uic, Tipotarjeta t)">
    @Override
    public String getAsString(FacesContext fc, UIComponent uic, Tipotarjeta t) {
        try {
            if (t == null) {
                return "";
           }
            if (t.getIdtipotarjeta() != null) {
                return t.getIdtipotarjeta().toString();
            }
        } catch (Exception e) {
            new FacesMessage("Error en converter  " + e.getLocalizedMessage());
        }
        return "";
    }
    // </editor-fold>
// <editor-fold defaultstate="collapsed" desc="Tipotarjeta getAsObject(FacesContext fc, UIComponent uic, String submittedValue)">

    @Override
    public Tipotarjeta getAsObject(FacesContext fc, UIComponent uic, String submittedValue) {
        Tipotarjeta result = new Tipotarjeta();
        if (submittedValue == null || submittedValue.isEmpty()) {
            return null;
        }

        try {
            Integer id = Integer.parseInt(submittedValue);
            Long idTipotarjeta = id.longValue();
            Optional<Tipotarjeta> optional = tipoTarjetaConverterServices.get(idTipotarjeta);
            if (optional.isPresent()) {
                result = optional.get();
            }
            return result;
        } catch (Exception e) {

            System.out.println("====================");
            System.out.println(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
            ConsoleUtil.test("\t " + FacesUtil.nameOfClassAndMethod() + " submittedValue " + submittedValue);
            System.out.println("====================");
            throw new ConverterException(new FacesMessage(submittedValue + " is not a valid selecction from Converter"), e);
        }
    }
// </editor-fold>
}

SelectOneMenu

Para el selectOneMenu se pasa la lista completa al services.

En la clase Faces

Necesita agregar en su clase

    // # Converter
     @Inject
    private Config config;

     @Inject
    @ConfigProperty(name = "converter.max.number.of.elements")
    private Provider<Integer> converterMaxNumberOfElements;

@Inject
TipoTarjetaConverterServices tipoTarjetaConverterServices;
/**
 * invoca al método para cargar la lista en el ConverterServices
 */
    @PostConstruct
    public void init() {
        try {
 loadTipotarjetaByProyecto(proyectoSelected);

 } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

}

/**
Carga la lista de tipotarjeta en el ConverterServices
*/
private void loadTipotarjetaByProyecto(Proyecto proyecto) {
        try {
          tipoTarjetaConverterServices.add(tipotarjetaServices.loadTipotarjetaByProyecto(proyecto))
            );

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
    }
/**

/**
 * Limpia la lista
 */
@PreDestroy
public void preDestroy() {
  tipoTarjetaConverterServices.destroyed();
}

En las paginas xhtml


 <p:selectOneMenu  value="#{tableroFaces.tarjetaSelected.tipotarjeta}" 
var="item">

<f:selectItems value="#{tipoTarjetaConverterServices.tipotarjetas}" 
 var="item" 
 itemLabel="#{item.tipotarjeta}"                                                    itemValue="#{item}"

 />
<p:column>
<i class="#{item.tipotarjeta}" /> #{item.tipotarjeta} 
</p:column>


</p:selectOneMenu>

Autocomplete

Pasamos el máximo de registros permitidos que se configuraron en el archivo microprofile-config.properties. Mediante el método:

calcularConverterMaxNumberOfElements(result.size(),converterMaxNumberOfElements.get())

  // <editor-fold defaultstate="collapsed" desc="List<Tipotarjeta> completeTipotarjeta(String query)">
    public List<Tipotarjeta> completeTipotarjeta(String query) {

        List<Tipotarjeta> result = new ArrayList<>();
        try {
            query = query.trim();
            result = tipotarjetaServices.likeByTipotarjeta(query);

            tipoTarjetaConverterServices.add(result.subList(0,                     
                    calcularConverterMaxNumberOfElements(result.size(),converterMaxNumberOfElements.get()))
            );
        } catch (Exception e) {

            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

        return result;
    }

En la pagina xhtml


 <p:autoComplete id="tipotarjeta" 
  multiple="false"
  value="#{tipoTarjetaFaces.tipotarjetaSelectedAutocomplete}"

  completeMethod="#{tipoTarjetaFaces.completeTipotarjeta}"

  var="tipotarjeta"
  itemLabel="#{tipotarjeta.tipotarjeta}" 

  itemValue="#{tipotarjeta}"

   forceSelection="true"

  title="#{msg['autocomplete.minimo3caracteres']}"

  dropdown="true"

  minQueryLength="3"

  scrollHeight="250"

  converter="#{tipotarjetaConverter}"
>

<p:column>
    <h:outputText style="vertical-align: middle; margin-left: .5rem" value="#{tipotarjeta.tipotarjeta} - #{tipotarjeta.grupoTipoTarjeta.grupoTipoTarjeta}"/>
</p:column>

<p:ajax event="itemSelect"  
  listener="#{tipoTarjetaFaces.autocompleteSelectedEvent}"  
  update=":form:growl, tipotarjeta, dataTable" />  

<p:ajax event="itemUnselect" 
  process="@this" 
  listener="#{tipoTarjetaFaces.autocompleteUnselectListener}" 

 update=":form:growl, tipotarjeta, dataTable"
 />
 </p:autoComplete>

Notificaciones personalizadas con WebSocket

aristides villarreal — Fri, 15 Dec 2023 14:47:28 +0000

En algunas ocasiones necesitamos enviar notificaciones personalizadas a usuarios específicos para indicarles que ha ocurrido una opción o de manera automática actualizar algún componente tal como un tablero, por ejemplo.

Para utilizar WebSocket en nuestras aplicaciones Jakarta EE, seguimos los siguientes pasos:

Configurar el archivo web.xml


<context-param>
 <param-name>jakarta.faces.ENABLE_CDI_RESOLVER_CHAIN</param-name>
     <param-value>true</param-value>
</context-param>
<context-param>
 <param-name>jakarta.faces.ENABLE_WEBSOCKET_ENDPOINT</param-name>
   <param-value>true</param-value>
</context-param>

microprofile-config.properties

En el archivo micropofile-config.properties agregue la propìedad

#------------------------------------
#--WebSocket
#-------------------------------------
websocket.minimums.seconds.for.update=50

En la cual se especifica el tiempo mínimo en minutos en los cuales se debe actualizar el formulario actual , una vez que se invoque el Websocket. Se establece este tiempo para evitar actualizaciones demasiado frecuentes que pueden causar afectaciones en el desempeño.
Si el tiempo es menor que el tiempo establecido, se incrementara el contador de notificaciones pendientes que se mostrara al usuario para que luego pueda dar clic en el botón de notificaciones y se actualice el formulario actual.

Defina la interface

public interface WebSocketPlantilla {

    public void sendMessageAll(String message, String scoped);

    public void sendMessageProyecto(String message, User user);

    public void sendMessageProyectoMultiple(String message, List<UserView> userViewList);


    public void sendMessageSprint(String message, User user);

    public void sendMessageSprintMultiple(String message, List<UserView> userViewList);

    public void sendMessageTablero(String message, User user);

    public void sendMessageTableroMultiple(String message, List<UserView> userViewList);

    public void sendMessageBacklog(String message, User user);

    public void sendMessageBacklogMultiple(String message, List<UserView> userViewList);

    public void sendMessagePapeleraReciclaje(String message, User user);

    public void sendMessagePapeleraReciclajeMultiple(String message, List<UserView> userViewList);

    public void sendMessagePanelTrabajo(String message, User user);

    public void sendMessagePanelTrabajoMultiple(String message, List<UserView> userViewList);

    public Collection<Long> collectionOfUserList(List<UserView> userList);
}

Cree la clase

@ViewScoped
@Named
public class WebSocketController implements Serializable, WebSocketPlantilla {

    @Inject
    @Push
    private PushContext proyectoChannel;

    @Inject
    @Push
    private PushContext proyChannel;

    @Inject
    @Push
    private PushContext sprintChannel;

    @Inject
    @Push
    private PushContext tableroChannel;

    @Inject
    @Push
    private PushContext backlogChannel;

    @Inject
    @Push
    private PushContext panelTrabajoChannel;

    @Inject
    @Push
    private PushContext papeleraReciclajeChannel;

    @Inject
    @Push
    PushContext allChannel;

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageProyecto(String message, User user) {
        proyectoChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userViewList
     */
    @Override
    public void sendMessageProyectoMultiple(String message, List<UserView> userViewList) {
        proyectoChannel.send(message, collectionOfUserList(userViewList));
    }

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageSprint(String message, User user) {
        sprintChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userViewList
     */
    @Override
    public void sendMessageSprintMultiple(String message, List<UserView> userViewList) {

        sprintChannel.send(message, collectionOfUserList(userViewList));
    }

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageTablero(String message, User user) {

        tableroChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userViewList
     */
    @Override
    public void sendMessageTableroMultiple(String message, List<UserView> userViewList) {

        tableroChannel.send(message, collectionOfUserList(userViewList));
    }

    @Override
    public void sendMessageAll(String message, String scoped) {
        allChannel.send(message, "user");
    }



    @Override
    public void sendMessageBacklog(String message, User user) {
    backlogChannel.send(message, user.getIduser());
    }

    @Override
    public void sendMessageBacklogMultiple(String message, List<UserView> userViewList) {
    backlogChannel.send(message, collectionOfUserList(userViewList));
    }

    @Override
    public void sendMessagePapeleraReciclaje(String message, User user) {
         papeleraReciclajeChannel.send(message, user.getIduser());
    }

    @Override
    public void sendMessagePapeleraReciclajeMultiple(String message, List<UserView> userViewList) {
     papeleraReciclajeChannel.send(message, collectionOfUserList(userViewList));
    }

    @Override
    public void sendMessagePanelTrabajo(String message, User user) {
         panelTrabajoChannel.send(message, user.getIduser());
    }

    @Override
    public void sendMessagePanelTrabajoMultiple(String message, List<UserView> userViewList) {
     panelTrabajoChannel.send(message, collectionOfUserList(userViewList));
    }



     @Override
    public Collection<Long> collectionOfUserList(List<UserView> userViewList) {
        Collection<Long> result = new ArrayList<>();
        try {
            userViewList.forEach(u -> {
                result.add(u.getIduser());
            });
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    public Collection<Long> collectionOfProyectoList(List<Proyecto> proyectoList) {
        Collection<Long> result = new ArrayList<>();
        try {
            proyectoList.forEach(u -> {
                result.add(u.getIdproyecto());
            });
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
}

Crear la interface FacesWebSocket


public interface FacesWebSocket {

public String refreshFromWebsocket();

public String updateForRemoteWebsocket();

public void sendMensajesWebsocket(MessageWebSocket messageWebSocket,Tarjeta tarjeta, Boolean exclude);


public void sendMensajesWebsocket(MessageWebSocket messageWebSocket);

public void onCompleteWebSocket();

    /**
     *
     * @param userViewProjectoSelectedForWebSocketList
     * @param tarjeta
     * @return La lista de userView para ser usada en el envio de WebSocket.
     * Verifica si es una tarjeta foranea y agrega el usuario.
     */
 public default List<UserView> filterUserViewListForWebSocket(List<UserView> userViewProjectoSelectedForWebSocketList, Tarjeta tarjeta) {
        List<UserView> result = new ArrayList<>();
        try {
            result.addAll(userViewProjectoSelectedForWebSocketList);
            /**
             * si es una tarjeta foranea agrega el usuario
             */
            if (tarjeta.getForeaneo()) {
                UserView uv = tarjeta.getUserView().get(0);

                Optional<UserView> userViewOptional = result.stream().filter(x -> x.getIduser().equals(uv.getIduser())).findFirst();
                if (!userViewOptional.isPresent()) {

                    result.add(uv);
                }
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

        return result;
    }

    // <editor-fold defaultstate="collapsed" desc="List<UserView> filterUserViewListForWebSocket(List<UserView> userViewProjectoSelectedForWebSocketList) {">
    public default List<UserView> filterUserViewListForWebSocket(List<UserView> userViewProjectoSelectedForWebSocketList) {
        List<UserView> result = new ArrayList<>();
        try {
            result.addAll(userViewProjectoSelectedForWebSocketList);

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
// </editor-fold>
    // <editor-fold defaultstate="collapsed" desc="List<UserView> userViewFromProjectExclude(Proyecto proyectoSelected, Boolean exclude, User... excludeUser)">

    /**
     *
     * @param proyectoSelected
     * @return Obtiene la lista de userView del proyecto
     */
    public default List<UserView> userViewFromProjectExclude(Proyecto proyectoSelected, Boolean exclude, User... excludeUser) {
        List<UserView> result = new ArrayList<>();
        try {
            Long iduser = 0l;
            if (excludeUser.length != 0) {
                iduser = excludeUser[0].getIduser();
                for (ProyectoMiembro pm : proyectoSelected.getProyectoMiembro()) {
                    if (exclude) {
                        if (iduser.equals(pm.getUserView().getIduser())) {
                        } else {
                            result.add(pm.getUserView());
                        }
                    } else {
                        result.add(pm.getUserView());
                    }

                }
            } else {
                proyectoSelected.getProyectoMiembro().forEach(pm -> {
                    result.add(pm.getUserView());
                });
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>   
    // <editor-fold defaultstate="collapsed" desc="List<UserView> userViewFromProjectExcludeIncludeOldUser(Proyecto proyectoSelected, List<ProyectoMiembro> proyectoMiembroOldList, Boolean exclude, User... excludeUser)">
    /**
     *
     * @param proyectoSelected
     * @return Obtiene la lista de userView del proyecto
     */
    public default List<UserView> userViewFromProjectExcludeIncludeOldUser(Proyecto proyectoSelected, List<ProyectoMiembro> proyectoMiembroOldList, Boolean exclude, User... excludeUser) {
        List<UserView> result = new ArrayList<>();
        try {
            List<ProyectoMiembro> proyectoMiembroList = new ArrayList<>();
            proyectoMiembroList.addAll(proyectoSelected.getProyectoMiembro());

            proyectoMiembroOldList.forEach(pm -> {
                Optional<ProyectoMiembro> proyectoMiembroOptional = proyectoSelected.getProyectoMiembro().stream().filter(x -> x.getUserView().getIduser().equals(pm.getUserView().getIduser())).findFirst();
                if (!proyectoMiembroOptional.isPresent()) {
                    proyectoMiembroList.add(pm);
                }
            });
            /*
             */

            Long iduser = 0l;
            if (excludeUser.length != 0) {
                iduser = excludeUser[0].getIduser();
                for (ProyectoMiembro pm : proyectoMiembroList) {
                    if (exclude) {
                        if (iduser.equals(pm.getUserView().getIduser())) {
                        } else {
                            result.add(pm.getUserView());
                        }
                    } else {
                        result.add(pm.getUserView());
                    }

                }
            } else {
                proyectoMiembroList.forEach(pm -> {
                    result.add(pm.getUserView());
                });
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

    // </editor-fold>   
    // <editor-fold defaultstate="collapsed" desc="List<UserView> userViewForWebSocketListFromProjectOfTarjeta(Tarjeta tarjeta, List<Proyecto> proyectoPorColaboradorList, User userLogged)">
    public default List<UserView> userViewForWebSocketListFromProjectOfTarjeta(Tarjeta tarjeta, List<Proyecto> proyectoPorColaboradorList, User userLogged) {
        List<UserView> result = new ArrayList<>();
        try {
            Proyecto proyectoWebSocket = new Proyecto();
            Boolean found = Boolean.FALSE;
            for (Proyecto p : proyectoPorColaboradorList) {
                if (p.getIdproyecto().equals(tarjeta.getIdproyecto())) {
                    proyectoWebSocket = p;
                    found = Boolean.TRUE;
                    break;
                }
            }
            if (found) {
                result = userViewFromProjectExclude(proyectoWebSocket, Boolean.FALSE, userLogged);
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
    // </editor-fold>    

    public default String validarEstadoIniciadoYFechaProyecto(Proyecto proyecto, JmoordbResourcesFiles rf) {
        String result = "";
        try {

            if (!proyecto.getEstado().equals("iniciado")) {
               result = rf.fromMessage("warning.proyectoestadonoiniciado");

            }

            if ((JmoordbCoreDateUtil.fechaIgual(JmoordbCoreDateUtil.getFechaHoraActual(), proyecto.getFechainicial())
                    || JmoordbCoreDateUtil.fechaMayor(JmoordbCoreDateUtil.getFechaHoraActual(), proyecto.getFechainicial()))
                    && (JmoordbCoreDateUtil.fechaIgual(JmoordbCoreDateUtil.getFechaHoraActual(), proyecto.getFechafinal())
                    || JmoordbCoreDateUtil.fechaMenor(JmoordbCoreDateUtil.getFechaHoraActual(), proyecto.getFechafinal()))) {


            } else {
                result = rf.fromMessage("warning.fechasfuerarangoproyecto");

            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }
}

Edite el template.xhtml

Añada funciones Javascript para procesar las respuestas de los Websocket. Se invocaran remoteCommand pasandole los parámetros evento, channel,message.

Estos p:remoteCommand, se deben agregar en cada formulario donde se desea validar el evento.

 <script>
   function handleMessageAllChannel(message, channelName, event) {
        var messageText = message.toString();
        var eventText = event.toString();
        var channelText = channelName.toString();
        remoteCommandWebSocketAll(
                  [
                    {name: 'event', value: eventText},
                    {name: 'channel', value: channelText},
                    {name: 'message', value: messageText}
                  ]);
  }

 function handleMessageProyectoChannel(message, channelName, event) {
       var messageText = message.toString();
       var eventText = event.toString();
       var channelText = channelName.toString();
       remoteCommandWebSocketProyecto(
                [
                 {name: 'event', value: eventText},
                 {name: 'channel', value: channelText},
                 {name: 'message', value: messageText}
                 ]);
            }

 function handleMessageTableroChannel(message, channelName, event) {
      var messageText = message.toString();
      var eventText = event.toString();
      var channelText = channelName.toString();
      remoteCommandWebSocketTablero(
                  [
                    {name: 'event', value: eventText},
                    {name: 'channel', value: channelText},
                    {name: 'message', value: messageText}
                   ]
                 );
           }

function handleMessageSprintChannel(message, channelName, event) {
       var messageText = message.toString();
       var eventText = event.toString();
       var channelText = channelName.toString();
       remoteCommandWebSocketSprint(
                  [
                   {name: 'event', value: eventText},
                   {name: 'channel', value: channelText},
                   {name: 'message', value: messageText}
                   ]);
       }

function handleMessageBacklogChannel(message, channelName, event) {
       var messageText = message.toString();
       var eventText = event.toString();
       var channelText = channelName.toString();
       remoteCommandWebSocketBacklog(
                  [
                   {name: 'event', value: eventText},
                   {name: 'channel', value: channelText},
                   {name: 'message', value: messageText}
                   ]);
      }

function handleMessagePapeleraReciclajeChannel(message, channelName, event) {
        var messageText = message.toString();
        var eventText = event.toString();
        var channelText = channelName.toString();
        remoteCommandWebSocketPapeleraReciclaje(
                [
                  {name: 'event', value: eventText},
                  {name: 'channel', value: channelText},
                  {name: 'message', value: messageText}
                 ]);
  }

function handleMessagePanelTrabajoChannel(message, channelName, event) {
      var messageText = message.toString();
      var eventText = event.toString();
      var channelText = channelName.toString();
      remoteCommandWebSocketPanelTrabajo(
                   [
                     {name: 'event', value: eventText},
                     {name: 'channel', value: channelText},
                     {name: 'message', value: messageText}
                   ]);
   }


function errorListener(code, channel, event) {
    if (code == 1001) {
            //  alert('error 1001 Server shutdwon');

    } else if (code == 1006) {
              //alert('error 1006 ');
              } else {
                    // alert('otro ');

                }

            }
</script>

Añada componentes Websocket, dentro de un componente


 <h:form>        

 <f:websocket channel="allChannel"  user="user" onmessage="handleMessageAllChannel" />

<f:websocket channel="tableroChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessageTableroChannel"
                             onerror="errorListener"/>

 <f:websocket channel="sprintChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessageSprintChannel"
                             onerror="errorListener"/>

 <f:websocket channel="backlogChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessageBacklogChannel" 
                             onerror="errorListener"/>

<f:websocket channel="papeleraReciclajeChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessagePapeleraReciclajeChannel" 
                             onerror="errorListener"/>

<f:websocket channel="panelTrabajoChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessagePanelTrabajoChannel" 
                             onerror="errorListener"/>

<f:websocket channel="proyectoChannel" scope="session"  user="#{loginFaces.userLogged.iduser}" onmessage="handleMessageProyectoChannel" 
                             onerror="errorListener"/>

Añada un p:remoteCommnad para atrapar la acción a realizar con el WebSocket.

<p:remoteCommand name="remoteCommandWebSocketAll" 
action="#{loginFaces.webSocketListenerMethod}" 
 update="template_growl_timesession" 

onerror="errorListener"/>

Edite la Clase Dashboard.java

Agregue los atributos para manejar el WebSocket

// <editor-fold defaultstate="collapsed" desc="WebSocket">

    @Inject
    WebSocketController webSocketController;
    private Boolean dialogVisibleWebSocket = Boolean.FALSE;
    private Boolean dialogVisibleAddWebSocket = Boolean.FALSE;
    private List<UserView> userViewForWebSocketList = new ArrayList<>();
    private Integer contadorNotificacionesWebsocket = 0;
    private Long jmoordbCronometerOld = 0L;

    // </editor-fold>

Leer la cantidad de segundos mínimos establecido en el archivo microprofile-config.properties.


// #Websocket    
    @Inject
    @ConfigProperty(name = "websocket.minimums.seconds.for.update")
    private Provider<Integer> websocketMinimumsSecondsForUpdate;

En el método init()

@PostConstruct
    public void init() {
        try {
            JmoordbCronometer.startCronometer(FacesUtil.nameOfClassAndMethod());
  /**
             * WebSocket
             */
contadorNotificacionesWebsocket = 0;
jmoordbCronometerOld = 0L;
dialogVisibleWebSocket = Boolean.FALSE;
dialogVisibleAddWebSocket = Boolean.FALSE;

...
}

En los métodos prepare

Debe colocar a True el atributo dialogVisibleWebSocket, para que no se actualice si existe un dialogo abierto en que se esta trabajando.
Y Colocar en TRUE al atributo dialogVisibleAddWebSocket solo en el método prepareNew()

public String prepareNew() {
    dialogVisibleWebSocket = Boolean.TRUE;
    dialogVisibleAddWebSocket = Boolean.TRUE;
}

El los demás métodos prepare no se utiliza dialogVisibleAddWebSocket

public String prepareEditar(Proyecto proyecto) {
        try {

            dialogVisibleWebSocket = Boolean.TRUE;
}
}

Recuerde que en cada método que se invoque desde un dialogo debe asignar el valor a False, este proceso se puede simplificar agregándolo al método refresh() que es invocado por todos los métodos.

En el método refresh()


public String refresh() {

     contadorNotificacionesWebsocket = 0;
     dialogVisibleWebSocket = Boolean.FALSE;
    dialogVisibleAddWebSocket = Boolean.FALSE;
}

En el método save()

Vamos a enviar notificaciones mediante Websocket a varios elementos tales como los canales de proyecto, tablero entre otros.
Creamos un objeto de tipo MessageWebSocket. Que esta incluido en la librería jmoordbcoreutilfaces.

public void save(Proyecto proyecto) {

 /**
  * WebSocket
 */
userViewForWebSocketList = userViewFromProjectExclude(proyecto, Boolean.FALSE, userLogged);

 MessageWebSocket messageWebSocket = new MessageWebSocket.Builder()
                        .producer(FacesUtil.nameOfClass())
                        .action(FacesUtil.nameOfMethod())
                        .key("proyecto")
                        .value(proyecto.getIdproyecto().toString())
                        .message("Clonar proyecto")
                        .iduser(userLogged.getIduser())
                        .date(JmoordbCoreDateUtil.fechaHoraActual())
                        .build();
                sendMensajesWebsocket(messageWebSocket);

}

Defina el método sendMensajesWebsocket(MessageWebSocket messageWebSocket)

En este caso se escribirán notificaciones a varios canales.


 @Override
public void sendMensajesWebsocket(MessageWebSocket messageWebSocket) {
    try {
        List<UserView> result = filterUserViewListForWebSocket(userViewForWebSocketList);

            webSocketController.sendMessageProyectoMultiple(messageWebSocket.toJSON(), result);

            webSocketController.sendMessageTableroMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessageSprintMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessagePapeleraReciclajeMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessageBacklogMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessagePanelTrabajoMultiple(messageWebSocket.toJSON(), result);

 } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
    }

Agregue los métodos para procesar los Websocket

@Override
 public String refreshFromWebsocket() {
    try {
/**
             * Leer los datos del Websocket
             */
            String event = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("event");

            String channel = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("channel");

            String message = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("message");

            MessageWebSocket mws = new MessageWebSocket();
            mws = mws.toMessageWebSocket(message);


        if (jmoordbCronometerOld.equals(0L)) {
             if (!dialogVisibleWebSocket) {
                refresh();
                PrimeFaces.current().ajax().update("form");
              }
          jmoordbCronometerOld = JmoordbCronometer.nanoSecondsNow();
            } else {
              Long dif = JmoordbCronometer.diference(jmoordbCronometerOld, JmoordbCronometer.nanoSecondsNow());
              Long seconds = dif / 1000;
              contadorNotificacionesWebsocket++;
              if (seconds < websocketMinimumsSecondsForUpdate.get().longValue()) {
                } else {
                  if (!dialogVisibleWebSocket) {
                      contadorNotificacionesWebsocket = 0;
                      refresh();
                     PrimeFaces.current().ajax().update("form");
                    }
                }

            jmoordbCronometerOld = JmoordbCronometer.nanoSecondsNow();
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }




@Override
public String updateForRemoteWebsocket() {
      try {
          if(dialogVisibleAddWebSocket){
                 closeOverlayPanel("PF('overlayPanelTarjetaAgregar').show()");
          }

       if (!dialogVisibleWebSocket) {
              return ":form";
          }
       } catch (Exception e) {           FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }

Defina el método onCompleteWebSocket()



    public void onCompleteWebSocket() {
        try {

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

    }

Edite la pagina profile.xhtml correspondiente al dashboard

Agregue un badge que mostrara la cantidad de notificaciones se han realizado escuchando el WebSocket y no se ha actualizado.

 <p:badge 
    value="#{dashboardFaces.contadorNotificacionesWebsocket}" 
    severity="danger">

 <p:commandLink  styleClass="ml-2" 
   action="#{dashboardFaces.refresh()}"     
   update=":form"
   title="#{core['label.notificaciones']}"
   >
   <i class="pi pi-bell" style="font-size: 2rem"/>

 </p:commandLink>
</p:badge>

Edite la pagina dashboard.xhtml, añada un remoteCommand de la siguiente manera.

 <h:form id="form" prependId="false"  >

<p:growl id="growl"/>

<p:remoteCommand name="remoteCommandWebSocketProyecto" action="#{dashboardFaces.refreshFromWebsocket()}"
                             update="#{dashboardFaces.updateForRemoteWebsocket()}" 
                             oncomplete="#{dashboardFaces.onCompleteWebSocket()}" 

                             />

Escuchar Varios webSocket

En el siguiente ejemplo, tenemos una situación que en el formulario principal al actualizar un proyecto, se debe notificar a todos los usuarios que se encuentren en ese proyecto, y además a usuarios que se encuentren en otro formulario como por ejemplo tablero.

Tablero

El tablero recibe notificaciones desde otro tablero, pero también puede recibir notificaciones desde el Dashboard, que puede enviar un mensaje como por ejemplo el proyecto fue cerrado.

Edite el formulario tablero.xhtml

Añada un remoteCommand


<p:remoteCommand name="remoteCommandWebSocketTablero" 
   action="#{tableroFaces.refreshFromWebsocket()}"
   oncomplete="#{tableroFaces.onCompleteWebSocket()}"
   update="#{tableroFaces.updateForRemoteWebsocket()}"
                             />

Edite el profile del tablero

Añada un p:badge para mostrar la notificación

<p:badge 
  value="#{tableroFaces.contadorNotificacionesWebsocket}"
  severity="danger">


 <p:commandLink  styleClass="ml-2" 

  action="#{tableroFaces.refresh()}"

  update=":form"

  title="#{core['label.notificaciones']}" >

  <i class="pi pi-bell" style="font-size: 2rem"/>

 </p:commandLink>
</p:badge>

TableroFaces.java

En la clase TableroFaces añada los siguientes atributos

Leer la cantidad de segundos mínimos establecido en el archivo microprofile-config.properties.


// #Websocket    
    @Inject
    @ConfigProperty(name = "websocket.minimums.seconds.for.update")
    private Provider<Integer> websocketMinimumsSecondsForUpdate;

Añada las propiedades


   // <editor-fold defaultstate="collapsed" desc="WebSocket">
    @Inject
    WebSocketController webSocketController;
    private Boolean dialogVisibleWebSocket = Boolean.FALSE;
    private Boolean dialogVisibleAddWebSocket = Boolean.FALSE;
    private List<UserView> userViewForWebSocketList = new ArrayList<>();
    private Integer contadorNotificacionesWebsocket = 0;
    private Long jmoordbCronometerOld = 0L;

    // </editor-fold>

En el método init()


 /*
            WebSocket
             */
 contadorNotificacionesWebsocket = 0;
 jmoordbCronometerOld = 0L;
 dialogVisibleWebSocket = Boolean.FALSE;
 dialogVisibleAddWebSocket = Boolean.FALSE;

En el método refresh

   public String refresh() {
        try {
            contadorNotificacionesWebsocket = 0;
            dialogVisibleWebSocket = Boolean.FALSE;
            dialogVisibleAddWebSocket = Boolean.FALSE;
            ...
       }
}

En los métodos prepareNew añada dialogVisibleAddWebSocket

 public String prepareNew() {

     dialogVisibleWebSocket = Boolean.TRUE;
     dialogVisibleAddWebSocket = Boolean.TRUE;
}

En los demás métodos prepare solo agregue dialogVisibleWebSocket

public String prepareEditar(Tarjeta tarjeta) {
        try {
            dialogVisibleWebSocket = Boolean.TRUE;
}
}

Agregue el método refreshFromWebsocket

Puede observar que este método contiene una verificación adicional para saber si fue invocado desde un tablero o si fue desde un Dashboard, en el caso que fue invocado desde un Dashboard, indica que el proyecto pudo haber cambiado y necesita obtener una actualización del proyecto de la base de datos.

 @Override
    public String refreshFromWebsocket() {
        try {

            /**
             * Leer los datos del Websocket
             */
            String event = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("event");

            String channel = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("channel");

            String message = FacesContext.getCurrentInstance().getExternalContext().getRequestParameterMap().get("message");

            MessageWebSocket mws = new MessageWebSocket();
            mws = mws.toMessageWebSocket(message);

            if (jmoordbCronometerOld.equals(0L)) {

                if (!dialogVisibleWebSocket) {
                   //Valida los datos del WebSocket
                    if (mws.getProducer().equals("DashboardFaces") && mws.getKey().equals("proyecto")
                            && mws.getValue().equals(proyectoSelected.getIdproyecto().toString())) {
                        validateChangeInProject();
                    }

                    refresh();
                    PrimeFaces.current().ajax().update("form");
                }
                jmoordbCronometerOld = JmoordbCronometer.nanoSecondsNow();
            } else {

                Long dif = JmoordbCronometer.diference(jmoordbCronometerOld, JmoordbCronometer.nanoSecondsNow());
                Long seconds = dif / 1000;
                contadorNotificacionesWebsocket++;
                if (seconds < websocketMinimumsSecondsForUpdate.get().longValue()) {

                } else {
                    if (!dialogVisibleWebSocket) {
                        //Valida los datos del WebSocket
                        if (mws.getProducer().equals("DashboardFaces") && mws.getKey().equals("proyecto")
                                && mws.getValue().equals(proyectoSelected.getIdproyecto().toString())) {
                            validateChangeInProject();
                        }
                        contadorNotificacionesWebsocket = 0;
                        refresh();
                        PrimeFaces.current().ajax().update("form");
                    }
                }

                jmoordbCronometerOld = JmoordbCronometer.nanoSecondsNow();
            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }

Agregar el método updateForRemoteWebsocket()


 public String updateForRemoteWebsocket() {
        try {
           if (dialogVisibleAddWebSocket) {

closeOverlayPanel("PF('overlayPanelTarjetaAgregar').show()");
          }

            if (!dialogVisible) {
                return ":form";
            }
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }

Añada el método onCompleteWebSocket()

public void onCompleteWebSocket() {
        try {

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }

    }

Defina el método para validar cambios en el Proyecto

 public String validateChangeInProject() {
        try {
            haveSprintOpen = Boolean.TRUE;
            isSprintVencido = Boolean.FALSE;

            Proyecto proyectoWebSocket = proyectoServices.findByIdproyecto(proyectoSelected.getIdproyecto());
            if (proyectoSelected.equals(proyectoWebSocket)) {

            } else {

                JmoordbCoreUtil.copyBeans(proyectoSelected, proyectoWebSocket);

                JmoordbCoreContext.put("DashboardFaces.proyectoSelected", proyectoSelected);
                String result = validarEstadoIniciadoYFechaProyecto(proyectoSelected, rf);
                if (!result.equals("")) {

                    haveSprintOpen = Boolean.FALSE;
                    isSprintVencido = Boolean.TRUE;
                    message = result;
                    FacesUtil.warningDialog(result);
                    PrimeFaces.current().ajax().update("form");

                }

            }

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }

En el método save, realice las operaciones y obtenga la lista de usuarios a los que se les debe enviar la notificación y utilice el método sendMessageTableroMultiple.

 public void save(Tarjeta tarjeta) {

MessageWebSocket messageWebSocket = new MessageWebSocket.Builder()
                        .producer(FacesUtil.nameOfClass())
                        .action(FacesUtil.nameOfMethod())
                        .key("tarjeta")
                        .value(tarjeta.getIdtarjeta().toString())
                        .message("Crear tarjeta")
                        .iduser(userLogged.getIduser())
                        .date(JmoordbCoreDateUtil.fechaHoraActual())
                        .build();
                sendMensajesWebsocket(messageWebSocket,tarjeta, Boolean.FALSE);
}

Añada el método


@Override
    public void sendMensajesWebsocket(MessageWebSocket messageWebSocket,Tarjeta tarjeta, Boolean exclude) {
        try {
            List<UserView> result = filterUserViewListForWebSocket(userViewForWebSocketList, tarjeta);
            webSocketController.sendMessageTableroMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessageBacklogMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessagePapeleraReciclajeMultiple(messageWebSocket.toJSON(), result);
            webSocketController.sendMessagePanelTrabajoMultiple(messageWebSocket.toJSON(), result);

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
    }

En el dialogo que usamos para agregar imágenes

Invocar los métodos

  <p:commandButton  value="#{core['button.save']}" icon="pi pi-save"
  action="#{tableroFaces.save(tableroFaces.tarjetaSelected)}"
  update=":form:growl"
  process="#{cc.attrs.id}"                                                 
  styleClass="w-6 ml-2"/>


   <p:commandButton value="#{core['button.cancel']}" icon="pi pi-times"                                               onclick="PF('overlayPanelTarjetaAgregar').hide()"
action="#{tableroFaces.refresh()}"                              
 update=":form"                                                   

styleClass="ui-button-outlined w-6 mr-2"/>

Jakarta WebSocket enviando mensajes

aristides villarreal — Thu, 07 Dec 2023 21:34:06 +0000

Enviar mensajes a todos los usuarios

Para utilizar WebSocket en nuestras aplicaciones Jakarta EE, seguimos los siguientes pasos:

Configurar el archivo web.xml


<context-param>
 <param-name>jakarta.faces.ENABLE_CDI_RESOLVER_CHAIN</param-name>
     <param-value>true</param-value>
</context-param>
<context-param>
 <param-name>jakarta.faces.ENABLE_WEBSOCKET_ENDPOINT</param-name>
   <param-value>true</param-value>
</context-param>

En el archivo template.xhtml

agregar dos commandButton

<p:commandButton id="sendMessageAll" 
 action="#{webSocketDomain.sendMessageAll('all','user')}" 
 value="sendMessageUserAll">
  <f:ajax />
</p:commandButton>

<p:commandButton id="sendMessageProyecto" 
action="#{webSocketDomain.sendMessageProyecto('proyecto ',loginFaces.userLogged)}" value="sendMessageProyecto">
 <f:ajax />
</p:commandButton>

El primero se usará para enviar un mensaje a todos los usuarios y el segundo para enviar un mensaje a un usuario en específico.

Al presionar el primer botón todos los usuarios recibirán un mensaje como el siguiente

Cree la interface

public interface WebSocketPlantilla {

    public void sendMessageAll(String message, String scoped);

    public void sendMessageProyecto(String message, User user);

    public void sendMessageProyectoMultiple(String message, List<User> userList);

    public void sendMessageSprint(String message, User user);


    public void sendMessageSprintMultiple(String message, List<User> userList) ;

    public void sendMessageTablero(String message, User user);

    public void sendMessageTableroMultiple(String message, List<User> userList);

    public Collection<Long> collectionOfUserList(List<User> userList);
}

Ahora es necesario crear una clase que denominaremos a modo de ejemplo como WebSocketController.
En esta clase utilizaremos PushContext para enviar los mensajes mediante WebSocket.

@ViewScoped
@Named
public class WebSocketController implements Serializable, WebSocketPlantilla {

    @Inject
    @Push
    private PushContext proyectoChannel;

    @Inject
    @Push
    private PushContext sprintChannel;

    @Inject
    @Push
    private PushContext tableroChannel;

    @Inject
    @Push
    PushContext allChannel;

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageProyecto(String message, User user) {
        proyectoChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userList
     */
    @Override
    public void sendMessageProyectoMultiple(String message, List<User> userList) {
        proyectoChannel.send(message, collectionOfUserList(userList));
    }

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageSprint(String message, User user) {
        sprintChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userList
     */
    @Override
    public void sendMessageSprintMultiple(String message, List<User> userList) {

        sprintChannel.send(message, collectionOfUserList(userList));
    }

    /**
     *
     * @param message
     * @param user
     */
    @Override
    public void sendMessageTablero(String message, User user) {

        tableroChannel.send(message, user.getIduser());

    }

    /**
     * *
     * Envia mensaje a muchos usuarios
     *
     * @param message
     * @param userList
     */
    @Override
    public void sendMessageTableroMultiple(String message, List<User> userList) {

        tableroChannel.send(message, collectionOfUserList(userList));
    }

    @Override
    public void sendMessageAll(String message, String scoped) {
       allChannel.send(message, "user");
    }

    @Override
    public Collection<Long> collectionOfUserList(List<User> userList) {
        Collection<Long> result = new ArrayList<>();
        try {
            userList.forEach(u -> {
                result.add(u.getIduser());
            });
        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return result;
    }

}

En el archivo template.xhtml añada

 <script>
            function handleMessageAllChannel(message, channelName, event) {
                alert('[handleMessageAllUser]: ' + message );

                remoteCommandWebSocketAll();

            }
            function handleMessageProyectoChannel(message, channelName, event) {
                alert('[handleMessageProyecto]: ' + message);


            }

</script>

Añada un f:websocket para escuchar en el canal allChannel y un p:remoteCommnad para invocar métodos al recibir la notificación.

Observe que se utiliza user="user".

  <f:websocket channel="allChannel"  user="user" onmessage="handleMessageAllChannel" />

 <p:remoteCommand name="remoteCommandWebSocketAll" action="#{loginFaces.webSocketListenerMethod}" 
                                 update="template_growl_timesession" />

En la clase LoginFaces añada

 // <editor-fold defaultstate="collapsed" desc="String websocketListenerMethod()">
    public String webSocketListenerMethod() {
        try {

            FacesUtil.successMessage("desde el websocket");

        } catch (Exception e) {
            FacesUtil.errorMessage(FacesUtil.nameOfClassAndMethod() + " " + e.getLocalizedMessage());
        }
        return "";
    }

Que enviara un mensaje mediante un p:growl de Primefaces

Enviar un mensaje a un usuario específico

Edite otra pagina que se habilite luego de autentificarse en el sistema, en este ejemplo: dashboard.xhtml

Añada un websocket, observe que se usa el canal proyectoChannel y el usuario que ingreso al sistema que se almacena en loginFaces.userLogged.iduser.

<f:websocket channel="proyectoChannel" user="#{loginFaces.userLogged.iduser}" onmessage="handleMessageProyectoChannel"/>

De esta manera se envía una notificación solo al usuario especificado en el parámetro user.