From 34e609be9c8b78ff8840d93eeda40d9de39a58fa Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Wed, 1 Nov 2023 15:20:52 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20UDM=E7=AD=BE=E7=BA=A6=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=AD=98=E5=82=A8=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 database/upgrade/zupgrade.sql                | 4 ++++
 database/upgvue3/zupgrade.sql                | 4 ++++
 features/udm_user/repo/repo_udm_auth_user.go | 1 +
 features/udm_user/repo/repo_udm_sub_user.go  | 1 +
 4 files changed, 10 insertions(+)

diff --git a/database/upgrade/zupgrade.sql b/database/upgrade/zupgrade.sql
index dd45fba1..76628d04 100644
--- a/database/upgrade/zupgrade.sql
+++ b/database/upgrade/zupgrade.sql
@@ -98,3 +98,7 @@ DELETE FROM ne_license WHERE file_name IS NULL;
 ALTER TABLE `omc_db`.`trace_data` 
 ADD COLUMN IF NOT EXISTS `length` int NULL AFTER `msg_direct`;
 
+-- UDM签约存储长度不足
+ALTER TABLE `omc_db`.`u_sub_user` 
+MODIFY COLUMN `sm_data` varchar(1500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'smData' AFTER `cn`,
+MODIFY COLUMN `eps_dat` varchar(1500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Eps' AFTER `smf_sel`;
diff --git a/database/upgvue3/zupgrade.sql b/database/upgvue3/zupgrade.sql
index dd45fba1..76628d04 100644
--- a/database/upgvue3/zupgrade.sql
+++ b/database/upgvue3/zupgrade.sql
@@ -98,3 +98,7 @@ DELETE FROM ne_license WHERE file_name IS NULL;
 ALTER TABLE `omc_db`.`trace_data` 
 ADD COLUMN IF NOT EXISTS `length` int NULL AFTER `msg_direct`;
 
+-- UDM签约存储长度不足
+ALTER TABLE `omc_db`.`u_sub_user` 
+MODIFY COLUMN `sm_data` varchar(1500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'smData' AFTER `cn`,
+MODIFY COLUMN `eps_dat` varchar(1500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Eps' AFTER `smf_sel`;
diff --git a/features/udm_user/repo/repo_udm_auth_user.go b/features/udm_user/repo/repo_udm_auth_user.go
index 1f3bf672..1f0c63fa 100644
--- a/features/udm_user/repo/repo_udm_auth_user.go
+++ b/features/udm_user/repo/repo_udm_auth_user.go
@@ -177,6 +177,7 @@ func (r *RepoUdmAuthUser) ClearAndInsert(neID string, authArr []model.UdmAuthUse
 		// 调用 InsertMulti 函数将批量数据插入数据库
 		results, err := datasource.DefaultDB().Table("u_auth_user").InsertMulti(batch)
 		if err != nil {
+			log.Errorf("InsertMulti err => %v", err)
 			continue
 		}
 		num += results
diff --git a/features/udm_user/repo/repo_udm_sub_user.go b/features/udm_user/repo/repo_udm_sub_user.go
index 202a53a9..d7f5ead9 100644
--- a/features/udm_user/repo/repo_udm_sub_user.go
+++ b/features/udm_user/repo/repo_udm_sub_user.go
@@ -196,6 +196,7 @@ func (r *RepoUdmSubUser) ClearAndInsert(neID string, subArr []model.UdmSubUser)
 		// 调用 InsertMulti 函数将批量数据插入数据库
 		results, err := datasource.DefaultDB().Table("u_sub_user").InsertMulti(batch)
 		if err != nil {
+			log.Errorf("InsertMulti err => %v", err)
 			continue
 		}
 		num += results