FS/FS/ClientAPI/MyAccount.pm

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