ddc88bac
zhangqijia
fix: 记录战斗
|
1
|
// 游戏服角色相关操作
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
2
|
package action
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
3
4
|
import (
|
29a163be
zhangqijia
fix: CreateReq ui...
|
5
|
"fmt"
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
6
|
"github.com/golang/protobuf/proto"
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
7
|
"pro2d/common"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
8
|
"pro2d/common/components"
|
29a163be
zhangqijia
fix: CreateReq ui...
|
9
|
"pro2d/common/db/redisproxy"
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
10
|
"pro2d/common/logger"
|
ddc88bac
zhangqijia
fix: 记录战斗
|
11
|
"pro2d/csvdata"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
12
|
"pro2d/models"
|
7f269318
zhangqijia
add pb.go; 添加关闭连接...
|
13
|
"pro2d/pb"
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
14
15
|
)
|
4a502dd5
zhangqijia
fix: game,account...
|
16
|
// HeartRpc 心跳请求
|
3e92be67
zhangqijia
fix: 优化协议,除了登录和创建...
|
17
|
func HeartRpc(role *models.RoleModel, msg components.IMessage) (int32, interface{}) {
|
0cc58315
zhangqijia
添加定时器, 检查心跳
|
18
|
//msg.Conn.SetLastHeartCheckTime()
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
19
20
21
|
return 0, nil
}
|
4a502dd5
zhangqijia
fix: game,account...
|
22
|
// getRandomName 随机名字
|
29a163be
zhangqijia
fix: CreateReq ui...
|
23
24
|
func getRandomName() string {
name := ""
|
eadc9aff
zhangqijia
feat: 增加上阵下阵协议,增加...
|
25
|
for {
|
29a163be
zhangqijia
fix: CreateReq ui...
|
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
name = common.RandomName(common.DefaultName)
if name == "" {
continue
}
relay, err := redisproxy.SETNX(fmt.Sprintf(common.NickNames, name), "1")
if err != nil {
continue
}
if relay.(int64) == 1 {
break
}
}
return name
}
|
4a502dd5
zhangqijia
fix: game,account...
|
42
43
44
45
46
|
/*
CreateRpc 创建角色请求
1: proto解析错误
2: 角色不存在
*/
|
3e92be67
zhangqijia
fix: 优化协议,除了登录和创建...
|
47
|
func CreateRpc(role1 *models.RoleModel, msg components.IMessage) (int32, interface{}) {
|
f8ce769e
zhangqijia
fix: rpc = rar + ...
|
48
|
req := pb.CreateRar{}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
49
|
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
50
|
logger.Error("CreateRpc err: %v", err)
|
101d1cc1
zhangqijia
feat: 一个基于redis的自...
|
51
|
return 1, err
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
52
|
}
|
29a163be
zhangqijia
fix: CreateReq ui...
|
53
|
role := models.RoleExistByUid(req.Token)
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
54
|
if role != nil {
|
101d1cc1
zhangqijia
feat: 一个基于redis的自...
|
55
56
57
58
59
60
|
return 2, "role exists"
}
roleId, err := common.GetNextRoleId()
if err != nil {
return 3, err
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
61
62
|
}
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
63
|
role = models.NewRole(roleId)
|
23822e2f
zhangqijia
fix: update proto...
|
64
65
66
|
role.Data.Uid = req.Token
role.Data.Level = 1
role.Data.Nick = getRandomName()
|
f8ce769e
zhangqijia
fix: rpc = rar + ...
|
67
|
if err = role.Create(); err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
68
|
logger.Error("CreateRpc role create err: %v", err)
|
a24dea4c
zhangqijia
fix: id自增做了写更新。阵容...
|
69
|
return 4, nil
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
70
|
}
|
8d983031
zhangqijia
loginReq uid -> t...
|
71
|
role.InitRole()
|
9644352a
zhangqijia
登录服改为http,游戏服改为长连...
|
72
73
74
|
return 0, nil
}
|
4a502dd5
zhangqijia
fix: game,account...
|
75
|
// ChangeTeamRpc 阵容变换
|
3e92be67
zhangqijia
fix: 优化协议,除了登录和创建...
|
76
|
func ChangeTeamRpc(role *models.RoleModel, msg components.IMessage) (int32, interface{}) {
|
f8ce769e
zhangqijia
fix: rpc = rar + ...
|
77
|
req := pb.ChangeTeamRar{}
|
eadc9aff
zhangqijia
feat: 增加上阵下阵协议,增加...
|
78
79
80
81
|
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
logger.Error("loginRpc err: %v", err)
return 1, nil
}
|
eadc9aff
zhangqijia
feat: 增加上阵下阵协议,增加...
|
82
83
84
|
role.UpdateTeam(req.Team)
return 0, nil
|
69d286a7
zhangqijia
fix: 插件用来做部分热更
|
85
|
}
|
17fe96be
zhangqijia
feat: 增加装备相关数据和协议
|
86
|
|
4a502dd5
zhangqijia
fix: game,account...
|
87
|
/*
|
4a502dd5
zhangqijia
fix: game,account...
|
88
89
90
|
RoleClearItemsRpc 删除物品
2 删除失败
*/
|
3e92be67
zhangqijia
fix: 优化协议,除了登录和创建...
|
91
|
func RoleClearItemsRpc(role *models.RoleModel, msg components.IMessage) (int32, interface{}) {
|
f8ce769e
zhangqijia
fix: rpc = rar + ...
|
92
|
req := pb.RoleClearItemsRar{}
|
51d48d11
zhangqijia
fix: 删除装备 删除物品请求
|
93
|
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
|
8f6d9ea9
zhangqijia
fix: UpLevel
|
94
|
logger.Error("proto rpc err: %v", err)
|
51d48d11
zhangqijia
fix: 删除装备 删除物品请求
|
95
96
|
return 1, nil
}
|
51d48d11
zhangqijia
fix: 删除装备 删除物品请求
|
97
|
|
c99d59cc
zhangqijia
fix: 批量删除物品
|
98
99
100
101
102
103
104
105
106
107
108
|
bkup := make(common.IMapStringNum)
for _, item := range req.Items {
for k, v := range common.StringToMapNum(item) {
tmp, ok := bkup[k]
if !ok {
tmp = 0
}
bkup[k] = v + tmp
}
}
|
77da2da8
zhangqijia
fix: add log
|
109
|
if !role.CostItems(bkup, &pb.LogConf{Desc: "clear_items"}) {
|
c99d59cc
zhangqijia
fix: 批量删除物品
|
110
|
logger.Error("cost err: %s", common.MapNumToString(bkup))
|
3e92be67
zhangqijia
fix: 优化协议,除了登录和创建...
|
111
|
return 2, nil
|
51d48d11
zhangqijia
fix: 删除装备 删除物品请求
|
112
113
114
115
|
}
return 0, nil
}
|
4a502dd5
zhangqijia
fix: game,account...
|
116
|
/*
|
ddc88bac
zhangqijia
fix: 记录战斗
|
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
RoleStartBattleRpc 开始战斗
*/
func RoleStartBattleRpc(role *models.RoleModel, msg components.IMessage) (int32, interface{}) {
req := pb.RoleStartBattleReq{}
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
logger.Error("loginRpc err: %v", err)
return 1, nil
}
//TODO 消耗体力
return 0, nil
}
/*
RoleEndBattleRpc 结束战斗
2 关卡不存在
RoleEndBattleRsp 返回值
*/
func RoleEndBattleRpc(role *models.RoleModel, msg components.IMessage) (int32, interface{}) {
req := pb.RoleEndBattleReq{}
if err := proto.Unmarshal(msg.GetData(), &req); err != nil {
logger.Error("loginRpc err: %v", err)
return 1, nil
}
|
ddc88bac
zhangqijia
fix: 记录战斗
|
143
|
chapterInfo := csvdata.Get().TbRogueChapter.Get(req.ChapterId)
|
23822e2f
zhangqijia
fix: update proto...
|
144
|
chapterCount, first := role.Data.Passchapters[req.ChapterId]
|
ddc88bac
zhangqijia
fix: 记录战斗
|
145
146
147
148
149
150
|
carbonInfo, ok := chapterInfo.Carbons[req.CarbonId]
if !ok {
logger.Error("carbonInfo not exists")
return 2, nil
}
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
151
152
153
154
155
156
157
|
//team
team, ok := role.Teams[req.TeamId]
if !ok {
logger.Error("team not exists")
return 3, nil
}
|
ddc88bac
zhangqijia
fix: 记录战斗
|
158
159
|
reward := make(common.IMapStringNum)
if !first {
|
23822e2f
zhangqijia
fix: update proto...
|
160
|
role.Data.Passchapters[req.ChapterId] = 1
|
ddc88bac
zhangqijia
fix: 记录战斗
|
161
162
163
164
|
for k, v := range common.StringToMapNum(carbonInfo.FirstAward) {
reward[k] = v
}
} else {
|
23822e2f
zhangqijia
fix: update proto...
|
165
|
role.Data.Passchapters[req.ChapterId] = chapterCount + 1
|
ddc88bac
zhangqijia
fix: 记录战斗
|
166
|
}
|
23822e2f
zhangqijia
fix: update proto...
|
167
|
role.SetProperty("passchapters", role.Data.Passchapters)
|
ddc88bac
zhangqijia
fix: 记录战斗
|
168
169
170
171
172
173
174
175
176
177
|
for k, v := range common.StringToMapNum(carbonInfo.NormalAward) {
rv, ok := reward[k]
if !ok {
reward[k] = v
} else {
reward[k] = rv + v
}
}
//award
|
dff17021
zhangqijia
fix
|
178
|
reward = role.Award(reward, &pb.LogConf{Desc: "out_battle", Int1: string(chapterInfo.ChapterId), Int2: string(chapterCount)})
|
ddc88bac
zhangqijia
fix: 记录战斗
|
179
180
|
//exp
|
686ff048
zhangqijia
fix: 结束战斗增加字段
|
181
|
var amount int32
|
ddc88bac
zhangqijia
fix: 记录战斗
|
182
|
if req.Pass {
|
686ff048
zhangqijia
fix: 结束战斗增加字段
|
183
|
amount = carbonInfo.CarbonExp
|
ddc88bac
zhangqijia
fix: 记录战斗
|
184
|
} else {
|
686ff048
zhangqijia
fix: 结束战斗增加字段
|
185
|
amount = carbonInfo.CarbonFailExp
|
ddc88bac
zhangqijia
fix: 记录战斗
|
186
|
}
|
686ff048
zhangqijia
fix: 结束战斗增加字段
|
187
|
level, exp := role.UpLevel(amount)
|
2ea16684
zhangqijia
fix: update
|
188
|
role.UpdateProperties(map[string]interface{}{"level": level, "exp": exp}, true)
|
ddc88bac
zhangqijia
fix: 记录战斗
|
189
|
|
a2d4f770
zhangqijia
fix: 首次通关记录到数据库
|
190
191
192
193
194
|
rsp := &pb.RoleEndBattleRsp{
RoleLevel: level,
RoleExp: exp,
}
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
195
|
//team exp
|
a2d4f770
zhangqijia
fix: 首次通关记录到数据库
|
196
|
heros := make([]*pb.Hero, 3)
|
23822e2f
zhangqijia
fix: update proto...
|
197
|
t := team.(*models.TeamModel).Data
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
198
199
|
h1, ok := role.Heros[t.HeroId1]
if ok {
|
4e75670c
zhangqijia
fix: 首次通关记录到数据库
|
200
|
level, exp = h1.(*models.HeroModel).UpLevel(amount)
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
201
202
|
h1.SetProperty("level", level)
h1.SetProperty("exp", exp)
|
23822e2f
zhangqijia
fix: update proto...
|
203
|
heros[0] = h1.(*models.HeroModel).Data
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
204
205
206
207
|
}
h2, ok := role.Heros[t.HeroId2]
if ok {
|
4e75670c
zhangqijia
fix: 首次通关记录到数据库
|
208
|
level, exp = h2.(*models.HeroModel).UpLevel(amount)
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
209
210
|
h2.SetProperty("level", level)
h2.SetProperty("exp", exp)
|
23822e2f
zhangqijia
fix: update proto...
|
211
|
heros[1] = h2.(*models.HeroModel).Data
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
212
213
214
215
|
}
h3, ok := role.Heros[t.HeroId3]
if ok {
|
4e75670c
zhangqijia
fix: 首次通关记录到数据库
|
216
|
level, exp = h3.(*models.HeroModel).UpLevel(amount)
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
217
218
|
h3.SetProperty("level", level)
h3.SetProperty("exp", exp)
|
23822e2f
zhangqijia
fix: update proto...
|
219
|
heros[2] = h3.(*models.HeroModel).Data
|
92256e32
zhangqijia
fix: 结束战斗的协议加上队伍id
|
220
221
|
}
|
a2d4f770
zhangqijia
fix: 首次通关记录到数据库
|
222
223
224
225
|
rsp.RoleExpamount = amount
rsp.Pass = req.Pass
rsp.Reward = common.MapNumToString(reward)
rsp.Hero = heros
|
ddc88bac
zhangqijia
fix: 记录战斗
|
226
227
|
return 0, rsp
}
|