package RPS::Import::RSDigitalFmt2;

#Created from specs in Fog Bugz Case 9654

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

my %field_map = (
    2 => {
        label              => 0,
        service_id         => 1,
        country            => 3,
        date_begin         => 4,
        date_end           => 5,
        product_type       => 6,
        format             => 7,
        service_product_id => 9,
        client_product_id  => 10,
        artist             => 11,
        upc                => 13,
        album              => 14,
        isrc               => 15,
        track_number       => 16,
        track              => 17,
        units              => 18,
        currency_code      => 19,
        free               => 22,
        price              => 24,
        media_type         => 25,

    },
);

my %product_type_map = (
    "a" => RPS::File::Sale::TYPE_ALBUM,
    "t" => RPS::File::Sale::TYPE_TRACK
);

my %format_map = (
    "1"  => RPS::File::Sale::FORMAT_DOWNLOAD,
    "2"  => RPS::File::Sale::FORMAT_DOWNLOADPREMIUM,
    "3"  => RPS::File::Sale::FORMAT_DOWNLOADUPGRADE,
    "4"  => RPS::File::Sale::FORMAT_DUALDOWNLOAD,
    "5"  => RPS::File::Sale::FORMAT_TETHERED,
    "6"  => RPS::File::Sale::FORMAT_VPD,
    "7"  => RPS::File::Sale::FORMAT_RINGTONE,
    "8"  => RPS::File::Sale::FORMAT_RINGBACK,
    "9"  => RPS::File::Sale::FORMAT_RINGTONE,          # was FORMAT_SMSTONE (FB1324)
    "10" => RPS::File::Sale::FORMAT_STREAM,
    "11" => RPS::File::Sale::FORMAT_STREAM,            # was FORMAT_VIDEOSTREAM (FB1324)
    "12" => RPS::File::Sale::FORMAT_BACKGROUNDMUSIC,
    "13" => RPS::File::Sale::FORMAT_JUKEBOX
);

my %media_type_map = (
    "a" => RPS::DB::Item::MediaType::kMediaTypeAudio,
    "v" => RPS::DB::Item::MediaType::kMediaTypeVideo
);

my %free_map = (
    'y' => 1,
    'n' => 0
);

#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  = ();

    my $currencyCode;

    $linenum = 1;

    my @valid_services = Client::Service::GetAllServiceIDs();

    my %valid_services_hash;

    foreach my $service_id (@valid_services) {
        $valid_services_hash{$service_id} = 1;
    }

    foreach my $line (@$lines) {
        my $label              = $line->[ $offsets->{label} ];
        my $service_id         = $line->[ $offsets->{service_id} ];
        my $country            = uc $line->[ $offsets->{country} ];
        my $f_date_begin       = $line->[ $offsets->{date_begin} ];
        my $f_date_end         = $line->[ $offsets->{date_end} ];
        my $f_product_type     = lc $line->[ $offsets->{product_type} ];
        my $f_format           = lc $line->[ $offsets->{format} ];
        my $service_product_id = $line->[ $offsets->{service_product_id} ];
        my $client_product_id  = $line->[ $offsets->{client_product_id} ];
        my $artist             = $line->[ $offsets->{artist} ];
        my $upc                = $line->[ $offsets->{upc} ];
        my $album              = $line->[ $offsets->{album} ];
        my $isrc               = $line->[ $offsets->{isrc} ];
        my $track_number       = $line->[ $offsets->{track_number} ];
        my $track              = $line->[ $offsets->{track} ];
        my $units              = $line->[ $offsets->{units} ];
        my $currency_code      = $line->[ $offsets->{currency_code} ];
        my $f_free             = lc $line->[ $offsets->{free} ];
        my $price              = $line->[ $offsets->{price} ];
        my $f_media_type       = lc $line->[ $offsets->{media_type} ];

        $upc =~ s/[^0-9]//g;
        $isrc = normalize_isrc($isrc);

        my ( $date_begin, $date_end ) = $self->_getDates( date_begin => $f_date_begin, date_end => $f_date_end, type => 'iso' );

        #        if(($f_date_begin =~ /^\d{4}-\d{2}$/) &&
        #        ($f_date_end =~ /^\d{4}-\d{2}$/)){
        #            $f_date_begin = $f_date_begin."-01";
        #            $f_date_end   = $f_date_end."-01";
        #
        #            ($date_begin, $date_end) =
        #            $self->_getDates(date_begin=>$f_date_begin,
        #            date_end=>$f_date_end, type=>"iso");
        #        }
        #        else{
        #            ($date_begin, $date_end) = (undef, undef);
        #        }

        my $product_type = $product_type_map{$f_product_type};
        my $format       = $format_map{$f_format};
        my $free         = $free_map{$f_free};
        my $media_type   = $media_type_map{$f_media_type};

        if (   $label
            && $service_id
            && $country
            && $f_date_begin
            && $f_date_end
            && $f_product_type
            && $f_format
            && $artist
            && ( $upc || $album || $isrc || $track )
            && $units =~ /\d+/
            && $currency_code
            && $f_media_type ) {
            if ( ( $units == 0 ) && ( $price == 0 ) ) {
                $linenum++;
                next;
            }

            if ( ( $units == 0 ) && ($free) ) {
                $self->errstr("Sale with no units has 'free' flag set at line number: $linenum");
                print STDERR "Sale with no units has 'free' flag set at line number: $linenum\n";
                return undef;
            }

            if ( ( $units < 0 ) && ($free) ) {
                $self->errstr("Sale with negative units has 'free' flag set at line number: $linenum");
                print STDERR "Sale with negative units has 'free' flag set at line number: $linenum\n";
                return undef;
            }

            if ( ( defined $price ) && ( $price != 0 ) && ($free) ) {
                $self->errstr("Price set for 'free' sale at line number: $linenum");
                print STDERR "Price set for 'free' sale at line number: $linenum\n";
                return undef;
            }

            unless ( $date_begin && $date_end ) {
                $self->errstr( "Couldn't get dates from $f_date_begin," . "$f_date_end (need yyyy-mm), line number: $linenum" );

                print STDERR "couldn't get dates from $f_date_begin," . "$f_date_end (need yyyy-mm), line number: $linenum\n";
                return undef;
            }

            unless ( ( $valid_services_hash{$service_id} ) && ( $service_id != 191 ) ) {
                $self->errstr("Invalid service ID $service_id at linenum: $linenum");
                print STDERR "Invalid service ID $service_id at linenum: $linenum\n";
                return undef;
            }

            unless ($product_type) {
                $self->errstr( "Invalid product type: $f_product_type (need 'A' or 'T') " . "at linenum: $linenum" );
                print STDERR "Invalid product type: $f_product_type (need 'A' or 'T') " . " at linenum: $linenum\n";
                return undef;
            }

            unless ($format) {
                $self->errstr("Invalid format ID: $f_format at line number: $linenum");
                print STDERR "Invalid format ID: $f_format at line number: $linenum\n";
                return undef;
            }

            unless ( $Common::Consts::CODE_TO_COUNTRY{$country} ) {
                $self->errstr("Invalid country code: $country at line number: $linenum");

                print STDERR "Invalid country code: $country at line number: $linenum\n";
                return undef;
            }

            unless ($media_type) {
                $self->errstr( "Invalid media type: $f_media_type " . "(need 'A' or 'V') at line number: $linenum" );

                print STDERR "Invalid media type: $f_media_type " . "(need 'A' or 'V') at line number: $linenum\n";
                return undef;
            }

            if (   ( $media_type ne RPS::DB::Item::MediaType::kMediaTypeVideo )
                && ( $f_format eq '11' ) ) {
                $self->errstr( "Media type set to 'Audio' for 'Video Stream' " . "format type at line number: $linenum" );

                print STDERR "Media type set to 'Audio' for 'Video Stream' " . "format type at line number: $linenum\n";
                return undef;
            }

            if ($f_free) {
                if ( !defined $free ) {
                    $self->errstr( "Invalid free flag $f_free (need 'Y' or 'N' or empty) " . " at line number: $linenum" );
                    print STDERR "Invalid free flag $f_free (need 'Y' or 'N' or empty) " . "at line number: $linenum\n";
                    return undef;
                }
            }

            my $sale = RPS::Import::SaleRec->new();
            $sale->labelName($label);
            $sale->serviceID($service_id);
            $sale->countryCode($country);
            $sale->dateBegin($date_begin);
            $sale->dateEnd($date_end);
            $sale->productType($product_type);
            $sale->formatType($format);
            $sale->serviceProductID($service_product_id);
            $sale->clientProductID($client_product_id);
            $sale->artistName($artist);
            $sale->upc($upc);
            $sale->albumName($album);
            $sale->isrc($isrc)             if ( $product_type eq RPS::File::Sale::TYPE_TRACK );
            $sale->trackNum($track_number) if ( $product_type eq RPS::File::Sale::TYPE_TRACK );
            $sale->trackName($track)       if ( $product_type eq RPS::File::Sale::TYPE_TRACK );
            $sale->currencyCode($currency_code);
            $sale->mediaType($media_type);
            $sale->lineNum($linenum);

            if ( ( $units == 0 ) && ( $price != 0 ) ) {

                if ( $price < 0 ) {
                    $sale->units(-1);
                    $sale->price( abs $price );
                    $self->_insertSale( sale => $sale );

                    $sale->units(1);
                    $sale->price(0);
                    $self->_insertSale( sale => $sale );
                } elsif ( $price > 0 ) {
                    $sale->units(1);
                    $sale->price($price);
                    $self->_insertSale( sale => $sale );

                    $sale->units(-1);
                    $sale->price(0);
                    $self->_insertSale( sale => $sale );
                }
            } else {

                if ( ( $units > 0 ) && ( $price > 0 ) ) {
                    $price /= $units;
                } elsif ( ( $units > 0 ) && ( $price < 0 ) ) {
                    $price = ( abs $price ) / $units;
                    $units *= -1;
                } elsif ( ( $units < 0 ) && ( $price > 0 ) ) {
                    $price = $price / ( abs $units );
                } elsif ( ( $units < 0 ) && ( $price < 0 ) ) {
                    $price = ( abs $price ) / ( abs $units );
                }

                $sale->units($units);
                $sale->free($free)   if ($free);
                $sale->price($price) if ( !$free );

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

        $linenum++;

    }

    return $linenum;
}

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