package RPS::Import::RSOutFmt;

use strict;
use Date::Calc qw(Days_in_Month  Add_Delta_Days);

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

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

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

# map version num to the field order
my %fieldMap =
(
	1 =>
	{
		'label'	    	=> 0,
		'service_id'	=> 1,
    'service_name'  => 2,
		'country'		=> 3,
		'start_date'	=> 4,
		'end_date'		=> 5,
		'ptype'			=> 6,
		'format'   		=> 7,
		'catno'   		=> 8,
		'upc'   		=> 9,
		'album'	    	=> 11,
		'artist'		=> 12,
		'isrc'			=> 18,
		'tracknum'	   	=> 21,
		'track'	    	=> 22,
		'units'	    	=> 27,
		#'price'	    	=> 28,
		'ext_price'	    	=> 29,
		'currency'	   	=> 30,
		'convrate'	   	=> 31,
		'free'  	   	=> 34,
		'price'         => 36,
	},
    2 =>
    {
        'label'             => 0,
        'service_id'        => 1,
        'service_name'      => 2,
        'outlet'            => 2,
        'country'           => 4,
        'start_date'        => 5,
        'end_date'          => 6,
        'ptype'             => 7,
        'format'            => 8,
        'catno'             => 9,
        'upc'               => 10,
        'album'             => 12,
        'album_artist'      => 13,
        'isrc'              => 19,
        'tracknum'          => 22,
        'track'             => 23,
        'artist'            => 24,
        'units'             => 28,
        'price'             => 29,
        'ext_price'         => 30,
        'currency'          => 31,
        'convrate'          => 32,
        'unit_price'        => 33,
        'free'              => 35,
        'dist_fee'          => 36,
        'net_price'         => 37,
    },
);

#public methods

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

	my $lines = $args{lines};
	my $fileObj = $args{file};
	my $version = $self->_version;
	
	my $currency_code;

    return undef unless (defined $lines && defined $version);

	my $offsets = $fieldMap{$version};

    my $linenum = 1;
    foreach my $line (@$lines)
    {
        if ($line->[$offsets->{label}] eq 'label-name') {
        
            if($version == 2){
                   my $currency_code_str = $line->[$offsets->{unit_price}];
                   
                   $currency_code_str =~ /([^-]+)-unit-price/;
                   
                   $currency_code = uc $1;                   
            }
            $linenum++;
            next;
        }
        
        # There may be sales with revenue but no units.
        my $counterFee = 0;
        
        my $service     = $line->[$offsets->{service_id}];
        my $serviceName = $line->[$offsets->{service_name}] if(defined $offsets->{service_name});
        my $prodtype    = $line->[$offsets->{ptype}];
        my $format      = $line->[$offsets->{format}];
        my $catno   	= $line->[$offsets->{catno}];
        my $upc			= $line->[$offsets->{upc}];
        my $isrc		= $line->[$offsets->{isrc}];
        my $label		= $line->[$offsets->{label}];
        my $artist		= $line->[$offsets->{artist}];
        $artist = $line->[$offsets->{album_artist}] if($artist eq "" && $version == 6);
        my $album		= $line->[$offsets->{album}];
        my $track		= $line->[$offsets->{track}];
        my $tracknum	= $line->[$offsets->{tracknum}];
        my $country 	= $line->[$offsets->{country}];
        my $currency	= $line->[$offsets->{currency}];
        my $convrate	= $line->[$offsets->{convrate}];
        my $free        = $line->[$offsets->{free}] =~ /^(1|Y)$/ ? 1 : 0;
        my $units	    = $line->[$offsets->{units}];
        my $price       = $line->[$offsets->{price}];
        my $ext_price       = $line->[$offsets->{ext_price}];
        
        if(($version == 1) && ($units == 0)){
            $linenum++;
            next;
        }
        
        if (!$price && $version == 1 && $units != 0) 
        {
          $price = $ext_price / $units;
        }
        elsif (!$price && $version == 1 && $units == 0)
        {
          $price = $ext_price;
        }
        elsif($version == 1){
            $price  /= $units;
        }
        else
        {
            # For a while the royalty report generator was reporting the dist-fee percentage
            # as a number between 0 and 100.  Two percent was written out as 2, although it
            # was stored correctly in the database as 0.02.
            #
            # Since we've been inconsistent with it, but the math always seems to have been correct
            # in the data, we'll just back into what the effective unit price. This only comes into
            # play as of version 2

            if ($units)
            {
                $price = $line->[$offsets->{net_price}] / $units;

				$price =~ s/^-0$/0/;

				$free = 1 if ( !$price );
            }
            else
            {
                # because we do some special handling for zero units later
                $price = $line->[$offsets->{net_price}];
            }
        }

        $country        =  $Common::Consts::COUNTRY_CODE{lc($line->[$offsets->{country}])} || $Common::Consts::COUNTRY_TO_CODE{lc($line->[$offsets->{country}])} if(length($line->[$offsets->{country}]) > 2);

        # We'll apply the conversion rate to the price, effectively converting
        # to USD.
        #
        if ($convrate && $version == 1)
        {
            $price *= $convrate;                      
        }
        
        if ($currency_code)
        {
          $currency = $currency_code;
        }

        my ($media_type,$fee);
        $media_type = $line->[$offsets->{'media-type'}] if($offsets->{'media-type'});
        
        
        
        $counterFee = 1 if($units == 0 && $price != 0);
        $units = 1 if($counterFee == 1);
        $price *= -1 if($counterFee == 1 && $price < 0);        

        if ($prodtype && ($units != 0 || $price != 0) && $service ne "service-id")
        {
            my ($dateBegin, $dateEnd) = $self->_getDates($line->[$offsets->{start_date}], $line->[$offsets->{end_date}]);

            unless ($dateBegin && $dateEnd) {
                $self->errstr("couldn't get dates");
                return undef;
            }

            if($service eq "" && defined $offsets->{service_name} && $serviceName ne "") {
                $service = $self->getServiceID($serviceName);
            }

            unless($service ne "") {
                $self->errstr("Service ID not provided line:".$linenum);
                print STDERR "No serviceID provided line:".$linenum . "\n";
                return undef;
            }
            
            unless($country ne "") {
                $self->errstr("Unknown country:" . $line->[$offsets->{country}]);
                print STDERR "Unknown country:".$line->[$offsets->{country}]."\n";
                return undef;
            }

            unless($format ne "") {
                $self->errstr("No format provided: " .$line->[$offsets->{format}]." line: ". $linenum);
                print STDERR "No format provided: " .$line->[$offsets->{format}]." line: ". $linenum . "\n";
                return undef;
            }

            my $sale = RPS::Import::SaleRec->new();

            $sale->serviceID($service) if($service ne "");
            $sale->productType($prodtype);
            $sale->formatType($format);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->clientProductID($catno);
            $sale->upc($upc);
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->labelName($label);
            if ($prodtype eq RPS::File::Sale::TYPE_TRACK) {
                $sale->trackName($track);
                $sale->trackNum($tracknum);
                $sale->isrc($isrc);
            }
            if($media_type) {
                $sale->mediaType($media_type);
            }
            $sale->units($units);
            $sale->price($price);
            $sale->countryCode($country);
            $sale->currencyCode($currency);
            $sale->lineNum($linenum);
            $sale->free($free);

            #$args{dumper}($sale); #cmd line debug 
            $self->_insertSale(sale => $sale);
            
            if ($counterFee == 1) 
            {
              $price  = 0;
              $units  = -1;              
              my $sale = RPS::Import::SaleRec->new();
  
              $sale->serviceID($service) if($service ne "");
              $sale->productType($prodtype);
              $sale->formatType($format);
              $sale->dateBegin($dateBegin);
              $sale->dateEnd($dateEnd);
              $sale->clientProductID($catno);
              $sale->upc($upc);
              $sale->artistName($artist);
              $sale->albumName($album);
              $sale->labelName($label);
              if ($prodtype eq RPS::File::Sale::TYPE_TRACK) {
                  $sale->trackName($track);
                  $sale->trackNum($tracknum);
                  $sale->isrc($isrc);
              }
              if($media_type) {
                  $sale->mediaType($media_type);
              }
              $sale->units($units);
              $sale->price($price);
              $sale->countryCode($country);
              $sale->currencyCode($currency);
              $sale->lineNum($linenum);
              $sale->free($free);
  
              #$args{dumper}($sale); #cmd line debug 
              $self->_insertSale(sale => $sale);            
            }                       
        }
        
        
        
        
        #else { print STDERR "Skip-> l:".$linenum ." pt: " .$prodtype." s: ".$service." u: ".$units." p: ".$price." ar: ".$artist." al: ".$album."<-Skip\n";}
        $linenum++;
    }
	return $linenum;
}

sub _getDates
{
    my $self = shift;
    my $start_date = shift;
    my $end_date = shift;
    my ($month_start,$month_end,$year_start,$year_end,$day_start,$day_end,$dateBegin,$dateEnd);

    # dates of the form yyyy-mm are allowed
    # in that case, set to first day of month for begin date
    # and last day of month for end date
    if($start_date =~ m/(\d{5})/) {
       ($year_start, $month_start, $day_start) = Add_Delta_Days(1900,1,1, $1-2);
    }
    elsif ($start_date =~ m/(\d{4})\D(\d+)\D(\d+)/) {
        $month_start = $2;
        $year_start = $1;
    }
    elsif($start_date =~ m/(\d+)\D(\d+)\D(\d{4})/) {
        $month_start = $1;
        $year_start = $3;
    }
    elsif($start_date =~ m/(\d{4})\D(\d+)/) {
        $month_start = $2;
        $year_start = $1;
    }
    if($end_date =~ m/(\d{5})/) {
        ($year_end, $month_end, $day_end) = Add_Delta_Days(1900,1,1, $1-2);
    }
    elsif($end_date =~ m/(\d{4})\D(\d+)\D(\d+)/) {
        $month_end = $2;
        $year_end = $1;
    }
    elsif($end_date =~ m/(\d+)\D(\d+)\D(\d{4})/) {
        $month_end = $1;
        $year_end = $3;
    }
    elsif($end_date =~ m/(\d{4})\D(\d+)/) {
        $month_end = $2;
        $year_end = $1;
    }
    if($month_end && $year_end && $day_end && $month_start && $year_start && $day_start) {
        $dateBegin = $year_start."-".$month_start."-".$day_start;
        $dateEnd    = $year_end."-".$month_end."-".$day_end;
        return ($dateBegin,$dateEnd);
    }
    elsif($month_end && $year_end && $month_start && $year_start) {
        $dateBegin = $year_start."-".$month_start."-01";
        $dateEnd    = $year_end."-".$month_end."-".Days_in_Month($year_end,$month_end);
        return ($dateBegin,$dateEnd);
    }
    else {
        print STDERR "Improper date format from: ". $dateBegin."\n";
        $self->errstr("Improper date format from: ". $dateBegin);
        print STDERR "Improper date end format from: ". $dateEnd."\n";
        $self->errstr("Improper date end format from: ". $dateEnd);
    }
    return undef;
}

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