package RPS::Import::Puretracks::v1;

use strict;

use Date::Calc qw(Days_in_Month Decode_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';

my %field_map = (
    1 => {
        date_row        => 0,
        date_col        => 0,
        units           => 0,
        code            => 1,
        artist          => 2,
        title           => 3,
        price           => 2,
        deduct          => 2,
        deduct_alt      => 1,
        summary_product => 0,
    },
    2 => {
        date_row        => 0,
        date_col        => 0,
        units           => 1,
        code            => 2,
        artist          => 3,
        title           => 4,
        price           => 3,
        deduct          => 3,
        summary_product => 1,
    },
    3 => {
        date_col        => 1,
        date_start_row  => 8,
        date_end_row    => 9,
        units           => 0,
        code            => 1,
        artist          => 2,
        artist_track    => 3,
        title           => 3,
        title_track     => 4,
        price           => 2,
        deduct          => 2,
        summary_product => 0,
    },
    4 => {
        date_col        => 1,
        date_start_row  => 8,
        date_end_row    => 9,
        units           => 0,
        code            => 1,
        artist          => 2,
        artist_track    => 3,
        title           => 3,
        title_track     => 4,
        price           => 2,
        deduct          => 2,
        summary_product => 0,
    },
    5 => {
        date_col        => 0,
        units           => 1,
        code_track      => 2,
        artist          => 3,
        title           => 2,
        title_track     => 4,
        price           => 3,
        deduct          => 2,
        summary_product => 1,
    },
    6 => {
        date_col        => 0,
        units           => 1,
        code            => 2,
        code_track      => 2,
        artist          => 3,
        title           => 4,
        price           => 3,
        deduct          => 0, # no-deductions??
        summary_product => 1,
    },
    7 => {
        date_col        => 1,
        date_start_row  => 8,
        date_end_row    => 9,
        units           => 9,
        code            => 4,
        artist          => 7,
        artist_track    => 7,
        title           => 8,
        title_track     => 8,
        price           => 3,
        detail_price    => 11,
        deduct          => 5,
        upc             => 2,
        isrc            => 3,
        spid            => 4,
        label           => 5,
        summary_product => 0,
    },
    8 => {
        date_col        => 0,
        units           => 1,
        code            => 2,
        code_track      => 2,
        artist          => 3,
        title           => 4,
        price           => 2,
        deduct          => 4, # no-deductions??
        summary_product => 0,
    },
    10 => {
        date_col        => 1,
        date_start_row  => 9,
        date_end_row    => 10,
        units           => 0,
        code            => 1,
        artist          => 2,
        artist_track    => 3,
        title           => 3,
        title_track     => 4,
        price           => 2,
        deduct          => 4,
        summary_product => 0,
    },
    9 => {
        date_col        => 1,
        date_start_row  => 8,
        date_end_row    => 9,
        units           => 0,
        code            => 1,
        artist          => 2,
        artist_track    => 3,
        title           => 3,
        title_track     => 4,
        price           => 3,
        deduct          => 5,
        summary_product => 0,
        upc             => 1,
        isrc            => 1,
        #spid            => 4,
        #label           => 5,
    },
    11 => {
        date_col        => 1,
        date_start_row  => 9,
        date_end_row    => 10,
        units           => 1,
        code            => 2,
        artist          => 4,
        title           => 5,
        price           => 3,
        deduct          => 5,
        summary_product => 0,
    },
);

#public methods

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

	my $sheets = $args{sheets};
    my $version = $self->_version();
    my $fileName = $args{file}->OrigFileName;
    #my $fileName = $args{OrigFileName}; ## for cmd-line testing

    my $offsets = $field_map{$version};

	my $summary = $sheets->[0];
	my $albums  = $sheets->[1];
	my $tracks  = $sheets->[2];

    my ($country, $currency);
    if ($fileName =~ m/ US / || $fileName =~ /_US_/ || $fileName =~ /^US_/ ) {
        $country  = 'US';
        $currency = 'USD';
    } else {
        $country  = 'CA';
        $currency = 'CAD';
    }

    my ($album_price, $track_price, $month);
    my ($albumDeduct, $trackDeduct);
    my $in_pub_deduct = 0;
    my ($priceColumn,$deductionColumn);
    foreach my $line (@$summary)
    {
        if($version == 11) {
            if($line->[0] eq "Type") {
                my @columns = @$line;
                for(my $x=0;$x<@columns;$x++) {
                    $priceColumn = $x if($line->[$x] =~ /net payment/i);
                    $deductionColumn = $x if($line->[$x] =~ /deduction/i);
                }
            }
            elsif($line->[$offsets->{summary_product}] eq "Product" && $album_price eq "") {
                $album_price = $line->[$priceColumn];
                $album_price /= $line->[1] if($line->[1]!=0);
                $albumDeduct = 0;
            }
            elsif($line->[$offsets->{summary_product}] eq "Track" && $track_price eq "") {
                $track_price = $line->[$priceColumn];
                $track_price /= $line->[1] if($line->[1] != 0);
                $trackDeduct = 0;
            }
        }
        elsif(($line->[$offsets->{summary_product}] eq "Product"||$line->[$offsets->{summary_product}] eq "Albums"||$line->[$offsets->{summary_product}] eq "Album") && ($version>6)) {
            $album_price = $line->[$offsets->{price}];
            $albumDeduct = $line->[$offsets->{deduct}]/$line->[1] if($line->[1]>0);

        }
        elsif(($line->[$offsets->{summary_product}] eq "Track" && $version>6)||($line->[$offsets->{summary_product}] eq "Tracks" && $version>6)) {
            $track_price = $line->[$offsets->{price}];
            $trackDeduct = $line->[$offsets->{deduct}]/$line->[1] if($line->[1]>0);

        }
        elsif ($line->[$offsets->{summary_product}] =~ /^(Albums|Product)$/)
        {
            if ($version =~ /^(5|6)$/)
            {
                $month = Decode_Month($line->[$offsets->{month}]);
                $album_price->{$month} = $line->[$offsets->{price}];
            }
            else
            {
                $album_price = $line->[$offsets->{price}];
            }
        }
        elsif ($line->[$offsets->{summary_product}] =~ /^Track/)
        {
            if ($version =~ /^(5|6)$/)
            {
                $track_price->{$month} = $line->[$offsets->{price}];
            }
            else
            {
                $track_price = $line->[$offsets->{price}];
            }
        }
        elsif ($line->[0] =~ /Publishing Deduction?/ || $line->[1] =~ /Publishing Deduction/i || ($in_pub_deduct && $version !~ /^(3|4)$/))
        {
            $in_pub_deduct = 1;

            $albumDeduct ||=
                $line->[$offsets->{deduct}] =~ m/^\$(\d+\.\d\d)\/per Albums?$/ ? $1 :
                $line->[$offsets->{deduct_alt}] =~ m/^\$(\d+\.\d\d)\/per Albums?$/ ? $1 :
                ($line->[$offsets->{summary_product}] =~ m/album/i &&
                    $line->[$offsets->{deduct}] =~ m/^(\d+(\.\d+)?)$/) ? $1 : 0;

            $trackDeduct ||=
                $line->[$offsets->{deduct}] =~ m/^\$(\d+\.\d\d)\/per Tracks?$/ ? $1 :
                $line->[$offsets->{deduct_alt}] =~ m/^\$(\d+\.\d\d)\/per Tracks?$/ ? $1 :
                ($line->[$offsets->{summary_product}] =~ m/track/i &&
                     $line->[$offsets->{deduct}] =~ m/^(\d+(\.\d+)?)$/) ? $1 : 0;
        }
    }

    if ($album_price eq "" && $track_price eq "") {
        $self->errstr("couldn't get prices");
        return undef;
    }

    if ($version =~ /^(5|6)$/)
    {
        map { $album_price->{$_} -= $albumDeduct } keys %$album_price;
        map { $track_price->{$_} -= $trackDeduct } keys %$track_price;
    }
    else
    {
        $album_price -= $albumDeduct;

        $track_price -= $trackDeduct;

    }

	my ($dateBegin, $dateEnd);
    if ($version == 8) {
        my $adjusted_filename = $fileName;
        $adjusted_filename =~ s/^.*US /Summary / if ($fileName =~ /US/);
        $adjusted_filename =~ s/^.*CA /Summary / if ($fileName =~ /CA/);
        $adjusted_filename =~ s/\.xls//;
        ($dateBegin,$dateEnd) = $self->_getDates($adjusted_filename);
    }
    elsif ($version == 1 || $version == 2) {
	    ($dateBegin, $dateEnd) = $self->_getDates($summary->[$offsets->{date_row}]->[$offsets->{date_col}]);
	    unless ($dateBegin && $dateEnd) {
            $self->errstr("couldn't get dates");
            print STDERR 'dates: '. $summary->[$offsets->{date_row}]->[$offsets->{date_col}] ."\n";
            return undef;
        }
    }
    elsif($version>7) {
        my @name_parts;
        $fileName =~ m/(\d{8})\-(\d{8})/;
        if($fileName =~ m/(\d{8})\-(\d{8})/) {
            $name_parts[0] = $1;
            $name_parts[1] = $2;
        }
        elsif($fileName =~ m/(\d{8}) \- (\d{8})/) {
            $name_parts[0] = $1;
            $name_parts[1] = $2;
        }
        elsif($fileName =~ m/(\d{8})\_\-\_(\d{8})/) {
            $name_parts[0] = $1;
            $name_parts[1] = $2;
        }
        ($dateBegin, $dateEnd) = $self->_getDates_alt($name_parts[0], $name_parts[1]);
        unless ($dateBegin && $dateEnd) {
            $self->errstr("couldn't get dates");
            print STDERR 'dates: '. $name_parts[0] . ", " .$name_parts[1] ."\n";
            return undef;
        }
    }
    elsif ($version !~ /(5|6)/)
    {
	    ($dateBegin, $dateEnd) = $self->_getDates_alt($summary->[$offsets->{date_start_row}]->[$offsets->{date_col}], $summary->[$offsets->{date_end_row}]->[$offsets->{date_col}]);
	    unless ($dateBegin && $dateEnd) {
            $self->errstr("couldn't get dates");
            print STDERR 'dates: '. $summary->[$offsets->{date_start_row}]->[$offsets->{date_col}] ."\n";
            return undef;
        }
    }
    my $linenum = $self->_processLines($albums, RPS::File::Sale::TYPE_ALBUM, $dateBegin, $dateEnd, $album_price, $country, $currency, $offsets,$version,$fileName);

    # on the track tab some of the columns shift (for some versions)
    foreach my $k(qw(artist title code))
    {
        my $trackKey = $k . '_track';
        $offsets->{$k} = $offsets->{$trackKey} if (exists $offsets->{$trackKey});
    }

    $linenum   += $self->_processLines($tracks, RPS::File::Sale::TYPE_TRACK, $dateBegin, $dateEnd, $track_price, $country, $currency, $offsets,$version,$fileName);

	return $linenum;
}

#
# Private methods
#


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

    my ($dateBegin, $dateEnd);
    if($date =~ m/Q(\d) (\d{4})/) {
        my $year = $2;
        my $qtr = $1;
        if ($qtr == 1) {
            $dateBegin = $year."-01-01";
            $dateEnd   = $year."-03-".Days_in_Month($year, 3);
        } elsif ($qtr == 2) {
            $dateBegin = $year."-04-01";
            $dateEnd   = $year."-06-".Days_in_Month($year, 6);
        } elsif ($qtr == 3) {
            $dateBegin = $year."-07-01";
            $dateEnd   = $year."-09-".Days_in_Month($year, 9);
        } elsif ($qtr == 4) {
            $dateBegin = $year."-10-01";
            $dateEnd   = $year."-12-".Days_in_Month($year, 12);
        }
    }
    elsif($date =~ m/Summary\s*(\w+)\s+(\d{4})$/) {
        my $month = Decode_Month($1);
        my $year  = $2;
        $dateBegin = sprintf("%04d-%02d-%02d", $year, $month, 1);
        $dateEnd   = sprintf("%04d-%02d-%02d", $year, $month, Days_in_Month($year, $month));
    }

	return ($dateBegin, $dateEnd);
}

sub _getDates_alt
{
	my $self = shift;
	my $date1 = shift;
	my $date2 = shift;
    my ($dateBegin, $dateEnd);

    if($date1 =~ m/(\d{4})(\d\d)(\d\d)/) {
        $dateBegin = sprintf("%04d-%02d-%02d",$1,$2,$3);
    }
    elsif ($date1 =~ m/^(\d+)$/) {
        my ($year, $month, $day) = Add_Delta_Days(1900,1,1, $1 - 2);
        $dateBegin = sprintf("%04d-%02d-%02d", $year, $month, 1);
    }
    if($date2 =~ m/(\d{4})(\d\d)(\d\d)/) {
        $dateEnd = sprintf("%04d-%02d-%02d",$1,$2,$3);
    }
    elsif ($date2 =~ m/^(\d+)$/) {
        my ($year, $month, $day) = Add_Delta_Days(1900,1,1, $1 - 2);
        $dateEnd   = sprintf("%04d-%02d-%02d", $year, $month, Days_in_Month($year, $month));
    }

	return ($dateBegin, $dateEnd);
}

sub _getDataRowDate
{
    my $self = shift;
    my $date = shift;

    return undef unless ($date =~ m/^(\w+)\D+\d+\D+(\d\d\d\d)$/);
    my $year = $2;
    my $month = Decode_Month($1);

    return undef unless ($month && $year);
    return (
        sprintf("%04d-%02d-01", $year, $month),
        sprintf("%04d-%02d-%02d", $year, $month, Days_in_Month($year, $month)),
        $month
    );
}

sub _processLines
{
    my $self        = shift;
    my $lines       = shift;
    my $prodtype    = shift;
    my $dateBegin   = shift;
    my $dateEnd     = shift;
    my $price       = shift;
    my $country     = shift;
    my $currency    = shift;
    my $offsets     = shift;
    my $version     = shift;
    my $fileName    = shift;
    my $dates = $dateBegin ? 1 : 0;
    my $month = 0;
	my $format = RPS::File::Sale::FORMAT_DOWNLOAD;

    my $linenum = 1;  ## starting off after header

    if($version==8 && $fileName =~ /US/ && $prodtype eq "A") {
        $offsets->{artist} -= 1;
        $offsets->{units} -= 1;
        $offsets->{title} -= 1;
    }
    if($version==8 && $fileName =~ /US/ && $prodtype eq "T") {
        $offsets->{artist} += 1;
        $offsets->{units} += 1;
        $offsets->{title} += 1;
    }

	foreach my $line (@$lines)
    {
		my $artist	= $line->[$offsets->{artist}];
		my ($units)	= $line->[$offsets->{units}] =~ m/^(\d+)$/;
        my $title = $line->[$offsets->{title}];
        my $test_title = $title =~ s/(\d)|\.//g;

        my $code = exists $offsets->{code} ? $line->[$offsets->{code}] : '';
        $code =~ s/^indy_//;
        $code =~ s/_mp3$//;

		unless ($units && defined $price && ($code || $artist || $title)) {
            $linenum++;
            next;
        }
        my ($label,$upc,$isrc,$spid);
        $label      = $line->[$offsets->{label}] if(defined $offsets->{label});
        $upc        = $line->[$offsets->{upc}] if(defined $offsets->{upc});
        $upc        =~ s/^indy_//;
        $upc        =~ s/_mp3$//;
        $isrc       = $line->[$offsets->{isrc}] if(defined $offsets->{isrc});
        $spid       = $line->[$offsets->{spid}] if(defined $offsets->{spid});
        $isrc       =~ s/\-//g;

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

        # if the date range wasn't passed, it will be grabbed from each data row
        # the month will be used to index the price array
        unless ($dates)
        {
            ($dateBegin, $dateEnd, $month) = $self->_getDataRowDate($line->[$offsets->{date_col}]);
            unless ($dateBegin && $month)
            {
                $self->errstr("couldn't get dates");
                print STDERR 'date: '. $line->[$offsets->{date_col}] ."\n";
                return undef;
            }
            $sale->price($price->{$month});
        }
        else
        {
                    if($version == 7)
                    {
                        my $price = $line->[$offsets->{detail_price}];
                        my $deduction = $line->[$offsets->{detail_price} + 1];
                        $price -= $deduction;
                        $price /= $units;
                        $sale->price($price);
                    }
                    else{
                        $sale->price($price);
                    }
        }
        if($test_title eq "" && $version==11 && $line->[$offsets->{title}+1] ne "") {
            my $new_test_title = $line->[$offsets->{title}+1];
            $new_test_title =~ s/(\d)|\.//g;
            if($new_test_title ne "") {
                $title = $line->[$offsets->{title}+1];
            }
        }
		$sale->productType($prodtype);
		$sale->formatType($format);
		$sale->dateBegin($dateBegin);
		$sale->dateEnd($dateEnd);
		$sale->artistName($artist);

    if ($prodtype eq RPS::File::Sale::TYPE_ALBUM)
    {
		    $sale->upc($code);
        $sale->upc($upc) if(defined $offsets->{upc} && $upc ne "");
		    $sale->albumName($title);
    }
    elsif ($prodtype eq RPS::File::Sale::TYPE_TRACK)
    {
    		if ($version != 9)
    		{
            $sale->upc($upc) if(defined $offsets->{upc} && $upc ne "");
      	}
		    $sale->isrc($code);
        $sale->isrc($isrc) if(defined $offsets->{isrc} && $isrc ne "");
		    $sale->trackName($title);
    }

    $sale->labelName($label) if(defined $offsets->{label} && $label ne "");
    $sale->serviceProductID($spid) if(defined $offsets->{spid} && $spid ne "");
		$sale->units($units);
		$sale->countryCode($country);
		$sale->currencyCode($currency);
		$sale->lineNum($linenum);

        ##$$args{dumper}($sale);  ## for cmd-line testing
		$self->_insertSale(sale => $sale);
		$linenum++;
	}
    return $linenum;
}

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