5 use Date::Parse 'str2time';
6 use Date::Format 'time2str';
7 use FS::UID qw(adminsuidsetup dbh);
13 getopts('H:U:P:D:T:', \%opt);
14 my $user = shift or die &usage;
16 my $dsn = 'dbi:mysql';
17 $dsn .= ":database=$opt{D}" if $opt{D};
18 $dsn .= ":host=$opt{H}" if $opt{H};
20 my $mysql = DBI->connect($dsn, $opt{U}, $opt{P})
25 my $fsdbh = FS::UID::dbh;
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'");
31 print "Adding freesidestatus column...\n";
32 $mysql->do("ALTER TABLE $table ADD COLUMN freesidestatus varchar(32)")
33 or die $mysql->errstr;
36 print "freesidestatus column present\n";
40 cdr_id call_start_time duration sip_call_id sip_from_tag
44 my $sql = 'SELECT '.join(',', @cols). " FROM $table WHERE freesidestatus IS NULL";
45 my $sth = $mysql->prepare($sql);
47 print "Importing ".$sth->rows." records...\n";
49 my $cdr_batch = new FS::cdr_batch({
50 'cdrbatch' => 'mysql-import-'. time2str('%Y/%m/%d-%T',time),
52 my $error = $cdr_batch->insert;
54 my $cdrbatchnum = $cdr_batch->cdrbatchnum;
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,
69 $cdr->startdate(str2time($cdr->calldate));
70 $cdr->cdrbatchnum($cdrbatchnum);
71 my $error = $cdr->insert;
73 print "failed import: $error\n";
77 if( $mysql->do("UPDATE $table SET freesidestatus = 'done'
85 print "failed to set status: ".$mysql->errstr."\n";
89 print "Done.\nImported $imports CDRs, marked $updates CDRs as done.\n";
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";