package RPS::Import::RSFormatFull;

use strict;

use Data::Dumper;

use Date::Calc qw(Days_in_Month Add_Delta_Days);

use lib '/app/tools/common/lib';
use Common::Util;
use Common::Consts;
use Common::RSMath qw(round);
use Common::Locale;

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

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

my %channelMap = (
    retail       => RPS::File::Sale::CHANNEL_RETAIL,
    military     => RPS::File::Sale::CHANNEL_MILITARY,
    px           => RPS::File::Sale::CHANNEL_MILITARY,
    club         => RPS::File::Sale::CHANNEL_CLUB,
    'mail order' => RPS::File::Sale::CHANNEL_MAILORDER,
    direct       => RPS::File::Sale::CHANNEL_DIRECT,
);

# map version num to the field order
my %fieldMap = (
    2 => {
        'outlet'       => 0,
        'country'      => 1,
        'date'         => 2,
        'artist'       => 3,
        'catno'        => 4,
        'album'        => 5,
        'upc'          => 6,
        'sales'        => 7,
        'salesprice'   => 8,
        'returns'      => 9,
        'returnsprice' => 10,
        'net'          => 11,
        'netprice'     => 12,
        'currency'     => 13,
        'netusd'       => 14,
        'format'       => 16,
    },
    3 => {
        'outlet'       => 0,
        'country'      => 1,
        'date'         => 2,
        'artist'       => 3,
        'catno'        => 4,
        'album'        => 5,
        'format'       => 6,
        'upc'          => 7,
        'channel'      => 8,
        'pricelevel'   => 9,
        'sales'        => 10,
        'salesprice'   => 11,
        'returns'      => 12,
        'returnsprice' => 13,
        'net'          => 14,
        'netprice'     => 15,
        'currency'     => 16,
        'netusd'       => 17,
    },

    # !!! Deprecated - mcps
    4 => {
        'outlet'         => 0,
        'country'        => 1,
        'date'           => 2,
        'artist'         => 3,
        'catno'          => 4,
        'album'          => 5,
        'format'         => 6,
        'upc'            => 7,
        'channel'        => 8,
        'pricelevel'     => 9,
        'currency'       => 10,
        'wholesaleprice' => 11,
        'price'          => 12,
        'sales'          => 13,
        'salesprice'     => 14,
        'returns'        => 15,
        'returnsprice'   => 16,
        'net'            => 17,
        'netprice'       => 18,
        'free'           => 19,
        'adjustment'     => 20,
        'royaltytype'    => 21,
        'comments'       => 22,
    },
);

#public methods

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

    my $lines   = $args{lines};
    my $fileObj = $args{file};
    my $version = $self->_version;

    return undef unless ( defined $lines && defined $version );

    if ( $version == 4 ) {
        $self->errstr("Invalid version of importer ($version)");
        return undef;
    }

    my $offsets;

    if ( exists $fieldMap{$version} ) {
        $offsets = $fieldMap{$version};
    } else {
        $self->errstr('wrong version');
        return 0;
    }

    my $linenum = 2;
    shift @$lines;    ## skip header

    $fileObj->Physical(1);

    foreach my $line (@$lines) {
        unless ( $line->[ $offsets->{country} ] ) {
            $linenum++;
            next;
        }

        my $price_level = RPS::File::Sale::PLEVEL_UNKNOWN;
        my $channel     = RPS::File::Sale::CHANNEL_RETAIL;
        if ( $version == 3 || $version == 4 ) {
            if ( $line->[ $offsets->{channel} ] ) {
                my $c = lc $line->[ $offsets->{channel} ];
                $channel = $channelMap{$c};
                unless ( defined $channel ) {
                    $self->errstr("unknown channel: $c");
                    return undef;
                }
            }
            if ( $line->[ $offsets->{pricelevel} ] ) {
                my $p = lc $line->[ $offsets->{pricelevel} ];
                $p = "unknown" if ( $p =~ /(\d)/ );
                if ( $p eq 'unknown' ) {
                    $price_level = RPS::File::Sale::PLEVEL_UNKNOWN;
                } elsif ( $p eq 'full' ) {
                    $price_level = RPS::File::Sale::PLEVEL_FULL;
                } elsif ( $p =~ m/^mid(line)?$/ ) {
                    $price_level = RPS::File::Sale::PLEVEL_MID;
                } elsif ( $p eq 'budget' ) {
                    $price_level = RPS::File::Sale::PLEVEL_BUDGET;
                } elsif ( $p eq 'promo' ) {
                    $price_level = RPS::File::Sale::PLEVEL_PROMO;
                } else {
                    $self->errstr("unknown price level: $p");
                }
            }
        }

        my ( $config, $prodtype );

        if ( $line->[ $offsets->{format} ] =~ m/^dvd$/i ) {
            $config   = "DVD";
            $prodtype = RPS::File::Sale::TYPE_DVD;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^cd$/i ) {
            $config   = "CD";
            $prodtype = RPS::File::Sale::TYPE_CD;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^lp$/i ) {
            $config   = "LP";
            $prodtype = RPS::File::Sale::TYPE_LP;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^ep$/i ) {
            $config   = "EP";
            $prodtype = RPS::File::Sale::TYPE_EP;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^cd2$/i ) {
            $config   = "CD2";
            $prodtype = RPS::File::Sale::TYPE_DBL_CD;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^2cd$/i ) {
            $config   = "CD2";
            $prodtype = RPS::File::Sale::TYPE_DBL_CD;
        } elsif ( $line->[ $offsets->{format} ] =~ m/^vhs$/i ) {
            $config   = "VHS";
            $prodtype = RPS::File::Sale::TYPE_VHS;
        } elsif ( $line->[ $offsets->{format} ] =~ /DVDCD/i ) {
            $config   = "DVD/CD";
            $prodtype = RPS::File::Sale::TYPE_DVD_CD_SET;
        } elsif ( $line->[ $offsets->{format} ] =~ /cas/i ) {
            $config   = "CASS";
            $prodtype = RPS::File::Sale::TYPE_CASS;
        } elsif ( $line->[ $offsets->{format} ] =~ /CD5/i ) {
            $config   = "CD5";
            $prodtype = RPS::File::Sale::TYPE_CD_SIN;
        } else {
            $self->errstr( "unknown format: " . $line->[ $offsets->{format} ] );
            return undef;
        }

        my $catno  = $line->[ $offsets->{catno} ];
        my $outlet = $line->[ $offsets->{outlet} ];
        my $artist = $line->[ $offsets->{artist} ];
        my $album  = $line->[ $offsets->{album} ];
        my $upc    = Common::Util::normalize_upc( $line->[ $offsets->{upc} ] );

        my $countryCode;
        if ( $line->[ $offsets->{country} ] =~ m/^\w\w$/ ) {
            $countryCode = uc $line->[ $offsets->{country} ];
            $countryCode = 'GB' if ( $countryCode eq 'UK' );
        } else {
            $countryCode = $Common::Consts::COUNTRY_CODE{ lc $line->[ $offsets->{country} ] };
        }
        my $currencyCode = $line->[ $offsets->{currency} ];

        unless ($countryCode) {
            $self->errstr( "unknown country: " . $line->[ $offsets->{country} ] );
            return undef;
        }

        #	    my ($dateBegin, $dateEnd) = $self->_getDates($line->[$offsets->{date}]);
        my ( $dateBegin, $dateEnd ) =
          $self->_getDates( date_begin => $line->[ $offsets->{date} ], date_end => $line->[ $offsets->{date} ] );

        unless ( defined $dateBegin && defined $dateEnd ) {
            $self->errstr( "Line $linenum: couldn't get dates from '" . $line->[ $offsets->{date} ] . "'" );
            return undef;
        }

        my $sales   = round( $line->[ $offsets->{sales} ] );
        my $returns = round( $line->[ $offsets->{returns} ] );
        $returns *= -1 if ( $returns < 0 && $self->{clientID} != 27 );

        #$returns            *= -1;

        # JPK
        # Localization.
        # net_usd is really 'net_base_currency'.
        # Won't we need to be prepared to localize this regex?
        #
        # No - In theory all of the numeric values will always be in 'us'
        # format : 12345.67
        #
        my $price         = $line->[ $offsets->{price} ];
        my $wholesale     = $line->[ $offsets->{wholesaleprice} ];
        my $sales_price   = $line->[ $offsets->{salesprice} ];
        my $returns_price = $line->[ $offsets->{returnsprice} ];
        my $net_price     = $line->[ $offsets->{netprice} ];
        my $net_usd       = $line->[ $offsets->{netusd} ];
        $sales   = 0 if ( $sales eq "" );
        $returns = 0 if ( $returns eq "" );
        $returns_price *= -1 if ( $returns_price < 0 && $self->{clientID} != 27 );
        $returns *= -1 if ( $self->{clientID} == 27 );

        if ( sprintf( "%.2f", ( $sales_price - $returns_price ) ) != sprintf( "%.2f", $net_price )
            || $sales - $returns != $line->[ $offsets->{net} ] ) {
            print STDERR "Mismatched Sale/Returns/SalesRevenue/ReturnsRevenue l:" . $linenum . "\n";
            $self->errstr( "Mismatched Sale/Returns/SalesRevenue/ReturnsRevenue l:" . $linenum );
            return undef;
        }

        # JPK - This will need to get a little fancier.
        #
        my $convRate = 1;
        $convRate = 0 if ( $currencyCode ne Common::Client::Current()->Locale()->currencyFormat()->currencyCode() );
        if ( $currencyCode ne Common::Client::Current()->Locale()->currencyFormat()->currencyCode() ) {
            if ( $net_price != 0 && $net_usd != 0 ) {
                $convRate = $net_usd / $net_price;
                $sales_price   *= $convRate;
                $returns_price *= $convRate;
                $net_price     *= $convRate;
                $currencyCode = Common::Client::Current()->Locale()->currencyFormat()->currencyCode();
                $convRate     = 1;
            }
        }

        my $skip_sale = 0;
        if ( $outlet =~ /datapak/i && $self->{clientID} == 27 ) {
            $skip_sale = $self->_filterDatapakSale( $catno, $upc );
            if ( $skip_sale > 2 ) {
                $catno     = $skip_sale;
                $skip_sale = 0;
            }
            $catno =~ s/\s.*$//;
        }

        # If the 'free goods' flag is set, I don't believe we need to concern ourselves with any pricing.
        #
        my $free = uc( $line->[ $offsets->{free} ] ) eq 'Y' ? 1 : 0;
        if ($free) {
            $net_price = $sales_price = $returns_price = 0;
        }

        my $adjustment = uc( $line->[ $offsets->{adjustment} ] ) eq 'Y' ? 1 : 0;
        my $comments;
        if ($adjustment) {

            # !!! Only sale units should be specified for an adjustment.
            #
            $comments = $line->[ $offsets->{comments} ];
        }

        # Parse the 'Royalty Type' column, if any.
        #

        my $usMechStatus = 0;
        my $ukMechStatus = 0;
        my $labelStatus  = 0;
        my $artistStatus = 0;

        if ( defined $offsets->{royaltytype} ) {

            # !!! and canadian, someday...
            #
            my $royaltyType = $line->[ $offsets->{royaltytype} ];
            if ( $royaltyType && 'ALL' ne uc($royaltyType) ) {

                # Turn -off- all the types, and only enable those that were specified.
                #
                $usMechStatus = 2;
                $ukMechStatus = 2;
                $labelStatus  = 2;
                $artistStatus = 2;

                my @types = split( ',', $royaltyType );
                foreach my $type (@types) {
                    my $testType = uc($type);
                    $artistStatus = 0 if ( 'ARTIST' eq $testType );
                    $labelStatus  = 0 if ( 'LABEL' eq $testType );
                    $usMechStatus = 0 if ( 'US-MECH' eq $testType );
                    $ukMechStatus = 0 if ( 'UK-MECH' eq $testType );
                    $ukMechStatus = 0 if ( 'GB-MECH' eq $testType );    # Just in case...
                }
            }
        }

        if (   $prodtype
            && ( $free || $net_price != 0 || $sales_price != 0 || $returns_price != 0 || $sales != 0 || $returns != 0 )
            && ( $album || $upc || $catno )
            && $skip_sale == 0 ) {
            my $sale = RPS::Import::SaleRec->new();

            $sale->productType($prodtype);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->outlet($outlet);
            $sale->clientProductID($catno);
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->upc($upc);
            $sale->free($free);
            $sale->price($price);
            $sale->wholesalePrice($wholesale);
            $sale->sales($sales);
            $sale->salesRevenue($sales_price);
            $sale->returns($returns);
            $sale->returnsRevenue($returns_price);
            $sale->totalRevenue($net_price);
            $sale->priceLevel($price_level);
            $sale->channel($channel);
            $sale->configuration($config);
            $sale->countryCode($countryCode);
            $sale->currencyCode($currencyCode);
            $sale->conversionRate($convRate);
            $sale->lineNum($linenum);
            $sale->mcps_adjustment($adjustment);
            $sale->comments($comments);
            $sale->mechanical_royalty_status($usMechStatus);
            $sale->uk_mechanical_royalty_status($ukMechStatus);
            $sale->artist_royalty_status($artistStatus);
            $sale->label_royalty_status($labelStatus);

            $self->_insertSale( sale => $sale );
        } elsif ( $prodtype && $net_price ne "" && ( $album || $upc || $catno ) && $skip_sale == 1 ) {
            my @datapak_collection_catalog = ( 1088, 1099, 1152, 1170, 1236, 9034 );

            $sales_price   /= @datapak_collection_catalog;
            $returns_price /= @datapak_collection_catalog;
            $net_price     /= @datapak_collection_catalog;
            for ( my $x = 0 ; $x < @datapak_collection_catalog ; $x++ ) {
                print STDERR "Split 6 Remap 1228 -> " . $datapak_collection_catalog[$x] . "\n";
                my $sale = RPS::Import::SaleRec->new();

                $sale->productType($prodtype);
                $sale->dateBegin($dateBegin);
                $sale->dateEnd($dateEnd);
                $sale->outlet($outlet);
                $sale->clientProductID( $datapak_collection_catalog[$x] );
                $sale->artistName($artist);
                $sale->albumName($album);
                $sale->upc($upc);
                $sale->sales($sales);
                $sale->salesRevenue($sales_price);
                $sale->returns($returns);
                $sale->returnsRevenue($returns_price);
                $sale->totalRevenue($net_price);
                $sale->priceLevel($price_level);
                $sale->channel($channel);
                $sale->configuration($config);
                $sale->countryCode($countryCode);
                $sale->currencyCode($currencyCode);
                $sale->conversionRate($convRate);
                $sale->lineNum($linenum);

                $self->_insertSale( sale => $sale );
            }
        }

        #else { print STDERR "Skip l:".$linenum." p:".$prodtype." np:".$net_price." a:".$album." s:".$sales." r:".$returns."\n"; }
        $linenum++;
    }

    $fileObj->Physical(1);
    $fileObj->Save();
    return $linenum;
}

#
# Private methods
#

sub _OLDgetDates {
    my $self = shift;
    my $date = shift;

    if ( $date =~ m/^(\d{4}-\d\d-\d\d)$/ ) {
        return ( $1, $1 );
    } elsif ( $date =~ m/^(\d+)\/(\d+)\/(\d{4})$/ ) {
        my $tmp = sprintf( "%04d-%02d-%02d", $3, $2, $1 );
        return ( $tmp, $tmp );
    } elsif ( $date =~ m/^(\d{4})(\d{2})$/ ) {
        return ( $1 . "-" . $2 . "-01", $1 . "-" . $2 . "-" . Days_in_Month( $1, $2 ) );
    } elsif ( $date =~ m/^(\d+)$/ ) {
        ## stupid excel dates...
        my ( $year, $month, $day ) = Add_Delta_Days( 1900, 1, 1, $1 - 2 );
        my $tmp = sprintf( "%d-%02d-%02d", $year, $month, $day );
        return ( $tmp, $tmp );
    }
    return undef;
}

sub _filterDatapakSale {
    my $self         = shift;
    my $catalog      = shift;
    my $upc          = shift;
    my @datapak_skip = (
        1151, 1152, 1215, 1161, 1173, 1174, 1209, 1210, 1183, 1184, 1232, 1233, 1238, 1240, 1247, 1248,
        1235, 1267, 1269, 1272, 1274, 1278, 1280, 1281, 1283, 1300, 1302, 1328, 9149, 1316, 1317, 1319,
        1320, 1307, 1308, 1245, 1246, 1275, 1277, 1295, 1296, 1298, 1299, 1303, 1305, 1031, 1035
    );

    my %datapak_map = (
        1026 => 1031,
        1150 => 1152,
        1154 => 1215,
        1172 => 1174,
        1208 => 1210,
        1212 => 1212,
        1231 => 1233,
        1239 => 1240,
        1249 => 1247,
        1234 => 1267,
        1268 => 1269,
        1273 => 1274,
        1279 => 1280,
        1282 => 1283,
        1301 => 1302,
        1327 => 1328,
        1315 => 1317,
        1318 => 1320,
        1306 => 1308,
        1244 => 1246,
        1276 => 1277,
        1294 => 1296,
        1297 => 1299,
        1304 => 1305,
    );
    $catalog =~ s/\s.*$//;
    $upc =~ s/\s.*//;
    for ( my $x = 0 ; $x < @datapak_skip ; $x++ ) {
        return 2 if ( $catalog == $datapak_skip[$x] );
    }
    if ( defined $datapak_map{$catalog} ) {
        print STDERR "FOUND REMAP c:" . $catalog . " t:" . $datapak_map{$catalog} . "\n";
        return $datapak_map{$catalog};
    } elsif ( $catalog == 1228 ) {
        return 1;
    } else {
        return 0;
    }

}

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