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.
632 lines
26 KiB
632 lines
26 KiB
package NGCP::Panel::Model::DB::InvoiceTemplate;
|
|
use base NGCP::Panel::Model::DB::Base;
|
|
|
|
#use irka;
|
|
use Data::Dumper;
|
|
|
|
sub getDefaultConditions{
|
|
my $self = shift;
|
|
my ($params) = @_;
|
|
#irka::loglong(Dumper($params));
|
|
my ($provider_id,$tt_sourcestate,$tt_type,$tt_id) = @$params{qw/provider_id tt_sourcestate tt_type tt_id/};
|
|
my $conditions = {};
|
|
#irka::loglong("getDefaultConditions: tt_id=$tt_id;\n");
|
|
if($tt_id){
|
|
$conditions = { id => $tt_id };
|
|
}else{
|
|
$conditions = {
|
|
reseller_id => $provider_id,
|
|
type => $tt_type,
|
|
is_active => 1,
|
|
};
|
|
}
|
|
return $conditions;
|
|
}
|
|
sub getInvoiceTemplate{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id,$tt_sourcestate,$tt_type,$tt_id) = @params{qw/provider_id tt_sourcestate tt_type tt_id/};
|
|
|
|
#irka::loglong("getInvoiceTemplate: tt_id=$tt_id;\n");
|
|
#irka::loglong(Dumper(\%params));
|
|
my $result = '';
|
|
|
|
my $conditions = $self->getDefaultConditions(\%params);
|
|
#my $tt_record = $self->resultset('invoice_templates')->search({
|
|
#it is hard to express my disappointment by DBIx implementation. Where pure SQL is easy to automate, flexible and powerful, with DBIx you can't even get DB as aliases, only additional accessors, which aren't a option. What a poor "wonabe hibernate" idea and implementation.
|
|
my $tt_record = $self->schema->resultset('invoice_templates')->search(
|
|
{ id => $tt_id }, {
|
|
#'+select' => [{'reseller_id' =>'provider_id','-as'=>'provider_id'},{'id' => 'tt_id','-as'=>'tt_id'}]
|
|
#'+select' => [
|
|
# [ 'reseller_id', {'-as'=>'provider_id'}],
|
|
# [ 'id', {'-as'=>'tt_id'}],
|
|
#],
|
|
#'+select' => [qw/reseller_id id/],
|
|
#'+as' => [qw/provider_id tt_id/]
|
|
#'-as' => [{reseller_id=>provider_id},{ id=>tt_id}]
|
|
}
|
|
)->first;
|
|
#here may be base64 decoding
|
|
|
|
#here we will rely on form checking and defaults
|
|
#if('saved' eq $tt_sourcestate){
|
|
if( $tt_record ){
|
|
$tt_sourcestate and $result = $tt_record->get_column( 'base64_'.$tt_sourcestate );
|
|
#$tt_record->reseller_id
|
|
$tt_id = $tt_record->get_column( 'id' );
|
|
}
|
|
if( $result && exists $params{result} ){
|
|
${$params{result}} = $result;
|
|
}
|
|
return ( $tt_id, \$result, $tt_record );#tt_record - sgorila hata, gori i saray
|
|
}
|
|
|
|
sub storeInvoiceTemplateContent{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id, $tt_sourcestate, $tt_type,$tt_string,$tt_id,$is_active,$name) = @params{qw/provider_id tt_sourcestate tt_type tt_string_sanitized tt_id is_active name/};
|
|
|
|
#my $tt_record = $self->resultset('invoice_templates')->search({
|
|
$self->schema->txn_do(sub {
|
|
#reseller_id and is_active aren't unique key, because is_active can kepp some 0 values for one reseller, we shouldn't keep active and inactive in one table
|
|
# $self->schema->resultset('invoice_templates')->update_or_create({
|
|
# reseller_id => $provider_id,
|
|
# type => $tt_type,
|
|
# is_active => 1,
|
|
# 'base64_'.$tt_sourcestate => $$tt_string,
|
|
# });
|
|
|
|
|
|
#here may be base64 decoding
|
|
|
|
# $self->schema->resultset('ivoice_template')->search({
|
|
# reseller_id => $provider_id,
|
|
# type => $tt_type,
|
|
# })->update_all({
|
|
# is_active => 0,
|
|
# });
|
|
#I think that SQl + DBI are much more flexible and compact
|
|
my $tt_record_created;
|
|
my $tt_record_updated;
|
|
if( !$tt_id ){
|
|
$tt_record_created = $self->schema->resultset('invoice_templates')->create({
|
|
reseller_id => $provider_id,
|
|
type => $tt_type,
|
|
# is_active => $is_active,
|
|
# name => $name,
|
|
'base64_'.$tt_sourcestate => $$tt_string,
|
|
});
|
|
if($tt_record_created){
|
|
$tt_id = $tt_record_created->id();
|
|
}
|
|
}else{
|
|
my $conditions = $self->getDefaultConditions(\%params);
|
|
$tt_record_updated = $self->schema->resultset('invoice_templates')->search($conditions);
|
|
$tt_record_updated->update({
|
|
# is_active => $is_active,
|
|
# name => $name,
|
|
'base64_'.$tt_sourcestate => $$tt_string,
|
|
});
|
|
}
|
|
# if($is_active && $tt_id){
|
|
# $self->deactivateOtherTemplates($provider_id,$tt_id);
|
|
# }
|
|
});
|
|
return { tt_id => $tt_id };
|
|
}
|
|
sub storeInvoiceTemplateInfo{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id,$tt_id,$is_active,$name) = @params{qw/provider_id tt_id is_active name/};
|
|
|
|
#my $tt_record = $self->resultset('invoice_templates')->search({
|
|
$self->schema->txn_do(sub {
|
|
my $tt_record_created;
|
|
my $tt_record_updated;
|
|
if( !$tt_id ){
|
|
$tt_record_created = $self->schema->resultset('invoice_templates')->create({
|
|
reseller_id => $provider_id,
|
|
is_active => $is_active,
|
|
name => $name,
|
|
});
|
|
if($tt_record_created){
|
|
$tt_id = $tt_record_created->id();
|
|
}
|
|
}else{
|
|
$tt_record_updated = $self->schema->resultset('invoice_templates')->search({ id => $tt_id });
|
|
$tt_record_updated->update({
|
|
is_active => $is_active,
|
|
name => $name,
|
|
});
|
|
}
|
|
if($is_active && $tt_id){
|
|
$self->deactivateOtherTemplates($provider_id,$tt_id);
|
|
}
|
|
});
|
|
return { tt_id => $tt_id };
|
|
}
|
|
sub getInvoiceTemplateList{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id,$tt_sourcestate,$tt_type, $tt_string, $tt_id) = @params{qw/provider_id tt_sourcestate tt_type tt_string_sanitized tt_id/};
|
|
|
|
#return [
|
|
#$self->schema->resultset('invoice_template_fake')->find(\'select * from invoice_templates')->all
|
|
#$self->schema->resultset('invoice_templates')->name(\'(select * from invoice_templates)')->all
|
|
#];
|
|
return $self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
});
|
|
}
|
|
sub deleteInvoiceTemplate{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id, $tt_id) = @params{qw/provider_id tt_id/};
|
|
return $self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
id => $tt_id,
|
|
})->delete_all;
|
|
}
|
|
sub activateInvoiceTemplate{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id, $tt_id) = @params{qw/provider_id tt_id/};
|
|
$self->schema->txn_do(sub {
|
|
$self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
id => $tt_id,
|
|
})->update({
|
|
is_active => 1,
|
|
});
|
|
$self->deactivateOtherTemplates($provider_id,$tt_id);
|
|
});
|
|
}
|
|
sub deactivateInvoiceTemplate{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id, $tt_id) = @params{qw/provider_id tt_id/};
|
|
$self->schema->txn_do(sub {
|
|
$self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
id => $tt_id,
|
|
})->update({
|
|
is_active => 0,
|
|
});
|
|
});
|
|
}
|
|
sub deactivateOtherTemplates{
|
|
my $self = shift;
|
|
my ($provider_id,$tt_id) = @_;
|
|
$self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
id => {'!=' => $tt_id },
|
|
is_active => 1,
|
|
})->update_all({
|
|
is_active => 0,
|
|
});
|
|
}
|
|
sub checkInvoiceTemplateProvider{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_id,$tt_id) = @params{qw/provider_id tt_id/};
|
|
my $tt_record = $self->schema->resultset('invoice_templates')->search({
|
|
reseller_id => $provider_id,
|
|
id => $tt_id,
|
|
});
|
|
if($tt_record->get_column('id')){
|
|
return 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
sub getContractInfo{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($contract_id) = @params{qw/contract_id/};
|
|
return $self->schema->resultset('contracts')->search({
|
|
id => $contract_id,
|
|
})->first;
|
|
}
|
|
sub getContactInfo{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($contact_id) = @params{qw/contact_id/};
|
|
return $self->schema->resultset('contacts')->search({
|
|
id => $contact_id,
|
|
})->first;
|
|
}
|
|
sub getBillingProfile{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($client_contract_id, $stime, $etime) = @params{qw/client_contract_id stime etime/};
|
|
#select distinct billing_profiles.*
|
|
#from billing_mappings
|
|
#inner join billing_profiles on billing_mappings.billing_profile_id=billing_profiles.id
|
|
#inner join contracts on contracts.id=billing_mappings.contract_id
|
|
#inner join products on billing_mappings.product_id=products.id and products.class in("sipaccount","pbxaccount")
|
|
#where
|
|
# contracts.status != "terminated"
|
|
# and contracts.contact_id=?
|
|
# and (billing_mappings.start_date <= ? OR billing_mappings.start_date IS NULL)
|
|
# and (billing_mappings.end_date >= ? OR billing_mappings.end_date IS NULL)
|
|
return $self->schema->resultset('billing_profiles')->search({
|
|
'contract.id' => $client_contract_id,
|
|
#'contract.status' => { '!=' => 'terminated' },
|
|
'product.class' => { '-in' => [qw/sipaccount pbxaccount/] },
|
|
'billing_mappings.start_date' => [
|
|
{ '<=' => $etime->epoch },
|
|
{ -is => undef },
|
|
],
|
|
'billing_mappings.end_date' => [
|
|
{ '>=' => $stime->epoch },
|
|
{ -is => undef },
|
|
],
|
|
},{
|
|
'join' => [ { 'billing_mappings' => [ 'product', 'contract' ] } ],
|
|
})->first;
|
|
}
|
|
sub getContractBalance{
|
|
my $self = shift;
|
|
my ($params) = @_;
|
|
my ($client_contract_id, $stime, $etime) = @$params{qw/client_contract_id stime etime/};
|
|
#select distinct billing_profiles.*
|
|
#from billing_mappings
|
|
#inner join billing_profiles on billing_mappings.billing_profile_id=billing_profiles.id
|
|
#inner join contracts on contracts.id=billing_mappings.contract_id
|
|
#inner join products on billing_mappings.product_id=products.id and products.class in("sipaccount","pbxaccount")
|
|
#where
|
|
# contracts.status != "terminated"
|
|
# and contracts.contact_id=?
|
|
# and (billing_mappings.start_date <= ? OR billing_mappings.start_date IS NULL)
|
|
# and (billing_mappings.end_date >= ? OR billing_mappings.end_date IS NULL)
|
|
return $self->schema->resultset('contract_balances')->search({
|
|
'contract_id' => $client_contract_id,
|
|
#'contract.status' => { '!=' => 'terminated' },
|
|
'start' => [
|
|
{ '<=' => $etime->ymd },
|
|
{ '-is' => undef },
|
|
],
|
|
'end' => [
|
|
{ '>=' => $stime->ymd },
|
|
{ '-is' => undef },
|
|
],
|
|
},undef)->first;
|
|
}
|
|
|
|
sub getProviderInvoiceList{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_reseller_id,$stime,$etime) = @params{qw/provider_id stime etime/};
|
|
$stime ||= NGCP::Panel::Utils::DateTime::current_local()->truncate( to => 'month' );
|
|
$etime ||= $stime->clone->add( months => 1);
|
|
$self->schema->resultset('invoices')->search({
|
|
'-and' =>
|
|
[
|
|
'contact.reseller_id' => $provider_reseller_id, #$client_contract_id - contract of the client
|
|
],
|
|
},{
|
|
'select' => [ 'contract_balances.invoice_id','contract_balances.start','contract_balances.end','contract_balances.cash_balance','contract_balances.free_time_balance','reseller.id','reseller.name','contact.id',],
|
|
'as' => [ 'invoice_id','contract_balance_start','contract_balance_end','cash_balance','free_time_balance', 'reseller_id', 'reseller_name','client_contact_id' ],
|
|
'prefetch' => [ {'contract_balances' => { 'contract' => { 'contact' => 'reseller' } } } ],
|
|
#'collapse' => 1,
|
|
'order_by' => [ { '-desc' => 'contract_balances.start' },{ '-asc' => 'contract_balances.end' }, ],
|
|
'alias' => 'me',
|
|
});
|
|
}
|
|
sub getProviderInvoiceListAjax{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_reseller_id,$client_contact_id,$stime,$etime) = @params{qw/provider_id client_contact_id stime etime/};
|
|
$stime ||= NGCP::Panel::Utils::DateTime::current_local()->truncate( to => 'month' );
|
|
$etime ||= $stime->clone->add( months => 1);
|
|
$self->schema->resultset('invoices')->search({
|
|
'-and' =>
|
|
[
|
|
'contact.reseller_id' => $provider_reseller_id, #$client_contract_id - contract of the client
|
|
$client_contact_id ? ('contact.id' => $client_contact_id) : (), #$client_contract_id - contract of the client
|
|
],
|
|
},{
|
|
#'select' => [ 'contract_balances.invoice_id','contract_balances.start','contract_balances.end','contract_balances.cash_balance','contract_balances.free_time_balance','reseller.id','reseller.name','contact.id',],
|
|
#'as' => [ 'invoice_id','contract_balance_start','contract_balance_end','cash_balance','free_time_balance', 'reseller_id', 'reseller_name','client_contact_id' ],
|
|
#'prefetch' => [ {'contract_balances' => { 'contract' => { 'contact' => 'reseller' } } } ],
|
|
##'collapse' => 1,
|
|
#'order_by' => [ { '-desc' => 'contract_balances.start' },{ '-asc' => 'contract_balances.end' }, ],
|
|
#'alias' => 'me',
|
|
});
|
|
}
|
|
sub createInvoice{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($contract_balance,$data,$stime,$etime) = @params{qw/contract_balance data stime etime/};
|
|
|
|
# my($contract_id, $stime, $etime) = @_;
|
|
##my $invoice_serial = $dbh->selectrow_array('select max(invoices.serial) from invoices inner join contract_balances on invoices.id=contract_balances.invoice_id where contract_balances.contract_id=?',undef,$contract_id );
|
|
#my $invoice_serial = $dbh->selectrow_array('select max(invoices.serial) from invoices');
|
|
#$invoice_serial += 1;
|
|
#$dbh->do('insert into invoices(year,month,serial)values(?,?,?)', undef, $stime->year, $stime->month,$invoice_serial );
|
|
#my $invoice_id = $dbh->last_insert_id(undef,'billing','invoices','id');
|
|
#$dbh->do('update contract_balances set invoice_id = ? where contract_id=? and start=? and end=?', undef, $invoice_id,$contract_id, $stime->datetime, $etime->datetime );
|
|
#return $dbh->selectrow_hashref('select * from invoices where id=?',undef, $invoice_id);
|
|
my $invoice;
|
|
|
|
if( $contract_balance->get_column('invoice_id')){
|
|
$invoice = $self->schema->resultset('invoices')->search({
|
|
id => $contract_balance->get_column('invoice_id'),
|
|
})->first;
|
|
}else{
|
|
|
|
my $invoice_serial = $self->schema->resultset('invoices')->search(undef, {
|
|
'select' => { 'max' => 'me.serial', '-as' => 'serial_max'},
|
|
})->first->get_column('serial_max');
|
|
$invoice_serial +=1;
|
|
|
|
my $invoice_record = $self->schema->resultset('invoices')->create({
|
|
year => $stime->year,
|
|
month => $stime->month,
|
|
serial => $invoice_serial,
|
|
data => $data,
|
|
});
|
|
if($invoice_record){
|
|
$self->schema->resultset('contract_balances')->search({
|
|
id => $contract_balance->get_column('id'),
|
|
})->update({
|
|
invoice_id => $invoice_record->id()
|
|
});
|
|
$invoice = $self->schema->resultset('invoices')->search({
|
|
id => $invoice_record->id(),
|
|
})->first;
|
|
}
|
|
}
|
|
return $invoice;
|
|
}
|
|
sub storeInvoiceData{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($invoice,$data_ref) = @params{qw/invoice data/};
|
|
$self->schema->resultset('invoices')->search({
|
|
id => $invoice->get_column('id'),
|
|
})->update({
|
|
data => $$data_ref
|
|
});
|
|
}
|
|
sub getInvoice{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($invoice_id) = @params{qw/invoice_id/};
|
|
return $self->schema->resultset('invoices')->search({
|
|
'id' => $invoice_id,
|
|
}, undef )->first;
|
|
}
|
|
sub getInvoiceProviderClients{
|
|
my $self = shift;
|
|
my (%params) = @_;
|
|
my ($provider_contact_id,$stime,$etime) = @params{qw/provider_id stime etime/};
|
|
$stime ||= NGCP::Panel::Utils::DateTime::current_local()->truncate( to => 'month' );
|
|
$etime ||= $stime->clone->add( months => 1);
|
|
$self->schema->resultset('contacts')->search_rs({
|
|
'-and' =>
|
|
[
|
|
'me.reseller_id' => $provider_contact_id, #$client_contract_id - contract of the client
|
|
],
|
|
'-exists' => $self->schema->resultset('billing_mappings')->search({
|
|
'contract.contact_id' => \' = me.id',
|
|
'product.class' => [ "sipaccount", "pbxaccount" ],
|
|
#'-and' => [
|
|
# 'start_date' => [ -or =>
|
|
# { '<=' => $etime->epoch },
|
|
# { -is => undef },
|
|
# ],
|
|
# 'end_date' => [ -or =>
|
|
# { '>=' => $stime->epoch },
|
|
# { -is => undef },
|
|
# ],
|
|
# ]
|
|
},{
|
|
alias => 'billing_mappings_top',
|
|
join => ['product','contract'],
|
|
})->as_query
|
|
});
|
|
}
|
|
|
|
sub get_contract_calls_rs{
|
|
my $self = shift;
|
|
my %params = @_;
|
|
(my($c,$provider_id,$client_contact_id,$client_contract_id,$stime,$etime)) = @params{qw/c provider_id client_contact_id client_contract_id stime etime/};#I think it may be a record (very long var name)
|
|
my %source_account_id_condition;
|
|
$stime ||= NGCP::Panel::Utils::DateTime::current_local()->truncate( to => 'month' );
|
|
$etime ||= $stime->clone->add( months => 1 );
|
|
if($client_contract_id){
|
|
%source_account_id_condition = ( 'source_user_id' => $client_contract_id );
|
|
}elsif($client_contact_id){
|
|
%source_account_id_condition = ( 'source_account.contact_id' => $client_contact_id );
|
|
}elsif($provider_id){
|
|
%source_account_id_condition = ( 'contact.reseller_id' => $client_contact_id );
|
|
}
|
|
# $source_account_id_condition = {
|
|
# 'in' => $self->getInvoiceProviderClients(%params)->search_rs({},{
|
|
# 'select' => 'me.id',
|
|
# })->as_query()
|
|
# };
|
|
# $source_account_id_condition = { 'in' => $self->getInvoiceProviderClients(
|
|
# provider_contact_id => $provider_contact_id,
|
|
# stime => $stime,
|
|
# etime => $etime,
|
|
# )->search_rs(undef,{
|
|
# 'select' => 'me.id',
|
|
# })->as_query };
|
|
#}
|
|
##I find that sql is more compact and clear
|
|
#$sql_of_all_provider_contract_id_clients_contact_ids_sip_pbx = ['
|
|
#select contacts.*
|
|
#from contacts
|
|
#where
|
|
# contacts.reseller_id=?
|
|
# and exists (select *
|
|
# from billing_mappings
|
|
# inner join contracts on contracts.id=billing_mappings.contract_id
|
|
# inner join products on billing_mappings.product_id=products.id and products.class in("sipaccount","pbxaccount")
|
|
# where contracts.contact_id=contacts.id
|
|
# and (start_date <= ? OR start_date IS NULL)
|
|
# and (end_date >= ? OR end_date IS NULL)
|
|
#)',$provider_contract_id, $etime->epoch, $stime->epoch];
|
|
#$sql_of_all_client_contract_id_calls = '
|
|
#select cdr.*
|
|
#from accounting.cdr
|
|
# inner join contracts on cdr.source_account_id=contracts.id
|
|
# and contracts.status != "terminated"
|
|
#where
|
|
# cdr.source_user_id != 0
|
|
# and cdr.call_status="ok"
|
|
# and exists (select *
|
|
# from billing_mappings
|
|
# inner join products on billing_mappings.product_id=products.id and products.class in("sipaccount","pbxaccount")
|
|
# where contracts.id=billing_mappings.contract_id
|
|
# and (billing_mappings.start_date >= now() OR start_date IS NULL)
|
|
# and (billing_mappings.end_date <= now() OR end_date IS NULL)
|
|
# )
|
|
# and contracts.contact_id=22
|
|
# order by cdr.start_time
|
|
#';
|
|
#
|
|
#$sql_of_all_provider_contact_id_clients_calls = '
|
|
#select cdr.*
|
|
#from contacts
|
|
# inner join contracts on contracts.contact_id=contacts.id
|
|
# and contacts.reseller_id=2 and contacts.reseller_id!=contacts.id
|
|
# inner join accounting.cdr on cdr.source_account_id=contracts.id
|
|
# and contracts.status != "terminated"
|
|
#where
|
|
# cdr.source_user_id != 0
|
|
# and cdr.call_status="ok"
|
|
# and exists (select *
|
|
# from billing_mappings
|
|
# inner join products on billing_mappings.product_id=products.id and products.class in("sipaccount","pbxaccount")
|
|
# where contracts.id=billing_mappings.contract_id
|
|
# and (billing_mappings.start_date >= now() OR start_date IS NULL)
|
|
# and (billing_mappings.end_date <= now() OR end_date IS NULL)
|
|
# )
|
|
# order by cdr.start_time
|
|
#';
|
|
#my $calls_rs = $self->schema->resultset('cdr')->search( {
|
|
# # source_user_id => { 'in' => [ map {$_->uuid} @{$contract->{subscriber}} ] },
|
|
# 'call_status' => 'ok',
|
|
# 'source_user_id' => { '!=' => '0' },
|
|
# 'contact.id' => { '!=' => $provider_contact_id },
|
|
# '-and' => [
|
|
# #'contact.reseller_id' => $provider_id, #$client_contract_id - contract of the client
|
|
# 'contact.reseller_id' => { '!=' => undef },
|
|
# ],
|
|
# 'source_account.status' => { '!=' => 'terminated'},
|
|
# '-exists' => $self->schema->resultset('billing_mappings')->search({
|
|
# 'contract_id' => \'= source_account.id',
|
|
# 'product.class' => [ "sipaccount", "pbxaccount" ],
|
|
# 'start_date' => [ -or =>
|
|
# { '<=' => 'cdr.start_time' },
|
|
# { -is => undef },
|
|
# ],
|
|
# 'end_date' => [ -or =>
|
|
# { '>=' => 'cdr.start_time' },
|
|
# { -is => undef },
|
|
# ],
|
|
# },{
|
|
# alias => 'billing_mappings_top',
|
|
# join => 'product',
|
|
# })->as_query,
|
|
#},{
|
|
# '+select' => [
|
|
# 'source_customer_billing_zones_history.zone',
|
|
# 'source_customer_billing_zones_history.detail',
|
|
# 'destination_user_in',
|
|
# ],
|
|
# '+as' => [qw/zone zone_detail destination/],
|
|
# 'join' => [
|
|
# {
|
|
# 'source_account' => 'contact',
|
|
# },
|
|
# 'source_customer_billing_zones_history',
|
|
# ]
|
|
#} );
|
|
|
|
my $calls_rs = $self->schema->resultset('cdr')->search( {
|
|
# source_user_id => { 'in' => [ map {$_->uuid} @{$contract->{subscriber}} ] },
|
|
'call_status' => 'ok',
|
|
'source_user_id' => { '!=' => '0' },
|
|
'contact.reseller_id' => { '!=' => undef },
|
|
start_time =>
|
|
[ -and =>
|
|
{ '>=' => $stime->epoch},
|
|
{ '<=' => $etime->epoch},
|
|
],
|
|
%source_account_id_condition
|
|
},{
|
|
'+select' => [
|
|
'source_customer_billing_zones_history.zone',
|
|
'source_customer_billing_zones_history.detail',
|
|
'destination_user_in',
|
|
],
|
|
'+as' => [qw/zone zone_detail destination/],
|
|
'join' => [
|
|
{
|
|
'source_account' => 'contact',
|
|
},
|
|
'source_customer_billing_zones_history',
|
|
]
|
|
} );
|
|
|
|
return $calls_rs;
|
|
}
|
|
sub get_contract_zonesfees_rs {
|
|
my $self = shift;
|
|
my %params = @_;
|
|
(my ($c,$provider_id,$client_contact_id,$client_contract_id,$stime,$etime)) = @params{qw/c provider_id client_contact_id client_contract_id stime etime/};
|
|
my %source_account_id_condition;
|
|
if(!$client_id){
|
|
$source_account_id_condition = { 'in' => $self->getInvoiceProviderClients(%params)->search_rs({},{
|
|
'select' => 'me.id',
|
|
})->as_query() };
|
|
}else{
|
|
$source_account_id_condition = $client_id;
|
|
}
|
|
|
|
# SELECT 'out' as direction, SUM(c.source_customer_cost) AS cost, b.zone,
|
|
# COUNT(*) AS number, SUM(c.duration) AS duration
|
|
# FROM accounting.cdr c
|
|
# LEFT JOIN billing.voip_subscribers v ON c.source_user_id = v.uuid
|
|
# LEFT JOIN billing.billing_zones_history b ON b.id = c.source_customer_billing_zone_id
|
|
# WHERE v.contract_id = ?
|
|
# AND c.call_status = 'ok'
|
|
# $start_time $end_time
|
|
# GROUP BY b.zone
|
|
|
|
my $zonecalls_rs = $self->schema->resultset('cdr')->search( {
|
|
# source_user_id => { 'in' => [ map {$_->uuid} @{$contract->{subscriber}} ] },
|
|
call_status => 'ok',
|
|
source_user_id => { '!=' => '0' },
|
|
#source_account_id => $source_account_id_condition,
|
|
|
|
# start_time =>
|
|
# [ -and =>
|
|
# { '>=' => $stime->epoch},
|
|
# { '<=' => $etime->epoch},
|
|
# ],
|
|
|
|
},{
|
|
'+select' => [
|
|
{ sum => 'me.source_customer_cost', -as => 'cost', },
|
|
{ sum => 'me.source_customer_free_time', -as => 'free_time', } ,
|
|
{ sum => 'me.duration', -as => 'duration', } ,
|
|
{ count => '*', -as => 'number', } ,
|
|
'source_customer_billing_zones_history.zone',
|
|
'source_customer_billing_zones_history.detail',
|
|
],
|
|
'+as' => [qw/cost free_time duration number zone zone_detail/],
|
|
#alias =>
|
|
join => 'source_customer_billing_zones_history',
|
|
group_by => 'source_customer_billing_zones_history.zone',
|
|
order_by => 'source_customer_billing_zones_history.zone',
|
|
} );
|
|
|
|
return $zonecalls_rs;
|
|
}
|
|
|
|
1; |