X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=fs_signup%2Ffs_signup_server;h=d6eb4a8d554bfcbba64741f35b4b658a42840954;hp=f3030e9ae7d339ab796a674853dc2ae46e61f6ea;hb=d2f3aff3c7fc373c9501d5b86d6c8fa8fd2e97ff;hpb=44e3eff0aa6e7bdb7f4ecd9ee1ddf141e1b68af3 diff --git a/fs_signup/fs_signup_server b/fs_signup/fs_signup_server index f3030e9ae..d6eb4a8d5 100755 --- a/fs_signup/fs_signup_server +++ b/fs_signup/fs_signup_server @@ -4,6 +4,7 @@ # use strict; +use vars qw($pid); use IO::Handle; use Storable qw(nstore_fd fd_retrieve); use Tie::RefHash; @@ -13,7 +14,9 @@ use FS::Conf; use FS::Record qw( qsearch qsearchs ); use FS::cust_main_county; use FS::cust_main; -use FS::msgcat qw(gettext); +use FS::cust_bill; +use FS::cust_pkg; +use FS::Msgcat qw(gettext); use vars qw( $opt $Debug ); @@ -24,8 +27,14 @@ my $user = shift or die &usage; my $conf = new FS::Conf; +if ($conf->exists('signup_server-quiet')) { + $FS::cust_bill::quiet = 1; + $FS::cust_pkg::quiet = 1; +} + #my @payby = qw(CARD PREPAY); my @payby = $conf->config('signup_server-payby'); +my $smtpmachine = $conf->config('smtpmachine'); my $machine = shift or die &usage; @@ -38,14 +47,22 @@ my $refnum = shift or die &usage; #causing trouble for some folks #$SIG{CHLD} = sub { wait() }; +$SIG{HUP} = \&killssh; +$SIG{INT} = \&killssh; +$SIG{QUIT} = \&killssh; +$SIG{TERM} = \&killssh; +$SIG{PIPE} = \&killssh; +sub killssh { kill 'TERM', $pid if $pid; exit; }; + my($fs_signupd)="/usr/local/sbin/fs_signupd"; while (1) { my($reader,$writer)=(new IO::Handle, new IO::Handle); #seems to be broken - calling ->flush explicitly# $writer->autoflush(1); warn "[fs_signup_server] Connecting to $machine...\n" if $Debug; - sshopen2($machine,$reader,$writer,$fs_signupd); + $pid = sshopen2($machine,$reader,$writer,$fs_signupd); + my @pops = qsearch('svc_acct_pop',{} ); my $init_data = { #'_protocol' => 'signup', @@ -57,12 +74,26 @@ while (1) { 'part_pkg' => [ - map { $_->hashref } + #map { $_->hashref } + map { { 'payby' => [ $_->payby ], %{$_->hashref} } } grep { $_->svcpart('svc_acct') && $pkgpart_href->{ $_->pkgpart } } qsearch( 'part_pkg', { 'disabled' => '' } ) ], - 'svc_acct_pop' => [ map { $_->hashref } qsearch ('svc_acct_pop',{} ) ], + 'agentnum2part_pkg' => + { + map { + my $href = $_->pkgpart_hashref; + $_->agentnum => + [ + map { { 'payby' => [ $_->payby ], %{$_->hashref} } } + grep { $_->svcpart('svc_acct') && $href->{ $_->pkgpart } } + qsearch( 'part_pkg', { 'disabled' => '' } ) + ]; + } qsearch('agent', {} ) + }, + + 'svc_acct_pop' => [ map { $_->hashref } @pops ], 'security_phrase' => $conf->exists('security_phrase'), @@ -70,7 +101,11 @@ while (1) { 'msgcat' => { map { $_=>gettext($_) } qw( passwords_dont_match invalid_card unknown_card_type not_a - ) } + ) }, + + 'statedefault' => $conf->config('statedefault') || 'CA', + + 'countrydefault' => $conf->config('countrydefault') || 'US', }; @@ -95,19 +130,20 @@ while (1) { #things that aren't necessary in base class, but are for signup server #return "Passwords don't match" # if $hashref->{'_password'} ne $hashref->{'_password2'} - $error ||= "Empty password" unless $signup_data->{'_password'}; - $error ||= "No POP selected" unless $signup_data->{'popnum'}; + $error ||= gettext('empty_password') unless $signup_data->{'_password'}; + $error ||= gettext('no_access_number_selected') + unless $signup_data->{'popnum'} || !scalar(@pops); #shares some stuff with htdocs/edit/process/cust_main.cgi... take any # common that are still here and library them. my $cust_main = new FS::cust_main ( { #'custnum' => '', - 'agentnum' => $agentnum, + 'agentnum' => $signup_data->{agentnum} || $agentnum, 'refnum' => $refnum, map { $_ => $signup_data->{$_} } qw( last first ss company address1 address2 city county state zip country - daytime night fax payby payinfo paydate payname referral_custnum + daytime night fax payby payinfo paydate payname referral_custnum comments ), } ); @@ -115,19 +151,18 @@ while (1) { $error ||= "Illegal payment type" unless grep { $_ eq $signup_data->{'payby'} } @payby; + $cust_main->payinfo($cust_main->daytime) + if $cust_main->payby eq 'LECB' && ! $cust_main->payinfo; + my @invoicing_list = split( /\s*\,\s*/, $signup_data->{'invoicing_list'} ); - my $part_pkg = - qsearchs( 'part_pkg', { 'pkgpart' => $signup_data->{'pkgpart'} } ) - or $error ||= "WARNING: unknown pkgpart ". $signup_data->{pkgpart}; - my $svcpart = $part_pkg->svcpart unless $error; + $signup_data->{'pkgpart'} =~ /^(\d+)$/ or '' =~ /^()$/; + my $pkgpart = $1; - # this should wind up in FS::cust_pkg! - my $agent = qsearchs( 'agent', { 'agentnum' => $agentnum } ); - #my $pkgpart_href = $agent->pkgpart_hashref; - $error ||= "WARNING: agent $agentnum can't purchase pkgpart ". - $signup_data->{pkgpart} - unless $pkgpart_href->{ $signup_data->{pkgpart} }; + my $part_pkg = + qsearchs( 'part_pkg', { 'pkgpart' => $pkgpart } ) + or $error ||= "WARNING: unknown pkgpart: $pkgpart"; + my $svcpart = $part_pkg->svcpart('svc_acct') unless $error; my $cust_pkg = new FS::cust_pkg ( { #later#'custnum' => $custnum, @@ -149,11 +184,97 @@ while (1) { use Tie::RefHash; tie my %hash, 'Tie::RefHash'; %hash = ( $cust_pkg => [ $svc_acct ] ); - $error ||= $cust_main->insert( \%hash, \@invoicing_list ); + $error ||= $cust_main->insert( \%hash, \@invoicing_list ); #msgcat + + if ( ! $error && $conf->exists('signup_server-realtime') ) { + + warn "[fs_signup_server] Billing customer...\n" if $Debug; + + my $bill_error = $cust_main->bill; + warn "[fs_signup_server] error billing new customer: $bill_error" + if $bill_error; + + $cust_main->apply_payments; + $cust_main->apply_credits; + + $bill_error = $cust_main->collect; + warn "[fs_signup_server] error collecting from new customer: $bill_error" + if $bill_error; + + if ( $cust_main->balance > 0 ) { + + #this makes sense. credit is "un-doing" the invoice + $cust_main->credit( $cust_main->balance, 'signup server decline' ); + $cust_main->apply_credits; + + #should check list for errors... + #$cust_main->suspend; + $cust_main->cancel; + + $error = '_decline'; + } + } warn "[fs_signup_server] Sending results...\n" if $Debug; print $writer $error, "\n"; + next if $error; + + if ( $conf->config('signup_server-email') ) { + warn "[fs_signup_server] Sending email...\n" if $Debug; + + #false laziness w/FS::cust_bill::send & FS::cust_pay::delete + use Mail::Header; + use Mail::Internet 1.44; + use Date::Format; + my $from = $conf->config('invoice_from'); #??? as good as any + $ENV{MAILADDRESS} = $from; + my $header = new Mail::Header ( [ + "From: $from", + "To: ". $conf->config('signup_server-email'), + "Sender: $from", + "Reply-To: $from", + "Date: ". time2str("%a, %d %b %Y %X %z", time), + "Subject: FREESIDE NOTIFICATION: Signup Server", + ] ); + my $body = [ + "This is an automatic message from your Freeside installation\n", + "informing you a customer has signed up via the signup server:\n", + "\n", + 'custnum : '. $cust_main->custnum. "\n", + 'Name : '. $cust_main->last. ", ". $cust_main->first. "\n", + 'Agent : '. $cust_main->agent->agent. "\n", + 'Package : '. $part_pkg->pkg. ' - '. $part_pkg->comment. "\n", + 'Signup Date : '. time2str('%C', time). "\n", + 'Username : '. $svc_acct->username. "\n", + #'Password : '. # config file to turn this on if noment insists + 'Day phone : '. $cust_main->daytime. "\n", + 'Night phone : '. $cust_main->night. "\n", + 'Address : '. $cust_main->address1. "\n", + ( $cust_main->address2 + ? ' '. $cust_main->address2. "\n" + : '' ), + ' '. $cust_main->city. ', '. $cust_main->state. ' '. + $cust_main->zip. "\n", + ( $cust_main->country eq 'US' + ? '' + : ' '. $cust_main->country. "\n" ), + "\n", + ]; + #if ( $cust_main->balance > 0 ) { + # push @$body, + # "This customer has an outstanding balance and has been suspended.\n"; + #} + my $message = new Mail::Internet ( 'Header' => $header, 'Body' => $body ); + $!=0; + $message->smtpsend( Host => $smtpmachine ) + or $message->smtpsend( Host => $smtpmachine, Debug => 1 ) + or warn "[fs_signup_server] can't send email to ". + $conf->config('signup_server-email'). + " via server $smtpmachine with SMTP: $!"; + #end-of-send mail + } + } close $writer; close $reader;