You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
217 lines
11 KiB
217 lines
11 KiB
|
|
use strict;
|
|
use warnings;
|
|
|
|
use File::Basename;
|
|
use Cwd;
|
|
use lib Cwd::abs_path(File::Basename::dirname(__FILE__));
|
|
|
|
use Utils::Api qw();
|
|
use Utils::Rateomat qw();
|
|
use Utils::Env qw();
|
|
use Test::More;
|
|
|
|
### testcase outline:
|
|
### onnet calls that consume profile's freecash
|
|
###
|
|
### this tests verify the free cash refill,
|
|
### for both prepaid and postpaid (new).
|
|
|
|
local $ENV{RATEOMAT_WRITE_CDR_RELATION_DATA} = 1;
|
|
local $ENV{RATEOMAT_PREPAID_UPDATE_BALANCE} = 1;
|
|
#Utils::Env::set_local_timezone('UTC','+00:00'); #'UTC'; #vagrant SYSTEM timezone is "Etc/UTC"
|
|
|
|
my $init_secs = 50;
|
|
my $follow_secs = 20;
|
|
my $free_cash_in = 60; #callee
|
|
my $free_cash_out = 50; #caller
|
|
|
|
foreach my $prepaid ((0,1)) { #0,1)) {
|
|
foreach my $balance ((undef,5,65)) { #undef,5,65)) {
|
|
my $now = Utils::Api::get_now();
|
|
my $begin = $now->clone->subtract(months => 3);
|
|
Utils::Api::set_time($begin);
|
|
my $provider = create_provider($prepaid,$free_cash_in,$free_cash_out);
|
|
|
|
my $caller = Utils::Api::setup_subscriber($provider,$provider->{subscriber_fees}->[0]->{profile},$balance,{ cc => 888, ac => '1<n>', sn => '<t>' });
|
|
my $caller_ratio = _get_free_ratio(Utils::Api::datetime_from_string($caller->{customer}->{create_timestamp}),
|
|
Utils::Api::datetime_from_string($caller->{first_interval}->{start}),
|
|
Utils::Api::datetime_from_string($caller->{first_interval}->{stop}));
|
|
is(Utils::Api::get_cash_balance($caller->{customer})->{ratio},$caller_ratio,"caller ratio $caller_ratio");
|
|
|
|
#Utils::Api::set_time($begin->clone->add(days => 10));
|
|
my $callee = Utils::Api::setup_subscriber($provider,$provider->{subscriber_fees}->[1]->{profile},$balance,{ cc => 888, ac => '2<n>', sn => '<t>' });
|
|
my $callee_ratio = _get_free_ratio(Utils::Api::datetime_from_string($callee->{customer}->{create_timestamp}),
|
|
Utils::Api::datetime_from_string($callee->{first_interval}->{start}),
|
|
Utils::Api::datetime_from_string($callee->{first_interval}->{stop}));
|
|
is(Utils::Api::get_cash_balance($callee->{customer})->{ratio},$callee_ratio,"callee ratio $callee_ratio");
|
|
|
|
my ($caller_delta,$callee_delta) = (0,0);
|
|
if (defined $balance) {
|
|
$caller_delta = $free_cash_out * $caller_ratio - $balance;
|
|
$callee_delta = $free_cash_in * $callee_ratio - $balance;
|
|
}
|
|
|
|
my $caller_costs = (($provider->{subscriber_fees}->[0]->{fees}->[0]->{onpeak_init_rate} *
|
|
$init_secs) + ($provider->{subscriber_fees}->[0]->{fees}->[0]->{onpeak_follow_rate} * $follow_secs))/100.0;
|
|
my $callee_costs = (($provider->{subscriber_fees}->[1]->{fees}->[0]->{onpeak_init_rate} *
|
|
$init_secs) + ($provider->{subscriber_fees}->[1]->{fees}->[0]->{onpeak_follow_rate} * $follow_secs))/100.0;
|
|
|
|
my $call_duration = $init_secs + $follow_secs - 1;
|
|
Utils::Api::set_time($now->clone->subtract(months => 2));
|
|
my $start_time1 = Utils::Api::current_unix() - $call_duration;
|
|
Utils::Api::set_time($now->clone->subtract(months => 1));
|
|
my $start_time2 = Utils::Api::current_unix() - $call_duration;
|
|
my @cdr_ids = ();
|
|
#if ($prepaid) {
|
|
# @cdr_ids = map { $_->{cdr}->{id}; } @{ Utils::Rateomat::create_prepaid_costs_cdrs([
|
|
# Utils::Rateomat::prepare_prepaid_costs_cdr($caller->{subscriber}, undef,
|
|
# $caller->{reseller}, $callee->{subscriber}, undef,
|
|
# $callee->{reseller}, '192.168.0.1', $start_time1, $call_duration,$caller_costs,0),
|
|
# Utils::Rateomat::prepare_prepaid_costs_cdr($caller->{subscriber}, undef,
|
|
# $caller->{reseller}, $callee->{subscriber}, undef,
|
|
# $callee->{reseller}, '192.168.0.1', $start_time2, $call_duration,$caller_costs,0),
|
|
# ]) };
|
|
#} else {
|
|
@cdr_ids = map { $_->{id}; } @{ Utils::Rateomat::create_cdrs([
|
|
Utils::Rateomat::prepare_cdr($caller->{subscriber}, undef,
|
|
$caller->{reseller}, $callee->{subscriber}, undef,
|
|
$callee->{reseller}, '192.168.0.1', $start_time1, $call_duration),
|
|
Utils::Rateomat::prepare_cdr($caller->{subscriber}, undef,
|
|
$caller->{reseller}, $callee->{subscriber}, undef,
|
|
$callee->{reseller}, '192.168.0.1', $start_time2, $call_duration),
|
|
]) };
|
|
#}
|
|
|
|
Utils::Api::set_time();
|
|
|
|
if (ok((scalar @cdr_ids) > 0 && Utils::Rateomat::run_rateomat_threads(),'rate-o-mat executed')) {
|
|
#ok(Utils::Rateomat::check_prepaid_costs_cdrs('',0,
|
|
# map { $_ => {
|
|
# id => $_,
|
|
# rating_status => 'ok',
|
|
# source_customer_cost => Utils::Rateomat::decimal_to_string(0),
|
|
# destination_customer_cost => Utils::Rateomat::decimal_to_string(0),
|
|
# };
|
|
# } @cdr_ids),'cdrs were all processed') if $prepaid;
|
|
ok(Utils::Rateomat::check_cdrs('',
|
|
map { $_ => {
|
|
id => $_,
|
|
rating_status => 'ok',
|
|
source_customer_cost => Utils::Rateomat::decimal_to_string($prepaid ? $caller_costs*100 : 0),
|
|
destination_customer_cost => Utils::Rateomat::decimal_to_string($prepaid ? $callee_costs*100 : 0),
|
|
};
|
|
} @cdr_ids),'cdrs were all processed'); # unless $prepaid;
|
|
my $label = ($prepaid ? 'prepaid ' : 'postpaid ') . 'freecash ' . (defined $balance ? "(balance $balance) " : '') . '- caller: ';
|
|
Utils::Api::check_interval_history($label,$caller->{customer}->{id}, [ {
|
|
profile => $provider->{subscriber_fees}->[0]->{profile}->{id},
|
|
cash => '~' . (defined $balance ? $balance : $free_cash_out * $caller_ratio),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[0]->{profile}->{id},
|
|
id => Utils::Rateomat::get_cdr_relation_data($label,$cdr_ids[0],'source','customer','contract_balance_id'),
|
|
cash => '~' . (($free_cash_out - $caller_costs) - $caller_delta),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[0]->{profile}->{id},
|
|
id => Utils::Rateomat::get_cdr_relation_data($label,$cdr_ids[1],'source','customer','contract_balance_id'),
|
|
cash => '~' . (($free_cash_out - $caller_costs) - $caller_delta),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[0]->{profile}->{id},
|
|
cash => '~' . ($free_cash_out - $caller_delta), #by panel
|
|
}]);
|
|
Utils::Rateomat::check_cdr_cash_balance_data($label,$cdr_ids[0],'source','customer','cash_balance',
|
|
{ before => ($free_cash_out - $caller_delta) * 100, after => ($free_cash_out - $caller_costs - $caller_delta) * 100 });
|
|
Utils::Rateomat::check_cdr_cash_balance_data($label,$cdr_ids[1],'source','customer','cash_balance',
|
|
{ before => ($free_cash_out - $caller_delta) * 100, after => ($free_cash_out - $caller_costs - $caller_delta) * 100 });
|
|
|
|
$label = ($prepaid ? 'prepaid ' : 'postpaid ') . 'freecash ' . (defined $balance ? "(balance $balance) " : '') . '- callee: ';
|
|
Utils::Api::check_interval_history($label,$callee->{customer}->{id}, [ {
|
|
profile => $provider->{subscriber_fees}->[1]->{profile}->{id},
|
|
cash => '~' . (defined $balance ? $balance : $free_cash_in * $callee_ratio),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[1]->{profile}->{id},
|
|
id => Utils::Rateomat::get_cdr_relation_data($label,$cdr_ids[0],'destination','customer','contract_balance_id'),
|
|
cash => '~' . ($free_cash_in - $callee_costs - $callee_delta),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[1]->{profile}->{id},
|
|
id => Utils::Rateomat::get_cdr_relation_data($label,$cdr_ids[1],'destination','customer','contract_balance_id'),
|
|
cash => '~' . ($free_cash_in - $callee_costs - $callee_delta),
|
|
},{
|
|
profile => $provider->{subscriber_fees}->[1]->{profile}->{id},
|
|
cash => '~' . ($free_cash_in - $callee_delta), #by panel
|
|
}]);
|
|
Utils::Rateomat::check_cdr_cash_balance_data($label,$cdr_ids[0],'destination','customer','cash_balance',
|
|
{ before => ($free_cash_in - $callee_delta) * 100, after => ($free_cash_in - $callee_costs - $callee_delta) * 100 });
|
|
Utils::Rateomat::check_cdr_cash_balance_data($label,$cdr_ids[1],'destination','customer','cash_balance',
|
|
{ before => ($free_cash_in - $callee_delta) * 100, after => ($free_cash_in - $callee_costs - $callee_delta) * 100 });
|
|
}
|
|
}
|
|
}
|
|
|
|
done_testing();
|
|
exit;
|
|
|
|
sub create_provider {
|
|
my ($prepaid,$free_cash_in,$free_cash_out) = @_;
|
|
|
|
return Utils::Api::setup_provider('test<n>.com', [
|
|
# rates:
|
|
{
|
|
interval_free_cash => $free_cash_out * 100,
|
|
prepaid => $prepaid,
|
|
fees => [
|
|
{
|
|
direction => 'out',
|
|
destination => '.',
|
|
onpeak_init_rate => 3,
|
|
onpeak_init_interval => $init_secs,
|
|
onpeak_follow_rate => 3,
|
|
onpeak_follow_interval => $follow_secs,
|
|
offpeak_init_rate => 2,
|
|
offpeak_init_interval => $init_secs,
|
|
offpeak_follow_rate => 2,
|
|
offpeak_follow_interval => $follow_secs,
|
|
},
|
|
]
|
|
}, {
|
|
interval_free_cash => $free_cash_in * 100,
|
|
prepaid => $prepaid,
|
|
fees => [
|
|
{
|
|
direction => 'in',
|
|
destination => '.',
|
|
source => '.',
|
|
onpeak_init_rate => 4,
|
|
onpeak_init_interval => $init_secs,
|
|
onpeak_follow_rate => 4,
|
|
onpeak_follow_interval => $follow_secs,
|
|
offpeak_init_rate => 2,
|
|
offpeak_init_interval => $init_secs,
|
|
offpeak_follow_rate => 2,
|
|
offpeak_follow_interval => $follow_secs,
|
|
},
|
|
]
|
|
},
|
|
], [
|
|
# billing networks:
|
|
]);
|
|
}
|
|
|
|
sub _get_free_ratio {
|
|
my ($ctime,$stime,$etime) = @_;
|
|
my $start_of_next_interval = _add_second($etime->clone,1);
|
|
$ctime = $ctime->clone->truncate(to => 'day') > $stime ? $ctime->clone->truncate(to => 'day') : $ctime;
|
|
diag('ratio = ' . ($start_of_next_interval->epoch - $ctime->epoch) . ' / ' . ($start_of_next_interval->epoch - $stime->epoch));
|
|
return ($start_of_next_interval->epoch - $ctime->epoch) / ($start_of_next_interval->epoch - $stime->epoch);
|
|
}
|
|
|
|
sub _add_second {
|
|
|
|
my ($dt,$skip_leap_seconds) = @_;
|
|
$dt->add(seconds => 1);
|
|
while ($skip_leap_seconds and $dt->second() >= 60) {
|
|
$dt->add(seconds => 1);
|
|
}
|
|
return $dt;
|
|
|
|
}
|