player.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690
  1. package models
  2. import (
  3. "context"
  4. "fmt"
  5. jsoniter "github.com/json-iterator/go"
  6. mhayaString "github.com/mhaya/extend/string"
  7. mhayaTime "github.com/mhaya/extend/time"
  8. "github.com/mhaya/game/game_cluster/internal/constant"
  9. "github.com/mhaya/game/game_cluster/internal/data"
  10. "github.com/mhaya/game/game_cluster/internal/mdb"
  11. "github.com/mhaya/game/game_cluster/internal/param"
  12. "github.com/mhaya/game/game_cluster/internal/token"
  13. "time"
  14. mhayaLogger "github.com/mhaya/logger"
  15. "math/rand"
  16. "strings"
  17. )
  18. type Player struct {
  19. UserName string `json:"userName" bson:"userName"`
  20. OpenId string `json:"openId" bson:"openId"`
  21. UserNameMaybe string `json:"userNameMaybe" bson:"userNameMaybe"`
  22. NickName string `json:"nickName" bson:"nickName"`
  23. Pid string `json:"pid" bson:"pid"`
  24. XID string `json:"xID" bson:"xID"`
  25. TonWall string `json:"tonWall" bson:"tonWall"`
  26. Email string `json:"email" bson:"email"`
  27. Mobile string `json:"mobile" bson:"mobile"`
  28. Avatar string `json:"avatar" bson:"avatar"`
  29. IsRobot int `json:"isRobot" bson:"isRobot"`
  30. IsLeader int `json:"isLeader" bson:"isLeader"`
  31. IsVip int `json:"isVip" bson:"isVip"`
  32. IsFirstBindingXID int `json:"isFirstBindingXID" bson:"isFirstBindingXID"`
  33. Level int `json:"level" bson:"level"`
  34. Exp int `json:"exp" bson:"exp"`
  35. Gender int `json:"gender" bson:"gender"`
  36. Birthday string `json:"birthday" bson:"birthday"`
  37. Successions int `json:"successions" bson:"successions"`
  38. MaxSuccessions int `json:"maxSuccessions" bson:"maxSuccessions"`
  39. PrevTime int64 `json:"prevTime" bson:"prevTime"`
  40. LoginTime int64 `json:"loginTime" bson:"loginTime"`
  41. LoginIP string `json:"loginIP" bson:"loginIP"`
  42. LoginFailure int `json:"loginFailure" bson:"loginFailure"`
  43. JoinIP string `json:"joinIP" bson:"joinIP"`
  44. Rank int `json:"rank" bson:"rank"`
  45. JoinTime int64 `json:"joinTime" bson:"joinTime"`
  46. CreateTime int64 `json:"createTime" bson:"createTime"`
  47. UpdateTime int64 `json:"updateTime" bson:"updateTime"`
  48. DailyRefreshTime int64 `json:"dailyRefreshTime" bson:"dailyRefreshTime"`
  49. WeeklyRefreshTime int64 `json:"weeklyRefreshTime" bson:"weeklyRefreshTime"`
  50. RollDay int64 `json:"rollDay" bson:"rollDay"`
  51. Status int `json:"status" bson:"status"`
  52. Roll *Roll `json:"roll" bson:"roll"`
  53. Guide int `json:"guide" bson:"guide"`
  54. Share *Share `json:"share" bson:"share"`
  55. FirstReward int `json:"firstReward" bson:"firstReward"`
  56. Index int `json:"-" bson:"index"`
  57. Item ItemBasePack `json:"item" bson:"item"`
  58. SinIn SignIn `json:"sinIn" bson:"sinIn"`
  59. DailyTask DailyTask `json:"dailyTask" bson:"dailyTask"`
  60. AchieveTask AchieveTask `json:"achieveTask" bson:"achieveTask"`
  61. RankReward RankReward `json:"rankReward" bson:"rankReward"`
  62. Invite Invite `json:"invite" bson:"invite"`
  63. InviteReward *InviteReward `json:"inviteReward" bson:"inviteReward"`
  64. PlayerReward map[int]*PlayerRewardBase `json:"-" bson:"-"`
  65. }
  66. func NewPlayer(token *token.Token) *Player {
  67. return &Player{
  68. UserName: token.PlayerID,
  69. OpenId: token.OpenID,
  70. NickName: token.Nickname,
  71. IsRobot: 0,
  72. Successions: 1,
  73. MaxSuccessions: 1,
  74. LoginTime: mhayaTime.Now().Unix(),
  75. CreateTime: mhayaTime.Now().Unix(),
  76. UpdateTime: mhayaTime.Now().Unix(),
  77. RollDay: mhayaTime.Now().Unix(),
  78. Exp: 0,
  79. Status: 1,
  80. Rank: 0,
  81. Item: NewItem(),
  82. Guide: 1,
  83. Level: 1,
  84. Index: 1,
  85. FirstReward: 1,
  86. Roll: &Roll{RollNums: 0, RollDays: 0},
  87. DailyTask: NewDailyTask(),
  88. Share: &Share{IsDrawShare: 0},
  89. SinIn: NewSignIn(),
  90. AchieveTask: NewAchieveTask(),
  91. RankReward: NewRankReward(),
  92. Invite: NewInvite(),
  93. }
  94. }
  95. func NewBotPlayer(token *token.Token) *Player {
  96. return &Player{
  97. UserName: token.PlayerID,
  98. OpenId: token.OpenID,
  99. NickName: token.Nickname,
  100. IsRobot: 1,
  101. Successions: 1,
  102. MaxSuccessions: 1,
  103. LoginTime: mhayaTime.Now().Unix(),
  104. CreateTime: mhayaTime.Now().Unix(),
  105. UpdateTime: mhayaTime.Now().Unix(),
  106. RollDay: mhayaTime.Now().Unix(),
  107. Exp: 0,
  108. Status: 1,
  109. Rank: 0,
  110. Item: NewItem(),
  111. Guide: 1,
  112. Level: 1,
  113. Index: 1,
  114. FirstReward: 1,
  115. Roll: &Roll{RollNums: 0, RollDays: 0},
  116. DailyTask: NewDailyTask(),
  117. Share: &Share{IsDrawShare: 0},
  118. SinIn: NewSignIn(),
  119. AchieveTask: NewAchieveTask(),
  120. RankReward: NewRankReward(),
  121. Invite: NewInvite(),
  122. }
  123. }
  124. func (p *Player) Init() {
  125. if p.InviteReward == nil {
  126. p.InviteReward = &InviteReward{IsClaim: 0}
  127. }
  128. }
  129. // InitDaily 每日刷新
  130. func (p *Player) InitDaily() {
  131. p.DailyRefreshTime = mhayaTime.Now().Add(-24 * time.Hour).Unix()
  132. if !mhayaTime.CreateFromTimestamp(p.DailyRefreshTime).IsToday() {
  133. //刷新每日任务
  134. p.DailyTask.RefreshDailyTask()
  135. //刷新抽奖每日分享
  136. p.Share.RefreshShare()
  137. //刷新是否有排行榜奖励
  138. p.RankReward.InitRank(p.UserName, 1)
  139. //更新时间到当天
  140. p.DailyRefreshTime = mhayaTime.Now().Unix()
  141. }
  142. }
  143. func (p *Player) InitWeekly() {
  144. if !mhayaTime.CreateFromTimestamp(p.WeeklyRefreshTime).IsThisWeek() {
  145. p.SinIn.RefreshSignIn()
  146. //刷新是否有排行榜奖励
  147. p.RankReward.InitRank(p.UserName, 2)
  148. p.WeeklyRefreshTime = mhayaTime.Now().Unix()
  149. }
  150. }
  151. func (p *Player) InitAchieveTask() {
  152. p.AchieveTask.RefreshAchieveTask()
  153. }
  154. func (p *Player) LevelUp() bool {
  155. ret, ok := data.LevelConfig.Get(p.Level + 1)
  156. if !ok {
  157. return false
  158. }
  159. curLevel := p.Level
  160. if p.Item[ItemRoll].CurNum >= ret.DiceNum && p.Item[ItemInvite].CurNum >= ret.Invite {
  161. p.Level += 1
  162. if p.Level > curLevel {
  163. p.Item[ItemRoll].AddMaxNum(ret.DiceLimit)
  164. p.Item[ItemRoll].CurNum = 0
  165. p.Item[ItemInvite].CurNum = 0
  166. //升级邀请奖励
  167. p.SetPassiveInviteReward()
  168. p.SetPlayerRewardLog(SourceLevelUp, p.Level, []data.ItemReward{{ItemID: ItemAllRoll, ItemBaseType: 2, Amount: ret.DiceLimit}}, []data.ItemReward{}, p.Level)
  169. return true
  170. }
  171. }
  172. return false
  173. }
  174. func (p *Player) RefreshRoll() bool {
  175. ret, ok := data.DiscreteRuleConfig.Get(RefreshRoll)
  176. if !ok {
  177. return false
  178. }
  179. arr := strings.Split(ret.Condition, ",")
  180. if len(arr) != 2 {
  181. return false
  182. }
  183. h, _ := mhayaString.ToInt64(arr[0])
  184. m, _ := mhayaString.ToInt64(arr[1])
  185. s := mhayaTime.CreateFromTimestamp(p.RollDay).DiffInSeconds(mhayaTime.Now())
  186. if s >= h {
  187. p.RollDay = mhayaTime.Now().Unix()
  188. num := p.Item[ItemRoll].AddAll()
  189. if num > 0 {
  190. p.SetPlayerRewardLog(SourceRefreshRoll, 1, []data.ItemReward{{ItemID: ItemRoll, ItemBaseType: 1, Amount: num}}, []data.ItemReward{}, 0)
  191. }
  192. mhayaLogger.Infof("RefreshRoll by condition 1 rollDay:%d,num:%v", s, num)
  193. return true
  194. } else if s >= m {
  195. p.RollDay = mhayaTime.Now().Unix()
  196. num := p.Item[ItemRoll].AddSame()
  197. if num > 0 {
  198. p.SetPlayerRewardLog(SourceRefreshRoll, 2, []data.ItemReward{{ItemID: ItemRoll, ItemBaseType: 1, Amount: num}}, []data.ItemReward{}, 0)
  199. }
  200. mhayaLogger.Infof("RefreshRoll by condition 2 rollDay:%d,num:%v", s, num)
  201. return true
  202. }
  203. return false
  204. }
  205. func (p *Player) CheckTaskByType1(openid int64, id int) bool {
  206. switch id {
  207. case 1: //关注关注推特
  208. return true
  209. case 2: //加入TG频道
  210. //if third.GetIfChannel(openid) == 1 {
  211. // return true
  212. //} else {
  213. // return false
  214. //}
  215. return true
  216. case 3: //关注Yutube账号
  217. return true
  218. case 4: //加入DC频道
  219. return true
  220. }
  221. return false
  222. }
  223. func (p *Player) FinishAchieveTaskByType1(id int) bool {
  224. if a, ok := p.AchieveTask[id]; ok {
  225. if a.Num == 0 && a.Validate == 1 { //待验证
  226. openid, _ := mhayaString.ToInt64(p.OpenId)
  227. if p.CheckTaskByType1(openid, id) {
  228. p.AchieveTask[id].Validate = 2 //验证成功
  229. p.AchieveTask[id].Num = 1
  230. p.AchieveTask[id].Status = 1
  231. } else {
  232. p.AchieveTask[id].Validate = 0 //验证成功
  233. p.AchieveTask[id].Status = 0
  234. mhayaLogger.Error("FinishAchieveTaskByType1 验证失败 username :%v, id : v%", p.UserName, id)
  235. return false
  236. }
  237. } else {
  238. if a.Validate == 0 {
  239. p.AchieveTask[id].Validate = 1
  240. }
  241. }
  242. return true
  243. }
  244. return false
  245. }
  246. // FinishAchieveTaskByType2 完成成就类型2
  247. func (p *Player) FinishAchieveTaskByType2() bool {
  248. var cur int
  249. for _, v := range p.AchieveTask {
  250. if v.Type == 2 {
  251. ret, ok := data.AchieveTaskConfig.Get(v.ID)
  252. if !ok {
  253. continue
  254. }
  255. if v.Num < ret.Condition && v.Num >= cur {
  256. p.AchieveTask[v.ID].Num += 1
  257. p.AchieveTask[v.ID].Status = 1
  258. p.AchieveTask[v.ID].RewardNum += 1
  259. return true
  260. }
  261. cur = ret.Condition
  262. }
  263. }
  264. return false
  265. }
  266. func (p *Player) FinishDailyTask(tp, num int) bool {
  267. var f bool
  268. for i := 0; i < num; i++ {
  269. for _, v := range p.DailyTask {
  270. if v.Type == tp && v.Status == 0 {
  271. p.DailyTask[v.ID].Num += 1
  272. if p.DailyTask[v.ID].Num == v.Condition {
  273. p.DailyTask[v.ID].Status = 1
  274. f = true
  275. continue
  276. }
  277. }
  278. }
  279. }
  280. return f
  281. }
  282. func (p *Player) RollOnce(num int) *param.RollOnce {
  283. var roll param.RollOnce
  284. levelConfig, ok := data.LevelConfig.Get(p.Level)
  285. if !ok {
  286. return nil
  287. }
  288. if levelConfig == nil {
  289. return nil
  290. }
  291. r1 := rand.Int31n(5) + 1
  292. r2 := rand.Int31n(5) + 1
  293. r3 := rand.Int31n(5) + 1
  294. //rule 4
  295. if (r1 == 1 && r2 == 1 && r3 == 1) || (r1 == 6 && r2 == 6 && r3 == 6) {
  296. roll.Score = levelConfig.Ratio * levelConfig.Rule4
  297. roll.RollType = constant.RollSpecialTripleBet
  298. } else if r1 == r2 && r2 == r3 {
  299. roll.Score = levelConfig.Ratio * levelConfig.Rule3
  300. roll.RollType = constant.RollTripleBet
  301. } else if r1 == r2 || r1 == r3 || r2 == r3 {
  302. roll.Score = levelConfig.Ratio * levelConfig.Rule2
  303. roll.RollType = constant.RollDoubleBet
  304. } else {
  305. roll.Score = levelConfig.Ratio * levelConfig.Rule1
  306. if r1+r2+r3 > 9 {
  307. roll.RollType = constant.RollBigBet
  308. } else {
  309. roll.RollType = constant.RollSmallBet
  310. }
  311. }
  312. roll.Rand = make(map[int]int32)
  313. roll.Rand[1] = r1
  314. roll.Rand[2] = r2
  315. roll.Rand[3] = r3
  316. p.Item[ItemScore].Add(roll.Score * num)
  317. p.Item[ItemRoll].sub(1 * num)
  318. p.SetPlayerRewardLog(SourceRoll, 0, []data.ItemReward{{ItemID: ItemScore, ItemBaseType: 1, Amount: roll.Score * num}}, []data.ItemReward{{ItemID: ItemRoll, ItemBaseType: 1, Amount: 1 * num}}, roll)
  319. p.Roll.RollNums += 1 * num
  320. roll.IsDailyTask = p.FinishDailyTask(1, num)
  321. roll.IsLevelUp = p.LevelUp()
  322. return &roll
  323. }
  324. // Draw 最多尝试重复执行50次
  325. func (p *Player) Draw() *param.Draw {
  326. for i := 0; i < 50; i++ {
  327. draw, ok := p.DrawOnce()
  328. if ok {
  329. return draw
  330. }
  331. }
  332. return nil
  333. }
  334. func (p *Player) DrawOnce() (*param.Draw, bool) {
  335. var ret map[int]*data.DrawConfigRow
  336. var draw param.Draw
  337. if p.Item[ItemDrawsNumber].Num <= 10 {
  338. ret = data.DrawConfig.GetByType(1)
  339. } else {
  340. ret = data.DrawConfig.GetByType(2)
  341. }
  342. weight := int(rand.Int31n(9999))
  343. var cur int
  344. var curID int
  345. var drawId int
  346. for _, v := range ret {
  347. if v.Weight == 0 {
  348. continue
  349. }
  350. if weight >= cur && weight < cur+v.Weight {
  351. curID = v.ID
  352. drawId = v.Order
  353. break
  354. }
  355. cur += v.Weight
  356. }
  357. if d, ok := ret[curID]; ok {
  358. if d.HourTotalCondition > 0 {
  359. i, err := GetDrawHour(curID)
  360. if err != nil {
  361. return nil, false
  362. }
  363. if int(i) > d.HourTotalCondition {
  364. return nil, false
  365. }
  366. }
  367. if d.DailyTotalCondition > 0 {
  368. i, err := GetDrawDailyKey(curID)
  369. if err != nil {
  370. return nil, false
  371. }
  372. if int(i) > d.DailyTotalCondition {
  373. return nil, false
  374. }
  375. }
  376. if d.WeeklyTotalCondition > 0 {
  377. i, err := GetDrawWeeklyKey(curID)
  378. if err != nil {
  379. return nil, false
  380. }
  381. if int(i) > d.WeeklyTotalCondition {
  382. return nil, false
  383. }
  384. }
  385. p.Item.AddItem(d.Reward)
  386. p.Item[ItemDrawsNumber].sub(1)
  387. draw.Reward = d.Reward
  388. draw.ID = drawId
  389. draw.CurID = curID
  390. if len(p.Roll.Draw) == 0 {
  391. p.Roll.Draw = make(map[int]int)
  392. }
  393. if len(p.Roll.DrawRatio) == 0 {
  394. p.Roll.DrawRatio = make(map[int]float64)
  395. }
  396. p.Roll.Draw[curID] += 1
  397. p.Roll.DrawTotal += 1
  398. p.Roll.DrawRatio[curID] = float64(p.Roll.Draw[curID]) / float64(p.Roll.DrawTotal)
  399. p.SetPlayerRewardLog(SourceDraw, 0, draw.Reward, []data.ItemReward{{1, ItemDrawsNumber, 1}}, draw)
  400. } else {
  401. return nil, false
  402. }
  403. return &draw, true
  404. }
  405. func GetDrawHour(id int) (int64, error) {
  406. s := mhayaTime.CreateFromTime(mhayaTime.Now().Hour(), 0, 0).ToDateTimeFormat()
  407. key := fmt.Sprintf("%v:%v:%v", constant.DrawHourKey, id, s)
  408. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  409. }
  410. func GetDrawDailyKey(id int) (int64, error) {
  411. key := fmt.Sprintf("%v:%v:%v", constant.DrawDailyKey, id, mhayaTime.Now().Format(mhayaTime.DateFormat))
  412. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  413. }
  414. func GetDrawWeeklyKey(id int) (int64, error) {
  415. key := fmt.Sprintf("%v:%v:%v", constant.DrawWeeklyKey, id, mhayaTime.Now().Week())
  416. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  417. }
  418. func (p *Player) SignIn() *param.ChangeData {
  419. var sign param.ChangeData
  420. p.SinIn.SignDailyTime = mhayaTime.Now().Unix()
  421. p.SinIn.Sign[p.SinIn.Num].IsSign = 1
  422. p.SinIn.Sign[p.SinIn.Num].SignTime = mhayaTime.Now().Unix()
  423. var addItem AddItem
  424. at := addItem.Add(p.SinIn.Sign[p.SinIn.Num].Reward)
  425. sign.AddItem = at
  426. p.Item.AddItem(p.SinIn.Sign[p.SinIn.Num].Reward)
  427. p.SinIn.Num += 1
  428. p.SetPlayerRewardLog(SourceSignIn, p.SinIn.Num, p.SinIn.Sign[p.SinIn.Num].Reward, []data.ItemReward{}, nil)
  429. sign.IsLevelUp = p.LevelUp()
  430. return &sign
  431. }
  432. func (p *Player) SetPlayerRewardLog(tp, tid int, addReward, subReward []data.ItemReward, desc interface{}) {
  433. p.Index += 1
  434. if len(p.PlayerReward) == 0 {
  435. p.PlayerReward = make(map[int]*PlayerRewardBase)
  436. }
  437. p.PlayerReward[p.Index] = &PlayerRewardBase{
  438. UserName: p.UserName,
  439. AddReward: addReward,
  440. SubReward: subReward,
  441. Desc: desc,
  442. Source: tp,
  443. SourceId: tid,
  444. CreateTime: mhayaTime.Now().Unix(),
  445. }
  446. }
  447. func (p *Player) SetPassiveInviteReward() {
  448. ret2, ok := data.DiscreteRuleConfig.Get(InvitePlayer)
  449. c, tok := mhayaString.ToInt(ret2.Condition)
  450. if !ok || !tok || c != p.Level {
  451. return
  452. }
  453. ret3, ok := data.DiscreteRuleConfig.Get(InviteVipPlayer)
  454. c, tok = mhayaString.ToInt(ret3.Condition)
  455. if !ok || !tok || c != p.Level {
  456. return
  457. }
  458. //被动邀请
  459. key := fmt.Sprintf("%v:1:%v", constant.InviteKey, p.UserName)
  460. pUid := mdb.RDB.Get(context.Background(), key).Val()
  461. pbase, err := mdb.RDB.Get(context.Background(), GetPlayBaseKey(pUid)).Bytes()
  462. if err != nil {
  463. return
  464. }
  465. mdb.RDB.Del(context.Background(), key)
  466. var base param.PlayerBase
  467. err = jsoniter.Unmarshal(pbase, &base)
  468. if err != nil {
  469. return
  470. }
  471. var addItem []data.ItemReward
  472. if p.IsVip == 0 {
  473. //主动邀请记录
  474. key = fmt.Sprintf("%v:%v:%v", constant.InviteKey, InvitePlayer, pUid)
  475. mdb.RDB.IncrBy(context.Background(), key, 1)
  476. addItem = append(addItem, ret2.Reward...)
  477. } else {
  478. key = fmt.Sprintf("%v:%v:%v", constant.InviteKey, InviteVipPlayer, pUid)
  479. mdb.RDB.IncrBy(context.Background(), key, 1)
  480. addItem = append(addItem, ret3.Reward...)
  481. }
  482. if base.IsLeader == 1 {
  483. ret, ok := data.DiscreteRuleConfig.Get(InvitePlayerByLeader)
  484. if !ok {
  485. return
  486. }
  487. addItem = append(addItem, ret.Reward...)
  488. }
  489. if p.InviteReward.IsClaim == 2 {
  490. p.InviteReward.Reward = []data.ItemReward{}
  491. p.InviteReward.IsClaim = 0
  492. p.InviteReward.RewardTime = 0
  493. }
  494. p.InviteReward.Reward = append(p.InviteReward.Reward, addItem...)
  495. }
  496. func (p *Player) SetInviteReward() {
  497. ret, ok := data.DiscreteRuleConfig.Get(InvitePlayerByLeader)
  498. if !ok {
  499. return
  500. }
  501. ret2, ok := data.DiscreteRuleConfig.Get(InvitePlayer)
  502. c, tok := mhayaString.ToInt(ret2.Condition)
  503. if !ok || !tok || c != p.Level {
  504. return
  505. }
  506. ret3, ok := data.DiscreteRuleConfig.Get(InviteVipPlayer)
  507. c, tok = mhayaString.ToInt(ret3.Condition)
  508. if !ok || !tok || c != p.Level {
  509. return
  510. }
  511. var addItem []data.ItemReward
  512. key1 := fmt.Sprintf("%v:%v:%v", constant.InviteKey, InvitePlayer, p.UserName)
  513. key2 := fmt.Sprintf("%v:%v:%v", constant.InviteKey, InviteVipPlayer, p.UserName)
  514. freeNum, _ := mdb.RDB.Get(context.Background(), key1).Int()
  515. VipNum, _ := mdb.RDB.Get(context.Background(), key2).Int()
  516. for i := 0; i < freeNum; i++ {
  517. addItem = append(addItem, ret2.Reward...)
  518. p.SetPlayerRewardLog(SourceInvite, InvitePlayer, []data.ItemReward{}, []data.ItemReward{}, 2)
  519. if p.IsLeader == 1 {
  520. addItem = append(addItem, ret.Reward...)
  521. p.SetPlayerRewardLog(SourceInvite, InvitePlayerByLeader, []data.ItemReward{}, []data.ItemReward{}, 2)
  522. }
  523. mdb.RDB.DecrBy(context.Background(), key1, 1)
  524. }
  525. for i := 0; i < VipNum; i++ {
  526. addItem = append(addItem, ret3.Reward...)
  527. p.SetPlayerRewardLog(SourceInvite, InviteVipPlayer, []data.ItemReward{}, []data.ItemReward{}, 2)
  528. if p.IsLeader == 1 {
  529. addItem = append(addItem, ret.Reward...)
  530. p.SetPlayerRewardLog(SourceInvite, InvitePlayerByLeader, []data.ItemReward{}, []data.ItemReward{}, 2)
  531. }
  532. mdb.RDB.DecrBy(context.Background(), key2, 1)
  533. }
  534. if (freeNum + VipNum) > 0 {
  535. SetRank(constant.RankSourceInvite, p.IsRobot, p.UserName, freeNum+VipNum)
  536. }
  537. if p.InviteReward.IsClaim == 2 {
  538. p.InviteReward.Reward = []data.ItemReward{}
  539. p.InviteReward.IsClaim = 0
  540. p.InviteReward.RewardTime = 0
  541. }
  542. p.InviteReward.Reward = append(p.InviteReward.Reward, addItem...)
  543. }
  544. func (p *Player) SetInvite(uid string) bool {
  545. key := fmt.Sprintf("%v:1:%v", constant.InviteKey, p.UserName)
  546. ret, ok := data.DiscreteRuleConfig.Get(InviteMaxExpireTime)
  547. if !ok {
  548. return false
  549. }
  550. t, _ := mhayaString.ToInt64(ret.Condition)
  551. err := mdb.RDB.Set(context.Background(), key, uid, time.Duration(t)*24*time.Hour).Err()
  552. if err != nil {
  553. return false
  554. }
  555. return true
  556. }
  557. func (p *Player) ClaimRankReward(id int) param.ChangeData {
  558. var resp param.ChangeData
  559. if rank, ok := p.RankReward[id]; ok {
  560. if rank.IsClaim == 0 && len(rank.Reward) > 0 {
  561. var addItem AddItem
  562. resp.AddItem = addItem.Add(rank.Reward)
  563. p.Item.AddItem(rank.Reward)
  564. p.RankReward[id].IsClaim = 1
  565. p.RankReward[id].ClaimTime = mhayaTime.Now().Unix()
  566. p.SetPlayerRewardLog(SourceRank, id, rank.Reward, []data.ItemReward{}, nil)
  567. }
  568. }
  569. p.LevelUp()
  570. return resp
  571. }
  572. func (p *Player) ClaimInviteReward(id int) param.ChangeData {
  573. var resp param.ChangeData
  574. if p.InviteReward.IsClaim == 0 {
  575. var addItem AddItem
  576. resp.AddItem = addItem.Add(p.InviteReward.Reward)
  577. p.Item.AddItem(p.InviteReward.Reward)
  578. p.InviteReward.IsClaim = 1
  579. p.InviteReward.RewardTime = mhayaTime.Now().Unix()
  580. p.SetPlayerRewardLog(SourceInvite, id, p.InviteReward.Reward, []data.ItemReward{}, nil)
  581. }
  582. p.LevelUp()
  583. return resp
  584. }
  585. func (p *Player) ClaimAchieveTaskReward(id int) param.ChangeData {
  586. var resp param.ChangeData
  587. if ach, ok := p.AchieveTask[id]; ok {
  588. if ach.Status == 1 && ach.RewardNum > 0 {
  589. var addItem AddItem
  590. resp.AddItem = addItem.Add(ach.Reward)
  591. p.Item.AddItem(ach.Reward)
  592. ach.RewardNum -= 1
  593. p.SetPlayerRewardLog(SourceAchieveTask, id, ach.Reward, []data.ItemReward{}, nil)
  594. }
  595. if ach.RewardNum == 0 {
  596. p.AchieveTask[id].Status = 2
  597. }
  598. }
  599. p.LevelUp()
  600. return resp
  601. }
  602. func (p *Player) ClaimDailyTaskReward(id int) param.ChangeData {
  603. var resp param.ChangeData
  604. if task, ok := p.DailyTask[id]; ok {
  605. if task.Status == 1 {
  606. var addItem AddItem
  607. resp.AddItem = addItem.Add(task.Reward)
  608. p.Item.AddItem(task.Reward)
  609. task.Status = 2
  610. p.SetPlayerRewardLog(SourceDailyTask, id, task.Reward, []data.ItemReward{}, nil)
  611. }
  612. }
  613. p.LevelUp()
  614. return resp
  615. }