TT#161550 properly report inserted/ignored cdr records

Change-Id: I2d16cca01ef86bf27d862598adecc5231c8ca347
4 years ago · 591663cb6f
parent 879bf33795
commit 591663cb6f
3 changed files with 2 additions and 3 deletions
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
@ -54,7 +54,6 @@ our @EXPORT_OK = qw(
    findby_id
    get_cdrid_range
    
-    buildrecords_fromrows
 );
 #process_records
 #delete_ids
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_group.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_group.pm
@ -102,7 +102,7 @@ sub insert_row {
    my ($data,$insert_ignore) = @_;
    check_table();
    if (insert_record($db,$xa_db,__PACKAGE__,$data,$insert_ignore,$insert_unique_fields)) {
-        return $xa_db->db_last_insert_id();
+        return $xa_db->db_last_insert_id() || 1;
    }
    return undef;

--- a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_tag_data.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_tag_data.pm
@ -126,7 +126,7 @@ sub insert_row {
    my ($data,$insert_ignore) = @_;
    check_table();
    if (insert_record($db,$xa_db,__PACKAGE__,$data,$insert_ignore,$insert_unique_fields)) {
-        return $xa_db->db_last_insert_id();
+        return $xa_db->db_last_insert_id() || 1;
    }
    return undef;