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

package RPS::ArtistRoyalty::Fast::Script::MapPayees;

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::Util;
use Common::Log;
use Common::Parser;
use Common::WriteXML;

use RPS::ArtistRoyalty::Fast::Static::ArtistPayeeAccounts;
use RPS::ArtistRoyalty::Fast::Mapped::Data;


use base 'Common::Script';


sub _options {{
    client_id => 
    {
        short       => 'c',
        required    => 1,
        description => 'Limit to this client id',
        parameter    => 'i'
    },
    data_path => 
    {
        short       => 'd',
        required    => 1,
        description => 'path to directory containing static data',
        parameter    => 's'
    },
    output_path => 
    {
        short       => 'o',
        required    => 1,
        description => 'path to directory to write output files',
        parameter    => 's'
    },
}}



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

    my $dataPath = $self->param('data_path');

    my $outputDirectory = $self->param('output_path');

    # JPK - Should it be the responsibility of this process to create the directory if
    # it doesn't already exist?   It's a bit of a stretch, but then again it's convenient...
    #
    if (! -d $outputDirectory)
    {
        # !!! Might want to make this behavior optional...
        #
        mkpath($outputDirectory);
    }


    # !!! Need to make this even more generic. 
    # !!! We want to emit a statement for every payee that is not inactive.

    Log->info("Getting Payee IDs");
    my $accounts = RPS::ArtistRoyalty::Fast::Static::ArtistPayeeAccounts->GetArtistPayeeAccounts($dataPath); 


    my $fd = $self->_openFileDescriptor($outputDirectory);
    
    while (my ($artistPayeeID, $dataString) = each %$accounts)
    {
        $self->_outputLine($fd, $artistPayeeID);
    }
}


sub _openFileDescriptor
{
    my ($self, $outputDirectory) = @_;

    open OUTPUT, "> $outputDirectory/" . RPS::ArtistRoyalty::Fast::Mapped::Data->FileName() . "_$$.unsorted" or die "ERROR: $!";

    return *OUTPUT;
}



sub _outputLine
{
    my ($self, $outFD, $artistPayeeID) = @_;

    # All this does is put a 'no-op' line in the data stream with the payee_id.
    # This will cause us to create a Statement for every Payee that has an account.
    #

my $gFormatString = 
       '%12d'  # payee_id        
     . "\t".'%12d'  # album_id - let's set this to 0 explicitly
     . "\t".'%12d'  # set this to 0 as well
     . "\t". RPS::ArtistRoyalty::Fast::Mapped::Data::kTypePayee
     . "\t".'0'     # type      
     . "\t".'%12d'  # and this 
     . "\t".'%12d'  # and this.  These first 6 fields are shared amongst all types.
     . "\n";

    print $outFD sprintf($gFormatString, 
     $artistPayeeID,
     0,
     0,
     0,
     0,
     );
}


1;