uniugm/admin/apps/game/domain/projects/smdl/account.go

package smdl

import (
	"admin/apps/game/domain/entity"
	"admin/apps/game/domain/projects/smdl/internal"
	"admin/apps/game/model"
	"admin/apps/game/model/dto"
	"admin/internal/errcode"
	"admin/lib/httpclient"
	"admin/lib/utils"
	"math"
	"net/url"
	"strconv"
)

type AccountHook struct {
}

func (hook *AccountHook) List(projectInfo *entity.Project, resource string, params *dto.CommonListReq,
	fields []*dto.CommonDtoFieldDesc, totalCount int, rows []dto.CommonDtoValues) (
	int, []*dto.CommonDtoFieldDesc, []dto.CommonDtoValues, error) {
	alisrvAddr := projectInfo.GetApiAddr()
	if alisrvAddr == "" {
		return 0, nil, nil, errcode.New(errcode.ServerError, "项目%v没有配置api服务器地址", projectInfo.Po.Name)
	}

	serverList, err := internal.GetRemoteServerInfoList(alisrvAddr)
	if err != nil {
		return 0, nil, nil, err
	}

	totalCount, reqPageServerList, err := getPaginationServerReqList(projectInfo, serverList, params, func(info *internal.ServerInfo) int { return info.TotalAccountCount })
	if err != nil {
		return 0, nil, nil, err
	}

	// {"data":[{"account":"20250425cs01","roleList":[{"account":"20250425cs01","createAt":1745567667525,"latestLoginAt":1745567714234,"roleId":"20001000001","serverId":"20001"}],"serverId":"20001"}],
	// "state":{"code":2000000,"msg":"OK"}}
	type RspData struct {
		State struct {
			Code int    `json:"code"`
			Msg  string `json:"msg"`
		} `json:"state"`

		Data []struct {
			Account  string  `json:"account"`
			ServerId string  `json:"serverId"`
			RoleList []*Role `json:"roleList"`
		} `json:"data"`
	}

	for _, reqServer := range reqPageServerList {
		body := &url.Values{}
		body.Add("serverid", reqServer.RawInfo.ServerId)
		body.Add("offset", strconv.Itoa(reqServer.Offset))
		body.Add("count", strconv.Itoa(reqServer.Count))
		body.Add("userlist", "true")

		rsp := &RspData{}
		err := httpclient.Request(alisrvAddr+"/rolelist", "get", body, rsp)
		if err != nil {
			return 0, nil, nil, err
		}

		for _, user := range rsp.Data {

			userPo := &model.Account{
				Account:      user.Account,
				ServerConfId: user.ServerId,
			}
			latestLoginTime := int64(0)
			earliestCreateTime := int64(math.MaxInt64)
			for _, v := range user.RoleList {
				userPo.RoleIds = append(userPo.RoleIds, v.RoleId)
				if latestLoginTime < v.LatestLoginTime {
					latestLoginTime = v.LatestLoginTime
				}
				if earliestCreateTime > v.CreateTime {
					earliestCreateTime = v.CreateTime
				}
			}
			userPo.LatestLoginTime = utils.ParseUnixTimestamp2LocalTime(latestLoginTime)
			userPo.CreateTime = utils.ParseUnixTimestamp2LocalTime(earliestCreateTime)
			et := (&entity.CommonResource{}).FromPo(userPo)
			rows = append(rows, et.ToCommonDto())
		}
	}

	return totalCount, fields, rows, nil
}

func getPaginationServerReqList(projectInfo *entity.Project, serverInfoList internal.ServerInfoList,
	params *dto.CommonListReq, queryCountField func(*internal.ServerInfo) int) (
	totalCount int, reqServerInfoList []*internal.PageServerCountInfo, err error) {

	pageNo := params.PageNo
	pageLen := params.PageLen
	whereConditions := params.ParsedWhereConditions

	reqServerList := make([]*internal.PageServerCountInfo, 0)

	if len(whereConditions.Conditions) > 1 {
		// 第一个是ProjectId条件
		if whereConditions.Conditions[1].Key != "ServerConfId" { // 账号、角色的条件检索只支持区服
			return 0, nil, errcode.New(errcode.ParamsInvalid, "where condition invalid:%+v", whereConditions.Conditions[0])
		}
		// 前端指定了查询某个区服的数据
		specServerId := whereConditions.Conditions[1].Value1.(string)
		for _, v := range serverInfoList {
			if v.ServerId == specServerId {
				offset := (pageNo - 1) * pageLen
				limit := pageLen
				totalCount = queryCountField(v)
				reqServerList = append(reqServerList, &internal.PageServerCountInfo{
					RawInfo: v,
					Offset:  offset,
					Count:   limit,
				})
				break
			}
		}
	} else {
		// 根据分页参数计算需要几个区服数据参与查询
		totalCountTmp, tidyPageInfoList := serverInfoList.TidyToPageList(pageLen, queryCountField)
		if len(tidyPageInfoList) == 0 {
			// 没有找到分页信息，返回空表
			return 0, nil, nil
		}
		totalCount = totalCountTmp
		for i, tidyPageInfo := range tidyPageInfoList {
			if i+1 == pageNo {
				reqServerList = append(reqServerList, tidyPageInfo.ServerList...)
				break
			}
		}
	}

	return totalCount, reqServerList, nil
}