#---------------------------------------------------------------
# ____                   _ _         ____  _
#|  _ \ ___  _   _  __ _| | |_ _   _/ ___|| |__   __ _ _ __ ___
#| |_) / _ \| | | |/ _` | | __| | | \___ \| '_ \ / _` | '__/ _ \
#|  _ < (_) | |_| | (_| | | |_| |_| |___) | | | | (_| | | |  __/
#|_| \_\___/ \__, |\__,_|_|\__|\__, |____/|_| |_|\__,_|_|  \___|
#            |___/             |___/
#
# Copyright (C) 2012 RoyaltyShare, Inc.   All Rights Reserved
#---------------------------------------------------------------

package RPS::LabelRoyalty::Fast::Script::RunLabelRoyalties;

use strict;
use Data::Dumper;
use File::Path;

use lib '/app/tools/common/lib';
use lib '/app/tools/rps/lib';
use lib '/app/tools/raptor/lib';

use DB_File;

use Common::Log;

use Common::RSApp;
use RPS::DB::Item::LabelRoyaltyRun;
use RPS::RoyaltyRun::Status;
use RPS::Statement::Label::PDF;
use RPS::LabelRoyalty::Job::CreatePDFStatements;

use base 'Common::Script';

sub _options {
    {
        client_id => {
            short       => 'c',
            required    => 1,
            description => 'Limit to this client id',
            parameter   => 'i'
        },
        run_id => {
            short       => 'r',
            required    => 1,
            description => 'The label_royalty_run_id we are creating statements for.',
            parameter   => 'i',
        },
        verbosity => {
            short       => 'V',
            required    => 0,
            description => 'Specify log level, old style',
            parameter   => 'i',
        },
    };
}

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

    my $runID = $self->param('run_id');

    Log->warn("Beginning royalty run $runID");

    # Read in the run record, so we can get the correct payor_id.
    #
    my $runData = RPS::DB::Item::LabelRoyaltyRun->Lookup( label_royalty_run_id => $runID );
    die "ERROR - invalid run id $runID" unless $runData;

    # JPK - For now, we'll assume that we're going to run everything on a single host.
    #

    # !!! These values should probably come from the config file system, but for the moment
    # !!! I will hard-code them.
    #
    my $staticDataPath = "/app/data/label_royalty_run/" . Common::RSApp::GetClientID() . "/" . $runID;
    my $outputDataPath = $staticDataPath . "/output";

    eval { $self->_runRoyalties( $runData, $staticDataPath, $outputDataPath ); };
    if ($@) {
        $runData->status(RPS::RoyaltyRun::Status::kError);

        #        $runData->error($@);
        $runData->end_time(Common::DB::Item::kDateTimeNow);
        Log->crit($@);
        $runData->save();
        die;
    }

    Log->warn("Finished royalty run $runID");

}

sub _runRoyalties {
    my ( $self, $runData, $staticPath, $outputPath ) = @_;

    my $binDir = '/app/tools/rps/lib/RPS/LabelRoyalty/Fast/bin';

    $runData->status(RPS::RoyaltyRun::Status::kRunning);
    $runData->start_time(Common::DB::Item::kDateTimeNow);
    $runData->pid($$);
    $runData->save();

    my $runID                = $runData->label_royalty_run_id();
    my $clientID             = Common::RSApp::GetClientID();
    my $salesMapProcessCount = 12;

    my @commands = (
        "$binDir/stageData.pl -c $clientID -r $runID -d $staticPath",
        "$binDir/mapPayees.pl  -c $clientID -d $staticPath -o $outputPath",
        "$binDir/mapSales.pl  -c $clientID -d $staticPath -o $outputPath -p$salesMapProcessCount",
        "$binDir/mapTransactions.pl  -c $clientID -d $staticPath -o $outputPath -vvv",
        "sort -s -t'" . "\t"
          . "' -k1,1n -k2,2n -k3,3n -k4,4n -k29,29n -k8,8n -k7,7n -k12,12 -k9,9 -k10,10 -k23,23 -k24,24n -k25,25n -k19,19 -k20,20 -k11,11n -k21,21 -k13,13n -k14,14n -k15,15n -k16,16n -k17,17 $outputPath/mapped_data_* > $outputPath/mapped_data.sorted",
        "$binDir/assembleStatements.pl -c $clientID -r $runID -s $staticPath -o $outputPath",
        "$binDir/commitFinalData.pl -c $clientID -r $runID -o $outputPath",

        #        "$binDir/mapReserves.pl -c $clientID -d $staticPath -o $outputPath",
        #        "$binDir/mapExpenses.pl -c $clientID -d $staticPath -o $outputPath",
        #        "$binDir/mapLicenseIncomeSales.pl  -c $clientID -d $staticPath -o $outputPath",
        #        "$binDir/mapPendingTransactions.pl  -c $clientID -d $staticPath -o $outputPath",
        #        "$binDir/mapPayees.pl  -c $clientID -d $staticPath -o $outputPath",
        #        "$binDir/mapAlbumContractAccounts.pl  -c $clientID -d $staticPath -o $outputPath",
        #        'sort -n -t$'."'\t' -k1 -k2 -k3 -k4 $outputPath/missed_sales_* > $outputPath/missed_sales.sorted",
        #        "$binDir/assembleMissedSaleLog.pl -c $clientID -r $runID -d $staticPath -o $outputPath",
    );

    foreach my $cmd (@commands) {
        Log->warn("executing: $cmd");
        my $status = system($cmd);
        die "ERROR EXECUTING '$cmd': ($?) $!" unless 0 == $status;
    }

    $runData->status(RPS::RoyaltyRun::Status::kComplete);
    $runData->end_time(Common::DB::Item::kDateTimeNow);
    $runData->save();

    # Finally, queue up the job to create PDF statements.
    #
    my $statementPath = RPS::Statement::Label::PDF::StatementPathFromRunID( $runID, $clientID );
    if ( !-d $statementPath ) {
        mkpath($statementPath) or die "ERROR: Unable to create path $statementPath: $!\n";
    }

    my $jobArgs = RPS::LabelRoyalty::Job::CreatePDFStatements->new(
        runID    => $runID,
        clientID => $clientID,
        filePath => $statementPath,
    );
    my $job = $jobArgs->enqueue();
}

1;