Correção no e-mail e adaptação nas chamadas do serviço de consultar trâmite, pre…

…sentes no cancelamento do processo

Correção no e-mail e adaptação nas chamadas do serviço de consultar trâmite, pre…
…sentes no cancelamento do processo
Eduardo Heinske
1 parent 31274e05
Showing 3 changed files with 97 additions and 50 deletions Show diff stats
dto/TramiteDTO.php
rn/ExpedirProcedimentoRN.php
rn/ProcessoEletronicoRN.php
@@ -18,11 +18,13 @@ class TramiteDTO extends InfraDTO {
         $this->adicionarAtributoTabelaRelacionada(InfraDTO::$PREFIXO_STR, 'NomeUsuario', 'nome', 'usuario');
         $this->adicionarAtributoTabelaRelacionada(InfraDTO::$PREFIXO_STR, 'NomeUnidade', 'nome', 'unidade');
+        $this->adicionarAtributoTabelaRelacionada(InfraDTO::$PREFIXO_NUM, 'IdProcedimento', 'id_procedimento', 'md_pen_processo_eletronico');
         $this->configurarPK('NumeroRegistro', InfraDTO::$TIPO_PK_INFORMADO);
         $this->configurarPK('IdTramite', InfraDTO::$TIPO_PK_INFORMADO);
         $this->configurarFK('NumeroRegistro', 'md_pen_tramite', 'numero_registro', InfraDTO::$TIPO_FK_OBRIGATORIA);
+        $this->configurarFK('NumeroRegistro', 'md_pen_processo_eletronico pe', 'pe.numero_registro');
         $this->configurarFK('IdUsuario', 'usuario u', 'u.id_usuario');
         $this->configurarFK('IdUnidade', 'unidade u', 'u.id_unidade');
     }
@@ -1016,7 +1016,7 @@ class ExpedirProcedimentoRN extends InfraRN {
     $idSerieEmail = $objInfraParametro->getValor('ID_SERIE_EMAIL');
     $docEmailEnviado = $objDocumentoDTO->getNumIdSerie() == $idSerieEmail && $objDocumentoDTO->getStrStaDocumento() == DocumentoRN::$TD_FORMULARIO_AUTOMATICO ? true : false;
-    if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_GERADO && !$docEmailEnviado) {
+    if($objDocumentoDTO->getStrStaDocumento() == DocumentoRN::$TD_EDITOR_INTERNO) {
       $objEditorDTO = new EditorDTO();
       $objEditorDTO->setDblIdDocumento($objDocumentoDTO->getDblIdDocumento());
@@ -1036,8 +1036,8 @@ class ExpedirProcedimentoRN extends InfraRN {
       $arrInformacaoArquivo['MIME_TYPE'] = 'text/html';
       $arrInformacaoArquivo['ID_ANEXO'] = null;
-    } else if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_RECEBIDO || $docEmailEnviado)  {
-
+    } else if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_RECEBIDO)  {
+   
       $objAnexoDTO = $this->consultarAnexo($objDocumentoDTO->getDblIdDocumento());
       if(!isset($objAnexoDTO)){
@@ -1086,8 +1086,23 @@ class ExpedirProcedimentoRN extends InfraRN {
       $arrInformacaoArquivo['ID_ANEXO'] = $objAnexoDTO->getNumIdAnexo();
       $arrInformacaoArquivo['dadosComplementaresDoTipoDeArquivo'] = $strDadosComplementaresDoTipoDeArquivo;
-    } else {
-      throw new InfraException('Procedência do documento inválida.');   
+    } 
+    else {
+
+        $objDocumentoDTO2 = new DocumentoDTO();
+        $objDocumentoDTO2->setDblIdDocumento($objDocumentoDTO->getDblIdDocumento());
+        $objDocumentoDTO2->setObjInfraSessao(SessaoSEI::getInstance());
+        $objDocumentoDTO2->setStrLinkDownload('controlador.php?acao=documento_download_anexo');
+        
+        $objDocumentoRN = new DocumentoRN();
+        $strResultado = $objDocumentoRN->consultarHtmlFormulario($objDocumentoDTO2);
+        
+        $arrInformacaoArquivo['NOME'] = $strProtocoloDocumentoFormatado . ".html";
+        $arrInformacaoArquivo['CONTEUDO'] = $strResultado;
+        $arrInformacaoArquivo['TAMANHO'] = strlen($strResultado);
+        $arrInformacaoArquivo['MIME_TYPE'] = 'text/html';
+        $arrInformacaoArquivo['ID_ANEXO'] = null;
+
     }
     return $arrInformacaoArquivo;
@@ -2043,11 +2058,38 @@ class ExpedirProcedimentoRN extends InfraRN {
     protected function cancelarTramiteInternoControlado(ProtocoloDTO $objDtoProtocolo) {
+        //Obtem o id_rh que representa a unidade no barramento
+        $objInfraParametro = new InfraParametro($this->inicializarObjInfraIBanco());
+        $numIdRespositorio = $objInfraParametro->getValor('PEN_ID_REPOSITORIO_ORIGEM');
+        
+        //Obtem os dados da unidade
+        $objPenUnidadeDTO = new PenUnidadeDTO();
+        $objPenUnidadeDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
+        $objPenUnidadeDTO->retNumIdUnidadeRH();
+                
+        $objGenericoBD = new GenericoBD($this->inicializarObjInfraIBanco());
+        $objPenUnidadeDTO = $objGenericoBD->consultar($objPenUnidadeDTO);
+        
+        $objTramiteDTO = new TramiteDTO();
+        $objTramiteDTO->setNumIdProcedimento($objDtoProtocolo->retDblIdProtocolo());
+        $objTramiteDTO->setOrd('Registro', InfraDTO::$TIPO_ORDENACAO_DESC);
+        $objTramiteDTO->setNumMaxRegistrosRetorno(1);
+        $objTramiteDTO->retNumIdTramite();
+        
+        $objTramiteBD = new TramiteBD($this->getObjInfraIBanco());
+        $arrObjTramiteDTO = $objTramiteBD->listar($objTramiteDTO);
+                
+        if(!$arrObjTramiteDTO){
+            return false;
+        }
+        
+        $objTramiteDTO = $arrObjTramiteDTO[0];
+        
         //Armazena o id do protocolo
         $dblIdProcedimento = $objDtoProtocolo->getDblIdProtocolo();
-        $tramites = $this->objProcessoEletronicoRN->consultarTramitesProtocolo($objDtoProtocolo->getStrProtocoloFormatado());
-        $tramite = $tramites ? array_pop($tramites) : null;
+        $tramites = $this->objProcessoEletronicoRN->consultarTramites($objTramiteDTO->getNumIdTramite(), null, $objPenUnidadeDTO->getNumIdUnidadeRH(), null, null, $numIdRespositorio);
+        $tramite = $tramites ? $tramites[0] : null;
         if (!$tramite) {
             throw new InfraException('Trâmite não encontrado para esse processo. ');
@@ -861,46 +861,7 @@ class ProcessoEletronicoRN extends InfraRN {
     }        
   }    
-   /**
-    * Consulta os tramites recusados
-    * 
-    * @return array
-    */
-   public function consultarTramitesRecusados($parNumIdRespositorio, $parNumIdEstrutura) {
-        try {
-            
-            $parametro = (object)array(
-                'filtroDeConsultaDeTramites' => (object)array(
-                    'situacaoAtual' => 9,
-                    'remetente' => (object)array(
-                        'identificacaoDoRepositorioDeEstruturas' => $parNumIdRespositorio,
-                        'numeroDeIdentificacaoDaEstrutura' => $parNumIdEstrutura
-                    )
-                )
-            );
-            
-            $objTramitesEncontrados = $this->getObjPenWs()->consultarTramites($parametro);
-            
-            $arrObjTramite = array();
-            
-            if (isset($objTramitesEncontrados->tramitesEncontrados)) {
-
-                $arrObjTramite = $objTramitesEncontrados->tramitesEncontrados->tramite;
-                
-                if(!is_array($arrObjTramite)) {
-                    $arrObjTramite = array($objTramitesEncontrados->tramitesEncontrados->tramite);
-                }
-            }
-
-            return $arrObjTramite; 
-        } 
-        catch (\SoapFault $fault) {
-            throw new InfraException(InfraString::formatarJavaScript($this->tratarFalhaWebService($fault)), $fault);
-        } 
-        catch (\Exception $e) {
-            throw new InfraException("Error Processing Request", $e);
-        }
-    }
+   
   public function consultarTramites($parNumIdTramite = null, $parNumeroRegistro = null, $parNumeroUnidadeRemetente = null, $parNumeroUnidadeDestino = null, $parProtocolo = null, $parNumeroRepositorioEstruturas = null) 
   {
@@ -916,11 +877,13 @@ class ProcessoEletronicoRN extends InfraRN {
       }
       if(!is_null($parNumeroUnidadeRemetente) && !is_null($parNumeroRepositorioEstruturas)){
+          $parametro->filtroDeConsultaDeTramites->remetente = new stdClass();
           $parametro->filtroDeConsultaDeTramites->remetente->identificacaoDoRepositorioDeEstruturas = $parNumeroRepositorioEstruturas;
           $parametro->filtroDeConsultaDeTramites->remetente->numeroDeIdentificacaoDaEstrutura = $parNumeroUnidadeRemetente;
       }
       if(!is_null($parNumeroUnidadeDestino) && !is_null($parNumeroRepositorioEstruturas)){
+          $parametro->filtroDeConsultaDeTramites->destinatario = new stdClass();
           $parametro->filtroDeConsultaDeTramites->destinatario->identificacaoDoRepositorioDeEstruturas = $parNumeroRepositorioEstruturas;
           $parametro->filtroDeConsultaDeTramites->destinatario->numeroDeIdentificacaoDaEstrutura = $parNumeroUnidadeDestino;
       }
@@ -1027,9 +990,24 @@ class ProcessoEletronicoRN extends InfraRN {
             throw new InfraException(utf8_encode('O processo não esta com o estado com "Em Processamento" ou "Bloqueado"'));
         }
+        $objTramiteDTO = new TramiteDTO();
+        $objTramiteDTO->setNumIdProcedimento($objProtocoloDTO->retDblIdProtocolo());
+        $objTramiteDTO->setOrd('Registro', InfraDTO::$TIPO_ORDENACAO_DESC);
+        $objTramiteDTO->setNumMaxRegistrosRetorno(1);
+        $objTramiteDTO->retNumIdTramite();
+        
+        $objTramiteBD = new TramiteBD($this->getObjInfraIBanco());
+        $arrObjTramiteDTO = $objTramiteBD->listar($objTramiteDTO);
+        
+        if(!$arrObjTramiteDTO){
+            throw new InfraException('Trâmite não encontrado');
+        }
+        
+        $objTramiteDTO = $arrObjTramiteDTO[0];
+        
         $objFiltro = new stdClass();
         $objFiltro->filtroDeConsultaDeTramites = new stdClass();
-        $objFiltro->filtroDeConsultaDeTramites->protocolo = $objProtocoloDTO->getStrProtocoloFormatado();
+        $objFiltro->filtroDeConsultaDeTramites->IDT = $objTramiteDTO->getNumIdTramite();
         $objResultado = $this->getObjPenWs()->consultarTramites($objFiltro);
@@ -1392,9 +1370,11 @@ class ProcessoEletronicoRN extends InfraRN {
     public function isDisponivelCancelarTramite($strProtocolo = ''){
+        //Obtem o id_rh que representa a unidade no barramento
         $objInfraParametro = new InfraParametro($this->inicializarObjInfraIBanco());
         $numIdRespositorio = $objInfraParametro->getValor('PEN_ID_REPOSITORIO_ORIGEM');
+        //Obtem os dados da unidade
         $objPenUnidadeDTO = new PenUnidadeDTO();
         $objPenUnidadeDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
         $objPenUnidadeDTO->retNumIdUnidadeRH();
@@ -1402,15 +1382,38 @@ class ProcessoEletronicoRN extends InfraRN {
         $objGenericoBD = new GenericoBD($this->inicializarObjInfraIBanco());
         $objPenUnidadeDTO = $objGenericoBD->consultar($objPenUnidadeDTO);
+        //Obtem os dados do último trâmite desse processo no barramento
+        $objProtocoloDTO = new ProtocoloDTO();
+        $objProtocoloDTO->setStrProtocoloFormatado($strProtocolo);
+        $objProtocoloDTO->retDblIdProtocolo();
+        
+        $objProtocoloRN = new ProtocoloRN();
+        $objProtocoloDTO = $objProtocoloRN->consultarRN0186($objProtocoloDTO);
+        
+        $objTramiteDTO = new TramiteDTO();
+        $objTramiteDTO->setNumIdProcedimento($objProtocoloDTO->retDblIdProtocolo());
+        $objTramiteDTO->setOrd('Registro', InfraDTO::$TIPO_ORDENACAO_DESC);
+        $objTramiteDTO->setNumMaxRegistrosRetorno(1);
+        $objTramiteDTO->retNumIdTramite();
+        
+        $objTramiteBD = new TramiteBD($this->getObjInfraIBanco());
+        $arrObjTramiteDTO = $objTramiteBD->listar($objTramiteDTO);
+                
+        if(!$arrObjTramiteDTO){
+            return false;
+        }
+        
+        $objTramiteDTO = $arrObjTramiteDTO[0];
+        
         try {
             $parametro = (object)array(
                 'filtroDeConsultaDeTramites' => (object)array(
+                    'IDT' => $objTramiteDTO->getNumIdTramite(),
                     'remetente' => (object)array(
                         'identificacaoDoRepositorioDeEstruturas' => $numIdRespositorio,
                         'numeroDeIdentificacaoDaEstrutura' => $objPenUnidadeDTO->getNumIdUnidadeRH()
                     ),
-                    'protocolo' => $strProtocolo
                 )
             );
@@ -1422,7 +1425,7 @@ class ProcessoEletronicoRN extends InfraRN {
                 $arrObjMetaTramite = !is_array($objMeta->tramitesEncontrados->tramite) ? array($objMeta->tramitesEncontrados->tramite) : $objMeta->tramitesEncontrados->tramite;
-                $objMetaTramite = array_pop($arrObjMetaTramite);
+                $objMetaTramite = $arrObjMetaTramite[0];
                 switch($objMetaTramite->situacaoAtual){
	@@ -1016,7 +1016,7 @@ class ExpedirProcedimentoRN extends InfraRN {		@@ -1016,7 +1016,7 @@ class ExpedirProcedimentoRN extends InfraRN {
1016	$idSerieEmail = $objInfraParametro->getValor('ID_SERIE_EMAIL');	1016	$idSerieEmail = $objInfraParametro->getValor('ID_SERIE_EMAIL');
1017	$docEmailEnviado = $objDocumentoDTO->getNumIdSerie() == $idSerieEmail && $objDocumentoDTO->getStrStaDocumento() == DocumentoRN::$TD_FORMULARIO_AUTOMATICO ? true : false;	1017	$docEmailEnviado = $objDocumentoDTO->getNumIdSerie() == $idSerieEmail && $objDocumentoDTO->getStrStaDocumento() == DocumentoRN::$TD_FORMULARIO_AUTOMATICO ? true : false;
1018		1018
1019	- if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_GERADO && !$docEmailEnviado) {	1019	+ if($objDocumentoDTO->getStrStaDocumento() == DocumentoRN::$TD_EDITOR_INTERNO) {
1020		1020
1021	$objEditorDTO = new EditorDTO();	1021	$objEditorDTO = new EditorDTO();
1022	$objEditorDTO->setDblIdDocumento($objDocumentoDTO->getDblIdDocumento());	1022	$objEditorDTO->setDblIdDocumento($objDocumentoDTO->getDblIdDocumento());
	@@ -1036,8 +1036,8 @@ class ExpedirProcedimentoRN extends InfraRN {		@@ -1036,8 +1036,8 @@ class ExpedirProcedimentoRN extends InfraRN {
1036	$arrInformacaoArquivo['MIME_TYPE'] = 'text/html';	1036	$arrInformacaoArquivo['MIME_TYPE'] = 'text/html';
1037	$arrInformacaoArquivo['ID_ANEXO'] = null;	1037	$arrInformacaoArquivo['ID_ANEXO'] = null;
1038		1038
1039	- } else if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_RECEBIDO \|\| $docEmailEnviado) {
1040	-	1039	+ } else if($objDocumentoDTO->getStrStaProtocoloProtocolo() == ProtocoloRN::$TP_DOCUMENTO_RECEBIDO) {
		1040	+
1041	$objAnexoDTO = $this->consultarAnexo($objDocumentoDTO->getDblIdDocumento());	1041	$objAnexoDTO = $this->consultarAnexo($objDocumentoDTO->getDblIdDocumento());
1042		1042
1043	if(!isset($objAnexoDTO)){	1043	if(!isset($objAnexoDTO)){
	@@ -1086,8 +1086,23 @@ class ExpedirProcedimentoRN extends InfraRN {		@@ -1086,8 +1086,23 @@ class ExpedirProcedimentoRN extends InfraRN {
1086	$arrInformacaoArquivo['ID_ANEXO'] = $objAnexoDTO->getNumIdAnexo();	1086	$arrInformacaoArquivo['ID_ANEXO'] = $objAnexoDTO->getNumIdAnexo();
1087	$arrInformacaoArquivo['dadosComplementaresDoTipoDeArquivo'] = $strDadosComplementaresDoTipoDeArquivo;	1087	$arrInformacaoArquivo['dadosComplementaresDoTipoDeArquivo'] = $strDadosComplementaresDoTipoDeArquivo;
1088		1088
1089	- } else {
1090	- throw new InfraException('Procedência do documento inválida.');	1089	+ }
		1090	+ else {
		1091	+
		1092	+ $objDocumentoDTO2 = new DocumentoDTO();
		1093	+ $objDocumentoDTO2->setDblIdDocumento($objDocumentoDTO->getDblIdDocumento());
		1094	+ $objDocumentoDTO2->setObjInfraSessao(SessaoSEI::getInstance());
		1095	+ $objDocumentoDTO2->setStrLinkDownload('controlador.php?acao=documento_download_anexo');
		1096	+
		1097	+ $objDocumentoRN = new DocumentoRN();
		1098	+ $strResultado = $objDocumentoRN->consultarHtmlFormulario($objDocumentoDTO2);
		1099	+
		1100	+ $arrInformacaoArquivo['NOME'] = $strProtocoloDocumentoFormatado . ".html";
		1101	+ $arrInformacaoArquivo['CONTEUDO'] = $strResultado;
		1102	+ $arrInformacaoArquivo['TAMANHO'] = strlen($strResultado);
		1103	+ $arrInformacaoArquivo['MIME_TYPE'] = 'text/html';
		1104	+ $arrInformacaoArquivo['ID_ANEXO'] = null;
		1105	+
1091	}	1106	}
1092		1107
1093	return $arrInformacaoArquivo;	1108	return $arrInformacaoArquivo;
	@@ -2043,11 +2058,38 @@ class ExpedirProcedimentoRN extends InfraRN {		@@ -2043,11 +2058,38 @@ class ExpedirProcedimentoRN extends InfraRN {
2043		2058
2044	protected function cancelarTramiteInternoControlado(ProtocoloDTO $objDtoProtocolo) {	2059	protected function cancelarTramiteInternoControlado(ProtocoloDTO $objDtoProtocolo) {
2045		2060
		2061	+ //Obtem o id_rh que representa a unidade no barramento
		2062	+ $objInfraParametro = new InfraParametro($this->inicializarObjInfraIBanco());
		2063	+ $numIdRespositorio = $objInfraParametro->getValor('PEN_ID_REPOSITORIO_ORIGEM');
		2064	+
		2065	+ //Obtem os dados da unidade
		2066	+ $objPenUnidadeDTO = new PenUnidadeDTO();
		2067	+ $objPenUnidadeDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
		2068	+ $objPenUnidadeDTO->retNumIdUnidadeRH();
		2069	+
		2070	+ $objGenericoBD = new GenericoBD($this->inicializarObjInfraIBanco());
		2071	+ $objPenUnidadeDTO = $objGenericoBD->consultar($objPenUnidadeDTO);
		2072	+
		2073	+ $objTramiteDTO = new TramiteDTO();
		2074	+ $objTramiteDTO->setNumIdProcedimento($objDtoProtocolo->retDblIdProtocolo());
		2075	+ $objTramiteDTO->setOrd('Registro', InfraDTO::$TIPO_ORDENACAO_DESC);
		2076	+ $objTramiteDTO->setNumMaxRegistrosRetorno(1);
		2077	+ $objTramiteDTO->retNumIdTramite();
		2078	+
		2079	+ $objTramiteBD = new TramiteBD($this->getObjInfraIBanco());
		2080	+ $arrObjTramiteDTO = $objTramiteBD->listar($objTramiteDTO);
		2081	+
		2082	+ if(!$arrObjTramiteDTO){
		2083	+ return false;
		2084	+ }
		2085	+
		2086	+ $objTramiteDTO = $arrObjTramiteDTO[0];
		2087	+
2046	//Armazena o id do protocolo	2088	//Armazena o id do protocolo
2047	$dblIdProcedimento = $objDtoProtocolo->getDblIdProtocolo();	2089	$dblIdProcedimento = $objDtoProtocolo->getDblIdProtocolo();
2048		2090
2049	- $tramites = $this->objProcessoEletronicoRN->consultarTramitesProtocolo($objDtoProtocolo->getStrProtocoloFormatado());
2050	- $tramite = $tramites ? array_pop($tramites) : null;	2091	+ $tramites = $this->objProcessoEletronicoRN->consultarTramites($objTramiteDTO->getNumIdTramite(), null, $objPenUnidadeDTO->getNumIdUnidadeRH(), null, null, $numIdRespositorio);
		2092	+ $tramite = $tramites ? $tramites[0] : null;
2051		2093
2052	if (!$tramite) {	2094	if (!$tramite) {
2053	throw new InfraException('Trâmite não encontrado para esse processo. ');	2095	throw new InfraException('Trâmite não encontrado para esse processo. ');