X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fpart_export%2Fikano.pm;h=68b1a9fded937462db91960c23e182d2fce71be7;hb=ffa18709ee8a4d05e18d2d406cf73afe79e52524;hp=ac1e5785aca8d6cae37917a014e597154f8271b3;hpb=57fecbd959fd5d72b20105161b7e3df94cbedd03;p=freeside.git diff --git a/FS/FS/part_export/ikano.pm b/FS/FS/part_export/ikano.pm index ac1e5785a..68b1a9fde 100644 --- a/FS/FS/part_export/ikano.pm +++ b/FS/FS/part_export/ikano.pm @@ -10,6 +10,7 @@ use FS::Record qw(qsearch qsearchs dbh); use FS::part_export; use FS::svc_dsl; use Data::Dumper; +use Carp qw(carp); @ISA = qw(FS::part_export); $me= '[' . __PACKAGE__ . ']'; @@ -24,12 +25,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 Net::Ikano from CPAN. @@ -42,6 +45,38 @@ sub rebless { shift; } sub external_pkg_map { 1; } +sub location_types { + ( + '' => '(None)', + 'APT' => 'Apartment', + 'BLDG' => 'Building', + 'FLR' => 'Floor', + '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) @@ -51,9 +86,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) { @@ -63,8 +108,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 @@ -115,8 +160,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) { @@ -207,7 +264,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 ) { @@ -216,7 +272,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"; @@ -225,7 +281,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"; @@ -258,21 +314,29 @@ sub ikano2fsnote { } ); } +# address always required for Ikano qual, TN optional (assume dry if not given) sub qual { my($self,$qual) = (shift,shift); -# address always required for Ikano qual, TN optional (assume dry if not given) + + 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 %location_hash = $qual->location; - return 'No address provided' unless %location_hash; 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", @@ -313,7 +377,7 @@ sub qual { }; } -sub qual_html { +sub qual_result { my($self,$qual) = (shift,shift); my %qual_options = $qual->options; @@ -325,41 +389,58 @@ sub qual_html { && $optionvalue ne '' ); } - # XXX: eventually perhaps this should return both the packages a link to - # order each package and go to the svc prov with the prequal id filled in - # but only if cust, not prospect! - my $list = "Qualifying Packages:"; - $list; + + my %not_avail = (); + foreach my $externalid ( grep !$found{$_}, @externalids ) { + $not_avail{$externalid} = $externalid; #a better label? + } + + { + 'pkglist' => \%pkglist, + 'not_avail' => \%not_avail, + }; } -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 = ' - '; - foreach my $note ( @notes ) { - $html .= " - - - - "; +sub quals_by_cust_and_pkg { + my($self, $custnum, $pkgpart) = (shift,shift,shift); + + die "invalid custnum or pkgpart" + unless ($custnum =~ /^\d+$/ && $pkgpart =~ /^\d+$/); + + my $part_pkg = qsearchs('part_pkg', { 'pkgpart' => $pkgpart } ); + die "no part_pkg found" unless $part_pkg; + my %vendor_pkg_ids = $part_pkg->vendor_pkg_ids; + my $external_id = $vendor_pkg_ids{$self->exportnum}; + die "no vendor package id defined on this package" unless $external_id; + + my $extra_sql = "where custnum = $custnum or locationnum in (select " + . "locationnum from cust_location where custnum = $custnum)"; + my @quals = qsearch( { 'table' => 'qual', 'extra_sql' => $extra_sql, } ); + + my @filtered_quals; + foreach my $qual ( @quals ) { + my %qual_options = $qual->options; + my( $optionname, $optionvalue ); + while (($optionname, $optionvalue) = each %qual_options) { + push @filtered_quals, $qual + if ( $optionname =~ /^ikano_Network_(\d+)_ProductGroup_(\d+)_Product_(\d+)_ProductCustomId$/ + && $optionvalue eq $external_id ); + } } - $html .= '
DateByPriorityNote
".time2str("$date_format %H:%M",$note->date)."".$note->by."". ($note->priority eq 'N' ? 'Normal' : 'High') ."".$note->note."
'; - $html; + + @filtered_quals; } sub loop_type_long { # sub, not a method @@ -396,15 +477,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}; @@ -416,7 +496,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 @@ -427,7 +507,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 @@ -465,11 +545,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; @@ -525,6 +613,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? @@ -548,6 +639,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 ''; @@ -586,7 +679,15 @@ sub _export_delete { sub export_expire { my($self, $svc_dsl, $date) = (shift, shift, shift); - + + if ( $FS::svc_Common::noexport_hack ) { + carp 'export_expire() suppressed by noexport_hack' + if $self->option('debug'); + return; + } + + return 'Invalid operation - Import Mode is enabled' if $self->import_mode; + my $result = $self->valid_order($svc_dsl,'expire'); return $result unless $result eq ''; @@ -650,6 +751,7 @@ sub export_expire { $svc_dsl->last_pull((time)+1); $svc_dsl->vendor_order_id($result->{'OrderId'}); $svc_dsl->vendor_order_status($result->{'Status'}); + $svc_dsl->monitored('Y'); local $FS::svc_Common::noexport_hack = 1; $result = $svc_dsl->replace; return "Error setting DSL fields: $result" if $result; @@ -663,6 +765,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 '';