Method BatchAddInternalUsers

api/service/user_service.go:81–229

BatchAddInternalUsers batch add internal users

(eid int64, users []InternalUserInfo)

// BatchAddInternalUsers batch add internal users
func (s *UserService) BatchAddInternalUsers(eid int64, users []InternalUserInfo) (*BatchAddInternalUserResult, error) {
	// Begin transaction
	// 去重收集需要在提交后关联的平台账号（仅手机号）
	accountsToLink := make(map[string]struct{})

	tx := model.DB.Begin()
	if tx.Error != nil {
		return nil, tx.Error
	}

	result := &BatchAddInternalUserResult{
		Success: []BatchAddUserResult{},
		Failed:  []BatchAddUserResult{},
	}

	// Process each user
	for _, userInfo := range users {
		username := userInfo.Username

		// Validate username format
		isEmail := helper.IsValidEmail(username)
		isMobile := helper.IsValidPhone(username)

		if !isEmail && !isMobile {
			result.Failed = append(result.Failed, BatchAddUserResult{
				Username: username,
				Message:  "invalid username",
			})
			continue
		}

		// Create user object
		user := model.User{
			Username: username,
			Nickname: userInfo.Nickname,
			Password: userInfo.Password,
			Eid:      eid,
			GroupId:  0,
			Type:     model.UserTypeInternal,
			Role:     model.RoleCommonUser,
		}

		// Set email or mobile
		if isMobile {
			user.Mobile = username
		}
		if isEmail {
			user.Email = username
		}

		// Validate user struct
		if err := common.Validate.Struct(&user); err != nil {
			result.Failed = append(result.Failed, BatchAddUserResult{
				Username: username,
				Message:  err.Error(),
			})
			continue
		}