"; die($select);
		$Rs = $this->_db->fetchAll($select);
		return $Rs;
	}

	public function saveAgendamento($dados) {

		$sql = "SELECT id_vistoria FROM seguro.propostas_vistorias_previas WHERE id = {$dados['id_proposta_vistoria']}";
		$id_vistoria = $this->_db->fetchOne($sql);

		$sql = "SELECT id_agendamento FROM sistema.vistorias_agendamentos WHERE id_vistoria = $id_vistoria";
		$id_agendamento = $this->_db->fetchOne($sql);

		$ModelAgendamentos = new Sistema_Model_Agendamentos();
		$dados['id'] = $id_agendamento;

		$ModelAgendamentos->save($dados);

		$Row = $this->getRow($dados['id_proposta_vistoria']);

		if(!$Row) {
			return;
		}

		$sql = "SELECT
				s.id
				FROM
				sistema.status s INNER JOIN
				sistema.tipo_status t ON s.id_tipo_status = t.id
				WHERE
				t.ds_chave = 'VP' AND s.cd_status = 3";

		$status = $this->_db->fetchOne($sql);
		$Row->id_status = $status;

		return $Row->save();

	}


	public function countLaudosPrevia($idVistoria) {
		$select = $this->select();
		$select->setIntegrityCheck(false);
		$select->from(array('vpl'=>'seguro.vistorias_previas_laudos'),'count(id)');
		$select->where('id_vistoria = ? ', $idVistoria);

		return $this->_db->fetchOne($select);
	}

	public function getIdLaudo($idVistoria, $dtLaudo) {
		$select = $this->select();
		$select->setIntegrityCheck(false);
		$select->from(array('vpl'=>'seguro.vistorias_previas_laudos'),'id');
		$select->join(array('v'=>'sinistro.v_laudos_cobranca_previa'),'v.id_vistoria_previa_laudo = vpl.id',false);
		$select->where('vpl.id_vistoria = ? ', $idVistoria);
		$select->where('v.dt_vistoria = ? ', $dtLaudo);

		return $this->_db->fetchOne($select);
	}

	public function temLaudoDigitado($id_proposta){
		$select = $this->select()->setIntegrityCheck(false);
		$select->from(array("vp" => $this->_schema.".".$this->_name),'id');
		$select->where('vp.id_proposta = ?', $id_proposta);
		$select->where('vp.id_status IN (70,71)');

		$Rs = $this->getAdapter()->fetchAll($select);
		if(count($Rs)){
			return true;
		}

		return false;
	}

	public function temLaudoNaoTransmitido($id_proposta){

		$Safra = new Produto_Model_Safras();
		$schema = $Safra->getSafraModel($id_proposta);

		$select = $this->select()->setIntegrityCheck(false);
		$select->from(array("vp" => $this->_schema.".".$this->_name),'id');
		$select->join(array('lvp001'=>$schema.'.lvp001'),'lvp001.id_proposta_vistoria = vp.id',false);
		$select->where('vp.id_proposta = ?', $id_proposta);
		$select->where('lvp001.fl_transmitido = ?','false');

		$Rs = $this->getAdapter()->fetchRow($select);
		if(!$Rs){
			return false;
		}

		return true;

	}

    public function getEmpresaByVistoria($id) {

        $select = $this->select()->setIntegrityCheck(false);
        $select->from(array('pvp' => $this->_schema.'.'.$this->_name), false);
        $select->join(array('ve' => 'sistema.vistorias_empresas'), 've.id_vistoria = pvp.id_vistoria', false);
        $select->join(array('e' => 'sistema.empresas'), 'e.id = ve.id_empresa', 'e.ds_nome_fantasia');
        $select->where('pvp.id = ?', $id);

        $nome = $this->getAdapter()->fetchOne($select);
        return ($nome ? $nome : false);
    }

	public function updateVistoriaMobile($id_vistoria){
		$this->_db->query('update seguro.propostas_vistorias_previas set fl_sincronizado = true where id_vistoria = '. $id_vistoria);
		return true;
	}

	public function getAgendamentoVistoriaPreviaByProposta($idProposta)
	{
		$select = $this->select()->setIntegrityCheck(false);
		$select->from(array('pvp' => $this->_schema.'.'.$this->_name), array('pvp.id as id_vistoria_previa', 'pvp.id_vistoria', "to_char(pvp.dt_prazo_agendamento, 'DD/MM/YYYY') as dt_prazo_agendamento"));
		$select->joinLeft(array('va' => 'sistema.vistorias_agendamentos'), 'va.id_vistoria = pvp.id_vistoria', false);
		$select->joinLeft(array('a' => 'sistema.agendamentos'), 'va.id_agendamento = a.id', array('a.id as id_agendamento', "to_char(a.dt_agendamento, 'DD/MM/YYYY') as dt_agendamento"));
		$select->where('pvp.id_proposta = ?', $idProposta);

		$row = $this->getAdapter()->fetchRow($select);
        return $row;
	}

	public function getById($idVP) {
		
	}

	public function getDataConsulta($where = array()) {
		$sql = "
			SELECT p.id,
			       p.id_proposta_mae,
			       s.cd_status || ' - ' || s.ds_status as status,
			       prop.ds_nome_proponente,
			       prod.ds_nome_abreviado,
			       m.ds_nome_municipio || '/' || e.ds_sigla as municipio,
			       case when su.ds_nome_usuario <> '' then su.ds_nome_usuario else su_criacao.ds_nome_usuario end as digitador,
			       svp.id as status_vistoria_id,
			       svp.ds_status as status_vistoria,
			       sa.id as status_analise_id,
			       sa.ds_status as status_analise,
			       case 
			         when svp.id = 71 THEN (SELECT dt_transmissao 
			         	                      FROM regulacao.lvp001 
			         	                     WHERE lvp001.id_proposta_vistoria = pvp.id order by lvp001.id_proposta_vistoria desc limit 1
			         	                   )
			         when svp.id = 70 THEN (SELECT dt_agendamento 
			         						  FROM sistema.agendamentos ag 
			         						  JOIN sistema.vistorias_agendamentos va ON va.id_agendamento = ag.id
			         						  JOIN sistema.vistorias v ON v.id = va.id_vistoria
			         						 WHERE pvp.id_vistoria = v.id order by v.id desc limit 1
			     						   ) 
			         else NULL
			       end as data,
			       sve.id_empresa,
			       prod.id_safra,
			       pvp.id as id_proposta_vistoria
			  FROM seguro.propostas AS p
			  JOIN sistema.status AS s ON s.id = p.id_status
			  JOIN seguro.propostas_proponentes as prop ON prop.id_proposta = p.id
			  JOIN produto.produtos AS prod ON p.id_produto = prod.id
			  JOIN seguro.propostas_propriedades AS pp ON pp.id_proposta = p.id
			  JOIN sistema.municipios AS m ON m.id = pp.id_municipio 
			  JOIN sistema.estados AS e ON e.id = m.id_estado
			  JOIN seguro.propostas_vistorias_previas pvp ON pvp.id_proposta = p.id
			  JOIN sistema.status AS svp ON svp.id = pvp.id_status
			  JOIN sistema.status AS sa ON sa.id = pvp.id_status_analise
			  JOIN sistema.usuarios AS su_criacao ON su_criacao.id = p.id_usuario_criacao
			  LEFT JOIN sistema.prepostos sp ON sp.id_usuario = p.id_usuario_criacao
			  LEFT JOIN sistema.usuarios su ON su.id = sp.id_usuario
			  LEFT JOIN sistema.vistorias_empresas sve ON sve.id_vistoria = pvp.id_vistoria
 		";

 		if (!empty($where)) {
 			$sql .= "WHERE " . implode(" AND ", $where);
 		}

		$rs = $this->_db->fetchAll($sql);
		return $rs;
	}

    public function getVistoriasByProposta(int $idProposta)
    {
        $select = $this->select()->setIntegrityCheck(false);
        $select->from(['spvp' => "{$this->_schema}.{$this->_name}"]);
        $select->where('spvp.id_proposta = ?', $idProposta);

        return $this->fetchAll($select);
    }

	public function getIdByPropostaVistoria(int $idProposta, int $idVistoria) {
	    $sub1 = $this->select()->setIntegrityCheck(false)
		    ->from(['pr' => 'seguro.propostas'], 'id_endosso')
	    	    ->where('id = ?', $idProposta);
	    $sub2 = $this->select()->setIntegrityCheck(false)
		    ->from(['pe' => 'seguro.propostas_endosso'], 'id_proposta')
		    ->where('id_endosso = ('.$sub1.')')
	    	    ->where('fl_proposta_vigente = true');
	    $select = $this->select()->setIntegrityCheck(false)
            	    ->from(['spvp' => "{$this->_schema}.{$this->_name}"], 'id')
            ->where('spvp.id_proposta = ('.$sub2.')')
            ->where('spvp.id_vistoria = ?', $idVistoria); 
        return $this->fetchRow($select);
    }

    public function updateIdPropostaEndossada(int $idProposta, int $idPropostaEndossada) {
        $vistorias = $this->fetchAll('id_proposta = '. $idPropostaEndossada.' and id_status not in (71,226)')->toArray(); 

        if (count($vistorias) > 0) {
            foreach ($vistorias as $vistoria) {
                $this->update(
                    ['id_proposta' => $idProposta],
                    'id = ' . $vistoria['id']
                );
            }
        }
    }

	/**
	 * Retorna as vistorias de acordo com a proposta e os status informados.
	 * 
	 * @param int $idProposta
	 * @param array $idStatus
	 */
	public function getByPropostaStatus(int $idProposta, array $idsStatus) {
		$status = implode(',', $idsStatus);

		$select = $this->select()->setIntegrityCheck(false);
		$select->from(array("vp" => $this->_schema.".".$this->_name), ['id', 'id_status', 'id_vistoria']);
		$select->join(
			array("pr" => "seguro.propostas"),
			"pr.id = vp.id_proposta",
			'id_proposta_mae,
			cast(pg.id_ramo as varchar) || \'.\' ||
			cast(pd.id_seguradora as varchar) || \'.\' ||
			cast(pr.id_produto as varchar) || \'.\' ||
			cast(pr.id as varchar) || \'-\' ||
			cast(pr.nr_digito_verificador as varchar)
			as nr_proposta'
		);
		$select->join(array('pd'=>'produto.produtos'),'pr.id_produto = pd.id','ds_nome_produto','');
		$select->joinLeft(array('pg'=>'produto.produtos_geral'),'pd.id_produto_geral = pg.id','');
		$select->join(array("ve" => "sistema.vistorias_empresas"), "ve.id_vistoria = vp.id_vistoria", null);
		$select->join(array("e" => "sistema.empresas"), "e.id = ve.id_empresa", ["ds_email_responsavel", "ds_nome_responsavel"]);
		$select->joinLeft(array("va" => "sistema.vistorias_agendamentos"), "va.id_vistoria = vp.id_vistoria", null);
		$select->joinLeft(array("a" => "sistema.agendamentos"), "a.id = va.id_agendamento", "to_char(a.dt_agendamento, 'DD/MM/YYYY') as dt_agendamento");
		$select->where('vp.id_proposta = ?', $idProposta);
		$select->where("vp.id_status IN ({$status})");
		$select->order("a.dt_agendamento DESC, vp.id DESC");
		
		return $this->getAdapter()->fetchAll($select);
	}

	/**
	 * Retorna os dados da vistoria pelo ID da proposta e pelo ID da vistoria
	 *
	 * @param int $idProposta
	 * @param int $idVistoria
	 * @return array
	 */
	public function getByIdVistoria(int $idVistoria): array
	{
		$select = $this->select()->setIntegrityCheck(false);
		$select->from(array("vp" => $this->_schema.".".$this->_name));
		$select->where('vp.id_vistoria = ?', $idVistoria);

		$rs = $this->getAdapter()->fetchRow($select);
		return $rs === false ? [] : $rs;
	}

	/**
	 * Altera o status da análise da vistoria para "Concluída - sem alterações"
	 *
	 * @param int $idVistoria
	 * @return Zend_Db_Table_Row
	 */
	private function alterarStatusAnaliseConcluida(int $idVistoria): Zend_Db_Table_Row
	{
		$row = $this->getRow($idVistoria);

		if (empty($row['id'])) {
			throw new Exception("Vistoria {$idVistoria} não encontrada.");
		}
			
		$row['id_status_analise'] = self::ID_STATUS_VP_ANALISE_CONCLUIDA_SEM_ALT;

		if (!$row->save()) {
			throw new Exception("Erro ao alterar o status de análise da vistoria {$idVistoria}.");
		}

		return $row;
	}

	/**
	 * Inclui um registro de alteração de status de análise da vistoria
	 *
	 * @param Zend_Db_Table_Row $row
	 */
	private function incluirHistorico(Zend_Db_Table_Row $row): void
	{
		$modelVistoriasEmpresas = new Sistema_Model_VistoriasEmpresas();
		$idEmpresaVistoria = $modelVistoriasEmpresas->getEmpresaByVistoria($row['id_vistoria']);

		if (empty($idEmpresaVistoria)) {
			throw new Exception("Erro ao buscar a empresa da vistoria {$row['id_vistoria']}.");
		}

		$modelVistoriaPreviaHistorico = new Seguro_Model_VistoriaPreviaHistorico();
		$dados['id_proposta_vistoria'] = $row->id;
		$dados['id_status'] = $row->id_status;
		$dados['id_status_analise'] = self::ID_STATUS_VP_ANALISE_CONCLUIDA_SEM_ALT;
		$dados['id_empresa_historico'] = $idEmpresaVistoria;
		$dados['id_status_alteracao'] = $row->id_status_alteracao;
		
		if (!$modelVistoriaPreviaHistorico->save($dados)) {
			throw new Exception("Erro ao incluir o histórico de alteração da vistoria {$row['id_vistoria']}.");
		}
	}

	/**
	 * Percorre todos os documentos da vistoria e altera para "Liberado" (fl_fila_transmissao = false)
	 * todos os arquivos que são diferentes do tipo "FOTO" e que estejam
	 * como "Aguardando Liberação" (fl_fila_transmissao = true).
	 *
	 * @param int $idPropostaVistoria
	 * @param int $idVistoria
	 */
	private function liberarDocumentos(int $idPropostaVistoria, int $idVistoria): void
	{
		$modelVistoriaPreviaEmpresaArquivos = new Seguro_Model_Vistoriapreviaempresaarquivos();
		$arquivos = $modelVistoriaPreviaEmpresaArquivos->getArquivos($idPropostaVistoria);
		
		foreach ($arquivos as $arquivo) {
			if ($arquivo['id_tipo_arquivo_laudo_previa'] != Sistema_Model_TipoArquivoLaudoPrevia::TIPO_FOTO &&
				!$arquivo['fl_fila_transmissao']
			){
				try {
					$modelVistoriaPreviaEmpresaArquivos->transmiteArquivo($arquivo['id'],$arquivo['ds_nome_arquivo']);
				} catch (\Throwable $th) {
					throw new Exception("Não foi possível realizar a liberação do arquivo {$arquivo['ds_nome_arquivo']} da vistoria {$idVistoria}.");
				}
			}
		}
	}

	/**
	 * Cadastra uma observação na proposta informado que a digitação de sinistro foi liberada
	 *
	 * @param int $idProposta
	 */
	private function cadastrarObservacao(int $idProposta): void
	{
		$modelPropostasObservacoes = new Seguro_Model_PropostasObservacoes();
		$dados = [
			'id_proposta' => $idProposta,
			'ds_observacao' => 'Digitação de Sinistro Liberada.'
		];
		
		if (!$modelPropostasObservacoes->save($dados)) {
			throw new Exception("Erro ao incluir a observação da proposta {$idProposta}.");
		}
	}

	/**
	 * Atualiza o status de análise para "Concluída - sem alterações", inclui o histórico de alteração do status,
	 * libera os documentos que estão como "Aguardando Liberação" e cadastra uma observação pra proposta.
	 *
	 * @param int $idVistoria
	 */
	public function concluirAnalise(int $idVistoria): void
	{
		$row = $this->alterarStatusAnaliseConcluida($idVistoria);
		$this->incluirHistorico($row);
		$this->liberarDocumentos($row['id'], $idVistoria);
		$this->cadastrarObservacao($row['id_proposta']);
	}
}