From 7b261f906ef7c60b0f7937f244c2f4cacae91be8 Mon Sep 17 00:00:00 2001
From: Rene Krenn <rkrenn@sipwise.com>
Date: Wed, 9 Mar 2022 10:59:20 +0100
Subject: [PATCH] TT#166652 add prov_subscriber->subscriber_profile relation

Change-Id: Id809f750969ed6778255d87f3e92876f6a672d34
(cherry picked from commit bca22edb8418521da398dd6436f11fb2ca815d12)
---
 .../provisioning/voip_subscriber_profiles.pm  | 19 ++++++++++++++++++-
 .../Trunk/provisioning/voip_subscribers.pm    |  2 ++
 2 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profiles.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profiles.pm
index 1c53989..c59da7b 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profiles.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscriber_profiles.pm
@@ -20,7 +20,7 @@ our @EXPORT_OK = qw(
     check_table
 
     findby_setid_name
-
+    findby_id
 );
 
 my $tablename = 'voip_subscriber_profiles';
@@ -48,6 +48,23 @@ sub new {
 
 }
 
+sub findby_id {
+
+    my ($id,$load_recursive) = @_;
+
+    check_table();
+    my $db = &$get_db();
+    my $table = $db->tableidentifier($tablename);
+
+    my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
+            $db->columnidentifier('id') . ' = ?';
+    my @params = ($id);
+    my $rows = $db->db_get_all_arrayref($stmt,@params);
+
+    return buildrecords_fromrows($rows,$load_recursive)->[0];
+
+}
+
 sub findby_setid_name {
 
     my ($set_id,$name,$load_recursive) = @_;
diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
index 1d0471c..0fd0f3d 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
@@ -236,6 +236,8 @@ sub buildrecords_fromrows {
             $record->load_relation($load_recursive,'voip_fax_preferences','NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_fax_preferences::findby_subscriberid',$record->{id},$load_recursive);
             $record->load_relation($load_recursive,'voip_fax_destinations','NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_fax_destinations::findby_subscriberid',$record->{id},$load_recursive);
             
+            $record->load_relation($load_recursive,'profile','NGCP::BulkProcessor::Dao::Trunk::provisioning::voip_subscriber_profiles::findby_id',$record->{profile_id},$load_recursive);
+            
             push @records,$record;
         }
     }