package RPS::Import::AMIEStreet2;

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';

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

my %field_map = (
    2 => {
        year            => 0,
        month           => 1,
        upc             => 2,
        isrc            => 3,
        product_type    => 5,
        format_type     => 6,
        artist          => 9,
        album           => 10,
        track           => 11,
        units           => 12,
        price           => 13,
        currency        => 17,
    },
    3 => {
        year            => 0,
        month           => 1,
        upc             => 2,
        isrc            => 3,
        content_id      => 5,
        product_type    => 6,
        format_type     => 7,
        artist          => 10,
        album           => 11,
        track           => 12,
        units           => 13,
        price           => 14,
        currency        => 18,
    },
);

#
# public methods
#

sub _importLines
{
    my $self = shift;
    my %args = @_;
    my $lines = $args{lines};
    my $version = $args{file}->VersionNum();
    my $fileName = $args{file}->OrigFileName();

    my $linenum = 1;
    my $country = "US";
    my $sheet_count = 0;
	my $sheet_names = $args{sheet_names};
	my $headerFound;

	foreach my $sheet(@{ $args{sheets} }) {
        $linenum = 1;
        $headerFound = 0;

		# Shift some columns over on for streaming sheet
		if($sheet_count == 2) {
			$field_map{$version}{units}--;
			$field_map{$version}{format_type}--;
			$field_map{$version}{artist}--;
			$field_map{$version}{album}--;
			$field_map{$version}{track}--;
			$field_map{$version}{price}++;
			$field_map{$version}{currency}--;
		}

    	foreach my $line (@$sheet)
        {
            my $isrc            = $line->[$field_map{$version}{isrc}];

			if ($headerFound)
            {
                my $upc             = $line->[$field_map{$version}{upc}];
                my $product_type    = $line->[$field_map{$version}{product_type}];
                my $format_type     = uc($line->[$field_map{$version}{format_type}]);
                my $artist          = $line->[$field_map{$version}{artist}];
                my $album           = $line->[$field_map{$version}{album}];
                my $track           = $line->[$field_map{$version}{track}];
                my $units           = $line->[$field_map{$version}{units}];
                my $price           = $line->[$field_map{$version}{price}];
                my $currency        = $line->[$field_map{$version}{currency}];
                my $clientProductID;

				if( $format_type eq 'D' ) {
					$format_type = RPS::File::Sale::FORMAT_DOWNLOAD;
				} elsif( $format_type eq 'S') {
					$format_type = RPS::File::Sale::FORMAT_STREAM;
				} elsif( $format_type eq 'T') {
					$format_type = RPS::File::Sale::FORMAT_TETHERED;
				}

                $product_type       = "T" if($product_type eq "S");
                $product_type       = "A" if($product_type eq "CD5");
                $product_type       = "A" if($product_type eq "C");
				$product_type       = "T" if($sheet_count == 2 ); # stream download

                if (defined($field_map{$version}{content_id}))
                {
                    $clientProductID = $line->[$field_map{$version}{content_id}];
                }

                if ( $price != 0 && ($album ne "" || $upc ne "" || $track  ne "" || $isrc  ne ""))
                {
                    my ($dateBegin, $dateEnd) = $self->_getDates($line->[$field_map{$version}{year}],$line->[$field_map{$version}{month}]);
                    unless ($dateBegin && $dateEnd) {
                        print STDERR "Couldn't get dates from l:".$linenum." d:".$line->[$field_map{$version}{year}]." - " . $line->[$field_map{$version}{month}] . "\n";
                        $self->errstr( "Couldn't get dates from l:".$linenum." d:".$line->[$field_map{$version}{year}]." - " . $line->[$field_map{$version}{month}]);
                        return undef;
                    }
					
					# For version three of this file the third sheet lists streamed
					# tracks.  The price column is the total revene not per unit like
					# the first sheet.  Case #11982
					if( $units && $sheet_count == 2 && $version == 3 ) {
						$price /= $units;
					}

                    my $sale = RPS::Import::SaleRec->new();
                    $sale->productType($product_type);
                    $sale->trackName($track);
                    $sale->isrc($isrc);
                    $sale->upc($upc);
                    $sale->formatType($format_type);
                    $sale->dateBegin($dateBegin);
                    $sale->dateEnd($dateEnd);
                    $sale->artistName($artist);
                    $sale->albumName($album);
                    $sale->price($price);
                    $sale->units($units);
                    $sale->countryCode($country);
                    $sale->clientProductID($clientProductID);
                    $sale->lineNum($linenum);

                    $self->_insertSale(sale => $sale);
                }
                #else { print STDERR "Skip l:".$linenum." a:".$artist." a:".$album." u:".$upc. " t:".$track." i:".$isrc."\n"; }
            }

			$headerFound = 1 if ( $isrc =~ /^isrc$/i );
            $linenum++;
        }

	    $sheet_count++;
	}

    return $linenum;
}

#
# Private methods
#

sub _getDates
{
    my $self = shift;
	my $year = shift;
	my $month = shift;
    my $dateBegin;
    my $dateEnd;

    if ($year && $month)
    {
        $dateBegin = sprintf("%04d-%02d-%02d", $year, $month, 1);
        $dateEnd = sprintf("%04d-%02d-%02d", $year, $month, Days_in_Month($year, $month));
    }

    return ($dateBegin, $dateEnd);
}


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