package RPS::Import::eMusicData;

use strict;


use Date::Calc qw(Days_in_Month);

use lib '/app/tools/common/lib';
use Common::Util;
use Common::Consts;

use lib '/app/tools/data_classes/lib';

# map version num to the field order
my %field_map = (
				 4 => {
				 		'label'			=> 2,
						'vendorid'		=> 3,
						'track'			=> 4,
						'artist'		=> 5,
						'album'			=> 6,
						'isrc'			=> 7,
						'units'			=> 10,
						'splitrevenue'	=> 12,
						'split'			=> 13,
						'currency'  => 5,
						},

				 5 => {
						'vendorid'	=> 0,
				 		'tracknum'	=> 1,
						'track'		=> 2,
						'artist'	=> 4,
						'upc'		=> 5,
						'isrc'		=> 6,
						'album'		=> 7,
						'units'		=> 8,
						'price'		=> 9,
						'currency'  => 5,
						},

				 6 => {
				 		'label'			=> 2,
						'vendorid'		=> 3,
						'track'			=> 4,
						'artist'		=> 5,
						# 'album' 		=> undef,
						'isrc'			=> 6,
						'units'			=> 9,
						'splitrevenue'	=> 11,
						'split'			=> 12,
						'currency'  => 5,
						},
				 7 => {
						'datasheet'	=> 1,
						'vendorid'	=> 0,
						'isrc'		=> 1,
						'upc'		=> 2,
						'artist'	=> 3,
						'album'		=> 4,
				 		'tracknum'	=> 5,
						'track'		=> 6,
						'units'		=> 8,
						'price'		=> 12,
						'currency'  => 5,
						},
				 8 => { # same as version 5 with 2 unused columns prepended
						'vendorid'	=> 2,
				 		'tracknum'	=> 3,
						'track'		=> 4,
						'artist'	=> 6,
						'upc'		=> 7,
						'isrc'		=> 8,
						'album'		=> 9,
						'units'		=> 10,
						'price'		=> 11,
						'currency'  => 5,
						},
				 13 => {  # same as v.7, but the file doesn't have the first (blank) tab
						'vendorid'	=> 0,
						'isrc'		=> 1,
						'upc'		=> 2,
						'artist'	=> 3,
						'album'		=> 4,
				 		'tracknum'	=> 5,
						'track'		=> 6,
						'units'		=> 8,
						'price'		=> 12,
						'currency'  => 5,
						},
				 '13eu' => {  # european sub-version; too difficult to determine from File.pm
						'vendorid'	=> 0,
						'isrc'		=> 1,
						'upc'		=> 2,
						'artist'	=> 3,
						'album'		=> 4,
				 		'tracknum'	=> 5,
						'track'		=> 6,
						'country'	=> 8,
						'units'		=> 9,
						'price'		=> 11,
						'currency'  => 5,
						},
				 '13pd' => {  # sub-version with public domain stuff
						'vendorid'	=> 0,
						'isrc'		=> 1,
						'upc'		=> 2,
						'artist'	=> 3,
						'album'		=> 4,
				 		'tracknum'	=> 5,
						'track'		=> 6,
						'country'	=> 8,
						'units'		=> 9,
						'price'		=> 13,
						'currency'  => 5,
						},
				 '13tp' => {  # sub-version with total payable to be used in place of price
						'vendorid'	=> 0,
						'isrc'		=> 1,
						'upc'		=> 2,
						'artist'	=> 3,
						'album'		=> 4,
				 		'tracknum'	=> 5,
						'track'		=> 6,
						'units'		=> 8,
						'price'		=> 13,
						'currency'  => 5,
						},						
				 14 => { # like 8 but with country
						'vendorid'	=> 2,
				 		'tracknum'	=> 3,
						'track'		=> 4,
						'artist'	=> 6,
						'upc'		=> 7,
						'isrc'		=> 8,
						'album'		=> 9,
						'country'	=> 10,
						'units'		=> 11,
						'price'		=> 12,
						'currency'  => 5,
						},
				 16 => { # like 14 but with public domain
						'vendorid'	=> 2,
				 		'tracknum'	=> 3,
						'track'		=> 4,
						'artist'	=> 6,
						'upc'		=> 7,
						'isrc'		=> 8,
						'album'		=> 9,
						'country'	=> 10,
						'units'		=> 11,
						'price'		=> 13,
						'currency'  => 5,
					},
                  17 => {
                        'vendorid'  => 0,
                        'tracknum'  => 5,
                        'track'     => 6,
                        'artist'    => 3,
                        'upc'       => 2,
                        'isrc'      => 1,
                        'album'     => 4,
                        'units'     => 8,
                        'price'     => 12,
						'currency'  => 5,
                   },
                  18 => {			'vendorid'	=> 2,
				 		'tracknum'	=> 4,
						'track'		=> 5,
						'artist'	=> 7,
						'upc'		=> 8,
						'isrc'		=> 9,
						'album'		=> 10,
						'country'	=> 11,
						'units'		=> 12,
						'price'		=> 18,
						'currency'  => 5,
						},
		20 => {'vendorid'       => 3,
                       'tracknum'       => 5,
                       'track'          => 6,
                       'artist'         => 8,
                       'upc'            => 9,
                       'isrc'           => 10,
                       'album'          => 11,
                       'country'        => 12,
                       'units'          => 13,
                       'currency'       => 14,
                       'price'          => 19,                       
                       },
                   
				 );

use lib '/app/tools/rps/lib';
use RPS::File::Sale;
use RPS::Import::Importer;
use base 'RPS::Import::Importer';

#public methods

sub _importLines
{
	my $self = shift;
	my %args = @_;

	my $retval = undef;
	my $fileObj = $args{file};
	my $fileName = $fileObj->OrigFileName;
	my $version = $fileObj->VersionNum;
    my $lines = $args{sheets}->[$field_map{$version}{datasheet} || 0]; 

    $version = $self->_isEuroFileV13($lines) if ($version == 13);

	return unless ($lines && $fileName && $version);
	
	my($dateBegin, $dateEnd);
	
    ($dateBegin, $dateEnd) = $self->_getDates($fileName);
    
    unless ($dateBegin && $dateEnd)
    {
        $self->errstr("couldn't get dates");
        return;
    }

    my $country;

    if ($version eq '13tp')
    {   
        # No country column in this version.
        $country = $self->_getCountry($fileName);
        $country = 'FR' if ($country eq 'FX'); ## special french thing              
        unless ($country)
        {
            $self->errstr("couldn't get country from filename");
            return;
        }                
    }    


    my $offsets;
    if($version && exists $field_map{$version})
    {
        $offsets = $field_map{$version};
    }
    else
    {
        $self->errstr("can't map version");
        return 0;
    }

    my $currencyCode;

    my $linenum = 1;
    foreach my $line(@$lines)
    {
        if ($linenum > 1)
        {
            my $prodtype	= RPS::File::Sale::TYPE_TRACK;
            my $format		= RPS::File::Sale::FORMAT_VPD;
            my $vendorID	= $line->[$offsets->{'vendorid'}];

            my $isrc		= Common::Util::normalize_isrc($line->[$offsets->{'isrc'}]);
            my $artist		= $line->[$offsets->{'artist'}];
            my $album;
            $album = $line->[$offsets->{'album'}] if (exists $offsets->{'album'});
            my $track		= $line->[$offsets->{'track'}];
            my ($units)		= $line->[$offsets->{'units'}] =~ m/^(-?\d+)$/;
            
            $currencyCode       = $line->[$offsets->{'currency'}] 
            if(defined $offsets->{'currency'});

            my ($label, $upc, $trackNum, $price);


            # !!! Here's a lovely hack.
            #
            if (lc($line->[$offsets->{'currency'}]) eq 'all currency in euros')
            {
                $currencyCode = 'EUR';
            }
            elsif (20 != $version)
            {
                $currencyCode = undef;
            }

            if ($version =~ /^(13eu|13pd|14|16|18|20)$/)
            {
                $country = $line->[$offsets->{'country'}];
                $country = 'FR' if ($country eq 'FX'); ## special french thing
            }        
            
            if ($version =~ /^(5|7|8|13|13eu|13tp|13pd|14|16|17|18|20)$/)
            {
                $upc		= Common::Util::normalize_upc($line->[$offsets->{'upc'}]);
                $trackNum	= $line->[$offsets->{'tracknum'}];
                ($price)	= $line->[$offsets->{'price'}] =~ m/^(-?\d*(\.\d*)?)$/;

                if ( $trackNum && $trackNum == -1 )
                {
                    $prodtype = RPS::File::Sale::TYPE_ALBUM;
                }

                $price /= $units if ($version =~ /^(7|13|13eu|13tp|13pd|17|18|20)$/ and $units > 0);

                if ($price)
                {
                    $price = sprintf("%.8f", $price);

                    # emusic reversed negative figures out of the total paid starting Q2 2004
                    if ($price < 0 && $dateEnd ge '2004-04-01')
                    {
                        if ( $units > 0 )
                        {
                            # Per FB13514, positive units with negative revenue is a return, so
                            # import the negative revenue as a positive number, and negate
                            # the units information.
                            #
                            $price *= -1;
                            $units *= -1;
                        }
                        else
                        {
                            # This shouldn't happen.
                            #
                            $self->errstr("Detected negative or zero units with negative revenue in line $linenum");
                            return undef;
                        }
                    }
                }
            }
            else
            {
                $label			= $line->[$offsets->{'label'}];
                my ($splitRev)	= $line->[$offsets->{'splitrevenue'}] =~ m/^(-?\d*(\.\d*)?)$/;
                my ($split)		= $line->[$offsets->{'split'}] =~ m/^(\d*\.\d*)$/;

                # emusic reversed negative figures out of the total paid starting Q2 2004
                if ($units && ($splitRev > 0 || $dateEnd lt '2004-04-01'))
                {
                    $price = sprintf("%.8f", ($splitRev * $split) / $units);
                }
                else
                {
                    $price = 0;
                }
            }

            if ($units && defined($price) && $track)
            {
                my $sale = RPS::Import::SaleRec->new();

                $sale->productType($prodtype);
                $sale->formatType($format);
                $sale->dateBegin($dateBegin);
                $sale->dateEnd($dateEnd);
                $sale->serviceProductID($vendorID);
                $sale->upc($upc);
                $sale->isrc($isrc);
                $sale->artistName($artist);
                $sale->albumName($album);
                $sale->trackName($track);
                $sale->labelName($label);
                $sale->trackNum($trackNum);
                $sale->units($units);
                $sale->price($price);
                if ($version =~ /^(13eu|13pd|13tp|14|16|18|20)$/){
                    $sale->countryCode($country);
                } 
                else{
                    $sale->countryCode('US');
                }                               
                $sale->currencyCode($currencyCode) if ($currencyCode);
                $sale->lineNum($linenum);

                $self->_insertSale(sale => $sale);
            }
        }
        $linenum++;
    }
    $retval = $linenum;

	return $retval;
}

#
# Private methods
#

sub _getDates
{
    my $self = shift;
    my $fileName = shift;

    my $dateBegin;
    my $dateEnd;

    my ($quarter, $year);
    my $numerical;
    if ($fileName =~ m/Q([1234])(\d{2})/i) {
        $quarter = $1;
        $year    = $2;
    } elsif( $fileName =~ m/Q(1|2|3|4).?(\d+)/i ) {
        $quarter = $1;
        $year    = $2;
    } elsif ($fileName =~ m/_(\d{4})Q([1234])/) {
        $quarter = $2;
        $year    = $1;
    } elsif ($fileName =~ m/(\d{4}).([1234])\w\w.quarter/) {
        $quarter = $2;
        $year    = $1;
    }
    elsif ($fileName =~ /Q(\d)(\d{2,4})/){
        $quarter = $1;
        $year = $2;
    }elsif($fileName =~ /(20\d\d)(\d\d)/){            
        $numerical = "$2"."-"."$1";       
    }	    
    else{
       return undef;
    }  
        
    if($quarter && $year)
    {
       if($year < 2000){
           $year += 2000;
       }
       
       ($dateBegin, $dateEnd) = 
        $self->SUPER::_getDates(date_begin=>"Q$quarter$year", type=>"quarter");
    }
    elsif($numerical){
       ($dateBegin, $dateEnd) = 
	$self->
	SUPER::_getDates(date_begin=>$numerical, type=>"numerical");
    }

     return ($dateBegin, $dateEnd);
}

sub _getCountry
{
	my $self = shift;
	my $fileName = shift;

	my $country;
	
	if($fileName =~ /USD/){
	    return "US";
	}
	elsif($fileName =~ /CAD/){
	    return "CA";
	}
	#if (($fileName =~ m/(\D{3})_+Q(1|2|3|4)(\w+)/i) || (($fileName =~ m/emusic (\D{3}) \d{4}/i)))
	#{
    #my $currencyCode = $1;
    #if ($currencyCode eq 'CAD') 
    #{
    #  $country = 'CA';
    #}
    #elsif ($currencyCode eq 'USD')
    #{
    #  $country = 'US'; 
    #}
    #else
    #{
    #  return undef; 
    #}      
  #}
  #else
  #{
  #  return undef; 
  #}

   return undef;
}


sub _isEuroFileV13 {
    my $self = shift;
    my $lines = shift;
    my $offsets = $field_map{'13'};

    foreach my $line (@$lines) {
        if ($line->[$offsets->{'artist'}] eq 'Artist' &&
            $line->[$offsets->{'album'}] eq 'Album Title' &&
            $line->[$offsets->{'track'}] eq 'Track Title') {
            if ($line->[$offsets->{'units'}] eq 'Territory') {
                if ($line->[$offsets->{'price'}] eq 'Net Royalty Pool Per Track') {                		
                    print STDERR "version: 13pd\n";
                    return '13pd';
                }
                print STDERR "version: 13eu ".($line->[$offsets->{'price'}])."\n";
                return '13eu';
            }
        		if ($line->[$offsets->{'price'} + 1] =~ m/^Total Payable/) {
                print STDERR "version: 13tp\n";
                return '13tp';                			               			
        		}            
            print STDERR "version: 13\n";
            return 13;
        }
    }
}

###
1;# Play nicely.
###