diff --git a/src/modules/network_data/repository/udm_sub.impl.go b/src/modules/network_data/repository/udm_sub.impl.go index 3afb58ab..e953240a 100644 --- a/src/modules/network_data/repository/udm_sub.impl.go +++ b/src/modules/network_data/repository/udm_sub.impl.go @@ -79,9 +79,6 @@ func (r *UDMSubImpl) ClearAndInsert(neID string, u []model.UDMSub) int64 { if err != nil { logger.Errorf("TRUNCATE err => %v", err) } - // multi-tenancy - r.SetTenantID(&u) - return r.Inserts(u) } @@ -226,6 +223,9 @@ func (r *UDMSubImpl) SelectList(u model.UDMSub) []model.UDMSub { // Insert 批量添加 func (r *UDMSubImpl) Inserts(uArr []model.UDMSub) int64 { + // multi-tenancy + r.SetTenantID(&uArr) + tx := datasource.DefaultDB().CreateInBatches(uArr, 2000) if err := tx.Error; err != nil { logger.Errorf("CreateInBatches err => %v", err)