2020 census data
[freeside.git] / bin / cdr-manual-rate
1 #!/usr/bin/perl
2
3 use FS::Record qw(qsearch qsearchs);
4 use FS::Misc::Getopt;
5 use FS::cdr;
6 use FS::Cursor;
7 our %opt;
8
9 getopts('f:');
10
11 unless ($opt{f}) {
12   die "
13   Usage:
14   cdr-manual-rate -f freesidestatus [ -s startdate ] [ -e enddate ] user
15 ";
16 }
17
18 $FS::UID::AutoCommit = 1; # because partial completion of this is useful
19
20 my $where_date;
21 if ($opt{start}) {
22   $where_date = " AND startdate >= $opt{start} ";
23 }
24 if ($opt{end}) {
25   $where_date .= " AND startdate < $opt{end} ";
26 }
27
28 my $cursor = FS::Cursor->new({
29     'table'     => 'cdr',
30     'hashref'   => { freesidestatus => $opt{f} },
31     'extra_sql' => $where_date,
32 });
33
34 our %svc_phone = (); # phonenum => svc_phone
35 our %pkgnum = ();    # phonenum => pkgnum
36 our %cust_pkg = ();  # pkgnum   => cust_pkg
37 our %pkgpart = ();   # phonenum => pkgpart
38 our %part_pkg = ();  # pkgpart  => part_pkg
39
40 # some stats
41 my $total = 0;
42 my $success = 0;
43 my $notfound = 0;
44 my $failed = 0;
45
46 while (my $cdr = $cursor->fetch) {
47
48     $total++;
49     my $cdrdesc = "CDR ". $cdr->acctid.", ".$cdr->src." -> ".$cdr->dst;
50
51     # borrow CDR-to-package matching code from cdrrated...
52     my $number = $cdr->charged_party || $cdr->src;
53
54     # strip the prefix from the number
55     my $prefix = '+1'; #$options{'default_prefix'};
56
57     $number = substr($number, length($prefix))
58       if $prefix eq substr($number, 0, length($prefix));
59     if ( $prefix && $prefix =~ /^\+(\d+)$/ ) {
60       $prefix = $1;
61       $number = substr($number, length($prefix))
62         if $prefix eq substr($number, 0, length($prefix));
63     }
64
65     # find a svc_phone that matches it
66     unless ( $svc_phone{$number} ) {
67       #only phone number matching supported right now
68       my $svc_phone = qsearchs('svc_phone', { 'phonenum' => $number } );
69       unless ( $svc_phone ) {
70         warn "can't find a phone service for $cdrdesc\n";
71         $notfound++;
72         next;
73       }
74
75       $svc_phone{$number} = $svc_phone;
76
77     }
78
79     # find the pkgnum
80     unless ( $pkgnum{$number} ) {
81
82       my $cust_pkg = $svc_phone{$number}->cust_svc->cust_pkg;
83       if (!$cust_pkg) {
84         warn "can't find a package for $cdrdesc\n";
85         $notfound++;
86         next;
87       }
88       $pkgnum{$number} = $cust_pkg->pkgnum;
89       $cust_pkg{$cust_pkg->pkgnum} ||= $cust_pkg;
90
91     }
92
93     unless ( $pkgpart{$number} ) {
94       #get the package, search through the part_pkg and linked for a voip_cdr def w/matching cdrtypenum (or no use_cdrtypenum)
95       my $cust_pkg = $cust_pkg{$pkgnum{$number}};
96       my @part_pkg;
97       foreach ($cust_pkg->part_pkg->self_and_bill_linked) {
98         if ($_->plan eq 'voip_cdr'
99                  && ( ! length($_->option_cacheable('use_cdrtypenum'))
100                       || $_->option_cacheable('use_cdrtypenum')
101                            eq $cdr->cdrtypenum #eq otherwise 0 matches ''
102                     )
103                  && ( ! length($_->option_cacheable('ignore_cdrtypenum'))
104                       || $_->option_cacheable('ignore_cdrtypenum')
105                            ne $cdr->cdrtypenum #ne otherwise 0 matches ''
106                     )
107
108         ) {
109           push @part_pkg, $_;
110         }
111       }
112
113       if (!@part_pkg) {
114         warn "can't find a voip_cdr package definition for $cdrdesc\n";
115         $notfound++;
116         next;
117       } elsif (scalar(@part_pkg) > 1) {
118         warn "found more than one package that could rate $cdrdesc\n";
119         $notfound++;
120         next;
121       }
122
123       $pkgpart{$number} = $part_pkg[0]->pkgpart;
124       $part_pkg{ $part_pkg[0]->pkgpart } ||= $part_pkg[0];
125
126     } # unless $pkgpart{$number}
127
128     # now actually rate the call. ignore included minutes, since that's a
129     # property of the billing cycle and this call isn't part of a billing
130     # cycle.
131     my $error = $cdr->rate(
132       'part_pkg'  => $part_pkg{ $pkgpart{$number} },
133       'cust_pkg'  => $cust_pkg{ $pkgnum{$number} },
134       'svcnum'    => $svc_phone{$number}->svcnum,
135     );
136     if ( $error ) {
137       warn "can't rate $cdrdesc: $error\n";
138       $failed++;
139       next;
140     }
141     $error = $cdr->set_status('done');
142     if ( $error ) {
143       # don't know how this would happen...
144       warn "can't set status on $cdrdesc: $error\n";
145       $failed++;
146       next;
147     }
148
149     $success++;
150 }
151
152 print "
153 Total CDRs:             $total
154 Incomplete information: $notfound
155 Failed rating:          $failed
156 Successfully rated:     $success
157 ";
158