package RPS::Import::Sony::v5;

use strict;

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

use lib '/app/tools/rps/lib';

use RPS::Import::ServiceMap;
use base 'RPS::Import::MapFaceBase';
use base 'RPS::Import::Importer';

use Data::Dumper;

sub _fieldMap {
    {
        # Header
        currencyCode => 'F',

        # Data
        serviceID   => 'B',
        countryCode => 'I',
        dateBegin   => 'K',
        dateEnd     => 'K',
        productType => 'J',
        formatType  => 'L',
        artistName  => 'E',
        upc         => 'C',
        albumName   => 'D',
        isrc        => 'F',
        trackName   => 'G',
        units       => 'AA',
        price       => 'AD',
    };
}

sub _headerIdentifier { ( albumName => 'Product Title' ) }

sub units {
    my $self   = shift;
    my $_units = $self->_getByFieldName('units');
    my $_price = $self->_getByFieldName('price');

    # Making units follow the sign of the revenue
    if ( ( $_price < 0 && $_units > 0 ) || ( $_price > 0 && $_units < 0 ) ) {
        $_units *= -1;
    }

    return $_units;
}

sub _isValidSaleRecord {
    my $self = shift;

    return ( defined( $self->units ) && ( $self->trackName || $self->albumName || $self->artistName || $self->upc ) );
}

# _productTypes returns a hashref that contains the RPS format,
# product and media mappings that correlate to the 'type' field.
# Although we use two columns (productType and formatType) to determine
# the mappings, we still return a hashref with a single key (the product
# type).  See _getBySaleType (defined elsewhere in this module) for
# more information.
#
sub _productTypes {
    my $self = shift;

    my $type   = lc( $self->_getByFieldName('productType') ) || return;
    my $format = lc( $self->_getByFieldName('formatType') )  || return;

    my $result;

    if ( $type eq 'audio lp' ) {
        $result = $format eq 'mobile'
          ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'online' && $self->trackName ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'online' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'physical retail' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'brkg-subscript' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'brkg-online' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : undef;
    }

    elsif ( $type eq 'audtrack' ) {
        $result = $format eq 'd2c-dig'
          ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'online' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'physical retail' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-online' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-subscript' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'locker-download' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'locker-stream' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'dl-condi' ? {
            formatType  => RPS::File::Sale::FORMAT_TETHERED,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-con' ?    # FB9011
          {
            formatType  => RPS::File::Sale::FORMAT_TETHERED,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'ephemera' ?    # FB18565
          {
            formatType  => RPS::File::Sale::FORMAT_PERFORMANCE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : undef;
    } elsif ( $type eq 'vidlp' ) {
        $result = $format eq 'online'
          ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : undef;
    } elsif ( $type eq 'audbndle' ) {
        $result =
          $format eq 'subscription'
          ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }
          : undef;
    }

    elsif ( $type eq 'bundle' ) {
        $result = $format eq 'online' && $self->trackName
          ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'online' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_ALBUM,
          }

          : undef;
    }

    elsif ( $type eq 'ringback' ) {
        $result = $format eq 'brkg-mobile'
          ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : undef;
    }

    elsif ( $type eq 'ringtone' ) {
        $result = $format eq 'brkg-mobile'
          ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'online' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-con' ?    # FB9011
          {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeAudio,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : undef;
    }

    elsif ( $type eq 'vidtone' ) {
        $result = $format eq 'mobile'
          ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_RINGTONE,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : undef;
    }

    elsif ( $type eq 'vidtrack' ) {
        $result = $format eq 'brkg-subscript'
          ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'online' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'other' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'subscription' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'mobile' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'locker-download' ? {
            formatType  => RPS::File::Sale::FORMAT_STREAM,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'brkg-online' ? {
            formatType  => RPS::File::Sale::FORMAT_DOWNLOAD,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : $format eq 'dl-condi' ?    # FB9011
          {
            formatType  => RPS::File::Sale::FORMAT_TETHERED,
            mediaType   => RPS::DB::Item::MediaType::kMediaTypeVideo,
            productType => RPS::File::Sale::TYPE_TRACK,
          }

          : undef;
    }

    return { $type => $result };
}

sub _getDateBegin {
    my $self = shift;
    my $date = $self->SUPER::_getDateBegin() || return;

    my $d = new Common::Date($date);
    return $d->halfBegin;
}

sub _getDateEnd {
    my $self = shift;
    my $date = $self->SUPER::_getDateEnd() || return;

    my $d = new Common::Date($date);
    return $d->halfEnd;
}

sub currencyCode { shift->{_currencyCode} }

sub countryCode {
    my $self    = shift;
    my $country = $self->SUPER::countryCode();

    my %countryMap = (
        'rep. korea'      => 'KR',
        'slovakia rep.'   => 'SK',
        'arab emirates'   => 'AE',
        'dominican rep.'  => 'DO',
        'st. lucia'       => 'LC',
        'antigua & barbu' => 'AG',
    );

    $country = $countryMap{ lc $country } if ( exists $countryMap{ lc $country } );

    my $c = new Common::Country( search => $country );
    return $c->alpha2() if ($c);

    return $country;    # Return original name and let MapFace deal with it
}

sub _processHeader {
    my $self = shift;

    $self->SUPER::_processHeader();

    my $currencyCode = $self->SUPER::currencyCode || return;

    return if ( $self->{_currencyCode} );

    $self->{_currencyCode} = $currencyCode if ( $currencyCode =~ /^\w{3}$/ );
}

# _getBySaleType - overridden here to use a different fieldname so that we
# can use MapFace with this importer.  The original method can be found in
# sale_import/lib/Import/Importer.pm.
#
# This method is used by the productType, formatType and mediaType accessors
# defined here and in the Importer base class (RPS/Importer.pm).
# In the base class, those methods call _getBySaleType with a specific field:
#
#   sub mediaType             { shift->_getBySaleType( 'mediaType' ) }
#   sub productType           { shift->_getBySaleType( 'productType' ) }
#   sub formatType            { shift->_getBySaleType( 'formatType' ) }
#
sub _getBySaleType {
    my $self  = shift;
    my $field = shift;

    assert( $field, "Field required" );

    my $type = lc( $self->_getByFieldName('productType') ) || return;    # use 'productType' instead of 'type'

    my $map = $self->_productTypes() || return;

    return $map->{$type} ? $map->{$type}->{$field} : undef;
}

# We also extend the productType, formatType and mediaType accessors
# so that we can log MapFace errors.
#
sub productType {
    my $self = shift;
    my $type = $self->SUPER::productType(@_);

    return $type if ($type);

    return $self->handleError( "Unable to determine product type", RPS::DB::Item::SaleImportError::kErrorProductType );
}

sub formatType {
    my $self = shift;
    my $type = $self->SUPER::formatType(@_);

    return $type if ($type);

    return $self->handleError( "Unable to determine format type", RPS::DB::Item::SaleImportError::kErrorFormatType );
}

sub mediaType {
    my $self = shift;
    my $type = $self->SUPER::mediaType(@_);

    return $type if ($type);

    return $self->handleError( "Unable to determine media type", RPS::DB::Item::SaleImportError::kErrorMediaType );
}

sub serviceID {
    my $self    = shift;
    my $service = $self->_getByFieldName('serviceID');

    # Default to Sony if blank
    return Client::Service::DSP_SONY unless ($service);

    my $serviceID = $self->getServiceID( lc($service) ) || $RPS::Import::ServiceMap::SERVICE_ALIASES{ lc $service };

    return $serviceID if ($serviceID);

    return $self->handleError( "Unknown service '$service'", RPS::DB::Item::SaleImportError::kErrorService );
}

#####    MapFace    #####
#

sub _mapFaceServiceID {
    return ('serviceID');
}

sub _mapFaceCountryCode {
    return ('countryCode');
}

sub _mapFaceProductType {
    return ( 'productType', 'formatType' );
}

sub _mapFaceFormatType {
    return ( 'productType', 'formatType' );
}

sub _mapFaceMediaType {
    return ( 'productType', 'formatType' );
}

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