Subversion Repositories Integrator Subversion

package br.com.sl.controller;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

import javax.faces.application.FacesMessage;
import javax.inject.Inject;
import javax.inject.Named;

import org.primefaces.PrimeFaces;
import org.springframework.context.annotation.Scope;

import br.com.ec.core.generic.GenericService;
import br.com.ec.core.util.VerificadorUtil;
import br.com.ec.web.exception.VerificadorLancamentoException;
import br.com.ec.web.exception.VerificadorLancamentoException.CommandBean;
import br.com.ec.web.generic.AbstractBean;
import br.com.ec.web.message.LancadorMensagem;
import br.com.kronus.core.PadraoGatilho;
import br.com.sl.domain.dto.RoboDTO;
import br.com.sl.domain.dto.robo.AlertaPadraoService;
import br.com.sl.domain.service.RoboOperadorService;

@Named
@Scope("view")
public class RoboBean extends AbstractBean<RoboDTO> implements Serializable {

        private RoboOperadorService roboOperadorService;
       
        private List<PadraoGatilho> padroesEmAberto;
        private Integer contadorUltimoCandle;
       
        private List<PadraoGatilho> padroes;
        private List<PadraoGatilho> padroesComG3;  // completos (G3 != null)
    private List<PadraoGatilho> padroesAteG2;  // parciais (G2 != null && G3 == null)
       
        @Inject
        public RoboBean(RoboOperadorService roboOperadorService) {
                this.roboOperadorService = roboOperadorService;
        }
       
        @Override
        public void preCarregamento() {
                limparEntidade();
                getEntidade().setRodando(roboOperadorService.isRodando());
        }

        @Override
        public void limparEntidade() {
                setEntidade(new RoboDTO());
                setPadroes(new ArrayList<PadraoGatilho>());
                setPadroesComG3(new ArrayList<PadraoGatilho>());
                setPadroesAteG2(new ArrayList<PadraoGatilho>());
        }

        @Override
        public GenericService<RoboDTO> getService() {
                return roboOperadorService;
        }
       
        @Override
        public RoboDTO getEntidade() {
                return entidade;
        }
       
        @Override
        public RoboDTO getId() {
                return getEntidade();
        }
       
        public List<PadraoGatilho> getPadroes() {
                return padroes;
        }
        public void setPadroes(List<PadraoGatilho> padroes) {
                this.padroes = padroes;
        }
       
        public List<PadraoGatilho> getPadroesComG3() {
                return padroesComG3;
        }
        public void setPadroesComG3(List<PadraoGatilho> padroesComG3) {
                this.padroesComG3 = padroesComG3;
        }
       
        public List<PadraoGatilho> getPadroesAteG2() {
                return padroesAteG2;
        }
        public void setPadroesAteG2(List<PadraoGatilho> padroesAteG2) {
                this.padroesAteG2 = padroesAteG2;
        }
       
        public void iniciar() {
                new VerificadorLancamentoException().tratarIhRelancarExcecaoSemLimparEntidade(new CommandBean() {
                        public void execute() {
                                // ANALISAR POR HISTÓRICO
                                getEntidade().setAnalisarPorHistoricoArquivo(true);
                               
                                roboOperadorService.iniciarOperacao(getEntidade().getAnalisarPorHistoricoArquivo());
                                setEntidade(roboOperadorService.statusRobo());
                                LancadorMensagem.lancarSucesso("ROBÔ INICIADO COM SUCESSO!");
                        }
                });
    }

    public void parar() {
        new VerificadorLancamentoException().tratarIhRelancarExcecaoSemLimparEntidade(new CommandBean() {
                        public void execute() {
                                roboOperadorService.pararOperacao();
                                setEntidade(roboOperadorService.statusRobo());
                                LancadorMensagem.lancarSucesso("ROBÔ PARADO COM SUCESSO!");
                        }
                });
    }
   
    public void preencherOutrosPadroes() {
                padroesComG3 = padroes.stream()
                .filter(p -> p.getGatilho2() != null && p.getGatilho3() != null)
                .collect(Collectors.toList());
                inverterLista(padroesComG3);

        padroesAteG2 = padroes.stream()
                .filter(p -> p.getGatilho2() != null && p.getGatilho3() == null)
                .collect(Collectors.toList());
        inverterLista(padroesAteG2);
        }
   
    public static List<PadraoGatilho> inverterLista(List<PadraoGatilho> candles) {
        List<PadraoGatilho> invertida = new ArrayList<>(candles);
        Collections.reverse(invertida);
        return invertida;
    }

    public void atualizarStatus() {
        setEntidade(roboOperadorService.statusRobo());
        if (VerificadorUtil.naoEstaNuloOuVazio(getEntidade().getPadroes())) {
                if (getEntidade().getPadroes().size() != getPadroes().size()) {
                        AlertaPadraoService.novoAlerta("NOVO PADRÃO IDENTIFICADO!");
                        PrimeFaces.current().executeScript("playAlertaAgressivo();");
                }
                setPadroes(getEntidade().getPadroes());
                preencherOutrosPadroes();
        }
        verificarNovosPadroes();
    }
   
    public void verificarNovosPadroes() {
        List<String> alertas = AlertaPadraoService.consumirAlertas();

        if (!alertas.isEmpty()) {
            for (String msg : alertas) {
                FacesMessage facesMessage = new FacesMessage(
                        FacesMessage.SEVERITY_INFO,
                        "Novo padrão identificado",
                        msg
                );
                javax.faces.context.FacesContext.getCurrentInstance()
                        .addMessage(null, facesMessage);
            }

            // Toca o som no cliente
            PrimeFaces.current().executeScript("playBeepPadrao();");
            // Se estiver em PF antigo:
            // RequestContext.getCurrentInstance().execute("playBeepPadrao();");
        }
    }

}