player.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657
  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. // FinishAchieveTaskByType1 完成成就类型1
  206. func (p *Player) FinishAchieveTaskByType1(id int) bool {
  207. if a, ok := p.AchieveTask[id]; ok {
  208. if a.Num == 0 {
  209. p.AchieveTask[id].Num = 1
  210. p.AchieveTask[id].Status = 1
  211. return true
  212. }
  213. }
  214. return false
  215. }
  216. // FinishAchieveTaskByType2 完成成就类型1
  217. func (p *Player) FinishAchieveTaskByType2() bool {
  218. var cur int
  219. for _, v := range p.AchieveTask {
  220. if v.Type == 2 {
  221. ret, ok := data.AchieveTaskConfig.Get(v.ID)
  222. if !ok {
  223. continue
  224. }
  225. if v.Num < ret.Condition && v.Num >= cur {
  226. p.AchieveTask[v.ID].Num += 1
  227. p.AchieveTask[v.ID].Status = 1
  228. p.AchieveTask[v.ID].RewardNum += 1
  229. return true
  230. }
  231. cur = ret.Condition
  232. }
  233. }
  234. return false
  235. }
  236. func (p *Player) FinishDailyTask(tp, num int) bool {
  237. var f bool
  238. for i := 0; i < num; i++ {
  239. for _, v := range p.DailyTask {
  240. if v.Type == tp && v.Status == 0 {
  241. p.DailyTask[v.ID].Num += 1
  242. if p.DailyTask[v.ID].Num == v.Condition {
  243. p.DailyTask[v.ID].Status = 1
  244. f = true
  245. continue
  246. }
  247. }
  248. }
  249. }
  250. return f
  251. }
  252. func (p *Player) RollOnce(num int) *param.RollOnce {
  253. var roll param.RollOnce
  254. levelConfig, ok := data.LevelConfig.Get(p.Level)
  255. if !ok {
  256. return nil
  257. }
  258. if levelConfig == nil {
  259. return nil
  260. }
  261. r1 := rand.Int31n(5) + 1
  262. r2 := rand.Int31n(5) + 1
  263. r3 := rand.Int31n(5) + 1
  264. //rule 4
  265. if (r1 == 1 && r2 == 1 && r3 == 1) || (r1 == 6 && r2 == 6 && r3 == 6) {
  266. roll.Score = levelConfig.Ratio * levelConfig.Rule4
  267. roll.RollType = constant.RollSpecialTripleBet
  268. } else if r1 == r2 && r2 == r3 {
  269. roll.Score = levelConfig.Ratio * levelConfig.Rule3
  270. roll.RollType = constant.RollTripleBet
  271. } else if r1 == r2 || r1 == r3 || r2 == r3 {
  272. roll.Score = levelConfig.Ratio * levelConfig.Rule2
  273. roll.RollType = constant.RollDoubleBet
  274. } else {
  275. roll.Score = levelConfig.Ratio * levelConfig.Rule1
  276. if r1+r2+r3 > 9 {
  277. roll.RollType = constant.RollBigBet
  278. } else {
  279. roll.RollType = constant.RollSmallBet
  280. }
  281. }
  282. roll.Rand = make(map[int]int32)
  283. roll.Rand[1] = r1
  284. roll.Rand[2] = r2
  285. roll.Rand[3] = r3
  286. p.Item[ItemScore].Add(roll.Score * num)
  287. p.Item[ItemRoll].sub(1 * num)
  288. p.SetPlayerRewardLog(SourceRoll, 0, []data.ItemReward{{ItemID: ItemScore, ItemBaseType: 1, Amount: roll.Score * num}}, []data.ItemReward{{ItemID: ItemRoll, ItemBaseType: 1, Amount: 1 * num}}, roll)
  289. p.Roll.RollNums += 1 * num
  290. roll.IsDailyTask = p.FinishDailyTask(1, num)
  291. roll.IsLevelUp = p.LevelUp()
  292. return &roll
  293. }
  294. // Draw 最多尝试重复执行50次
  295. func (p *Player) Draw() *param.Draw {
  296. for i := 0; i < 50; i++ {
  297. draw, ok := p.DrawOnce()
  298. if ok {
  299. return draw
  300. }
  301. }
  302. return nil
  303. }
  304. func (p *Player) DrawOnce() (*param.Draw, bool) {
  305. var ret map[int]*data.DrawConfigRow
  306. var draw param.Draw
  307. if p.Item[ItemDrawsNumber].Num <= 10 {
  308. ret = data.DrawConfig.GetByType(1)
  309. } else {
  310. ret = data.DrawConfig.GetByType(2)
  311. }
  312. weight := int(rand.Int31n(9999))
  313. var cur int
  314. var curID int
  315. var drawId int
  316. for _, v := range ret {
  317. if v.Weight == 0 {
  318. continue
  319. }
  320. if weight >= cur && weight < cur+v.Weight {
  321. curID = v.ID
  322. drawId = v.Order
  323. break
  324. }
  325. cur += v.Weight
  326. }
  327. if d, ok := ret[curID]; ok {
  328. if d.HourTotalCondition > 0 {
  329. i, err := GetDrawHour(curID)
  330. if err != nil {
  331. return nil, false
  332. }
  333. if int(i) > d.HourTotalCondition {
  334. return nil, false
  335. }
  336. }
  337. if d.DailyTotalCondition > 0 {
  338. i, err := GetDrawDailyKey(curID)
  339. if err != nil {
  340. return nil, false
  341. }
  342. if int(i) > d.DailyTotalCondition {
  343. return nil, false
  344. }
  345. }
  346. if d.WeeklyTotalCondition > 0 {
  347. i, err := GetDrawWeeklyKey(curID)
  348. if err != nil {
  349. return nil, false
  350. }
  351. if int(i) > d.WeeklyTotalCondition {
  352. return nil, false
  353. }
  354. }
  355. p.Item.AddItem(d.Reward)
  356. p.Item[ItemDrawsNumber].sub(1)
  357. draw.Reward = d.Reward
  358. draw.ID = drawId
  359. draw.CurID = curID
  360. if len(p.Roll.Draw) == 0 {
  361. p.Roll.Draw = make(map[int]int)
  362. }
  363. if len(p.Roll.DrawRatio) == 0 {
  364. p.Roll.DrawRatio = make(map[int]float64)
  365. }
  366. p.Roll.Draw[curID] += 1
  367. p.Roll.DrawTotal += 1
  368. p.Roll.DrawRatio[curID] = float64(p.Roll.Draw[curID]) / float64(p.Roll.DrawTotal)
  369. p.SetPlayerRewardLog(SourceDraw, 0, draw.Reward, []data.ItemReward{{1, ItemDrawsNumber, 1}}, draw)
  370. } else {
  371. return nil, false
  372. }
  373. return &draw, true
  374. }
  375. func GetDrawHour(id int) (int64, error) {
  376. s := mhayaTime.CreateFromTime(mhayaTime.Now().Hour(), 0, 0).ToDateTimeFormat()
  377. key := fmt.Sprintf("%v:%v:%v", constant.DrawHourKey, id, s)
  378. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  379. }
  380. func GetDrawDailyKey(id int) (int64, error) {
  381. key := fmt.Sprintf("%v:%v:%v", constant.DrawDailyKey, id, mhayaTime.Now().Format(mhayaTime.DateFormat))
  382. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  383. }
  384. func GetDrawWeeklyKey(id int) (int64, error) {
  385. key := fmt.Sprintf("%v:%v:%v", constant.DrawWeeklyKey, id, mhayaTime.Now().Week())
  386. return mdb.RDB.IncrBy(context.Background(), key, 1).Result()
  387. }
  388. func (p *Player) SignIn() *param.ChangeData {
  389. var sign param.ChangeData
  390. p.SinIn.SignDailyTime = mhayaTime.Now().Unix()
  391. p.SinIn.Sign[p.SinIn.Num].IsSign = 1
  392. p.SinIn.Sign[p.SinIn.Num].SignTime = mhayaTime.Now().Unix()
  393. var addItem AddItem
  394. at := addItem.Add(p.SinIn.Sign[p.SinIn.Num].Reward)
  395. sign.AddItem = at
  396. p.Item.AddItem(p.SinIn.Sign[p.SinIn.Num].Reward)
  397. p.SinIn.Num += 1
  398. p.SetPlayerRewardLog(SourceSignIn, p.SinIn.Num, p.SinIn.Sign[p.SinIn.Num].Reward, []data.ItemReward{}, nil)
  399. sign.IsLevelUp = p.LevelUp()
  400. return &sign
  401. }
  402. func (p *Player) SetPlayerRewardLog(tp, tid int, addReward, subReward []data.ItemReward, desc interface{}) {
  403. p.Index += 1
  404. if len(p.PlayerReward) == 0 {
  405. p.PlayerReward = make(map[int]*PlayerRewardBase)
  406. }
  407. p.PlayerReward[p.Index] = &PlayerRewardBase{
  408. UserName: p.UserName,
  409. AddReward: addReward,
  410. SubReward: subReward,
  411. Desc: desc,
  412. Source: tp,
  413. SourceId: tid,
  414. CreateTime: mhayaTime.Now().Unix(),
  415. }
  416. }
  417. func (p *Player) SetPassiveInviteReward() {
  418. ret2, ok := data.DiscreteRuleConfig.Get(InvitePlayer)
  419. c, tok := mhayaString.ToInt(ret2.Condition)
  420. if !ok || !tok || c != p.Level {
  421. return
  422. }
  423. ret3, ok := data.DiscreteRuleConfig.Get(InviteVipPlayer)
  424. c, tok = mhayaString.ToInt(ret3.Condition)
  425. if !ok || !tok || c != p.Level {
  426. return
  427. }
  428. //被动邀请
  429. key := fmt.Sprintf("%v:1:%v", constant.InviteKey, p.UserName)
  430. pUid := mdb.RDB.Get(context.Background(), key).Val()
  431. pbase, err := mdb.RDB.Get(context.Background(), GetPlayBaseKey(pUid)).Bytes()
  432. if err != nil {
  433. return
  434. }
  435. mdb.RDB.Del(context.Background(), key)
  436. var base param.PlayerBase
  437. err = jsoniter.Unmarshal(pbase, &base)
  438. if err != nil {
  439. return
  440. }
  441. var addItem []data.ItemReward
  442. if p.IsVip == 0 {
  443. //主动邀请记录
  444. key = fmt.Sprintf("%v:%v:%v", constant.InviteKey, InvitePlayer, pUid)
  445. mdb.RDB.IncrBy(context.Background(), key, 1)
  446. addItem = append(addItem, ret2.Reward...)
  447. } else {
  448. key = fmt.Sprintf("%v:%v:%v", constant.InviteKey, InviteVipPlayer, pUid)
  449. mdb.RDB.IncrBy(context.Background(), key, 1)
  450. addItem = append(addItem, ret3.Reward...)
  451. }
  452. if base.IsLeader == 1 {
  453. ret, ok := data.DiscreteRuleConfig.Get(InvitePlayerByLeader)
  454. if !ok {
  455. return
  456. }
  457. addItem = append(addItem, ret.Reward...)
  458. }
  459. if p.InviteReward.IsClaim == 2 {
  460. p.InviteReward.Reward = []data.ItemReward{}
  461. p.InviteReward.IsClaim = 0
  462. p.InviteReward.RewardTime = 0
  463. }
  464. p.InviteReward.Reward = append(p.InviteReward.Reward, addItem...)
  465. }
  466. func (p *Player) SetInviteReward() {
  467. ret, ok := data.DiscreteRuleConfig.Get(InvitePlayerByLeader)
  468. if !ok {
  469. return
  470. }
  471. ret2, ok := data.DiscreteRuleConfig.Get(InvitePlayer)
  472. c, tok := mhayaString.ToInt(ret2.Condition)
  473. if !ok || !tok || c != p.Level {
  474. return
  475. }
  476. ret3, ok := data.DiscreteRuleConfig.Get(InviteVipPlayer)
  477. c, tok = mhayaString.ToInt(ret3.Condition)
  478. if !ok || !tok || c != p.Level {
  479. return
  480. }
  481. var addItem []data.ItemReward
  482. key1 := fmt.Sprintf("%v:%v:%v", constant.InviteKey, InvitePlayer, p.UserName)
  483. key2 := fmt.Sprintf("%v:%v:%v", constant.InviteKey, InviteVipPlayer, p.UserName)
  484. freeNum, _ := mdb.RDB.Get(context.Background(), key1).Int()
  485. VipNum, _ := mdb.RDB.Get(context.Background(), key2).Int()
  486. for i := 0; i < freeNum; i++ {
  487. addItem = append(addItem, ret2.Reward...)
  488. p.SetPlayerRewardLog(SourceInvite, InvitePlayer, []data.ItemReward{}, []data.ItemReward{}, 2)
  489. if p.IsLeader == 1 {
  490. addItem = append(addItem, ret.Reward...)
  491. p.SetPlayerRewardLog(SourceInvite, InvitePlayerByLeader, []data.ItemReward{}, []data.ItemReward{}, 2)
  492. }
  493. mdb.RDB.DecrBy(context.Background(), key1, 1)
  494. }
  495. for i := 0; i < VipNum; i++ {
  496. addItem = append(addItem, ret3.Reward...)
  497. p.SetPlayerRewardLog(SourceInvite, InviteVipPlayer, []data.ItemReward{}, []data.ItemReward{}, 2)
  498. if p.IsLeader == 1 {
  499. addItem = append(addItem, ret.Reward...)
  500. p.SetPlayerRewardLog(SourceInvite, InvitePlayerByLeader, []data.ItemReward{}, []data.ItemReward{}, 2)
  501. }
  502. mdb.RDB.DecrBy(context.Background(), key2, 1)
  503. }
  504. if (freeNum + VipNum) > 0 {
  505. SetRank(constant.RankSourceInvite, p.IsRobot, p.UserName, freeNum+VipNum)
  506. }
  507. if p.InviteReward.IsClaim == 2 {
  508. p.InviteReward.Reward = []data.ItemReward{}
  509. p.InviteReward.IsClaim = 0
  510. p.InviteReward.RewardTime = 0
  511. }
  512. p.InviteReward.Reward = append(p.InviteReward.Reward, addItem...)
  513. }
  514. func (p *Player) SetInvite(uid string) bool {
  515. key := fmt.Sprintf("%v:1:%v", constant.InviteKey, p.UserName)
  516. ret, ok := data.DiscreteRuleConfig.Get(InviteMaxExpireTime)
  517. if !ok {
  518. return false
  519. }
  520. t, _ := mhayaString.ToInt64(ret.Condition)
  521. err := mdb.RDB.Set(context.Background(), key, uid, time.Duration(t)*24*time.Hour).Err()
  522. if err != nil {
  523. return false
  524. }
  525. return true
  526. }
  527. func (p *Player) ClaimRankReward(id int) param.ChangeData {
  528. var resp param.ChangeData
  529. if rank, ok := p.RankReward[id]; ok {
  530. if rank.IsClaim == 0 && len(rank.Reward) > 0 {
  531. var addItem AddItem
  532. resp.AddItem = addItem.Add(rank.Reward)
  533. p.Item.AddItem(rank.Reward)
  534. p.RankReward[id].IsClaim = 1
  535. p.RankReward[id].ClaimTime = mhayaTime.Now().Unix()
  536. p.SetPlayerRewardLog(SourceRank, id, rank.Reward, []data.ItemReward{}, nil)
  537. }
  538. }
  539. p.LevelUp()
  540. return resp
  541. }
  542. func (p *Player) ClaimInviteReward(id int) param.ChangeData {
  543. var resp param.ChangeData
  544. if p.InviteReward.IsClaim == 0 {
  545. var addItem AddItem
  546. resp.AddItem = addItem.Add(p.InviteReward.Reward)
  547. p.Item.AddItem(p.InviteReward.Reward)
  548. p.InviteReward.IsClaim = 1
  549. p.InviteReward.RewardTime = mhayaTime.Now().Unix()
  550. p.SetPlayerRewardLog(SourceInvite, id, p.InviteReward.Reward, []data.ItemReward{}, nil)
  551. }
  552. p.LevelUp()
  553. return resp
  554. }
  555. func (p *Player) ClaimAchieveTaskReward(id int) param.ChangeData {
  556. var resp param.ChangeData
  557. if ach, ok := p.AchieveTask[id]; ok {
  558. if ach.Status == 1 && ach.RewardNum > 0 {
  559. var addItem AddItem
  560. resp.AddItem = addItem.Add(ach.Reward)
  561. p.Item.AddItem(ach.Reward)
  562. ach.RewardNum -= 1
  563. p.SetPlayerRewardLog(SourceAchieveTask, id, ach.Reward, []data.ItemReward{}, nil)
  564. }
  565. if ach.RewardNum == 0 {
  566. p.AchieveTask[id].Status = 2
  567. }
  568. }
  569. p.LevelUp()
  570. return resp
  571. }
  572. func (p *Player) ClaimDailyTaskReward(id int) param.ChangeData {
  573. var resp param.ChangeData
  574. if task, ok := p.DailyTask[id]; ok {
  575. if task.Status == 1 {
  576. var addItem AddItem
  577. resp.AddItem = addItem.Add(task.Reward)
  578. p.Item.AddItem(task.Reward)
  579. task.Status = 2
  580. p.SetPlayerRewardLog(SourceDailyTask, id, task.Reward, []data.ItemReward{}, nil)
  581. }
  582. }
  583. p.LevelUp()
  584. return resp
  585. }