Fix/correcao criar bloco generico para cada unidade com seus processos

src/PENIntegracao.php

@@ -138,7 +138,7 @@ public function montarBotaoProcesso(ProcedimentoAPI $objSeiIntegracaoDTO)
       ProtocoloRN::$TE_PROCEDIMENTO_BLOQUEADO
     ));
 
-    $bolBlocoAbertoUnidade = false; 
+    $bolBlocoAbertoUnidade = false;
     $objTramiteEmBlocoDTO = new TramiteEmBlocoDTO();
     $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_ABERTO);
     $objTramiteEmBlocoDTO->setNumIdUnidade($objSessaoSEI->getNumIdUnidadeAtual());
@@ -155,11 +155,18 @@ public function montarBotaoProcesso(ProcedimentoAPI $objSeiIntegracaoDTO)
     $bolProcessoEmBloco = false;
     $objPenBlocoProcessoDTO = new PenBlocoProcessoDTO();
     $objPenBlocoProcessoDTO->setDblIdProtocolo($dblIdProcedimento);
+    $objPenBlocoProcessoDTO->setNumIdUnidade($objSessaoSEI->getNumIdUnidadeAtual());
+    $objPenBlocoProcessoDTO->retNumIdAndamento();
     $objPenBlocoProcessoDTO->retNumIdBloco();
 
     $objPenBlocoProcessoRN = new PenBlocoProcessoRN();
-    if (count($objPenBlocoProcessoRN->listar($objPenBlocoProcessoDTO)) > 0){
-      $bolProcessoEmBloco = true;
+    $arrObjPenBlocoProcessoDTO = $objPenBlocoProcessoRN->listar($objPenBlocoProcessoDTO);
+    if (count($arrObjPenBlocoProcessoDTO) > 0){
+      foreach ($arrObjPenBlocoProcessoDTO as $objBlocoProcessoDTO) {
+        if ($objBlocoProcessoDTO->getNumIdAndamento() != ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_RECIBO_RECEBIDO_REMETENTE) {
+          $bolProcessoEmBloco = true;
+        }
+      }
     }
 
     $objPenUnidadeDTO = new PenUnidadeDTO();

src/pen_procedimento_cancelar_expedir.php

@@ -40,10 +40,14 @@
     // TODO: tratar atualização a partir de um metodo
     $objTramiteEmBlocoDTO = new TramiteEmBlocoDTO();
     $objTramiteEmBlocoDTO->setNumId($tramiteEmBlocoProtocoloDTO->getNumIdBloco());
-    $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_CONCLUIDO_PARCIALMENTE);
-
+    $objTramiteEmBlocoDTO->retTodos();
+    // Consultar se o bloco esta como concluído
     $objTramiteEmBlocoRN = new TramiteEmBlocoRN();
-    $objTramiteEmBlocoRN->alterar($objTramiteEmBlocoDTO);
+    $retObjTramiteEmBlocoDTO = $objTramiteEmBlocoRN->consultar($objTramiteEmBlocoDTO);
+    if ($retObjTramiteEmBlocoDTO != null && $retObjTramiteEmBlocoDTO->getStrStaEstado() != TramiteEmBlocoRN::$TE_CONCLUIDO) {
+      $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_CONCLUIDO_PARCIALMENTE);
+      $objTramiteEmBlocoRN->alterar($objTramiteEmBlocoDTO);
+    }
   }
 
   $objExpedirProcedimentosRN = new ExpedirProcedimentoRN();

src/pen_tramita_em_bloco_protocolo_listar.php

@@ -12,7 +12,8 @@
   switch ($_GET['acao']) {
     case 'pen_tramita_em_bloco_protocolo_excluir':
       try {
-
+        $objTramitaEmBlocoProtocoloRN = new PenBlocoProcessoRN();
+
         $arrStrIds = $objPaginaSEI->getArrStrItensSelecionados();
         $arrObjTramiteBlocoProtocoloDTO = array();
         if (count($arrStrIds) > 0) {
@@ -34,7 +35,9 @@
           $arrObjTramiteBlocoProtocoloDTO[] = $objTramiteEmBlocoProtocoloDTO;
         }
 
-        $objTramitaEmBlocoProtocoloRN = new PenBlocoProcessoRN();
+        $objTramitaEmBlocoProtocoloRN->verificarExclusaoBloco($arrObjTramiteBlocoProtocoloDTO);
+
+        // Excluir permitidos
         $objTramitaEmBlocoProtocoloRN->excluir($arrObjTramiteBlocoProtocoloDTO);
 
         $dblIdBloco = $arrObjTramiteBlocoProtocoloDTO[0]->getNumIdBloco();
@@ -43,7 +46,7 @@
         $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_CONCLUIDO_PARCIALMENTE);
         $objTramiteEmBlocoDTO->retNumId();
         $objTramiteEmBlocoDTO->retStrStaEstado();
-   
+
         $objTramiteEmBlocoRN = new TramiteEmBlocoRN();
         $blocoResultado = $objTramiteEmBlocoRN->consultar($objTramiteEmBlocoDTO);
 
@@ -114,9 +117,10 @@
               $objTramiteEmBlocoRN->alterar($objTramiteEmBlocoDTO);
             }
           }
-        } 
+        }
 
         PaginaSEI::getInstance()->setStrMensagem('Operação realizada com sucesso.');
+
       } catch (Exception $e) {
         PaginaSEI::getInstance()->processarExcecao($e);
       }
@@ -202,6 +206,14 @@
     $strResultado .= '<th class="infraTh" width="10%">Ações</th>' . "\n";
     $strResultado .= '</thead>' . "\n";
     $strCssTr = '';
+
+    $situacaoPodeExcluir = array(
+      ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CANCELADO,
+      ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_RECUSADO,
+      ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CIENCIA_RECUSA,
+      ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CANCELADO_AUTOMATICAMENTE ,
+    );
+
     foreach ($arrTramitaEmBlocoProtocoloDTO as $i => $objTramitaEmBlocoProtocoloDTO) {
       $strCssTr = ($strCssTr == '<tr class="infraTrClara">') ? '<tr class="infraTrEscura">' : '<tr class="infraTrClara">';
       $strResultado .= $strCssTr;
@@ -231,6 +243,7 @@
 
       $strResultado .= '<td align="center">' . "\n";
       switch ($objTramitaEmBlocoProtocoloDTO->getNumIdAndamento()) {
+        case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_NAO_INICIADO:
         case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_INICIADO:
         case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_COMPONENTES_ENVIADOS_REMETENTE:
         case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_METADADOS_RECEBIDO_DESTINATARIO:
@@ -249,7 +262,6 @@
         case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CANCELADO_AUTOMATICAMENTE:
           $strResultado .= '<img src="' . PENIntegracao::getDiretorioImagens() . '/falhou.png" title="Cancelado" style="width:16px; alt="Cancelado" />';
             break;
-        case ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_NAO_INICIADO:
         default:
           $strResultado .= '<img src="' . PENIntegracao::getDiretorioImagens() . '/nao_iniciado.png" title="Em aberto" style="width:16px;" alt="Em aberto" />';
             break;

src/pen_tramite_processo_em_bloco_cadastrar.php

@@ -46,12 +46,13 @@
 
         $objPenBlocoProcessoDTO = new PenBlocoProcessoDTO();
         $objPenBlocoProcessoDTO->setDblIdProtocolo($_GET['id_procedimento']);
+        $objPenBlocoProcessoDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
         $objPenBlocoProcessoDTO->retDblIdProtocolo();
         $objPenBlocoProcessoDTO->retNumIdBlocoProcesso();
         $objPenBlocoProcessoDTO->retNumIdBloco();
 
         $objPenBlocoProcessoRN = new PenBlocoProcessoRN();
-        $arrObjPenBlocoProcessoDTO[] = $objPenBlocoProcessoRN->consultar($objPenBlocoProcessoDTO);
+        $arrObjPenBlocoProcessoDTO = $objPenBlocoProcessoRN->listar($objPenBlocoProcessoDTO);
         $objPenBlocoProcessoRN->excluir($arrObjPenBlocoProcessoDTO);
         $strMensagem = 'O processo "' . $procedimento->getStrProtocoloProcedimentoFormatado() . '" foi removido com sucesso do bloco de trâmite externo';
       } catch (Exception $e) {
@@ -161,7 +162,8 @@
             $dtRegistro = date('d/m/Y H:i:s');
             $objPenBlocoProcessoDTO->setDthRegistro($dtRegistro);
             $objPenBlocoProcessoDTO->setDthAtualizado($dtRegistro);
-            $objPenBlocoProcessoDTO->setNumIdAndamento(ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_NAO_INICIADO);
+            $objPenBlocoProcessoDTO->setNumIdUsuario($objSessaoSEI->getNumIdUsuario());
+            $objPenBlocoProcessoDTO->setNumIdUnidade($objSessaoSEI->getNumIdUnidadeAtual());
 
             $validar = $objPenBlocoProcessoRN->validarBlocoDeTramite($idItensSelecionados);
 

src/rn/ExpedirProcedimentoRN.php

@@ -3027,7 +3027,13 @@ protected function cancelarTramiteInternoControlado(ProtocoloDTO $objDtoProtocol
       $objPenLoteProcedimentoDTO = new PenBlocoProcessoDTO();
       $objPenLoteProcedimentoDTO->retTodos();
       $objPenLoteProcedimentoDTO->setDblIdProtocolo($dblIdProcedimento);
-      $objPenLoteProcedimentoDTO->setNumIdAndamento(ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_INICIADO);
+      $objPenLoteProcedimentoDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
+      $objPenLoteProcedimentoDTO->setNumIdAndamento(array(
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_NAO_INICIADO,
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_INICIADO,
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_COMPONENTES_ENVIADOS_REMETENTE
+      ), InfraDTO::$OPER_IN);
+      $objPenLoteProcedimentoDTO->setNumMaxRegistrosRetorno(1);
 
       $objPenLoteProcedimentoRN = new PenBlocoProcessoRN();
       $objPenLoteProcedimentoDTO = $objPenLoteProcedimentoRN->consultar($objPenLoteProcedimentoDTO);

src/rn/PenBlocoProcessoRN.php

@@ -16,6 +16,40 @@ protected function inicializarObjInfraIBanco()
     return BancoSEI::getInstance();
   }
 
+  public function verificarExclusaoBloco(array $arrObjDTO)
+  {
+    $podeExcluir = true;
+    $messagem = "Existem protocolos em andamento que não pode ser excluídos.";
+
+    foreach ($arrObjDTO as $objPenLoteProcedimentoDTO) {
+      $objPenLoteProcedimentoDTO->retNumIdBlocoProcesso();
+      $objPenLoteProcedimentoDTO->retNumIdAndamento();
+      $objPenLoteProcedimentoDTO->retStrProtocoloFormatadoProtocolo();
+
+      $objPenLoteProcedimentoBD = new PenLoteProcedimentoBD($this->getObjInfraIBanco());
+      $objPenLoteProcedimentoDTO = $objPenLoteProcedimentoBD->consultar($objPenLoteProcedimentoDTO);
+
+      $situacaoPodeExcluir = array(
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CANCELADO,
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_RECUSADO,
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CIENCIA_RECUSA,
+        ProcessoEletronicoRN::$STA_SITUACAO_TRAMITE_CANCELADO_AUTOMATICAMENTE ,
+      );
+      if (
+        $objPenLoteProcedimentoDTO != null
+        && !is_null($objPenLoteProcedimentoDTO->getNumIdAndamento())
+        && !in_array($objPenLoteProcedimentoDTO->getNumIdAndamento(), $situacaoPodeExcluir)
+      ) {
+        $messagem .= "\n - {$objPenLoteProcedimentoDTO->getStrProtocoloFormatadoProtocolo()}";
+        $podeExcluir = false;
+      }
+    }
+
+    if (!$podeExcluir) {
+      throw new InfraException($messagem);
+    }
+  }
+
   protected function obterPendenciasLoteControlado(PenBlocoProcessoDTO $objPenLoteProcedimentoDTO)
   {
     try {
@@ -399,9 +433,10 @@ protected function validarBlocoDeTramiteControlado($idProtocolo)
     $objPenBlocoProcessoDTO = new PenBlocoProcessoDTO();
     $objPenBlocoProcessoDTO->retNumIdBlocoProcesso();
     $objPenBlocoProcessoDTO->setDblIdProtocolo($idProtocolo);
+    $objPenBlocoProcessoDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
     $objPenBlocoProcessoDTO->retNumIdBloco();
     $objPenBlocoProcessoDTO->retDblIdProtocolo();
-    // $objPenBlocoProcessoDTO->retStrIdxRelBlocoProtocolo();
+    $objPenBlocoProcessoDTO->retStrProtocoloFormatadoProtocolo();
 
     $arrTramitaEmBloco = $this->listar($objPenBlocoProcessoDTO);
 
@@ -420,15 +455,27 @@ protected function validarBlocoDeTramiteControlado($idProtocolo)
       $tramiteEmBloco = $tramiteEmBlocoRN->consultar($tramiteEmBlocoDTO);
 
       if (!empty($tramiteEmBloco)) {
-        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getDblIdProtocolo()} encontra-se inserido no bloco {$tramiteEmBloco->getNumId()} - {$tramiteEmBloco->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
+        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrProtocoloFormatadoProtocolo()} encontra-se inserido no bloco {$tramiteEmBloco->getNumId()} - {$tramiteEmBloco->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
       }
 
       $processoRecusadoNoBlocoParcial = $this->validarBlocoEstadoConcluidoParcial($tramitaEmBloco->getNumIdBloco(), $idProtocolo);
       if ($processoRecusadoNoBlocoParcial !== false) {
-        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getDblIdProtocolo()} encontra-se inserido no bloco {$processoRecusadoNoBlocoParcial->getNumId()} - {$processoRecusadoNoBlocoParcial->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
+        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrProtocoloFormatadoProtocolo()} encontra-se inserido no bloco {$processoRecusadoNoBlocoParcial->getNumId()} - {$processoRecusadoNoBlocoParcial->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
       }
     }
 
+    $objExpedirProcedimentoRN = new ExpedirProcedimentoRN();
+    $objProcedimentoDTO = $objExpedirProcedimentoRN->consultarProcedimento($idProtocolo);
+
+    $bolProcessoEstadoNormal = !in_array($objProcedimentoDTO->getStrStaEstadoProtocolo(), array(
+      ProtocoloRN::$TE_PROCEDIMENTO_SOBRESTADO,
+      ProtocoloRN::$TE_PROCEDIMENTO_BLOQUEADO
+    ));
+    if (!$bolProcessoEstadoNormal) {
+      return "Prezado(a) usuário(a), o processo {$objProcedimentoDTO->getStrProtocoloProcedimentoFormatado()} encontra-se bloqueado."
+        . " Dessa forma, não foi possível realizar a sua inserção no bloco selecionado.";
+    }
+
     return false;
   }
 
@@ -539,9 +586,13 @@ public function atualizarEstadoDoBlocoConcluidoParcialmente($arrTramiteEmBlocoPr
   {
     $objTramiteEmBlocoDTO = new TramiteEmBlocoDTO();
     $objTramiteEmBlocoDTO->setNumId($arrTramiteEmBlocoProtocoloDTO[0]->getNumIdBloco());
-    $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_CONCLUIDO_PARCIALMENTE);
-
+    $objTramiteEmBlocoDTO->retTodos();
+    // Consultar se o bloco esta como concluído
     $objTramiteEmBlocoRN = new TramiteEmBlocoRN();
-    $objTramiteEmBlocoRN->alterar($objTramiteEmBlocoDTO);
+    $retObjTramiteEmBlocoDTO = $objTramiteEmBlocoRN->consultar($objTramiteEmBlocoDTO);
+    if ($retObjTramiteEmBlocoDTO != null && $retObjTramiteEmBlocoDTO->getStrStaEstado() != TramiteEmBlocoRN::$TE_CONCLUIDO) {
+      $objTramiteEmBlocoDTO->setStrStaEstado(TramiteEmBlocoRN::$TE_CONCLUIDO_PARCIALMENTE);
+      $objTramiteEmBlocoRN->alterar($objTramiteEmBlocoDTO);
+    }
   }
 }

src/rn/TramitaEmBlocoProtocoloRN.php

@@ -297,7 +297,7 @@ protected function validarBlocoDeTramiteControlado($idProtocolo)
     $tramitaEmBlocoProtocoloDTO->retNumId();
     $tramitaEmBlocoProtocoloDTO->setDblIdProtocolo($idProtocolo);
     $tramitaEmBlocoProtocoloDTO->retNumIdTramitaEmBloco();
-    $tramitaEmBlocoProtocoloDTO->retStrIdxRelBlocoProtocolo();
+    $tramitaEmBlocoProtocoloDTO->retStrProtocoloFormatadoProtocolo();
 
     $arrTramitaEmBloco = $this->listar($tramitaEmBlocoProtocoloDTO);
 
@@ -316,12 +316,12 @@ protected function validarBlocoDeTramiteControlado($idProtocolo)
       $tramiteEmBloco = $tramiteEmBlocoRN->consultar($tramiteEmBlocoDTO);
 
       if (!empty($tramiteEmBloco)) {
-        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrIdxRelBlocoProtocolo()} encontra-se inserido no bloco {$tramiteEmBloco->getNumId()} - {$tramiteEmBloco->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
+        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrProtocoloFormatadoProtocolo()} encontra-se inserido no bloco {$tramiteEmBloco->getNumId()} - {$tramiteEmBloco->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
       }
 
       $processoRecusadoNoBlocoParcial = $this->validarBlocoEstadoConcluidoParcial($tramitaEmBloco->getNumIdBloco(), $idProtocolo);
       if ($processoRecusadoNoBlocoParcial !== false) {
-        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrIdxRelBlocoProtocolo()} encontra-se inserido no bloco {$processoRecusadoNoBlocoParcial->getNumId()} - {$processoRecusadoNoBlocoParcial->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
+        return "Prezado(a) usuário(a), o processo {$tramitaEmBloco->getStrProtocoloFormatadoProtocolo()} encontra-se inserido no bloco {$processoRecusadoNoBlocoParcial->getNumId()} - {$processoRecusadoNoBlocoParcial->getStrDescricao()}. Para continuar com essa ação é necessário que o processo seja removido do bloco em questão.";
       }
     }
 

src/scripts/sei_atualizar_versao_modulo_pen.php

@@ -2842,14 +2842,14 @@ protected function instalarV3070()
     $objInfraAgendamentoTarefaBD = new InfraAgendamentoTarefaBD(BancoSEI::getInstance());
     $objReceberProcessosPEN = new InfraAgendamentoTarefaDTO();
     $objReceberProcessosPEN->setStrComando("PENAgendamentoRN::processarTarefasPEN");
+    $objReceberProcessosPEN->retTodos();
     if ($objInfraAgendamentoTarefaBD->contar($objReceberProcessosPEN) > 0) {
       $objReceberProcessosPEN->retTodos();
       $objReceberProcessosPEN = $objInfraAgendamentoTarefaBD->consultar($objReceberProcessosPEN);
-      $objReceberProcessosPEN->setStrSinAtivo("N");
-      $objInfraAgendamentoTarefaBD->alterar($objReceberProcessosPEN);
+      $objInfraAgendamentoTarefaBD->excluir($objReceberProcessosPEN);
     }
 
-    $sql = "SELECT 
+    $sql = "SELECT DISTINCT
           mpel.*,
           mprel.id_procedimento,
           p.protocolo_formatado,
@@ -2864,12 +2864,12 @@ protected function instalarV3070()
 
     $lotesVazios = $objInfraBanco->consultarSql($sql);
 
-    $sql = "SELECT 
+    $sql = "SELECT DISTINCT
           mpb.id as id_bloco,
           mpbp.id_protocolo,
           p.protocolo_formatado,
-          p.id_unidade_geradora,
-          p.id_usuario_gerador,
+          mpb.id_unidade as id_unidade_geradora,
+          mpb.id_usuario as id_usuario_gerador,
           mpel.*,
           mprel.id_andamento,
           mprel.id_atividade_expedicao,
@@ -3005,14 +3005,8 @@ protected function instalarV3070()
     }
 
     $objReceberProcessosPEN = new InfraAgendamentoTarefaDTO();
-    $objReceberProcessosPEN->setStrComando("PENAgendamentoRN::processarTarefasPEN");
-    if ($objInfraAgendamentoTarefaBD->contar($objReceberProcessosPEN) > 0) {
-      $objReceberProcessosPEN->retTodos();
-      $objReceberProcessosPEN = $objInfraAgendamentoTarefaBD->consultar($objReceberProcessosPEN);
-      $objReceberProcessosPEN->setStrComando("PENAgendamentoRN::processarTarefasRecebimentoPEN");
-      $objReceberProcessosPEN->setStrSinAtivo("S");
-      $objInfraAgendamentoTarefaBD->alterar($objReceberProcessosPEN);
-    } else {
+    $objReceberProcessosPEN->setStrComando("PENAgendamentoRN::processarTarefasRecebimentoPEN");
+    if ($objInfraAgendamentoTarefaBD->contar($objReceberProcessosPEN) == 0) {
       $objReceberProcessosPEN->setStrComando("PENAgendamentoRN::processarTarefasRecebimentoPEN");
       $strDesc = "Recebe as notificações de novos trâmites de processos/documentos, notificações de conclusão de trâmites ou recusas de recebimento de processos por outras instituições. \n\n";
       $strDesc .= "Este agendamento considera os seguintes parâmetros durante sua execução:\n";
@@ -3084,7 +3078,12 @@ private function atualizarBlocosLegado($blocosTramite)
   {
     if (!empty($blocosTramite)) {
       $objPenBlocoProcessoRN = new PenBlocoProcessoRN();
+      $arrIdProtocolo = array();
       foreach($blocosTramite as $blocoTramite) {
+        if (in_array($blocoTramite['id_protocolo'], $arrIdProtocolo)) {
+          continue;
+        }
+
         $objPenBlocoProcessoDTO = new PenBlocoProcessoDTO();
 
         $objPenBlocoProcessoDTO->setDblIdProtocolo($blocoTramite['id_protocolo']);
@@ -3126,6 +3125,8 @@ private function atualizarBlocosLegado($blocosTramite)
         }
         $objPenBlocoProcessoDTO->setDthRegistro($dthRegistro);
         $objPenBlocoProcessoDTO = $objPenBlocoProcessoRN->cadastrar($objPenBlocoProcessoDTO);
+
+        $arrIdProtocolo[] = $blocoTramite['id_protocolo'];
       }
     }
   }
@@ -3141,7 +3142,12 @@ private function atualizarLotesLegados($lotesVazios)
     if (!empty($lotesVazios)) {
       $objPenBlocoProcessoRN = new PenBlocoProcessoRN();
       $dthRegistro = date('d/m/Y H:i:s');
+      $arrIdProcedimento = array();
       foreach ($lotesVazios as $loteVazio) {
+        if (in_array($loteVazio['id_procedimento'], $arrIdProcedimento)) {
+          continue;
+        }
+
         $objTramiteEmBlocoDTO = $this->cadastrarBlocoGenerico($loteVazio['id_unidade'], $loteVazio['id_usuario']);
         $numIdAndamento = $this->buscarIdAndamento($loteVazio['id_procedimento']);
 
@@ -3165,6 +3171,8 @@ private function atualizarLotesLegados($lotesVazios)
         $objPenBlocoProcessoDTO->setDthRegistro($dthRegistro);
 
         $objPenBlocoProcessoDTO = $objPenBlocoProcessoRN->cadastrar($objPenBlocoProcessoDTO);
+
+        $arrIdProcedimento[] = $loteVazio['id_procedimento'];
       }
     }
   }