互动
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

156 lines
5.3 KiB

5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
4 years ago
5 years ago
4 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
  1. package client
  2. import (
  3. "fmt"
  4. "hudongzhuanjia/controllers"
  5. "hudongzhuanjia/models"
  6. activity_service "hudongzhuanjia/services/activity"
  7. pay_service "hudongzhuanjia/services/pay"
  8. ws_send_service "hudongzhuanjia/services/ws_send"
  9. "hudongzhuanjia/utils/code"
  10. "hudongzhuanjia/utils/define"
  11. "math/rand"
  12. "time"
  13. )
  14. type ShakeRedEnvelopeCtl struct {
  15. controllers.AuthorCtl
  16. }
  17. func (t *ShakeRedEnvelopeCtl) Status() {
  18. ruleId := t.MustGetInt64("shake_red_envelope_rule_id")
  19. rule := new(models.ShakeRedEnvelopeRule)
  20. exist, err := models.Get(rule, ruleId)
  21. t.CheckErr(err)
  22. t.Assert(exist, code.MSG_SHAKERB_RECORD_NOT_EXIST, "摇红包规则不存在")
  23. t.JSON(map[string]interface{}{
  24. "status": rule.ShakeRedEnvelopeStatus,
  25. })
  26. }
  27. func (t *ShakeRedEnvelopeCtl) Shake() {
  28. ruleId := t.MustGetInt64("shake_red_envelope_rule_id")
  29. userId := t.MustGetUID()
  30. areaId := t.MustGetAreaId()
  31. // 查询摇红包规则
  32. rule := new(models.ShakeRedEnvelopeRule)
  33. exist, err := models.Get(rule, ruleId)
  34. t.CheckErr(err)
  35. t.Assert(exist, code.MSG_SHAKERB_RULE_NOT_EXIST, "摇红包规则不存在")
  36. t.CheckRunning(rule.ShakeRedEnvelopeStatus)
  37. // 查询摇红包活动主id, is_pay=1给钱了,给摇
  38. envelope := new(models.ShakeRedEnvelopeActivity)
  39. exist, err = envelope.GetPayedById(rule.ShakeRedEnvelopeActivityId)
  40. t.CheckErr(err)
  41. t.Assert(exist, code.MSG_SHAKERB_NOT_EXIST, "摇红包不存在")
  42. activity := new(models.Activity)
  43. exist, err = models.Get(activity, envelope.ActivityId)
  44. t.CheckErr(err)
  45. t.Assert(exist, code.MSG_ACTIVITY_NOT_EXIST, "互动不存在")
  46. t.CheckRunning(activity.Status)
  47. area := models.AreaStore{}
  48. exist, err = models.Get(&area, areaId)
  49. t.CheckErr(err)
  50. t.Assert(exist, code.MSG_AREASTORE_NOT_EXIST, "地区不存在")
  51. moduleService, exist, err := activity_service.GetModuleService(define.MODULE_SHAKRB, activity.Id)
  52. t.CheckErr(err)
  53. t.Assert(exist, code.MSG_MODULE_NOT_EXIST, "活动模块不存在")
  54. record := new(models.ShakeRedEnvelopeRecord) /// 之后使用, 存入乐观锁
  55. if moduleService.BesideRepeat == define.MODULE_BESIDE_REPEAT { // 剔除摇过红包的用户
  56. exist, err = record.ExistRecord(activity.RehearsalId, rule.Id, userId)
  57. t.CheckErr(err)
  58. t.Assert(!exist, code.MSG_SHAKERB_RECORD_NOT_HIT, "您已经摇过红包了,请等待下一轮.") // 不存在继续往下走
  59. }
  60. // done: 增加概率, 修改概率
  61. r := rand.New(rand.NewSource(time.Now().UnixNano()))
  62. t.Assert(r.Float64()*100 <= rule.Probability, code.MSG_SHAKERB_RECORD_NOT_HIT, "您与红包擦肩而过") // 必须在红包概率以内才能获取
  63. // 增加session 或者乐观锁
  64. exist, err = record.GetByRuleId(ruleId, activity.RehearsalId, 0)
  65. t.CheckErr(err)
  66. t.Assert(exist, code.MSG_SHAKERB_RECORD_NOT_HIT, "红包已经派发完毕")
  67. // 查询用户
  68. user := new(models.User)
  69. exist, err = models.Get(user, userId)
  70. t.CheckErr(err)
  71. t.Assert(exist, code.MSG_USER_NOT_EXIST, "用户不存在")
  72. record.IsDraw = 0
  73. record.UserId = userId
  74. record.AreaId = areaId
  75. row, err := models.Update(record.Id, record, "is_draw", "user_id", "area_id")
  76. t.CheckErr(err)
  77. t.Assert(row == 1, code.MSG_SHAKERB_RECORD_NOT_HIT, "您与红包擦肩而过") // 那么 row == 1 为已经成功抢到
  78. // 记录红包 ---> 非彩排才能
  79. if activity.RehearsalId == 0 {
  80. result, err := pay_service.SendRedPack("欧轩互动", user.Openid, "红包只会越抢越多",
  81. "直播抢红包活动", "抢的多,赚得多", int(record.Amount*100), 1, 2)
  82. t.CheckErr(err)
  83. record.MchBillno = result.MchBillno
  84. models.Update(record.Id, record, "mch_billno")
  85. }
  86. // 通知大屏
  87. total, err := new(models.ShakeRedEnvelopeRecord).Total(activity.Id, activity.RehearsalId, envelope.Id, rule.Id)
  88. remaining, err := new(models.ShakeRedEnvelopeRecord).Count(activity.Id, activity.RehearsalId, envelope.Id, rule.Id, -1)
  89. t.CheckErr(err)
  90. go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id),
  91. define.TYPE_H5USER, userId, map[string]interface{}{
  92. "customer_id": area.CustomerId,
  93. "user_id": user.Id,
  94. "type": "shake_rb",
  95. "data": map[string]interface{}{
  96. "amount": record.Amount,
  97. "nickname": user.Nickname,
  98. "avatar": user.Avatar,
  99. "total": total - remaining, //
  100. "remaining": remaining, //
  101. },
  102. })
  103. go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id),
  104. define.TYPE_CUSTOMER, area.CustomerId, map[string]interface{}{
  105. "customer_id": area.CustomerId,
  106. "user_id": user.Id,
  107. "type": "shake_rb",
  108. "data": map[string]interface{}{
  109. "amount": record.Amount,
  110. "nickname": user.Nickname,
  111. "avatar": user.Avatar,
  112. "total": total - remaining, //
  113. "remaining": remaining, //
  114. },
  115. })
  116. t.JSON(map[string]interface{}{
  117. "amount": record.Amount,
  118. "shake_red_envelope_record_id": record.Id,
  119. })
  120. }
  121. // 用户红包
  122. func (t *ShakeRedEnvelopeCtl) UserRedEnvelopes() {
  123. uid := t.MustGetUID()
  124. activityId := t.MustGetInt64("activity_id")
  125. activity := new(models.Activity)
  126. exist, err := models.Get(activity, activityId)
  127. t.CheckErr(err)
  128. t.Assert(exist, code.MSG_ACTIVITY_NOT_EXIST, "活动不存在")
  129. records, err := models.GetRedEnvelopesByUserId(uid, activityId, activity.RehearsalId)
  130. t.CheckErr(err)
  131. t.JSON(map[string]interface{}{
  132. "list": records,
  133. "total": len(records),
  134. })
  135. }