diff options
author | Ivan Kohler <ivan@freeside.biz> | 2014-07-26 15:18:33 -0700 |
---|---|---|
committer | Ivan Kohler <ivan@freeside.biz> | 2014-07-26 15:18:33 -0700 |
commit | 7caec8842cb8959515204b45aef368f243e87e33 (patch) | |
tree | f615e7134282eaa714e36da4db2a361cde21a703 /FS/bin | |
parent | 02bf58c3c5db507d4652d24b1788208ca6c4d759 (diff) |
queue statistics, RT#30238
Diffstat (limited to 'FS/bin')
-rw-r--r-- | FS/bin/freeside-queued | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/FS/bin/freeside-queued b/FS/bin/freeside-queued index f1a87cac9..70d853483 100644 --- a/FS/bin/freeside-queued +++ b/FS/bin/freeside-queued @@ -11,6 +11,7 @@ use FS::Conf; use FS::Record qw(qsearch); use FS::queue; use FS::queue_depend; +use FS::queue_stat; use FS::Log; use FS::Cron::expire_user_pref qw( expire_user_pref ); @@ -140,6 +141,8 @@ while (1) { foreach my $job ( @jobs ) { + my $start_date = time; + $log->debug('locking queue job', object => $job); my %hash = $job->hash; @@ -236,6 +239,20 @@ while (1) { dbh->commit; # for the job itself } + if ( $ljob->job eq 'FS::cust_main::queued_bill' ) { + my $queue_stat = new FS::queue_stat { + 'jobnum' => $ljob->jobnum, + 'job' => $ljob->job, + 'custnum' => $ljob->custnum, + 'insert_date' => $ljob->_date, + 'start_date' => $start_date, + 'end_date' => time, + }; + my $error = $queue_stat->insert; + die $error if $error; + dbh->commit; #for the stat + } + if ( UNIVERSAL::can(dbh, 'sprintProfile') ) { open(PROFILE,">%%%FREESIDE_LOG%%%/queueprofile.$$.".time) or die "can't open profile file: $!"; |