1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
package FS::Cron::bill;
use strict;
use vars qw( @ISA @EXPORT_OK );
use Exporter;
use Date::Parse;
use FS::Record qw(qsearch qsearchs);
use FS::cust_main;
@ISA = qw( Exporter );
@EXPORT_OK = qw ( bill );
sub bill {
my %opt = @_;
$FS::cust_main::DEBUG = 1 if $opt{'v'};
my %search = ();
$search{'payby'} = $opt{'p'} if $opt{'p'};
$search{'agentnum'} = $opt{'a'} if $opt{'a'};
#we're at now now (and later).
my($time)= $opt{'d'} ? str2time($opt{'d'}) : $^T;
$time += $opt{'y'} * 86400 if $opt{'y'};
# select * from cust_main where
my $where_pkg = <<"END";
0 < ( select count(*) from cust_pkg
where cust_main.custnum = cust_pkg.custnum
and ( cancel is null or cancel = 0 )
and ( setup is null or setup = 0
or bill is null or bill <= $time
or ( expire is not null and expire <= $^T )
)
)
END
# or
my $where_bill_event = <<"END";
0 < ( select count(*) from cust_bill
where cust_main.custnum = cust_bill.custnum
and 0 < charged
- coalesce(
( select sum(amount) from cust_bill_pay
where cust_bill.invnum = cust_bill_pay.invnum )
,0
)
- coalesce(
( select sum(amount) from cust_credit_bill
where cust_bill.invnum = cust_credit_bill.invnum )
,0
)
and 0 < ( select count(*) from part_bill_event
where payby = cust_main.payby
and ( disabled is null or disabled = '' )
and seconds <= $time - cust_bill._date
and 0 = ( select count(*) from cust_bill_event
where cust_bill.invnum = cust_bill_event.invnum
and part_bill_event.eventpart = cust_bill_event.eventpart
and status = 'done'
)
)
)
END
my $extra_sql = ( scalar(%search) ? ' AND ' : ' WHERE ' ). "( $where_pkg OR $where_bill_event )";
my @cust_main;
if ( @ARGV ) {
@cust_main = map { qsearchs('cust_main', { custnum => $_, %search } ) } @ARGV
} else {
@cust_main = qsearch('cust_main', \%search, '', $extra_sql );
}
;
my($cust_main,%saw);
foreach $cust_main ( @cust_main ) {
# $^T not $time because -d is for pre-printing invoices
foreach my $cust_pkg (
grep { $_->expire && $_->expire <= $^T } $cust_main->ncancelled_pkgs
) {
my $error = $cust_pkg->cancel;
warn "Error cancelling expired pkg ". $cust_pkg->pkgnum. " for custnum ".
$cust_main->custnum. ": $error"
if $error;
}
# $^T not $time because -d is for pre-printing invoices
foreach my $cust_pkg (
grep { $_->part_pkg->is_prepaid
&& $_->bill && $_->bill < $^T && ! $_->susp
}
$cust_main->ncancelled_pkgs
) {
my $action = $cust_pkg->part_pkg->option('recur_action') || 'suspend';
my $error = $cust_pkg->$action();
warn "Error suspending package ". $cust_pkg->pkgnum.
" for custnum ". $cust_main->custnum.
": $error"
if $error;
}
my $error = $cust_main->bill( 'time' => $time,
'resetup' => $opt{'s'},
);
warn "Error billing, custnum ". $cust_main->custnum. ": $error" if $error;
$cust_main->apply_payments_and_credits;
$error = $cust_main->collect( 'invoice_time' => $time,
'freq' => $opt{'freq'},
);
warn "Error collecting, custnum". $cust_main->custnum. ": $error" if $error;
}
}
|
