From 7cc444f4ba54638ec739ed00fd4dafd24f5a8fc6 Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Wed, 8 Nov 2023 19:42:39 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20UDM=E9=89=B4=E6=9D=83=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E8=B7=B3=E8=BF=87=E7=A9=BAImsi=E6=8F=92=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 features/udm_user/service/service_udm_auth_user.go | 8 ++++++++
 features/udm_user/service/service_udm_sub_user.go  | 8 ++++++++
 2 files changed, 16 insertions(+)

diff --git a/features/udm_user/service/service_udm_auth_user.go b/features/udm_user/service/service_udm_auth_user.go
index 0a90db94..5cd1e9cd 100644
--- a/features/udm_user/service/service_udm_auth_user.go
+++ b/features/udm_user/service/service_udm_auth_user.go
@@ -99,6 +99,10 @@ func (r *ServiceUdmAuthUser) InsertCSV(neID string, data []map[string]string) in
 		if s, ok := v["opc"]; ok {
 			authUser.Opc = s
 		}
+
+		if authUser.Imsi == "" {
+			continue
+		}
 		arr = append(arr, authUser)
 	}
 	return r.repoAuthUser.Inserts(arr)
@@ -121,6 +125,10 @@ func (r *ServiceUdmAuthUser) InsertTxt(neID string, data [][]string) int64 {
 		if len(v) == 5 {
 			authUser.Opc = v[4]
 		}
+
+		if authUser.Imsi == "" {
+			continue
+		}
 		arr = append(arr, authUser)
 	}
 
diff --git a/features/udm_user/service/service_udm_sub_user.go b/features/udm_user/service/service_udm_sub_user.go
index 3bd72ca2..f5bb673d 100644
--- a/features/udm_user/service/service_udm_sub_user.go
+++ b/features/udm_user/service/service_udm_sub_user.go
@@ -149,6 +149,10 @@ func (r *ServiceUdmSubUser) InsertCSV(neID string, data []map[string]string) int
 				subUser.StaticIp = arr[8]
 			}
 		}
+
+		if subUser.Imsi == "" {
+			continue
+		}
 		arr = append(arr, subUser)
 	}
 	return r.repoSunUser.Inserts(arr)
@@ -184,6 +188,10 @@ func (r *ServiceUdmSubUser) InsertTxt(neID string, data [][]string) int64 {
 			subUser.StaticIp = v[18]
 			subUser.EpsDat = strings.Join(v[10:], ",")
 		}
+
+		if subUser.Imsi == "" {
+			continue
+		}
 		arr = append(arr, subUser)
 	}
 	return r.repoSunUser.Inserts(arr)