bin/cdr-opensips.import

   1 #!/usr/bin/perl
   2
   3 use strict;
   4 use vars qw( $DEBUG );
   5 use Date::Parse 'str2time';
   6 use Date::Format 'time2str';
   7 use FS::UID qw(adminsuidsetup dbh);
   8 use FS::cdr;
   9 use DBI;
  10 use Getopt::Std;
  11
  12 my %opt;
  13 getopts('H:U:P:D:T:', \%opt);
  14 my $user = shift or die &usage;
  15
  16 my $dsn = 'dbi:mysql';
  17 $dsn .= ":database=$opt{D}" if $opt{D};
  18 $dsn .= ":host=$opt{H}" if $opt{H};
  19
  20 my $mysql = DBI->connect($dsn, $opt{U}, $opt{P})
  21   or die $DBI::errstr;
  22
  23 adminsuidsetup $user;
  24
  25 my $fsdbh = FS::UID::dbh;
  26
  27 # check for existence of freesidestatus
  28 my $table = $opt{T} || 'cdrs';
  29 my $status = $mysql->selectall_arrayref("SHOW COLUMNS FROM $table WHERE Field = 'freesidestatus'");
  30 if( ! @$status ) {
  31   print "Adding freesidestatus column...\n";
  32   $mysql->do("ALTER TABLE $table ADD COLUMN freesidestatus varchar(32)")
  33     or die $mysql->errstr;
  34 }
  35 else {
  36   print "freesidestatus column present\n";
  37 }
  38
  39 my @cols = ( qw(
  40   cdr_id call_start_time duration sip_call_id sip_from_tag
  41   sip_to_tag created
  42   ) );
  43
  44 my $sql = 'SELECT '.join(',', @cols). " FROM $table WHERE freesidestatus IS NULL";
  45 my $sth = $mysql->prepare($sql);
  46 $sth->execute;
  47 print "Importing ".$sth->rows." records...\n";
  48
  49 my $cdr_batch = new FS::cdr_batch({
  50     'cdrbatch' => 'mysql-import-'. time2str('%Y/%m/%d-%T',time),
  51   });
  52 my $error = $cdr_batch->insert;
  53 die $error if $error;
  54 my $cdrbatchnum = $cdr_batch->cdrbatchnum;
  55 my $imports = 0;
  56 my $updates = 0;
  57
  58 my $row;
  59 while ( $row = $sth->fetchrow_hashref ) {
  60   my $cdr = FS::cdr->new({
  61       calldate    => $row->{'call_start_time'},
  62       src         => $row->{'sip_from_tag'},
  63       dst         => $row->{'sip_to_tag'},
  64       duration    => $row->{'duration'},
  65       billsec     => $row->{'duration'},
  66       uniqueid    => $row->{'cdr_id'},
  67       cdrbatchnum => $cdrbatchnum,
  68     });
  69   $cdr->startdate(str2time($cdr->calldate));
  70   $cdr->cdrbatchnum($cdrbatchnum);
  71   my $error = $cdr->insert;
  72   if($error) {
  73     print "failed import: $error\n";
  74   }
  75   else {
  76     $imports++;
  77     if( $mysql->do("UPDATE $table SET freesidestatus = 'done'
  78         WHERE cdr_id = ?",
  79         undef,
  80         $row->{'cdr_id'}
  81       ) ) {
  82         $updates++;
  83     }
  84     else {
  85       print "failed to set status: ".$mysql->errstr."\n";
  86     }
  87   }
  88 }
  89 print "Done.\nImported $imports CDRs, marked $updates CDRs as done.\n";
  90 $mysql->disconnect;
  91
  92 sub usage {
  93   "Usage: \n  cdr-opensips.import\n\t[ -H host ]\n\t-D database\n\t-U user\n\t-P password\n\tfreesideuser\n";
  94 }
  95