package RPS::Import::YouTube2;

use strict;

use Date::Calc qw(Days_in_Month Decode_Month);

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

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 base 'RPS::Import::Importer';

my %field_map = (
    7 =>
    {
        header_col => 0,
        date_col => 1,        
        service_product_id => 1,
        track_ii => 2,
        units_i => 6,
        units_ii => 8,
        units_iii => 10,
        price => 13,
        isrc => 17,
        upc => 19,
        artist => 20,
        track_i => 21,
        album => 22,
        label => 23  
    },
);

#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} };
    
    my $track_url_start = "http://youtube.com/watch?v=";

    return undef unless ($lines);

    my $linenum = 1;
           
    my $offsets = $field_map{$version};
    my %errors = ();  
        
    my ($dateBegin, $dateEnd);
    
    my $type = RPS::File::Sale::TYPE_TRACK;
    my $format = RPS::File::Sale::FORMAT_STREAM; # was FORMAT_VIDEOSTREAM (FB1324)
    
    my $header;
    
    foreach my $line(@$lines)
    {
        my $service_product_id = $line->[$offsets->{service_product_id}];
        my $artist = $line->[$offsets->{artist}];
        my $track = $line->[$offsets->{track_i}];
        
        if(!$track){
            $track = $line->[$offsets->{track_ii}];
        }
        
        my $album = $line->[$offsets->{album}];
        my $isrc = normalize_isrc($line->[$offsets->{isrc}]);
        my $units = $line->[$offsets->{units_i}] + 
        $line->[$offsets->{units_ii}] + $line->[$offsets->{units_iii}];
        
        
        
        my $price = $line->[$offsets->{price}];
        my $label = $line->[$offsets->{label}];
        my $upc = $line->[$offsets->{upc}];
        
        $label =~ s/\(www.*\)//g;
        
        my $f_date_begin;
        my $f_date_end;
        
        if(!$dateBegin && 
        ($line->[$offsets->{date_col}] =~ /\d{4}\D\d{2}\D\d{2}/)){
            $dateBegin = $line->[$offsets->{date_col}];
        }
        elsif(!$dateEnd && 
        ($line->[$offsets->{date_col}] =~ /\d{4}\D\d{2}\D\d{2}/)){
            $dateEnd = $line->[$offsets->{date_col}];
        }
        
        if($line->[$offsets->{header_col}] =~ /#(.*)/){
            $header = $line->[$offsets->{header_col}];
            $linenum++;
            next;
        }
        
        
        if($service_product_id && $units =~ /\d+/ && $price =~ /\d+/ 
        && ($header =~ /commercial-share per video_id table/ || 
        $header =~ /ugc-share per video_id table/)) 
        {           
            $price = ($price / $units) if($units > 0);
            
            my $free = $price == 0 ? 1 : 0;
            
            if(!$track){
                $track = $track_url_start.$service_product_id;
            }
            
            my $sale = RPS::Import::SaleRec->new();

            $sale->serviceProductID($service_product_id);
            $sale->mediaType(2);           
            $sale->productType($type);
            $sale->formatType($format);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->isrc($isrc) if ($isrc);
            $sale->upc($upc) if ($upc);
            $sale->artistName($artist);
            $sale->trackName($track);
            $sale->albumName($album);
            $sale->labelName($label);
            $sale->units($units);
            $sale->price($price);
            $sale->free($free);
            $sale->lineNum($linenum);
            
            #$args{dumper}($sale);  ## for cmd-line testing
            $self->_insertSale(sale => $sale);
        }
        
        $linenum++;
    }
    

    return $linenum;
}

#
# Private methods
#


sub _getDates
{
    my $self       = shift;
    my $date_begin = shift;
    my $date_end   = shift;
    
   $date_begin =~ /(\d+)\/(\d+)\/(\d+)/;
   
   my $year = $3;
   
    if($year < 2000){
        $year += 2000;
   }
   
   my ($begin_month, $begin_day, $begin_year) = ($1, $2, $year);
   
   #print STDERR "Passed date begin: $date_begin date end: $date_end\n";
     
   $date_end   =~ /(\d+)\/(\d+)\/(\d+)/;
   
   $year = $3;
   
   if($year < 2000){
        $year += 2000;
   }
   
   my ($end_month, $end_day, $end_year) = ($1, $2, $year);
   
   #print STDERR "End month $end_month end day $end_day ".
   "end year $end_year begin month $begin_month begin day $begin_day begin year $begin_year\n";
   
   if(!($end_month && $end_day && $end_year && 
   $begin_month && $begin_day && $begin_year)){
        return undef;
   }
       
    my $dateBegin = sprintf("%04d-%02d-%02d", $begin_year, $begin_month, $begin_day);
    my $dateEnd   = sprintf("%04d-%02d-%02d", $end_year, $end_month, $end_day);
    
    return ($dateBegin, $dateEnd);    
    
}

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