package RPS::Import::PanicButton;

use strict;

use Date::Calc qw(Days_in_Month);
use Math::BigFloat;

use lib '/app/tools/common/lib';
use Common::Util;
use Common::Consts qw(%CODE_TO_COUNTRY);

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

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


my %field_map = (
   1 => {
          'date'      => 1,
          'label'     => 2,
          'format'    => 3, 
          'prodtype'  => 4,
          'svcprodid' => 5,
          'aartist'   => 6,
          'album'     => 7,
          'tartist'   => 8,
          'track'     => 9,
          'tracknum'  => 10,
          'upc'       => 11,
          'isrc'      => 12,
          'service'   => 13,
          'country'   => 14, 
          'free'      => 15,
          'units'     => 16,
          'retail'    => 17,
          'price'     => 18,
				},		
   2 => {
          'date'      => 1,
          'label'     => 2,
          'format'    => 3, 
          'prodtype'  => 4,
          'svcprodid' => 5,
          'aartist'   => 6,
          'album'     => 7,
          'tartist'   => 8,
          'track'     => 9,
          'upc'       => 10,
          'isrc'      => 11,
          'service'   => 12,
          'country'   => 13, 
          'free'      => 14,
          'units'     => 15,
          'retail'    => 16,
          'price'     => 17,
				},																		
  );

#public methods

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

    my $lines = $args{lines};
    return 0 unless ($lines);
    
    my $fileObj = $args{file};
    my $version = $fileObj->VersionNum;
    my $offsets = $field_map{$version};    

    my %errors = ();
    my $linenum = 1;
    foreach my $line(@$lines)
    {
        my $label       = $line->[$offsets->{'label'}];
        my $svcProdID   = $line->[$offsets->{'svcprodid'}];
        my $album       = $line->[$offsets->{'album'}];
        my $track       = $line->[$offsets->{'track'}];
        my $trackNum    = $line->[$offsets->{'tracknum'}];
        my $upc         = $line->[$offsets->{'upc'}];
        my $isrc        = $line->[$offsets->{'isrc'}];
        my $service     = $line->[$offsets->{'service'}];
        my $free        = lc $line->[$offsets->{'free'}] eq 'y' ? 1 : 0;

        my ($units)     = $line->[$offsets->{'units'}];
        my ($retail)    = $line->[$offsets->{'retail'}];
        my ($price)     = Math::BigFloat->new($line->[$offsets->{'price'}]);

        if ($units!=0 && defined $price)
        {
            if($units<0 || $price<0) {
                $units *= -1 if ($units<0);
                $price *= -1 if($price<0);
                $retail *= -1 if($retail<0);
                $price /= $units;
                $retail /= $units;
                $units *= -1 if ($units>0);
                $price *= -1 if($price<0);
                $retail *= -1 if($retail<0);
            }
            else {
                 $price /= $units;
                 $retail /= $units;
            }
            my $format =
                $line->[$offsets->{'format'}] =~ m/permanent/i ? RPS::File::Sale::FORMAT_DOWNLOAD :
                $line->[$offsets->{'format'}] =~ m/tethered/i ? RPS::File::Sale::FORMAT_TETHERED :
                $line->[$offsets->{'format'}] =~ m/stream/i ? RPS::File::Sale::FORMAT_STREAM :
                $line->[$offsets->{'format'}] =~ m/ringtone/i ? RPS::File::Sale::FORMAT_RINGTONE :
                '';
#            unless ($format || exists $errors{ $line->[$offsets->{'format'}] })
#            {
#                $self->warning();
#                print STDERR "unknown format: ". $line->[$offsets->{'format'}] ."\n";
#                $errors{ $line->[$offsets->{'format'}] } = 1;
#            }

            my $prodType =
                lc $line->[$offsets->{'prodtype'}] eq 'a' ? RPS::File::Sale::TYPE_ALBUM :
                RPS::File::Sale::TYPE_TRACK;

            my $artist =
                $prodType eq RPS::File::Sale::TYPE_ALBUM ?
                $line->[$offsets->{'aartist'}] : $line->[$offsets->{'tartist'}];

            $line->[$offsets->{'service'}] =~ s/virgin digital/virgin/i;
            $line->[$offsets->{'service'}] =~ s/APPLE/iTunes/i;
            $line->[$offsets->{'service'}] = 'AMAZON' if ($line->[$offsets->{'service'}] =~ m/AMAZON/);

            my $serviceID = $self->getServiceID($line->[$offsets->{'service'}]);
#            unless ($serviceID || exists $errors{ $line->[$offsets->{'service'}] })
#            {
#                $self->warning();
#                print STDERR "unknown service: ". $line->[$offsets->{'service'}] ."\n";
#                $errors{ $line->[$offsets->{'service'}] } = 1;
#            }

            my $countryCode = uc $line->[$offsets->{'country'}];
#            unless (exists $CODE_TO_COUNTRY{$countryCode} || exists $errors{$countryCode})
#            {
#                $self->warning();
#                print STDERR "unknown country: $countryCode\n";
#                $errors{$countryCode} = 1;
#            }

            my ($dateBegin, $dateEnd) = $self->_getDates(date_begin => $line->[$offsets->{'date'}], type => 'numerical_year_first');
#            unless ($dateBegin && $dateEnd)
#            {
#                $self->errstr("couldn't get dates");
#                print STDERR 'dates: '. $line->[$offsets->{'date'}] ."\n";
#                return undef;
#            }

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

            $sale->productType($prodType);
            $sale->formatType($format);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->countryCode($countryCode);
            $sale->free($free);
            $sale->isrc($isrc);
            $sale->labelName($label);
            $sale->lineNum($linenum);
            $sale->price($price);
            $sale->retail($retail);
            $sale->serviceProductID($svcProdID);
            $sale->serviceID($serviceID);
            $sale->trackName($track);
            $sale->trackNum($trackNum);
            $sale->units($units);
            $sale->upc($upc);
    
            #$args{dumper}($sale);  ## for cmd-line testing
            $self->_insertSale(sale => $sale);
        }#else { print STDERR "skip: $linenum u: $units p: $price\n"; }
        $linenum++;
    }

    return %errors ? undef : $linenum;
}

#
# Private methods
#

sub _validateSaleRec
{
    my ($self, $saleRec) = @_;

    # This importer cares about service_id.
    #
    if (! $saleRec->serviceID())
    {
        die Import::ValidationError->new($saleRec, "Unable to identify service");
    }

    return $self->SUPER::_validateSaleRec($saleRec);
}

sub __getDates
{
    my $self = shift;
    my $dateCol = shift;

    return undef unless ($dateCol =~ m/^(\d\d\d\d)\D(\d\d)$/);
    my ($year, $month) = ($1, $2);

    return (
        Common::Util::normalize_date(join('-', $year, $month,1)),
        Common::Util::normalize_date(join('-', $year, $month, Days_in_Month($year, $month))),
    );
}

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