package RPS::Import::TouchNGo; use strict; use Date::Calc qw(Days_in_Month Add_Delta_Days Decode_Month); use lib '/app/tools/common/lib'; use Common::Consts qw(%COUNTRY_CODE); 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'; my %fieldMap = ( 1 => { service_id => 0, units => 1, artist => 3, title => 4, label => 5, price => 7, }, 2 => { isrc_upc => 0, artist => 1, title => 2, downloads => 3, download_revenue => 4, streams => 5, stream_revenue => 6, free => 7, label => 9, label_percent => 10, }, ); #public methods sub _importLines { my $self = shift; my %args = @_; my $fileObj = $args{file}; my $version = $args{file}->VersionNum(); my $fileName = $args{file}->OrigFileName(); my $serviceID = $args{file}->ServiceID; my $sheet_count = 0; return undef unless ( defined $args{sheets} && defined $version ); my $offsets = $fieldMap{$version}; my $sheet_names = $args{sheet_names}; my $header_found = 0; my $linenum = 1; my ( $dateBegin, $dateEnd ) = _getDates($fileName); if ( $version == 1 ) { foreach my $sheet ( @{ $args{sheets} } ) { $linenum = 1; if ( $sheet_names->[$sheet_count] !~ /summary/i ) { foreach my $line (@$sheet) { my $country = "US"; my $currency = "USD"; my $product = RPS::File::Sale::TYPE_TRACK; my $artist = $line->[ $offsets->{artist} ]; my $format = RPS::File::Sale::FORMAT_DOWNLOAD; my $title = $line->[ $offsets->{title} ]; my $label = $line->[ $offsets->{label} ]; my $units = $line->[ $offsets->{units} ]; my $price = $line->[ $offsets->{price} ]; my $service_id = $line->[ $offsets->{service_id} ]; my $upc = $service_id if ( $service_id =~ /^(\d)/ ); my $isrc = $service_id if ( $service_id !~ /^(\d)/ ); $product = RPS::File::Sale::TYPE_ALBUM if ( $service_id =~ /^(\d)/ ); $price /= $units if ( $units != 0 ); if ( $units && $country && $price && $title && $title ne "Title" ) { unless ( defined $dateBegin && defined $dateEnd ) { print STDERR "Couldn't get dates from: " . $fileName . "\n"; $self->errstr( "couldn't get dates from: " . $fileName ); return undef; } my $sale = RPS::Import::SaleRec->new(); $sale->mediaType(2) if ( $format =~ /video/i ); $sale->productType($product); $sale->dateBegin($dateBegin); $sale->dateEnd($dateEnd); $sale->isrc($isrc) if ( $product eq RPS::File::Sale::TYPE_TRACK ); $sale->upc($upc) if ( $product eq RPS::File::Sale::TYPE_ALBUM ); $sale->artistName($artist); $sale->trackName($title) if ( $product eq RPS::File::Sale::TYPE_TRACK ); $sale->albumName($title) if ( $product eq RPS::File::Sale::TYPE_ALBUM ); $sale->labelName($label); $sale->formatType($format); $sale->units($units); $sale->price($price); $sale->countryCode($country); $sale->currencyCode($currency); $sale->lineNum($linenum); $self->_insertSale( sale => $sale ); } #else { print STDERR "skip sh: ".$sheet_names->[$sheet_count] . ": l: " . $linenum . " - c:".$country." u:".$units." p:".$price." t:".$title."\n"; } $linenum++; } } $sheet_count++; } } elsif ( $version == 2 ) { foreach my $sheet ( @{ $args{sheets} } ) { $linenum = 1; if ( $sheet_names->[$sheet_count] !~ /summary/i ) { foreach my $line (@$sheet) { my $country = "US"; my $currency = "USD"; my $product; if ( substr( $line->[ $offsets->{isrc_upc} ], 0, 1 ) eq 'U' ) { $product = RPS::File::Sale::TYPE_TRACK; } else { $product = RPS::File::Sale::TYPE_ALBUM; } my $isrc_upc = $line->[ $offsets->{isrc_upc} ]; my $title = $line->[ $offsets->{title} ]; my $artist = $line->[ $offsets->{artist} ]; my $label = $line->[ $offsets->{label} ]; my $downloads = $line->[ $offsets->{downloads} ]; my $download_revenue = $line->[ $offsets->{download_revenue} ]; my $streams = $line->[ $offsets->{streams} ]; my $stream_revenue = $line->[ $offsets->{stream_revenue} ]; my $free_units = $line->[ $offsets->{free} ]; my $label_percent = $line->[ $offsets->{label_percent} ]; $label_percent =~ s/\D//g; $label_percent *= .01; if ($isrc_upc) { unless ( defined $dateBegin && defined $dateEnd ) { print STDERR "Couldn't get dates from: " . $fileName . "\n"; $self->errstr( "couldn't get dates from: " . $fileName ); return undef; } my $sale = RPS::Import::SaleRec->new(); $sale->productType($product); $sale->dateBegin($dateBegin); $sale->dateEnd($dateEnd); $sale->isrc($isrc_upc) if ( $product eq RPS::File::Sale::TYPE_TRACK ); $sale->upc($isrc_upc) if ( $product eq RPS::File::Sale::TYPE_ALBUM ); $sale->artistName($artist); $sale->trackName($title) if ( $product eq RPS::File::Sale::TYPE_TRACK ); $sale->albumName($title) if ( $product eq RPS::File::Sale::TYPE_ALBUM ); $sale->labelName($label); $sale->countryCode($country); $sale->currencyCode($currency); $sale->lineNum($linenum); my $price; # If there are downloads, add this sale if ( $downloads > 0 ) { $sale->formatType(RPS::File::Sale::FORMAT_DOWNLOAD); $sale->units($downloads); $price = $label_percent * ( $download_revenue / $downloads ); $price = sprintf( "%.8f", $price ); $sale->price($price); $self->_insertSale( sale => $sale ); } # If there are streams, add this sale if ( $streams > 0 ) { $sale->formatType(RPS::File::Sale::FORMAT_STREAM); $sale->units($streams); $price = $label_percent * ( $stream_revenue / $streams ); $price = sprintf( "%.8f", $price ); $sale->price($price); $self->_insertSale( sale => $sale ); } # If there are free streams, add this sale if ( $free_units > 0 ) { $sale->formatType(RPS::File::Sale::FORMAT_STREAM); $sale->units($free_units); $sale->free(1); $sale->price(0); $self->_insertSale( sale => $sale ); } } #else { print STDERR "skip sh: ".$sheet_names->[$sheet_count] . ": l: " . $linenum . " - c:".$country." u:".$units." p:".$price." t:".$title."\n"; } $linenum++; } } $sheet_count++; } } return $linenum; } # # Private methods # sub _getDates { my ( $year, $month, $day, $monthName, $qtr, $passed_date, $dateBegin, $dateEnd ); $passed_date = shift; $passed_date =~ s/\s.*$//; if ( $passed_date =~ m/_(\d\d)_(\d\d)_(\d\d)/ ) { $year = $3 + 2000; $month = $1; $day = $2; } if ( $year && $month && $day ) { return ( $year . "-" . sprintf( "%02d", $month ) . "-01", $year . "-" . sprintf( "%02d", $month ) . "-" . sprintf( "%02d", $day ) ); } return undef; } ### 1; # Play nicely. ###