jyActivity.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317
  1. package activity
  2. import (
  3. dateFormate "app.yhyue.com/moapp/jybase/date"
  4. "app.yhyue.com/moapp/jybase/go-logger/logger"
  5. "app.yhyue.com/moapp/jybase/redis"
  6. "app.yhyue.com/moapp/message/db"
  7. "app.yhyue.com/moapp/message/handler/award"
  8. "fmt"
  9. "github.com/gogf/gf/v2/os/gcfg"
  10. "github.com/gogf/gf/v2/os/gctx"
  11. "github.com/gogf/gf/v2/os/gtime"
  12. "github.com/gogf/gf/v2/util/gconv"
  13. "sync"
  14. "time"
  15. )
  16. /*
  17. 投标人专属免费计划
  18. */
  19. type JyActivity struct {
  20. T1, T2, Ed time.Time //预热活动、开始时间、结束时间
  21. DailyClock string //预热活动每天开始时间
  22. ActivityCode string //活动code
  23. Missions map[string]struct { //任务
  24. Points int `json:"points"`
  25. Schedule int `json:"schedule"`
  26. }
  27. ScheduleReward map[int]struct { //进度奖励
  28. SubVip int `json:"subvip"`
  29. Schedule int `json:"schedule"`
  30. }
  31. DoubleEleven bool //22年双十一活动开关
  32. }
  33. const (
  34. BidderPlanRedis = "main" //redis缓存库名
  35. PowerCacheDb = "newother"
  36. PowerCacheKey = "bigmember_power_3_%s"
  37. IsGetUserBaseInfoRedisKey = "baseinfo_%s"
  38. BidderPlanScheduleCache = "bidderPlan_v1_ScheduleValue_%s" //活动累计进度
  39. BidderPlanFastClickCheck = "bidderPlanFastClickValue_%s" //防止连点
  40. BidderPlanScheduleAwardStatus = "bidderPlan_v1_ScheduleAward_%s_%d" //奖励领取状态
  41. BidderPlanBuySVipStatus = "bidderPlanActivity_v1_BuySVipCacheKey_%s" //购买
  42. BidderPlanInviteMissionsStatus = "bidderPlanActivity_v1_InviteCacheKey_%s" //邀请
  43. BidderPlanShareMissionsStatus = "bidderPlanActivity_v1_ShareCacheKey_%s" //分享
  44. BidderPlanDailyBoonKey = "bidderPlanActivity_v1_DailyBoon_%s" //领取每日限量福利
  45. BidderPlanHasDailyBoonKey = "bidderPlanActivity_v1_HasDailyBoon_%s" //是否领取过每日限量福利
  46. BidderPlanShare = "bidderPlanActivity_v1_ShareOk_%s" //是否分享
  47. QuestionnaireSubmit = "questionnaireSubmit_%s" //是否已提交问卷
  48. WinnerInfoKey = "winnerinfokey_22_12_12"
  49. )
  50. var (
  51. MembershipDay *JyActivity
  52. ActivityLock = &sync.Mutex{}
  53. )
  54. func init() {
  55. MembershipDay = &JyActivity{
  56. T1: gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "jyactivity.dateRange.t1").String(), "2006-01-02T15:04:05Z").Time,
  57. T2: gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "jyactivity.dateRange.t2").String(), "2006-01-02T15:04:05Z").Time,
  58. Ed: gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "jyactivity.dateRange.ed").String(), "2006-01-02T15:04:05Z").Time,
  59. }
  60. MembershipDay.DailyClock = gcfg.Instance().MustGet(gctx.New(), "jyactivity.dailyBoon.clock").String()
  61. MembershipDay.ActivityCode = gcfg.Instance().MustGet(gctx.New(), "jyactivity.code").String()
  62. //加载任务
  63. if loadMissionsErr := gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions").Scan(&MembershipDay.Missions); loadMissionsErr != nil {
  64. logger.Error(fmt.Sprintf("JyBidderPlan 加载任务异常 %v", loadMissionsErr))
  65. }
  66. //加载进度奖励
  67. if loadScheduleErr := gcfg.Instance().MustGet(gctx.New(), "jyactivity.scheduleReward").Scan(&MembershipDay.ScheduleReward); loadScheduleErr != nil {
  68. logger.Error(fmt.Sprintf("JyBidderPlan 加载进度异常 %v", loadScheduleErr))
  69. }
  70. MembershipDay.DoubleEleven = gcfg.Instance().MustGet(gctx.New(), "jyactivity.power.switch", false).Bool()
  71. }
  72. // InActivity 是否在活动时间内
  73. // bTime 是否在预热时间段内
  74. // iTime 是否在正式活动时间内
  75. // aTime 是否在全部活动时间内
  76. func (BP *JyActivity) InActivity() (bTime, iTime, aTime bool) {
  77. now := time.Now()
  78. bTime = now.After(MembershipDay.T1) && now.Before(MembershipDay.T2)
  79. aTime = now.After(MembershipDay.T1) && now.Before(MembershipDay.Ed)
  80. if bTime {
  81. return
  82. }
  83. iTime = now.After(MembershipDay.T2) && now.Before(MembershipDay.Ed)
  84. return
  85. }
  86. // cacheLong 缓存时间
  87. func (BP *JyActivity) cacheLong() int {
  88. return 60 * 60 * 24 * 30
  89. }
  90. // FastClickCheck 连点处理,防止重复领取
  91. func (BP *JyActivity) FastClickCheck(userId string) bool {
  92. key := fmt.Sprintf(BidderPlanFastClickCheck, userId)
  93. if redis.Incr(BidderPlanRedis, key) == 1 {
  94. _ = redis.SetExpire(BidderPlanRedis, key, 1)
  95. return true
  96. }
  97. return false
  98. }
  99. // GetSchedule 查询活动任务进度
  100. func (BP *JyActivity) GetSchedule(userId string) int {
  101. return -redis.GetInt(BidderPlanRedis, fmt.Sprintf(BidderPlanScheduleCache, userId))
  102. }
  103. func (BP *JyActivity) GetScheduleQuery(userId string, schedule int) (status int) {
  104. if BP.GetSchedule(userId) < schedule {
  105. return 0
  106. }
  107. key := fmt.Sprintf(BidderPlanScheduleAwardStatus, userId, schedule)
  108. if redis.Get(BidderPlanRedis, key) == nil {
  109. status = gconv.Int(redis.Incr(BidderPlanRedis, key))
  110. _ = redis.SetExpire(BidderPlanRedis, key, BP.cacheLong())
  111. } else {
  112. status = redis.GetInt(BidderPlanRedis, key)
  113. }
  114. if status > 1 {
  115. status = 1
  116. }
  117. return
  118. }
  119. // ScheduleGiven 活动任务进度奖励
  120. func (BP *JyActivity) ScheduleGiven(userId string, schedule int) error {
  121. if _, inActivity, _ := BP.InActivity(); !inActivity {
  122. return fmt.Errorf("不在活动时间内")
  123. }
  124. if BP.GetScheduleQuery(userId, schedule) != 1 {
  125. return fmt.Errorf("非领取状态")
  126. }
  127. scheduleAward, ok := BP.ScheduleReward[schedule]
  128. if !ok {
  129. return fmt.Errorf("未知请求")
  130. }
  131. if err := award.GivenSubVip(userId, award.SubVip{
  132. Num: gconv.Int64(scheduleAward.SubVip),
  133. ActivityCode: BP.ActivityCode,
  134. Desc: fmt.Sprintf("达到%d剑鱼币", schedule),
  135. Date: time.Now().Unix(),
  136. }); err != nil {
  137. return fmt.Errorf("领取奖励异常")
  138. }
  139. key := fmt.Sprintf(BidderPlanScheduleAwardStatus, userId, schedule)
  140. redis.Put(BidderPlanRedis, key, -1, BP.cacheLong())
  141. return nil
  142. }
  143. // AddSchedule 增加活动进度
  144. func (BP *JyActivity) AddSchedule(userId string, value int) (after int) {
  145. if value > 0 {
  146. key := fmt.Sprintf(BidderPlanScheduleCache, userId)
  147. after = -gconv.Int(redis.Decrby(BidderPlanRedis, key, value))
  148. if value == after { //首次设置过期值
  149. _ = redis.SetExpire(BidderPlanRedis, key, BP.cacheLong())
  150. }
  151. }
  152. return
  153. }
  154. // FreeSubscribe 免费订阅
  155. type FreeSubscribe struct {
  156. OAreaP map[string]interface{} `json:"o_area"`
  157. AKey []interface{} `json:"a_key"`
  158. }
  159. // MissionsSVipBuyQuery 购买超级订阅
  160. // status:0 未完成 1 待领取 -1已领取
  161. // 是否购买超级订阅
  162. func (BP *JyActivity) MissionsSVipBuyQuery(userId string) (status int) {
  163. finish := func() bool {
  164. count := db.Mysql.CountBySql(`SELECT count(id) FROM dataexport_order WHERE product_type ='VIP订阅' AND order_money > 0 AND order_status>0 AND create_time > ? AND create_time < ? AND user_id=? `, BP.T2.Format(dateFormate.Date_Full_Layout), BP.Ed.Format(dateFormate.Date_Full_Layout), userId)
  165. if count > 0 {
  166. return true
  167. }
  168. return false
  169. }()
  170. if !finish {
  171. return 0
  172. }
  173. key := fmt.Sprintf(BidderPlanBuySVipStatus, userId)
  174. if redis.Get(BidderPlanRedis, key) == nil {
  175. status = gconv.Int(redis.Incr(BidderPlanRedis, key))
  176. _ = redis.SetExpire(BidderPlanRedis, key, BP.cacheLong())
  177. } else {
  178. status = redis.GetInt(BidderPlanRedis, key)
  179. }
  180. if status > 1 {
  181. status = 1
  182. }
  183. return
  184. }
  185. // MissionsSVipBuyGiven 订阅任务领取奖励
  186. func (BP *JyActivity) MissionsSVipBuyGiven(userId string) error {
  187. if _, inActivity, _ := BP.InActivity(); !inActivity {
  188. return fmt.Errorf("不在活动时间内")
  189. }
  190. status := BP.MissionsSVipBuyQuery(userId)
  191. if status != 1 {
  192. return fmt.Errorf("非领取状态")
  193. }
  194. if givenPointsErr := award.GivenPoints(userId, award.Points{
  195. Num: gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.buysubvip.points").Int64(),
  196. Type: 1010,
  197. ActivityCode: BP.ActivityCode,
  198. Desc: "购买超级订阅任务完成",
  199. Date: time.Now().Unix(),
  200. }); givenPointsErr != nil {
  201. return fmt.Errorf("领取奖励异常")
  202. }
  203. //设置已领取
  204. redis.Put(BidderPlanRedis, fmt.Sprintf(BidderPlanBuySVipStatus, userId), -1, BP.cacheLong())
  205. //增加任务进度
  206. BP.AddSchedule(userId, gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.buysubvip.schedule").Int())
  207. return nil
  208. }
  209. // MissionsInviteQuery 邀请任务状态查询
  210. // status:0 未完成 1 待领取 -1已领取
  211. func (BP *JyActivity) MissionsInviteQuery(userId string) (status int) {
  212. status = redis.GetInt(BidderPlanRedis, fmt.Sprintf(BidderPlanInviteMissionsStatus, userId))
  213. if status > 1 {
  214. status = 1
  215. }
  216. return status
  217. }
  218. // MissionsInviteGiven 邀请任务奖励领取
  219. func (BP *JyActivity) MissionsInviteGiven(userId string) error {
  220. if _, inActivity, _ := BP.InActivity(); !inActivity {
  221. return fmt.Errorf("不在活动时间内")
  222. }
  223. status := BP.MissionsInviteQuery(userId)
  224. if status != 1 {
  225. return fmt.Errorf("非领取状态")
  226. }
  227. //领取
  228. if givenPointsErr := award.GivenPoints(userId, award.Points{
  229. Num: gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.invite.points").Int64(),
  230. Type: 1008,
  231. ActivityCode: BP.ActivityCode,
  232. Desc: "邀请领好礼任务完成",
  233. Date: time.Now().Unix(),
  234. }); givenPointsErr != nil {
  235. return fmt.Errorf("领取奖励异常")
  236. }
  237. //设置已领取
  238. redis.Put(BidderPlanRedis, fmt.Sprintf(BidderPlanInviteMissionsStatus, userId), -1, BP.cacheLong())
  239. //增加任务进度
  240. BP.AddSchedule(userId, gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.invite.schedule").Int())
  241. return nil
  242. }
  243. // MissionsShareQuery 分享活动
  244. // status:0 未完成 1 待领取 -1已领取
  245. func (BP *JyActivity) MissionsShareQuery(userId string) (status int) {
  246. finished, _ := redis.Exists(BidderPlanRedis, fmt.Sprintf(BidderPlanShare, userId))
  247. if !finished {
  248. return 0
  249. }
  250. key := fmt.Sprintf(BidderPlanShareMissionsStatus, userId)
  251. if redis.Get(BidderPlanRedis, key) == nil {
  252. status = gconv.Int(redis.Incr(BidderPlanRedis, key))
  253. _ = redis.SetExpire(BidderPlanRedis, key, BP.cacheLong())
  254. } else {
  255. status = redis.GetInt(BidderPlanRedis, key)
  256. }
  257. if status > 1 {
  258. status = 1
  259. }
  260. return
  261. }
  262. // MissionsShareGiven 分享活动
  263. func (BP *JyActivity) MissionsShareGiven(userId string) error {
  264. if _, inActivity, _ := BP.InActivity(); !inActivity {
  265. return fmt.Errorf("不在活动时间内")
  266. }
  267. status := BP.MissionsShareQuery(userId)
  268. if status != 1 {
  269. return fmt.Errorf("非领取状态")
  270. }
  271. if givenPointsErr := award.GivenPoints(userId, award.Points{
  272. Num: gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.share.points").Int64(),
  273. Type: 1011,
  274. ActivityCode: BP.ActivityCode,
  275. Desc: "分享活动任务完成",
  276. Date: time.Now().Unix(),
  277. }); givenPointsErr != nil {
  278. return fmt.Errorf("领取奖励异常")
  279. }
  280. //设置已领取
  281. redis.Put(BidderPlanRedis, fmt.Sprintf(BidderPlanShareMissionsStatus, userId), -1, BP.cacheLong())
  282. //增加任务进度
  283. BP.AddSchedule(userId, gcfg.Instance().MustGet(gctx.New(), "jyactivity.missions.share.schedule").Int())
  284. return nil
  285. }