user_noviceWelfare.go 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. package gatesink
  2. import (
  3. "bet24.com/log"
  4. activityservice "bet24.com/servers/micros/activityservice/proto"
  5. "encoding/json"
  6. )
  7. // 处理新手福利指令
  8. func (this *user) onNoviceWelfareMsg(msg, data string) {
  9. switch msg {
  10. case "getSysNoviceWelfare": // 获取系统新手福利
  11. this.getSysNoviceWelfare(msg)
  12. case "getUserNoviceWelfare": // 获取用户新手福利
  13. this.getUserNoviceWelfare(msg)
  14. case "claimNoviceWelfareAward": // 领取新手福利奖励
  15. this.claimNoviceWelfareAward(msg, data)
  16. case "getNoviceWelfareGiftPacks":
  17. this.getNoviceWelfareGiftPacks(msg, data)
  18. case "getNoviceWelfareGiftPackUserTerms":
  19. this.getNoviceWelfareGiftPackUserTerms(msg, data)
  20. case "claimNoviceWelfareGiftPack":
  21. this.claimNoviceWelfareGiftPack(msg, data)
  22. default:
  23. log.Release("user.onNoviceWelfareMsg unhandled msg %s", msg)
  24. }
  25. }
  26. // 获取系统新手福利
  27. func (this *user) getSysNoviceWelfare(msg string) {
  28. resp := activityservice.GetSysNoviceWelfare()
  29. d, _ := json.Marshal(resp)
  30. this.WriteMsg(msg, string(d))
  31. return
  32. }
  33. // 获取用户新手福利
  34. func (this *user) getUserNoviceWelfare(msg string) {
  35. resp := activityservice.GetUserNoviceWelfare(this.getUserId())
  36. d, _ := json.Marshal(resp)
  37. this.WriteMsg(msg, string(d))
  38. return
  39. }
  40. // 领取新手福利奖励
  41. func (this *user) claimNoviceWelfareAward(msg, data string) {
  42. var req activityservice.Request
  43. ret := "fail"
  44. if err := json.Unmarshal([]byte(data), &req); err != nil {
  45. log.Error("user.claimNoviceWelfareAward unmarshal fail %v", err)
  46. this.WriteMsg(msg, ret)
  47. return
  48. }
  49. b := activityservice.ClaimNoviceWelfareAward(this.getUserId(), req.DayIndex, req.IsFinalPackage)
  50. if b {
  51. ret = "ok"
  52. }
  53. this.WriteMsg(msg, ret)
  54. return
  55. }
  56. // 获取新手购买礼包
  57. func (this *user) getNoviceWelfareGiftPacks(msg string, data string) {
  58. this.WriteMsg(msg, activityservice.GetGiftPackages(this.getUserId()))
  59. return
  60. }
  61. // 获取我的礼包状态
  62. func (this *user) getNoviceWelfareGiftPackUserTerms(msg string, data string) {
  63. this.WriteMsg(msg, activityservice.GetUserGiftPackages(this.getUserId()))
  64. return
  65. }
  66. func (this *user) claimNoviceWelfareGiftPack(msg, data string) {
  67. var req activityservice.Request
  68. var ret struct {
  69. Success bool
  70. ErrorMsg string
  71. }
  72. if err := json.Unmarshal([]byte(data), &req); err != nil {
  73. log.Error("user.claimNoviceWelfareGiftPack unmarshal fail %s", data)
  74. ret.ErrorMsg = "Invalid argument"
  75. d, _ := json.Marshal(ret)
  76. this.WriteMsg(msg, string(d))
  77. return
  78. }
  79. ret.Success, ret.ErrorMsg = activityservice.ClaimGiftPack(this.getUserId(), req.PackageId, req.TermId)
  80. d, _ := json.Marshal(ret)
  81. this.WriteMsg(msg, string(d))
  82. return
  83. }