package RPS::Import::BMGSony2;

use strict;


use Date::Calc qw(Days_in_Month);

use lib '/app/tools/common/lib';
use Common::Util;
use Common::Consts;

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

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


# map version number to data columns
my %fieldMap = (
    2 => {
    'date'    => 1,
    'channel'=> 4,
    'upc'    => 5,
    'artist' => 6,
    'title'  => 7,
    'config' => 8,
    'label'  => 14,
    'transaction' => 15,
    'retail' => 17,
    'wholesale' => 19,
    'price1' => 20,
    'price1' => 20,
    'price2' => 23,
    'price3' => 24,
    'units'  => 26,
    },
    5 => {
    'date'   => 1,
    'channel'=> 4,
    'upc'    => 5,
    'artist' => 6,
    'title'  => 7,
    'config' => 8,
    'label'  => 14,
    'transaction' => 15,
    'price1' => 16,
    'price2' => 17,
    #'price3' => 24,
    'units'  => 19,
    },
);

#public methods

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

	my $fileObj = $args{file};
	my $version = $fileObj->VersionNum;

	my $offset = $fieldMap{$version};

    my $lines = $args{lines};

    shift @$lines;
    my $linenum = 2;

    foreach my $line (@$lines) {

        my $price_level = RPS::File::Sale::PLEVEL_FULL;

        my $upc         = $line->[$offset->{'upc'}];
        my $album       = $line->[$offset->{'title'}];
        my $artist      = $line->[$offset->{'artist'}];
        my $label       = $line->[$offset->{'label'}];
        my $config      = $line->[$offset->{'config'}];


        my ($sales, $returns, $sales_p, $returns_p, $total, $price1, $price2, $price3);
        if ($line->[$offset->{'transaction'}] eq 'shipment') {
            ($sales)   = $line->[$offset->{'units'}] =~ m/^\s*(-?[0-9]+)\s*$/;
            ($price1)  = $line->[$offset->{'price1'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            ($price2)  = $line->[$offset->{'price2'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            ($price3)  = $line->[$offset->{'price3'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            $sales_p   = $price1 + $price2 + $price3;
            $total     = $sales_p;
            $returns   = 0;
            $returns_p = 0;
        } elsif ($line->[$offset->{'transaction'}] eq 'return') {
            ($returns) = $line->[$offset->{'units'}] =~ m/^\s*(-?[0-9]+)\s*$/;
            ($price1)  = $line->[$offset->{'price1'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            ($price2)  = $line->[$offset->{'price2'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            ($price3)  = $line->[$offset->{'price3'}] =~ m/^\s*(-?[0-9]*\.?[0-9]*)\s*$/;
            $returns_p = $price1 + $price2 + $price3;
            $total     = $returns_p;
            $returns   *= -1;
            $returns_p *= -1;
            $sales     = 0;
            $sales_p   = 0;
        }

        my $retail_price  = $line->[$offset->{'retail'}];
        my $wholesale_price  = $line->[$offset->{'wholesale'}];

        if ($album && $config && defined $upc && ($total || $sales || $returns)) {

            my ($dateBegin, $dateEnd) = $self->_getDates($line->[$offset->{'date'}]);
            unless ($dateBegin && $dateEnd) {
                $self->errstr("couldn't get dates from ".$line->[$offset->{'date'}]." on $linenum - ".$line->[$offset->{'title'}]);
                return undef;
                next;
            }

            my $channel     = $line->[$offset->{'channel'}];
            if ($channel eq 'commercial') {
                $channel     = RPS::File::Sale::CHANNEL_RETAIL;
            } elsif ($channel eq 'military') {
                $channel     = RPS::File::Sale::CHANNEL_MILITARY;
            } else {
                $self->errstr("unknown channel: ".$channel);
                return undef;
            }

            my $prodtype;
            if ($config eq 'CD' || $config eq 'SGCD') {
                $prodtype = RPS::File::Sale::TYPE_CD;
            } elsif ($config eq 'LP' || $config eq 'SGVY') {
                $prodtype = RPS::File::Sale::TYPE_LP;
            } elsif ($config eq 'DVD' || $config eq 'DVDS') {
                $prodtype = RPS::File::Sale::TYPE_DVD;
            } elsif ($config eq 'VID') {
                $prodtype = RPS::File::Sale::TYPE_VHS;
            } else {
                $self->errstr("unknown config: $config");
                return undef;
            }

            my $sale = RPS::Import::SaleRec->new();

            $sale->productType($prodtype);
            $sale->dateBegin($dateBegin);
            $sale->dateEnd($dateEnd);
            $sale->upc($upc);
            $sale->artistName($artist);
            $sale->albumName($album);
            $sale->labelName($label);
            $sale->retailPrice($retail_price);
            $sale->wholesalePrice($wholesale_price);
            $sale->sales($sales);
            $sale->returns($returns);
            $sale->salesRevenue($sales_p);
            $sale->returnsRevenue($returns_p);
            $sale->totalRevenue($total);
            $sale->priceLevel($price_level);
            $sale->configuration($config);
            $sale->channel($channel);
            $sale->countryCode("US");
            $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 = shift;

    my ($startDate, $endDate);
    if ($date =~ m/^(\d\d\d\d)(\d\d)$/) {
        my $year  = $1;
        my $month = $2;
        $startDate = sprintf("%04d-%02d-%02d", $year, $month, 1);
        $endDate   = sprintf("%04d-%02d-%02d", $year, $month, Days_in_Month($year, $month));
    } else {
        return undef;
    }

	return ($startDate, $endDate);
}

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