package RPS::Import::Sony::v7;

use strict;

use lib '/app/tools/common/lib';
use Common::Date;
use Common::Country;

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

use Data::Dumper;

sub _headerIdentifier { (dateBegin => 'Month') }

sub _fieldMap {
    {
        labelName        => 'D',
        countryCode      => 'G',
        dateBegin        => 'N',
        dateEnd          => 'N',
        productType      => 'O',  
        artistName       => 'J',
        upc              => 'M',
        albumName        => 'I',
        channel          => 'H',
        priceLevel       => 'O',
        sales            => 'Z',
        returns          => 'Z',        
        salesRevenue     => 'AA',
        returnsRevenue   => 'AA',
        totalRevenue     => 'AA',
    }
}

sub currencyCode { 'AUD' }
sub physical     { 1 }

sub sales {
    my $self = shift;
    my $sales = $self->_getByFieldName('sales');   
    if ($sales < 0)
    { 
        return undef;
    }
    else 
    {
        return $sales;
    }
}

sub returns {
    my $self = shift;
    my $returns = $self->_getByFieldName('returns');   
    if ($returns > 0)
    { 
        return undef;
    }
    else 
    {
        $returns *= -1;
        return $returns;
    }
}

sub salesRevenue {
    my $self = shift;
    my $salesRevenue = $self->_getByFieldName('salesRevenue');   
    if ($salesRevenue < 0)
    { 
        return undef;
    }
    else 
    {
        return $salesRevenue;
    }
}

sub returnsRevenue {
    my $self = shift;
    my $returnsRevenue = $self->_getByFieldName('returnsRevenue');   
    if ($returnsRevenue > 0)
    { 
        return undef;
    }
    else 
    {
        $returnsRevenue *= -1;
        return $returnsRevenue;
    }
}


sub countryCode {
        
    my $self = shift;
    my $countryName = uc($self->_getByFieldName('countryCode')) || return;  
    
    if ($countryName eq 'NEZ')
    {
        $countryName = 'NZL';
    } 
        
    my $cObj= Common::Country->Get( $countryName );
    my $countryCode = $cObj->alpha2() if ( $cObj );
    if ( !$countryCode )
    {
        $self->fail( "Could not determine country code from $countryName" );
        return undef;  
    }    
    return $countryCode;
}

sub _getDateBegin {
        
    my $self = shift;
    my $dateBegin = lc($self->_getByFieldName('dateBegin')) || return;  
    
    my $month = substr($dateBegin, 0, 2);
    
    my $year = substr($dateBegin, 2);
    
    if ($month eq '1h')
    {
        $month = '01';
    } elsif ($month eq '2h') {
        $month = '07';
    } else {
        $self->fail( "Could not determine date from $dateBegin" );
        return undef;   
    }
    
    $dateBegin = $year . "-" . $month . "-01";
    return $dateBegin;    
}

sub _getDateEnd {
        
    my $self = shift;
    my $dateEnd = lc($self->_getByFieldName('dateEnd')) || return;   
    
    my $month = substr($dateEnd, 0, 2);
    my $year = substr($dateEnd, 2);
    if ($month eq '1h')
    {
        $month = '06-30';
    } elsif ($month eq '2h') {
        $month = '12-31';
    } else {
        $self->fail( "Could not determine date from $dateEnd" );
        return undef;   
    }
    
    $dateEnd = $year . "-" . $month;
    return $dateEnd;    
}


sub productType {
    my $self = shift;
    my $productType = lc($self->_getByFieldName('productType')) || return;

    if ($productType =~ m/\w{1} (\d{2})/)
    {
        my $productCode = $1;

        if( $productCode == 31 ) {
            return RPS::File::Sale::TYPE_CD;
    
        } elsif( $productCode == 39 ) {
            return RPS::File::Sale::TYPE_CD;
    
        } elsif( $productCode == 73 ) {
            return RPS::File::Sale::TYPE_DVD;
        }
    }

    $self->fail( "Could not determine product type from $productType" );
    return undef;
}


sub priceLevel {
    my $self = shift;
    my $priceLevel = lc($self->_getByFieldName('priceLevel')) || return;

    if ($priceLevel =~ m/(\w{1}) \d{2}/)
    {
        my $priceCode = $1;

        if( $priceCode eq 'b' ) {
            return RPS::File::Sale::PLEVEL_BUDGET;
    
        } elsif( $priceCode eq 'm' ) {
            return RPS::File::Sale::PLEVEL_MID;
    
        } elsif( $priceCode eq 'f' ) {
            return RPS::File::Sale::PLEVEL_FULL;
        }
    }

    $self->fail( "Could not determine price tier from $priceLevel" );
    return undef;
}


sub channel {
    my $self = shift;
    my $channel = lc($self->_getByFieldName('channel')) || return;

    if( $channel eq 'ind' ) {
        return RPS::File::Sale::CHANNEL_RETAIL;

    } elsif( $channel eq 'rtt' ) {
        return RPS::File::Sale::CHANNEL_RETAIL;

    } elsif( $channel eq 'rcc' ) {
        return RPS::File::Sale::CHANNEL_CLUB;

    } elsif( $channel eq 'px' ) {
        return RPS::File::Sale::CHANNEL_MILITARY;
    }

    $self->fail( "Could not determine channel from $channel" );
    return undef;
}


sub _isValidSaleRecord {
	my $self = shift;

	return ( defined($self->sales || $self->returns) && $self->albumName );
}

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