From: Mark Wells <mark@freeside.biz>
Date: Mon, 3 Dec 2012 19:47:37 +0000 (-0800)
Subject: don't queue spool_upload jobs until all queued_bill jobs are finished, #6802
X-Git-Url: http://git.freeside.biz/gitweb/?a=commitdiff_plain;h=245fa062729d5f48da967ec91f476ca075c5ebc0;p=freeside.git

don't queue spool_upload jobs until all queued_bill jobs are finished, #6802
---

diff --git a/FS/FS/Cron/upload.pm b/FS/FS/Cron/upload.pm
index dfdacf0d7..1f21ee96e 100644
--- a/FS/FS/Cron/upload.pm
+++ b/FS/FS/Cron/upload.pm
@@ -112,6 +112,29 @@ sub upload {
 
   } #!if cust_bill-ftp_spool
 
+  # if there's nothing to do, don't hold up the rest of the process
+  return '' if !@tasks;
+
+  # wait for any ongoing billing jobs to complete
+  if ($opt{m}) {
+    my $dbh = dbh;
+    my $sql = "SELECT count(*) FROM queue LEFT JOIN cust_main USING(custnum) ".
+    "WHERE queue.job='FS::cust_main::queued_bill' AND status != 'failed'";
+    if (@agents) {
+      $sql .= ' AND cust_main.agentnum IN('.
+        join(',', map {$_->agentnum} @agents).
+        ')';
+    }
+    my $sth = $dbh->prepare($sql) or die $dbh->errstr;
+    while (1) {
+      $sth->execute()
+        or die "Unexpected error executing statement $sql: ". $sth->errstr;
+      last if $sth->fetchrow_arrayref->[0] == 0;
+      warn "Waiting 5min for billing to complete...\n" if $DEBUG;
+      sleep 300;
+    }
+  }
+
   foreach (@tasks) {
 
     my $agentnum = $_->{agentnum};
@@ -166,21 +189,6 @@ sub spool_upload {
   local $FS::UID::AutoCommit = 0;
   my $dbh = dbh;
 
-  # wait for any ongoing billing jobs to complete
-  # (should this exclude status='failed')?
-  if ($opt{m}) {
-    my $sql = "SELECT count(*) FROM queue LEFT JOIN cust_main USING(custnum) ".
-    "WHERE queue.job='FS::cust_main::queued_bill'";
-    $sql .= " AND cust_main.agentnum = $agentnum" if $agentnum =~ /^\d+$/;
-    my $sth = $dbh->prepare($sql) or die $dbh->errstr;
-    while (1) {
-      $sth->execute()
-        or die "Unexpected error executing statement $sql: ". $sth->errstr;
-      last if $sth->fetchrow_arrayref->[0] == 0;
-      sleep 300;
-    }
-  }
-
   if ( $agentnum ) {
     my $agent = qsearchs( 'agent', { agentnum => $agentnum } )
       or die "no such agent: $agentnum";