pabx-app/importaBilhetes.php

<?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);
    }
}
?>