OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

fix: 批量5000异常

Browse Source
This commit is contained in:
TsMask
2023-09-23 18:11:03 +08:00
parent b35ac3e50b
commit e34bba442a
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
features/udm_user/repo/repo_udm_auth_user.go
View File

@@ -166,7 +166,7 @@ func (r *RepoUdmAuthUser) ClearAndInsert(neID string, authArr []model.UdmAuthUse
} }
n := len(authArr) n := len(authArr)
batchSize := 5000 batchSize := 2000
for i := 0; i < n; i += batchSize { for i := 0; i < n; i += batchSize {
end := i + batchSize end := i + batchSize
if end > n { if end > n {
@@ -198,7 +198,7 @@ func (r *RepoUdmAuthUser) Insert(authUser model.UdmAuthUser) int64 {
func (r *RepoUdmAuthUser) Inserts(authUsers []model.UdmAuthUser) int64 { func (r *RepoUdmAuthUser) Inserts(authUsers []model.UdmAuthUser) int64 {
var num int64 var num int64
n := len(authUsers) n := len(authUsers)
batchSize := 5000 batchSize := 2000
for i := 0; i < n; i += batchSize { for i := 0; i < n; i += batchSize {
end := i + batchSize end := i + batchSize
if end > n { if end > n {

4
features/udm_user/repo/repo_udm_sub_user.go
View File

@@ -185,7 +185,7 @@ func (r *RepoUdmSubUser) ClearAndInsert(neID string, subArr []model.UdmSubUser)
} }
n := len(subArr) n := len(subArr)
batchSize := 5000 batchSize := 2000
for i := 0; i < n; i += batchSize { for i := 0; i < n; i += batchSize {
end := i + batchSize end := i + batchSize
if end > n { if end > n {
@@ -225,7 +225,7 @@ func (r *RepoUdmSubUser) Insert(subUser model.UdmSubUser) int64 {
func (r *RepoUdmSubUser) Inserts(subUser []model.UdmSubUser) int64 { func (r *RepoUdmSubUser) Inserts(subUser []model.UdmSubUser) int64 {
var num int64 var num int64
n := len(subUser) n := len(subUser)
batchSize := 5000 batchSize := 2000
for i := 0; i < n; i += batchSize { for i := 0; i < n; i += batchSize {
end := i + batchSize end := i + batchSize
if end > n { if end > n {