fix: update admin flows and review report

internal/service/user_service.go

@@ -211,3 +211,163 @@ func (s *UserService) BatchDelete(ctx context.Context, req *BatchDeleteRequest)
 	err := s.userRepo.BatchDelete(ctx, req.IDs)
 	return int64(len(req.IDs)), err
 }
+
+// GetUserRoles 获取用户的所有角色
+func (s *UserService) GetUserRoles(ctx context.Context, userID int64) ([]*domain.Role, error) {
+	// 检查用户是否存在
+	if _, err := s.userRepo.GetByID(ctx, userID); err != nil {
+		return nil, err
+	}
+
+	// 获取用户角色关联
+	userRoles, err := s.userRoleRepo.GetByUserID(ctx, userID)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(userRoles) == 0 {
+		return []*domain.Role{}, nil
+	}
+
+	// 获取角色ID列表
+	roleIDs := make([]int64, len(userRoles))
+	for i, ur := range userRoles {
+		roleIDs[i] = ur.RoleID
+	}
+
+	// 批量获取角色详情
+	var roles []*domain.Role
+	for _, roleID := range roleIDs {
+		role, err := s.roleRepo.GetByID(ctx, roleID)
+		if err != nil {
+			continue // 跳过不存在的角色
+		}
+		roles = append(roles, role)
+	}
+
+	return roles, nil
+}
+
+// AssignRoles 分配用户角色
+func (s *UserService) AssignRoles(ctx context.Context, userID int64, roleIDs []int64) error {
+	// 检查用户是否存在
+	if _, err := s.userRepo.GetByID(ctx, userID); err != nil {
+		return err
+	}
+
+	// 验证所有角色存在
+	for _, roleID := range roleIDs {
+		if _, err := s.roleRepo.GetByID(ctx, roleID); err != nil {
+			return fmt.Errorf("角色 %d 不存在", roleID)
+		}
+	}
+
+	// 删除用户现有角色
+	if err := s.userRoleRepo.DeleteByUserID(ctx, userID); err != nil {
+		return err
+	}
+
+	// 创建新的用户角色关联
+	var userRoles []*domain.UserRole
+	for _, roleID := range roleIDs {
+		userRoles = append(userRoles, &domain.UserRole{
+			UserID: userID,
+			RoleID: roleID,
+		})
+	}
+
+	return s.userRoleRepo.BatchCreate(ctx, userRoles)
+}
+
+// AdminRoleID is the ID of the admin role
+const AdminRoleID = 1
+
+// ListAdmins 获取所有管理员
+func (s *UserService) ListAdmins(ctx context.Context) ([]*domain.User, error) {
+	// 获取管理员角色ID列表
+	adminUserIDs, err := s.userRoleRepo.GetUserIDByRoleID(ctx, AdminRoleID)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(adminUserIDs) == 0 {
+		return []*domain.User{}, nil
+	}
+
+	// 获取所有管理员用户
+	var admins []*domain.User
+	for _, adminID := range adminUserIDs {
+		user, err := s.userRepo.GetByID(ctx, adminID)
+		if err != nil {
+			continue // 跳过不存在的用户
+		}
+		admins = append(admins, user)
+	}
+
+	return admins, nil
+}
+
+// CreateAdmin 创建管理员
+func (s *UserService) CreateAdmin(ctx context.Context, req *CreateAdminRequest) (*domain.User, error) {
+	// 检查用户名是否已存在
+	existingUser, err := s.userRepo.GetByUsername(ctx, req.Username)
+	if err == nil && existingUser != nil {
+		return nil, errors.New("用户名已存在")
+	}
+
+	// 创建用户
+	hashedPassword, err := auth.HashPassword(req.Password)
+	if err != nil {
+		return nil, errors.New("密码哈希失败")
+	}
+
+	user := &domain.User{
+		Username: req.Username,
+		Password: hashedPassword,
+		Status:   domain.UserStatusActive,
+	}
+
+	if req.Email != "" {
+		user.Email = &req.Email
+	}
+	if req.Nickname != "" {
+		user.Nickname = req.Nickname
+	}
+
+	if err := s.userRepo.Create(ctx, user); err != nil {
+		return nil, err
+	}
+
+	// 分配管理员角色
+	userRole := &domain.UserRole{
+		UserID: user.ID,
+		RoleID: AdminRoleID,
+	}
+	if err := s.userRoleRepo.Create(ctx, userRole); err != nil {
+		return nil, err
+	}
+
+	return user, nil
+}
+
+// DeleteAdmin 删除管理员（移除管理员角色）
+func (s *UserService) DeleteAdmin(ctx context.Context, userID int64) error {
+	// 检查用户是否存在
+	if _, err := s.userRepo.GetByID(ctx, userID); err != nil {
+		return err
+	}
+
+	// 不能删除自己
+	// 注意：这里需要从handler传入当前用户ID进行校验
+
+	// 删除用户的管理员角色
+	return s.userRoleRepo.DeleteByUserAndRole(ctx, userID, AdminRoleID)
+}
+
+// CreateAdminRequest 创建管理员请求
+type CreateAdminRequest struct {
+	Username string `json:"username" binding:"required"`
+	Password string `json:"password" binding:"required"`
+	Email   string `json:"email"`
+	Nickname string `json:"nickname"`
+}