Subversion Repositories Integrator Subversion

import java.util.ArrayList;

import br.com.ec.domain.dto.ModeloDTO;

import br.com.ec.domain.dto.RankingComprasTransferenciasEstiloDTO;

import br.com.ec.domain.dto.RankingComprasTransferenciasEstiloPorLojaDTO;

import br.com.ec.domain.dto.RankingModeloDTO;

import br.com.ec.domain.dto.consulta.ParametrosConsultaModelosMaisVendidosDTO;

import br.com.ec.domain.dto.consulta.ParametrosConsultaPorPeriodoDTO;

import br.com.ec.domain.model.tipos.TipoEstiloProduto;

import br.com.ec.domain.model.tipos.TipoGenero;

import br.com.ec.domain.model.tipos.TipoOrdenacaoMaisVendidos;

import br.com.ec.domain.model.tipos.TipoProduto;

        @Override

        public List<RankingModeloDTO> consultarModelosMaisVendidos(ParametrosConsultaModelosMaisVendidosDTO parametrosConsulta) {

                List<RankingModeloDTO> modelos = new ArrayList<RankingModeloDTO>();

                try {  

                        StringBuilder sql = new StringBuilder();

                        sql.append("SELECT COUNT(l), m.seq_modelo, m.dsc_modelo ");

                        // CONSULTANDO ESTOQUE DO MODELO

                        sql.append(",(SELECT SUM(pl.qtd_estoque) FROM sc_sec.sec_produto_loja pl ");

                        sql.append("LEFT JOIN sc_sec.sec_produto pp ON pp.seq_produto = pl.seq_produto ");

                        sql.append("LEFT JOIN sc_sec.sec_modelo mm ON mm.seq_modelo = pp.seq_modelo ");

                        sql.append("WHERE mm.seq_modelo = m.seq_modelo AND pp.tip_produto = 'C') ");

                        sql.append("FROM sc_sec.sec_lancamento l ");

                        sql.append("LEFT JOIN sc_sec.sec_venda v ON l.seq_venda = v.seq_venda ");

                        sql.append("LEFT JOIN sc_sec.sec_produto p ON p.seq_produto = l.seq_produto ");

                        sql.append("LEFT JOIN sc_sec.sec_modelo m ON m.seq_modelo = p.seq_modelo ");

                        sql.append("WHERE v.dth_venda <= :dataFinal AND v.dth_venda > :dataInicial ");

                        sql.append("AND p.tip_produto = 'C' ");

                        sql.append("AND m.seq_modelo IS NOT NULL ");

                        sql.append("GROUP BY m.seq_modelo, m.dsc_modelo ");

                        sql.append("ORDER BY COUNT(l) DESC ");

                        Query query = getEntityManager().createNativeQuery(sql.toString());

                        Date dataInicial = DataUtils.getDataComHorarioMinimo(parametrosConsulta.getDataInicial());

                        Date dataFinal = DataUtils.getDataComHorarioMaximo(parametrosConsulta.getDataFinal());

                        query.setParameter("dataInicial", dataInicial);

                        query.setParameter("dataFinal", dataFinal);

                        List<Object[]> resultList = query.getResultList();

                        for (Object[] objects : resultList) {

                                RankingModeloDTO rankingModeloDTO = new RankingModeloDTO();

                                rankingModeloDTO.setModelo(new ModeloDTO(Long.parseLong(objects[1].toString()), objects[2].toString(), null));

                                rankingModeloDTO.setQuantidadeVendas(Integer.valueOf(objects[0].toString()));

                                rankingModeloDTO.setQuantidadeEstoqueGeral(Integer.valueOf(objects[3].toString()));

                                modelos.add(rankingModeloDTO);

                        }

                } catch(Exception ex) {

                        ex.printStackTrace();

                        return null;

                }

                return modelos;

                /*

                sql.append("SELECT new br.com.ec.domain.dto.RankingModeloDTO(l.produto.modelo, SUM(l.valorVenda), SUM(l.valorCompra), COUNT(l.produto.modelo), ");

                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getSequencialLoja())) {

                        sql.append("(");

                        sql.append(adicionarConsultaDoEstoque(parametrosConsulta.getSequencialLoja(), "l.produto.modelo", parametrosConsulta.getTipoProduto(), parametrosConsulta.getEstiloProduto()));

                        sql.append("), ");

                }

                sql.append("(");

                sql.append(adicionarConsultaDoEstoque(null, "l.produto.modelo", parametrosConsulta.getTipoProduto(), parametrosConsulta.getEstiloProduto()));

                sql.append(")) FROM Lancamento l ");

                sql.append("WHERE l.venda.dataVenda >= :dataInicial AND l.venda.dataVenda <= :dataFinal ");

                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getSequencialLoja())) {

                        sql.append("AND l.venda.loja.sequencial = :sequencialLoja ");

                }

                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoProduto())) {

                        sql.append("AND l.produto.tipo = :tipoProduto ");

                }

                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getModelo())) {

                        sql.append("AND l.produto.modelo = :modelo ");

                }

                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getEstiloProduto())) {

                        sql.append("AND l.produto.estilo = :estiloProduto ");

                }

                sql.append("GROUP BY l.produto.modelo ");

                if (parametrosConsulta.getTipoOrdenacao().equals(TipoOrdenacaoMaisVendidos.LUCRO.getValor())) {

                        sql.append("ORDER BY SUM(l.valorVenda - l.valorCompra) DESC ");

                } else if (parametrosConsulta.getTipoOrdenacao().equals(TipoOrdenacaoMaisVendidos.QUANTIDADE.getValor())) {

                        sql.append("ORDER BY COUNT(l.produto.modelo) DESC ");

                } else if (parametrosConsulta.getTipoOrdenacao().equals(TipoOrdenacaoMaisVendidos.VALOR_VENDIDO.getValor())) {

                        sql.append("ORDER BY SUM(l.valorVenda) DESC ");

                }

                try {

                        TypedQuery<RankingModeloDTO> query = getEntityManager().createQuery(sql.toString(), RankingModeloDTO.class)

                                        .setParameter("dataInicial", DataUtils.getDataComHorarioMinimo(parametrosConsulta.getDataInicial()))

                                        .setParameter("dataFinal", DataUtils.getDataComHorarioMaximo(parametrosConsulta.getDataFinal()));

                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getQuantidadeModelos())) {

                                query.setMaxResults(parametrosConsulta.getQuantidadeModelos());

                        }

                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getSequencialLoja())) {

                                query.setParameter("sequencialLoja", parametrosConsulta.getSequencialLoja());

                        }

                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoProduto())) {

                                query.setParameter("tipoProduto", parametrosConsulta.getTipoProduto());

                        }

                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getModelo())) {

                                query.setParameter("modelo", parametrosConsulta.getModelo());

                        }

                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getEstiloProduto())) {

                                query.setParameter("estiloProduto", parametrosConsulta.getEstiloProduto());

                        }

                        return query.getResultList();

                } catch(Exception ex) {

                        ex.printStackTrace();

                        return null;

                }

                */

        }

        @Override

        public List<RankingComprasTransferenciasEstiloDTO> consultarRankingPorEstilo(Long sequencialModelo, ParametrosConsultaPorPeriodoDTO parametrosConsultaPorPeriodoDTO) {

                List<RankingComprasTransferenciasEstiloDTO> rankingPorEstilo = new ArrayList<RankingComprasTransferenciasEstiloDTO>();

                try {  

                        StringBuilder sql = new StringBuilder();

                        sql.append("SELECT p.tip_estilo ");

                        sql.append("," + adicionarConsultaVendasRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.UNISSEX.getValor()));

                        sql.append("," + adicionarConsultaVendasRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.MASCULINO.getValor()));

                        sql.append("," + adicionarConsultaVendasRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.FEMININO.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.UNISSEX.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.MASCULINO.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstilo(TipoProduto.CAPA.getValor(), TipoGenero.FEMININO.getValor()));

                        sql.append("FROM sc_sec.sec_lancamento l ");

                        sql.append("LEFT JOIN sc_sec.sec_venda v ON l.seq_venda = v.seq_venda ");

                        sql.append("LEFT JOIN sc_sec.sec_produto p ON p.seq_produto = l.seq_produto ");

                        sql.append("LEFT JOIN sc_sec.sec_modelo m ON m.seq_modelo = p.seq_modelo ");

                        sql.append("WHERE v.dth_venda <= :dataFinal AND v.dth_venda >= :dataInicial ");

                        sql.append("AND p.tip_produto = '" + TipoProduto.CAPA.getValor() + "' ");

                        sql.append("AND m.seq_modelo = :sequencialModelo ");

                        sql.append("GROUP BY p.tip_estilo ");

                        sql.append("ORDER BY p.tip_estilo ");

                        Query query = getEntityManager().createNativeQuery(sql.toString());

                        Date dataInicial = DataUtils.getDataComHorarioMinimo(parametrosConsultaPorPeriodoDTO.getDataInicial());

                        Date dataFinal = DataUtils.getDataComHorarioMaximo(parametrosConsultaPorPeriodoDTO.getDataFinal());

                        query.setParameter("dataInicial", dataInicial);

                        query.setParameter("dataFinal", dataFinal);

                        query.setParameter("sequencialModelo", sequencialModelo);

                        List<Object[]> resultList = query.getResultList();

                        for (Object[] objects : resultList) {

                                RankingComprasTransferenciasEstiloDTO rankingEstiloDTO = new RankingComprasTransferenciasEstiloDTO();

                                rankingEstiloDTO.setEstilo(TipoEstiloProduto.parse(objects[0].toString()));

                                rankingEstiloDTO.setQuantidadeVendasUnissex(Integer.valueOf(objects[1].toString()));

                                rankingEstiloDTO.setQuantidadeVendasMasculino(Integer.valueOf(objects[2].toString()));

                                rankingEstiloDTO.setQuantidadeVendasFeminino(Integer.valueOf(objects[3].toString()));

                                rankingEstiloDTO.setQuantidadeEstoqueUnissex(Integer.valueOf(objects[4].toString()));

                                rankingEstiloDTO.setQuantidadeEstoqueMasculino(Integer.valueOf(objects[5].toString()));

                                rankingEstiloDTO.setQuantidadeEstoqueFeminino(Integer.valueOf(objects[6].toString()));

                                rankingPorEstilo.add(rankingEstiloDTO);

                        }

                } catch(Exception ex) {

                        ex.printStackTrace();

                        return null;

                }

                return rankingPorEstilo;

        }

        private String adicionarConsultaVendasRankingPorEstilo(String tipoProduto, String tipoGenero) {

                StringBuilder sql = new StringBuilder();

                sql.append("(SELECT COUNT(*) FROM sc_sec.sec_lancamento ll ");

                sql.append("LEFT JOIN sc_sec.sec_venda vv ON ll.seq_venda = vv.seq_venda ");

                sql.append("LEFT JOIN sc_sec.sec_produto pp ON pp.seq_produto = ll.seq_produto ");

                sql.append("LEFT JOIN sc_sec.sec_modelo mm ON mm.seq_modelo = pp.seq_modelo ");

                sql.append("WHERE vv.dth_venda <= :dataFinal AND vv.dth_venda >= :dataInicial ");

                sql.append("AND mm.seq_modelo = :sequencialModelo AND pp.tip_estilo = p.tip_estilo ");

                sql.append("AND pp.tip_produto = '" + tipoProduto + "' AND pp.tip_genero LIKE '" + tipoGenero + "') ");

                return sql.toString();

        }

        private String adicionarConsultaEstoqueRankingPorEstilo(String tipoProduto, String tipoGenero) {

                StringBuilder sql = new StringBuilder();

                sql.append("(SELECT SUM(pl.qtd_estoque) FROM sc_sec.sec_produto_loja pl ");

                sql.append("LEFT JOIN sc_sec.sec_produto pp ON pp.seq_produto = pl.seq_produto ");

                sql.append("LEFT JOIN sc_sec.sec_modelo mm ON mm.seq_modelo = pp.seq_modelo ");

                sql.append("WHERE mm.seq_modelo = :sequencialModelo AND pp.tip_estilo = p.tip_estilo ");

                sql.append("AND pp.tip_produto = '" + tipoProduto + "' AND pp.tip_genero LIKE '" + tipoGenero + "') ");

                return sql.toString();

        }

        @Override

        public List<RankingComprasTransferenciasEstiloPorLojaDTO> consultarRankingPorEstiloPorLoja(Long sequencialModelo,

                        String tipoEstilo, ParametrosConsultaPorPeriodoDTO parametrosConsultaPorPeriodoDTO) {

                List<RankingComprasTransferenciasEstiloPorLojaDTO> rankingPorEstiloPorLoja = new ArrayList<RankingComprasTransferenciasEstiloPorLojaDTO>();

                try {  

                        StringBuilder sql = new StringBuilder();

                        sql.append("SELECT v.seq_loja, lj.dsc_loja ");

                        sql.append("," + adicionarConsultaVendasRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.UNISSEX.getValor()));

                        sql.append("," + adicionarConsultaVendasRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.MASCULINO.getValor()));

                        sql.append("," + adicionarConsultaVendasRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.FEMININO.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.UNISSEX.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.MASCULINO.getValor()));

                        sql.append("," + adicionarConsultaEstoqueRankingPorEstiloPorLoja(TipoProduto.CAPA.getValor(), TipoGenero.FEMININO.getValor()));

                        sql.append("FROM sc_sec.sec_lancamento l ");

                        sql.append("LEFT JOIN sc_sec.sec_venda v ON l.seq_venda = v.seq_venda ");

                        sql.append("LEFT JOIN sc_sec.sec_loja lj ON lj.seq_loja = v.seq_loja ");

                        sql.append("LEFT JOIN sc_sec.sec_produto p ON p.seq_produto = l.seq_produto ");

                        sql.append("LEFT JOIN sc_sec.sec_modelo m ON m.seq_modelo = p.seq_modelo ");

                        sql.append("WHERE v.dth_venda <= :dataFinal AND v.dth_venda >= :dataInicial ");

                        sql.append("AND p.tip_produto = '" + TipoProduto.CAPA.getValor() + "' ");

                        sql.append("AND m.seq_modelo = :sequencialModelo ");

                        sql.append("AND p.tip_estilo = :tipoEstilo ");

                        sql.append("AND lj.ind_ativo IS TRUE ");

                        sql.append("GROUP BY lj.num_ordem, v.seq_loja, lj.dsc_loja ");

                        sql.append("ORDER BY lj.num_ordem ");

                        Query query = getEntityManager().createNativeQuery(sql.toString());

                        Date dataInicial = DataUtils.getDataComHorarioMinimo(parametrosConsultaPorPeriodoDTO.getDataInicial());

                        Date dataFinal = DataUtils.getDataComHorarioMaximo(parametrosConsultaPorPeriodoDTO.getDataFinal());

                        query.setParameter("dataInicial", dataInicial);

                        query.setParameter("dataFinal", dataFinal);

                        query.setParameter("sequencialModelo", sequencialModelo);

                        query.setParameter("tipoEstilo", tipoEstilo);

                        List<Object[]> resultList = query.getResultList();

                        for (Object[] objects : resultList) {

                                RankingComprasTransferenciasEstiloPorLojaDTO rankingEstiloPorLojaDTO = new RankingComprasTransferenciasEstiloPorLojaDTO();

                                rankingEstiloPorLojaDTO.setLojaDTO(new LojaDTO(Long.parseLong(objects[0].toString()), objects[1].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeVendasUnissex(Integer.valueOf(objects[2].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeVendasMasculino(Integer.valueOf(objects[3].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeVendasFeminino(Integer.valueOf(objects[4].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeEstoqueUnissex(Integer.valueOf(objects[5].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeEstoqueMasculino(Integer.valueOf(objects[6].toString()));

                                rankingEstiloPorLojaDTO.setQuantidadeEstoqueFeminino(Integer.valueOf(objects[7].toString()));

                                rankingPorEstiloPorLoja.add(rankingEstiloPorLojaDTO);

                        }

                } catch(Exception ex) {

                        ex.printStackTrace();

                        return null;

                }

                return rankingPorEstiloPorLoja;

        }

        private String adicionarConsultaVendasRankingPorEstiloPorLoja(String tipoProduto, String tipoGenero) {

                StringBuilder sql = new StringBuilder();

                sql.append("(SELECT COUNT(*) FROM sc_sec.sec_lancamento ll ");

                sql.append("LEFT JOIN sc_sec.sec_venda vv ON ll.seq_venda = vv.seq_venda ");

                sql.append("LEFT JOIN sc_sec.sec_produto pp ON pp.seq_produto = ll.seq_produto ");

                sql.append("LEFT JOIN sc_sec.sec_modelo mm ON mm.seq_modelo = pp.seq_modelo ");

                sql.append("WHERE vv.dth_venda <= :dataFinal AND vv.dth_venda >= :dataInicial ");

                sql.append("AND vv.seq_loja = v.seq_loja ");

                sql.append("AND mm.seq_modelo = :sequencialModelo AND pp.tip_estilo = :tipoEstilo ");

                sql.append("AND pp.tip_produto = '" + tipoProduto + "' AND pp.tip_genero LIKE '" + tipoGenero + "') ");

                return sql.toString();

        }

        private String adicionarConsultaEstoqueRankingPorEstiloPorLoja(String tipoProduto, String tipoGenero) {

                StringBuilder sql = new StringBuilder();

                sql.append("(SELECT SUM(pl.qtd_estoque) FROM sc_sec.sec_produto_loja pl ");

                sql.append("LEFT JOIN sc_sec.sec_produto pp ON pp.seq_produto = pl.seq_produto ");

                sql.append("LEFT JOIN sc_sec.sec_modelo mm ON mm.seq_modelo = pp.seq_modelo ");

                sql.append("WHERE pl.seq_loja = v.seq_loja AND mm.seq_modelo = :sequencialModelo ");

                sql.append("AND pp.tip_estilo = p.tip_estilo ");

                sql.append("AND pp.tip_produto = '" + tipoProduto + "' AND pp.tip_genero LIKE '" + tipoGenero + "') ");

                return sql.toString();

        }

        /*

        private String adicionarConsultaDoEstoque(Long sequencialLoja, String modelo, String tipoProduto, String estiloProduto) {

                sql.append("SELECT SUM(pl.quantidadeEstoque) FROM ProdutoLoja pl ");

                sql.append("WHERE pl.produto.modelo = " + modelo + " ");

                if (VerificadorUtil.naoEstaNuloOuVazio(sequencialLoja)) {

                        sql.append("AND pl.loja.sequencial = :sequencialLoja ");

                }

                if (VerificadorUtil.naoEstaNuloOuVazio(tipoProduto)) {

                        sql.append("AND pl.produto.tipo = :tipoProduto ");

                }

                if (VerificadorUtil.naoEstaNuloOuVazio(estiloProduto)) {

                        sql.append("AND pl.produto.estilo = :estiloProduto ");

                }

                return sql.toString().trim();

        }

         */