fix: insert udm subscriber not include tenant info issue

This commit is contained in:
2024-07-09 09:28:58 +08:00
parent 0515996389
commit c503e2ec5d

View File

@@ -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)