X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=FS%2Fbin%2Ffreeside-eftca-download;h=56d82c7f5e4001b404dc33480f84a436c3a72bdc;hp=3d717bcc6ec98a63491dad285783e69a653d43e1;hb=HEAD;hpb=db4d8679af26c301cb66f3f3da7f7cd7a3ae4854

diff --git a/FS/bin/freeside-eftca-download b/FS/bin/freeside-eftca-download
index 3d717bcc6..56d82c7f5 100755
--- a/FS/bin/freeside-eftca-download
+++ b/FS/bin/freeside-eftca-download
@@ -11,6 +11,7 @@ use FS::Record qw(qsearch qsearchs);
 use FS::pay_batch;
 use FS::cust_pay_batch;
 use FS::Conf;
+use FS::Log;
 
 use vars qw( $opt_v $opt_a );
 getopts('va:');
@@ -38,87 +39,143 @@ my @fields = (
 my $user = shift or die &HELP_MESSAGE;
 adminsuidsetup $user;
 
+my $log = FS::Log->new('freeside-eftca-download');
+log_info( "EFT Canada download started\n" );
+
 if ( $opt_a ) {
-  die "no such directory: $opt_a\n"
+  log_error_and_die( "no such directory: $opt_a\n" )
     unless -d $opt_a;
-  die "archive directory $opt_a is not writable by the freeside user\n"
-    unless -w $opt_a;
+  log_error_and_die(
+    "archive directory $opt_a is not writable by the freeside user\n"
+  ) unless -w $opt_a;
 }
 
 #my $tmpdir = File::Temp->newdir();
 my $tmpdir = tempdir( CLEANUP => 1 ); #DIR=>somewhere?
 
 my $conf = new FS::Conf;
-my @batchconf = $conf->config('batchconfig-eft_canada');
-# BIN, terminalID, merchantID, username, password
-my $username = $batchconf[0] or die "no EFT Canada batch username configured\n";
-my $password = $batchconf[1] or die "no EFT Canada batch password configured\n";
-
-my $host = 'ftp.eftcanada.com';
-print STDERR "Connecting to $username\@$host...\n" if $opt_v;
-
-my $sftp = Net::SFTP::Foreign->new( host => $host,
-                                    user => $username,
-                                    password => $password,
-                                    timeout => 30,
-                                    );
-die "failed to connect to '$username\@$host'\n(".$sftp->error.")\n" if $sftp->error;
 
-$sftp->setcwd('/Returns');
+my @agents;
+if ( $conf->exists('batch-spoolagent') ) {
+  local $@;
+  eval { @agents = qsearch('agent', { 'disabled' => '' }); };
+  log_error_and_die("Fatal database error: $@")
+    if $@;
+} else {
+  @agents = (1);
+}
 
-my $files = $sftp->ls('.', wanted => qr/^ReturnFile/, names_only => 1);
-die "no response files found\n" if !@$files;
+foreach my $agent (@agents) {
 
-FILE: foreach my $filename (@$files) {
-  print STDERR "Retrieving $filename\n" if $opt_v;
-  $sftp->get("$filename", "$tmpdir/$filename");
-  if($sftp->error) {
-    warn "failed to download $filename\n";
-    next FILE;
+  my @batchconf;
+  if ( $conf->exists('batch-spoolagent') ) {
+    @batchconf = $conf->config('batchconfig-eft_canada', $agent->agentnum, 1);
+    if ( !length($batchconf[0]) ) {
+      log_info(
+        "agent '".$agent->agent.
+        "' has no batchconfig-eft_canada setting; skipped.\n"
+      );
+      next;
+    }
+  } else {
+    @batchconf = $conf->config('batchconfig-eft_canada');
   }
+  # user, password, transaction code, delay days
+  my $user = $batchconf[0]
+    or log_error_and_die( "no EFT Canada batch username configured\n" );
+  my $pass = $batchconf[1]
+    or log_error_and_die( "no EFT Canada batch password configured\n" );
+
+  my $host = 'ftp.eftcanada.com';
+  log_info( "Connecting to $user\@$host...\n" );
+
+  my $sftp = Net::SFTP::Foreign->new( host     => $host,
+                                      user     => $user,
+                                      password => $pass,
+                                      timeout  => 30,
+                                    );
+  log_error_and_die("failed to connect to '$user\@$host'\n(".$sftp->error.")\n")
+    if $sftp->error;
 
-  #move to server archive dir
-  $sftp->rename("$filename", "Archive/$filename");
-  if($sftp->error) {
-    warn "failed to archive $filename on server\n";
-  } # process it anyway though
-
-  #copy to local archive dir
-  if ( $opt_a ) {
-    print STDERR "Copying $tmpdir/$filename to archive dir $opt_a\n"
-      if $opt_v;
-    system 'cp', "$tmpdir/$filename", $opt_a;
-    warn "failed to copy $tmpdir/$filename to $opt_a: $@" if $@;
-  }
+  $sftp->setcwd('/Returns');
 
-  open my $fh, "<$tmpdir/$filename";
-  # Some duplication with FS::pay_batch::import_results, but we're really 
-  # doing something different here.
-  my $csv = new Text::CSV_XS ( { quote_char => undef, sep_char => '|' } );
-  my %hash;
-  while (my $line = <$fh>) {
-    next if $line =~ /^\s*$/;
-    $csv->parse($line) or do {
-      warn "can't parse $filename: ".$csv->error_input."\n";
-      next FILE; #parsing errors = reading the wrong kind of file
-    };
-    @hash{@fields} = $csv->fields();
-    print STDERR "voiding paybatchnum#$hash{paybatchnum}\n" if $opt_v;
-    my $cpb = qsearchs('cust_pay_batch', 
-                        { paybatchnum => $hash{'paybatchnum'} });
-    if ( !$cpb ) {
-      warn "can't find paybatchnum #$hash{paybatchnum} ($hash{first} $hash{last}, $hash{paid})\n";
-      next;
+  my $files = $sftp->ls('.', wanted => qr/\.txt$/, names_only => 1);
+  log_info_and_die( "Finished: No response files found\n" )
+    if !@$files;
+
+  FILE: foreach my $filename (@$files) {
+    log_info( "Retrieving $filename\n" );
+    $sftp->get("$filename", "$tmpdir/$filename");
+    if($sftp->error) {
+      log_info( "failed to download $filename\n" );
+      next FILE;
     }
-    my $error = $cpb->decline("Returned payment ($hash{returncode})");
-    if ( $error ) {
-      warn "can't void paybatchnum #$hash{paybatchnum}: $error\n";
+
+    #move to server archive dir
+    $sftp->rename("$filename", "Archive/$filename");
+    if($sftp->error) {
+      log_info(  "failed to archive $filename on server\n" );
+    } # process it anyway though
+
+    #copy to local archive dir
+    if ( $opt_a ) {
+      log_info( "Copying $tmpdir/$filename to archive dir $opt_a\n" );
+      system 'cp', "$tmpdir/$filename", $opt_a;
+      log_info( "failed to copy $tmpdir/$filename to $opt_a: $@" )
+        if $@;
     }
+
+    open my $fh, "<$tmpdir/$filename";
+    # Some duplication with FS::pay_batch::import_results, but we're really 
+    # doing something different here.
+    my $csv = new Text::CSV_XS ( { quote_char => undef, sep_char => '|' } );
+    my %hash;
+    while (my $line = <$fh>) {
+      next if $line =~ /^\s*$/;
+      $csv->parse($line) or do {
+        log_info( "can't parse $filename: ".$csv->error_input."\n" );
+        next FILE; #parsing errors = reading the wrong kind of file
+      };
+      @hash{@fields} = $csv->fields();
+      log_info( "voiding paybatchnum#$hash{paybatchnum}\n" );
+      my $cpb = qsearchs('cust_pay_batch', 
+                          { paybatchnum => $hash{'paybatchnum'} });
+      if ( !$cpb ) {
+        log_info(
+          "can't find paybatchnum #$hash{paybatchnum} ".
+          "($hash{first} $hash{last}, $hash{paid})\n"
+        );
+        next;
+      }
+      my $error = $cpb->decline("Returned payment ($hash{returncode})");
+      if ( $error ) {
+        log_info( "can't void paybatchnum #$hash{paybatchnum}: $error\n" );
+      }
+    }
+    close $fh;
   }
-  close $fh;
+
 }
 
-print STDERR "Finished!\n" if $opt_v;
+log_info( "Finished!\n" );
+
+sub log_info {
+  my $log_message = shift;
+  $log->info( $log_message );
+  print STDERR $log_message if $opt_v;
+}
+
+sub log_info_and_die {
+  my $log_message = shift;
+  $log->info( $log_message );
+  die $log_message;
+}
+
+sub log_error_and_die {
+  my $log_message = shift;
+  $log->error( $log_message );
+  die $log_message;
+}
 
 =head1 NAME