ReceberComponenteDigitalRN.php
6.79 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
<?php
require_once dirname(__FILE__) . '/../../../SEI.php';
class ReceberComponenteDigitalRN extends InfraRN
{
private $objProcessoEletronicoRN;
private $objInfraParametro;
private $arrAnexos = array();
public function __construct()
{
parent::__construct();
$this->objInfraParametro = new InfraParametro(BancoSEI::getInstance());
$this->objProcessoEletronicoRN = new ProcessoEletronicoRN();
}
public function setArrAnexos($arrAnexos){
$this->arrAnexos = $arrAnexos;
}
public function getArrAnexos(){
return $this->arrAnexos;
}
protected function inicializarObjInfraIBanco()
{
return BancoSEI::getInstance();
}
protected function receberComponenteDigitalControlado(ComponenteDigitalDTO $parObjComponenteDigitalDTO)
{
if(!isset($parObjComponenteDigitalDTO) || !isset($parObjComponenteDigitalDTO)) {
throw new InfraException('Parâmetro $parObjComponenteDigitalDTO não informado.');
}
$objAnexoDTO = null;
foreach($this->arrAnexos as $key => $objAnexo){
if(array_key_exists($parObjComponenteDigitalDTO->getStrHashConteudo(), $objAnexo) && $objAnexo['recebido'] == false){
$objAnexoDTO = $objAnexo[$parObjComponenteDigitalDTO->getStrHashConteudo()];
$this->arrAnexos[$key]['recebido'] = true;
break;
}
}
if(is_null($objAnexoDTO)){
throw new InfraException('Anexo '.$parObjComponenteDigitalDTO->getStrHashConteudo().' não encontrado '.var_export($this->arrAnexos, true));
}
//Validar o hash do documento recebido com os dados informados pelo remetente
//$this->validarIntegridadeDoComponenteDigital($objAnexoDTO, $parObjComponenteDigitalDTO);
//Transferir documentos validados para o repositório final de arquivos
$this->cadastrarComponenteDigital($parObjComponenteDigitalDTO, $objAnexoDTO);
//Registrar anexo relacionado com o componente digital
$this->registrarAnexoDoComponenteDigital($parObjComponenteDigitalDTO, $objAnexoDTO);
}
private function registrarAnexoDoComponenteDigital($parObjComponenteDigitalDTO, $parObjAnexoDTO)
{
$objComponenteDigitalDTO = new ComponenteDigitalDTO();
$objComponenteDigitalDTO->setNumIdTramite($parObjComponenteDigitalDTO->getNumIdTramite());
$objComponenteDigitalDTO->setStrNumeroRegistro($parObjComponenteDigitalDTO->getStrNumeroRegistro());
$objComponenteDigitalDTO->setDblIdDocumento($parObjComponenteDigitalDTO->getDblIdDocumento());
$objComponenteDigitalDTO->setNumIdAnexo($parObjAnexoDTO->getNumIdAnexo());
$objComponenteDigitalBD = new ComponenteDigitalBD($this->getObjInfraIBanco());
$objComponenteDigitalDTO = $objComponenteDigitalBD->alterar($objComponenteDigitalDTO);
}
public function copiarComponenteDigitalPastaTemporaria($objComponenteDigital)
{
$objAnexoRN = new AnexoRN();
$strNomeArquivoUpload = $objAnexoRN->gerarNomeArquivoTemporario();
$strConteudoCodificado = $objComponenteDigital->conteudoDoComponenteDigital;
$strNome = $objComponenteDigital->nome;
$fp = fopen(DIR_SEI_TEMP.'/'.$strNomeArquivoUpload,'w');
fwrite($fp,$strConteudoCodificado);
fclose($fp);
//Atribui informações do arquivo anexo
$objAnexoDTO = new AnexoDTO();
$objAnexoDTO->setNumIdAnexo($strNomeArquivoUpload);
$objAnexoDTO->setDthInclusao(InfraData::getStrDataHoraAtual());
$objAnexoDTO->setNumTamanho(filesize(DIR_SEI_TEMP.'/'.$strNomeArquivoUpload));
$objAnexoDTO->setNumIdUsuario(SessaoSEI::getInstance()->getNumIdUsuario());
return $objAnexoDTO;
}
public function validarIntegridadeDoComponenteDigital(AnexoDTO $objAnexoDTO, $strHashConteudo, $parNumIdentificacaoTramite)
{
$strHashInformado = $strHashConteudo;
$strHashInformado = base64_decode($strHashInformado);
$objAnexoRN = new AnexoRN();
$strCaminhoAnexo = DIR_SEI_TEMP.'/'.$objAnexoDTO->getNumIdAnexo();
$strHashDoArquivo = hash_file("sha256", $strCaminhoAnexo, true);
if(strcmp($strHashInformado, $strHashDoArquivo) != 0) {
$this->objProcessoEletronicoRN->recusarTramite($parNumIdentificacaoTramite, "Hash do componente digital não confere com o valor informado pelo remetente.", ProcessoEletronicoRN::MTV_RCSR_TRAM_CD_CORROMPIDO);
// Adiciono nos detalhes o nome do método para poder manipular o cache
throw new InfraException("Hash do componente digital não confere com o valor informado pelo remetente.", null, __METHOD__);
}
}
public function cadastrarComponenteDigital(ComponenteDigitalDTO $parObjComponenteDigitalDTO, AnexoDTO $parObjAnexoDTO)
{
//Obter dados do documento
$objDocumentoDTO = new DocumentoDTO();
$objDocumentoDTO->retDblIdDocumento();
$objDocumentoDTO->retDblIdProcedimento();
$objDocumentoDTO->setDblIdDocumento($parObjComponenteDigitalDTO->getDblIdDocumento());
$objDocumentoRN = new DocumentoRN();
$objDocumentoDTO = $objDocumentoRN->consultarRN0005($objDocumentoDTO);
if ($objDocumentoDTO==null){
throw new InfraException("Documento não pode ser localizado (".$parObjComponenteDigitalDTO->getDblIdDocumento().")");
}
$objProtocoloDTO = new ProtocoloDTO();
$objProtocoloDTO->retDblIdProtocolo();
$objProtocoloDTO->retStrProtocoloFormatado();
$objProtocoloDTO->setDblIdProtocolo($objDocumentoDTO->getDblIdDocumento());
$objProtocoloRN = new ProtocoloRN();
$objProtocoloDTO = $objProtocoloRN->consultarRN0186($objProtocoloDTO);
//Complementa informações do componente digital
$parObjAnexoDTO->setStrNome($parObjComponenteDigitalDTO->getStrNome());
$arrStrNome = explode('.',$parObjComponenteDigitalDTO->getStrNome());
$strProtocoloFormatado = current($arrStrNome);
$objDocumentoDTO->setObjProtocoloDTO($objProtocoloDTO);
$objProtocoloDTO->setArrObjAnexoDTO(array($parObjAnexoDTO));
$objDocumentoDTO = $objDocumentoRN->alterarRN0004($objDocumentoDTO);
// @join_tec US029 (#3790)
/*$objObservacaoDTO = new ObservacaoDTO();
$objObservacaoDTO->setDblIdProtocolo($objProtocoloDTO->getDblIdProtocolo());
$objObservacaoDTO->setStrDescricao(sprintf('Número SEI do Documento na Origem: %s', $strProtocoloFormatado));
$objObservacaoDTO->setNumIdUnidade(SessaoSEI::getInstance()->getNumIdUnidadeAtual());
$objObservacaoBD = new ObservacaoRN();
$objObservacaoBD->cadastrarRN0222($objObservacaoDTO);*/
}
}