bin/artera.import

   1 #!/usr/bin/perl -w
   2
   3 use strict;
   4
   5 use Text::CSV_XS;
   6 use FS::UID qw(adminsuidsetup);
   7 use FS::Record qw(qsearchs);
   8 use FS::svc_external;
   9 use FS::svc_domain;
  10 use FS::svc_acct;
  11
  12 $FS::svc_Common::noexport_hack = 1;
  13
  14 my $svcpart = 30;
  15
  16 my $user = shift
  17   or die 'Usage:\n\n  artera.import user <artera_active_orders.csv';
  18 adminsuidsetup $user;
  19
  20 ##
  21
  22 my $csv = new Text::CSV_XS;
  23
  24 my $header = scalar(<>);
  25
  26 my( $num, $linked ) = ( 0, 0 );
  27
  28 while (<>) {
  29   my $status = $csv->parse($_)
  30     or die $csv->error_input;
  31   my($serial, $keycode, $name, $ordernum, $email) = $csv->fields();
  32   #warn join(" - ", $serial, $keycode, $name, $ordernum, $email ). "\n";
  33
  34   $email =~ /^([^@]+)\@([^@]+)$/
  35     or die $email;
  36   my($username, $domain) = ( $1, $2 );
  37   my $svc_domain = qsearchs('svc_domain', { 'domain'  => $domain } );
  38   my $cust_svc = '';
  39   if ( $svc_domain ) {
  40     my $svc_acct = qsearchs('svc_acct', {
  41       'username' => $username,
  42       'domsvc'   => $svc_domain->svcnum,
  43     } );
  44     $cust_svc = $svc_acct->cust_svc
  45       if $svc_acct;
  46   #} else {
  47   #  warn "can't find domain $domain\n";
  48   }
  49
  50   my $svc_external = new FS::svc_external {
  51     'svcpart' => $svcpart,
  52     'pkgnum'  => ( $cust_svc ? $cust_svc->pkgnum : '' ),
  53     'id'      => $serial,
  54     'title'   => $keycode,
  55   };
  56   #my $error = $svc_external->check;
  57   my $error = $svc_external->insert;
  58   die $error if $error;
  59
  60   $num++;
  61   $linked++ if $cust_svc;
  62   #print "$num imported, $linked linked\n";
  63
  64 }
  65
  66 print "$num imported, $linked linked\n";
  67