FEAT: Funções hubsoftModel.js

- Query de coleta de atendimentos refactorado.

- Criado funções de query para validar status do atendimento no Hub e validar mensagens do atendimento.
This commit is contained in:
Gabriel Amancio 2025-10-07 16:00:50 -03:00
parent f5e2cb9add
commit 35ce8a4c49

View File

@ -10,12 +10,22 @@ const pool = new Pool({
}); });
const getAtendimentosFromDB = async () => { const getAtendimentosFromDB = async () => {
const query = 'SELECT * FROM atendimento WHERE id_tipo_atendimento = 4 AND id_usuario_abertura = 248 AND ( id_atendimento_status = 33 OR id_atendimento_status = 1 OR id_atendimento_status = 2 );'; const query = 'SELECT a.id_atendimento, a.id_usuario_abertura, a.id_atendimento_status, a.protocolo, a.descricao_abertura, a.data_cadastro, a.nome_contato, c.codigo_cliente, s.descricao FROM atendimento AS a INNER JOIN cliente_servico AS cs ON a.id_cliente_servico = cs.id_cliente_servico INNER JOIN cliente AS c ON cs.id_cliente = c.id_cliente INNER JOIN servico AS s ON cs.id_servico = s.id_servico WHERE a.id_tipo_atendimento = 4 AND a.id_usuario_abertura = 248 AND a.id_atendimento_status IN (1, 2, 33) AND s.ativo = true;';
const { rows } = await pool.query(query); const { rows } = await pool.query(query);
return rows; return rows;
} }
const validateAtendimentoStatus = (id_atendimento) => {
const query = `SELECT id_atendimento_status FROM atendimento WHERE id_atendimento = ${id_atendimento};`;
return pool.query(query);
}
const validateMensagensByAtendimento = (id_atendimento) => {
const query = `SELECT id_atendimento_mensagem, id_atendimento, mensagem, data_cadastro FROM atendimento_mensagem WHERE id_atendimento = ${id_atendimento} ;`
return pool.query(query);
}
module.exports = { module.exports = {
getAtendimentosFromDB getAtendimentosFromDB, validateAtendimentoStatus, validateMensagensByAtendimento
}; };