Change-Id: I5381b36e226b1c0c2032fa40c3a082b85485e4ac
(cherry picked from commit b35b0e1cbc)
changes/68/21168/3
Rene Krenn
7 years ago
parent
0a7e733bab
commit
2492ef2767
@ -0,0 +1,542 @@
|
||||
package NGCP::Panel::Utils::BillingMappings;
|
||||
use strict;
|
||||
use warnings;
|
||||
|
||||
use Sipwise::Base;
|
||||
use NGCP::Panel::Utils::DateTime qw();
|
||||
use DateTime::Format::Strptime qw();
|
||||
|
||||
sub get_actual_billing_mapping {
|
||||
my %params = @_;
|
||||
my ($c,$schema,$contract,$now) = @params{qw/c schema contract now/};
|
||||
$schema //= $c->model('DB');
|
||||
$now //= NGCP::Panel::Utils::DateTime::current_local;
|
||||
my $contract_create = NGCP::Panel::Utils::DateTime::set_local_tz($contract->create_timestamp // $contract->modify_timestamp);
|
||||
my $dtf = $schema->storage->datetime_parser;
|
||||
$now = $contract_create if $now < $contract_create; #if there is no mapping starting with or before $now, it would returns the mapping with max(id):
|
||||
my $bm_actual = $schema->resultset('billing_mappings_actual')->search({ contract_id => $contract->id },{bind => [ ( $dtf->format_datetime($now) ) x 2, ($contract->id) x 2 ],})->first;
|
||||
if ($bm_actual) {
|
||||
return $bm_actual->billing_mappings->first;
|
||||
}
|
||||
return undef;
|
||||
}
|
||||
|
||||
sub get_actual_billing_mapping_stmt {
|
||||
my %params = @_;
|
||||
my ($c,$schema,$contract,$now,$projection,$contract_id_alias) = @params{qw/c schema contract now projection contract_id_alias/};
|
||||
$schema //= $c->model('DB');
|
||||
$now //= NGCP::Panel::Utils::DateTime::current_local;
|
||||
my $dtf = $schema->storage->datetime_parser;
|
||||
$projection //= 'actual_billing_mapping.id';
|
||||
$contract_id_alias //= 'me.id';
|
||||
|
||||
return sprintf(<<EOS
|
||||
select
|
||||
%s
|
||||
from
|
||||
billing.billing_mappings actual_billing_mapping
|
||||
join billing.billing_profiles billing_profile on actual_billing_mapping.billing_profile_id = billing_profile.id
|
||||
left join billing.billing_networks billing_network on actual_billing_mapping.network_id = billing_network.id
|
||||
join billing.products product on actual_billing_mapping.product_id = product.id
|
||||
where
|
||||
actual_billing_mapping.contract_id = %s
|
||||
and (actual_billing_mapping.end_date >= %s or actual_billing_mapping.end_date is null)
|
||||
and (actual_billing_mapping.start_date <= %s or actual_billing_mapping.start_date is null)
|
||||
order by actual_billing_mapping.start_date desc, actual_billing_mapping.id desc limit 1
|
||||
EOS
|
||||
, $projection, $contract_id_alias, ( map { '"'.$_.'"'; } ( $dtf->format_datetime($now), $dtf->format_datetime($now) ) ));
|
||||
|
||||
}
|
||||
|
||||
sub prepare_billing_mappings {
|
||||
my (%params) = @_;
|
||||
|
||||
my ($c,$resource,$old_resource,$mappings_to_create,$now,$delete_mappings,$err_code,$billing_profile_field,$billing_profiles_field,$profile_package_field,$billing_profile_definition_field) = @params{qw/c resource old_resource mappings_to_create now delete_mappings err_code billing_profile_field billing_profiles_field profile_package_field billing_profile_definition_field/};
|
||||
|
||||
my $schema = $c->model('DB');
|
||||
if (!defined $err_code || ref $err_code ne 'CODE') {
|
||||
$err_code = sub { return 0; };
|
||||
}
|
||||
|
||||
my $profile_def_mode = $resource->{billing_profile_definition} // 'id';
|
||||
$now //= NGCP::Panel::Utils::DateTime::current_local;
|
||||
|
||||
my $reseller_id = undef;
|
||||
my $is_customer = 1;
|
||||
if (defined $resource->{contact_id}) {
|
||||
my $contact = $schema->resultset('contacts')->find($resource->{contact_id});
|
||||
if ($contact) {
|
||||
$reseller_id = $contact->reseller_id; #($contact->reseller_id // -1);
|
||||
$is_customer = defined $reseller_id;
|
||||
}
|
||||
}
|
||||
|
||||
my $product_id = undef; #any subsequent create will fail without product_id
|
||||
my $prepaid = undef;
|
||||
my $billing_profile_id = undef;
|
||||
if (defined $old_resource) {
|
||||
# TODO: what about changed product, do we allow it?
|
||||
my $billing_mapping;
|
||||
if (exists $old_resource->{billing_mapping_id}) {
|
||||
$billing_mapping = $schema->resultset('billing_mappings')->find($old_resource->{billing_mapping_id});
|
||||
} elsif (exists $old_resource->{id}) {
|
||||
$billing_mapping = get_actual_billing_mapping(schema => $schema,
|
||||
contract => $schema->resultset('contracts')->find($old_resource->{id}),
|
||||
now => $now);
|
||||
#} else {
|
||||
# return 0 unless &{$err_code}("No billing mapping or contract defined");
|
||||
}
|
||||
$product_id = $billing_mapping->contract->product->id;
|
||||
$prepaid = $billing_mapping->billing_profile->prepaid;
|
||||
$billing_profile_id = $billing_mapping->billing_profile->id;
|
||||
} else {
|
||||
if (exists $resource->{type} || exists $c->stash->{type}) {
|
||||
my $productclass = (exists $c->stash->{type} ? $c->stash->{type} : $resource->{type});
|
||||
my $product = $schema->resultset('products')->search_rs({ class => $productclass })->first;
|
||||
if ($product) {
|
||||
$product_id = $product->id;
|
||||
}
|
||||
} elsif (exists $resource->{product_id}) {
|
||||
$product_id = $resource->{product_id};
|
||||
}
|
||||
}
|
||||
|
||||
if ('id' eq $profile_def_mode) {
|
||||
my $delete = undef;
|
||||
if (defined $old_resource) { #update
|
||||
if (defined $resource->{billing_profile_id}) {
|
||||
if ($billing_profile_id != $resource->{billing_profile_id}) {
|
||||
#change profile:
|
||||
$delete = 0; #1; #delete future mappings?
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_network(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
resource => $resource,
|
||||
profile_id_field => 'billing_profile_id',
|
||||
field => $billing_profile_field,
|
||||
);
|
||||
my ($profile) = @$entities{qw/profile/};
|
||||
push(@$mappings_to_create,{billing_profile_id => $profile->id,
|
||||
network_id => undef,
|
||||
product_id => $product_id,
|
||||
start_date => $now,
|
||||
end_date => undef,
|
||||
});
|
||||
} else {
|
||||
#not changed, don't touch mappings
|
||||
$delete = 0;
|
||||
}
|
||||
} else {
|
||||
#undef profile is not allowed
|
||||
$delete = 0;
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_network(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
resource => $resource,
|
||||
profile_id_field => 'billing_profile_id',
|
||||
field => $billing_profile_field,
|
||||
);
|
||||
}
|
||||
} else { #create
|
||||
$delete = 1; #for the sake of completeness
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_network(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
resource => $resource,
|
||||
profile_id_field => 'billing_profile_id',
|
||||
field => $billing_profile_field,
|
||||
);
|
||||
my ($profile) = @$entities{qw/profile/};
|
||||
push(@$mappings_to_create,{billing_profile_id => $profile->id,
|
||||
network_id => undef,
|
||||
product_id => $product_id,
|
||||
#we don't change the former behaviour in update situations:
|
||||
start_date => undef,
|
||||
end_date => undef,
|
||||
});
|
||||
}
|
||||
if (defined $delete_mappings && ref $delete_mappings eq 'SCALAR') {
|
||||
$$delete_mappings = $delete;
|
||||
}
|
||||
delete $resource->{profile_package_id};
|
||||
} elsif ('profiles' eq $profile_def_mode) {
|
||||
if (!defined $resource->{billing_profiles}) {
|
||||
$resource->{billing_profiles} //= [];
|
||||
}
|
||||
if (ref $resource->{billing_profiles} ne "ARRAY") {
|
||||
return 0 unless &{$err_code}("Invalid field 'billing_profiles'. Must be an array.",$billing_profiles_field);
|
||||
}
|
||||
my %interval_type_counts = ( open => 0, open_any_network => 0, 'open end' => 0, 'open start' => 0, 'start-end' => 0 );
|
||||
my $dtf = $schema->storage->datetime_parser;
|
||||
foreach my $mapping (@{$resource->{billing_profiles}}) {
|
||||
if (ref $mapping ne "HASH") {
|
||||
return 0 unless &{$err_code}("Invalid element in array 'billing_profiles'. Must be an object.",$billing_profiles_field);
|
||||
}
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_network(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
resource => $mapping,
|
||||
field => $billing_profiles_field,
|
||||
profile_id_field => 'profile_id',
|
||||
network_id_field => 'network_id',
|
||||
);
|
||||
my ($profile,$network) = @$entities{qw/profile network/};
|
||||
if (defined $prepaid) {
|
||||
if ($profile->prepaid != $prepaid) {
|
||||
return 0 unless &{$err_code}("Future switching between prepaid and post-paid billing profiles is not supported (" . $profile->name . ").",$billing_profiles_field);
|
||||
}
|
||||
} else {
|
||||
$prepaid = $profile->prepaid;
|
||||
}
|
||||
|
||||
# TODO: what about changed product, do we allow it?
|
||||
#my $product_class = delete $mapping->{type};
|
||||
#unless( (defined $product_class ) && ($product_class eq "sipaccount" || $product_class eq "pbxaccount") ) {
|
||||
# return 0 unless &{$err_code}("Mandatory 'type' parameter is empty or invalid, must be 'sipaccount' or 'pbxaccount'.");
|
||||
#}
|
||||
#my $product = $schema->resultset('products')->search_res({ class => $product_class })->first;
|
||||
#unless($product) {
|
||||
# return 0 unless &{$err_code}("Invalid 'type'.");
|
||||
#} else {
|
||||
# # add product_id just for form check (not part of the actual contract item)
|
||||
# # and remove it after the check
|
||||
# $mapping->{product_id} = $product->id;
|
||||
#}
|
||||
|
||||
my $start = (defined $mapping->{start} ? NGCP::Panel::Utils::DateTime::from_string($mapping->{start}) : undef);
|
||||
my $stop = (defined $mapping->{stop} ? NGCP::Panel::Utils::DateTime::from_string($mapping->{stop}) : undef);
|
||||
|
||||
if (!defined $start && !defined $stop) { #open interval
|
||||
$interval_type_counts{open} += 1;
|
||||
$interval_type_counts{open_any_network} += 1 unless $network;
|
||||
} elsif (defined $start && !defined $stop) { #open end interval
|
||||
my $start_str = $dtf->format_datetime($start);
|
||||
if ($start <= $now) {
|
||||
return 0 unless &{$err_code}("'start' timestamp ($start_str) is not in future.",$billing_profiles_field);
|
||||
}
|
||||
#if (exists $start_dupes{$start_str}) {
|
||||
# $start_dupes{$start_str} += 1;
|
||||
# return 0 unless &{$err_code}("Identical 'start' timestamps ($start_str) not allowed.");
|
||||
#} else {
|
||||
# $start_dupes{$start_str} = 1;
|
||||
#}
|
||||
$interval_type_counts{'open end'} += 1;
|
||||
} elsif (!defined $start && defined $stop) { #open start interval
|
||||
my $stop_str = $dtf->format_datetime($stop);
|
||||
return 0 unless &{$err_code}("Interval with 'stop' timestamp ($stop_str) but no 'start' timestamp specified.",$billing_profiles_field);
|
||||
$interval_type_counts{'open start'} //= 0;
|
||||
$interval_type_counts{'open start'} += 1;
|
||||
} else { #start-end interval
|
||||
my $start_str = $dtf->format_datetime($start);
|
||||
if ($start <= $now) {
|
||||
return 0 unless &{$err_code}("'start' timestamp ($start_str) is not in future.",$billing_profiles_field);
|
||||
}
|
||||
my $stop_str = $dtf->format_datetime($stop);
|
||||
if ($start >= $stop) {
|
||||
return 0 unless &{$err_code}("'start' timestamp ($start_str) has to be before 'stop' timestamp ($stop_str).",$billing_profiles_field);
|
||||
}
|
||||
#if (exists $start_dupes{$start_str}) {
|
||||
# $start_dupes{$start_str} += 1;
|
||||
# return 0 unless &{$err_code}("Identical 'start' timestamps ($start_str) not allowed.");
|
||||
#} else {
|
||||
# $start_dupes{$start_str} = 1;
|
||||
#}
|
||||
$interval_type_counts{'start-end'} += 1;
|
||||
}
|
||||
|
||||
push(@$mappings_to_create,{
|
||||
billing_profile_id => $profile->id,
|
||||
network_id => ($is_customer && defined $network ? $network->id : undef),
|
||||
product_id => $product_id,
|
||||
start_date => $start,
|
||||
end_date => $stop,
|
||||
});
|
||||
}
|
||||
|
||||
if (!defined $old_resource && $interval_type_counts{'open_any_network'} < 1) {
|
||||
return 0 unless &{$err_code}("An initial interval without 'start' and 'stop' timestamps and no billing network is required.",$billing_profiles_field);
|
||||
} elsif (defined $old_resource && $interval_type_counts{'open'} > 0) {
|
||||
return 0 unless &{$err_code}("Adding intervals without 'start' and 'stop' timestamps is not allowed.",$billing_profiles_field);
|
||||
}
|
||||
if (defined $delete_mappings && ref $delete_mappings eq 'SCALAR') {
|
||||
$$delete_mappings = 1; #always clear future mappings to place new ones
|
||||
}
|
||||
delete $resource->{profile_package_id};
|
||||
} elsif ('package' eq $profile_def_mode) {
|
||||
if (!$is_customer) {
|
||||
return 0 unless &{$err_code}("Setting a profile package is supported for customer contracts only.",$billing_profile_definition_field);
|
||||
}
|
||||
my $delete = undef;
|
||||
if (defined $old_resource) { #update
|
||||
if (defined $old_resource->{profile_package_id} && !defined $resource->{profile_package_id}) {
|
||||
#clear package: don't touch billing mappings (just clear profile package)
|
||||
$delete = 0;
|
||||
} elsif (!defined $old_resource->{profile_package_id} && defined $resource->{profile_package_id}) {
|
||||
#set package: apply initial mappings
|
||||
$delete = 0; #1; #delete future mappings?
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_package(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
package_id => $resource->{profile_package_id},
|
||||
field => $profile_package_field,
|
||||
);
|
||||
my ($package) = @$entities{qw/package/};
|
||||
foreach my $mapping ($package->initial_profiles->all) {
|
||||
push(@$mappings_to_create,{ #assume not terminated,
|
||||
billing_profile_id => $mapping->profile_id,
|
||||
network_id => ($is_customer ? $mapping->network_id : undef),
|
||||
product_id => $product_id,
|
||||
start_date => $now,
|
||||
end_date => undef,
|
||||
});
|
||||
}
|
||||
} elsif (defined $old_resource->{profile_package_id} && defined $resource->{profile_package_id}) {
|
||||
if ($old_resource->{profile_package_id} != $resource->{profile_package_id}) {
|
||||
#change package: apply initial mappings
|
||||
$delete = 0; #1; #delete future mappings?
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_package(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
package_id => $resource->{profile_package_id},
|
||||
field => $profile_package_field,
|
||||
);
|
||||
my ($package) = @$entities{qw/package/};
|
||||
foreach my $mapping ($package->initial_profiles->all) {
|
||||
push(@$mappings_to_create,{ #assume not terminated,
|
||||
billing_profile_id => $mapping->profile_id,
|
||||
network_id => ($is_customer ? $mapping->network_id : undef),
|
||||
product_id => $product_id,
|
||||
start_date => $now,
|
||||
end_date => undef,
|
||||
});
|
||||
}
|
||||
} else {
|
||||
#package unchanged: don't touch billing mappings
|
||||
$delete = 0;
|
||||
}
|
||||
} else {
|
||||
#package unchanged (null): don't touch billing mappings
|
||||
$delete = 0;
|
||||
}
|
||||
} else { #create
|
||||
$delete = 1; #for the sake of completeness
|
||||
my $entities = {};
|
||||
return 0 unless _check_profile_package(c => $c, reseller_id => $reseller_id, err_code => $err_code, entities => $entities,
|
||||
package_id => $resource->{profile_package_id},
|
||||
field => $profile_package_field,
|
||||
);
|
||||
my ($package) = @$entities{qw/package/};
|
||||
foreach my $mapping ($package->initial_profiles->all) {
|
||||
push(@$mappings_to_create,{ #assume not terminated,
|
||||
billing_profile_id => $mapping->profile_id,
|
||||
network_id => ($is_customer ? $mapping->network_id : undef),
|
||||
product_id => $product_id,
|
||||
start_date => undef, #$now,
|
||||
end_date => undef,
|
||||
});
|
||||
}
|
||||
}
|
||||
if (defined $delete_mappings && ref $delete_mappings eq 'SCALAR') {
|
||||
$$delete_mappings = $delete;
|
||||
}
|
||||
} else {
|
||||
return 0 unless &{$err_code}("Invalid 'billing_profile_definition'.",$billing_profile_definition_field);
|
||||
}
|
||||
|
||||
delete $resource->{billing_profile_id};
|
||||
delete $resource->{billing_profiles};
|
||||
|
||||
delete $resource->{billing_profile_definition};
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
sub _check_profile_network {
|
||||
my (%params) = @_;
|
||||
my ($c,$res,$profile_id_field,$network_id_field,$field,$reseller_id,$err_code,$entities) = @params{qw/c resource profile_id_field network_id_field field reseller_id err_code entities/};
|
||||
|
||||
my $schema = $c->model('DB');
|
||||
if (!defined $err_code || ref $err_code ne 'CODE') {
|
||||
$err_code = sub { return 0; };
|
||||
}
|
||||
|
||||
unless(defined $res->{$profile_id_field}) {
|
||||
return 0 unless &{$err_code}("Invalid '$profile_id_field', not defined.",$field);
|
||||
}
|
||||
my $profile = $schema->resultset('billing_profiles')->find($res->{$profile_id_field});
|
||||
unless($profile) {
|
||||
return 0 unless &{$err_code}("Invalid '$profile_id_field' ($res->{$profile_id_field}).",$field);
|
||||
}
|
||||
if ($profile->status eq 'terminated') {
|
||||
return 0 unless &{$err_code}("Invalid '$profile_id_field' ($res->{$profile_id_field}), already terminated.",$field);
|
||||
}
|
||||
if (defined $reseller_id && defined $profile->reseller_id && $reseller_id != $profile->reseller_id) { #($profile->reseller_id // -1)) {
|
||||
return 0 unless &{$err_code}("The reseller of the contact doesn't match the reseller of the billing profile (" . $profile->name . ").",$field);
|
||||
}
|
||||
my $network;
|
||||
if (defined $network_id_field && defined $res->{$network_id_field}) {
|
||||
$network = $schema->resultset('billing_networks')->find($res->{$network_id_field});
|
||||
unless($network) {
|
||||
return 0 unless &{$err_code}("Invalid '$network_id_field' ($res->{$network_id_field}).",$field);
|
||||
}
|
||||
if (defined $reseller_id && defined $network->reseller_id && $reseller_id != $network->reseller_id) { #($network->reseller_id // -1)) {
|
||||
return 0 unless &{$err_code}("The reseller of the contact doesn't match the reseller of the billing network (" . $network->name . ").",$field);
|
||||
}
|
||||
}
|
||||
if (defined $entities and ref $entities eq 'HASH') {
|
||||
$entities->{profile} = $profile;
|
||||
$entities->{network} = $network;
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
|
||||
sub _check_profile_package {
|
||||
my (%params) = @_;
|
||||
my ($c,$res,$package_id,$reseller_id,$field,$err_code,$entities) = @params{qw/c resource package_id reseller_id field err_code entities/};
|
||||
|
||||
my $schema = $c->model('DB');
|
||||
if (!defined $err_code || ref $err_code ne 'CODE') {
|
||||
$err_code = sub { return 0; };
|
||||
}
|
||||
|
||||
unless(defined $package_id) {
|
||||
return 0 unless &{$err_code}("Invalid 'profile_package_id', not defined.",$field);
|
||||
}
|
||||
my $package = $schema->resultset('profile_packages')->find($package_id);
|
||||
unless($package) {
|
||||
return 0 unless &{$err_code}("Invalid 'profile_package_id'.",$field);
|
||||
}
|
||||
|
||||
if (defined $reseller_id && defined $package->reseller_id && $reseller_id != $package->reseller_id) {
|
||||
return 0 unless &{$err_code}("The reseller of the contact doesn't match the reseller of the profile package (" . $package->name . ").",$field);
|
||||
}
|
||||
|
||||
if (defined $entities and ref $entities eq 'HASH') {
|
||||
$entities->{package} = $package;
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
|
||||
sub resource_from_future_mappings {
|
||||
my ($contract) = @_;
|
||||
return resource_from_mappings($contract,1);
|
||||
}
|
||||
|
||||
sub resource_from_mappings {
|
||||
|
||||
my ($contract,$future_only) = @_;
|
||||
|
||||
my $is_customer = (defined $contract->contact->reseller_id ? 1 : 0);
|
||||
my @mappings_resource = ();
|
||||
|
||||
my $datetime_fmt = DateTime::Format::Strptime->new(
|
||||
pattern => '%F %T',
|
||||
); #validate_forms uses RFC3339 otherwise, which contains the tz offset part
|
||||
|
||||
foreach my $mapping (billing_mappings_ordered($future_only ? future_billing_mappings($contract->billing_mappings) : $contract->billing_mappings)->all) {
|
||||
my %m = $mapping->get_inflated_columns;
|
||||
delete $m{id};
|
||||
$m{start} = delete $m{start_date};
|
||||
$m{stop} = delete $m{end_date};
|
||||
$m{start} = $datetime_fmt->format_datetime($m{start}) if defined $m{start};
|
||||
$m{stop} = $datetime_fmt->format_datetime($m{stop}) if defined $m{stop};
|
||||
$m{profile_id} = delete $m{billing_profile_id};
|
||||
delete $m{contract_id};
|
||||
delete $m{product_id};
|
||||
delete $m{network_id} unless $is_customer;
|
||||
push(@mappings_resource,\%m);
|
||||
}
|
||||
|
||||
return \@mappings_resource;
|
||||
|
||||
}
|
||||
|
||||
sub billing_mappings_ordered {
|
||||
my ($rs,$now,$actual_bmid) = @_;
|
||||
|
||||
my $dtf;
|
||||
$dtf = $rs->result_source->schema->storage->datetime_parser if defined $now;
|
||||
|
||||
my @select = ();
|
||||
if ($now) {
|
||||
push(@select,{ '' => \[ 'if(`me`.`start_date` is null,0,`me`.`start_date` > ?)', $dtf->format_datetime($now) ], -as => 'is_future' });
|
||||
}
|
||||
if ($actual_bmid) {
|
||||
push(@select,{ '' => \[ '`me`.`id` = ?', $actual_bmid ], -as => 'is_actual' });
|
||||
}
|
||||
|
||||
return $rs->search_rs(
|
||||
{},
|
||||
{ order_by => { '-asc' => ['start_date', 'id']},
|
||||
(scalar @select == 1 ? ('+select' => $select[0]) : ()),
|
||||
(scalar @select > 1 ? ('+select' => \@select) : ()),
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
sub remove_future_billing_mappings {
|
||||
|
||||
my ($contract,$now) = @_;
|
||||
$now //= NGCP::Panel::Utils::DateTime::current_local;
|
||||
|
||||
future_billing_mappings($contract->billing_mappings,$now)->delete;
|
||||
|
||||
}
|
||||
|
||||
sub future_billing_mappings {
|
||||
|
||||
my ($rs,$now) = @_;
|
||||
$now //= NGCP::Panel::Utils::DateTime::current_local;
|
||||
|
||||
return $rs->search_rs({start_date => { '>' => $now },});
|
||||
|
||||
}
|
||||
|
||||
sub get_billingmappings_timeline_data {
|
||||
my ($c,$contract,$range) = @_;
|
||||
unless ($range) {
|
||||
$range = eval { $c->req->body_data; };
|
||||
if ($@) {
|
||||
$c->log->error('error decoding timeline json request: ' . $@);
|
||||
}
|
||||
}
|
||||
my $start;
|
||||
$start = NGCP::Panel::Utils::DateTime::from_string($range->{start}) if $range->{start};
|
||||
my $end;
|
||||
$end = NGCP::Panel::Utils::DateTime::from_string($range->{end}) if $range->{end};
|
||||
$c->log->debug("timeline range $start - $end");
|
||||
#the max start date (of mappings with NULL end date) less than
|
||||
#the visible range end will become the range start:
|
||||
my $max_start_date = $contract->billing_mappings->search({
|
||||
($end ? (start_date => [ -or =>
|
||||
{ '<=' => $end },
|
||||
{ '=' => undef },
|
||||
]) : ()),
|
||||
end_date => { '=' => undef },
|
||||
},{
|
||||
order_by => { '-desc' => ['start_date', 'me.id']}, #NULL start dates at last
|
||||
})->first;
|
||||
#lower the range start, if required:
|
||||
if ($max_start_date) {
|
||||
if ($max_start_date->start_date) {
|
||||
$start = $max_start_date->start_date if (not $start or $max_start_date->start_date < $start);
|
||||
} else {
|
||||
$start = $max_start_date->start_date;
|
||||
}
|
||||
}
|
||||
my $res = $contract->billing_mappings->search({
|
||||
($end ? (start_date => ($start ? [ -and => {
|
||||
'<=' => $end },{ #hide mappings beginning after range end
|
||||
'>=' => $start #and beginning before range start (max_start_date).
|
||||
},] : [ -or => { #if there is a mapping with NULL start only,
|
||||
'<=' => $end },{ #include all mapping beginning before range end.
|
||||
'=' => undef
|
||||
},])) : ()),
|
||||
},{
|
||||
order_by => { '-asc' => ['start_date', 'me.id']},
|
||||
prefetch => [ 'billing_profile' , 'network' ]
|
||||
});
|
||||
my @timeline_events = map {
|
||||
{ $_->get_columns,
|
||||
billing_profile => { ($_->billing_profile ? ( name => $_->billing_profile->name, ) : ()) },
|
||||
network => { ($_->network ? ( name => $_->network->name, ) : ()) },
|
||||
};
|
||||
} $res->all;
|
||||
return \@timeline_events;
|
||||
}
|
||||
|
||||
1;
|
||||
Loading…
Reference in new issue