package controller

import (
	"encoding/json"
	"sort"
	"strings"

	"be.ems/src/framework/constants/cachekey"
	"be.ems/src/framework/i18n"
	"be.ems/src/framework/redis"
	"be.ems/src/framework/utils/ctx"
	"be.ems/src/framework/vo"
	"be.ems/src/framework/vo/result"
	"be.ems/src/modules/monitor/model"
	"be.ems/src/modules/monitor/service"

	"github.com/gin-gonic/gin"
)

// 实例化控制层 SysUserOnlineController 结构体
var NewSysUserOnline = &SysUserOnlineController{
	sysUserOnlineService: service.NewSysUserOnline,
}

// 在线用户监控
//
// PATH /monitor/online
type SysUserOnlineController struct {
	sysUserOnlineService *service.SysUserOnline // 在线用户服务
}

// 在线用户列表
//
// GET /list
//
//	@Tags			monitor/online
//	@Accept			json
//	@Produce		json
//	@Success		200	{object}	object	"Response Results"
//	@Security		ApiKeyAuth
//	@Summary		System Online User List
//	@Description	System Online User List
//	@Router			/monitor/online/list [get]
func (s *SysUserOnlineController) List(c *gin.Context) {
	language := ctx.AcceptLanguage(c)
	ipaddr := c.Query("ipaddr")
	userName := c.Query("userName")

	// 获取所有在线用户key
	keys, _ := redis.GetKeys("", cachekey.LOGIN_TOKEN_KEY+"*")

	// 分批获取
	arr := make([]string, 0)
	for i := 0; i < len(keys); i += 20 {
		end := i + 20
		if end > len(keys) {
			end = len(keys)
		}
		chunk := keys[i:end]
		values, _ := redis.GetBatch("", chunk)
		for _, v := range values {
			arr = append(arr, v.(string))
		}
	}

	// 遍历字符串信息解析组合可用对象
	userOnlines := make([]model.SysUserOnline, 0)
	for _, str := range arr {
		if str == "" {
			continue
		}

		var loginUser vo.LoginUser
		err := json.Unmarshal([]byte(str), &loginUser)
		if err != nil {
			continue
		}

		onlineUser := s.sysUserOnlineService.LoginUserToUserOnline(loginUser)
		if onlineUser.TokenID != "" {
			onlineUser.LoginLocation = i18n.TKey(language, onlineUser.LoginLocation)
			userOnlines = append(userOnlines, onlineUser)
		}
	}

	// 根据查询条件过滤
	filteredUserOnlines := make([]model.SysUserOnline, 0)
	if ipaddr != "" && userName != "" {
		for _, o := range userOnlines {
			if strings.Contains(o.IPAddr, ipaddr) && strings.Contains(o.UserName, userName) {
				filteredUserOnlines = append(filteredUserOnlines, o)
			}
		}
	} else if ipaddr != "" {
		for _, o := range userOnlines {
			if strings.Contains(o.IPAddr, ipaddr) {
				filteredUserOnlines = append(filteredUserOnlines, o)
			}
		}
	} else if userName != "" {
		for _, o := range userOnlines {
			if strings.Contains(o.UserName, userName) {
				filteredUserOnlines = append(filteredUserOnlines, o)
			}
		}
	} else {
		filteredUserOnlines = userOnlines
	}

	// 按登录时间排序
	sort.Slice(filteredUserOnlines, func(i, j int) bool {
		return filteredUserOnlines[j].LoginTime > filteredUserOnlines[i].LoginTime
	})

	c.JSON(200, result.Ok(map[string]any{
		"total": len(filteredUserOnlines),
		"rows":  filteredUserOnlines,
	}))
}

// 在线用户强制退出
//
// DELETE /:tokenId
func (s *SysUserOnlineController) ForceLogout(c *gin.Context) {
	language := ctx.AcceptLanguage(c)
	tokenId := c.Param("tokenId")
	if tokenId == "" || tokenId == "*" {
		c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
		return
	}

	// 删除token
	ok, _ := redis.Del("", cachekey.LOGIN_TOKEN_KEY+tokenId)
	if ok {
		c.JSON(200, result.Ok(nil))
		return
	}
	c.JSON(200, result.Err(nil))
}