69d286a7
zhangqijia
fix: 插件用来做部分热更
|
1
|
package action
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
2
3
4
|
import (
"github.com/golang/protobuf/proto"
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
5
|
"pro2d/common"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
6
|
"pro2d/common/components"
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
7
|
"pro2d/common/logger"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
8
|
"pro2d/models"
|
7f269318
zhangqijia
add pb.go; 添加关闭连接...
|
9
|
"pro2d/pb"
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
10
11
|
)
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
12
|
func HeartRpc(msg components.IMessage) (int32, interface{}) {
|
0cc58315
zhangqijia
添加定时器, 检查心跳
|
13
|
//msg.Conn.SetLastHeartCheckTime()
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
14
15
16
|
return 0, nil
}
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
17
|
func CreateRpc(msg components.IMessage) (int32, interface{}) {
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
18
|
req := pb.CreateReq{}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
19
|
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
20
|
logger.Error("CreateRpc err: %v", err)
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
21
22
23
24
25
26
27
|
return 1, nil
}
role := models.RoleExistByUid(req.Uid)
if role != nil {
return 2, nil
}
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
28
|
roleId := common.SnowFlack.NextValStr()
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
29
|
role = models.NewRole(roleId)
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
30
|
if err := role.Create(); err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
31
|
logger.Error("CreateRpc role create err: %v", err)
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
32
33
34
35
36
|
return 3, nil
}
return 0, nil
}
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
37
|
func LoginRpc(msg components.IMessage) (int32, interface{}) {
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
38
|
//logger.Debug("11111111cmd: %v, msg: %s", msg.GetHeader().GetMsgID(), msg.GetData())
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
39
|
req := pb.LoginReq{}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
40
|
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
41
|
logger.Error("loginRpc err: %v", err)
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
42
43
44
|
return 1, nil
}
|
436e0af4
zhangqijia
reactor: dir; Ac...
|
45
|
role := models.RoleExistByUid(req.Token)
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
46
47
48
|
if role == nil {
return 2, nil
}
|
7f269318
zhangqijia
add pb.go; 添加关闭连接...
|
49
50
|
role.SetProperty("Device", req.Device)
|
6f0d72bd
zhangqijia
定时器功能完善优化
|
51
|
return 0, &pb.RoleRsp{
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
52
53
54
|
Role: role.Role,
Hero: role.GetAllHero(),
Team: role.Teams.Team,
|
6f0d72bd
zhangqijia
定时器功能完善优化
|
55
|
Equips: []*pb.Equipment{role.Equip.Equip},
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
56
|
}
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
57
|
}
|