Blame view

cmd/gameserver/action/RoleAction.go 1.29 KB
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
  }