فهرست منبع

Revert "update 新增获取玩家中奖记录(默认查询最近三天)接口"

This reverts commit 0a1f8251
zhengtao 8 ماه پیش
والد
کامیت
2f76782347

+ 0 - 25
game/game_cluster/nodes/webadmin/controller/player.go

@@ -64,28 +64,3 @@ func (w *PlayerManage) GetPlayerInfo(ctx *gin.Context) {
 		"msg":  "success",
 	})
 }
-
-func (w *PlayerManage) GetRewardList(ctx *gin.Context) {
-	req := entity.RewardListReq{}
-	if err := ctx.ShouldBindJSON(&req); err != nil {
-		ctx.JSON(200, gin.H{
-			"code": 400,
-			"msg":  err.Error(),
-		})
-		return
-	}
-	resp, total, err := w.sev.RewardList(ctx, req)
-	if err != nil {
-		ctx.JSON(200, gin.H{
-			"code": 400,
-			"msg":  err.Error(),
-		})
-		return
-	}
-	ctx.JSON(200, gin.H{
-		"code":  200,
-		"data":  resp,
-		"msg":   "success",
-		"total": total,
-	})
-}

+ 0 - 20
game/game_cluster/nodes/webadmin/entity/admin.go

@@ -128,23 +128,3 @@ type PlayerInfoResp struct {
 	DrawShareTime  int64  `json:"drawShareTime" bson:"drawShareTime"`   // 领取时间
 	FirstReward    int    `json:"firstReward" bson:"firstReward"`       // 是否已领取首次登陆奖励
 }
-
-type RewardListReq struct {
-	Page      int    `json:"page" binding:"required"`
-	Size      int    `json:"size" binding:"required"`
-	UserName  string `json:"userName"`   // 用户名
-	StartTime int64  `json:"start_time"` // 开始时间
-	EndTime   int64  `json:"end_time"`   // 结束时间
-}
-
-type RewardListResp struct {
-	UserName   string        `json:"userName" bson:"userName"` // 用户名
-	AddReward  []*ItemReward `json:"AddReward" bson:"addReward"`
-	CreateTime int64         `json:"createTime" bson:"createTime"`
-}
-
-type ItemReward struct {
-	ItemID   int    // itemID:道具ID
-	Amount   int    // amount:数量
-	ItemName string // itemName:道具名称
-}

+ 3 - 41
game/game_cluster/nodes/webadmin/router/router.go

@@ -37,50 +37,20 @@ func (c *Controller) SetRouter() {
 }
 
 func (c *Controller) InitApiRouter(u *gin.RouterGroup) {
-	u.Use(Auth(c.App.Settings()))
-
-	// 综合统计
-	u.POST("/statistics/overview", controller.NewSynthesis().Overview)
-
-	// 活动统计
-	u.POST("/statistics/activity", controller.NewSynthesis().Activity)
-
-	// 用户统计
-	u.POST("/statistics/user/list", controller.NewSynthesis().UserList)
+	u.Use(Auth())
 	u.POST("/user/log/daily", controller.NewSynthesis().FindUserLogDaily)
-
-	// 转盘统计
-	u.POST("/statistics/turntable", controller.NewSynthesis().Turntable)
-
-	// 资产统计
-	u.POST("/statistics/assets", controller.NewSynthesis().Assets)
-
-	// 邀请统计
-	u.POST("/statistics/invite", controller.NewSynthesis().Invite)
-
-	// 后台操作记录
-	u.POST("/user/log", controller.NewSynthesis().Records)
-
-	// 活跃统计
 	u.POST("/user/retention", controller.NewSynthesis().FindUserRetention)
 	u.POST("/user/country", controller.NewSynthesis().FindUserCountryCount)
-	u.POST("/user/level", controller.NewSynthesis().FindUserLevel)
-
-	// 提现统计
 	u.POST("/user/withdrawal", controller.NewSynthesis().FindWithdrawal)
-	u.POST("/user/withdrawal/export", controller.NewSynthesis().WithdrawalExport)
 	u.POST("/user/withdrawal/status", controller.NewSynthesis().WithdrawalStatus)
 	u.POST("/user/withdrawal/status_batch", controller.NewSynthesis().WithdrawalStatusBatch)
-
-	// 账号管理
+	u.POST("/user/level", controller.NewSynthesis().FindUserLevel)
 	u.POST("/user/changePassword", controller.NewAdmin().ChangePassword)
 	u.POST("/user/add", controller.NewAdmin().Add)
 	u.POST("/user/del", controller.NewAdmin().Del)
 	u.POST("/user/find", controller.NewAdmin().FindAll)
 	u.POST("/user/update", controller.NewAdmin().UpdateStatus)
-	u.POST("/user/serverStatus", controller.NewAdmin().GetServerStatus)
-
-	// 账号角色管理
+	u.POST("/user/server_status", controller.NewAdmin().GetServerStatus)
 	u.POST("/role/add", controller.NewRole().Add)
 	u.POST("/role/update", controller.NewRole().Update)
 	u.POST("/role/del", controller.NewRole().Del)
@@ -96,20 +66,12 @@ func (c *Controller) InitApiRouter(u *gin.RouterGroup) {
 	u.POST("/role/admin_unbind_role", controller.NewRole().AdminUnBindRole)
 	u.POST("/role/admin_bind_role", controller.NewRole().AdminBindRole)
 	u.POST("/role/admin_role_info", controller.NewRole().GetAdminRole)
-
-	// IP白名单
 	u.POST("/whitelist/add", controller.NewWhitelist().AddWhitelist)
 	u.POST("/whitelist/remove", controller.NewWhitelist().RemoveWhitelist)
 	u.POST("/whitelist/list", controller.NewWhitelist().GetWhitelist)
 	u.POST("/player/list", controller.NewPlayerManage().GetPlayerlist)
 	u.POST("/player/info", controller.NewPlayerManage().GetPlayerInfo)
 	u.POST("/player/rewardList", controller.NewPlayerManage().GetRewardList)
-
-	// 风控
-	u.POST("/riskControl/multipleFingerprintInIp", controller.NewRiskControl().MultipleFingerprintInIp)
-	u.POST("/riskControl/multipleAddressInTg", controller.NewRiskControl().MultipleAddressInTg)
-	u.POST("/riskControl/multipleTgInAddress", controller.NewRiskControl().MultipleTgInAddress)
-	u.POST("/riskControl/multipleTgInIp", controller.NewRiskControl().MultipleTgInIp)
 }
 
 // func (c *Controller) InitMdb() {

+ 0 - 84
game/game_cluster/nodes/webadmin/service/playerMange.go

@@ -3,11 +3,8 @@ package service
 import (
 	"context"
 	"log"
-	"time"
 
-	mhayaTime "github.com/mhaya/extend/time"
 	"github.com/mhaya/game/game_cluster/internal/constant"
-	"github.com/mhaya/game/game_cluster/internal/data"
 	"github.com/mhaya/game/game_cluster/internal/mdb"
 	"github.com/mhaya/game/game_cluster/internal/mdb/models"
 	"github.com/mhaya/game/game_cluster/nodes/webadmin/entity"
@@ -154,84 +151,3 @@ func (a *PlayerManage) PlayerInfo(ctx context.Context, req entity.PlayerInfoReq)
 		FirstReward:    player.FirstReward,
 	}, nil
 }
-
-// 获取玩家中奖记录(默认查询最近三天)
-func (a *PlayerManage) RewardList(ctx context.Context, req entity.RewardListReq) ([]*entity.RewardListResp, int64, error) {
-	page := req.Page
-	// 验证参数
-	if page <= 0 {
-		page = 1
-	}
-	pageSize := req.Size
-	if pageSize <= 0 {
-		pageSize = 10
-	}
-
-	// 构建查询条件
-	filter := bson.M{}
-	if req.UserName != "" {
-		filter["userName"] = bson.M{"$regex": escapeRegex(req.UserName), "$options": "i"}
-	}
-
-	startTime := mhayaTime.Now().StartOfDay().Unix()
-	endTime := mhayaTime.Now().EndOfDay().Add(3 * 24 * time.Hour).Unix()
-	if req.StartTime > 0 && req.StartTime < req.EndTime {
-		startTime = req.StartTime
-	}
-
-	if req.EndTime > 0 && req.EndTime <= endTime {
-		endTime = req.EndTime
-	}
-
-	filter["createTime"] = bson.M{
-		"$gte": startTime,
-		"$lte": endTime,
-	}
-
-	// 设置分页选项
-	skip := (page - 1) * pageSize
-	limit := pageSize
-	findOptions := options.Find().SetSkip(int64(skip)).SetLimit(int64(limit))
-
-	collection := mdb.MDB.Collection(constant.CNamePlayerReward)
-	// 获取总数total
-	count, err := collection.CountDocuments(ctx, filter)
-	if err != nil {
-		return nil, 0, err
-	}
-
-	// 执行查询
-	cursor, err := collection.Find(ctx, filter, findOptions)
-	if err != nil {
-		return nil, 0, err
-	}
-	defer func() {
-		if closeErr := cursor.Close(ctx); closeErr != nil {
-			log.Printf("Error closing cursor: %v", closeErr)
-		}
-	}()
-
-	// 解析结果
-	results := make([]*entity.RewardListResp, 0)
-	for cursor.Next(ctx) {
-		var result entity.RewardListResp
-		if err := cursor.Decode(&result); err != nil {
-			return nil, 0, err
-		}
-		results = append(results, &result)
-	}
-	if err := cursor.Err(); err != nil {
-		return nil, 0, err
-	}
-
-	for _, result := range results {
-		for _, v := range result.AddReward {
-			cfg, exist := data.ItemConfig.Get(v.ItemID)
-			if exist {
-				v.ItemName = cfg.ItemKey
-			}
-		}
-	}
-
-	return results, count, nil
-}