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

fix: UDM鉴权用户跳过空Imsi插入

Browse Source
This commit is contained in:
TsMask
2023-11-08 19:42:39 +08:00
parent fe0c7334ef
commit 7cc444f4ba
2 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
features/udm_user/service/service_udm_auth_user.go
View File

@@ -99,6 +99,10 @@ func (r *ServiceUdmAuthUser) InsertCSV(neID string, data []map[string]string) in
if s, ok := v["opc"]; ok { if s, ok := v["opc"]; ok {
authUser.Opc = s authUser.Opc = s
} }
if authUser.Imsi == "" {
continue
}
arr = append(arr, authUser) arr = append(arr, authUser)
} }
return r.repoAuthUser.Inserts(arr) return r.repoAuthUser.Inserts(arr)
@@ -121,6 +125,10 @@ func (r *ServiceUdmAuthUser) InsertTxt(neID string, data [][]string) int64 {
if len(v) == 5 { if len(v) == 5 {
authUser.Opc = v[4] authUser.Opc = v[4]
} }
if authUser.Imsi == "" {
continue
}
arr = append(arr, authUser) arr = append(arr, authUser)
} }

8
features/udm_user/service/service_udm_sub_user.go
View File

@@ -149,6 +149,10 @@ func (r *ServiceUdmSubUser) InsertCSV(neID string, data []map[string]string) int
subUser.StaticIp = arr[8] subUser.StaticIp = arr[8]
} }
} }
if subUser.Imsi == "" {
continue
}
arr = append(arr, subUser) arr = append(arr, subUser)
} }
return r.repoSunUser.Inserts(arr) return r.repoSunUser.Inserts(arr)
@@ -184,6 +188,10 @@ func (r *ServiceUdmSubUser) InsertTxt(neID string, data [][]string) int64 {
subUser.StaticIp = v[18] subUser.StaticIp = v[18]
subUser.EpsDat = strings.Join(v[10:], ",") subUser.EpsDat = strings.Join(v[10:], ",")
} }
if subUser.Imsi == "" {
continue
}
arr = append(arr, subUser) arr = append(arr, subUser)
} }
return r.repoSunUser.Inserts(arr) return r.repoSunUser.Inserts(arr)