sipwise
/
bulk-processor
mirror of https://github.com/sipwise/bulk-processor.git
1
0
Fork 0
Code Issues Releases Wiki Activity

TT#55815 TT#55816 TT#55817 .ama export: scenarios

Browse Source 
- "blind xfer"
- "no xfer"
- "attn xfer"

Change-Id: I51d536992eeb031a6a49fa45eb091dc6c49599dd
changes/54/28054/15
Rene Krenn 7 years ago
parent 9370109e73
commit 0d481d1cc9
8 changed files with 526 additions and 126 deletions
Show Stats Download Patch File Download Diff File

22
lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
Unescape View File

@ -43,6 +43,7 @@ our @EXPORT_OK = qw(
process_fromto
get_callidprefix
findby_callid
$OK_CALL_STATUS
@ -247,6 +248,27 @@ sub findby_callidprefix {
}
sub findby_callid {
my ($xa_db,$call_id,$joins,$conditions,$load_recursive) = @_;
check_table();
my $db = &$get_db();
$xa_db //= $db;
my $table = $db->tableidentifier($tablename);
my @conditions = @{$conditions // []};
push(@conditions,{ $table . '.call_id' => { '=' => '?' } });
my $stmt = 'SELECT ' . join(',', map { $table . '.' . $db->columnidentifier($_); } @$expected_fieldnames) . ' ' .
_get_export_stmt($db,undef,$joins,\@conditions) .
' ORDER BY ' . $table . '.start_time ASC';
my @params = ($call_id);
my $rows = $xa_db->db_get_all_arrayref($stmt,@params);
return buildrecords_fromrows($rows,$load_recursive);
}
sub update_row {
my ($xa_db,$data) = @_;

131
lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_group.pm
Unescape View File

@ -0,0 +1,131 @@
package NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_group;
use strict;
## no critic
use NGCP::BulkProcessor::Logging qw(
getlogger
);
use NGCP::BulkProcessor::ConnectorPool qw(
get_accounting_db
destroy_dbs
);
use NGCP::BulkProcessor::SqlProcessor qw(
checktableinfo
copy_row
);
use NGCP::BulkProcessor::SqlRecord qw();
require Exporter;
our @ISA = qw(Exporter NGCP::BulkProcessor::SqlRecord);
our @EXPORT_OK = qw(
gettablename
check_table
findby_cdrid
findby_callid
);
#findby_callid
my $tablename = 'cdr_group';
my $get_db = \&get_accounting_db;
my $expected_fieldnames = [
"cdr_id",
"call_id",
"cdr_start_time",
];
my $indexes = {};
my $insert_unique_fields = [];
sub new {
my $class = shift;
my $self = NGCP::BulkProcessor::SqlRecord->new($class,$get_db,
$tablename,$expected_fieldnames,$indexes);
copy_row($self,shift,$expected_fieldnames);
return $self;
}
sub findby_cdrid {
my ($xa_db,$cdrid,$load_recursive) = @_;
check_table();
my $db = &$get_db();
$xa_db //= $db;
my $table = $db->tableidentifier($tablename);
my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
$db->columnidentifier('cdr_id') . ' = ?';
my @params = ($cdrid);
my $rows = $xa_db->db_get_all_arrayref($stmt,@params);
return buildrecords_fromrows($rows,$load_recursive);
}
sub findby_callid {
my ($xa_db,$callid,$load_recursive) = @_;
check_table();
my $db = &$get_db();
$xa_db //= $db;
my $table = $db->tableidentifier($tablename);
my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
$db->columnidentifier('call_id') . ' = ?';
my @params = ($callid);
my $rows = $xa_db->db_get_all_arrayref($stmt,@params);
return buildrecords_fromrows($rows,$load_recursive);
}
sub buildrecords_fromrows {
my ($rows,$load_recursive) = @_;
my @records = ();
my $record;
if (defined $rows and ref $rows eq 'ARRAY') {
foreach my $row (@$rows) {
$record = __PACKAGE__->new($row);
# transformations go here ...
push @records,$record;
}
}
return \@records;
}
sub gettablename {
return $tablename;
}
sub check_table {
return checktableinfo($get_db,
__PACKAGE__,$tablename,
$expected_fieldnames,
$indexes);
}
1;

443
lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/CDR.pm
Unescape View File

@ -24,6 +24,9 @@ use NGCP::BulkProcessor::Projects::Export::Ama::Ccs::Settings qw(
$ama_outgoing_trunk_group_number
$ama_originating_digits_cdr_field
$ama_terminating_digits_cdr_field
$ivr_duration_limit
$primary_alias_pattern
);
use NGCP::BulkProcessor::Logging qw (
@ -40,6 +43,7 @@ use NGCP::BulkProcessor::LogError qw(
use NGCP::BulkProcessor::Dao::Trunk::accounting::cdr qw();
use NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status qw();
use NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data qw();
use NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_group qw();
use NGCP::BulkProcessor::Dao::Trunk::accounting::mark qw();
use NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscribers qw();
@ -86,7 +90,12 @@ our @EXPORT_OK = qw(
reset_export_status
);
my $DIRECT_FORWARDER_SCENARIO = 1;
my $BLIND_TRANSFER_NO_IVR = 1;
my $BLIND_TRANSFER = 2;
my $NO_TRANSFER_NO_IVR = 3;
my $NO_TRANSFER = 4;
my $ATTN_TRANSFER_NO_IVR = 5;
my $ATTN_TRANSFER = 6;
my $file_sequence_number : shared = 0;
my $rowcount : shared = 0;
@ -165,7 +174,9 @@ sub export_cdrs {
static_context => $static_context,
process_code => sub {
my ($context,$records,$row_offset) = @_;
# we only want to export a call scenario of eg. 4 cdrs, if the block (eg. 1000 cdrs) contains all 4.
$context->{block_call_id_map} = {};
my $cdr_id_map = {};
foreach my $record (@$records) {
my ($id,$call_id) = @$record;
my $call_id_prefix = NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::get_callidprefix($call_id);
@ -174,6 +185,14 @@ sub export_cdrs {
} else {
$context->{block_call_id_map}->{$call_id_prefix} = 1;
}
$cdr_id_map->{$id} = 1;
}
$context->{correlated_cdrs_map} = {};
foreach my $record (@$records) {
my ($id,$call_id) = @$record;
$context->{correlated_cdrs_map}->{$id} = _find_child_cdrs($context,$id);
my $call_id_prefix = NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::get_callidprefix($call_id);
map { $context->{block_call_id_map}->{$call_id_prefix} += 1 if exists $cdr_id_map->{$_->{id}}; } @{$context->{correlated_cdrs_map}->{$id}};
}
foreach my $record (@$records) {
if (defined $export_cdr_limit) {
@ -278,70 +297,256 @@ sub export_cdrs {
return ($result,$warning_count,\@ama_files);
}
sub _find_child_cdrs {
my ($context,$id) = @_;
my @correlated_cdrs = ();
foreach my $correlated_group_cdr (@{NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_group::findby_cdrid($context->{db},$id)}) {
foreach my $correlated_cdr (@{NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::findby_callid($context->{db},$correlated_group_cdr->{call_id})}) {
push(@correlated_cdrs,$correlated_cdr);
}
}
return \@correlated_cdrs;
}
sub _export_cdrs_init_context {
my ($context,$cdr_id,$call_id) = @_;
my $result = 0;
$context->{cdrs} = [];
my $parent_cdrs;
$context->{call_id} = $call_id;
my $scenario = { code => 0, };
my $scenario = { code => 0, ama => [], };
$context->{scenario} = $scenario;
if (not exists $context->{file_cdr_id_map}->{$cdr_id}) {
if (not exists $context->{file_cdr_id_map}->{$cdr_id}) { #skip if processed for a file already
my $call_id_prefix = NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::get_callidprefix($call_id);
if (exists $context->{block_call_id_map}->{$call_id_prefix}) {
$context->{cdrs} = NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::findby_callidprefix($context->{db},
$call_id,$export_cdr_joins,$export_cdr_conditions); #already sorted
my $cdrs_in_block = delete $context->{block_call_id_map}->{$call_id_prefix};
if ((scalar @{$context->{cdrs}}) == $cdrs_in_block) {
my $malformed = 0;
if ((scalar @{$context->{cdrs}}) == 2
and not $context->{cdrs}->[0]->is_xfer()
and $context->{cdrs}->[1]->is_xfer()
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 ($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;
if (exists $context->{block_call_id_map}->{$call_id_prefix}) { #skip if this callid form parent calls that have already been processed
if ((scalar @{NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_group::findby_callid($context->{db},$call_id)}) == 0) { #skip if this is a correlated (child) cdr
$parent_cdrs = NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::findby_callidprefix($context->{db},
$call_id,$export_cdr_joins,$export_cdr_conditions); #already sorted
my @scenario_cdrs = @$parent_cdrs;
foreach my $cdr (@$parent_cdrs) {
my @correlated_cdrs;
if (exists $context->{correlated_cdrs_map}->{$cdr->{id}}) {
@correlated_cdrs = @{$context->{correlated_cdrs_map}->{$cdr->{id}}};
} else {
$malformed = 1;
@correlated_cdrs = @{_find_child_cdrs($context,$cdr->{id})};
}
#} else {
# print "blah";
$cdr->{_correlated_cdrs} = \@correlated_cdrs;
push(@scenario_cdrs,@correlated_cdrs);
}
foreach my $cdr (@{$context->{cdrs}}) {
if ($result) {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::OK;
} elsif ($malformed) {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::FAILED;
} else {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::SKIPPED;
$scenario->{parent_cdrs} = $parent_cdrs;
$scenario->{all_cdrs} = \@scenario_cdrs;
my $cdrs_in_block = delete $context->{block_call_id_map}->{$call_id_prefix};
if ((scalar @scenario_cdrs) == $cdrs_in_block) {
my $malformed = 0;
#blind xfer:
if ((scalar @$parent_cdrs) == 2
and not $parent_cdrs->[0]->is_xfer()
and $parent_cdrs->[1]->is_xfer()
and (scalar @{$parent_cdrs->[0]->{_correlated_cdrs}}) == 0
and (scalar @{$parent_cdrs->[1]->{_correlated_cdrs}}) == 0
and ($scenario->{ccs_subscriber} = NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscribers::findby_uuid(undef,$parent_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])
and (not defined $primary_alias_pattern or $scenario->{ccs_subscriber}->{primary_alias}->{username} =~ $primary_alias_pattern)
) {
my $ivr_duration = abs($parent_cdrs->[0]->{start_time} - $parent_cdrs->[1]->{init_time});
if ($ivr_duration < $ivr_duration_limit) {
$scenario->{code} = $BLIND_TRANSFER_NO_IVR;
} else {
$scenario->{code} = $BLIND_TRANSFER;
}
$result = 1;
#no transfer:
} elsif ((scalar @$parent_cdrs) == 1
and not $parent_cdrs->[0]->is_xfer()
and not $parent_cdrs->[0]->is_pbx()
and (scalar @{$parent_cdrs->[0]->{_correlated_cdrs}}) == 0
and ($scenario->{ccs_subscriber} = NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscribers::findby_uuid(undef,$parent_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])
and (not defined $primary_alias_pattern or $scenario->{ccs_subscriber}->{primary_alias}->{username} =~ $primary_alias_pattern)
) {
my $ivr_duration = $parent_cdrs->[0]->{duration};
if ($ivr_duration < $ivr_duration_limit) {
$scenario->{code} = $NO_TRANSFER_NO_IVR;
} else {
$scenario->{code} = $NO_TRANSFER;
}
$result = 1;
#attn transfer:
} elsif ((scalar @$parent_cdrs) == 2
and not $parent_cdrs->[0]->is_pbx()
and $parent_cdrs->[1]->is_pbx()
and (scalar @{$parent_cdrs->[0]->{_correlated_cdrs}}) == 0
and (scalar @{$parent_cdrs->[1]->{_correlated_cdrs}}) == 1
and ($scenario->{ccs_subscriber} = NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscribers::findby_uuid(undef,$parent_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])
and (not defined $primary_alias_pattern or $scenario->{ccs_subscriber}->{primary_alias}->{username} =~ $primary_alias_pattern)
) {
my $correlated_cdr = $parent_cdrs->[1]->{_correlated_cdrs}->[0];
my $ivr_duration = abs($correlated_cdr->{start_time} - $parent_cdrs->[1]->{init_time});
if ($ivr_duration < $ivr_duration_limit) {
$scenario->{code} = $ATTN_TRANSFER_NO_IVR;
} else {
$scenario->{code} = $ATTN_TRANSFER;
}
$result = 1;
} #elsif (...
#
#}
foreach my $cdr (@scenario_cdrs) {
if ($result) {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::OK;
} elsif ($malformed) {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::FAILED;
} else {
$cdr->{_extended_export_status} = $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::SKIPPED;
}
$context->{file_cdr_id_map}->{$cdr->{id}} = $cdr; #->{start_time};
lock $rowcount;
$rowcount += 1;
}
$context->{file_cdr_id_map}->{$cdr->{id}} = $cdr; #->{start_time};
lock $rowcount;
$rowcount += 1;
}
}
}
}
if ($scenario->{code} == $DIRECT_FORWARDER_SCENARIO) {
$scenario->{start_time} = $context->{cdrs}->[0]->{start_time};
$scenario->{duration} = $context->{cdrs}->[0]->{duration};
$scenario->{originating} = $context->{cdrs}->[0]->{$ama_originating_digits_cdr_field};
$scenario->{terminating} = $context->{cdrs}->[1]->{$ama_terminating_digits_cdr_field};
$scenario->{unanswered} = ($context->{cdrs}->[1]->{call_status} ne $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::OK_CALL_STATUS ? 1 : 0);
$scenario->{correlation_id} = substr($context->{cdrs}->[0]->{id},-7);
$scenario->{nod} = {
originating_digits => $scenario->{originating},
switch_number_digits => $scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '0001',
};
if ($scenario->{code} == $BLIND_TRANSFER_NO_IVR) {
my $originating = $parent_cdrs->[0]->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[1]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[1]->{start_time}, #?
duration => $parent_cdrs->[1]->{duration},
originating => $originating,
terminating => $terminating,
unanswered => ($parent_cdrs->[1]->{call_status} ne $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::OK_CALL_STATUS ? 1 : 0),
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '0001',
},
});
} elsif ($scenario->{code} == $BLIND_TRANSFER) {
my $originating = $parent_cdrs->[0]->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[1]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[0]->{start_time}, #?
duration => abs($parent_cdrs->[0]->{start_time} - $parent_cdrs->[1]->{init_time}),
originating => $originating,
terminating => $terminating,
unanswered => 0,
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '6001',
},
},{
start_time => $parent_cdrs->[1]->{start_time},
duration => $parent_cdrs->[1]->{duration},
originating => $originating,
terminating => $terminating,
unanswered => ($parent_cdrs->[1]->{call_status} ne $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::OK_CALL_STATUS ? 1 : 0),
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '2002',
},
});
} elsif ($scenario->{code} == $NO_TRANSFER_NO_IVR) {
my $originating = $parent_cdrs->[0]->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[0]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[0]->{start_time}, #?
duration => 0,
originating => $originating,
terminating => $terminating,
unanswered => 1,
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '0001',
},
});
} elsif ($scenario->{code} == $NO_TRANSFER) {
my $originating = $parent_cdrs->[0]->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[0]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[0]->{start_time}, #?
duration => $parent_cdrs->[0]->{duration},
originating => $originating,
terminating => $terminating,
unanswered => 0,
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '6001',
},
},{
start_time => $parent_cdrs->[0]->{start_time}, #?
duration => 0,
originating => $originating,
terminating => $terminating,
unanswered => 1,
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '2002',
},
});
} elsif ($scenario->{code} == $ATTN_TRANSFER_NO_IVR) {
my $correlated_cdr = $parent_cdrs->[1]->{_correlated_cdrs}->[0];
my $originating = $correlated_cdr->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[1]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[1]->{start_time}, #?
duration => $correlated_cdr->{duration} - abs($correlated_cdr->{start_time} - $parent_cdrs->[1]->{start_time}),
originating => $originating,
terminating => $terminating,
unanswered => ($correlated_cdr->{call_status} ne $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::OK_CALL_STATUS ? 1 : 0),
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '0001',
},
});
} elsif ($scenario->{code} == $ATTN_TRANSFER) {
my $correlated_cdr = $parent_cdrs->[1]->{_correlated_cdrs}->[0];
my $originating = $correlated_cdr->{$ama_originating_digits_cdr_field};
my $terminating = $parent_cdrs->[1]->{$ama_terminating_digits_cdr_field};
push(@{$scenario->{ama}},{
start_time => $parent_cdrs->[1]->{start_time}, #?
duration => abs($correlated_cdr->{start_time} - $parent_cdrs->[1]->{init_time}),
originating => $originating,
terminating => $terminating,
unanswered => 0,
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '6001',
},
},{
start_time => $parent_cdrs->[1]->{start_time}, #?
duration => $correlated_cdr->{duration} - abs($correlated_cdr->{start_time} - $parent_cdrs->[1]->{start_time}),
originating => $originating,
terminating => $terminating,
unanswered => ($correlated_cdr->{call_status} ne $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr::OK_CALL_STATUS ? 1 : 0),
correlation_id => substr($parent_cdrs->[0]->{id},-7),
nod => {
originating_digits => $originating,
switch_number_digits => $terminating, #$scenario->{ccs_subscriber}->{primary_alias}->{username},
mode => '2002',
},
});
}
return $result;
@ -432,6 +637,76 @@ sub _get_transfer_in {
}
sub _create_ama_record {
my ($context,$ama) = @_;
$context->{file}->update_start_end_time($ama->{start_time},$ama->{start_time} + $ama->{duration});
return NGCP::BulkProcessor::Projects::Export::Ama::Format::Record->new(
NGCP::BulkProcessor::Projects::Export::Ama::Format::Structures::Structure0510->new(
call_type => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::CallType::STATION_PAID,
rewritten => 0,
sensor_id => $ama_sensor_id,
padding => 0,
recording_office_id => $ama_recording_office_id,
call_type => '970',
#timing ind 000
#seervice observed 0c
unanswered => $ama->{unanswered}, #called party off-hook setzen
date => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::Date::get_ama_date(from_epoch($ama->{start_time})),
service_feature => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ServiceFeature::OTHER,
originating_significant_digits => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_length($ama->{originating}),
originating_open_digits_1 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_1($ama->{originating}),
originating_open_digits_2 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_2($ama->{originating}),
domestic_international => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::DomesticInternational::INTERNATIONAL, #get_number_domestic_international($context->{destination}),
terminating_significant_digits => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_length($ama->{terminating}),
terminating_open_digits_1 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_1($ama->{terminating}),
terminating_open_digits_2 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_2($ama->{terminating}),
connect_time => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ConnectTime::get_connect_time(from_epoch($ama->{start_time})),
elapsed_time => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ElapsedTime::get_elapsed_time($ama->{duration}),
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module611->new(
generic_context_identifier => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::GenericContextIdentifier::IN_CORRELATION_ID,
parsing_rules => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::GenericContextIdentifier::IN_CORRELATION_ID_PARSING_RULES,
additional_digits_dialed => $ama->{correlation_id},
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module199->new(
network_operator_data => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::NetworkOperatorData::get_network_operator_data(
$ama->{nod}->{originating_digits},
$ama->{nod}->{switch_number_digits},
$ama->{nod}->{mode},
),
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module104->new(
direction => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::TrunkIdentification::INCOMING,
trunk_group_number => $ama_incoming_trunk_group_number,
trunk_member_number => '0000',
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module104->new(
direction => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::TrunkIdentification::OUTGOING,
trunk_group_number => $ama_outgoing_trunk_group_number,
trunk_member_number => '0000',
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module000->new(
),
);
}
sub _create_ama_records {
my ($context,$scenario_name) = @_;
my $records = [ map { _create_ama_record($context,$_); } @{$context->{scenario}->{ama}} ];
_info($context,"$scenario_name - cdr ids " . join(', ', map { $_->{id}; } @{$context->{scenario}->{all_cdrs}}) . ':' . join("\n", map { $_->to_string(); } @$records),1);
return $records;
}
sub _get_record {
my %params = @_;
@ -441,70 +716,20 @@ sub _get_record {
context
/};
if ($context->{scenario}->{code} == $DIRECT_FORWARDER_SCENARIO) {
$context->{file}->update_start_end_time($context->{scenario}->{start_time},$context->{scenario}->{start_time} + $context->{scenario}->{duration});
my $record = NGCP::BulkProcessor::Projects::Export::Ama::Format::Record->new(
NGCP::BulkProcessor::Projects::Export::Ama::Format::Structures::Structure0510->new(
call_type => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::CallType::STATION_PAID,
rewritten => 0,
sensor_id => $ama_sensor_id,
padding => 0,
recording_office_id => $ama_recording_office_id,
call_type => '970',
#timing ind 000
#seervice observed 0c
unanswered => $context->{scenario}->{unanswered}, #called party off-hook setzen
date => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::Date::get_ama_date(from_epoch($context->{scenario}->{start_time})),
service_feature => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ServiceFeature::OTHER,
originating_significant_digits => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_length($context->{scenario}->{originating}),
originating_open_digits_1 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_1($context->{scenario}->{originating}),
originating_open_digits_2 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_2($context->{scenario}->{originating}),
domestic_international => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::DomesticInternational::INTERNATIONAL, #get_number_domestic_international($context->{destination}),
terminating_significant_digits => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_length($context->{scenario}->{terminating}),
terminating_open_digits_1 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_1($context->{scenario}->{terminating}),
terminating_open_digits_2 => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::SignificantDigitsNextField::get_number_digits_2($context->{scenario}->{terminating}),
connect_time => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ConnectTime::get_connect_time(from_epoch($context->{scenario}->{start_time})),
elapsed_time => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::ElapsedTime::get_elapsed_time($context->{scenario}->{duration}),
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module611->new(
generic_context_identifier => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::GenericContextIdentifier::IN_CORRELATION_ID,
parsing_rules => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::GenericContextIdentifier::IN_CORRELATION_ID_PARSING_RULES,
additional_digits_dialed => $context->{scenario}->{correlation_id},
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module199->new(
network_operator_data => NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::NetworkOperatorData::get_network_operator_data(
$context->{scenario}->{nod}->{originating_digits},
$context->{scenario}->{nod}->{switch_number_digits},
$context->{scenario}->{nod}->{mode},
),
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module104->new(
direction => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::TrunkIdentification::INCOMING,
trunk_group_number => $ama_incoming_trunk_group_number,
trunk_member_number => '0000',
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module104->new(
direction => $NGCP::BulkProcessor::Projects::Export::Ama::Format::Fields::TrunkIdentification::OUTGOING,
trunk_group_number => $ama_outgoing_trunk_group_number,
trunk_member_number => '0000',
),
NGCP::BulkProcessor::Projects::Export::Ama::Format::Modules::Module000->new(
),
);
_info($context,"ama record from cdr ids " . join(', ',map { $_->{id}; } @{$context->{cdrs}}) . ':' . $record->to_string(),1);
return $record;
if ($context->{scenario}->{code} == $BLIND_TRANSFER_NO_IVR) {
return _create_ama_records($context,'BLIND_TRANSFER_NO_IVR');
} elsif ($context->{scenario}->{code} == $BLIND_TRANSFER) {
return _create_ama_records($context,'BLIND_TRANSFER');
} elsif ($context->{scenario}->{code} == $NO_TRANSFER_NO_IVR) {
return _create_ama_records($context,'NO_TRANSFER_NO_IVR');
} elsif ($context->{scenario}->{code} == $NO_TRANSFER) {
return _create_ama_records($context,'NO_TRANSFER');
} elsif ($context->{scenario}->{code} == $ATTN_TRANSFER_NO_IVR) {
return _create_ama_records($context,'ATTN_TRANSFER_NO_IVR');
} elsif ($context->{scenario}->{code} == $ATTN_TRANSFER) {
return _create_ama_records($context,'ATTN_TRANSFER');
} else {
_error($context,"unknown scenario $context->{scenario}->{code} for cdr ids " . join(', ',map { $_->{id}; } @{$context->{cdrs}}) );
_error($context,"unknown scenario $context->{scenario}->{code} for cdr ids " . join(', ',map { $_->{id}; } @{$context->{scenario}->{all_cdrs}}) );
}
}

12
lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/Settings.pm
Unescape View File

@ -61,6 +61,8 @@ our @EXPORT_OK = qw(
$ama_originating_digits_cdr_field
$ama_terminating_digits_cdr_field
$ivr_duration_limit
$primary_alias_pattern
);
our $defaultconfig = 'config.cfg';
@ -88,6 +90,9 @@ our $ama_outgoing_trunk_group_number;
our $ama_originating_digits_cdr_field;
our $ama_terminating_digits_cdr_field;
our $ivr_duration_limit = 5;
our $primary_alias_pattern = undef;
sub update_settings {
my ($data,$configfile) = @_;
@ -128,6 +133,13 @@ sub update_settings {
configurationerror($configfile,'unknown ama_terminating_digits_cdr_field',getlogger(__PACKAGE__));
}
$ivr_duration_limit = $data->{ivr_duration_limit} if exists $data->{ivr_duration_limit};
my $regexp_result;
$primary_alias_pattern = $data->{primary_alias_pattern} if exists $data->{primary_alias_pattern};
($regexp_result,$primary_alias_pattern) = parse_regexp($primary_alias_pattern,$configfile);
$result &= $regexp_result;
return $result;
}

2
lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/config.debug.cfg
Unescape View File

@ -59,6 +59,6 @@ doneemailrecipient =
##logging:
fileloglevel = DEBUG
#DEBUG
screenloglevel = INFO
screenloglevel = DEBUG
#INFO
emailloglevel = OFF

3
lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/settings.cfg
Unescape View File

@ -27,3 +27,6 @@ ama_incoming_trunk_group_number = 2999
ama_outgoing_trunk_group_number = 2014
ama_originating_digits_cdr_field = source_cli
ama_terminating_digits_cdr_field = destination_user_in
ivr_duration_limit = 5
primary_alias_pattern = 431976

6
lib/NGCP/BulkProcessor/Projects/Export/Ama/Ccs/settings.debug.cfg
Unescape View File

@ -12,6 +12,7 @@ export_cdr_rollover_fsn = 1
#, { 'accounting.cdr.rating_status' => { '=' => '"ok"' } }
#{ 'accounting.cdr.call_status' => { '=' => '"ok"' } }
#export_cdr_joins = { 'accounting.cdr_export_status_data esd' => { 'esd.cdr_id' => 'accounting.cdr.id' } }, { 'accounting.cdr_export_status es' => { 'es.id' => 'esd.status_id' } }
export_cdr_conditions = { 'accounting.cdr.id' => { '>=' => '51' } }
use_tempfiles = 1
make_dir = 1
@ -27,4 +28,7 @@ ama_recording_office_id = 438716
ama_incoming_trunk_group_number = 2999
ama_outgoing_trunk_group_number = 2014
ama_originating_digits_cdr_field = source_cli
ama_terminating_digits_cdr_field = destination_user_in
ama_terminating_digits_cdr_field = destination_user_in
ivr_duration_limit = 5
#primary_alias_pattern = 431976

33
lib/NGCP/BulkProcessor/Projects/Export/Ama/Format/File.pm
Unescape View File

@ -294,23 +294,26 @@ sub write_record {
) unless $self->{record_count} > 0;
my $result = 0;
my $record = &$get_record(@_);
if (not $self->add_record($record)) {
$result |= $self->close(
get_transfer_out => $get_transfer_out,
commit_cb => $commit_cb,
@_
);
$self->add_record(
$self->_save_transfer_in(&$get_transfer_in(
#file_sequence_number => 1,
my $records = &$get_record(@_);
$records = [ $records ] unless 'ARRAY' eq ref $records;
foreach my $record (@$records) {
if (not $self->add_record($record)) {
$result |= $self->close(
get_transfer_out => $get_transfer_out,
commit_cb => $commit_cb,
@_
)),
1
);
);
$self->add_record(
$self->_save_transfer_in(&$get_transfer_in(
$self->add_record($record);
#file_sequence_number => 1,
@_
)),
1
);
$self->add_record($record);
}
}
return $result;

Write Preview
Loading…
Cancel
Save