X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=bin%2Fcdr-voipnow.import;h=c16b00d7c89fd7f5718d76c4fd045a1c705ad590;hp=eb36010af91c74f17014fd8dd8cc8e3f2a740dac;hb=6d167446d719a361d84bf6be752ad24d718eaa35;hpb=7d1cf3b75da3ba9aab3667cdc0125e25bbc76438

diff --git a/bin/cdr-voipnow.import b/bin/cdr-voipnow.import
index eb36010af..c16b00d7c 100755
--- a/bin/cdr-voipnow.import
+++ b/bin/cdr-voipnow.import
@@ -45,7 +45,8 @@ print "Selecting CDRs from $start_id to ".($end_id || 'end')."...\n";
 my $table = $opt{T} || 'call_history';
 # spelled "disposion" in the table
 my @cols = ( qw( 
-  id extension_number flow channel partyid start answer duration disposion) );
+  id extension_number flow channel partyid start answer duration disposion did
+  client_client_id ) );
 my $sql = 'SELECT '.join(',', @cols). " FROM $table WHERE id >= $start_id";
 $sql .= " AND id <= $end_id" if $end_id;
 $sql .= " ORDER BY id";
@@ -80,6 +81,7 @@ while ( $row = $sth->fetchrow_hashref ) {
       startdate     => str2time($row->{start}),
       answerdate    => str2time($row->{answer}),
       cdrbatchnum   => $cdrbatchnum,
+      accountcode   => $row->{client_client_id},
     }
   );
   print $row->{id},"\n" if $opt{v};
@@ -88,7 +90,7 @@ while ( $row = $sth->fetchrow_hashref ) {
     $cdr->dst($row->{'partyid'});
   }
   elsif ( $row->{flow} eq 'in' ) {
-    $cdr->dst($row->{'extension_number'});
+    $cdr->dst($row->{'did'});
     $cdr->src($row->{'partyid'});
   }
   else {