FS/FS/ClientAPI/Signup.pm

   1 package FS::ClientAPI::Signup;
   2
   3 use strict;
   4 use Tie::RefHash;
   5 use FS::Conf;
   6 use FS::Record qw(qsearch qsearchs dbdef);
   7 use FS::Msgcat qw(gettext);
   8 use FS::Misc qw(card_types);
   9 use FS::ClientAPI_SessionCache;
  10 use FS::agent;
  11 use FS::cust_main_county;
  12 use FS::part_pkg;
  13 use FS::svc_acct_pop;
  14 use FS::cust_main;
  15 use FS::cust_pkg;
  16 use FS::svc_acct;
  17 use FS::acct_snarf;
  18 use FS::queue;
  19 use FS::reg_code;
  20
  21 sub signup_info {
  22   my $packet = shift;
  23
  24   my $conf = new FS::Conf;
  25
  26   use vars qw($signup_info_cache); #cache for performance;
  27   $signup_info_cache ||= {
  28     'cust_main_county' =>
  29       [ map { $_->hashref } qsearch('cust_main_county', {}) ],
  30
  31     'agent' =>
  32       [
  33         map { $_->hashref }
  34           qsearch('agent', { 'disabled' => '' } )
  35       ],
  36
  37     'part_referral' =>
  38       [
  39         map { $_->hashref }
  40           qsearch('part_referral', { 'disabled' => '' })
  41       ],
  42
  43     'agentnum2part_pkg' =>
  44       {
  45         map {
  46           my $href = $_->pkgpart_hashref;
  47           $_->agentnum =>
  48             [
  49               map { { 'payby'       => [ $_->payby ],
  50                       'freq_pretty' => $_->freq_pretty,
  51                       'options'     => { $_->options },
  52                       %{$_->hashref}
  53                   } }
  54                 grep { $_->svcpart('svc_acct') && $href->{ $_->pkgpart } }
  55                   qsearch( 'part_pkg', { 'disabled' => '' } )
  56             ];
  57         } qsearch('agent', { 'disabled' => '' })
  58       },
  59
  60     'svc_acct_pop' => [ map { $_->hashref } qsearch('svc_acct_pop',{} ) ],
  61
  62     'emailinvoiceonly' => $conf->exists('emailinvoiceonly'),
  63
  64     'security_phrase' => $conf->exists('security_phrase'),
  65
  66     'payby' => [ $conf->config('signup_server-payby') ],
  67
  68     'card_types' => card_types(),
  69
  70     'cvv_enabled' => defined dbdef->table('cust_main')->column('paycvv'), # 1,
  71
  72     'ship_enabled' => defined dbdef->table('cust_main')->column('ship_last'),#1,
  73
  74     'msgcat' => { map { $_=>gettext($_) } qw(
  75       passwords_dont_match invalid_card unknown_card_type not_a empty_password illegal_or_empty_text
  76     ) },
  77
  78     'statedefault' => $conf->config('statedefault') || 'CA',
  79
  80     'countrydefault' => $conf->config('countrydefault') || 'US',
  81
  82     'refnum' => $conf->config('signup_server-default_refnum'),
  83
  84     'default_pkgpart' => $conf->config('signup_server-default_pkgpart'),
  85
  86   };
  87
  88   my $signup_info = { %$signup_info_cache };
  89
  90   my @addl = qw( signup_server-classnum2 signup_server-classnum3 );
  91
  92   if ( grep { $conf->exists($_) } @addl ) {
  93
  94     $signup_info->{optional_packages} = [];
  95
  96     foreach my $addl ( @addl ) {
  97       my $classnum = $conf->config($addl) or next;
  98
  99       my @pkgs = map { {
 100                          'freq_pretty' => $_->freq_pretty,
 101                          'options'     => { $_->options },
 102                          %{ $_->hashref }
 103                        };
 104                      }
 105                      qsearch( 'part_pkg', { classnum => $classnum } );
 106
 107       push @{$signup_info->{optional_packages}}, \@pkgs;
 108
 109     }
 110
 111   }
 112
 113   my $agentnum = $packet->{'agentnum'}
 114                  || $conf->config('signup_server-default_agentnum');
 115   $agentnum =~ /^(\d*)$/ or die "illegal agentnum";
 116   $agentnum = $1;
 117
 118   my $session = '';
 119   if ( exists $packet->{'session_id'} ) {
 120     my $cache = new FS::ClientAPI_SessionCache( {
 121       'namespace' => 'FS::ClientAPI::Agent',
 122     } );
 123     $session = $cache->get($packet->{'session_id'});
 124     if ( $session ) {
 125       $agentnum = $session->{'agentnum'};
 126     } else {
 127       return { 'error' => "Can't resume session" }; #better error message
 128     }
 129   }elsif( exists $packet->{'customer_session_id'} ) {
 130     my $cache = new FS::ClientAPI_SessionCache( {
 131       'namespace' => 'FS::ClientAPI::MyAccount',
 132     } );
 133     $session = $cache->get($packet->{'customer_session_id'});
 134     if ( $session ) {
 135       my $custnum = $session->{'custnum'};
 136       my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum });
 137       return { 'error' => "Can't find your customer record" } unless $cust_main;
 138       $agentnum = $cust_main->agentnum;
 139     } else {
 140       return { 'error' => "Can't resume session" }; #better error message
 141     }
 142   }
 143
 144   $signup_info->{'part_pkg'} = [];
 145
 146   if ( $packet->{'reg_code'} ) {
 147     $signup_info->{'part_pkg'} =
 148       [ map { { 'payby'       => [ $_->payby ],
 149                 'freq_pretty' => $_->freq_pretty,
 150                 'options'     => { $_->options },
 151                 %{$_->hashref}
 152               };
 153             }
 154           grep { $_->svcpart('svc_acct') }
 155           map { $_->part_pkg }
 156             qsearchs( 'reg_code', { 'code'     => $packet->{'reg_code'},
 157                                     'agentnum' => $agentnum,              } )
 158
 159       ];
 160
 161     $signup_info->{'error'} = 'Unknown registration code'
 162       unless @{ $signup_info->{'part_pkg'} };
 163
 164   } elsif ( $packet->{'promo_code'} ) {
 165
 166     $signup_info->{'part_pkg'} =
 167       [ map { { 'payby'   => [ $_->payby ],
 168                 'freq_pretty' => $_->freq_pretty,
 169                 'options'     => { $_->options },
 170                 %{$_->hashref}
 171             } }
 172           grep { $_->svcpart('svc_acct') }
 173             qsearch( 'part_pkg', { 'promo_code' => {
 174                                      op=>'ILIKE',
 175                                      value=>$packet->{'promo_code'}
 176                                    },
 177                                    'disabled'   => '',                  } )
 178       ];
 179
 180     $signup_info->{'error'} = 'Unknown promotional code'
 181       unless @{ $signup_info->{'part_pkg'} };
 182   }
 183
 184   if ( $agentnum ) {
 185     $signup_info->{'part_pkg'} = $signup_info->{'agentnum2part_pkg'}{$agentnum}
 186       unless @{ $signup_info->{'part_pkg'} };
 187
 188     $signup_info->{'part_referral'} =
 189       [
 190         map { $_->hashref }
 191           qsearch( {
 192                      'table'     => 'part_referral',
 193                      'hashref'   => { 'disabled' => '' },
 194                      'extra_sql' => "AND (    agentnum = $agentnum  ".
 195                                     "      OR agentnum IS NULL    ) ",
 196                    },
 197                  )
 198       ];
 199
 200   }
 201   # else {
 202   # delete $signup_info->{'part_pkg'};
 203   #}
 204
 205   $signup_info->{'part_pkg'} = [ sort { $a->{pkg} cmp $b->{pkg} }  # case?
 206                                       @{ $signup_info->{'part_pkg'} }
 207                                ];
 208
 209   if ( exists $packet->{'session_id'} ) {
 210     my $agent_signup_info = { %$signup_info };
 211     delete $agent_signup_info->{agentnum2part_pkg};
 212     $agent_signup_info->{'agent'} = $session->{'agent'};
 213     $agent_signup_info;
 214   } else {
 215     $signup_info;
 216   }
 217
 218 }
 219
 220 sub new_customer {
 221   my $packet = shift;
 222
 223   my $conf = new FS::Conf;
 224
 225   #things that aren't necessary in base class, but are for signup server
 226     #return "Passwords don't match"
 227     #  if $hashref->{'_password'} ne $hashref->{'_password2'}
 228   return { 'error' => gettext('empty_password') }
 229     unless length($packet->{'_password'});
 230   # a bit inefficient for large numbers of pops
 231   return { 'error' => gettext('no_access_number_selected') }
 232     unless $packet->{'popnum'} || !scalar(qsearch('svc_acct_pop',{} ));
 233
 234   my $agentnum;
 235   if ( exists $packet->{'session_id'} ) {
 236     my $cache = new FS::ClientAPI_SessionCache( {
 237       'namespace' => 'FS::ClientAPI::Agent',
 238     } );
 239     my $session = $cache->get($packet->{'session_id'});
 240     if ( $session ) {
 241       $agentnum = $session->{'agentnum'};
 242     } else {
 243       return { 'error' => "Can't resume session" }; #better error message
 244     }
 245   } else {
 246     $agentnum = $packet->{agentnum}
 247                 || $conf->config('signup_server-default_agentnum');
 248   }
 249
 250   #shares some stuff with htdocs/edit/process/cust_main.cgi... take any
 251   # common that are still here and library them.
 252   my $cust_main = new FS::cust_main ( {
 253     #'custnum'          => '',
 254     'agentnum'      => $agentnum,
 255     'refnum'        => $packet->{refnum}
 256                        || $conf->config('signup_server-default_refnum'),
 257
 258     map { $_ => $packet->{$_} } qw(
 259
 260       last first ss company address1 address2
 261       city county state zip country
 262       daytime night fax
 263
 264       ship_last ship_first ship_ss ship_company ship_address1 ship_address2
 265       ship_city ship_county ship_state ship_zip ship_country
 266       ship_daytime ship_night ship_fax
 267
 268       payby
 269       payinfo paycvv paydate payname
 270       paystart_month paystart_year payissue
 271       payip
 272
 273       referral_custnum comments
 274     )
 275
 276   } );
 277
 278   return { 'error' => "Illegal payment type" }
 279     unless grep { $_ eq $packet->{'payby'} }
 280                 $conf->config('signup_server-payby');
 281
 282   $cust_main->payinfo($cust_main->daytime)
 283     if $cust_main->payby eq 'LECB' && ! $cust_main->payinfo;
 284
 285   my @invoicing_list = $packet->{'invoicing_list'}
 286                          ? split( /\s*\,\s*/, $packet->{'invoicing_list'} )
 287                          : ();
 288
 289   $packet->{'pkgpart'} =~ /^(\d+)$/ or '' =~ /^()$/;
 290   my $pkgpart = $1;
 291   return { 'error' => 'Please select a package' } unless $pkgpart; #msgcat
 292
 293   my $part_pkg =
 294     qsearchs( 'part_pkg', { 'pkgpart' => $pkgpart } )
 295       or return { 'error' => "WARNING: unknown pkgpart: $pkgpart" };
 296   my $svcpart = $part_pkg->svcpart('svc_acct');
 297
 298   my $reg_code = '';
 299   if ( $packet->{'reg_code'} ) {
 300     $reg_code = qsearchs( 'reg_code', { 'code'     => $packet->{'reg_code'},
 301                                         'agentnum' => $agentnum,             } )
 302       or return { 'error' => 'Unknown registration code' };
 303   }
 304
 305   my $cust_pkg = new FS::cust_pkg ( {
 306     #later#'custnum' => $custnum,
 307     'pkgpart'    => $packet->{'pkgpart'},
 308     'promo_code' => $packet->{'promo_code'},
 309     'reg_code'   => $packet->{'reg_code'},
 310   } );
 311   #my $error = $cust_pkg->check;
 312   #return { 'error' => $error } if $error;
 313
 314   my $svc_acct = new FS::svc_acct ( {
 315     'svcpart'   => $svcpart,
 316     map { $_ => $packet->{$_} }
 317       qw( username _password sec_phrase popnum ),
 318   } );
 319
 320   my @acct_snarf;
 321   my $snarfnum = 1;
 322   while (    exists($packet->{"snarf_machine$snarfnum"})
 323           && length($packet->{"snarf_machine$snarfnum"}) ) {
 324     my $acct_snarf = new FS::acct_snarf ( {
 325       'machine'   => $packet->{"snarf_machine$snarfnum"},
 326       'protocol'  => $packet->{"snarf_protocol$snarfnum"},
 327       'username'  => $packet->{"snarf_username$snarfnum"},
 328       '_password' => $packet->{"snarf_password$snarfnum"},
 329     } );
 330     $snarfnum++;
 331     push @acct_snarf, $acct_snarf;
 332   }
 333   $svc_acct->child_objects( \@acct_snarf );
 334
 335   my $y = $svc_acct->setdefault; # arguably should be in new method
 336   return { 'error' => $y } if $y && !ref($y);
 337
 338   #$error = $svc_acct->check;
 339   #return { 'error' => $error } if $error;
 340
 341   #setup a job dependancy to delay provisioning
 342   my $placeholder = new FS::queue ( {
 343     'job'    => 'FS::ClientAPI::Signup::__placeholder',
 344     'status' => 'locked',
 345   } );
 346   my $error = $placeholder->insert;
 347   return { 'error' => $error } if $error;
 348
 349   use Tie::RefHash;
 350   tie my %hash, 'Tie::RefHash';
 351   %hash = ( $cust_pkg => [ $svc_acct ] );
 352   #msgcat
 353   $error = $cust_main->insert(
 354     \%hash,
 355     \@invoicing_list,
 356     'depend_jobnum' => $placeholder->jobnum,
 357   );
 358   if ( $error ) {
 359     my $perror = $placeholder->delete;
 360     $error .= " (Additionally, error removing placeholder: $perror)" if $perror;
 361     return { 'error' => $error };
 362   }
 363
 364   if ( $conf->exists('signup_server-realtime') ) {
 365
 366     #warn "[fs_signup_server] Billing customer...\n" if $Debug;
 367
 368     my $bill_error = $cust_main->bill;
 369     #warn "[fs_signup_server] error billing new customer: $bill_error"
 370     #  if $bill_error;
 371
 372     $cust_main->apply_payments_and_credits;
 373
 374     $bill_error = $cust_main->collect('realtime' => 1);
 375     #warn "[fs_signup_server] error collecting from new customer: $bill_error"
 376     #  if $bill_error;
 377
 378     if ( $cust_main->balance > 0 ) {
 379
 380       #this makes sense.  credit is "un-doing" the invoice
 381       $cust_main->credit( $cust_main->balance, 'signup server decline' );
 382       $cust_main->apply_credits;
 383
 384       #should check list for errors...
 385       #$cust_main->suspend;
 386       local $FS::svc_Common::noexport_hack = 1;
 387       $cust_main->cancel('quiet'=>1);
 388
 389       my $perror = $placeholder->depended_delete;
 390       warn "error removing provisioning jobs after decline: $perror" if $perror;
 391       unless ( $perror ) {
 392         $perror = $placeholder->delete;
 393         warn "error removing placeholder after decline: $perror" if $perror;
 394       }
 395
 396       return { 'error' => '_decline' };
 397     }
 398
 399   }
 400
 401   if ( $reg_code ) {
 402     $error = $reg_code->delete;
 403     return { 'error' => $error } if $error;
 404   }
 405
 406   $error = $placeholder->delete;
 407   return { 'error' => $error } if $error;
 408
 409   return { error => '' };
 410
 411 }
 412
 413 1;