diff --git a/asterisk/var_lib_asterisk/agi-bin/agente_fila.php b/asterisk/var_lib_asterisk/agi-bin/agente_fila.php index 42a9f68a..ebf6d058 100755 --- a/asterisk/var_lib_asterisk/agi-bin/agente_fila.php +++ b/asterisk/var_lib_asterisk/agi-bin/agente_fila.php @@ -137,7 +137,7 @@ if ($dados[0]) { /* * Função retorna numero de Protocolo de Atendimento para o agente */ -$protocolo = GeraProtocolo($conexao, $UNIQUEID); +$protocolo = GeraProtocolo($conexao, $UNIQUEID, $org_id); /* * Pesquisa se existe informaçoes retornadas pela integração ativa. diff --git a/asterisk/var_lib_asterisk/agi-bin/pbx_complemento.php b/asterisk/var_lib_asterisk/agi-bin/pbx_complemento.php index 93d70d8c..f360a647 100755 --- a/asterisk/var_lib_asterisk/agi-bin/pbx_complemento.php +++ b/asterisk/var_lib_asterisk/agi-bin/pbx_complemento.php @@ -112,7 +112,7 @@ if (!$consulta) { /* * Função retorna numero de Protocolo de Atendimento para o agente */ - $protocolo = GeraProtocolo($conexao, $uniqueid); + $protocolo = GeraProtocolo($conexao, $uniqueid, $org_id); $query = "UPDATE pbx_supervisor_agentes SET protocolo = '$protocolo', origem_destino = '$destino',canal_agente = '$canal_agente' , status = 'CHAMANDO',duracao = 'now()',tipo_ligacao = 'S',uniqueid = '$uniqueid',uniqueid2 = '$uniqueid',tipo_discagem = 'MANUAL' WHERE ramal = '$origem' and org_id = $org_id"; $result = pg_query($conexao, $query); @@ -338,7 +338,7 @@ if (strtolower($contexto) == 'ext-transferencia') { /* * Função retorna numero de Protocolo de Atendimento para o agente */ - $protocolo = GeraProtocolo($conexao, $uniqueid); + $protocolo = GeraProtocolo($conexao, $uniqueid, $org_id); $query = "UPDATE pbx_supervisor_agentes SET protocolo = '$protocolo', canal = '$canal', origem_destino = '$origem',status = 'CHAMANDO',duracao = 'now()',tipo_ligacao = 'E',uniqueid = '$uniqueid',uniqueid2 = '$uniqueid',tipo_discagem = 'MANUAL' where ramal = '$destino' and org_id = $org_id"; $result = pg_query($conexao, $query); diff --git a/include/util/util.php b/include/util/util.php index 8af8f0c9..26c1a286 100755 --- a/include/util/util.php +++ b/include/util/util.php @@ -1846,10 +1846,10 @@ function GenerateCsvFromArray($data, $delimiter = ',', $enclosure = '"') return $contents; } -function GetProto($db, $uniqueId, $protoParceiro = '') +function GetProto($db, $uniqueId, $protoParceiro = '', $org_id) { try { - $query = "select prm_agente_proto, prm_use_proto_parceiro from pbx_parametros where id = 1"; + $query = "SELECT prm_agente_proto, prm_use_proto_parceiro FROM pbx_parametros WHERE org_id IN ($org_id, 0) LIMIT 1;"; $result = pg_query($db, $query); if (!$result || !pg_num_rows($result)) { GeraExcept("Não foi possível consultar os parametros do sistema!"); @@ -1867,7 +1867,7 @@ function GetProto($db, $uniqueId, $protoParceiro = '') * Verifica se o protocolo já existe protocolo */ $anoAtu = date('Y'); - $query = " select ano::text || '-' || lpad(numproto::text,6,'0') as protocolo, protoparceiro from pbx_protocolo_reg where uniqueid = '$uniqueId'"; + $query = " select ano::text || '-' || lpad(numproto::text,6,'0') as protocolo, protoparceiro from pbx_protocolo_reg where uniqueid = '$uniqueId' and org_id in ($org_id, 0)"; $result = pg_query($db, $query); if (!$result) { GeraExcept("Não foi possível consultar protocolos existentes!"); @@ -1895,7 +1895,7 @@ function GetProto($db, $uniqueId, $protoParceiro = '') */ $protoParceiro = $useProtoParceiro ? trim($protoParceiro) : ''; $anoAtu = date('Y'); - $query = "select max(numProto) from pbx_protocolo_reg where ano = '$anoAtu'"; + $query = "select max(numProto) from pbx_protocolo_reg where ano = '$anoAtu' and org_id in ($org_id, 0)"; $result = pg_query($db, $query); if ($result) { @@ -1908,8 +1908,8 @@ function GetProto($db, $uniqueId, $protoParceiro = '') //return $protoAgt; $query = "insert into pbx_protocolo_reg - ( uniqueid, ano, numProto, protocolo, protoparceiro) - values('$uniqueId', '$anoAtu', '$numProto', '$proto', $protoParceiro)"; + ( uniqueid, ano, numProto, protocolo, protoparceiro, org_id) + values('$uniqueId', '$anoAtu', '$numProto', '$proto', $protoParceiro, $org_id)"; $result = pg_query($db, $query); if (!$result) { @@ -1979,7 +1979,7 @@ function VerificaClassificacao($db, $fila, $matricula, $ramal, $uniqueid, $class } } -function GeraProtocolo($db, $uniqueid) +function GeraProtocolo($db, $uniqueid, $org_id) { /* @@ -1987,7 +1987,7 @@ function GeraProtocolo($db, $uniqueid) */ $tentativa = 0; while (true) { - $proto = @GetProto($db, $uniqueid); + $proto = @GetProto($db, $uniqueid, '', $org_id); if ($proto == '99') { $proto = '0000-000000'; break;