FS/FS/Cron/notify.pm

   1 package FS::Cron::notify;
   2
   3 use strict;
   4 use vars qw( @ISA @EXPORT_OK $DEBUG );
   5 use Exporter;
   6 use FS::UID qw( dbh );
   7 use FS::Record qw(qsearch);
   8 use FS::cust_main;
   9 use FS::cust_pkg;
  10
  11 @ISA = qw( Exporter );
  12 @EXPORT_OK = qw ( notify_flat_delay );
  13 $DEBUG = 0;
  14
  15 sub notify_flat_delay {
  16
  17   my %opt = @_;
  18
  19   my $oldAutoCommit = $FS::UID::AutoCommit;
  20   $DEBUG = 1 if $opt{'v'};
  21
  22   #we're at now now (and later).
  23   my($time) = $^T;
  24
  25   # select * from cust_pkg where
  26   my $where_pkg = <<"END";
  27     where ( cancel is null or cancel = 0 )
  28       and ( bill > 0 )
  29       and
  30       0 < ( select count(*) from part_pkg
  31               where cust_pkg.pkgpart = part_pkg.pkgpart
  32                 and part_pkg.plan = 'flat_delayed'
  33                 and 0 < ( select count (*) from part_pkg_option
  34                             where part_pkg.pkgpart = part_pkg_option.pkgpart
  35                               and part_pkg_option.optionname = 'recur_notify'
  36                               and part_pkg_option.optionvalue > 0
  37                               and 0 <= $time
  38                                 + cast(part_pkg_option.optionvalue as integer)
  39                                   * 86400
  40                                 - cust_pkg.bill
  41                               and ( cust_pkg.expire is null
  42                                 or  cust_pkg.expire > $time
  43                                   + cast(part_pkg_option.optionvalue as integer)
  44                                     * 86400
  45                                   )
  46                         )
  47           )
  48       and
  49       0 = ( select count(*) from cust_pkg_option
  50               where cust_pkg.pkgnum = cust_pkg_option.pkgnum
  51                 and cust_pkg_option.optionname = 'impending_recur_notification_sent'
  52                 and cust_pkg_option.optionvalue = 1
  53           )
  54 END
  55
  56   if ($opt{a}) {
  57     $where_pkg .= <<END;
  58       and 0 < ( select count(*) from cust_main
  59                   where cust_pkg.custnum = cust_main.custnum
  60                     and cust_main.agentnum = $opt{a}
  61               )
  62 END
  63   }
  64
  65   my @cust_pkg;
  66   if ( @ARGV ) {
  67     $where_pkg .= "and ( " . join( "OR ", map { "custnum = $_" } @ARGV) . " )";
  68   }
  69
  70   my $orderby = "order by custnum, bill";
  71
  72   my $extra_sql = "$where_pkg $orderby";
  73
  74   @cust_pkg = qsearch('cust_pkg', {}, '', $extra_sql );
  75
  76   my @packages = ();
  77   my @recurdates = ();
  78   my @cust_pkgs = ();
  79   while ( scalar(@cust_pkg) ) {
  80     my $cust_main = $cust_pkg[0]->cust_main;
  81     my $custnum = $cust_pkg[0]->custnum;
  82     warn "working on $custnum" if $DEBUG;
  83     while (scalar(@cust_pkg)){
  84       last if ($cust_pkg[0]->custnum != $custnum);
  85       warn "storing information on " . $cust_pkg[0]->pkgnum if $DEBUG;
  86       push @packages, $cust_pkg[0]->part_pkg->pkg;
  87       push @recurdates, $cust_pkg[0]->bill;
  88       push @cust_pkgs, $cust_pkg[0];
  89       shift @cust_pkg;
  90     }
  91     my $error =
  92       $cust_main->notify( 'impending_recur_template',
  93                           'extra_fields' => { 'packages'   => \@packages,
  94                                               'recurdates' => \@recurdates,
  95                                               'package'    => $packages[0],
  96                                               'recurdate'  => $recurdates[0],
  97                                             },
  98                         );
  99     warn "Error notifying, custnum ". $cust_main->custnum. ": $error" if $error;
 100
 101     unless ($error) {
 102       local $SIG{HUP} = 'IGNORE';
 103       local $SIG{INT} = 'IGNORE';
 104       local $SIG{QUIT} = 'IGNORE';
 105       local $SIG{TERM} = 'IGNORE';
 106       local $SIG{TSTP} = 'IGNORE';
 107
 108       my $oldAutoCommit = $FS::UID::AutoCommit;
 109       local $FS::UID::AutoCommit = 0;
 110       my $dbh = dbh;
 111
 112       for (@cust_pkgs) {
 113         my %options = ($_->options,  'impending_recur_notification_sent' => 1 );
 114         $error = $_->replace( $_, options => \%options );
 115         if ($error){
 116           $dbh->rollback or die $dbh->errstr if $oldAutoCommit;
 117           die "Error updating package options for customer". $cust_main->custnum.
 118                ": $error" if $error;
 119         }
 120       }
 121
 122       $dbh->commit or die $dbh->errstr if $oldAutoCommit;
 123
 124     }
 125
 126     @packages = ();
 127     @recurdates = ();
 128     @cust_pkgs = ();
 129
 130   }
 131
 132   dbh->commit or die dbh->errstr if $oldAutoCommit;
 133
 134 }
 135
 136 1;