export host selection per service, RT#17914
[freeside.git] / FS / FS / part_export / ikano.pm
index 63b0ed3..23917bf 100644 (file)
@@ -24,12 +24,14 @@ tie my %options, 'Tie::IxHash',
                    default => 'ATT,BELLCA',
                    },
   'debug' => { label => 'Debug Mode',  type => 'checkbox' },
+  'import' => { label => 'Import Mode',  type => 'checkbox' },
 ;
 
 %info = (
   'svc'     => 'svc_dsl',
   'desc'    => 'Provision DSL to Ikano',
   'options' => \%options,
+  'no_machine' => 1,
   'notes'   => <<'END'
 Requires installation of
 <a href="http://search.cpan.org/dist/Net-Ikano">Net::Ikano</a> from CPAN.
@@ -51,12 +53,29 @@ sub location_types {
     'LOT'  => 'Lot',
     'RM'   => 'Room',
     'SLIP' => 'Slip',
+    'SUIT' => 'Suite',
     'TRLR' => 'Trailer',
     'UNIT' => 'Unit',
     'WING' => 'Wing',
   );
 }
 
+sub location_types_parse {
+  my $class = shift;
+  my %t = $class->location_types;
+  delete $t{''};
+  (
+    (map { $_ => $_ } keys %t),
+    (reverse %t),
+    'STE' => 'SUIT', #USPS
+  );
+}
+
+sub import_mode {
+    my $self = shift;
+    $self->option('import');
+}
+
 sub dsl_pull {
 # we distinguish between invalid new data (return error) versus data that
 # has legitimately changed (may eventually execute hooks; now just update)
@@ -66,9 +85,19 @@ sub dsl_pull {
 # current assumptions of what won't change (from their side):
 # vendor_order_id, vendor_qual_id, vendor_order_type, pushed, monitored,
 # last_pull, address (from qual), contact info, ProductCustomId
-    my($self, $svc_dsl, $threshold) = (shift, shift, shift);
-    my $result = $self->valid_order($svc_dsl,'pull');
-    return $result unless $result eq '';
+    my($self, $svc_dsl, $threshold, $import) = (shift, shift, shift, shift);
+
+    return 'Invalid operation - Import Mode is enabled' 
+        if $self->import_mode && !$import;
+
+    return 'invalid arguments' if $import && !$self->import_mode;
+
+    warn "$me dsl_pull: import mode" if $self->option('debug');
+
+    unless ( $import ) { 
+        my $result = $self->valid_order($svc_dsl,'pull');
+        return $result unless $result eq '';
+    }
 
     my $now = time;
     if($now - $svc_dsl->last_pull < $threshold) {
@@ -78,8 +107,8 @@ sub dsl_pull {
        return '';
     }
   
-    $result = $self->ikano_command('ORDERSTATUS', 
-       { OrderId => $svc_dsl->vendor_order_id } ); 
+    my $result = $self->ikano_command('ORDERSTATUS', 
+                                   { OrderId => $svc_dsl->vendor_order_id } );
     return $result unless ref($result); # scalar (string) is an error
 
     # now we're getting an OrderResponse which should have one Order in it
@@ -130,8 +159,20 @@ sub dsl_pull {
     return 'Invalid number of products on order' if scalar(@product) != 1;
     my $product = $result->{'Product'}[0];
 
+    $svc_dsl->vendor_order_type('NEW') if $import; # lame
+
     # 3. phonenum 
-    if($svc_dsl->loop_type eq '') { # line-share
+    if ( $import ) {
+        if ( $product->{'PhoneNumber'} eq 'STANDALONE' ) {
+            $svc_dsl->phonenum($product->{'VirtualPhoneNumber'});
+            $svc_dsl->loop_type('0');
+        }
+        else {
+            $svc_dsl->phonenum($product->{'PhoneNumber'});
+            $svc_dsl->loop_type('');
+        }
+    }
+    elsif($svc_dsl->loop_type eq '') { # line-share
 # TN may change only if sub changes it and New or Change order in Completed status
        my $tn = $product->{'PhoneNumber'};
        if($tn ne $svc_dsl->phonenum) {
@@ -222,7 +263,6 @@ sub dsl_pull {
     my @onotes = $svc_dsl->notes;
     # assume notes we already have don't change & no notes added from our side
     # so using the horrible code below just find what we're missing and add it
-    my $error;
     foreach my $inote ( @inotes ) {
        my $found = 0;
        foreach my $onote ( @onotes ) {
@@ -231,7 +271,7 @@ sub dsl_pull {
                last;
            }
        }
-       $error = $inote->insert unless ( $found );
+       my $error = $inote->insert unless ( $found );
        if ( $error ) {
          $dbh->rollback if $oldAutoCommit;
          return "Cannot add note: $error";
@@ -240,7 +280,7 @@ sub dsl_pull {
     
     $svc_dsl->last_pull((time));
     local $FS::svc_Common::noexport_hack = 1;
-    $error = $svc_dsl->replace; 
+    my $error = $svc_dsl->replace; 
     if ( $error ) {
       $dbh->rollback if $oldAutoCommit;
       return "Cannot update DSL data: $error";
@@ -276,19 +316,26 @@ sub ikano2fsnote {
 # address always required for Ikano qual, TN optional (assume dry if not given)
 sub qual {
     my($self,$qual) = (shift,shift);
+    
+    return 'Invalid operation - Import Mode is enabled' if $self->import_mode;
 
     my %location_hash = $qual->location_hash; 
     return 'No address provided' unless keys %location_hash;
 
+    return 'Location kind is required' unless $location_hash{location_kind};
+
     my $svctn = $qual->phonenum;
 
+    my $zip = $location_hash{zip};
+    $zip =~ s/(\d{5})-\d{4}/$1/;
+
     my $result = $self->ikano_command('PREQUAL',
       { AddressLine1 => $location_hash{address1},
        AddressUnitType => $location_hash{location_type},
        AddressUnitValue => $location_hash{location_number},
        AddressCity => $location_hash{city},
        AddressState => $location_hash{state},
-       ZipCode => $location_hash{zip},
+       ZipCode => $zip,
        Country => $location_hash{country},
        LocationType => $location_hash{location_kind},
        PhoneNumber => length($svctn) > 1 ? $svctn : "STANDALONE",
@@ -342,21 +389,27 @@ sub qual_result {
     }
 
     my %pkglist = ();
-    my $result = { 'header' => 'Qualifying Packages',
-                  'pkglist' => \%pkglist,
-                };
-
+    my %found = ();
     my @part_pkgs = qsearch( 'part_pkg', { 'disabled' => '' } );
     foreach my $part_pkg ( @part_pkgs ) {
        my %vendor_pkg_ids = $part_pkg->vendor_pkg_ids;
        my $externalid = $vendor_pkg_ids{$self->exportnum} 
            if defined $vendor_pkg_ids{$self->exportnum};
-       if ( $externalid && grep( $_ eq $externalid, @externalids )) {
-           $pkglist{$part_pkg->pkgpart} = $part_pkg->pkg." - ".$part_pkg->comment;
+       if ( $externalid && grep { $_ eq $externalid } @externalids ) {
+           $pkglist{$part_pkg->pkgpart} = $part_pkg->pkg_comment;
+            $found{$externalid}++;
        }
     }
 
-    $result;
+    my %not_avail = ();
+    foreach my $externalid ( grep !$found{$_}, @externalids ) {
+      $not_avail{$externalid} = $externalid; #a better label?
+    }
+
+    { 
+      'pkglist'   => \%pkglist,
+      'not_avail' => \%not_avail,
+    };
 }
 
 sub quals_by_cust_and_pkg { 
@@ -389,24 +442,6 @@ sub quals_by_cust_and_pkg {
     @filtered_quals;
 }
 
-sub notes_html { 
-    my($self,$svc_dsl) = (shift,shift);
-    my $conf = new FS::Conf;
-    my $date_format = $conf->config('date_format') || '%m/%d/%Y';
-    my @notes = $svc_dsl->notes;
-    my $html = '<TABLE border="1" cellspacing="2" cellpadding="2" id="dsl_notes">
-       <TR><TH>Date</TH><TH>By</TH><TH>Priority</TH><TH>Note</TH></TR>';
-    foreach my $note ( @notes ) {
-       $html .= "<TR>
-           <TD>".time2str("$date_format %H:%M",$note->date)."</TD>
-           <TD>".$note->by."</TD>
-           <TD>". ($note->priority eq 'N' ? 'Normal' : 'High') ."</TD>
-           <TD>".$note->note."</TD></TR>";
-    }
-    $html .= '</TABLE>';
-    $html;
-}
-
 sub loop_type_long { # sub, not a method
     my($svc_dsl) = (shift);
     return $loopType{$svc_dsl->loop_type};
@@ -441,15 +476,14 @@ sub valid_order {
        if $self->option('debug');
 
   # common to all order types/status/loop_type
-  my $error = !($svc_dsl->desired_due_date
-           &&  grep($_ eq $svc_dsl->vendor_order_type, Net::Ikano->orderTypes)
-           &&  $svc_dsl->first
-           &&  $svc_dsl->last
-           &&  defined $svc_dsl->loop_type
-           &&  $svc_dsl->vendor_qual_id
-           );
-  return 'Missing or invalid order data' if $error;
+  return 'No desired_due_date' unless $svc_dsl->desired_due_date; 
+  return 'Unknown vendor_order_type'
+    unless grep $_ eq $svc_dsl->vendor_order_type, Net::Ikano->orderTypes;
+  return 'No first name' unless $svc_dsl->first;
+  return 'No last name' unless $svc_dsl->get('last');
+  return 'No loop type' unless defined $svc_dsl->loop_type;
+  return 'No vendor_qual_id' unless $svc_dsl->vendor_qual_id;
+
   my %vendor_pkg_ids = $svc_dsl->cust_svc->cust_pkg->part_pkg->vendor_pkg_ids;
   return 'Package does not have an external id configured'
     unless defined $vendor_pkg_ids{$self->exportnum};
@@ -461,7 +495,7 @@ sub valid_order {
   # weird ifs & long lines for readability and ease of understanding - don't change
   if($svc_dsl->vendor_order_type eq 'NEW') {
     if($svc_dsl->pushed) {
-       $error = !( ($action eq 'pull' || $action eq 'statuschg' 
+       my $error = !( ($action eq 'pull' || $action eq 'statuschg' 
                        || $action eq 'delete' || $action eq 'expire')
            &&  length($svc_dsl->vendor_order_id) > 0
            &&  length($svc_dsl->vendor_order_status) > 0
@@ -472,7 +506,7 @@ sub valid_order {
            if ($action eq 'statuschg' && length($svc_dsl->phonenum) < 1);
     }
     else { # unpushed New order - cannot do anything other than push it
-       $error = !($action eq 'insert'
+       my $error = !($action eq 'insert'
            &&  length($svc_dsl->vendor_order_id) < 1
            &&  length($svc_dsl->vendor_order_status) < 1
            && ( ($svc_dsl->phonenum eq '' && $svc_dsl->loop_type eq '0') # dry
@@ -510,11 +544,19 @@ sub qual2termsid {
 sub _export_insert {
   my( $self, $svc_dsl ) = (shift, shift);
 
+  if($self->import_mode) {
+      warn "$me _export_insert: import mode" if $self->option('debug');
+      $svc_dsl->pushed((time)-2);
+      $svc_dsl->last_pull((time)-1); 
+      return $self->dsl_pull($svc_dsl,0,1);
+  }
+
   my $result = $self->valid_order($svc_dsl,'insert');
   return $result unless $result eq '';
 
   my $isp_chg = $svc_dsl->isp_chg eq 'Y' ? 'YES' : 'NO';
-  my $contactTN = $svc_dsl->cust_svc->cust_pkg->cust_main->daytime;
+  my $cust_main = $svc_dsl->cust_svc->cust_pkg->cust_main;
+  my $contactTN = $cust_main->daytime || $cust_main->night || '5555555555';
   $contactTN =~ s/[^0-9]//g;
 
   my %vendor_pkg_ids = $svc_dsl->cust_svc->cust_pkg->part_pkg->vendor_pkg_ids;
@@ -570,6 +612,9 @@ sub _export_insert {
 
 sub _export_replace {
   my( $self, $new, $old ) = (shift, shift, shift);
+    
+  return 'Invalid operation - Import Mode is enabled' if $self->import_mode;
+
 # XXX only supports password changes now, but should return error if 
 # another change is attempted?
 
@@ -593,6 +638,8 @@ sub _export_replace {
 sub _export_delete {
   my( $self, $svc_dsl ) = (shift, shift);
   
+  return 'Invalid operation - Import Mode is enabled' if $self->import_mode;
+
   my $result = $self->valid_order($svc_dsl,'delete');
   return $result unless $result eq '';
 
@@ -632,6 +679,8 @@ sub _export_delete {
 sub export_expire {
   my($self, $svc_dsl, $date) = (shift, shift, shift);
   
+  return 'Invalid operation - Import Mode is enabled' if $self->import_mode;
+
   my $result = $self->valid_order($svc_dsl,'expire');
   return $result unless $result eq '';
   
@@ -709,6 +758,8 @@ sub export_expire {
 
 sub statuschg {
   my( $self, $svc_dsl, $type ) = (shift, shift, shift);
+  
+  return 'Invalid operation - Import Mode is enabled' if $self->import_mode;
 
   my $result = $self->valid_order($svc_dsl,'statuschg');
   return $result unless $result eq '';