package RPS::Import::Fontana2008;

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 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 %service_map = (
    'Calabash Music'            => Client::Service::DSP_CALABASH,
    'Dancetracks Digital'       => Client::Service::DSP_DANCETRACKS,
    'DestraMusic.com'           => Client::Service::DSP_DESTRAMUSIC,
    'iTunes Music Store'        => Client::Service::DSP_ITUNES,
    'Mix and Burn'              => Client::Service::DSP_MIXANDBURN,
    'm-Qube'                    => Client::Service::DSP_MQUBE,
    'MSN Music Service'         => Client::Service::DSP_MSNMUSIC,
    'RealNetworks / Rhapsody'   => Client::Service::DSP_REAL,
    'T-Online'                  => Client::Service::DSP_TONLINE,
    'Virtual Music Stores'      => Client::Service::DSP_VIRTUALMUSICSTORE,
    'Virginmega.fr'             => Client::Service::DSP_VIRGINMEGA,
    'Snocap/Myspace'            => Client::Service::DSP_SNOCAP,
    'Napster - Streams'         => Client::Service::DSP_NAPSTER,
    'Rhapsody'                  => Client::Service::DSP_REAL,
    'FNAC'                      => Client::Service::DSP_FNAC,
    'Starbucks'                 => Client::Service::DSP_STARBUCKS,
    'My Store'                  => Client::Service::DSP_MYSTORE,
    'Audio Lunchbox - Streams'  => Client::Service::DSP_AUDIOLUNCHBOX,
    'eMusic'                    => Client::Service::DSP_EMUSIC,
    'Sony Connect'              => Client::Service::DSP_SONY,
    'Fun Mobility'              => Client::Service::DSP_FUNMOBILITY,
    'Zingy Mobile'              => Client::Service::DSP_ZINGY,
    'Beatport.com'              => Client::Service::DSP_BEATPORT,
    'Other Music'               => Client::Service::DSP_OTHERMUSIC,
    'Verizon'                   => Client::Service::DSP_VERIZON,
    'MediaNet Digital'          => Client::Service::DSP_MEDIANET,
    'OD2 (Loudeye)'             => Client::Service::DSP_OD2,
    'SecuryCast Download'       => Client::Service::DSP_SECURYCAST,
    'Thumbplay - **updated'     => Client::Service::DSP_THUMBPLAY,
    'Bell Mobility Full Track'  => Client::Service::DSP_BELLMOBILITY,
    'Hudson Entertainment (US)' => Client::Service::DSP_HUDSON,
    'Pure Tracks'               => Client::Service::DSP_PURETRACKS,
    'Jamba/Jamster'             => Client::Service::DSP_JAMSTER,
    'Navio / gBox'              => Client::Service::DSP_NAVIO,
    'Bell Mobility Ringtone'    => Client::Service::DSP_BELLMOBILITY,
    'Mbop Digital'              => Client::Service::DSP_MBOPDIGITAL,
    'Slacker'                   => Client::Service::DSP_SLACKERINC,
    'Livewire Mobile / Groove Mobile'
                                => Client::Service::DSP_GROOVEMOBILE,
    'Amazon MP3'                => Client::Service::DSP_AMAZON,
    'Rogers Wireless Ringtone'
                                => Client::Service::DSP_ROGERSWIRELESS,
    'm-Qube / VeriSign'         => Client::Service::DSP_MQUBE,
    'BOOST MOBILE/NEXTEL'       => Client::Service::DSP_BOOST,
    'LISTEN/RHAPSODY'           => Client::Service::DSP_LISTEN,
    'MEDIAPORT ENTERTAINMENT INC.' => Client::Service::DSP_MEDIAPORT,
    'MOD SYSTEMS, INC.'         => Client::Service::DSP_MODSYSTEMS,
    'MUSICGREMLIN, INC.'        => Client::Service::DSP_MUSICGREMLIN,
    'NextRadio Solutions'       => Client::Service::DSP_NEXTRADIO,
    'T-MOBILE USA'              => Client::Service::DSP_TMOBILE,
    'VIRGIN MOBILE USA'         => Client::Service::DSP_VIRGINMOBILE,
    'APPLE DIGITAL SALES'       => Client::Service::DSP_ITUNES,
    'LAST.FM'                   => Client::Service::DSP_LASTFM,
    'MOHEN, INC.'               => Client::Service::DSP_SPIRALFROG,
    'DIGITAL KIOSK TECHNOLOGIES LLC' => Client::Service::DSP_DIGITALKIOSKTECH,
    'YOU TUBE'                  => Client::Service::DSP_YOUTUBE,
    'VIRTUAL MUSIC STORES, INC.' => Client::Service::DSP_VIRTUALMUSICSTORE,
    'TEENHOLLYWOOD.COM INC.'    => Client::Service::DSP_TEENHOLLYWOOD,
    'PURETRACKS/B3'             => Client::Service::DSP_PURETRACKS,
    'NEUROTIC / AMPLIFIED'      => Client::Service::DSP_NEUROTICMEDIA,
    'NAVIO SYSTEMS, INC.'       => Client::Service::DSP_NAVIO,
    'LA LA MEDIA, INC.'         => Client::Service::DSP_LALA,
    'FULL AUDIO/MUSICNOW'       => Client::Service::DSP_MUSICNOW,
    'CLEAR CHANNEL BROADCASTING, INC.' => Client::Service::DSP_CLEARCHANNEL,
    'CELLMANIA'                 => Client::Service::DSP_CELLMANIA,
                               );

my %fontana_formats = (
    'PERMANENT DOWNLOADS'            => RPS::File::Sale::FORMAT_DOWNLOAD,
    'PERMANENT DOWNLOADS PROMO'      => RPS::File::Sale::FORMAT_DOWNLOAD,
    'AD SUPPORTED STREAMS'           => RPS::File::Sale::FORMAT_STREAM,
    'KIOSK'                          => RPS::File::Sale::FORMAT_DOWNLOAD,
    'OTA PERMANENT DOWNLOADS'        => RPS::File::Sale::FORMAT_DOWNLOAD,
    'PORTABLE SUB CLIENT PLAYS'      => RPS::File::Sale::FORMAT_STREAM,
    'PORTABLE SUB DEVICE PLAYS'      => RPS::File::Sale::FORMAT_STREAM,
    'PORTABLE SUB STREAMS'           => RPS::File::Sale::FORMAT_STREAM,
    'PROGRAMMED STREAMING'           => RPS::File::Sale::FORMAT_STREAM,
    'RINGBACKS'                      => RPS::File::Sale::FORMAT_RINGTONE,
    'STANDARD MOBILE RINGSOUNDS'     => RPS::File::Sale::FORMAT_RINGTONE,
    'STREAMS'                        => RPS::File::Sale::FORMAT_STREAM,
    'SUBSCRIPTION MASTERTONES'       => RPS::File::Sale::FORMAT_RINGTONE,
    'TETHERED/CONDITIONAL DOWNLOADS' => RPS::File::Sale::FORMAT_TETHERED,
    'VIDEO DOWNLOADS'                => RPS::File::Sale::FORMAT_DOWNLOAD, # was FORMAT_VIDEO (FB1324)
    'USER GENERATED STREAMS (UMG AUDIO / USER VIDEO)' => RPS::File::Sale::FORMAT_STREAM, # was FORMAT_VIDEOSTREAM (FB1324)
    'VIDEO STREAMS'                  => RPS::File::Sale::FORMAT_STREAM, # was FORMAT_VIDEOSTREAM (FB1324)
    'DRM FREE UPGRADE'               => RPS::File::Sale::FORMAT_DOWNLOADUPGRADE,
    'MOBILE VIDEO STREAMING'         => RPS::File::Sale::FORMAT_STREAM, # was FORMAT_VIDEOSTREAM (FB1324)
    'OTA VIDEO DOWNLOADS'            => RPS::File::Sale::FORMAT_DOWNLOAD,
    'PERM DL FROM OTA - W/O WHOLESALE' => RPS::File::Sale::FORMAT_DOWNLOAD,
    'PROGRAMMED VIDEO STREAMING'     => RPS::File::Sale::FORMAT_STREAM, # was FORMAT_VIDEOSTREAM (FB1324)
    'SUBSCRIPTION OTA PERMANENT DOWNLOADS (AUDIO)' => RPS::File::Sale::FORMAT_VPD,
);

my %field_map = (
    4 =>
    {
        format  => 1,
        service => 2,
        type    => 4,
        artist  => 5,
        album   => 6,
        track   => 8,
        isrc    => 9,
        units   => 11,
        price   => 12,
    },
    5 =>
    {
        format  => 3,
        service => 5,
        type    => 8,
        isrc    => 9,
        artist  => 10,
        track   => 11,
        album   => 12,
        units   => 15,
        price   => 16,
    },
    6 =>
    {
        label   => 0,
        format  => 3,
        service => 5,
        type    => 8,
        upc     => 9,
        artist  => 10,
        album   => 11,
        units   => 16,
        price   => 17,
    },
);

#public methods

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

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

    return undef unless ($lines);

    my $gross_total = 0;

    my $linenum = 1;

    my $offsets = $field_map{$version};
    my %errors = ();

    #$canadian_dollar = 1 if($fileName =~ /^CAD_/);

    my ($dateBegin, $dateEnd) = $self->_getDates($fileName);

    unless ($dateBegin && $dateEnd) {
                $self->errstr("couldn't get dates from filename: $fileName");
                print STDERR "$fileName\n";
                return undef;
            }

    foreach my $line(@$lines)
    {

        my $serviceName = $line->[ $offsets->{service} ];
        $serviceName =~ s/\s-\s\w+.*$//;
        $serviceName =~ s/\ssubscription.*$//i;
        $serviceName =~ s/\sdownload.*$//i;
        my $serviceID = $self->getServiceID($serviceName) || $service_map{$serviceName};

        my $strippedServiceName = $serviceName =~ s/\s/_/g;
        $serviceID = $self->getServiceID($strippedServiceName) ||
        $service_map{$strippedServiceName} if($serviceID eq "");

        my $artist = $line->[ $offsets->{artist} ];
        my $album  = $line->[ $offsets->{album} ];
        my $track  = $line->[ $offsets->{track} ];


        my $isrc   = Common::Util::normalize_isrc($line->[ $offsets->{isrc} ]);
        my $upc    = Common::Util::normalize_upc($line->[ $offsets->{upc} ]);
        my $label  = $line->[ $offsets->{label} ] if( defined($offsets->{label}) );
        my ($units)       = $line->[ $offsets->{units} ];
        my ($total_price) = $line->[ $offsets->{price} ];

        if($units eq ""){
            $linenum++;
            next;
        }


        $total_price =~ s/(\-?\$?\,)//g;

        my $price = $total_price / $units if (defined $total_price && defined $units && $units != 0);

        my $type;
        if ($line->[ $offsets->{type} ] =~ /track/i) {
            $type = RPS::File::Sale::TYPE_TRACK;
        }
        elsif ($line->[ $offsets->{type} ] =~ /album/i) {
            $type = RPS::File::Sale::TYPE_ALBUM;
        }
        elsif (($line->[ $offsets->{type}] =~ /sold as/i)
        || $line->[ $offsets->{type}]  eq ""){
        }
        else{
             unless ($errors{$type}) {
                    $self->errstr("unknown type: ".$line->[$offsets->{type}]." at line number: $linenum");
                    print STDERR "type: ".$line->[$offsets->{type}]."\n";
                    $errors{$type} = 1;
                }
                #return undef;
       	}

        my $formatName = $line->[ $offsets->{format} ];
        my $format = $fontana_formats{$formatName};
        #my $free = ($formatName =~ m/^promotional use$/i) ? 1 : 0;
        my $free = ($formatName =~ m/promo/i) ? 1 : 0;

        if($free){
            $price = 0;
        }

        my $mediaType;

        if( $formatName =~ /^video downloads$/i ||
            $formatName =~ /^user generated streams \(umg audio \/ user video\)$/i ||
            $formatName =~ /^video streams$/i ||
            $formatName =~ /^mobile video streaming$/i ||
            $formatName =~ /^programmed video streaming$/i )
        {
            $mediaType = RPS::DB::Item::MediaType::kMediaTypeVideo;
        }
        else
        {
            $mediaType = RPS::DB::Item::MediaType::kMediaTypeAudio;
        }

        if($units && $album && $artist && defined $price && $type)
        {
            unless ($format) {
                unless ($errors{$formatName}) {
                    $self->errstr("unknown format $formatName at line number: $linenum");
                    print STDERR "Format: $formatName\n";
                    $errors{$formatName} = 1;
                }
                return undef;
            }
            unless ($serviceID) {
                unless ($errors{$serviceName}) {
                    $self->errstr('Unknown service:'.$serviceName."at line number: $linenum");
                    print STDERR "unknown service: ".$line->[$offsets->{service}] . " - " . $serviceName . "\n";
                    $errors{$serviceName} = 1;
                }
                return undef;
            }
            my $sale = RPS::Import::SaleRec->new();

            $sale->serviceID($serviceID);

            $sale->mediaType($mediaType);

            $sale->labelName($label);
            $sale->productType($type);
            $sale->formatType($format);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->isrc($isrc) if ($type eq RPS::File::Sale::TYPE_TRACK);
            $sale->upc($upc) if ($upc && ($version == 6));
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->trackName($track) if ($type eq RPS::File::Sale::TYPE_TRACK);
            $sale->units($units);
            $sale->price($price);
            $sale->free($free);
            $sale->lineNum($linenum);
            $sale->countryCode('US');

            #if (1 == $canadian_dollar)
            #{
            #    $sale->currencyCode('CAD');
            #}
            #else
            #{
            #    $sale->currencyCode('USD');
            #}
            #if(defined $offsets->{currency} && $line->[$offsets->{currency}] ne "") {
            #    $sale->currencyCode(uc($line->[$offsets->{currency}]));
            #}
            #
            # !!! We'll let the inherited code decide how to set the conversion_rate.

            #$args{dumper}($sale);  ## for cmd-line testing
            $self->_insertSale(sale => $sale);
        }
        #else { print STDERR "skipped: u($units) album($album) artist($artist) price($price) type($type)\n"; }

        $linenum++;
    }

    return $linenum;
}

#
# Private methods
#


sub _getDates
{
    my $self  = shift;
    my $passed_date = shift;

    my $year;
    my $month;

    #return undef if ($year eq '' || $month eq '' || $year > 3000 || $year < 2000);

    my ($dateBegin, $dateEnd);

    if($passed_date =~ /(\d\d)(\d\d)\./){
        $month = $1;
        $year  = 2000 + $2;
    }
    elsif($passed_date =~ /(\d{2})\D(\d{2})\D(\d{2})/){
        $month = $1;
        $year = 2000 + $3;
    }
    elsif($passed_date =~ /(\d{2})\D(\d{4})/){
        $month = $1;
        $year = $2;
    }
    else{
        return undef;
    }

    $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.
###