player.go 20 KB

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