/* * Copyright (C) 2007-2007 the GSAN - Sistema Integrado de Gestão de Serviços de Saneamento * * This file is part of GSAN, an integrated service management system for Sanitation * * GSAN is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License. * * GSAN is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA */ /* * GSAN - Sistema Integrado de Gestão de Serviços de Saneamento * Copyright (C) <2007> * Adriano Britto Siqueira * Alexandre Santos Cabral * Ana Carolina Alves Breda * Ana Maria Andrade Cavalcante * Aryed Lins de Araújo * Bruno Leonardo Rodrigues Barros * Carlos Elmano Rodrigues Ferreira * Cláudio de Andrade Lira * Denys Guimarães Guenes Tavares * Eduardo Breckenfeld da Rosa Borges * Fabíola Gomes de Araújo * Flávio Leonardo Cavalcanti Cordeiro * Francisco do Nascimento Júnior * Homero Sampaio Cavalcanti * Ivan Sérgio da Silva Júnior * José Edmar de Siqueira * José Thiago Tenório Lopes * Kássia Regina Silvestre de Albuquerque * Leonardo Luiz Vieira da Silva * Márcio Roberto Batista da Silva * Maria de Fátima Sampaio Leite * Micaela Maria Coelho de Araújo * Nelson Mendonça de Carvalho * Newton Morais e Silva * Pedro Alexandre Santos da Silva Filho * Rafael Corrêa Lima e Silva * Rafael Francisco Pinto * Rafael Koury Monteiro * Rafael Palermo de Araújo * Raphael Veras Rossiter * Roberto Sobreira Barbalho * Rodrigo Avellar Silveira * Rômulo Aurélio de Melo Souza Filho * Rosana Carvalho Barbosa * Sávio Luiz de Andrade Cavalcante * Tai Mu Shih * Thiago Augusto Souza do Nascimento * Tiago Moreno Rodrigues * Vivianne Barbosa Sousa * * Este programa é software livre; você pode redistribuí-lo e/ou * modificá-lo sob os termos de Licença Pública Geral GNU, conforme * publicada pela Free Software Foundation; versão 2 da * Licença. * Este programa é distribuído na expectativa de ser útil, mas SEM * QUALQUER GARANTIA; sem mesmo a garantia implícita de * COMERCIALIZAÇÃO ou de ADEQUAÇÃO A QUALQUER PROPÓSITO EM * PARTICULAR. Consulte a Licença Pública Geral GNU para obter mais * detalhes. * Você deve ter recebido uma cópia da Licença Pública Geral GNU * junto com este programa; se não, escreva para Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA * 02111-1307, USA. */ package gcom.micromedicao; import gcom.batch.UnidadeProcessamento; import gcom.cadastro.funcionario.Funcionario; import gcom.cadastro.imovel.FiltroImovel; import gcom.cadastro.imovel.Imovel; import gcom.cadastro.localidade.Localidade; import gcom.cadastro.localidade.Quadra; import gcom.cadastro.localidade.SetorComercial; import gcom.cadastro.sistemaparametro.SistemaParametro; import gcom.faturamento.FaturamentoGrupo; import gcom.faturamento.FiltroFaturamentoGrupo; import gcom.micromedicao.leitura.LeituraAnormalidade; import gcom.micromedicao.medicao.MedicaoHistorico; import gcom.micromedicao.medicao.MedicaoTipo; import gcom.util.ControladorException; import gcom.util.ErroRepositorioException; import gcom.util.IoUtil; import gcom.util.Util; import gcom.util.filtro.ParametroSimples; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.util.ArrayList; import java.util.Calendar; import java.util.Collection; import java.util.Date; import java.util.Iterator; import javax.ejb.SessionBean; import org.apache.commons.fileupload.FileItem; import gcom.cadastro.imovel.Categoria; /** * Controlador Micromedicao COSANPA * * @author Raphael Rossiter * @date 24/04/2009 */ public class ControladorMicromedicaoCOSANPASEJB extends ControladorMicromedicao implements SessionBean{ private static final long serialVersionUID = 1L; //============================================================================================================== // MÉTODOS EXCLUSIVOS DA COSANPA //============================================================================================================== /** * [UC00083] Gerar Dados para Leitura * * [SB0005] Gerar Relação(ROL) em TXT - COSANPA * * @author Raphael Rossiter * @date 27/08/2009 * * @param colecaoRota * @param anoMesCorrente * @param idGrupoFaturamentoRota * @param sistemaParametro * @param idFuncionalidadeIniciada * @return Collection * @throws ErroRepositorioException */ public Collection gerarDadosPorLeituraMicroColetor(Collection colecaoRota, Integer anoMesCorrente, Integer idGrupoFaturamentoRota, SistemaParametro sistemaParametro, int idFuncionalidadeIniciada) throws ControladorException { int idUnidadeIniciada = 0; try { Iterator colecaoRotaIterator = colecaoRota.iterator(); StringBuilder arquivoTxt = new StringBuilder(); Integer qtdImoveis = 0; MovimentoRoteiroEmpresa movimentoRoteiroEmpresa = null; //PAGINAÇÃO DO ARQUIVO Integer numeroPaginacao = 1; Localidade localidadeAnterior = null; Integer codigoSetorComercialAnterior = null; Rota rotaAnterior = null; int qtdImoveisLocalidadeSetorRota = 0; while (colecaoRotaIterator.hasNext()) { Rota rota = (Rota) colecaoRotaIterator.next(); //------------------------- // // Registrar o início do processamento da Unidade de // Processamento // do Batch // // ------------------------- idUnidadeIniciada = getControladorBatch() .iniciarUnidadeProcessamentoBatch(idFuncionalidadeIniciada, UnidadeProcessamento.ROTA, rota.getId()); //CONTROLE DE PAGINAÇÃO DA PESQUISA int numeroIndice = 0; int quantidadeRegistrosPesquisa = 1000; boolean flagTerminou = false; //MOVIMENTO ROTEIRO EMPRESA Collection objetosMovimentoRoteiroEmpresa = new ArrayList(); while (!flagTerminou) { try { //PESQUISANDO MOVIMENTO ROTEIRO EMPRESA objetosMovimentoRoteiroEmpresa = repositorioMicromedicao .pesquisarImoveisParaLeituraPorColecaoRotaCOSANPA(rota, numeroIndice, anoMesCorrente); } catch (ErroRepositorioException e) { throw new ControladorException("erro.sistema", e); } if (objetosMovimentoRoteiroEmpresa != null && !objetosMovimentoRoteiroEmpresa.isEmpty()) { for (Object[] dadosMovimentoRoteiroEmpresa : objetosMovimentoRoteiroEmpresa) { //QUANTIDADE TOTAL DE IMÓVEIS qtdImoveis = qtdImoveis + objetosMovimentoRoteiroEmpresa.size(); //CONTROLE DE PAGINAÇÃO DA PESQUISA if (objetosMovimentoRoteiroEmpresa.size() < quantidadeRegistrosPesquisa) { flagTerminou = true; } else { numeroIndice = numeroIndice + quantidadeRegistrosPesquisa; } boolean ligacaoAgua = false; boolean ligacaoPoco = false; // cria uma string builder para adicionar no arquivo StringBuilder arquivoTxtLinha = new StringBuilder(); movimentoRoteiroEmpresa = (MovimentoRoteiroEmpresa) dadosMovimentoRoteiroEmpresa[0]; Integer idQuadra = (Integer) dadosMovimentoRoteiroEmpresa[1]; Quadra quadra = new Quadra(); quadra.setId(idQuadra); Imovel imovel = new Imovel(); imovel.setId(movimentoRoteiroEmpresa.getImovel().getId()); imovel.setQuadra(quadra); movimentoRoteiroEmpresa.setImovel(imovel); //QUANTIDADE DE IMOVEIS POR LOCALIDADE, SETOR E ROTA qtdImoveisLocalidadeSetorRota++; //PAGINAÇÃO DO ARQUIVO if (localidadeAnterior == null){ //CARREGANDO PELA PRIMEIRA VEZ AS INFORMAÇÕES DE LOCALIDADE E SETOR ANTERIORES localidadeAnterior = movimentoRoteiroEmpresa.getLocalidade(); codigoSetorComercialAnterior = movimentoRoteiroEmpresa.getCodigoSetorComercial(); rotaAnterior = rota; } else{ //QUEBRA DE LOCALIDADE if (!localidadeAnterior.getId().equals( movimentoRoteiroEmpresa.getLocalidade().getId())){ numeroPaginacao = 1; qtdImoveisLocalidadeSetorRota = 1; } //QUEBRA DE SETOR COMERCIAL else if (!codigoSetorComercialAnterior.equals( movimentoRoteiroEmpresa.getCodigoSetorComercial())){ numeroPaginacao = 1; qtdImoveisLocalidadeSetorRota = 1; } /* * QUEBRA DE ROTA * QUEBRA POR QUANTIDADE DE IMÓVEIS COM MESMA: LOCALIDADE, SETOR E ROTA */ else if (!rotaAnterior.getId().equals(rota.getId()) || qtdImoveisLocalidadeSetorRota > 12){ numeroPaginacao++; qtdImoveisLocalidadeSetorRota = 1; } } //GERANDO O ARQUIVO TXT adicionarLinhaTxt(arquivoTxt, arquivoTxtLinha, null, null, null, null, null, movimentoRoteiroEmpresa, ligacaoAgua, ligacaoPoco, null, false, sistemaParametro, rota.getId(), null, anoMesCorrente, numeroPaginacao); /* * PAGINAÇÃO DO ARQUIVO * GUARDANDO AS INFORMAÇÕES DA LOCALIDADE ANTERIOR E DO SETOR COMERCIAL ANTERIOR */ localidadeAnterior = movimentoRoteiroEmpresa.getLocalidade(); codigoSetorComercialAnterior = movimentoRoteiroEmpresa.getCodigoSetorComercial(); rotaAnterior = rota; } } else{ flagTerminou = true; } } // Encerra a unidade de Faturamento getControladorBatch().encerrarUnidadeProcessamentoBatch( null, idUnidadeIniciada, false); } //FIM LOOP DE ROTA /* * Atualiza a data e a hora da realização da atividade com a data e * a hora correntes. */ try { repositorioMicromedicao.atualizarFaturamentoAtividadeCronograma( idGrupoFaturamentoRota, anoMesCorrente); } catch (ErroRepositorioException e) { throw new ControladorException("erro.sistema", e); } //INSERINDO NA BASE O ARQUIVO_TEXTO_ROTEIRO_EMPRESA if (arquivoTxt != null && arquivoTxt.length() != 0) { //GERANDO O NOME DO ARQUIVO String anoCom2Digitos = "" + Util.obterAno(movimentoRoteiroEmpresa.getAnoMesMovimento()); anoCom2Digitos = anoCom2Digitos.substring(2,4); String nomeArquivo = "cons" + anoCom2Digitos + Util.adicionarZerosEsquedaNumero(2, "" + Util.obterMes(movimentoRoteiroEmpresa.getAnoMesMovimento())) + "." + Util.adicionarZerosEsquedaNumero(3, movimentoRoteiroEmpresa.getRota().getFaturamentoGrupo().getId().toString()); //GERANDO O ARQUIVO TXT this.inserirArquivoTextoRoteiroEmpresa(anoMesCorrente, movimentoRoteiroEmpresa, qtdImoveis, arquivoTxt, nomeArquivo); } } catch (Exception e) { /* * Este catch serve para interceptar qualquer exceção que o processo batch * venha a lançar e garantir que a unidade de processamento do batch * será atualizada com o erro ocorrido. */ e.printStackTrace(); getControladorBatch().encerrarUnidadeProcessamentoBatch(e, idUnidadeIniciada, true); } return null; } /** * [UC0083]- Gerar dados para Leitura Author: Rômulo Aurélio Date: * 08/07/2008 * * @param arquivoTxt * @param arquivoTxtLinha * @param arquivoTxtFiscalizacao * @param arquivoHeaderFiscalizacao * @param quantidadeRegistros * @param quantidadeMovimentoRoteiroEmpresa * @param quantidadeRegistrosFiscalizacao * @param movimentoRoteiroEmpresa * @param ligacaoAgua * @param ligacaoPoco * @param idFaturamentoGrupoOld * @param headerArquivo * @param sistemaParametro * @param idRotaOld * @param dataCalendar * @param anoMesCorrente */ private void adicionarLinhaTxt(StringBuilder arquivoTxt, StringBuilder arquivoTxtLinha, StringBuilder arquivoTxtFiscalizacao, StringBuilder arquivoHeaderFiscalizacao, Integer quantidadeRegistros, Integer quantidadeMovimentoRoteiroEmpresa, Integer quantidadeRegistrosFiscalizacao, MovimentoRoteiroEmpresa movimentoRoteiroEmpresa, boolean ligacaoAgua, boolean ligacaoPoco, Integer idFaturamentoGrupoOld, boolean headerArquivo, SistemaParametro sistemaParametro, Integer idRotaOld, Calendar dataCalendar, Integer anoMesCorrente, Integer numeroPagina) throws ControladorException{ //Matrícula com Dígito Verificador (IMOV_ID da tabela MOVIMENTO_ROTEIRO_EMPRESA) arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getImovel() .getId().toString(), 15)); //Setor (somente cidade planejada) (Numérico) if (movimentoRoteiroEmpresa.getCodigoSetorComercial() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando( 3, movimentoRoteiroEmpresa.getCodigoSetorComercial().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); } //Rota (Numérico) if (movimentoRoteiroEmpresa.getCodigoRota() != null){ arquivoTxtLinha.append("" + Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getCodigoRota().toString())); } else{ arquivoTxtLinha.append("" + Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } //Setor (somente cidade planejada) arquivoTxtLinha.append(Util.completaString("", 3)); //Quadra (somente cidade planejada) arquivoTxtLinha.append(Util.completaString("", 3)); //Sub-Quadra (somente cidade planejada) arquivoTxtLinha.append(Util.completaString("", 2)); //Lote (somente cidade planejada) arquivoTxtLinha.append(Util.completaString("", 3)); //Sub-Lote (somente cidade planejada) arquivoTxtLinha.append(Util.completaString("", 2)); //Unidade (Seqüência - cidade não planejada) Lote (Numérico) if (movimentoRoteiroEmpresa.getNumeroLoteImovel() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando( 6, movimentoRoteiroEmpresa.getNumeroLoteImovel().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(6, "")); } //Código da ligação / Matrícula (Alfanumérico) arquivoTxtLinha.append(completaString(movimentoRoteiroEmpresa.getImovel() .getId().toString(), 15)); //Dígito verificador da ligação (Numérico) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Hidrômetro / Medidor (Alfanumérico) if (movimentoRoteiroEmpresa.getNumeroHidrometro() != null){ arquivoTxtLinha.append(Util.completaString( movimentoRoteiroEmpresa.getNumeroHidrometro().toString(), 12)); } else{ arquivoTxtLinha.append(Util.completaString("", 12)); } //Situação do usuário (*) (Alfanumérico) if (movimentoRoteiroEmpresa.getDescricaoLigacaoAguaSituacao() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getDescricaoLigacaoAguaSituacao(), 15)); } else{ arquivoTxtLinha.append(Util.completaString("", 15)); } //Serviço (*) (Alfanumérico) if (movimentoRoteiroEmpresa.getMedicaoTipo() != null){ if (movimentoRoteiroEmpresa.getMedicaoTipo().getId().equals(MedicaoTipo.LIGACAO_AGUA)){ arquivoTxtLinha.append(Util.completaString("SO AGUA", 15)); } else{ arquivoTxtLinha.append(Util.completaString("SO ESGOTO", 15)); } } else{ arquivoTxtLinha.append(Util.completaString("", 15)); } //Nome do Consumidor (Alfanumérico) if (movimentoRoteiroEmpresa.getNomeCliente() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getNomeCliente(), 40)); } else{ arquivoTxtLinha.append(Util.completaString("", 40)); } //Logradouro (Alfanumérico) if (movimentoRoteiroEmpresa.getLogradouro() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getLogradouro() .getDescricaoFormatada(), 40)); } else{ arquivoTxtLinha.append(Util.completaString("", 40)); } //Número do imóvel (Alfanumérico) if (movimentoRoteiroEmpresa.getNumeroImovel() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getNumeroImovel(), 6)); } else{ arquivoTxtLinha.append(Util.completaString("", 6)); } //Complemento do endereço do imóvel (Alfanumérico) if (movimentoRoteiroEmpresa.getComplementoEndereco() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getComplementoEndereco(), 15)); } else{ arquivoTxtLinha.append(Util.completaString("", 15)); } //Bairro do imóvel (Alfanumérico) if (movimentoRoteiroEmpresa.getNomeBairro() != null){ arquivoTxtLinha.append(Util.completaString(movimentoRoteiroEmpresa.getNomeBairro(), 20)); } else{ arquivoTxtLinha.append(Util.completaString("", 20)); } /* * Número de economias Domiciliar (Numérico) * Número de economias Comercial (Numérico) * Número de economias Industrial (Numérico) * Número de economias Pública (Numérico) */ if (movimentoRoteiroEmpresa.getDescricaoAbreviadaCategoriaImovel() != null){ if (movimentoRoteiroEmpresa.getDescricaoAbreviadaCategoriaImovel().equals( Categoria.RESIDENCIAL_DESCRICAO_ABREVIADA)){ if (movimentoRoteiroEmpresa.getQuantidadeEconomias() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getQuantidadeEconomias().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } else if (movimentoRoteiroEmpresa.getDescricaoAbreviadaCategoriaImovel().equals( Categoria.COMERCIAL_DESCRICAO_ABREVIADA)){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); if (movimentoRoteiroEmpresa.getQuantidadeEconomias() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getQuantidadeEconomias().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } else if (movimentoRoteiroEmpresa.getDescricaoAbreviadaCategoriaImovel().equals( Categoria.INDUSTRIAL_DESCRICAO_ABREVIADA)){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); if (movimentoRoteiroEmpresa.getQuantidadeEconomias() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getQuantidadeEconomias().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); if (movimentoRoteiroEmpresa.getQuantidadeEconomias() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getQuantidadeEconomias().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } } } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } //Número de economias Outras (Numérico) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); //Leitura Anterior (Numérico) Integer numeroLeituraAnterior = 0; if (movimentoRoteiroEmpresa.getNumeroLeituraAnterior() != null){ numeroLeituraAnterior = Integer.valueOf(movimentoRoteiroEmpresa.getNumeroLeituraAnterior()); arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(8, movimentoRoteiroEmpresa.getNumeroLeituraAnterior().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(8, "")); } //Ocorrência principal Anterior (Numérico) if (movimentoRoteiroEmpresa.getCodigoAnormalidadeAnterior() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getCodigoAnormalidadeAnterior().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } //Consumo mínimo (m3) (Numérico) if (movimentoRoteiroEmpresa.getNumeroFaixaLeituraEsperadaInicial() != null){ Integer consumoMinimo = movimentoRoteiroEmpresa.getNumeroFaixaLeituraEsperadaInicial().intValue() - numeroLeituraAnterior; arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, consumoMinimo.toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, "")); } //Consumo máximo (m3) (Numérico) if (movimentoRoteiroEmpresa.getNumeroFaixaLeituraEsperadaFinal() != null){ Integer consumoMaximo = movimentoRoteiroEmpresa.getNumeroFaixaLeituraEsperadaFinal().intValue() - numeroLeituraAnterior; arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, consumoMaximo.toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, "")); } //Consumo médio (m3) (Numérico) if (movimentoRoteiroEmpresa.getNumeroConsumoMedio() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, movimentoRoteiroEmpresa.getNumeroConsumoMedio().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, "")); } //Observações (Alfanumérico) arquivoTxtLinha.append(Util.completaString("", 60)); //Número de moradores (Numérico) if (movimentoRoteiroEmpresa.getNumeroMoradores() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(2, movimentoRoteiroEmpresa.getNumeroMoradores().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(2, "")); } //Ano/Mês de faturamento (AAAAMM) arquivoTxtLinha.append(movimentoRoteiroEmpresa.getAnoMesMovimento()); //Telefone 01 arquivoTxtLinha.append(Util.completaString("", 16)); //Telefone 02 arquivoTxtLinha.append(Util.completaString("", 16)); //Categoria 01 (1 - Domiciliar, 2 - Comercial, 3 - Industrial, 4 - Pública, 5 - Outras) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Subcategoria da categoria 01 arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); //Categoria 02 (1 - Domiciliar, 2 - Comercial, 3 - Industrial, 4 - Pública, 5 - Outras) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Subcategoria da categoria 02 arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); //Categoria 03 (1 - Domiciliar, 2 - Comercial, 3 - Industrial, 4 - Pública, 5 - Outras) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Subcategoria da categoria 03 arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); //Categoria 04 (1 - Domiciliar, 2 - Comercial, 3 - Industrial, 4 - Pública, 5 - Outras) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Subcategoria da categoria 04 arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); //Categoria 05 (1 - Domiciliar, 2 - Comercial, 3 - Industrial, 4 - Pública, 5 - Outras) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(1, "")); //Subcategoria da categoria 05 arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); /* * Campo livre (será enviado e retornado) * * Identificação do sublote (QQQQLLLLSSS) (Alfanumérico) * Concatenar Quadra + Lote + Sublote */ if (movimentoRoteiroEmpresa.getNumeroQuadra() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando( 4, movimentoRoteiroEmpresa.getNumeroQuadra().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } if (movimentoRoteiroEmpresa.getNumeroLoteImovel() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando( 4, movimentoRoteiroEmpresa.getNumeroLoteImovel().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } if (movimentoRoteiroEmpresa.getNumeroSubloteImovel() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando( 3, movimentoRoteiroEmpresa.getNumeroSubloteImovel().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); } arquivoTxtLinha.append(Util.completaString("", 19)); /* * Filler (Deverá ser preenchido com espaços em branco, será utilizado quando for(em) * incluído(s) novo(s) campo(s) no READER®. O tamanho deste campo deverá ser diminuído do * tamanho total do(s) campo(s) incluído(s), então o tamanho da linha (registro) permanecerá o mesmo) * (Alfanumérico) */ arquivoTxtLinha.append(Util.completaString("", 212)); //Fixo A01 (Alfanumérico) arquivoTxtLinha.append("A01"); //Mês e Ano de referência (MM/AAAA) (Alfanumérico) arquivoTxtLinha.append(Util.formatarAnoMesParaMesAno(movimentoRoteiroEmpresa.getAnoMesMovimento())); //Grupo (Alfanumérico) if (movimentoRoteiroEmpresa.getFaturamentoGrupo() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, movimentoRoteiroEmpresa.getFaturamentoGrupo().getId().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(4, "")); } //Página (Numérico) arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(5, numeroPagina.toString())); //Localidade (Alfanumérico) if (movimentoRoteiroEmpresa.getLocalidade() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(10, movimentoRoteiroEmpresa.getLocalidade().getId().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(10, "")); } //Distrito (Alfanumérico) arquivoTxtLinha.append(Util.completaString("", 4)); //Face (Alfanumérico) if (movimentoRoteiroEmpresa.getCodigoQuadraFace() != null){ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, movimentoRoteiroEmpresa.getCodigoQuadraFace().toString())); } else{ arquivoTxtLinha.append(Util.adicionarZerosEsquedaNumeroTruncando(3, "")); } // Registro Detalhe arquivoTxt.append(arquivoTxtLinha); arquivoTxt.append(System.getProperty("line.separator")); } /** * [UC0082] Registrar Leituras e Anormalidades * * @author Raphael Rossiter * @date 03/09/2009 * * @param idFaturamentoGrupo * @param fileItem * @return Collection * @throws ControladorException */ public Collection processarArquivoTextoParaRegistrarLeiturasAnormalidades( Integer idFaturamentoGrupo, FileItem fileItem) throws ControladorException{ Collection colecaoMedicaoHistorico = new ArrayList(); // ABRINDO O ARQUIVO InputStreamReader reader; try { reader = new InputStreamReader(fileItem.getInputStream()); } catch (IOException e) { e.printStackTrace(); throw new ControladorException("erro.importacao.nao_concluida"); } // PREPARANDO OBJETO PARA LER O ARQUIVO BufferedReader buffer = new BufferedReader(reader); //VARIÁVEl PARA LER O ARQUIVO LINHA A LINHA boolean eof = false; //CARREGANDO OS DADOS DO GRUPO DE FATURAMENTO ONDE SERÃO REGISTRADAS AS LEITURAS FiltroFaturamentoGrupo filtroFaturamentoGrupo = new FiltroFaturamentoGrupo(); filtroFaturamentoGrupo.adicionarParametro(new ParametroSimples( FiltroFaturamentoGrupo.ID, idFaturamentoGrupo)); Collection colecaoFaturamentoGrupo = this.getControladorUtil() .pesquisar(filtroFaturamentoGrupo, FaturamentoGrupo.class.getName()); FaturamentoGrupo faturamentoGrupo = null; if (colecaoFaturamentoGrupo != null && !colecaoFaturamentoGrupo.isEmpty()) { faturamentoGrupo = (FaturamentoGrupo) Util .retonarObjetoDeColecao(colecaoFaturamentoGrupo); } else { throw new ControladorException("atencao.entidade.inexistente",null, "Faturamento Grupo"); } while (!eof) { // PEGANDO A LINHA DO ARQUIVO String linhaLida; try { linhaLida = buffer.readLine(); } catch (IOException e) { e.printStackTrace(); throw new ControladorException("erro.importacao.nao_concluida"); } if (linhaLida == null) { // ÚLTIMA LINHA DO ARQUIVO eof = true; } else if (linhaLida.length() == 420){ // VARIÁVEIS QUE SERÃO UTILIZADAS PARA GERAÇÃO DA MEDIÇÃO HISTÓRICO MedicaoHistorico medicaoHistorico = new MedicaoHistorico(); MedicaoTipo medicaoTipo = new MedicaoTipo(); Funcionario funcionario = new Funcionario(); LeituraAnormalidade leituraAnormalidade = new LeituraAnormalidade(); Imovel imovel = new Imovel(); SetorComercial setorComercial = new SetorComercial(); Quadra quadra = new Quadra(); //MÊS E ANO DA LEITURA String anoMesLeitura = linhaLida.substring(362, 369); //VALIDANDO O MÊS E ANO DA LEITURA boolean anoMesInvalido = Util.validarMesAno(anoMesLeitura); if (!anoMesInvalido) { throw new ControladorException("atencao.anomes.faturamento.invalido"); } if (!faturamentoGrupo.getAnoMesReferencia().equals( Util.formatarMesAnoComBarraParaAnoMes(anoMesLeitura))) { throw new ControladorException( "atencao.anomes.faturamento.nao.corresponde"); } //ID DO GRUPO DE FATURAMENTO INFORMADO NO ARQUIVO String idFaturamentoHeaderString = linhaLida.substring(369, 373).trim(); Integer idFaturamentoHeader = null; if (!idFaturamentoHeaderString.equals("")) { idFaturamentoHeader = new Integer(linhaLida.substring(369, 373)); } if (idFaturamentoHeader != null && !idFaturamentoGrupo.equals(idFaturamentoHeader)) { throw new ControladorException("atencao.nao.grupo.faturamento"); } //INICIANDO O PROCESSO DE LEITURA DO ARQUIVO // ID DO FUNCIONARIO String idFuncionario = linhaLida.substring(410, 420).trim(); if (!idFuncionario.equals("")) { funcionario.setId(new Integer(idFuncionario)); } else { funcionario.setId(null); } medicaoHistorico.setFuncionario(funcionario); //DATA DE LEITURA String dataColeta = linhaLida.substring(24, 26) + linhaLida.substring(27, 29) + linhaLida.substring(30, 34); medicaoHistorico.setDataLeituraParaRegistrar(dataColeta); //IMÓVEL String idImovel = linhaLida.substring(0, 15).trim(); System.out.println(idImovel); if (!idImovel.equals("")) { FiltroImovel filtroImovel = new FiltroImovel(); filtroImovel.adicionarCaminhoParaCarregamentoEntidade("localidade"); filtroImovel.adicionarParametro(new ParametroSimples( FiltroImovel.ID, Integer.valueOf(idImovel))); Collection colecaoImovel = this.getControladorUtil().pesquisar(filtroImovel, Imovel.class.getName()); if (colecaoImovel != null && !colecaoImovel.isEmpty()){ imovel = (Imovel) Util.retonarObjetoDeColecao(colecaoImovel); } else{ continue; } } else { imovel.setId(null); } //LOCALIDADE JA ESTÁ SENDO CARREGADA NO IMÓVEL //CÓDIGO DO SETOR COMERCIAL String codigoSetorComercial = linhaLida.substring(392, 395).trim(); if (!codigoSetorComercial.equals("")) { setorComercial.setCodigo(new Integer(linhaLida.substring(392, 395))); } else { setorComercial.setCodigo(0); } imovel.setSetorComercial(setorComercial); //NÚMERO DA QUADRA String numeroQuadra = linhaLida.substring(62, 66).trim(); if (!numeroQuadra.equals("")) { quadra.setNumeroQuadra(new Integer(linhaLida.substring(62, 66))); } else { quadra.setNumeroQuadra(0); } imovel.setQuadra(quadra); //LOTE String lote = linhaLida.substring(66, 70).trim(); if (!lote.equals("")) { imovel.setLote(new Short(lote)); } else { imovel.setLote(new Short("0")); } //SUBLOTE String subLote = linhaLida.substring(70, 73).trim(); if (!subLote.equals("")) { imovel.setSubLote(new Short(subLote)); } else { imovel.setSubLote(new Short("0")); } medicaoHistorico.setImovel(imovel); // TIPO DE MEDIÇÃO String idMedicaoTipo = "1"; medicaoTipo.setId(new Integer(idMedicaoTipo)); medicaoHistorico.setMedicaoTipo(medicaoTipo); // LEITURA DO HIDRÔMETRO String leituraHidrometro = null; leituraHidrometro = linhaLida.substring(16, 24).trim(); if (!leituraHidrometro.equals("")) { try { medicaoHistorico.setLeituraAtualInformada(new Integer( leituraHidrometro)); } catch (NumberFormatException ex) { medicaoHistorico.setLeituraAtualInformada(0); } } else { medicaoHistorico.setLeituraAtualInformada(null); } //ANORMALIDADE String idLeituraAnormalidade = linhaLida.substring(42, 46).trim(); if (!idLeituraAnormalidade.equals("")) { try { leituraAnormalidade.setId(new Integer(idLeituraAnormalidade)); } catch (NumberFormatException ex) { leituraAnormalidade.setId(0); } } else { leituraAnormalidade.setId(null); } medicaoHistorico .setLeituraAnormalidadeInformada(leituraAnormalidade); // INDICADOR DE CONFIRMAÇÃO DA LEITURA if (linhaLida.substring(15, 16).equals("S")){ medicaoHistorico.setIndicadorConfirmacaoLeitura("1"); } else{ medicaoHistorico.setIndicadorConfirmacaoLeitura("2"); } //INSERINDO A MEDIÇÃO HISTORICO QUE FOI GERADA A PARTIR DO ARQUIVO TXT colecaoMedicaoHistorico.add(medicaoHistorico); } else{ //ÚLTIMA LINHA DO ARQUIVO eof = true; } } // FECHANDO O ARQUIVO try { buffer.close(); reader.close(); fileItem.getInputStream().close(); } catch (IOException e) { e.printStackTrace(); throw new ControladorException("erro.importacao.nao_concluida"); } return colecaoMedicaoHistorico; } /** * [UC0083] - Gerar Dados para Leitura Empresa * * @author Rômulo Aurélio * @date 09/07/2008 * * @param anoMesFaturamento * @param movimentoRoteiroEmpresa * @param qtdImoveis * @param arquivoTexto * param nomeArquivo * */ public void inserirArquivoTextoRoteiroEmpresa(Integer anoMesFaturamento, MovimentoRoteiroEmpresa movimentoRoteiroEmpresa, Integer qtdImoveis, StringBuilder arquivoTexto, String nomeArquivo) throws ControladorException { boolean gerarArquivoTexto = true; ArquivoTextoRoteiroEmpresa arquivo; try { arquivo = this.repositorioMicromedicao .pesquisaArquivoTextoParaLeiturista( anoMesFaturamento,movimentoRoteiroEmpresa.getFaturamentoGrupo().getId()); } catch (ErroRepositorioException e1) { throw new ControladorException("erro.sistema", e1); } if(arquivo!=null){ if(arquivo.getSituacaoTransmissaoLeitura().getId() .compareTo(SituacaoTransmissaoLeitura.LIBERADO)==0){ this.getControladorUtil().remover(arquivo); }else{ gerarArquivoTexto = false; } } if(gerarArquivoTexto){ ArquivoTextoRoteiroEmpresa arquivoTextoRoteiroEmpresa = new ArquivoTextoRoteiroEmpresa(); // ANO_MES_REFERENCIA arquivoTextoRoteiroEmpresa.setAnoMesReferencia(anoMesFaturamento); // FATURAMENTO_GRUPO FaturamentoGrupo faturamentoGrupo = new FaturamentoGrupo(); faturamentoGrupo.setId(movimentoRoteiroEmpresa.getFaturamentoGrupo().getId()); arquivoTextoRoteiroEmpresa.setFaturamentoGrupo(faturamentoGrupo); // EMPRESA arquivoTextoRoteiroEmpresa.setEmpresa(movimentoRoteiroEmpresa .getEmpresa()); // LOCALIDADE Localidade localidade = new Localidade(); localidade.setId(movimentoRoteiroEmpresa.getLocalidade().getId()); arquivoTextoRoteiroEmpresa.setLocalidade(localidade); // CÓDIGO DO SETOR COMERCIAL arquivoTextoRoteiroEmpresa .setCodigoSetorComercial1(movimentoRoteiroEmpresa .getCodigoSetorComercial()); // MENOR E MAIOR NÚMERO DA QUADRA PARA ROTA Object[] intervalorNumeroQuadra = null; try { intervalorNumeroQuadra = this.repositorioFaturamento .pesquisarIntervaloNumeroQuadraPorRota(movimentoRoteiroEmpresa .getRota().getId()); } catch (ErroRepositorioException e) { sessionContext.setRollbackOnly(); throw new ControladorException("erro.sistema", e); } if (intervalorNumeroQuadra != null && intervalorNumeroQuadra[0] != null && intervalorNumeroQuadra[1] != null){ arquivoTextoRoteiroEmpresa .setNumeroQuadraInicial1((Integer) intervalorNumeroQuadra[0]); arquivoTextoRoteiroEmpresa .setNumeroQuadraFinal1((Integer) intervalorNumeroQuadra[1]); } else{ // PARA OS CASOS DE ROTA ALTERNATIVA arquivoTextoRoteiroEmpresa.setNumeroQuadraInicial1(0); arquivoTextoRoteiroEmpresa.setNumeroQuadraFinal1(0); } // QUANTIDADE DE IMÓVEIS arquivoTextoRoteiroEmpresa.setQuantidadeImovel(qtdImoveis); //NOME DO ARQUIVO arquivoTextoRoteiroEmpresa.setNomeArquivo(nomeArquivo); // ARQUIVO TEMPORÁRIO GERADO PARA ROTA byte[] arquivoTextoByte = null; try { arquivoTextoByte = IoUtil.transformarObjetoParaBytes(arquivoTexto); } catch (IOException e) { sessionContext.setRollbackOnly(); throw new ControladorException("erro.sistema", e); } arquivoTextoRoteiroEmpresa.setArquivoTexto(arquivoTextoByte); // SITUACAO_TRANSMISSAO_LEITURA SituacaoTransmissaoLeitura situacaoTransmissaoLeitura = new SituacaoTransmissaoLeitura(); situacaoTransmissaoLeitura.setId(SituacaoTransmissaoLeitura.LIBERADO); arquivoTextoRoteiroEmpresa .setSituacaoTransmissaoLeitura(situacaoTransmissaoLeitura); //SITUACAO_TRANSMISSAO_LEITURA ServicoTipoCelular servicoTipoCelular = new ServicoTipoCelular(); servicoTipoCelular.setId(ServicoTipoCelular.LEITURA); arquivoTextoRoteiroEmpresa .setServicoTipoCelular(servicoTipoCelular); // ULTIMA ALTERACAO arquivoTextoRoteiroEmpresa.setUltimaAlteracao(new Date()); // INSERINDO NA BASE this.getControladorUtil().inserir(arquivoTextoRoteiroEmpresa); } } //valida anoMes para caso de uso anlise excecoes leituras public boolean validaDataFaturamentoIncompativel(String anoMesReferencia, String anoMesAtual) { boolean retorno = true; String anoMesReferenciaMaisUmMes = "" + Util.somarData(new Integer(anoMesReferencia)); String anoMesReferenciaMenosUmMes = "" + Util.subtrairMesDoAnoMes(new Integer(anoMesReferencia), 1); if (!((Util.compararAnoMesReferencia(new Integer(anoMesReferencia), new Integer(anoMesAtual), "=")) || (Util.compararAnoMesReferencia(new Integer( anoMesReferenciaMaisUmMes), new Integer(anoMesAtual), "=")) || (Util.compararAnoMesReferencia(new Integer( anoMesReferenciaMenosUmMes), new Integer(anoMesAtual), "=")))) { retorno = false; } return retorno; } //valida anoMes para caso de uso anlise excecoes leituras public boolean validaDataFaturamentoIncompativelInferior( String anoMesReferencia, String anoMesAnterior) { boolean retorno = true; String anoMesReferenciaMenosUmMes = "" + Util.subtrairMesDoAnoMes(new Integer(anoMesReferencia), 2); // Comparando a data anterior faturada no form com o ano // mês // referência e com o ano mês anterior if (!((Util.compararAnoMesReferencia(new Integer(anoMesReferencia), new Integer(anoMesAnterior), "=")) || (Util.compararAnoMesReferencia(new Integer( anoMesReferenciaMenosUmMes), new Integer(anoMesAnterior), "=")) || (Util .compararAnoMesReferencia(new Integer(anoMesReferencia), new Integer(Util.somaMesAnoMesReferencia(new Integer( anoMesAnterior), 1)), "=")))) { retorno = false; } return retorno; } }