#!/usr/bin/perl
#------------------------------------------------------------
# Copyright (C) 2006 RoyaltyShare, Inc.   All Rights Reserved
# $Id$
#------------------------------------------------------------
use strict;

use Data::Dumper;
use Getopt::Std;
use POSIX qw(ceil);
use Carp;

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

use lib '/app/tools/rps/lib';
use RPS::Mechanical::MechanicalRun;
use RPS::DB::Item::MechanicalRun;
use RPS::DB::Item::Product;
use RPS::DB::Item::Publisher;
use RPS::DB::Item::PublisherAccount;
use RPS::DB::Item::Track;
use RPS::DB::Item::TrackLicense;
use RPS::DB::Item::LicenseReserve;
use RPS::DB::Item::LicenseReserveRun;
use RPS::DB::Item::ReserveLiquidation;
use RPS::DB::Item::PendingTransaction;
use RPS::DB::Item::MechanicalStatement;
use RPS::DB::Item::MechanicalStatementTransaction;
use RPS::DB::Item::MechanicalStatementItem;
use RPS::DB::Item::MechanicalCarryover;
use RPS::DB::Item::MechanicalRunCarryover;
use RPS::DB::Item::MechanicalStatementLicense;
use RPS::DB::Item::SaleMechanicalStatementItemMap;
use RPS::DB::Item::FinanceAccount;
use RPS::DB::Item::FinanceTransaction;

use lib '/app/tools/raptor/lib';
use Raptor::DB::Item::Sale;

my $gVerbosityLevel = 1;
my $gRunLabel;

# Get the id from the command-line
#
my %options;
_parseCommandLine( \%options );
_rebuild( $options{clientID} );

sub _parseCommandLine {
    my ($settings) = @_;

    my %opt;
    getopts( 'c:V:', \%opt );

    if ( !$opt{c} ) {
        _usage();
        exit(1);
    }
    $settings->{clientID} = $opt{c};

    if ( defined $opt{V} ) {
        $gVerbosityLevel = $opt{V};
    }
}

sub _usage {
    print "\nusage: $0 -c <client_id> -r <mechanical_run_id>\n";
    print "\n";
    print "Arguments:\n";
    print "\t-c <client_id>\t\tThe client_id of the client to process\n";
    print "\t-r <mechanical_run_id>\t\tThe mechanical_run_id to commit\n";
}

sub _rebuild {
    my ($clientID) = @_;

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

    my $clientDB = Common::RSApp::GetClientDB();

    my $statementTransactions = RPS::DB::Item::MechanicalStatementTransaction->GetAll();
    while ( my $statementTrans = $statementTransactions->next() ) {
        my $statementItem =
          RPS::DB::Item::MechanicalStatement->Lookup( mechanical_statement_id => $statementTrans->mechanical_statement_id );
        next unless $statementItem;
        my $publisherID      = $statementItem->publisher_id;
        my $payorID          = $statementItem->payor_id;
        my $publisherAccount = RPS::DB::Item::PublisherAccount->Lookup( publisher_id => $publisherID, payor_id => $payorID );
        my $financeAccountID = $publisherAccount->finance_account_id;

        # Sanity check - should be exactly 1 finance transaction that will match.
        #
        my $where =
            "where finance_account_id=$financeAccountID"
          . " and amount="
          . $clientDB->DBQuote( $statementTrans->amount() )
          . " and type_code="
          . $clientDB->DBQuote( $statementTrans->type_code() );
        if ( defined $statementTrans->memo() ) {
            $where .= " and memo=" . $clientDB->DBQuote( $statementTrans->memo() );
        } else {
            $where .= " and memo is null";
        }
        if ( defined $statementTrans->check_number() ) {
            $where .= " and check_number=" . $clientDB->DBQuote( $statementTrans->check_number() );
        } else {
            $where .= " and check_number is null";
        }

        my $sql = "SELECT COUNT(*) FROM finance_transaction $where";

        my $sth   = $clientDB->DoCmd($sql);
        my $hr    = $sth->fetchrow_hashref();
        my $count = $hr->{'COUNT(*)'};
        die "ERROR: count is $count for finance account $financeAccountID statement trans: " . Dumper($statementTrans) if ( 1 != $count );

        # Create the new pending transaction.
        #
        my $newPending = RPS::DB::Item::PendingTransaction->Create(
            finance_account_id => $financeAccountID,
            amount             => $statementTrans->amount(),
            type_code          => $statementTrans->type_code(),
        );
        if ( defined $statementTrans->memo() ) {
            $newPending->memo( $statementTrans->memo() );
        }
        if ( defined $statementTrans->check_number() ) {
            $newPending->check_number( $statementTrans->check_number() );
        }
        $newPending->save();

        # Delete the finance_transaction.
        # (the old-fashioned way)
        #
        $clientDB->DoCmd("DELETE from finance_transaction $where");
    }
}

sub _report {
    my ( $string, $verbosity ) = @_;
    $verbosity = 1 unless defined $verbosity;

    if ( $gVerbosityLevel >= $verbosity ) {
        print STDERR $string . "\n";
    }
}