package RPS::Import::Hostess::v1;

use strict;

use lib '/app/tools/common/lib';
use Common::Util qw(normalize_upc normalize_isrc);

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

sub _headerIdentifier { ( upc => 'UPC' ) }

sub _fieldMap {
    my $self      = shift;
    my %field_map = (
        1 => {
            labelName  => 'M',
            serviceID  => 'S',
            dateBegin  => 'A',
            dateEnd    => 'B',
            formatType => 'J',
            artistName => 'K',
            upc        => 'C',
            albumName  => 'L',
            trackName  => 'L',
            isrc       => 'D',
            units      => 'F',
            price      => 'H',
        },
        2 => {
            labelName  => 'M',
            serviceID  => 'R',
            dateBegin  => 'A',
            dateEnd    => 'B',
            formatType => 'J',
            artistName => 'K',
            upc        => 'C',
            albumName  => 'L',
            trackName  => 'L',
            isrc       => 'D',
            units      => 'F',
            price      => 'H',
        },
    );
    return $field_map{ $self->version };
}

sub countryCode { 'JP' }

sub currencyCode { 'JPY' }

sub serviceID {
    my $self      = shift;
    my $service   = $self->_getByFieldName('serviceID');
    my $serviceID = $self->getServiceID( lc($service) ) || $RPS::Import::ServiceMap::SERVICE_ALIASES{ lc $service };
    return $serviceID if ($serviceID);
    return Client::Service::DSP_HOSTESS if ( '' eq $service );

    $self->fail("Unknown service '$service'");
}

sub saleDates {
    my $self      = shift;
    my $dateBegin = $self->_getByFieldName('dateBegin');
    my $dateEnd   = $self->_getByFieldName('dateEnd');
    $dateBegin =~ s/\./\//g;
    $dateEnd =~ s/\./\//g;
    return $self->_getDates( date_begin => $dateBegin, date_end => $dateEnd, type => 'eur' );
}

sub productType {
    my $self = shift;
    my $isrc = $self->_getByFieldName('isrc');
    return ( defined $isrc && '' ne $isrc ) ? RPS::File::Sale::TYPE_TRACK : RPS::File::Sale::TYPE_ALBUM;
}

sub formatType {
    my $self = shift;
    my $type = $self->_getByFieldName('formatType');

    if ( '' eq $type || $type =~ /^ftd$/i ) {
        return RPS::File::Sale::FORMAT_DOWNLOAD;
    } elsif ( $type =~ /^stream$/i || $type =~ /^linear radio$/i ) {
        return RPS::File::Sale::FORMAT_STREAM;
    }
    $self->fail("Could not determine format type from '$type'");
}

sub mediaType { RPS::DB::Item::MediaType::kMediaTypeAudio; }

sub trackName {
    my $self = shift;
    return $self->productType eq RPS::File::Sale::TYPE_ALBUM ? undef : $self->SUPER::trackName;
}

sub albumName {
    my $self = shift;
    return $self->productType eq RPS::File::Sale::TYPE_TRACK ? undef : $self->SUPER::albumName;
}

sub isrc {
    my $self = shift;
    my $isrc = $self->_getByFieldName('isrc');
    return normalize_isrc($isrc);
}

sub upc {
    my $self = shift;
    my $upc  = $self->_getByFieldName('upc');
    return normalize_upc($upc);
}

sub _isValidSaleRecord {
    my $self = shift;
    return ( defined( $self->units ) && $self->units != 0 && ( $self->trackName || $self->albumName ) );
}

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