package py.com.personal.bc.recargacontrafactura.cache;

import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import javax.annotation.PostConstruct;
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;

import org.slf4j.Logger;

import py.com.personal.bc.initializer.EagerLoad;
import py.com.personal.bc.messaging.CrudMessageHandler;
import py.com.personal.bc.messaging.TopicRegistration;
import py.com.personal.bc.recargacontrafactura.dao.RecargaFacturaSegmentacionClientesDAO;
import py.com.personal.bc.recargacontrafactura.model.RecargaFacturaSegmentacionClientes;

@TopicRegistration("recarga-factura-segmentacion-clientes")
@EagerLoad
@ApplicationScoped
public class RecargaFacturaSegmentacionClientesCache extends CrudMessageHandler<RecargaFacturaSegmentacionClientes>{

	private final Map<String, RecargaFacturaSegmentacionClientes> listaSegmentacionClientes = new ConcurrentHashMap<>();

	@Inject
    private RecargaFacturaSegmentacionClientesDAO dao;

    @Inject
    private Logger logger;

    @PostConstruct
    public void inicializar() throws Exception{
        logger.info("Inicializando caché RecargaFacturaSegmentacionClientes");

        List<RecargaFacturaSegmentacionClientes> list = null;
        try {
            list = dao.load();
        } catch (Exception e) {
        	e.printStackTrace();
            logger.error("Error al cargar caché RecargaFacturaSegmentacionClientes", e);
            throw e;
        }

        this.listaSegmentacionClientes.clear();
        synchronized (this.listaSegmentacionClientes){
            for(RecargaFacturaSegmentacionClientes o: list){
                this.listaSegmentacionClientes.put(o.getCodigoAbonado(), o);
            }
            logger.info("Caché RecargaFacturaSegmentacionClientes cargado exitosamente: {}", listaSegmentacionClientes.toString());
        }
    }
}