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

TT#77954 merge tool: location records

Browse Source 
Change-Id: I94d493730b4ea6c2aa0e48581ebc651a380f4897
changes/28/38528/2
Rene Krenn 5 years ago
parent 2bd47061a1
commit 00bba0da7b
4 changed files with 338 additions and 0 deletions
Show Stats Download Patch File Download Diff File

167
lib/NGCP/BulkProcessor/Dao/mr341/kamailio/location.pm
Unescape View File

@ -0,0 +1,167 @@
package NGCP::BulkProcessor::Dao::mr341::kamailio::location;
use strict;
## no critic
use threads::shared;
use NGCP::BulkProcessor::Logging qw(
getlogger
);
use NGCP::BulkProcessor::ConnectorPool qw(
get_kamailio_db
);
use NGCP::BulkProcessor::SqlProcessor qw(
checktableinfo
copy_row
);
use NGCP::BulkProcessor::SqlRecord qw();
use NGCP::BulkProcessor::Utils qw(threadid);
require Exporter;
our @ISA = qw(Exporter NGCP::BulkProcessor::SqlRecord);
our @EXPORT_OK = qw(
gettablename
check_table
source_findby_username
);
my $tablename = 'location';
my $get_db = \&get_kamailio_db;
my $expected_fieldnames = [
'id',
'username',
'domain',
'contact',
'received',
'path',
'expires',
'q',
'callid',
'cseq',
'last_modified',
'flags',
'cflags',
'user_agent',
'socket',
'methods',
'ruid',
'reg_id',
'instance',
#'server_id',
#'connection_id',
#'keepalive',
#'partition',
];
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 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);
}
sub source_new {
my $class = shift;
my $self = NGCP::BulkProcessor::SqlRecord->new_shared($class,shift,
$tablename,$expected_fieldnames,$indexes);
copy_row($self,shift,$expected_fieldnames);
return $self;
}
sub source_findby_username_domain {
my ($source_dbs,$username) = @_;
my $source_db = $source_dbs->{kamailio_db};
check_table($source_db);
my $db = &$source_db();
my $table = $db->tableidentifier($tablename);
my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
$db->columnidentifier('username') . ' = ?';
my @params = ($username);
my $rows = $db->db_get_all_arrayref($stmt,@params);
return source_buildrecords_fromrows($rows,$source_dbs);
}
sub source_buildrecords_fromrows {
my ($rows,$source_dbs) = @_;
my @records : shared = ();
my $record;
if (defined $rows and ref $rows eq 'ARRAY') {
foreach my $row (@$rows) {
$record = __PACKAGE__->source_new($source_dbs->{kamailio_db},$row);
# transformations go here ...
push @records,$record;
}
}
return \@records;
}
1;

2
lib/NGCP/BulkProcessor/Dao/mr341/provisioning/voip_subscribers.pm
Unescape View File

@ -23,6 +23,7 @@ use NGCP::BulkProcessor::SqlRecord qw();
use NGCP::BulkProcessor::Dao::mr341::provisioning::voip_dbaliases qw();
use NGCP::BulkProcessor::Dao::mr341::provisioning::voip_usr_preferences qw();
use NGCP::BulkProcessor::Dao::mr341::kamailio::voicemail_users qw();
use NGCP::BulkProcessor::Dao::mr341::kamailio::locations qw();
use NGCP::BulkProcessor::Dao::mr341::provisioning::voip_trusted_sources qw();
use NGCP::BulkProcessor::Dao::mr341::provisioning::voip_cf_destination_sets qw();
@ -139,6 +140,7 @@ sub source_buildrecords_fromrows {
$record->{voip_usr_preferences} = NGCP::BulkProcessor::Dao::mr341::provisioning::voip_usr_preferences::source_findby_subscriberid($source_dbs,$record->{id});
$record->{voicemail_users} = NGCP::BulkProcessor::Dao::mr341::kamailio::voicemail_users::source_findby_customerid($source_dbs,$record->{uuid});
$record->{registrations} = NGCP::BulkProcessor::Dao::mr341::kamailio::location::source_findby_username_domain($source_dbs,$record->{username});
$record->{trusted_sources} = NGCP::BulkProcessor::Dao::mr341::provisioning::voip_trusted_sources::source_findby_subscriberid($source_dbs,$record->{id});

167
lib/NGCP/BulkProcessor/Dao/mr553/kamailio/location.pm
Unescape View File

@ -0,0 +1,167 @@
package NGCP::BulkProcessor::Dao::mr553::kamailio::location;
use strict;
## no critic
use threads::shared;
use NGCP::BulkProcessor::Logging qw(
getlogger
);
use NGCP::BulkProcessor::ConnectorPool qw(
get_kamailio_db
);
use NGCP::BulkProcessor::SqlProcessor qw(
checktableinfo
copy_row
);
use NGCP::BulkProcessor::SqlRecord qw();
use NGCP::BulkProcessor::Utils qw(threadid);
require Exporter;
our @ISA = qw(Exporter NGCP::BulkProcessor::SqlRecord);
our @EXPORT_OK = qw(
gettablename
check_table
source_findby_username
);
my $tablename = 'location';
my $get_db = \&get_kamailio_db;
my $expected_fieldnames = [
'id',
'username',
'domain',
'contact',
'received',
'path',
'expires',
'q',
'callid',
'cseq',
'last_modified',
'flags',
'cflags',
'user_agent',
'socket',
'methods',
'ruid',
'reg_id',
'instance',
#'server_id',
#'connection_id',
#'keepalive',
#'partition',
];
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 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);
}
sub source_new {
my $class = shift;
my $self = NGCP::BulkProcessor::SqlRecord->new_shared($class,shift,
$tablename,$expected_fieldnames,$indexes);
copy_row($self,shift,$expected_fieldnames);
return $self;
}
sub source_findby_username_domain {
my ($source_dbs,$username) = @_;
my $source_db = $source_dbs->{kamailio_db};
check_table($source_db);
my $db = &$source_db();
my $table = $db->tableidentifier($tablename);
my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
$db->columnidentifier('username') . ' = ?';
my @params = ($username);
my $rows = $db->db_get_all_arrayref($stmt,@params);
return source_buildrecords_fromrows($rows,$source_dbs);
}
sub source_buildrecords_fromrows {
my ($rows,$source_dbs) = @_;
my @records : shared = ();
my $record;
if (defined $rows and ref $rows eq 'ARRAY') {
foreach my $row (@$rows) {
$record = __PACKAGE__->source_new($source_dbs->{kamailio_db},$row);
# transformations go here ...
push @records,$record;
}
}
return \@records;
}
1;

2
lib/NGCP/BulkProcessor/Dao/mr553/provisioning/voip_subscribers.pm
Unescape View File

@ -23,6 +23,7 @@ use NGCP::BulkProcessor::SqlRecord qw();
use NGCP::BulkProcessor::Dao::mr553::provisioning::voip_dbaliases qw();
use NGCP::BulkProcessor::Dao::mr553::provisioning::voip_usr_preferences qw();
use NGCP::BulkProcessor::Dao::mr553::kamailio::voicemail_users qw();
use NGCP::BulkProcessor::Dao::mr553::kamailio::location qw();
use NGCP::BulkProcessor::Dao::mr553::provisioning::voip_trusted_sources qw();
use NGCP::BulkProcessor::Dao::mr553::provisioning::voip_cf_destination_sets qw();
@ -140,6 +141,7 @@ sub source_buildrecords_fromrows {
$record->{voip_usr_preferences} = NGCP::BulkProcessor::Dao::mr553::provisioning::voip_usr_preferences::source_findby_subscriberid($source_dbs,$record->{id});
$record->{voicemail_users} = NGCP::BulkProcessor::Dao::mr553::kamailio::voicemail_users::source_findby_customerid($source_dbs,$record->{uuid});
$record->{registrations} = NGCP::BulkProcessor::Dao::mr553::kamailio::location::source_findby_username_domain($source_dbs,$record->{username});
$record->{trusted_sources} = NGCP::BulkProcessor::Dao::mr553::provisioning::voip_trusted_sources::source_findby_subscriberid($source_dbs,$record->{id});

Write Preview
Loading…
Cancel
Save