|
|
|
@ -38,7 +38,7 @@ func (h *MsgToPushHandler) Init(svc *svc.ServiceContext) {
|
|
|
|
|
h.commandManager = command.NewManager()
|
|
|
|
|
h.commandManager.Register(h.handleJoinGame, "j", "加入", "加入游戏")
|
|
|
|
|
h.commandManager.Register(h.handleOutbreak, "s")
|
|
|
|
|
h.commandManager.Register(h.handleWai, "w")
|
|
|
|
|
h.commandManager.Register(h.handleWai, "w", "我在哪")
|
|
|
|
|
h.commandManager.Register(h.handleCreateUnit, "c1", "c2", "c3", "c4")
|
|
|
|
|
h.commandManager.Register(h.handleMove, "m1", "m2", "m3")
|
|
|
|
|
h.commandManager.Register(h.handleMode, "r1", "r2", "r3")
|
|
|
|
@ -119,6 +119,7 @@ func (h *MsgToPushHandler) handleDanmaku(data []byte, msgKey string) {
|
|
|
|
|
PUid: strconv.FormatInt(msgFromMq.Uid, 10),
|
|
|
|
|
})
|
|
|
|
|
if err == nil {
|
|
|
|
|
pbUser.UId = rpcUser.User.Id
|
|
|
|
|
pbUser.Avatar = rpcUser.User.PAvatar
|
|
|
|
|
} else {
|
|
|
|
|
logger.SLog.Info("rpc获取用户信息失败")
|
|
|
|
|