ReceberComponenteDigitalRN.php
6.09 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
<?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));
}
//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);
return strcmp($strHashInformado, $strHashDoArquivo) == 0;
}
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("Registro não encontrado.");
}
$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);*/
}
}