diff --git a/lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/CDR.pm b/lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/CDR.pm index 4d8498a..6dd0c0b 100644 --- a/lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/CDR.pm +++ b/lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/CDR.pm @@ -303,12 +303,13 @@ sub _export_cdrs_init_context { and ($scenario->{ccs_subscriber} = NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscribers::findby_uuid(undef,$context->{cdrs}->[0]->{destination_user_id})) and ($scenario->{ccs_subscriber}->{primary_alias} = NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_dbaliases::findby_subscriberidisprimary($scenario->{ccs_subscriber}->{id},1)->[0]) ) { - if (not $context->{cdrs}->[0]->{$ama_originating_digits_cdr_field} - or not $context->{cdrs}->[1]->{$ama_terminating_digits_cdr_field}) { - $malformed = 1; - } else { + if ($context->{cdrs}->[0]->{$ama_originating_digits_cdr_field} =~ /^[0-9]$/ + and $context->{cdrs}->[1]->{$ama_terminating_digits_cdr_field} =~ /^[0-9]$/ + ) { $scenario->{code} = $DIRECT_FORWARDER_SCENARIO; $result = 1; + } else { + $malformed = 1; } #} else { # print "blah"; diff --git a/lib/NGCP/BulkProcessor/Projects/Export/Ama/Format/File.pm b/lib/NGCP/BulkProcessor/Projects/Export/Ama/Format/File.pm index 06d0330..e9cf7d5 100644 --- a/lib/NGCP/BulkProcessor/Projects/Export/Ama/Format/File.pm +++ b/lib/NGCP/BulkProcessor/Projects/Export/Ama/Format/File.pm @@ -138,9 +138,9 @@ sub get_filesize { sub _rename { my $self = shift; my ($filename) = @_; - $filename = rename($self->{tempfilename},$filename); - _chownmod($filename,$files_owner,$files_group,oct(666),$files_mask); - return $filename; + my $result = rename($self->{tempfilename},$filename); + _chownmod($filename,$files_owner,$files_group,oct(666),$files_mask) if $result; + return $result; } sub _makedir {