#!/usr/bin/perl

use strict;
use Getopt::Std;
use IO::File;
use Date::Calc;
use Data::Dumper;

use lib '/app/tools/common/lib';
use Common::RSDB;
use Common::RSApp;
use Common::Assert;

use lib '/app/tools/rps/lib';
use RPS::DB::Item::Expense;
use RPS::DB::Item::ExpenseType;
use RPS::DB::Item::ExpenseName;

=begin
select nac.artist_contract_id, ac.album_contract_id
from new_artist_contract nac, artist_payee ap, album_contract ac, album a
where nac.artist_payee_id=ap.artist_payee_id
  and a.album_id=ac.album_id
  and ac.artist_contract_id=nac.artist_contract_id
  and a.catalog_number='HMU 907231'
  and ap.client_account_id='2120-1029';
=cut

# Parse the command-line.
#
my ( $clientID, $inputFile ) = parseCommandLine();

$| = 1;

my $rsdb = Common::RSDB->new( client_id => $clientID );

# Instantiate the application singleton object.
#
my $appSingleton = Common::RSApp->new( clientID => $clientID );

# create expense name
#
my $expenseNameObj = RPS::DB::Item::ExpenseName->Lookup( name => "Advance" );

if ( !$expenseNameObj ) {
    $expenseNameObj = RPS::DB::Item::ExpenseName->Create( name => "Advance" );
    $expenseNameObj->save();
}

my $matched   = 0;
my $unmatched = 0;
my $skipped   = 0;

my $sql = "
select nac.artist_contract_id, ac.album_contract_id
from new_artist_contract nac, artist_payee ap, album_contract ac, album a
where nac.artist_payee_id=ap.artist_payee_id
  and a.album_id=ac.album_id
  and ac.artist_contract_id=nac.artist_contract_id
  and a.catalog_number like ?
  and ap.client_account_id=?
";
my %contractExpenseType = ();
open( F, $inputFile ) or die "oops $!\n";
while (<F>) {
    chop;
    s/"//g;
    my ( $acctID, $title, $amount, $junk, $payeeID, $note, $catID ) = split /\t/;
    my @fields = split /\t/;

    if ( $amount == 0 ) {
        $skipped++;
        next;
    }

    $catID = "%$catID" unless ( $catID =~ m/^4/ );
    my $sth = $rsdb->DoCmdWithPlaceholders( $sql, [ $catID, $payeeID ] );
    unless ( $sth->rows ) {
        print "no match for cat: $catID, payee: $payeeID\n";
        $unmatched++;
        next;
    }

    if ( $sth->rows > 1 ) {
        print "multimatch $catID $payeeID\n";
        next;
    }

    $matched++;
    my ( $artistContractID, $albumContractID ) = $sth->fetchrow_array();
    print "found match for cat: $catID, payee $payeeID ($artistContractID, $albumContractID)\n";

    #next;

    if ( !$contractExpenseType{$artistContractID} ) {

        # create an expense type for advance
        #
        my $newExpenseType = RPS::DB::Item::ExpenseType->Create(
            artist_contract_id => $artistContractID,
            expense_name_id    => $expenseNameObj->expense_name_id,
            percent            => 100,
        );
        $newExpenseType->save();
        $contractExpenseType{$artistContractID} = $newExpenseType->expense_type_id;
    }

    my %params = (
        expense_type_id => $contractExpenseType{$artistContractID},
        amount          => $amount,
        parent_type     => RPS::DB::Item::Expense::kParentAlbumContract(),
        parent_id       => $albumContractID,

        # usually this would be copied from the expense type, but we'll just hard code it here because we know it should always be 100
        percent => 100,
        memo    => $note,
    );
    my $newExpense = RPS::DB::Item::Expense->Create(%params);
    $newExpense->save();
}

print "skipped: $skipped\nunmatched: $unmatched\nmatched: $matched\n";

sub parseCommandLine {
    my %opt;
    getopts( 'c:f:', \%opt );

    my $clientID  = $opt{c};
    my $inputFile = $opt{f};

    unless ( $clientID =~ /^\d+$/ && $clientID > 0 ) {
        die usage("You must specify a valid client ID");
    }

    unless ($inputFile) {
        die usage("You must specify a catalog file to import");
    }

    unless ( -e $inputFile ) {
        die usage("The specified catalog file does not exist");
    }

    return ( $clientID, $inputFile );
}

sub usage {
    my $errstr = shift;
    my $text = ($errstr) ? "ERROR: $errstr\n" : '';
    $text .= "Usage: $0 -c <clientID> -f <inputFile>\n";
    return $text;
}