Change-Id: I2be104b5770c7f68f334d7d6b2867cb5383607cfchanges/05/18105/15
Rene Krenn
7 years ago
parent
16c186e610
commit
f450458ec1
@ -0,0 +1,32 @@
|
||||
package Utils::Env;
|
||||
|
||||
use strict;
|
||||
use warnings;
|
||||
|
||||
use Test::More;
|
||||
use POSIX qw(tzset strftime);
|
||||
|
||||
require Exporter;
|
||||
our @ISA = qw(Exporter);
|
||||
our @EXPORT_OK = qw(
|
||||
set_local_timezone
|
||||
);
|
||||
|
||||
## no critic (Variables::RequireLocalizedPunctuationVars)
|
||||
#$ENV{RATEOMAT_BILLING_DB_HOST} = '192.168.0.84';
|
||||
#$ENV{RATEOMAT_PROVISIONING_DB_HOST} = '192.168.0.84';
|
||||
#$ENV{RATEOMAT_ACCOUNTING_DB_HOST} = '192.168.0.84';
|
||||
|
||||
$ENV{CATALYST_SERVER} = 'https://127.0.0.1:1443';
|
||||
|
||||
sub set_local_timezone {
|
||||
(my $tz,$ENV{RATEOMAT_CONNECTION_TIMEZONE}) = @_;
|
||||
if ($tz) {
|
||||
my $old_tz = strftime("%Z", localtime());
|
||||
$ENV{TZ} = $tz;
|
||||
tzset;
|
||||
diag("switching local timezone from $old_tz to " . strftime("%Z", localtime()));
|
||||
}
|
||||
}
|
||||
|
||||
1;
|
||||
@ -0,0 +1,215 @@
|
||||
|
||||
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;
|
||||
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;
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue