package service

import (
	"strings"

	"kefu-cloud/server/internal/model"
	"kefu-cloud/server/internal/ws"
)

// UniqueUint 去重并过滤零值。
func UniqueUint(ids []uint) []uint {
	seen := make(map[uint]struct{}, len(ids))
	out := make([]uint, 0, len(ids))
	for _, id := range ids {
		if id == 0 {
			continue
		}
		if _, ok := seen[id]; ok {
			continue
		}
		seen[id] = struct{}{}
		out = append(out, id)
	}
	return out
}

// UserDisplayName 坐席展示名（昵称优先，其次用户名）。
func UserDisplayName(userID uint) string {
	var user model.User
	if err := model.DB.Select("id", "nickname", "username").First(&user, userID).Error; err != nil {
		return "未知坐席"
	}
	if strings.TrimSpace(user.Nickname) != "" {
		return user.Nickname
	}
	if strings.TrimSpace(user.Username) != "" {
		return user.Username
	}
	return "未知坐席"
}

// BroadcastSessionMessage 会话新消息广播（坐席 + 访客）。
func BroadcastSessionMessage(session *model.Session, message model.Message) {
	payload, err := ws.NewEvent("message", session.ID, message)
	if err == nil {
		ws.DefaultHub.BroadcastToSession(session.TenantID, session.ID, session.AgentID, payload)
	}
}

// BroadcastSessionUpdate 会话状态变更广播：坐席列表需要刷新；访客也必须收到
// ended/active，才能弹出评价或更新接待状态。
func BroadcastSessionUpdate(session *model.Session) {
	payload, err := ws.NewEvent("session_updated", session.ID, map[string]interface{}{"status": session.Status})
	if err != nil {
		return
	}
	ws.DefaultHub.BroadcastToTenantStaff(session.TenantID, payload)
	ws.DefaultHub.BroadcastToVisitor(session.TenantID, session.ID, payload)
}