90b62b44e4
All checks were successful
ci/woodpecker/push/my-first-workflow Pipeline was successful
refactor(common): 统一Redis连接方式并优化代码结构
- 将 g.Redis("cool").Conn(ctx) 统一改为 Redis.Conn(ctx) 的调用方式
- 在coolconfig中添加ServerList.GetID()方法用于生成服务器唯一标识
- 引入gconv包用于类型转换操作
feat(rpc): 完善ListenFight函数实现集群消息监听
- 新增ListenFight函数，完全对齐ListenFunc
32 lines
948 B
Go
32 lines
948 B
Go
package controller
|
|
|
|
import (
|
|
"blazing/common/socket/errorcode"
|
|
"blazing/cool"
|
|
"blazing/logic/service/common"
|
|
"blazing/logic/service/fight"
|
|
"blazing/logic/service/fight/info"
|
|
"blazing/logic/service/player"
|
|
"context"
|
|
)
|
|
|
|
// 表示"宠物王加入"的入站消息数据
|
|
type PetTOPLEVELnboundInfo struct {
|
|
Head common.TomeeHeader `cmd:"2458" struc:"skip"`
|
|
Mode uint32 //巅峰赛对战模式 19 = 普通模式单精灵 20 = 普通模式多精灵
|
|
|
|
}
|
|
|
|
func (h Controller) JoINtop(data *PetTOPLEVELnboundInfo, c *player.Player) (result *fight.NullOutboundInfo, err errorcode.ErrorCode) {
|
|
cool.RedisDo(context.TODO(), "sun:join", info.RPCFightinfo{
|
|
PlayerID: c.Info.UserID,
|
|
Mode: data.Mode,
|
|
Type: 1,
|
|
})
|
|
|
|
// // 类型断言为 UniversalClient
|
|
// universalClient, _ := client.(goredis.UniversalClient)
|
|
// repo.NewPlayerRepository(universalClient).AddPlayerToPool(context.TODO(), data.Head.UserID, 1)
|
|
return nil, -1
|
|
}
|