From 40a440bb61ee5710a9d727e8b52b9889df0d3ef2 Mon Sep 17 00:00:00 2001 From: eduardo.praxedes Date: Mon, 17 Oct 2016 21:49:16 -0200 Subject: [PATCH] Correção dos bugs na lista de processos expedidos, na acentuação dos interessados no destinatário, referência cruzada e Exibição do Download de Recibods --- LEIAME.txt | 3 ++- pen_procedimento_expedido_listar.php | 4 ++-- rn/EnviarReciboTramiteRN.php | 91 +++---------------------------------------------------------------------------------------- rn/ProcessoEletronicoRN.php | 9 ++++----- rn/ReceberProcedimentoRN.php | 4 ++-- sip_atualizar_versao_modulo_pen.php | 1269 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++---------------------------------------- verificar-servicos.sh | 50 ++++++++++++++++++++++++++------------------------ 7 files changed, 1268 insertions(+), 162 deletions(-) diff --git a/LEIAME.txt b/LEIAME.txt index 9ac97c7..562cde8 100644 --- a/LEIAME.txt +++ b/LEIAME.txt @@ -147,5 +147,6 @@ PROCEDIMENTOS PARA INSTALAÇÂO: 17) O Barramento de PEN ao calcular os hashs para gerar recibos de tramite, leva em consideração a data/horário. Portanto é importante que todos os nós da aplicação esteja sincronizados com o NTP.br. Este link pode ajudar a configurar conforme o SO utilizado: https://www.vivaolinux.com.br/artigo/Servidor-NTP-Configuracao-e-ajuste-de-data-e-hora - + + 18) É altamente aconselhável deixar o arquivo .pem do certificado digital fora do path do apache (var/www/html) diff --git a/pen_procedimento_expedido_listar.php b/pen_procedimento_expedido_listar.php index 7477b8c..e7d1df3 100644 --- a/pen_procedimento_expedido_listar.php +++ b/pen_procedimento_expedido_listar.php @@ -20,7 +20,7 @@ try { $objFiltroDTO = new ProtocoloDTO(); $objFiltroDTO->setStrStaEstado(ProtocoloRN::$TE_BLOQUEADO); $objFiltroDTO->setNumIdTarefaAtividade(ProcessoEletronicoRN::$TI_PROCESSO_ELETRONICO_PROCESSO_EXPEDIDO); - $objFiltroDTO->setDistinct(true); + // $objFiltroDTO->setDistinct(true); $objFiltroDTO->retDblIdProtocolo(); $objFiltroDTO->retStrProtocoloFormatado(); @@ -53,7 +53,7 @@ try { if(!empty($arrObjProcessoExpedidoDTO)) { $arrObjProcessoExpedidoDTO = InfraArray::distinctArrInfraDTO($arrObjProcessoExpedidoDTO, 'IdProtocolo'); - + $numRegistros = count($arrObjProcessoExpedidoDTO); } } diff --git a/rn/EnviarReciboTramiteRN.php b/rn/EnviarReciboTramiteRN.php index 0eedb08..027e54e 100644 --- a/rn/EnviarReciboTramiteRN.php +++ b/rn/EnviarReciboTramiteRN.php @@ -94,9 +94,6 @@ class EnviarReciboTramiteRN extends InfraRN if($objTramite->situacaoAtual != ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_COMPONENTES_RECEBIDOS_DESTINATARIO) { return; } - - - //TODO: Verificar necessidade de dessa validação //Verificar se todos os componentes digitais foram obtidos e validados @@ -119,94 +116,10 @@ class EnviarReciboTramiteRN extends InfraRN //} //TODO: Analisar necessidade do tratamento de datas abaixo já que todos os servidores que integrarem ao PEN deverão estar sincronizados - //com o $dthRecebimentoComponentesDigitais = $this->obterDataRecebimentoComponentesDigitais($objTramite); $dthRecebimentoComponentesDigitais = $dthRecebimentoComponentesDigitais ?: date(); $dthRecebimento = gmdate("Y-m-d\TH:i:s.000\Z", InfraData::getTimestamp($dthRecebimentoComponentesDigitais)); -// if($parArrObjComponenteDigitalDTO == null) { -// $parArrObjComponenteDigitalDTO = $this->listarComponenteDigitalDTO($parNumIdTramite); -// } -// $arrHashConteudo = InfraArray::converterArrInfraDTO($parArrObjComponenteDigitalDTO, 'HashConteudo', null); -// sort($arrHashConteudo); -// -// // @join_tec US008.11 (#23092) -// if(empty($arrHashConteudo)) { -// // Caso de retrasmição os componentes digitais não são reenviados, então -// // não é gravado o recibo. Adicionamos alguma possição no array para -// // gravar pelo menos um recibo. -// $arrHashConteudo[] = ''; -// } - - //Busca os metadados do processo - /* $objMetaRetorno = $this->objProcessoEletronicoRN->solicitarMetadados($numIdTramite); - - //Obtem os dados necessários para consultar os trâmites relacionados a unidade destinatário e ao processo recebido - $parProtocolo = $objMetaRetorno->metadados->processo->protocolo; - $parNumeroUnidadeDestino = $objMetaRetorno->metadados->destinatario->numeroDeIdentificacaoDaEstrutura; - $parNumeroRepositorioEstruturas = $objMetaRetorno->metadados->destinatario->identificacaoDoRepositorioDeEstruturas; - - //Consulta os trâmites relacionados - $arrObjTramites = new $this->objProcessoEletronicoRN->consultarTramites($parNumIdTramite, null, null, $parNumeroUnidadeDestino, $parProtocolo, $parNumeroRepositorioEstruturas); - $arrObjTramites = is_array($arrObjTramites->tramitesEncontrados->tramite) ? $arrObjTramites->tramitesEncontrados->tramite : array($arrObjTramites->tramitesEncontrados->tramite); - - $arrTramitesAnteriores = array(); - - foreach($arrObjTramite as $tramiteAntigo){ - if($tramiteAntigo->IDT != $parNumIdTramite){ - $arrTramitesAnteriores[] = $tramiteAntigo; - } - } - - $arrHashTramitesAnteriores = array(); - - foreach($arrTramitesAnteriores as $tramiteAntigo){ - - //Solicita os metadados desse trâmite - $objMetaTramiteAntigo = $this->objProcessoEletronicoRN->solicitarMetadados($tramiteAntigo); - - //Transforma os documento em um array - $arrDocumentosTramiteAntigo = is_array($objMetaTramiteAntigo->metadados->processo->documento) ? $objMetaTramiteAntigo->metadados->processo->documento : array($objMetaTramiteAntigo->metadados->processo->documento); - - - } - - - */ - - /* - $arrStrHashConteudo = array(); - - $objMetaRetorno = $this->objProcessoEletronicoRN->solicitarMetadados($numIdTramite); - - $objMetaProcesso = $objMetaRetorno->metadados->processo; - - $arrObjMetaDocumento = is_array($objMetaProcesso->documento) ? $objMetaProcesso->documento : array($objMetaProcesso->documento); - - $objDTO = new ComponenteDigitalDTO(); - $objBD = new ComponenteDigitalBD($this->inicializarObjInfraIBanco()); - - foreach($arrObjMetaDocumento as $objMetaDocumento) { - - $strHashConteudo = ProcessoEletronicoRN::getHashFromMetaDados($objMetaDocumento->componenteDigital->hash); - - $objDTO->setStrHashConteudo($strHashConteudo); - - if($objBD->contar($objDTO) > 0) { - - $arrStrHashConteudo[] = $strHashConteudo; - } - } - - return $arrStrHashConteudo;*/ - - //$arrHashConteudo = $this->gerarReciboTramite($parNumIdTramite); - - /* foreach($parArrayHash as $strHashConteudo) { - - // @join_tec R003 S001 US036 (#3869) - $this->cadastrarReciboTramiteRecebimento($strNumeroRegistro, $parNumIdTramite, $strHashConteudo); - }*/ $strReciboTramite = ""; $strReciboTramite .= "$parNumIdTramite"; @@ -221,8 +134,10 @@ class EnviarReciboTramiteRN extends InfraRN } $strReciboTramite .= ""; + //Envia o Recibo de salva no banco + $hashAssinatura = $this->objProcessoEletronicoRN->enviarReciboDeTramite($parNumIdTramite, $dthRecebimento, $strReciboTramite); + $this->cadastrarReciboTramiteRecebimento($strNumeroRegistro, $parNumIdTramite, $hashAssinatura); - $this->objProcessoEletronicoRN->enviarReciboDeTramite($parNumIdTramite, $dthRecebimento, $strReciboTramite); } private function obterDataRecebimentoComponentesDigitais($parObjTramite){ diff --git a/rn/ProcessoEletronicoRN.php b/rn/ProcessoEletronicoRN.php index 0e2f97f..cad2cab 100644 --- a/rn/ProcessoEletronicoRN.php +++ b/rn/ProcessoEletronicoRN.php @@ -1069,7 +1069,7 @@ class ProcessoEletronicoRN extends InfraRN { } } - public function enviarReciboDeTramite($parNumIdTramite, $parDthRecebimento, $parStrReciboTramite) + public function enviarReciboDeTramite($parNumIdTramite, $parDthRecebimento, $parStrReciboTramite) { try { @@ -1080,8 +1080,6 @@ class ProcessoEletronicoRN extends InfraRN { throw new InfraException("Erro ao obter chave privada do certificado digital."); } - // $recibo = $parStrReciboTramite; - openssl_sign($parStrReciboTramite, $strHashAssinatura, $objPrivatekey, 'sha256'); $strHashDaAssinaturaBase64 = base64_encode($strHashAssinatura); @@ -1092,9 +1090,10 @@ class ProcessoEletronicoRN extends InfraRN { $parametro->dadosDoReciboDeTramite->dataDeRecebimento = $parDthRecebimento; $parametro->dadosDoReciboDeTramite->hashDaAssinatura = $strHashDaAssinaturaBase64; - // throw new InfraException('TESTE '.var_export($parametro, true)." DELIMITADOR ".$recibo); - return $this->getObjPenWs()->enviarReciboDeTramite($parametro); + $this->getObjPenWs()->enviarReciboDeTramite($parametro); + + return $strHashDaAssinaturaBase64; } catch (\SoapFault $fault) { diff --git a/rn/ReceberProcedimentoRN.php b/rn/ReceberProcedimentoRN.php index 5b31fd5..6a1295c 100644 --- a/rn/ReceberProcedimentoRN.php +++ b/rn/ReceberProcedimentoRN.php @@ -887,7 +887,7 @@ class ReceberProcedimentoRN extends InfraRN $objInteressado = $arrObjInteressados[$i]; $objParticipanteDTO = new ParticipanteDTO(); $objParticipanteDTO->setStrSiglaContato($objInteressado->numeroDeIdentificacao); - $objParticipanteDTO->setStrNomeContato($objInteressado->nome); + $objParticipanteDTO->setStrNomeContato(utf8_decode($objInteressado->nome)); $objParticipanteDTO->setStrStaParticipacao(ParticipanteRN::$TP_INTERESSADO); $objParticipanteDTO->setNumSequencia($i); $arrObjParticipantesDTO[] = $objParticipanteDTO; @@ -1102,7 +1102,7 @@ class ReceberProcedimentoRN extends InfraRN $objProtocoloDTO->setStrDescricao(utf8_decode($objDocumento->descricao)); $objDocumentoDTO->setStrNumero(utf8_decode($objDocumento->descricao)); }else{ - $objProtocoloDTO->setStrDescricao(""); + $objProtocoloDTO->setStrDescricao(""); $objDocumentoDTO->setStrNumero(""); } //TODO: Avaliar regra de formação do número do documento diff --git a/sip_atualizar_versao_modulo_pen.php b/sip_atualizar_versao_modulo_pen.php index 3ab0ecf..9566060 100644 --- a/sip_atualizar_versao_modulo_pen.php +++ b/sip_atualizar_versao_modulo_pen.php @@ -1,63 +1,1252 @@ getObjInfraIBanco(); + + $strTableDrive = get_parent_class($objInfraBanco); + $strQuery = ''; + + switch($strTableDrive) { + + case 'InfraMySql': + $strQuery = sprintf("ALTER TABLE `%s` ALTER COLUMN `%s` SET DEFAULT '%s'", $strNomeTabela, $strNomeColuna, $strValorPadrao); + break; + + case 'InfraSqlServer': + $strQuery = sprintf("ALTER TABLE [%s] ADD DEFAULT('%s') FOR [%s]", $strNomeTabela, $strValorPadrao, $strNomeColuna); + + case 'InfraOracle': + break; + } + + if($bolRetornarQuery === false) { + + $objInfraBanco->executarSql($strQuery); + } + else { + + return $strQuery; + } + } + + /** + * Verifica se o usuário do drive de conexão possui permissão para criar/ remover + * estruturas + * + * @return PenMetaBD + */ + public function isDriverPermissao(){ + + $objInfraBanco = $this->getObjInfraIBanco(); + + if(count($this->obterTabelas('sei_teste'))==0){ + $objInfraBanco->executarSql('CREATE TABLE sei_teste (id '.$this->tipoNumero().' NULL)'); + } + + $objInfraBanco->executarSql('DROP TABLE sei_teste'); + + return $this; + } + + /** + * Verifica se o banco do SEI é suportador pelo atualizador + * + * @throws InfraException + * @return PenMetaBD + */ + public function isDriverSuportado(){ + + $strTableDrive = get_parent_class($this->getObjInfraIBanco()); + + switch($strTableDrive) { + + case 'InfraMySql': + // Fix para bug de MySQL versão inferior ao 5.5 o default engine + // é MyISAM e não tem suporte a FOREING KEYS + $this->getObjInfraIBanco()->executarSql('SET STORAGE_ENGINE=InnoDB'); + case 'InfraSqlServer': + case 'InfraOracle': + break; + + default: + throw new InfraException('BANCO DE DADOS NAO SUPORTADO: ' . $strTableDrive); + + } + + return $this; + } + + /** + * Verifica se a versão sistema é compativel com a versão do módulo PEN + * + * @throws InfraException + * @return PenMetaBD + */ + public function isVersaoSuportada($strRegexVersaoSistema, $strVerMinRequirida){ + + $numVersaoRequerida = intval(preg_replace('/\D+/', '', $strVerMinRequirida)); + $numVersaoSistema = intval(preg_replace('/\D+/', '', $strRegexVersaoSistema)); + + if($numVersaoRequerida > $numVersaoSistema){ + throw new InfraException('VERSAO DO FRAMEWORK PHP INCOMPATIVEL (VERSAO ATUAL '.$strRegexVersaoSistema.', VERSAO REQUERIDA '.$strVerMinRequirida.')'); + } + + return $this; + } + + /** + * Apaga a chave primária da tabela + * + * @throws InfraException + * @return PenMetaBD + */ + public function removerChavePrimaria($strNomeTabela, $strNomeChave){ + + if($this->isChaveExiste($strNomeTabela, $strNomeChave)) { + + $strTableDrive = get_parent_class($this->getObjInfraIBanco()); + + switch($strTableDrive) { + + case 'InfraMySql': + $this->getObjInfraIBanco()->executarSql('ALTER TABLE '.$strNomeTabela.' DROP PRIMARY KEY'); + break; + + case 'InfraSqlServer': + $this->getObjInfraIBanco()->executarSql('ALTER TABLE '.$strNomeTabela.' DROP CONSTRAINT '.$strNomeChave); + break; + + case 'InfraOracle': + break; + } + } + return $this; + } + + public function isChaveExiste($strNomeTabela = '', $strNomeChave = ''){ + + $objInfraBanco = $this->getObjInfraIBanco(); + $strTableDrive = get_parent_class($objInfraBanco); + + switch($strTableDrive) { + + case 'InfraMySql': + $strSql = " SELECT COUNT(CONSTRAINT_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.TABLE_CONSTRAINTS + WHERE CONSTRAINT_SCHEMA = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."' + AND CONSTRAINT_NAME = '".$strNomeChave."'"; + break; + + case 'InfraSqlServer': + + $strSql = " SELECT COUNT(CONSTRAINT_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.TABLE_CONSTRAINTS + WHERE CONSTRAINT_CATALOG = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."' + AND CONSTRAINT_NAME = '".$strNomeChave."'"; + break; + + case 'InfraOracle': + $strSql = "SELECT 0 AS EXISTE"; + break; + } + + $strSql = preg_replace('/\s+/', ' ', $strSql); + $arrDados = $objInfraBanco->consultarSql($strSql); + + return (intval($arrDados[0]['EXISTE']) > 0) ? true : false; + } + + public function adicionarChaveUnica($strNomeTabela = '', $arrNomeChave = array()){ + + $this->getObjInfraIBanco() + ->executarSql('ALTER TABLE '.$strNomeTabela.' ADD CONSTRAINT UK_'.$strNomeTabela.' UNIQUE('.implode(', ', $arrNomeChave).')'); + } + + public function renomearTabela($strNomeTabelaAtual, $strNomeTabelaNovo){ + + if($this->isTabelaExiste($strNomeTabelaAtual)) { + + $objInfraBanco = $this->getObjInfraIBanco(); + + $strTableDrive = get_parent_class($objInfraBanco); + $strQuery = ''; + + switch ($strTableDrive) { + + case 'InfraMySql': + $strQuery = sprintf("ALTER TABLE `%s` RENAME TO `%s`", $strNomeTabelaAtual, $strNomeTabelaNovo); + break; + + case 'InfraSqlServer': + $strQuery = sprintf("sp_rename '%s', '%s'", $strNomeTabelaAtual, $strNomeTabelaNovo); + + case 'InfraOracle': + $strQuery = sprintf("RENAME TABLE %s TO %s", $strNomeTabelaAtual, $strNomeTabelaNovo); + break; + } + + $objInfraBanco->executarSql($strQuery); + } + } + + + /** + * Verifica se uma tabela existe no banco + * + * @throws InfraException + * @return bool + */ + public function isTabelaExiste($strNomeTabela = ''){ + + $objInfraBanco = $this->getObjInfraIBanco(); + $strTableDrive = get_parent_class($objInfraBanco); + + switch($strTableDrive) { + + case 'InfraMySql': + $strSql = "SELECT COUNT(TABLE_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.TABLES + WHERE TABLE_SCHEMA = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."'"; + break; + + case 'InfraSqlServer': + + $strSql = "SELECT COUNT(TABLE_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.TABLES + WHERE TABLE_CATALOG = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."'"; + break; + + case 'InfraOracle': + $strSql = "SELECT 0 AS EXISTE"; + break; + } + + $strSql = preg_replace('/\s+/', ' ', $strSql); + $arrDados = $objInfraBanco->consultarSql($strSql); + + return (intval($arrDados[0]['EXISTE']) > 0) ? true : false; + } + + public function isColuna($strNomeTabela = '', $strNomeColuna = ''){ + + $objInfraBanco = $this->getObjInfraIBanco(); + $strTableDrive = get_parent_class($objInfraBanco); + + switch($strTableDrive) { + + case 'InfraMySql': + $strSql = "SELECT COUNT(TABLE_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.COLUMNS + WHERE TABLE_SCHEMA = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."' + AND COLUMN_NAME = '".$strNomeColuna."'"; + break; + + case 'InfraSqlServer': + + $strSql = "SELECT COUNT(COLUMN_NAME) AS EXISTE + FROM INFORMATION_SCHEMA.COLUMNS + WHERE TABLE_CATALOG = '".$objInfraBanco->getBanco()."' + AND TABLE_NAME = '".$strNomeTabela."' + AND COLUMN_NAME = '".$strNomeColuna."'"; + break; + + case 'InfraOracle': + $strSql = "SELECT 0 AS EXISTE"; + break; + } + + $strSql = preg_replace('/\s+/', ' ', $strSql); + $arrDados = $objInfraBanco->consultarSql($strSql); + + return (intval($arrDados[0]['EXISTE']) > 0) ? true : false; + + + } + + /** + * Cria a estrutura da tabela no padrão ANSI + * + * @throws InfraException + * @return PenMetaBD + */ + public function criarTabela($arrSchema = array()){ + + $strNomeTabela = $arrSchema['tabela']; + + + if($this->isTabelaExiste($strNomeTabela)) { + return $this; + } + + $objInfraBanco = $this->getObjInfraIBanco(); + $arrColunas = array(); + $arrStrQuery = array(); + + foreach($arrSchema['cols'] as $strNomeColuna => $arrColunaConfig) { + + list($strTipoDado, $strValorPadrao) = $arrColunaConfig; + + if($strValorPadrao != self::SNULLO && $strValorPadrao != self::NNULLO) { + + $arrStrQuery[] = $this->adicionarValorPadraoParaColuna($strNomeTabela, $strNomeColuna, $strValorPadrao, true); + $strValorPadrao = self::NNULLO; + } + + $arrColunas[] = $strNomeColuna.' '.$strTipoDado.' '.$strValorPadrao; + } + + $objInfraBanco->executarSql('CREATE TABLE '.$strNomeTabela.' ('.implode(', ', $arrColunas).')'); + + if(!empty($arrSchema['pk'])) { + + $this->adicionarChavePrimaria($strNomeTabela, 'pk_'.$strNomeTabela, $arrSchema['pk']); + + if(count($arrSchema['pk']) > 1) { + + foreach($arrSchema['pk'] as $strPk) { + + $objInfraBanco->executarSql('CREATE INDEX idx_'.$strNomeTabela.'_'.$strPk.' ON '.$strNomeTabela.'('.$strPk.')'); + } + } + } + + if(array_key_exists('uk', $arrSchema) && !empty($arrSchema['uk'])) { + + $this->adicionarChaveUnica($strNomeTabela, $arrSchema['uk']); + } + + if(!empty($arrSchema['fks'])) { + + foreach($arrSchema['fks'] as $strTabelaOrigem => $array) { + + $strNomeFK = 'fk_'.$strNomeTabela.'_'.$strTabelaOrigem; + $arrCamposOrigem = (array)array_shift($array); + $arrCampos = $arrCamposOrigem; + + if(!empty($array)) { + $arrCampos = (array)array_shift($array); + } + + $this->adicionarChaveEstrangeira($strNomeFK, $strNomeTabela, $arrCampos, $strTabelaOrigem, $arrCamposOrigem); + } + } + + if(!empty($arrStrQuery)) { + + foreach($arrStrQuery as $strQuery) { + $objInfraBanco->executarSql($strQuery); + } + } + + return $this; + } + + /** + * Apagar a estrutura da tabela no banco de dados + * + * @throws InfraException + * @return PenMetaBD + */ + public function removerTabela($strNomeTabela = ''){ + + $this->getObjInfraIBanco()->executarSql('DROP TABLE '.$strNomeTabela); + return $this; + } + + public function adicionarChaveEstrangeira($strNomeFK, $strTabela, $arrCampos, $strTabelaOrigem, $arrCamposOrigem) { + + if(!$this->isChaveExiste($strTabela, $strNomeFK)) { + parent::adicionarChaveEstrangeira($strNomeFK, $strTabela, $arrCampos, $strTabelaOrigem, $arrCamposOrigem); + } + return $this; + } + + public function adicionarChavePrimaria($strTabela, $strNomePK, $arrCampos) { + + if(!$this->isChaveExiste($strTabela, $strNomePK)) { + parent::adicionarChavePrimaria($strTabela, $strNomePK, $arrCampos); + } + return $this; + } + + public function alterarColuna($strTabela, $strColuna, $strTipo, $strNull = '') { + parent::alterarColuna($strTabela, $strColuna, $strTipo, $strNull); + return $this; + } + + public function excluirIndice($strTabela, $strIndex) { + if($this->isChaveExiste($strTabela, $strFk)) { + parent::excluirIndice($strTabela, $strIndex); + } + return $this; + } + + public function excluirChaveEstrangeira($strTabela, $strFk) { + if($this->isChaveExiste($strTabela, $strFk)) { + parent::excluirChaveEstrangeira($strTabela, $strFk); + } + return $this; + } +} + +abstract class PenAtualizadorRN extends InfraRN { + + const VER_NONE = '0.0.0'; // Modulo não instalado + const VER_001 = '0.0.1'; + const VER_002 = '0.0.2'; + const VER_003 = '0.0.3'; + const VER_004 = '0.0.4'; + const VER_005 = '0.0.5'; + + protected $sei_versao; + + /** + * @var string Versão mínima requirida pelo sistema para instalação do PEN + */ + protected $versaoMinRequirida; + + /** + * @var InfraIBanco Instância da classe de persistência com o banco de dados + */ + protected $objBanco; + + /** + * @var InfraMetaBD Instância do metadata do banco de dados + */ + protected $objMeta; + + /** + * @var InfraDebug Instância do debuger + */ + protected $objDebug; + + /** + * @var integer Tempo de execução do script + */ + protected $numSeg = 0; + + /** + * @var array Argumentos passados por linha de comando ao script + */ + protected $arrArgs = array(); + + /** + * Inicia a conexão com o banco de dados + */ + protected function inicializarObjMetaBanco() { + if (empty($this->objMeta)) { + $this->objMeta = new PenMetaBD($this->inicializarObjInfraIBanco()); + } + return $this->objMeta; + } + + /** + * Adiciona uma mensagem ao output para o usuário + * + * @return null + */ + protected function logar($strMsg) { + $this->objDebug->gravar($strMsg); + } + + /** + * Inicia o script criando um contator interno do tempo de execução + * + * @return null + */ + protected function inicializar($strTitulo) { + + $this->numSeg = InfraUtil::verificarTempoProcessamento(); + + $this->logar($strTitulo); + } + + /** + * Finaliza o script informando o tempo de execução. + * + * @return null + */ + protected function finalizar() { + + $this->logar('TEMPO TOTAL DE EXECUCAO: ' . InfraUtil::verificarTempoProcessamento($this->numSeg) . ' s'); + + $this->objDebug->setBolLigado(false); + $this->objDebug->setBolDebugInfra(false); + $this->objDebug->setBolEcho(false); + + print PHP_EOL; + die(); + } + + /** + * Método criado em função de um bug com a InfraRN na linha 69, onde usamos + * uma instância do banco do SIP e a versão esta no banco SEI, essa verificação + * e lançamento de uma excessão pelos bancos terem nome diferentes tava o + * atualizado + * + * @todo Migrar para classe PenMetaBD + * @return null + */ + protected function setVersao($strRegexVersao, $objInfraBanco = null) { + + InfraDebug::getInstance()->gravarInfra(sprintf('[%s->%s]', get_class($this), __FUNCTION__)); + + + if ($this->getVersao($objInfraBanco)) { + + $sql = sprintf("UPDATE infra_parametro SET valor = '%s' WHERE nome = '%s'", $strRegexVersao, $this->sei_versao); + } else { + + $sql = sprintf("INSERT INTO infra_parametro(nome, valor) VALUES('%s', '%s')", $this->sei_versao, $strRegexVersao); + } + + if (empty($objInfraBanco)) { + + $objInfraBanco = $this->inicializarObjInfraIBanco(); + } + + $objInfraBanco->executarSql($sql); + + return $strRegexVersao; + } + + /** + * Retorna a versão atual do modulo, se já foi instalado + * + * @todo Migrar para classe PenMetaBD + * @param InfraBanco $objInfraBanco Conexão com o banco SEI ou SIP + * @return string + */ + protected function getVersao($objInfraBanco = null) { + + InfraDebug::getInstance()->gravarInfra(sprintf('[%s->%s]', get_class($this), __FUNCTION__)); + + $sql = sprintf("SELECT valor FROM infra_parametro WHERE nome = '%s'", $this->sei_versao); + + if (empty($objInfraBanco)) { + + $objInfraBanco = $this->inicializarObjInfraIBanco(); + } + + $arrResultado = $objInfraBanco->consultarSql($sql); + + if (empty($arrResultado)) { + return null; + } + + $arrLinha = current($arrResultado); + + return $arrLinha['valor']; + } + + /** + * Verifica se o número da versão é valido + * + * @param string $strVersao Versão a ser instalada + * @return bool + */ + protected function isVersaoValida($strVersao = self::VER_NONE) { + + if (empty($strVersao)) { + return false; + } + + // Remove os caracteres não númericos + $strVersao = preg_replace('/\D+/', '', $strVersao); + + // Tem que no mínimo 3 digitos + if (strlen($strVersao) < 3) { + return false; + } + + return is_numeric($strVersao) ? true : false; + } + + /** + * Verifica se um paramêtro existe, caso sim retorna o seu valor, senão + * retorna o default especificado. + * + * @param string $strChave Nome do paramêtro + * @param string $strParam String a ser formatada com o valor do paramêtro + * @param string $strParamDefault String que retorna caso o valor do + * paramêtro não exista + * @param bool $bolAlgumFiltroUsado Ponteiro de controle para verificar se + * pelo menos um paramêtro foi encontrado + * @return string + */ + private function getStrArg($strChave = '', $strParam = '', $strParamDefault = '', &$bolAlgumFiltroUsado) { + + if (array_key_exists($strChave, $this->arrArgs)) { + $bolAlgumFiltroUsado = true; + return sprintf($strParam, str_pad($this->arrArgs[$strChave], 3, '0', STR_PAD_LEFT)); + } + return $strParamDefault; + } + + /** + * Retorna a última versão disponivel. Verifica as constantes que iniciam + * com VER_ + */ + private function getUltimaVersao() { + + $objReflection = new ReflectionClass(__CLASS__); + $arrVersao = array_flip(preg_grep('/^VER\_/', array_flip($objReflection->getConstants()))); + sort($arrVersao); + return array_pop($arrVersao); + } + + /** + * Encontra os métodos com notação para instalar a versão selecionada + * + * @return string Número da versão + */ + protected function executarControlado() { + + $this->inicializarObjMetaBanco() + ->isDriverSuportado() + ->isDriverPermissao(); + //->isVersaoSuportada(SEI_VERSAO, $this->versaoMinRequirida); + + $arrMetodo = array(); + + // Retorna a última versão disponibilizada pelo script. Sempre tenta atualizar + // para versão mais antiga + $strVersaoInstalar = $this->getUltimaVersao(); + + //throw new InfraException($strVersaoInstalar); + $objInfraBanco = $this->inicializarObjInfraIBanco(); + // Versão atual + $strPenVersao = $this->getVersao($objInfraBanco); + if (!$this->isVersaoValida($strPenVersao)) { + // Não instalado + $strPenVersao = $this->setVersao(self::VER_NONE, $objInfraBanco); + } + + $numPenVersao = substr($strPenVersao, -1); + $numVersaoInstalar = intval(substr($strVersaoInstalar, -1)); + + $bolAlgumFiltroUsado = false; + $strRegexRelease = $this->getStrArg('release', '(R%s)', '(R[0-9]{1,3})?', $bolAlgumFiltroUsado); + $strRegexSprint = $this->getStrArg('sprint', '(S%s)', '(S[0-9]{1,3})?', $bolAlgumFiltroUsado); + $strRegexItem = $this->getStrArg('user-story', '(US%s)', '(US|IW[0-9]{1,3})?', $bolAlgumFiltroUsado); + $strRegexItem = $this->getStrArg('item-worker', '(IW%s)', $strRegexItem, $bolAlgumFiltroUsado); + + // Instalar todas atualizações + if ($bolAlgumFiltroUsado === false) { + + $strRegexVersao = sprintf('[%d-%d]', ($numPenVersao + 1), $numVersaoInstalar); + } + // Instalar somente a solicitada + else { + // Caso algum paramêtro seja adicionado não deve passar para próxima versão + $strVersaoInstalar = $strPenVersao; + $strRegexVersao = intval(substr($strPenVersao, -1) + 1); + } + + // instalarV[0-9]{1,2}[0-9](R[0-9]{1,3})?(S[0-9]{1,3})?(US|IW[0-9]{1,4})? + $strRegex = sprintf('/^instalarV[0-9][0-9]%s%s%s%s/i', $strRegexVersao, $strRegexRelease, $strRegexSprint, $strRegexItem + ); + + // Tenta encontrar métodos que iniciem com instalar + $arrMetodo = (array) preg_grep($strRegex, get_class_methods($this)); + + if (empty($arrMetodo)) { + + throw new InfraException(sprintf('NENHUMA ATUALIZACAO FOI ENCONTRADA SUPERIOR A VERSAO %s DO MODULO PEN', $strPenVersao)); + } else { + + foreach ($arrMetodo as $strMetodo) { + + $this->{$strMetodo}(); + } + } + $this->setVersao($strVersaoInstalar, $objInfraBanco); + + return $strVersaoInstalar; + } + + /** + * Método que inicia o processo + */ + public function atualizarVersao() { + + $this->inicializar('INICIANDO ATUALIZACAO DO MODULO PEN NO SEI VERSAO ' . SEI_VERSAO); + + try { + + $strRegexVersao = $this->executar(); + $this->logar('ATUALIZADA VERSAO: ' . $strRegexVersao); + } catch (InfraException $e) { + + $this->logar('Erro: ' . $e->getStrDescricao()); + } catch (\Exception $e) { + + $this->logar('Erro: ' . $e->getMessage()); + } + + $this->finalizar(); + } + + /** + * Construtor + * + * @param array $arrArgs Argumentos enviados pelo script + */ + public function __construct($arrArgs = array()) { + + ini_set('max_execution_time', '0'); + ini_set('memory_limit', '-1'); + @ini_set('zlib.output_compression', '0'); + @ini_set('implicit_flush', '1'); + ob_implicit_flush(); + + $this->arrArgs = $arrArgs; + + $this->inicializarObjMetaBanco(); + + $this->objDebug = InfraDebug::getInstance(); + $this->objDebug->setBolLigado(true); + $this->objDebug->setBolDebugInfra(true); + $this->objDebug->setBolEcho(true); + $this->objDebug->limpar(); + } + +} + +class PenAtualizarSipRN extends PenAtualizadorRN { + + protected $versaoMinRequirida = '1.30.0'; + protected $sei_versao = 'PEN_VERSAO_MODULO_SIP'; + private $arrRecurso = array(); + private $arrMenu = array(); + + /** + * Retorna/Cria a conexão com o banco de dados + * + * @return InfraIBanco + */ + protected function inicializarObjInfraIBanco() { + if (empty($this->objBanco)) { + + $this->objBanco = BancoSip::getInstance(); + } + return $this->objBanco; + } + + /** + * Retorna o ID do sistema + * + * @return int + */ + protected function getNumIdSistema($strSigla = 'SIP') { + + $objDTO = new SistemaDTO(); + $objDTO->setStrSigla($strSigla); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdSistema(); + + $objRN = new SistemaRN(); + $objDTO = $objRN->consultar($objDTO); + + return (empty($objDTO)) ? '0' : $objDTO->getNumIdSistema(); + } + + /** + * + * @return int Código do Menu + */ + protected function getNumIdMenu($strMenu = 'Principal', $numIdSistema = 0) { + + $objDTO = new MenuDTO(); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setStrNome($strMenu); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdMenu(); + + $objRN = new MenuRN(); + $objDTO = $objRN->consultar($objDTO); + + if (empty($objDTO)) { + throw new InfraException('Menu ' . $strMenu . ' não encontrado.'); + } + + return $objDTO->getNumIdMenu(); + } + + /** + * + * @return int Código do Recurso gerado + */ + protected function criarRecurso($strNome = '', $strDescricao = null, $numIdSistema = 0) { + + $objDTO = new RecursoDTO(); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setStrNome($strNome); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdRecurso(); + + $objBD = new RecursoBD($this->getObjInfraIBanco()); + $objDTO = $objBD->consultar($objDTO); + + if (empty($objDTO)) { + + $objDTO = new RecursoDTO(); + $objDTO->setNumIdRecurso(null); + $objDTO->setStrDescricao($strDescricao); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setStrNome($strNome); + $objDTO->setStrCaminho('controlador.php?acao=' . $strNome); + $objDTO->setStrSinAtivo('S'); + + $objDTO = $objBD->cadastrar($objDTO); + } + + $this->arrRecurso[] = $objDTO->getNumIdRecurso(); + + return $objDTO->getNumIdRecurso(); + } + + /** + * Cria um menu + * + * @return int + */ + protected function criarMenu($strRotulo = '', $numSequencia = 10, $numIdItemMenuPai = null, $numIdMenu = null, $numIdRecurso = null, $numIdSistema = 0) { + + $objDTO = new ItemMenuDTO(); + $objDTO->setNumIdItemMenuPai($numIdItemMenuPai); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setStrRotulo($strRotulo); + $objDTO->setNumIdRecurso($numIdRecurso); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdItemMenu(); + + $objBD = new ItemMenuBD($this->inicializarObjInfraIBanco()); + $objDTO = $objBD->consultar($objDTO); + + if (empty($objDTO)) { + + $objDTO = new ItemMenuDTO(); + $objDTO->setNumIdMenu($numIdMenu); + $objDTO->setNumIdMenuPai($numIdMenu); + $objDTO->setNumIdItemMenu(null); + $objDTO->setNumIdItemMenuPai($numIdItemMenuPai); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setNumIdRecurso($numIdRecurso); + $objDTO->setStrRotulo($strRotulo); + $objDTO->setStrDescricao(null); + $objDTO->setNumSequencia($numSequencia); + $objDTO->setStrSinNovaJanela('N'); + $objDTO->setStrSinAtivo('S'); + + $objDTO = $objBD->cadastrar($objDTO); + } + + if (!empty($numIdRecurso)) { + + $this->arrMenu[] = array($objDTO->getNumIdItemMenu(), $numIdMenu, $numIdRecurso); + } + + return $objDTO->getNumIdItemMenu(); + } + + public function addRecursosToPerfil($numIdPerfil, $numIdSistema) { + + if (!empty($this->arrRecurso)) { + + $objDTO = new RelPerfilRecursoDTO(); + $objBD = new RelPerfilRecursoBD($this->inicializarObjInfraIBanco()); + + foreach ($this->arrRecurso as $numIdRecurso) { + + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setNumIdPerfil($numIdPerfil); + $objDTO->setNumIdRecurso($numIdRecurso); + + if ($objBD->contar($objDTO) == 0) { + $objBD->cadastrar($objDTO); + } + } + } + } + + public function addMenusToPerfil($numIdPerfil, $numIdSistema) { + + if (!empty($this->arrMenu)) { + + $objDTO = new RelPerfilItemMenuDTO(); + $objBD = new RelPerfilItemMenuBD($this->inicializarObjInfraIBanco()); + + foreach ($this->arrMenu as $array) { + + list($numIdItemMenu, $numIdMenu, $numIdRecurso) = $array; + + $objDTO->setNumIdPerfil($numIdPerfil); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setNumIdRecurso($numIdRecurso); + $objDTO->setNumIdMenu($numIdMenu); + $objDTO->setNumIdItemMenu($numIdItemMenu); + + if ($objBD->contar($objDTO) == 0) { + $objBD->cadastrar($objDTO); + } + } + } + } + + public function atribuirPerfil($numIdSistema) { + + $objDTO = new PerfilDTO(); + $objBD = new PerfilBD($this->inicializarObjInfraIBanco()); + $objRN = $this; + + // Vincula a um perfil os recursos e menus adicionados nos métodos criarMenu e criarReturso + $fnCadastrar = function($strNome, $numIdSistema) use($objDTO, $objBD, $objRN) { + + $objDTO->unSetTodos(); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setStrNome($strNome, InfraDTO::$OPER_LIKE); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdPerfil(); + + $objPerfilDTO = $objBD->consultar($objDTO); + + if (!empty($objPerfilDTO)) { + $objRN->addRecursosToPerfil($objPerfilDTO->getNumIdPerfil(), $numIdSistema); + $objRN->addMenusToPerfil($objPerfilDTO->getNumIdPerfil(), $numIdSistema); + } + }; + + $fnCadastrar('ADMINISTRADOR', $numIdSistema); + $fnCadastrar('BASICO', $numIdSistema); + } + + /** + * Instala/Atualiza os módulo PEN para versão 1.0 + */ + protected function instalarV001() { + + $numIdSistema = $this->getNumIdSistema('SEI'); + $numIdMenu = $this->getNumIdMenu('Principal', $numIdSistema); + + //---------------------------------------------------------------------- + // Expedir procedimento + //---------------------------------------------------------------------- + $this->criarRecurso('pen_procedimento_expedir', 'Expedir Procedimento', $numIdSistema); + $this->criarRecurso('apensados_selecionar_expedir_procedimento', 'Processos Apensados', $numIdSistema); + $numIdRecurso = $this->criarRecurso('pen_procedimento_expedido_listar', 'Processos Expedidos', $numIdSistema); + $this->criarMenu('Processos Expedidos', 55, null, $numIdMenu, $numIdRecurso, $numIdSistema); + //---------------------------------------------------------------------- + // Mapeamento de documentos enviados + //---------------------------------------------------------------------- + $this->criarRecurso('pen_map_tipo_doc_enviado_visualizar', 'Visualização de mapeamento de documentos enviados', $numIdSistema); + + // Acha o menu existente de Tipos de Documento + $objItemMenuDTO = new ItemMenuDTO(); + $objItemMenuDTO->setNumIdSistema($numIdSistema); + $objItemMenuDTO->setNumIdMenu($numIdMenu); + $objItemMenuDTO->setStrRotulo('Tipos de Documento'); + $objItemMenuDTO->setNumMaxRegistrosRetorno(1); + $objItemMenuDTO->retNumIdItemMenu(); + + $objItemMenuBD = new ItemMenuBD($this->inicializarObjInfraIBanco()); + $objItemMenuDTO = $objItemMenuBD->consultar($objItemMenuDTO); + + if (empty($objItemMenuDTO)) { + throw new InfraException('Menu "Tipo de Documentos" não foi localizado'); + } + + $numIdItemMenuPai = $objItemMenuDTO->getNumIdItemMenu(); + + // Gera o submenu Mapeamento + $_numIdItemMenuPai = $this->criarMenu('Mapeamento', 50, $numIdItemMenuPai, $numIdMenu, null, $numIdSistema); + + // Gera o submenu Mapeamento > Envio + $numIdItemMenuPai = $this->criarMenu('Envio', 10, $_numIdItemMenuPai, $numIdMenu, null, $numIdSistema); + + // Gera o submenu Mapeamento > Envio > Cadastrar + $numIdRecurso = $this->criarRecurso('pen_map_tipo_doc_enviado_cadastrar', 'Cadastro de mapeamento de documentos enviados', $numIdSistema); + $this->criarMenu('Cadastrar', 10, $numIdItemMenuPai, $numIdMenu, $numIdRecurso, $numIdSistema); + + // Gera o submenu Mapeamento > Envio > Listar + $numIdRecurso = $this->criarRecurso('pen_map_tipo_doc_enviado_listar', 'Listagem de mapeamento de documentos enviados', $numIdSistema); + $this->criarMenu('Listar', 20, $numIdItemMenuPai, $numIdMenu, $numIdRecurso, $numIdSistema); + + // Gera o submenu Mapeamento > Recebimento + $numIdItemMenuPai = $this->criarMenu('Recebimento', 20, $_numIdItemMenuPai, $numIdMenu, null, $numIdSistema); + + // Gera o submenu Mapeamento > Recebimento > Cadastrar + $numIdRecurso = $this->criarRecurso('pen_map_tipo_doc_recebido_cadastrar', 'Cadastro de mapeamento de documentos recebidos', $numIdSistema); + $this->criarMenu('Cadastrar', 10, $numIdItemMenuPai, $numIdMenu, $numIdRecurso, $numIdSistema); + + // Gera o submenu Mapeamento > Recebimento > Listar + $numIdRecurso = $this->criarRecurso('pen_map_tipo_doc_recebido_listar', 'Listagem de mapeamento de documentos recebidos', $numIdSistema); + $this->criarMenu('Listar', 20, $numIdItemMenuPai, $numIdMenu, $numIdRecurso, $numIdSistema); + + //Atribui as permissões aos recursos e menus + $this->atribuirPerfil($numIdSistema); + } + + protected function instalarV003R003S003IW001() { + + + $objBD = new ItemMenuBD($this->inicializarObjInfraIBanco()); + + //---------------------------------------------------------------------- + // Achar o root + + $numIdSistema = $this->getNumIdSistema('SEI'); + $numIdMenu = $this->getNumIdMenu('Principal', $numIdSistema); + + $objDTO = new ItemMenuDTO(); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setNumIdMenu($numIdMenu); + $objDTO->setStrRotulo('Administração'); + $objDTO->setNumMaxRegistrosRetorno(1); + $objDTO->retNumIdItemMenu(); + + $objDTO = $objBD->consultar($objDTO); + + if (empty($objDTO)) { + throw new InfraException('Menu "Administração" não foi localizado'); + } + + $numIdItemMenuRoot = $objDTO->getNumIdItemMenu(); + //---------------------------------------------------------------------- + // Acha o nodo do mapeamento + + $objItemMenuDTO = new ItemMenuDTO(); + $objItemMenuDTO->setNumIdSistema($numIdSistema); + $objItemMenuDTO->setNumIdMenu($numIdMenu); + $objItemMenuDTO->setStrRotulo('Mapeamento'); + $objItemMenuDTO->setNumSequencia(50); + $objItemMenuDTO->setNumMaxRegistrosRetorno(1); + $objItemMenuDTO->retTodos(); + + $objItemMenuDTO = $objBD->consultar($objItemMenuDTO); + if (!empty($objItemMenuDTO)) { + + $numIdItemMenuMapeamento = $objItemMenuDTO->getNumIdItemMenu(); + + $objDTO = new ItemMenuDTO(); + $objDTO->setNumIdSistema($numIdSistema); + $objDTO->setNumIdMenu($numIdMenu); + $objDTO->setNumIdItemMenuPai($numIdItemMenuMapeamento); + $objDTO->retTodos(); + + $arrObjDTO = $objBD->listar($objDTO); + + if (!empty($arrObjDTO)) { + + $numIdItemMenuPai = $this->criarMenu('Processo Eletrônico Nacional', 0, $numIdItemMenuRoot, $numIdMenu, null, $numIdSistema); + $numIdItemMenuPai = $this->criarMenu('Mapeamento de Tipos de Documento', 10, $numIdItemMenuPai, $numIdMenu, null, $numIdSistema); + + foreach ($arrObjDTO as $objDTO) { + + $objDTO->setNumIdItemMenuPai($numIdItemMenuPai); + + $objBD->alterar($objDTO); + } + + $objBD->excluir($objItemMenuDTO); + } + } + } + +} + +class PenConsoleRN extends InfraRN { + + protected $objRN; + protected $strAction; + protected $arrTokens = array(); + protected $objInfraBanco; + + public function __construct($objRN = null, $tokens = array()) { + + if(!is_null($objRN)) { + + parent::__construct(); + + if(!is_object($objRN)) { + throw new InfraException('Requerido objeto Infra'); + } + + if(get_parent_class($objRN) !== 'InfraRN') { + throw new InfraException('Requerido objeto Infra que seja extendido de InfraRN'); + } + + $this->objRN = $objRN; + } + + if(empty($tokens)) { + $tokens = $_SERVER['argv']; + } + + $this->criarTokens($tokens); + } + + /** + * Inicializador o banco de dados + */ + protected function inicializarObjInfraIBanco() { + if(empty($this->objInfraBanco)){ + $this->objInfraBanco = BancoSEI::getInstance(); + } + return $this->objInfraBanco; + } + + /** + * Processa os parâmetros passados ao script pelo cli + * + * @param array $arguments + * @return null + */ + protected function criarTokens($arguments = array()){ + + if(empty($arguments)) { + throw new InfraException('Script não pode ser executado pela web'); + } + + $strScript = array_shift($arguments); + + if(!empty($this->objRN)) { + + $strAction = array_shift($arguments); + + if(substr($strAction, 0, 2) == '--') { + throw new InfraException('O primeiro paramêtro deve ser uma action da RN'); + } + + $this->strAction = $strAction; + } + + foreach($arguments as $key => $argument) { + + if(substr($argument, 0, 2) === '--'){ + + $string = preg_replace('/^--/', '', $argument); + $array = explode('=', $string); + + $key = array_shift($array); + $value = (count($array) > 0) ? array_shift($array) : true; + + $this->arrTokens[$key] = $value; + } + } + } + + /** + * Retorna os parâmetros + */ + public function getTokens(){ + return $this->arrTokens; + } + public function run(){ + + if(empty($this->objRN)) { + throw new InfraException('Nenhuma RN foi adicionada ao console'); + } + + if(!method_exists($this->objRN, $this->strAction)) { + + throw new InfraException(sprintf('Nenhuma ação "%s" foi encontrada em %s '.PHP_EOL.$this->objRN->ajuda(), $this->strAction, get_class($this->objRN))); + } + + if(array_key_exists('ajuda', $this->arrTokens)) { + + print $this->objRN->ajuda(); + return true; + } + + return call_user_func(array($this->objRN, $this->strAction), $this->getTokens()); + } + + public static function format($strMensagem = '', $strFonte = '', $bolBold = false){ + + $strBold = ($bolBold !== false) ? '1' : '0'; + + //$strMensagem = escapeshellarg($strMensagem); + + if(!empty($strFonte)) { + + switch($strFonte){ + + case 'green': + $strMensagem = "\033[".$strBold.";32m".$strMensagem; + break; + + case 'red': + $strMensagem = "\033[".$strBold.";31m".$strMensagem; + break; + + case 'blue': + $strMensagem = "\033[".$strBold.";34m".$strMensagem; + break; + + case 'yellow': + $strMensagem = "\033[".$strBold.";33m".$strMensagem; + break; + + } + } + return static::resetAfter($strMensagem); + } + + public static function resetAfter($strMensagem = ''){ + + return $strMensagem. "\033[0m"; + } +} + +try { + $objPenConsoleRN = new PenConsoleRN(); $arrArgs = $objPenConsoleRN->getTokens(); - + $objAtualizarRN = new PenAtualizarSipRN($arrArgs); $objAtualizarRN->atualizarVersao(); - + exit(0); -} -catch(Exception $e) { - +} catch (Exception $e) { + print InfraException::inspecionar($e); - + try { LogSEI::getInstance()->gravar(InfraException::inspecionar($e)); } catch (Exception $e) { } - + exit(1); } print PHP_EOL; - -/** - # Apagar modulo PEN no SEI pelo MySQL - - # Apagar modulo PEN no SIP pelo MySQL - SET FOREIGN_KEY_CHECKS = 1; - - DELETE FROM sip.recurso WHERE nome IN( - 'pen_procedimento_expedir', - 'pen_procedimento_expedido_listar', - 'pen_map_tipo_doc_enviado_visualizar', - 'pen_map_tipo_doc_enviado_cadastrar', - 'pen_map_tipo_doc_enviado_listar', - 'pen_map_tipo_doc_recebido_cadastrar', - 'pen_map_tipo_doc_recebido_listar' - ); - SET FOREIGN_KEY_CHECKS = 0; - - */ \ No newline at end of file diff --git a/verificar-servicos.sh b/verificar-servicos.sh index a608298..f0caafe 100644 --- a/verificar-servicos.sh +++ b/verificar-servicos.sh @@ -1,35 +1,37 @@ #!/bin/bash -if $(service gearmand status | grep -qv "running") ; then - service gearmand start; - LOG="Servico gearman foi iniciado" +PATH=/usr/bin:/sbin:/bin:/usr/sbin +export PATH + +if $(service gearmand status | grep -qv "running") ; then + service gearmand start; + LOG="Servico gearman foi iniciado" fi -if $(service supervisord status | grep -qv "running") ; then - service supervisord start; - LOG="Servico supervisor foi iniciado" +if $(service supervisord status | grep -qv "running") ; then + service supervisord start; + LOG="Servico supervisor foi iniciado" else - COMMAND=$(ps -C php -f | grep -o "PendenciasTramiteRN.php"); - - if [ -z "$COMMAND" ] - then - service supervisord restart; - LOG="Servico supervisor foi reiniciado" - fi - - COMMAND=$(ps -C php -f | grep -o "ProcessarPendenciasRN.php"); - - if [ -z "$COMMAND" ] - then - service supervisord restart; - LOG="Servico supervisor foi reiniciado" - fi + COMMAND=$(ps -C php -f | grep -o "PendenciasTramiteRN.php"); + + if [ -z "$COMMAND" ] + then + service supervisord restart; + LOG="Servico supervisor foi reiniciado" + fi + + COMMAND=$(ps -C php -f | grep -o "ProcessarPendenciasRN.php"); + + if [ -z "$COMMAND" ] + then + service supervisord restart; + LOG="Servico supervisor foi reiniciado" + fi fi if [ -n "$LOG" ] then - /usr/bin/php console.php log --msg="$LOG" > /dev/null + #/usr/bin/php console.php log --msg="$LOG" > /dev/null + echo $LOG fi - - -- libgit2 0.21.2