forked from SimplesIP/pabx-pesquisa
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
86 lines
2.9 KiB
86 lines
2.9 KiB
<?php |
|
|
|
/* |
|
* To change this template, choose Tools | Templates |
|
* and open the template in the editor. |
|
*/ |
|
|
|
|
|
|
|
$dbPort = "5432"; |
|
$dbHost = "127.0.0.1"; |
|
$dbName = "pbx"; |
|
$dbUser = "contacte"; |
|
$dbPassword = "ctepgSQL"; |
|
$str = "host='$dbHost' port='$dbPort' dbname='$dbName' user='$dbUser' password='$dbPassword'"; |
|
$dbcon = @pg_connect($str); |
|
|
|
//verifica se a conexao foi criada com sucesso. |
|
$statusCon = pg_connection_status($dbcon); |
|
|
|
if ($statusCon === 0) { |
|
|
|
$sql = 'begin'; |
|
$result = @pg_query($sql, $dbcon); |
|
|
|
// Pega o id max da tabela a receber os dados importados. |
|
$sql = "select coalesce(max(id),0) from pbx_eventos_dacs"; |
|
$result = @pg_query($sql, $dbcon); |
|
$row = @pg_fetch_row($result); |
|
$maxEvento = $row[0]; |
|
|
|
//Verifica se houve erros na execução da query. |
|
$result = empty(pg_last_error()); |
|
|
|
if ($result) { |
|
$sql = "insert |
|
into pbx_eventos_dacs (id,uid1, uid2, fila, agente, evento, param1, param2, param3, param4) |
|
select id, uid1, uid2, fila, agente, evento, param1, param2, param3, param4 |
|
from ast_eventos_dacs |
|
where id > $maxEvento"; |
|
$result = @pg_query($sql, $dbcon); |
|
|
|
|
|
//Verifica se houve erros na execução do insert. |
|
$result = empty(pg_last_error()); |
|
|
|
if ($result) { |
|
// Pega o id max da tabela a receber os dados importados. |
|
$sql = "select coalesce(max(id_bilhetes),0) from pbx_bilhetes"; |
|
$result = @pg_query($sql, $dbcon); |
|
$row = @pg_fetch_row($result); |
|
$maxBilhete = $row[0]; |
|
|
|
//Verifica se houve erros na execução da query. |
|
$result = empty(pg_last_error()); |
|
|
|
if ($result) { |
|
$sql = "insert |
|
into pbx_bilhetes( |
|
id_bilhetes, calldate, clid, src, dst, dcontext, channel, dstchannel, |
|
lastapp, lastdata, duration, billsec, disposition, amaflags, |
|
accountcode, uniqueid, userfield) |
|
select id_bilhetes, calldate, clid, src, dst, dcontext, channel, dstchannel, |
|
lastapp, lastdata, duration, billsec, disposition, amaflags, |
|
accountcode, uniqueid, userfield |
|
from ast_bilhetes |
|
where id_bilhetes > $maxBilhete"; |
|
|
|
$result = @pg_query($sql, $dbcon); |
|
|
|
//Verifica se houve erros na execução do insert. |
|
$result = empty(pg_last_error()); |
|
} |
|
} |
|
} |
|
|
|
//Excuta o commit se não houve erros na execução dos inserts |
|
if ($result) { |
|
$sql = 'commit'; |
|
$result = @pg_query($sql, $dbcon); |
|
} else { |
|
$sql = 'rollback'; |
|
$result = @pg_query($sql, $dbcon); |
|
} |
|
} |
|
?>
|
|
|