package RPS::Import::INGrooves::Base;

use strict;

use lib '/app/tools/common/lib';
use Common::Country;

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

use base 'RPS::Import::INGroovesBase';

#public methods

sub _getDateFromSheet
{
    my $self = shift;
    my $sheetName = @_;
    # override this if you want to extract date from a specific sheet
    # otherwise the date will be determined on a line-by-line basis
    return undef;
}

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

    my $fileObj = $args{file};
    my $version = $args{file}->VersionNum();
    my $fileName = $args{file}->OrigFileName();
    my $sheet_count = 0;
    return undef unless (defined $args{sheets} && defined $version);

    my $offsets = $self->_fieldMap;

    my $sheet_names = $args{sheet_names};
    my $_numsheets = (scalar @{$sheet_names});

    my $header_found = 0;
    my $linenum = 1;
    my %prices;
    my ($dateBegin,$dateEnd);
    my $useGlobalDate;

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

        my $currentSheetName = $sheet_names->[$sheet_count];

        #
        # The sale dates can be determined from a specific sheet and used
        # globally for all sales, or they can be determined from each
        # individual sales line.
        #
        if ( !$dateBegin && !$dateEnd && $self->_getDateFromSheet( $currentSheetName ) )
        {
            foreach my $line (@$sheet)
            {
                my $dlabel = $line->[$offsets->{date_begin}-1];
                my $dt = $line->[$offsets->{date_begin}];
                if ( !$dateBegin && !$dateEnd && $dlabel && $dlabel =~ m/date\:/i )
                {
                    ($dateBegin, $dateEnd) = $self->_getDates( date_begin=>$dt );
                    $useGlobalDate = 1;
                }
            }
        }

        if ( ( !$currentSheetName && $_numsheets == 0 ) ||
             ( $currentSheetName && $currentSheetName =~ /details/i ) )
        {

            foreach my $line (@$sheet) {
                my $artist = $line->[$offsets->{artist}];
                my $track  = $line->[$offsets->{track}];
                my $album  = $line->[$offsets->{album}];

                my $countryName = $line->[$offsets->{country}];

                # Seeing lots of country names
                #
                my @countryNameArray = split(/\,/, $countryName);
                $countryName = @countryNameArray[0];

                my $isrc = $line->[$offsets->{isrc}];
                my $upc  = $line->[$offsets->{upc}];

                my $_service   = $line->[$offsets->{service}];
                my $_assetType = $line->[$offsets->{prodtype}];

                #----------------------------------------------------------
                # Per FB14063, we strip off any trailing country code data.
                #----------------------------------------------------------
                $_service     =~ s/ (\w{3})$//;

                #--------------------------------------------------------
                # lookup the service, format, product type and media type
                # information using the information in the STATEMENT and
                # ASSET TYPE columns.
                #--------------------------------------------------------
                my ($serviceID, $format, $prodtype, $mediaType );
                if ( $_service && $_service !~ m/STATEMENT/i && $_assetType )
                {
                    ($serviceID, $format, $prodtype, $mediaType ) = $self->_getServiceFormat($_service, $_assetType);
                    if ( !$format )
                    {
                        $self->errstr("Unable to determine format from '$_service' on line $linenum");
                        return undef;
                    }
                }

                my $label               = $line->[$offsets->{label}] if (defined $offsets->{label} );
                
                my $units               = $line->[$offsets->{units}] if (defined $offsets->{units});
                my $price               = $line->[$offsets->{price}];

                my $currency = "USD";

                if ($units != 0) {
                    $price = sprintf("%.8f", $price / ($units * -1)) if($units < 0);
                    $price = sprintf("%.8f", $price / $units) if($units > 0);
                    $price = sprintf("%.8f", $price * -1) if($price < 0);
                }

                my $free = ($price == 0 ) ? 1 : 0;

                if ($units && $price ne "" && ($track||$album) && $format && $track !~ /^title$/i && $track !~ /^song$/i) {

                    if ( !$useGlobalDate )
                    {
                        ($dateBegin, $dateEnd) = $self->_getDates( date_begin=>$line->[$offsets->{date_begin}], date_end=>$line->[$offsets->{date_end}] );
                    }

                    unless( defined $countryName ) {
                        $self->errstr("Missing country on line $linenum");
                        return undef;
                    }


                    my $_altName = $self->_getAlternateCountryName($countryName);

                    if ( $_altName ) {
                        $countryName = $_altName;
                    }

                    my $countryObj = Common::Country->Get( $countryName );
                    my $country = $countryObj->alpha2 if( $countryObj );

                    unless (defined $dateBegin && defined $dateEnd) {
                        $self->errstr("Couldn't get dates from line $linenum");
                        return undef;
                    }

                    unless (defined $serviceID) {
                        $self->errstr("Unrecognized service on line $linenum: $_service");
                        return undef;
                    }

                    my $catalogNumber;
                    if ( defined $offsets->{catalog_number} )
                    {
                        $catalogNumber = $line->[$offsets->{catalog_number}];
                    }

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

                    $sale->serviceProductID($catalogNumber) if ( $catalogNumber );
                    $sale->productType($prodtype);
                    $sale->dateBegin($dateBegin);
                    $sale->dateEnd($dateEnd);
                    $sale->artistName($artist);
                    $sale->trackName($track) if ($prodtype eq RPS::File::Sale::TYPE_TRACK);
                    $sale->albumName($album) if (defined $album && $album ne "");
                    $sale->upc($upc) if(defined $upc);
                    $sale->isrc($isrc) if(defined $isrc);
                    $sale->labelName($label) if(defined $label);
                    $sale->serviceID($serviceID);
                    $sale->formatType($format);
                    $sale->units($units);
                    $sale->price($price);
                    $sale->free($free);
                    $sale->countryCode($country);
                    $sale->currencyCode($currency);
                    $sale->mediaType($mediaType);
                    $sale->lineNum($linenum);

                    $self->_insertSale(sale => $sale);
                }
                #else { print STDERR "skip sh: ".$sheet_names->[$sheet_count] . ": l: " . $linenum . " - u:".$units." p:".$price." a:".$artist." t:".$track." f:".$format."\n"; }
                $linenum++;
            }
        }
        $sheet_count++;
    }
    return $linenum;
}

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