package RPS::Import::Revolver;

use strict;

use Date::Calc qw(Days_in_Month Decode_Month);

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

use lib '/app/tools/data_classes/lib';
use Client::Service;

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

use base 'RPS::Import::Importer';

my %field_map = (
    1 => {
        month          => 1,  # B
        year           => 2,  # C
        catalog_number => 3,  # D
        upc            => 4,  # E
        isrc           => 5,  # F
        artist         => 6,  # G
        album          => 7,  # H
        track          => 8,  # I
        country        => 10, # K
        service        => 11, # L
        units          => 12, # M
        revenue        => 16, # Q       
    },

);

my %gServiceFormatMap = (
    'rhapsody - streams'      => RPS::File::Sale::FORMAT_STREAM,
    'xbox music \(zune\)'     => RPS::File::Sale::FORMAT_STREAM,
    'amazonmp3 cloud us'      => RPS::File::Sale::FORMAT_STREAM,
    'amazonmp3 us'            => RPS::File::Sale::FORMAT_DOWNLOAD,
    'amazon cloud us'         => RPS::File::Sale::FORMAT_DOWNLOAD,
    'itunes match (us|ca|mx)' => RPS::File::Sale::FORMAT_STREAM,
    'itunes (us|ca|mx)'       => RPS::File::Sale::FORMAT_DOWNLOAD,
    'last.fm - (interactive|radio)'                 => RPS::File::Sale::FORMAT_STREAM,
    'slacker - (basic|plus|premium) radio service'  => RPS::File::Sale::FORMAT_STREAM,
    'zune - monthly zune pass 15 plus 10'           => RPS::File::Sale::FORMAT_STREAM,
    'amazon cloud us'         => RPS::File::Sale::FORMAT_DOWNLOAD,
    'medianet digital'        => RPS::File::Sale::FORMAT_STREAM,
    'amazonmp3'               => RPS::File::Sale::FORMAT_DOWNLOAD,
    'emusic (ca|us)'          => RPS::File::Sale::FORMAT_DOWNLOAD,
);

#public methods

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

    my $lines = $args{lines};
    my $version = $args{file}->VersionNum();
    my $fileName = $args{file}->OrigFileName();
    my @sheets = @{ $args{sheets} };

    return undef unless ($lines);

    my $linenum = 1;
    
    my $offsets = $field_map{$version};
    my %errors = ();
     
    foreach my $line(@$lines)
    {       
        my $countryName = lc $line->[ $offsets->{country} ];
        if ($countryName eq 'country of sale')  # skip header
        {
            $linenum++;
            next;
        }

        my $serviceName = $line->[ $offsets->{service} ];
        my $serviceID;
        
        if($serviceName){
            $serviceID = $self->getServiceID( $serviceName ) || $RPS::Import::ServiceMap::SERVICE_ALIASES{ lc $serviceName };
        }
        
        my $album  = $line->[ $offsets->{album} ];
        my $track  = $line->[ $offsets->{track} ];
        

        next if ($countryName =~ m/^$/ && $album =~ m/^$/ && $track =~ m/^$/); # blank lines at eof

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

            if(!$countryCode || '' eq $countryCode)
            {
                $self->errstr("Unknown country '$countryName' in line:".$linenum);
                return undef;
            }
        }
        else
        {
            $self->errstr("Missing country in line:".$linenum);
            return undef;
        }

        if(!$countryName || '' eq $countryName) {
            $self->errstr("Missing country in line:".$linenum);
            return undef;
        }

        my ($dateBegin, $dateEnd) = $self->_getDates($line->[ $offsets->{year} ], 
        $line->[ $offsets->{month} ]);     
        
        my $artist = $line->[ $offsets->{artist} ];
               
        my $catalog_number = $line->[ $offsets->{catalog_number} ];
        
        my $upc    = Common::Util::normalize_upc($line->[ $offsets->{upc} ]);
        my $isrc   = Common::Util::normalize_isrc($line->[ $offsets->{isrc} ]);
        my ($units)       = $line->[ $offsets->{units} ];
        my $revenue = $line->[ $offsets->{revenue} ];
        
        my $product_type;
        my $format_type = $serviceName ? $self->_getFormatType( $serviceName ) : undef;

        if( $isrc )
        {
            $product_type = RPS::File::Sale::TYPE_TRACK;
        }
        else
        {
            $product_type = RPS::File::Sale::TYPE_ALBUM;
            if( $track && '' ne $track )
            {
                $album = $track; # Use track name as album name (FB17250)
                undef $track;
            }
        }
        
        my $price = 0;
        
        $price = $revenue / $units if($units != 0);
        
        if ($units =~ /\d+/ && ($track || $album) && defined $price && $artist) 
        {
            if( $price < 0 && $units > 0 ) # returns
            {
                $price = abs($price);
                $units *= -1;
            }

            if( !$format_type && !$serviceName )
            {
                # From Case 1967
                # If blank & product = track & PPU < .50 = DTeth.  If Blank + product = track + PPU > .51 = D.  
                # If blank & product = album & PPU < 3 = DTeth.  If Blank + product = album + PPU > 3.01 = D.  
                my $ppu = $price / $units;  # recall, price is _net_ revenue
                if( $product_type eq RPS::File::Sale::TYPE_TRACK )
                {
                    $format_type = ( abs($ppu) <= 0.50 ) ? RPS::File::Sale::FORMAT_TETHERED : RPS::File::Sale::FORMAT_DOWNLOAD;
                }
                elsif( $product_type eq RPS::File::Sale::TYPE_ALBUM )
                {
                    $format_type = ( abs($ppu) <= 3 ) ? RPS::File::Sale::FORMAT_TETHERED : RPS::File::Sale::FORMAT_DOWNLOAD;
                }

            }

            unless ($countryCode or exists $errors{$countryName}) {
                $self->errstr('unknown country:'.$countryName . " line:".$linenum);
                print STDERR "country: '$countryName' line: $linenum\n";
                $errors{$countryName} = 1;
            }
            unless ($dateBegin && $dateEnd) {
                $self->errstr("couldn't get dates");
                print STDERR 'y,m: ', $line->[ $offsets->{year} ], ',', $line->[ $offsets->{month} ], "\n";
                return undef;
            }
            
            if($serviceName){
            
                unless ($serviceID) {
                    unless ($errors{$serviceName}) {
                        $self->errstr('Unknown service:'.$serviceName);
                        print STDERR "Unknown service: '$serviceName'\n";
                        $errors{$serviceName} = 1;
                    }
                }
            }
            my $sale = RPS::Import::SaleRec->new();

            $sale->serviceID($serviceID) if ($serviceName);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->upc($upc);
            $sale->isrc($isrc) if( $product_type eq RPS::File::Sale::TYPE_TRACK );
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->trackName($track) if( $product_type eq RPS::File::Sale::TYPE_TRACK );
            $sale->units($units);
            $sale->price($price);
            $sale->productType($product_type);
            $sale->formatType($format_type);
            $sale->lineNum($linenum);
            $sale->countryCode($countryCode);
            $sale->clientProductID($catalog_number);

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

    return $linenum;
}



#
# Private methods
#

sub _getFormatType {
    my $self = shift;
    my $serviceName = shift;
    my $_format;

    # New and improved format type rules (see Case 1967):
    #
    # If service name ends in 
    #   streams = DS
    #   downloads = D
    #   basic = Dteth
    #   plays = DS
    #   MediaNet Digital - albums = D
    #   Mix and Burn = D
    #   Napster - ads = DS
    #   Napster - OTA = D
    #   Navio / gBox = D
    #   Passalong = D
    #   Pure Tracks = D
    #   Ruckus Network - university = DS
    #   SecuryCast Download = D
    #   Slacker - basic = DS
    #   Slacker - premium = DS
    #   T-Online = D
    #   Verizon = D
    #   Spring = D
    #   Sprint = D
    #   Rogers Wireless - subscriptions = DTeth
    #   Napster - download = D
    #   Rogers Wireless - subscriptions = D
    #   Virginmega.fr = D

    # If blank & product = track & PPU < .50 = DTeth.  If Blank + product = track + PPU > .51 = D.  
    # If blank & product = album & PPU < 3 = DTeth.  If Blank + product = album + PPU > 3.01 = D.  

    if( $serviceName =~ /streams$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /downloads$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /basic$/i ) # = Dteth
    {
        $_format = RPS::File::Sale::FORMAT_TETHERED;
    }
    elsif( $serviceName =~ /plays$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /MediaNet Digital - albums$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Mix and Burn$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Napster - ads$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /Napster - OTA$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Navio \/ gBox$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Passalong$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Pure Tracks$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Ruckus Network - university$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /SecuryCast Download$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Slacker - basic$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /Slacker - premium$/i ) # = DS
    {
        $_format = RPS::File::Sale::FORMAT_STREAM;
    }
    elsif( $serviceName =~ /T-Online$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Verizon$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Spring$/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Sprint/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Rogers Wireless - subscriptions/i ) # = DTeth
    {
        $_format = RPS::File::Sale::FORMAT_TETHERED;
    }
    elsif( $serviceName =~ /Napster - download/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /Rogers Wireless - subscriptions/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }
    elsif( $serviceName =~ /virginmega.fr/i ) # = D
    {
        $_format = RPS::File::Sale::FORMAT_DOWNLOAD;
    }

    # Old-style format lookup (FB17031).
    #
#    foreach my $s (keys %gServiceFormatMap)
#    {
#        if( $serviceName =~ /$s/i )
#        {
#            $_format = $gServiceFormatMap{$s};
#            last;
#        }
#    }

    return $_format;
}

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

    my ($dateBegin, $dateEnd);
    
    if(!$year || !$month){
        return undef;
    }
    
    my %months =
    ("jan" => 1,
     "feb" => 2,
     "mar" => 3,
     "apr" => 4,
     "may" => 5,
     "jun" => 6,
     "jul" => 7,
     "aug" => 8,
     "sep" => 9,
     "oct" => 10,
     "nov" => 11,
     "dec" => 12);
     
     my $month_num;
     
    if((lc $month) =~ /(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)/)
    {
        my $month_abbr = $1;
          
        $month_num = $months{$month_abbr};

        if(!$month_num){
            return undef;
        }

        $dateBegin = sprintf("%04d-%02d-%02d", $year, $month_num, 1);
        $dateEnd   = sprintf("%04d-%02d-%02d", $year, $month_num, Days_in_Month($year, $month_num));
    }
    elsif( $month =~ /q(\d)/i )
    {
        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);
        }

    }
     
    return ($dateBegin, $dateEnd);
}

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