improve performance of DID provisioning status report, RT10988
[freeside.git] / bin / set-lata-have_usage
1 #!/usr/bin/perl
2 use strict;
3 use warnings;
4 use FS::UID qw(adminsuidsetup);
5 use FS::Record qw(qsearch qsearchs dbh);
6 use FS::lata;
7 use FS::phone_avail;
8 use FS::svc_phone;
9 use Data::Dumper;
10
11 print "started time=".time."\n";
12
13 my $user = shift;
14 adminsuidsetup $user;
15
16 local $SIG{HUP} = 'IGNORE';
17 local $SIG{INT} = 'IGNORE';
18 local $SIG{QUIT} = 'IGNORE';
19 local $SIG{TERM} = 'IGNORE';
20 local $SIG{TSTP} = 'IGNORE';
21 local $SIG{PIPE} = 'IGNORE';
22
23 my $oldAutoCommit = $FS::UID::AutoCommit;
24 local $FS::UID::AutoCommit = 0;
25 my $dbh = dbh;
26
27 my %latas = map { $_->latanum => $_ } qsearch('lata', {});
28
29 foreach my $lata ( keys %latas ) {
30         next unless $latas{$lata}->have_usage > 0;
31         $latas{$lata}->have_usage(0);
32         my $error = $latas{$lata}->replace;
33         if ( $error ) {
34             $dbh->rollback if $oldAutoCommit;
35             die "error replacing LATA $lata: $error";
36         }
37 }
38 print "cleared have_usage for all LATAs time=".time."\n";
39
40 my @dids = qsearch({     'table'     => 'svc_phone',
41                                 'hashref'   => 
42                                     { 'latanum' =>
43                                         { 'op'      => '>',
44                                           'value'   => '0',
45                                         },
46                                     },
47                                 'addl_from' => 'join phone_avail using (svcnum)',
48                                   });
49 print "DID query finished time=".time."\n";
50
51 my $count = 0;
52 foreach my $did ( @dids ) {
53     print "count=$count time=".time."\n" if $count % 1000 == 0;
54     my @cdrs = $did->get_cdrs;
55     my $lata = $latas{$did->latanum};
56     $count++;
57     if ( scalar(@cdrs) ) {
58         if ( !$lata->have_usage ) {
59             $lata->have_usage(1);
60         }
61         else {
62             $lata->have_usage($lata->have_usage+1);
63         }
64     }
65 }
66
67 print "Set have_usage finished time=".time."\n";
68
69 foreach my $lata ( keys %latas ) {
70     if ( $latas{$lata}->modified ) {
71         print "$lata ".$latas{$lata}->have_usage."\n";
72         my $error = $latas{$lata}->replace;
73         if ( $error ) {
74             $dbh->rollback if $oldAutoCommit;
75             die "error replacing LATA $lata: $error";
76         }
77     }
78 }
79
80 $dbh->commit or die $dbh->errstr if $oldAutoCommit;
81 print "done time=".time."\n";