X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fcdr.pm;h=e8be0805669b38cb2dc93076cb5c1608409c6bf4;hb=99305e66f7e7a5cc16a35694f57a6adb49691625;hp=bd0ed57e90490095f00018acd2d14b203b91ca0a;hpb=a4dc6eea04eb566cfa21d424fe1bd62661134fdf;p=freeside.git

diff --git a/FS/FS/cdr.pm b/FS/FS/cdr.pm
index bd0ed57e9..e8be08056 100644
--- a/FS/FS/cdr.pm
+++ b/FS/FS/cdr.pm
@@ -899,9 +899,14 @@ sub _upgrade_data {
 
   my %cdrbatchnum = ();
   while (my $row = $sth->fetchrow_arrayref) {
-    my $cdr_batch = new FS::cdr_batch { 'cdrbatch' => $row->[0] };
-    my $error = $cdr_batch->insert;
-    die $error if $error;
+
+    my $cdr_batch = qsearchs( 'cdr_batch', { 'cdrbatch' => $row->[0] } );
+    unless ( $cdr_batch ) {
+      $cdr_batch = new FS::cdr_batch { 'cdrbatch' => $row->[0] };
+      my $error = $cdr_batch->insert;
+      die $error if $error;
+    }
+
     $cdrbatchnum{$row->[0]} = $cdr_batch->cdrbatchnum;
   }