FS/FS/ClientAPI/MyAccount.pm

   1 package FS::ClientAPI::MyAccount;
   2
   3 use strict;
   4 use vars qw($cache);
   5 use subs qw(_cache);
   6 use Digest::MD5 qw(md5_hex);
   7 use Date::Format;
   8 use Business::CreditCard;
   9 use Time::Duration;
  10 use FS::CGI qw(small_custview); #doh
  11 use FS::UI::Web;
  12 use FS::UI::bytecount;
  13 use FS::Conf;
  14 use FS::Record qw(qsearch qsearchs);
  15 use FS::Msgcat qw(gettext);
  16 use FS::Misc qw(card_types);
  17 use FS::ClientAPI_SessionCache;
  18 use FS::svc_acct;
  19 use FS::svc_domain;
  20 use FS::svc_external;
  21 use FS::part_svc;
  22 use FS::cust_main;
  23 use FS::cust_bill;
  24 use FS::cust_main_county;
  25 use FS::cust_pkg;
  26 use FS::payby;
  27 use FS::acct_rt_transaction;
  28 use HTML::Entities;
  29
  30 #false laziness with FS::cust_main
  31 BEGIN {
  32   eval "use Time::Local;";
  33   die "Time::Local minimum version 1.05 required with Perl versions before 5.6"
  34     if $] < 5.006 && !defined($Time::Local::VERSION);
  35   eval "use Time::Local qw(timelocal_nocheck);";
  36 }
  37
  38 use vars qw( @cust_main_editable_fields );
  39 @cust_main_editable_fields = qw(
  40   first last company address1 address2 city
  41     county state zip country daytime night fax
  42   ship_first ship_last ship_company ship_address1 ship_address2 ship_city
  43     ship_state ship_zip ship_country ship_daytime ship_night ship_fax
  44   payby payinfo payname paystart_month paystart_year payissue payip
  45 );
  46
  47 use subs qw(_provision);
  48
  49 sub _cache {
  50   $cache ||= new FS::ClientAPI_SessionCache( {
  51                'namespace' => 'FS::ClientAPI::MyAccount',
  52              } );
  53 }
  54
  55 #false laziness w/FS::ClientAPI::passwd::passwd
  56 sub login {
  57   my $p = shift;
  58
  59   my $svc_domain = qsearchs('svc_domain', { 'domain' => $p->{'domain'} } )
  60     or return { error => 'Domain '. $p->{'domain'}. ' not found' };
  61
  62   my $svc_acct = qsearchs( 'svc_acct', { 'username'  => $p->{'username'},
  63                                          'domsvc'    => $svc_domain->svcnum, }
  64                          );
  65   return { error => 'User not found.' } unless $svc_acct;
  66
  67   my $conf = new FS::Conf;
  68   my $pkg_svc = $svc_acct->cust_svc->pkg_svc;
  69   return { error => 'Only primary user may log in.' }
  70     if $conf->exists('selfservice_server-primary_only')
  71        && ( ! $pkg_svc || $pkg_svc->primary_svc ne 'Y' );
  72
  73   return { error => 'Incorrect password.' }
  74     unless $svc_acct->check_password($p->{'password'});
  75
  76   my $session = {
  77     'svcnum' => $svc_acct->svcnum,
  78   };
  79
  80   my $cust_pkg = $svc_acct->cust_svc->cust_pkg;
  81   if ( $cust_pkg ) {
  82     my $cust_main = $cust_pkg->cust_main;
  83     $session->{'custnum'} = $cust_main->custnum;
  84   }
  85
  86   my $session_id;
  87   do {
  88     $session_id = md5_hex(md5_hex(time(). {}. rand(). $$))
  89   } until ( ! defined _cache->get($session_id) ); #just in case
  90
  91   _cache->set( $session_id, $session, '1 hour' );
  92
  93   return { 'error'      => '',
  94            'session_id' => $session_id,
  95          };
  96 }
  97
  98 sub logout {
  99   my $p = shift;
 100   if ( $p->{'session_id'} ) {
 101     _cache->remove($p->{'session_id'});
 102     return { 'error' => '' };
 103   } else {
 104     return { 'error' => "Can't resume session" }; #better error message
 105   }
 106 }
 107
 108 sub customer_info {
 109   my $p = shift;
 110
 111   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 112   return { 'error' => $session } if $context eq 'error';
 113
 114   my %return;
 115   if ( $custnum ) { #customer record
 116
 117     my $search = { 'custnum' => $custnum };
 118     $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 119     my $cust_main = qsearchs('cust_main', $search )
 120       or return { 'error' => "unknown custnum $custnum" };
 121
 122     $return{balance} = $cust_main->balance;
 123
 124     $return{tickets} = [ ($cust_main->tickets) ];
 125
 126     my @open = map {
 127                      {
 128                        invnum => $_->invnum,
 129                        date   => time2str("%b %o, %Y", $_->_date),
 130                        owed   => $_->owed,
 131                      };
 132                    } $cust_main->open_cust_bill;
 133     $return{open_invoices} = \@open;
 134
 135     my $conf = new FS::Conf;
 136     $return{small_custview} =
 137       small_custview( $cust_main, $conf->config('countrydefault') );
 138
 139     $return{name} = $cust_main->first. ' '. $cust_main->get('last');
 140
 141     for (@cust_main_editable_fields) {
 142       $return{$_} = $cust_main->get($_);
 143     }
 144
 145     if ( $cust_main->payby =~ /^(CARD|DCRD)$/ ) {
 146       $return{payinfo} = $cust_main->paymask;
 147       @return{'month', 'year'} = $cust_main->paydate_monthyear;
 148     }
 149
 150     $return{'invoicing_list'} =
 151       join(', ', grep { $_ !~ /^(POST|FAX)$/ } $cust_main->invoicing_list );
 152     $return{'postal_invoicing'} =
 153       0 < ( grep { $_ eq 'POST' } $cust_main->invoicing_list );
 154
 155     if (scalar($conf->config('support_packages'))) {
 156       my @support_services = ();
 157       foreach ($cust_main->support_services) {
 158         my $seconds = $_->svc_x->seconds;
 159         my $time_remaining = (($seconds < 0) ? '-' : '' ).
 160                              int(abs($seconds)/3600)."h".
 161                              sprintf("%02d",(abs($seconds)%3600)/60)."m";
 162         my $cust_pkg = $_->cust_pkg;
 163         my $pkgnum = '';
 164         my $pkg = '';
 165         $pkgnum = $cust_pkg->pkgnum if $cust_pkg;
 166         $pkg = $cust_pkg->part_pkg->pkg if $cust_pkg;
 167         push @support_services, { svcnum => $_->svcnum,
 168                                   time => $time_remaining,
 169                                   pkgnum => $pkgnum,
 170                                   pkg => $pkg,
 171                                 };
 172       }
 173       $return{support_services} = \@support_services;
 174     }
 175
 176   } elsif ( $session->{'svcnum'} ) { #no customer record
 177
 178     my $svc_acct = qsearchs('svc_acct', { 'svcnum' => $session->{'svcnum'} } )
 179       or die "unknown svcnum";
 180     $return{name} = $svc_acct->email;
 181
 182   } else {
 183
 184     return { 'error' => 'Expired session' }; #XXX redirect to login w/this err!
 185
 186   }
 187
 188   return { 'error'          => '',
 189            'custnum'        => $custnum,
 190            %return,
 191          };
 192
 193 }
 194
 195 sub edit_info {
 196   my $p = shift;
 197   my $session = _cache->get($p->{'session_id'})
 198     or return { 'error' => "Can't resume session" }; #better error message
 199
 200   my $custnum = $session->{'custnum'}
 201     or return { 'error' => "no customer record" };
 202
 203   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 204     or return { 'error' => "unknown custnum $custnum" };
 205
 206   my $new = new FS::cust_main { $cust_main->hash };
 207   $new->set( $_ => $p->{$_} )
 208     foreach grep { exists $p->{$_} } @cust_main_editable_fields;
 209
 210   if ( $p->{'payby'} =~ /^(CARD|DCRD)$/ ) {
 211     $new->paydate($p->{'year'}. '-'. $p->{'month'}. '-01');
 212     if ( $new->payinfo eq $cust_main->paymask ) {
 213       $new->payinfo($cust_main->payinfo);
 214     } else {
 215       $new->paycvv($p->{'paycvv'});
 216     }
 217   }
 218
 219   my @invoicing_list;
 220   if ( exists $p->{'invoicing_list'} || exists $p->{'postal_invoicing'} ) {
 221     #false laziness with httemplate/edit/process/cust_main.cgi
 222     @invoicing_list = split( /\s*\,\s*/, $p->{'invoicing_list'} );
 223     push @invoicing_list, 'POST' if $p->{'postal_invoicing'};
 224   } else {
 225     @invoicing_list = $cust_main->invoicing_list;
 226   }
 227
 228   my $error = $new->replace($cust_main, \@invoicing_list);
 229   return { 'error' => $error } if $error;
 230   #$cust_main = $new;
 231
 232   return { 'error' => '' };
 233 }
 234
 235 sub payment_info {
 236   my $p = shift;
 237   my $session = _cache->get($p->{'session_id'})
 238     or return { 'error' => "Can't resume session" }; #better error message
 239
 240   ##
 241   #generic
 242   ##
 243
 244   use vars qw($payment_info); #cache for performance
 245   unless ( $payment_info ) {
 246
 247     my $conf = new FS::Conf;
 248     my %states = map { $_->state => 1 }
 249                    qsearch('cust_main_county', {
 250                      'country' => $conf->config('countrydefault') || 'US'
 251                    } );
 252
 253     $payment_info = {
 254
 255       #list all counties/states/countries
 256       'cust_main_county' =>
 257         [ map { $_->hashref } qsearch('cust_main_county', {}) ],
 258
 259       #shortcut for one-country folks
 260       'states' =>
 261         [ sort { $a cmp $b } keys %states ],
 262
 263       'card_types' => card_types(),
 264
 265       'paytypes' => [ @FS::cust_main::paytypes ],
 266
 267       'stateid_label' => FS::Msgcat::_gettext('stateid'),
 268       'stateid_state_label' => FS::Msgcat::_gettext('stateid_state'),
 269
 270       'show_ss'  => $conf->exists('show_ss'),
 271       'show_stateid' => $conf->exists('show_stateid'),
 272       'show_paystate' => $conf->exists('show_bankstate'),
 273     };
 274
 275   }
 276
 277   ##
 278   #customer-specific
 279   ##
 280
 281   my %return = %$payment_info;
 282
 283   my $custnum = $session->{'custnum'};
 284
 285   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 286     or return { 'error' => "unknown custnum $custnum" };
 287
 288   $return{balance} = $cust_main->balance;
 289
 290   $return{payname} = $cust_main->payname
 291                      || ( $cust_main->first. ' '. $cust_main->get('last') );
 292
 293   $return{$_} = $cust_main->get($_) for qw(address1 address2 city state zip);
 294
 295   $return{payby} = $cust_main->payby;
 296   $return{stateid_state} = $cust_main->stateid_state;
 297
 298   if ( $cust_main->payby =~ /^(CARD|DCRD)$/ ) {
 299     $return{card_type} = cardtype($cust_main->payinfo);
 300     $return{payinfo} = $cust_main->paymask;
 301
 302     @return{'month', 'year'} = $cust_main->paydate_monthyear;
 303
 304   }
 305
 306   if ( $cust_main->payby =~ /^(CHEK|DCHK)$/ ) {
 307     my ($payinfo1, $payinfo2) = split '@', $cust_main->paymask;
 308     $return{payinfo1} = $payinfo1;
 309     $return{payinfo2} = $payinfo2;
 310     $return{paytype}  = $cust_main->paytype;
 311     $return{paystate} = $cust_main->paystate;
 312
 313   }
 314
 315   #doubleclick protection
 316   my $_date = time;
 317   $return{paybatch} = "webui-MyAccount-$_date-$$-". rand() * 2**32;
 318
 319   return { 'error' => '',
 320            %return,
 321          };
 322
 323 };
 324
 325 #some false laziness with httemplate/process/payment.cgi - look there for
 326 #ACH and CVV support stuff
 327 sub process_payment {
 328
 329   my $p = shift;
 330
 331   my $session = _cache->get($p->{'session_id'})
 332     or return { 'error' => "Can't resume session" }; #better error message
 333
 334   my %return;
 335
 336   my $custnum = $session->{'custnum'};
 337
 338   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 339     or return { 'error' => "unknown custnum $custnum" };
 340
 341   $p->{'payname'} =~ /^([\w \,\.\-\']+)$/
 342     or return { 'error' => gettext('illegal_name'). " payname: ". $p->{'payname'} };
 343   my $payname = $1;
 344
 345   $p->{'paybatch'} =~ /^([\w \!\@\#\$\%\&\(\)\-\+\;\:\'\"\,\.\?\/\=]*)$/
 346     or return { 'error' => gettext('illegal_text'). " paybatch: ". $p->{'paybatch'} };
 347   my $paybatch = $1;
 348
 349   $p->{'payby'} =~ /^([A-Z]{4})$/
 350     or return { 'error' => "illegal_payby " . $p->{'payby'} };
 351   my $payby = $1;
 352
 353   my $payinfo;
 354   my $paycvv = '';
 355   if ( $payby eq 'CHEK' || $payby eq 'DCHK' ) {
 356
 357     $p->{'payinfo1'} =~ /^([\dx]+)$/
 358       or return { 'error' => "illegal account number ". $p->{'payinfo1'} };
 359     my $payinfo1 = $1;
 360      $p->{'payinfo2'} =~ /^([\dx]+)$/
 361       or return { 'error' => "illegal ABA/routing number ". $p->{'payinfo2'} };
 362     my $payinfo2 = $1;
 363     $payinfo = $payinfo1. '@'. $payinfo2;
 364
 365     $payinfo = $cust_main->payinfo
 366       if $cust_main->paymask eq $payinfo;
 367
 368   } elsif ( $payby eq 'CARD' || $payby eq 'DCRD' ) {
 369
 370     $payinfo = $p->{'payinfo'};
 371     $payinfo =~ s/[^\dx]//g;
 372     $payinfo =~ /^(\d{13,16})$/
 373       or return { 'error' => gettext('invalid_card') }; # . ": ". $self->payinfo
 374     $payinfo = $1;
 375
 376     $payinfo = $cust_main->payinfo
 377       if $cust_main->paymask eq $payinfo;
 378
 379     validate($payinfo)
 380       or return { 'error' => gettext('invalid_card') }; # . ": ". $self->payinfo
 381     return { 'error' => gettext('unknown_card_type') }
 382       if cardtype($payinfo) eq "Unknown";
 383
 384     if ( length($p->{'paycvv'}) && $p->{'paycvv'} !~ /^\s*$/ ) {
 385       if ( cardtype($payinfo) eq 'American Express card' ) {
 386         $p->{'paycvv'} =~ /^\s*(\d{4})\s*$/
 387           or return { 'error' => "CVV2 (CID) for American Express cards is four digits." };
 388         $paycvv = $1;
 389       } else {
 390         $p->{'paycvv'} =~ /^\s*(\d{3})\s*$/
 391           or return { 'error' => "CVV2 (CVC2/CID) is three digits." };
 392         $paycvv = $1;
 393       }
 394     }
 395
 396   } else {
 397     die "unknown payby $payby";
 398   }
 399
 400   my %payby2fields = (
 401     'CARD' => [ qw( paystart_month paystart_year payissue address1 address2 city state zip payip ) ],
 402     'CHEK' => [ qw( ss paytype paystate stateid stateid_state payip ) ],
 403   );
 404
 405   my $error = $cust_main->realtime_bop( $FS::payby::payby2bop{$payby}, $p->{'amount'},
 406     'quiet'    => 1,
 407     'payinfo'  => $payinfo,
 408     'paydate'  => $p->{'year'}. '-'. $p->{'month'}. '-01',
 409     'payname'  => $payname,
 410     'paybatch' => $paybatch,
 411     'paycvv'   => $paycvv,
 412     map { $_ => $p->{$_} } @{ $payby2fields{$payby} }
 413   );
 414   return { 'error' => $error } if $error;
 415
 416   $cust_main->apply_payments;
 417
 418   if ( $p->{'save'} ) {
 419     my $new = new FS::cust_main { $cust_main->hash };
 420     if ($payby eq 'CARD' || $payby eq 'DCRD') {
 421       $new->set( $_ => $p->{$_} )
 422         foreach qw( payname paystart_month paystart_year payissue payip
 423                     address1 address2 city state zip payinfo );
 424       $new->set( 'payby' => $p->{'auto'} ? 'CARD' : 'DCRD' );
 425     } elsif ($payby eq 'CHEK' || $payby eq 'DCHK') {
 426       $new->set( $_ => $p->{$_} )
 427         foreach qw( payname payip paytype paystate
 428                     stateid stateid_state );
 429       $new->set( 'payinfo' => $payinfo );
 430       $new->set( 'payby' => $p->{'auto'} ? 'CHEK' : 'DCHK' );
 431     }
 432     $new->set( 'paydate' => $p->{'year'}. '-'. $p->{'month'}. '-01' );
 433     my $error = $new->replace($cust_main);
 434     return { 'error' => $error } if $error;
 435     $cust_main = $new;
 436   }
 437
 438   return { 'error' => '' };
 439
 440 }
 441
 442 sub process_payment_order_pkg {
 443   my $p = shift;
 444
 445   my $hr = process_payment($p);
 446   return $hr if $hr->{'error'};
 447
 448   order_pkg($p);
 449 }
 450
 451 sub process_prepay {
 452
 453   my $p = shift;
 454
 455   my $session = _cache->get($p->{'session_id'})
 456     or return { 'error' => "Can't resume session" }; #better error message
 457
 458   my %return;
 459
 460   my $custnum = $session->{'custnum'};
 461
 462   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 463     or return { 'error' => "unknown custnum $custnum" };
 464
 465   my( $amount, $seconds, $upbytes, $downbytes, $totalbytes ) = ( 0, 0, 0, 0, 0 );
 466   my $error = $cust_main->recharge_prepay( $p->{'prepaid_cardnum'},
 467                                            \$amount,
 468                                            \$seconds,
 469                                            \$upbytes,
 470                                            \$downbytes,
 471                                            \$totalbytes,
 472                                          );
 473
 474   return { 'error' => $error } if $error;
 475
 476   return { 'error'     => '',
 477            'amount'    => $amount,
 478            'seconds'   => $seconds,
 479            'duration'  => duration_exact($seconds),
 480            'upbytes'   => $upbytes,
 481            'upload'    => FS::UI::bytecount::bytecount_unexact($upbytes),
 482            'downbytes' => $downbytes,
 483            'download'  => FS::UI::bytecount::bytecount_unexact($downbytes),
 484            'totalbytes'=> $totalbytes,
 485            'totalload' => FS::UI::bytecount::bytecount_unexact($totalbytes),
 486          };
 487
 488 }
 489
 490 sub invoice {
 491   my $p = shift;
 492   my $session = _cache->get($p->{'session_id'})
 493     or return { 'error' => "Can't resume session" }; #better error message
 494
 495   my $custnum = $session->{'custnum'};
 496
 497   my $invnum = $p->{'invnum'};
 498
 499   my $cust_bill = qsearchs('cust_bill', { 'invnum'  => $invnum,
 500                                           'custnum' => $custnum } )
 501     or return { 'error' => "Can't find invnum" };
 502
 503   #my %return;
 504
 505   return { 'error'        => '',
 506            'invnum'       => $invnum,
 507            'invoice_text' => join('', $cust_bill->print_text ),
 508            'invoice_html' => $cust_bill->print_html,
 509          };
 510
 511 }
 512
 513 sub invoice_logo {
 514   my $p = shift;
 515
 516   #sessioning for this?  how do we get the session id to the backend invoice
 517   # template so it can add it to the link, blah
 518
 519   my $templatename = $p->{'templatename'};
 520
 521   #false laziness-ish w/view/cust_bill-logo.cgi
 522
 523   my $conf = new FS::Conf;
 524   if ( $templatename =~ /^([^\.\/]*)$/ && $conf->exists("logo_$1.png") ) {
 525     $templatename = "_$1";
 526   } else {
 527     $templatename = '';
 528   }
 529
 530   my $filename = "logo$templatename.png";
 531
 532   return { 'error'        => '',
 533            'logo'         => $conf->config_binary($filename),
 534            'content_type' => 'image/png', #should allow gif, jpg too
 535          };
 536 }
 537
 538
 539 sub list_invoices {
 540   my $p = shift;
 541   my $session = _cache->get($p->{'session_id'})
 542     or return { 'error' => "Can't resume session" }; #better error message
 543
 544   my $custnum = $session->{'custnum'};
 545
 546   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 547     or return { 'error' => "unknown custnum $custnum" };
 548
 549   my @cust_bill = $cust_main->cust_bill;
 550
 551   return  { 'error'       => '',
 552             'invoices'    =>  [ map { { 'invnum' => $_->invnum,
 553                                         '_date'  => $_->_date,
 554                                       }
 555                                     } @cust_bill
 556                               ]
 557           };
 558 }
 559
 560 sub cancel {
 561   my $p = shift;
 562   my $session = _cache->get($p->{'session_id'})
 563     or return { 'error' => "Can't resume session" }; #better error message
 564
 565   my $custnum = $session->{'custnum'};
 566
 567   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
 568     or return { 'error' => "unknown custnum $custnum" };
 569
 570   my @errors = $cust_main->cancel( 'quiet'=>1 );
 571
 572   my $error = scalar(@errors) ? join(' / ', @errors) : '';
 573
 574   return { 'error' => $error };
 575
 576 }
 577
 578 sub list_pkgs {
 579   my $p = shift;
 580
 581   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 582   return { 'error' => $session } if $context eq 'error';
 583
 584   my $search = { 'custnum' => $custnum };
 585   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 586   my $cust_main = qsearchs('cust_main', $search )
 587     or return { 'error' => "unknown custnum $custnum" };
 588
 589   #return { 'cust_pkg' => [ map { $_->hashref } $cust_main->ncancelled_pkgs ] };
 590
 591   my $conf = new FS::Conf;
 592
 593   { 'svcnum'   => $session->{'svcnum'},
 594     'custnum'  => $custnum,
 595     'cust_pkg' => [ map {
 596                           { $_->hash,
 597                             $_->part_pkg->hash,
 598                             part_svc =>
 599                               [ map $_->hashref, $_->available_part_svc ],
 600                             cust_svc =>
 601                               [ map { my $ref = { $_->hash,
 602                                                   label => [ $_->label ],
 603                                                 };
 604                                       $ref->{_password} = $_->svc_x->_password
 605                                         if $context eq 'agent'
 606                                         && $conf->exists('agent-showpasswords')
 607                                         && $_->part_svc->svcdb eq 'svc_acct';
 608                                       $ref;
 609                                     } $_->cust_svc
 610                               ],
 611                           };
 612                         } $cust_main->ncancelled_pkgs
 613                   ],
 614     'small_custview' =>
 615       small_custview( $cust_main, $conf->config('countrydefault') ),
 616   };
 617
 618 }
 619
 620 sub list_svcs {
 621   my $p = shift;
 622
 623   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 624   return { 'error' => $session } if $context eq 'error';
 625
 626   my $search = { 'custnum' => $custnum };
 627   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 628   my $cust_main = qsearchs('cust_main', $search )
 629     or return { 'error' => "unknown custnum $custnum" };
 630
 631   my @cust_svc = ();
 632   #foreach my $cust_pkg ( $cust_main->ncancelled_pkgs ) {
 633   foreach my $cust_pkg ( $p->{'ncancelled'}
 634                          ? $cust_main->ncancelled_pkgs
 635                          : $cust_main->unsuspended_pkgs ) {
 636     push @cust_svc, @{[ $cust_pkg->cust_svc ]}; #@{[ ]} to force array context
 637   }
 638   @cust_svc = grep { $_->part_svc->svcdb eq $p->{'svcdb'} } @cust_svc
 639     if $p->{'svcdb'};
 640
 641   #@svc_x = sort { $a->domain cmp $b->domain || $a->username cmp $b->username }
 642   #              @svc_x;
 643
 644   {
 645     #no#'svcnum'   => $session->{'svcnum'},
 646     'custnum'  => $custnum,
 647     'svcs'     => [ map {
 648                           my $svc_x = $_->svc_x;
 649                           my($label, $value) = $_->label;
 650                           my $part_pkg = $svc_x->cust_svc->cust_pkg->part_pkg;
 651
 652                           { 'svcnum'    => $_->svcnum,
 653                             'label'     => $label,
 654                             'value'     => $value,
 655                             'username'  => $svc_x->username,
 656                             'email'     => $svc_x->email,
 657                             'seconds'   => $svc_x->seconds,
 658                             'upbytes'   => FS::UI::bytecount::display_bytecount($svc_x->upbytes),
 659                             'downbytes' => FS::UI::bytecount::display_bytecount($svc_x->downbytes),
 660                             'totalbytes'=> FS::UI::bytecount::display_bytecount($svc_x->totalbytes),
 661                             'recharge_amount' => $part_pkg->option('recharge_amount', 1),
 662                             'recharge_seconds' => $part_pkg->option('recharge_seconds', 1),
 663                             'recharge_upbytes' => FS::UI::bytecount::display_bytecount($part_pkg->option('recharge_upbytes', 1)),
 664                             'recharge_downbytes' => FS::UI::bytecount::display_bytecount($part_pkg->option('recharge_downbytes', 1)),
 665                             'recharge_totalbytes' => FS::UI::bytecount::display_bytecount($part_pkg->option('recharge_totalbytes', 1)),
 666                             # more...
 667                           };
 668                         }
 669                         @cust_svc
 670                   ],
 671   };
 672
 673 }
 674
 675 sub _list_svc_usage {
 676   my($svc_acct, $begin, $end) = @_;
 677   my @usage = ();
 678   foreach my $part_export (
 679     map { qsearch ( 'part_export', { 'exporttype' => $_ } ) }
 680     qw (sqlradius sqlradius_withdomain')
 681   ) {
 682
 683     push @usage, @ { $part_export->usage_sessions($begin, $end, $svc_acct) };
 684   }
 685   (@usage);
 686 }
 687
 688 sub list_svc_usage {
 689   _usage_details(\&_list_svc_usage, @_);
 690 }
 691
 692 sub _list_support_usage {
 693   my($svc_acct, $begin, $end) = @_;
 694   my @usage = ();
 695   foreach ( grep { $begin <= $_->_date && $_->_date <= $end }
 696             qsearch('acct_rt_transaction', { 'svcnum' => $svc_acct->svcnum })
 697           ) {
 698     push @usage, { 'seconds'  => $_->seconds,
 699                    'support'  => $_->support,
 700                    '_date'    => $_->_date,
 701                    'id'       => $_->transaction_id,
 702                    'creator'  => $_->creator,
 703                    'subject'  => $_->subject,
 704                    'status'   => $_->status,
 705                    'ticketid' => $_->ticketid,
 706                  };
 707   }
 708   (@usage);
 709 }
 710
 711 sub list_support_usage {
 712   _usage_details(\&_list_support_usage, @_);
 713 }
 714
 715 sub _usage_details {
 716   my ($callback, $p) = (shift,shift);
 717
 718   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 719   return { 'error' => $session } if $context eq 'error';
 720
 721   my $search = { 'svcnum' => $p->{'svcnum'} };
 722   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 723   my $svc_acct = qsearchs ( 'svc_acct', $search );
 724   return { 'error' => 'No service selected in list_svc_usage' }
 725     unless $svc_acct;
 726
 727   my $freq   = $svc_acct->cust_svc->cust_pkg->part_pkg->freq;
 728   my $start  = $svc_acct->cust_svc->cust_pkg->setup;
 729   #my $end    = $svc_acct->cust_svc->cust_pkg->bill; # or time?
 730   my $end    = time;
 731
 732   unless($p->{beginning}){
 733     $p->{beginning} = $svc_acct->cust_svc->cust_pkg->last_bill;
 734     $p->{ending} = $end;
 735   }
 736
 737   my (@usage) = &$callback($svc_acct,$p->{beginning},$p->{ending});
 738
 739   #kinda false laziness with FS::cust_main::bill, but perhaps
 740   #we should really change this bit to DateTime and DateTime::Duration
 741   #
 742   #change this bit to use Date::Manip? CAREFUL with timezones (see
 743   # mailing list archive)
 744   my ($nsec,$nmin,$nhour,$nmday,$nmon,$nyear) =
 745     (localtime($p->{ending}) )[0,1,2,3,4,5];
 746   my ($psec,$pmin,$phour,$pmday,$pmon,$pyear) =
 747     (localtime($p->{beginning}) )[0,1,2,3,4,5];
 748
 749   if ( $freq =~ /^\d+$/ ) {
 750     $nmon += $freq;
 751     until ( $nmon < 12 ) { $nmon -= 12; $nyear++; }
 752     $pmon -= $freq;
 753     until ( $pmon >= 0 ) { $pmon += 12; $pyear--; }
 754   } elsif ( $freq =~ /^(\d+)w$/ ) {
 755     my $weeks = $1;
 756     $nmday += $weeks * 7;
 757     $pmday -= $weeks * 7;
 758   } elsif ( $freq =~ /^(\d+)d$/ ) {
 759     my $days = $1;
 760     $nmday += $days;
 761     $pmday -= $days;
 762   } elsif ( $freq =~ /^(\d+)h$/ ) {
 763     my $hours = $1;
 764     $nhour += $hours;
 765     $phour -= $hours;
 766   } else {
 767     return { 'error' => "unparsable frequency: ". $freq };
 768   }
 769
 770   my $previous  = timelocal_nocheck($psec,$pmin,$phour,$pmday,$pmon,$pyear);
 771   my $next      = timelocal_nocheck($nsec,$nmin,$nhour,$nmday,$nmon,$nyear);
 772
 773   {
 774     'error'     => '',
 775     'svcnum'    => $p->{svcnum},
 776     'beginning' => $p->{beginning},
 777     'ending'    => $p->{ending},
 778     'previous'  => ($previous > $start) ? $previous : $start,
 779     'next'      => ($next < $end) ? $next : $end,
 780     'usage'     => \@usage,
 781   };
 782 }
 783
 784 sub order_pkg {
 785   my $p = shift;
 786
 787   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 788   return { 'error' => $session } if $context eq 'error';
 789
 790   my $search = { 'custnum' => $custnum };
 791   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 792   my $cust_main = qsearchs('cust_main', $search )
 793     or return { 'error' => "unknown custnum $custnum" };
 794
 795   #false laziness w/ClientAPI/Signup.pm
 796
 797   my $cust_pkg = new FS::cust_pkg ( {
 798     'custnum' => $custnum,
 799     'pkgpart' => $p->{'pkgpart'},
 800   } );
 801   my $error = $cust_pkg->check;
 802   return { 'error' => $error } if $error;
 803
 804   my @svc = ();
 805   unless ( $p->{'svcpart'} eq 'none' ) {
 806
 807     my $svcdb;
 808     my $svcpart = '';
 809     if ( $p->{'svcpart'} =~ /^(\d+)$/ ) {
 810       $svcpart = $1;
 811       my $part_svc = qsearchs('part_svc', { 'svcpart' => $svcpart } );
 812       return { 'error' => "Unknown svcpart $svcpart" } unless $part_svc;
 813       $svcdb = $part_svc->svcdb;
 814     } else {
 815       $svcdb = 'svc_acct';
 816     }
 817     $svcpart ||= $cust_pkg->part_pkg->svcpart($svcdb);
 818
 819     my %fields = (
 820       'svc_acct'     => [ qw( username domsvc _password sec_phrase popnum ) ],
 821       'svc_domain'   => [ qw( domain ) ],
 822       'svc_external' => [ qw( id title ) ],
 823     );
 824
 825     my $svc_x = "FS::$svcdb"->new( {
 826       'svcpart'   => $svcpart,
 827       map { $_ => $p->{$_} } @{$fields{$svcdb}}
 828     } );
 829
 830     if ( $svcdb eq 'svc_acct' ) {
 831       my @acct_snarf;
 832       my $snarfnum = 1;
 833       while ( length($p->{"snarf_machine$snarfnum"}) ) {
 834         my $acct_snarf = new FS::acct_snarf ( {
 835           'machine'   => $p->{"snarf_machine$snarfnum"},
 836           'protocol'  => $p->{"snarf_protocol$snarfnum"},
 837           'username'  => $p->{"snarf_username$snarfnum"},
 838           '_password' => $p->{"snarf_password$snarfnum"},
 839         } );
 840         $snarfnum++;
 841         push @acct_snarf, $acct_snarf;
 842       }
 843       $svc_x->child_objects( \@acct_snarf );
 844     }
 845
 846     my $y = $svc_x->setdefault; # arguably should be in new method
 847     return { 'error' => $y } if $y && !ref($y);
 848
 849     $error = $svc_x->check;
 850     return { 'error' => $error } if $error;
 851
 852     push @svc, $svc_x;
 853
 854   }
 855
 856   use Tie::RefHash;
 857   tie my %hash, 'Tie::RefHash';
 858   %hash = ( $cust_pkg => \@svc );
 859   #msgcat
 860   $error = $cust_main->order_pkgs( \%hash, '', 'noexport' => 1 );
 861   return { 'error' => $error } if $error;
 862
 863   my $conf = new FS::Conf;
 864   if ( $conf->exists('signup_server-realtime') ) {
 865
 866     my $bill_error = _do_bop_realtime( $cust_main );
 867
 868     if ($bill_error) {
 869       $cust_pkg->cancel('quiet'=>1);
 870       return $bill_error;
 871     } else {
 872       $cust_pkg->reexport;
 873     }
 874
 875   } else {
 876     $cust_pkg->reexport;
 877   }
 878
 879   return { error => '', pkgnum => $cust_pkg->pkgnum };
 880
 881 }
 882
 883 sub change_pkg {
 884   my $p = shift;
 885
 886   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 887   return { 'error' => $session } if $context eq 'error';
 888
 889   my $search = { 'custnum' => $custnum };
 890   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 891   my $cust_main = qsearchs('cust_main', $search )
 892     or return { 'error' => "unknown custnum $custnum" };
 893
 894   my $cust_pkg = qsearchs('cust_pkg', { 'pkgnum' => $p->{pkgnum} } )
 895     or return { 'error' => "unknown package $p->{pkgnum}" };
 896
 897   my @newpkg;
 898   my $error = FS::cust_pkg::order( $custnum,
 899                                    [$p->{pkgpart}],
 900                                    [$p->{pkgnum}],
 901                                    \@newpkg,
 902                                  );
 903
 904   my $conf = new FS::Conf;
 905   if ( $conf->exists('signup_server-realtime') ) {
 906
 907     my $bill_error = _do_bop_realtime( $cust_main );
 908
 909     if ($bill_error) {
 910       $newpkg[0]->suspend;
 911       return $bill_error;
 912     } else {
 913       $newpkg[0]->reexport;
 914     }
 915
 916   } else {
 917     $newpkg[0]->reexport;
 918   }
 919
 920   return { error => '', pkgnum => $cust_pkg->pkgnum };
 921
 922 }
 923
 924 sub order_recharge {
 925   my $p = shift;
 926
 927   my($context, $session, $custnum) = _custoragent_session_custnum($p);
 928   return { 'error' => $session } if $context eq 'error';
 929
 930   my $search = { 'custnum' => $custnum };
 931   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
 932   my $cust_main = qsearchs('cust_main', $search )
 933     or return { 'error' => "unknown custnum $custnum" };
 934
 935   my $cust_svc = qsearchs( 'cust_svc', { 'svcnum' => $p->{'svcnum'} } )
 936     or return { 'error' => "unknown service " . $p->{'svcnum'} };
 937
 938   my $svc_x = $cust_svc->svc_x;
 939   my $part_pkg = $cust_svc->cust_pkg->part_pkg;
 940
 941   my %vhash =
 942     map { $_ =~ /^recharge_(.*)$/; $1, $part_pkg->option($_, 1) }
 943     qw ( recharge_seconds recharge_upbytes recharge_downbytes
 944          recharge_totalbytes );
 945   my $amount = $part_pkg->option('recharge_amount', 1);
 946
 947   my ($l, $v, $d) = $cust_svc->label;  # blah
 948   my $pkg = "Recharge $v";
 949
 950   my $bill_error = $cust_main->charge($amount, $pkg,
 951      "time: $vhash{seconds}, up: $vhash{upbytes}," .
 952      "down: $vhash{downbytes}, total: $vhash{totalbytes}",
 953      $part_pkg->taxclass); #meh
 954
 955   my $conf = new FS::Conf;
 956   if ( $conf->exists('signup_server-realtime') && !$bill_error ) {
 957
 958     $bill_error = _do_bop_realtime( $cust_main );
 959
 960     if ($bill_error) {
 961       return $bill_error;
 962     } else {
 963       my $error = $svc_x->recharge (\%vhash);
 964       return { 'error' => $error } if $error;
 965     }
 966
 967   } else {
 968     my $error = $bill_error;
 969     $error ||= $svc_x->recharge (\%vhash);
 970     return { 'error' => $error } if $error;
 971   }
 972
 973   return { error => '', svc => $cust_svc->part_svc->svc };
 974
 975 }
 976
 977 sub _do_bop_realtime {
 978   my ($cust_main) = @_;
 979
 980     my $old_balance = $cust_main->balance;
 981
 982     my $bill_error =    $cust_main->bill
 983                      || $cust_main->apply_payments_and_credits
 984                      || $cust_main->collect('realtime' => 1);
 985
 986     if (    $cust_main->balance > $old_balance
 987          && $cust_main->balance > 0
 988          && $cust_main->payby !~ /^(BILL|DCRD|DCHK)$/ ) {
 989       #this makes sense.  credit is "un-doing" the invoice
 990       $cust_main->credit( sprintf("%.2f", $cust_main->balance - $old_balance ),
 991                           'self-service decline' );
 992       $cust_main->apply_credits( 'order' => 'newest' );
 993
 994       return { 'error' => '_decline', 'bill_error' => $bill_error };
 995     }
 996
 997     '';
 998 }
 999
1000 sub cancel_pkg {
1001   my $p = shift;
1002   my $session = _cache->get($p->{'session_id'})
1003     or return { 'error' => "Can't resume session" }; #better error message
1004
1005   my $custnum = $session->{'custnum'};
1006
1007   my $cust_main = qsearchs('cust_main', { 'custnum' => $custnum } )
1008     or return { 'error' => "unknown custnum $custnum" };
1009
1010   my $pkgnum = $p->{'pkgnum'};
1011
1012   my $cust_pkg = qsearchs('cust_pkg', { 'custnum' => $custnum,
1013                                         'pkgnum'  => $pkgnum,   } )
1014     or return { 'error' => "unknown pkgnum $pkgnum" };
1015
1016   my $error = $cust_pkg->cancel( 'quiet'=>1 );
1017   return { 'error' => $error };
1018
1019 }
1020
1021 sub provision_acct {
1022   my $p = shift;
1023
1024   return { 'error' => gettext('passwords_dont_match') }
1025     if $p->{'_password'} ne $p->{'_password2'};
1026   return { 'error' => gettext('empty_password') }
1027     unless length($p->{'_password'});
1028
1029   _provision( 'FS::svc_acct',
1030               [qw(username _password)],
1031               [qw(username _password)],
1032               $p,
1033               @_
1034             );
1035 }
1036
1037 sub provision_external {
1038   my $p = shift;
1039   #_provision( 'FS::svc_external', [qw(id title)], [qw(id title)], $p, @_ );
1040   _provision( 'FS::svc_external',
1041               [],
1042               [qw(id title)],
1043               $p,
1044               @_
1045             );
1046 }
1047
1048 sub _provision {
1049   my( $class, $fields, $return_fields, $p ) = splice(@_, 0, 4);
1050
1051   my($context, $session, $custnum) = _custoragent_session_custnum($p);
1052   return { 'error' => $session } if $context eq 'error';
1053
1054   my $search = { 'custnum' => $custnum };
1055   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
1056   my $cust_main = qsearchs('cust_main', $search )
1057     or return { 'error' => "unknown custnum $custnum" };
1058
1059   my $pkgnum = $p->{'pkgnum'};
1060
1061   my $cust_pkg = qsearchs('cust_pkg', { 'custnum' => $custnum,
1062                                         'pkgnum'  => $pkgnum,
1063                                                                } )
1064     or return { 'error' => "unknown pkgnum $pkgnum" };
1065
1066   my $part_svc = qsearchs('part_svc', { 'svcpart' => $p->{'svcpart'} } )
1067     or return { 'error' => "unknown svcpart $p->{'svcpart'}" };
1068
1069   my $svc_x = $class->new( {
1070     'pkgnum'  => $p->{'pkgnum'},
1071     'svcpart' => $p->{'svcpart'},
1072     map { $_ => $p->{$_} } @$fields
1073   } );
1074   my $error = $svc_x->insert;
1075   $svc_x = qsearchs($svc_x->table, { 'svcnum' => $svc_x->svcnum })
1076     unless $error;
1077
1078   return { 'svc'   => $part_svc->svc,
1079            'error' => $error,
1080            map { $_ => $svc_x->get($_) } @$return_fields
1081          };
1082
1083 }
1084
1085 sub part_svc_info {
1086   my $p = shift;
1087
1088   my($context, $session, $custnum) = _custoragent_session_custnum($p);
1089   return { 'error' => $session } if $context eq 'error';
1090
1091   my $search = { 'custnum' => $custnum };
1092   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
1093   my $cust_main = qsearchs('cust_main', $search )
1094     or return { 'error' => "unknown custnum $custnum" };
1095
1096   my $pkgnum = $p->{'pkgnum'};
1097
1098   my $cust_pkg = qsearchs('cust_pkg', { 'custnum' => $custnum,
1099                                         'pkgnum'  => $pkgnum,
1100                                                                } )
1101     or return { 'error' => "unknown pkgnum $pkgnum" };
1102
1103   my $svcpart = $p->{'svcpart'};
1104
1105   my $pkg_svc = qsearchs('pkg_svc', { 'pkgpart' => $cust_pkg->pkgpart,
1106                                       'svcpart' => $svcpart,           } )
1107     or return { 'error' => "unknown svcpart $svcpart for pkgnum $pkgnum" };
1108   my $part_svc = $pkg_svc->part_svc;
1109
1110   my $conf = new FS::Conf;
1111
1112   return {
1113     'svc'     => $part_svc->svc,
1114     'svcdb'   => $part_svc->svcdb,
1115     'pkgnum'  => $pkgnum,
1116     'svcpart' => $svcpart,
1117     'custnum' => $custnum,
1118
1119     'security_phrase' => 0, #XXX !
1120     'svc_acct_pop'    => [], #XXX !
1121     'popnum'          => '',
1122     'init_popstate'   => '',
1123     'popac'           => '',
1124     'acstate'         => '',
1125
1126     'small_custview' =>
1127       small_custview( $cust_main, $conf->config('countrydefault') ),
1128
1129   };
1130
1131 }
1132
1133 sub unprovision_svc {
1134   my $p = shift;
1135
1136   my($context, $session, $custnum) = _custoragent_session_custnum($p);
1137   return { 'error' => $session } if $context eq 'error';
1138
1139   my $search = { 'custnum' => $custnum };
1140   $search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
1141   my $cust_main = qsearchs('cust_main', $search )
1142     or return { 'error' => "unknown custnum $custnum" };
1143
1144   my $svcnum = $p->{'svcnum'};
1145
1146   my $cust_svc = qsearchs('cust_svc', { 'svcnum'  => $svcnum, } )
1147     or return { 'error' => "unknown svcnum $svcnum" };
1148
1149   return { 'error' => "Service $svcnum does not belong to customer $custnum" }
1150     unless $cust_svc->cust_pkg->custnum == $custnum;
1151
1152   my $conf = new FS::Conf;
1153
1154   return { 'svc'   => $cust_svc->part_svc->svc,
1155            'error' => $cust_svc->cancel,
1156            'small_custview' =>
1157              small_custview( $cust_main, $conf->config('countrydefault') ),
1158          };
1159
1160 }
1161
1162 sub myaccount_passwd {
1163   my $p = shift;
1164   my($context, $session, $custnum) = _custoragent_session_custnum($p);
1165   return { 'error' => $session } if $context eq 'error';
1166
1167   return { 'error' => "New passwords don't match." }
1168     if $p->{'new_password'} ne $p->{'new_password2'};
1169
1170   return { 'error' => 'Enter new password' }
1171     unless length($p->{'new_password'});
1172
1173   #my $search = { 'custnum' => $custnum };
1174   #$search->{'agentnum'} = $session->{'agentnum'} if $context eq 'agent';
1175   $custnum =~ /^(\d+)$/ or die "illegal custnum";
1176   my $search = " AND custnum = $1";
1177   $search .= " AND agentnum = ". $session->{'agentnum'} if $context eq 'agent';
1178
1179   my $svc_acct = qsearchs( {
1180     'table'     => 'svc_acct',
1181     'addl_from' => 'LEFT JOIN cust_svc  USING ( svcnum  ) '.
1182                    'LEFT JOIN cust_pkg  USING ( pkgnum  ) '.
1183                    'LEFT JOIN cust_main USING ( custnum ) ',
1184     'hashref'   => { 'svcnum' => $p->{'svcnum'}, },
1185     'extra_sql' => $search, #important
1186   } )
1187     or return { 'error' => "Service not found" };
1188
1189   $svc_acct->_password($p->{'new_password'});
1190   my $error = $svc_acct->replace();
1191
1192   my($label, $value) = $svc_acct->cust_svc->label;
1193
1194   return { 'error' => $error,
1195            'label' => $label,
1196            'value' => $value,
1197          };
1198
1199 }
1200
1201 #--
1202
1203 sub _custoragent_session_custnum {
1204   my $p = shift;
1205
1206   my($context, $session, $custnum);
1207   if ( $p->{'session_id'} ) {
1208
1209     $context = 'customer';
1210     $session = _cache->get($p->{'session_id'})
1211       or return ( 'error' => "Can't resume session" ); #better error message
1212     $custnum = $session->{'custnum'};
1213
1214   } elsif ( $p->{'agent_session_id'} ) {
1215
1216     $context = 'agent';
1217     my $agent_cache = new FS::ClientAPI_SessionCache( {
1218       'namespace' => 'FS::ClientAPI::Agent',
1219     } );
1220     $session = $agent_cache->get($p->{'agent_session_id'})
1221       or return ( 'error' => "Can't resume session" ); #better error message
1222     $custnum = $p->{'custnum'};
1223
1224   } else {
1225     return ( 'error' => "Can't resume session" ); #better error message
1226   }
1227
1228   ($context, $session, $custnum);
1229
1230 }
1231
1232 1;
1233