diff --git a/lib/NGCP/BulkProcessor/Dao/mr103/billing/contracts.pm b/lib/NGCP/BulkProcessor/Dao/mr103/billing/contracts.pm index 75e8913..8cdfbbe 100644 --- a/lib/NGCP/BulkProcessor/Dao/mr103/billing/contracts.pm +++ b/lib/NGCP/BulkProcessor/Dao/mr103/billing/contracts.pm @@ -47,7 +47,7 @@ my $get_db = \&get_billing_db; my $expected_fieldnames = [ 'id', 'customer_id', - 'reseller_id', + #'reseller_id', 'contact_id', 'order_id', 'status', @@ -174,7 +174,7 @@ sub source_process_records { destroy_reader_dbs_code => $destroy_reader_dbs_code, multithreading => $multithreading, tableprocessing_threads => $numofthreads, - 'select' => 'SELECT c.*,r.name as reseller_name FROM ' . $table . ' c left join billing.resellers r on c.reseller_id = r.id WHERE c.status != "' . $TERMINATED_STATE . '"', # and id = 7185', + 'select' => 'SELECT c.*,"UPC" as reseller_name FROM ' . $table . ' c WHERE status != "' . $TERMINATED_STATE . '"', # and id = 7185', 'selectcount' => 'SELECT COUNT(c.id) FROM ' . $table . ' c WHERE c.status != "' . $TERMINATED_STATE . '"', # and id = 7185', ); } @@ -188,7 +188,7 @@ sub source_findby_id { my $db = &$source_db(); my $table = $db->tableidentifier($tablename); - my $stmt = 'SELECT c.*,r.name as reseller_name FROM ' . $table . ' c join billing.resellers r on c.reseller_id = r.id WHERE ' . + my $stmt = 'SELECT c.*,"UPC" as reseller_name FROM ' . $table . ' c WHERE ' . 'c.id = ?'; my @params = ($id); diff --git a/lib/NGCP/BulkProcessor/Dao/mr103/provisioning/voip_subscribers.pm b/lib/NGCP/BulkProcessor/Dao/mr103/provisioning/voip_subscribers.pm index 4e2172f..6184468 100644 --- a/lib/NGCP/BulkProcessor/Dao/mr103/provisioning/voip_subscribers.pm +++ b/lib/NGCP/BulkProcessor/Dao/mr103/provisioning/voip_subscribers.pm @@ -45,15 +45,15 @@ my $expected_fieldnames = [ 'uuid', 'password', - 'timezone', + #'timezone', 'admin', 'account_id', 'webusername', 'webpassword', - 'autoconf_displayname', - 'autoconf_group_id', + #'autoconf_displayname', + #'autoconf_group_id', 'modify_timestamp', 'create_timestamp',