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. ###