diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm index 43b2d65c..69be2019 100644 --- 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 diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_group.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_group.pm index 14194663..d6769e43 100644 --- 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; diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_tag_data.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr_tag_data.pm index 68201d49..efe5d68f 100644 --- 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;