#!/usr/bin/perl -w

use strict;

Calculate->start();

package Calculate;

use lib '/app/tools/common/lib';
use lib '/app/tools/rps/lib';
use Common::RSApp;
use Common::Client;
use Common::Log;

use RPS::DB::Item::MechanicalRun;
use RPS::DB::Item::MechanicalStatementPublisher;
use RPS::DB::Item::Publisher;

use base 'Common::Script';

sub _options {
    {
        client_id => {
            short       => 'c',
            description => 'Limit to client id',
            required    => 0,
            parameter   => 'i'
        },
    };
}

# Override to only run on RPS clients.
#
sub _getProductionClientIDs {
    #
    # No reason to limit this to the 'local' clients...
    #
    return Common::RSDB::GetAllRPSClientIDs();
}

sub _getLocalClientIDs {
    return Common::RSDB::GetLocalRPSClientIDs();
}

sub run_process {
    my $self = shift;
    print("client\trun\tstmt\tpubID\tpubName\tprvBal\tsub\ttSub\tsTotal\tdue\tADJ\n");

    $self->SUPER::run_process();
}

sub _process {
    my ($self) = @_;

    my $client = Common::Client::Current();
    my $dbo    = Common::RSApp::GetClientDB();

    Log->notice("------------------------------------------------------------");
    Log->notice( "Starting " . $client->ClientName() );

    # So... need to find and fix on-hold stuff.
    # That should be swell.
    # Need to proceed in an orderly fashion, somehow.
    # Only want to look at runs from this year.
    # Need to follow all 'on-hold' publishers through each complete run.

    my %publishers;

    my $allRuns =
      RPS::DB::Item::MechanicalRun->GetAllLegacy("SELECT * FROM mechanical_run WHERE status in (1,2,5) ORDER BY mechanical_run_id asc");
    while ( my $run = $allRuns->next() ) {
        Log->info( " RUN: " . $run->mechanical_run_id );

        # Find the on-hold dudes for this run.
        #
        my $onHoldItems = RPS::DB::Item::MechanicalStatementPublisher->GetAll(
"SELECT * FROM mechanical_statement_publisher WHERE on_hold=1 AND mechanical_statement_id IN (select mechanical_statement_id from mechanical_statement where mechanical_run_id="
              . $run->mechanical_run_id()
              . ")" );
        while ( my $onHoldItem = $onHoldItems->next() ) {

            # For now, just stash this item.  We'll iterate over the lists later.
            # !!! Well, should we do that?   What if something goes on hold, then off hold, then back on again?
            # !!! Might need to adjust this logic to account for that.
            #
            push @{ $self->{_statementPublisherItems}{ $onHoldItem->publisher_id() } },
              { item => $onHoldItem, runID => $run->mechanical_run_id() };
            if ( !$publishers{ $onHoldItem->publisher_id() } ) {
                my $p = RPS::DB::Item::Publisher->Lookup( publisher_id => $onHoldItem->publisher_id() );
                my $name = $p->publisher_name;
                if ( $p->agent_id || $p->admin_id ) {
                    $name .= ' (*)';
                }
                $publishers{ $onHoldItem->publisher_id() } = $name;
            }
        }
    }

    # Now let's look at the items we've found
    #
    my $lastPubID = 0;
    my $adj       = 0;
    foreach my $publisherID ( sort { $a <=> $b } keys %{ $self->{_statementPublisherItems} } ) {
        if ( 0 != $lastPubID && $lastPubID != $publisherID ) {
            print( $client->ClientName() . "\t\t\t$lastPubID\t" . $publishers{$lastPubID} . "\t\t\t\t\t\t$adj\n" );
            $lastPubID = $publisherID;
            $adj       = 0;
        }
        $lastPubID = $publisherID;

        my $pubStatementItems = $self->{_statementPublisherItems}{$publisherID};
        foreach my $dataBlock (@$pubStatementItems) {
            my $item  = $dataBlock->{item};
            my $runID = $dataBlock->{runID};
            print(  $client->ClientName() . "\t"
                  . $runID . "\t"
                  . $item->mechanical_statement_id() . "\t"
                  . $item->publisher_id() . "\t"
                  . $publishers{$publisherID} . "\t"
                  . $item->previous_balance() . "\t"
                  . $item->subtotal() . "\t"
                  . $item->transaction_subtotal() . "\t"
                  . $item->statement_total() . "\t"
                  . $item->amount_due()
                  . "\n" );

            $adj += $item->statement_total() . "\n";
        }
    }
    if ($lastPubID) {
        print( $client->ClientName() . "\t\t\t$lastPubID\t" . $publishers{$lastPubID} . "\t\t\t\t\t\t$adj\n" );
    }

    Log->notice("------------------------------------------------------------");
    Log->notice(" ");

    $self->{_statementPublisherItems} = {};
}

1;