feat: UDM数据批量导入拼减少防止溢出限制

src/modules/network_data/repository/udm_sub.go

@@ -19,7 +19,7 @@ var NewUDMSub = &UDMSubUser{
 	s.id, s.imsi, s.msisdn, s.ne_id, 
 	s.am_dat, s.ambr, s.nssai, s.rat, s.arfb, s.sar, s.cn_type, s.rfsp_index, s.reg_timer, s.ue_usage_type, s.active_time, s.mico, s.odb_ps, s.group_id, 
 	s.eps_dat, s.eps_flag, s.eps_odb, s.hplmn_odb, s.ard, s.epstpl, s.context_id, s.apn_mum, s.apn_context, s.static_ip, 
-	s.sm_data, s.smf_sel, s.cag,
+	s.sm_data, s.smf_sel, s.cag, s.create_time, s.created_at, 
 	t.tenant_id, t.tenant_name
 	from u_sub_user s
 	left join sys_tenant t on t.tenant_id = s.tenant_id and t.status = 1`,
@@ -60,6 +60,8 @@ var NewUDMSub = &UDMSubUser{
 		"smf_sel": "SmfSel",
 		"cag":     "Cag",
 
+		"create_time": "CreateTime",
+		"created_at":  "CreatedAt",
 		"tenant_id":   "TenantID",
 		"tenant_name": "TenantName", // Tenant name for multi-tenancy
 	},
@@ -262,7 +264,7 @@ func (r *UDMSubUser) Inserts(uArr []model.UDMSubUser) int64 {
 	// multi-tenancy
 	r.SetTenantID(&uArr)
 
-	tx := datasource.DefaultDB().CreateInBatches(uArr, 2000)
+	tx := datasource.DefaultDB().CreateInBatches(uArr, 1000)
 	if err := tx.Error; err != nil {
 		logger.Errorf("CreateInBatches err => %v", err)
 	}