player.go 20 KB

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