|
@@ -1,84 +0,0 @@
|
|
|
-package activity
|
|
|
-
|
|
|
-import (
|
|
|
- "app.yhyue.com/moapp/jybase/common"
|
|
|
- "app.yhyue.com/moapp/message/db"
|
|
|
- "app.yhyue.com/moapp/message/util"
|
|
|
- "fmt"
|
|
|
- "log"
|
|
|
-
|
|
|
- "github.com/gogf/gf/v2/frame/g"
|
|
|
- "github.com/gogf/gf/v2/net/ghttp"
|
|
|
-)
|
|
|
-
|
|
|
-type MyPrize struct {
|
|
|
-}
|
|
|
-
|
|
|
-func (c *MyPrize) Show(r *ghttp.Request) {
|
|
|
- var (
|
|
|
- allShare []map[string]interface{}
|
|
|
- max = 4
|
|
|
- shareStatus = "share_interests" //默认邀请权益 用户判断
|
|
|
- )
|
|
|
- userid := r.Get("userId").String()
|
|
|
- aData, b := db.Mgo.FindOne("user_share", map[string]interface{}{"shared_uid": userid})
|
|
|
- if aData != nil && len(*aData) > 0 && b {
|
|
|
- max = 3
|
|
|
- allShare = append(allShare, *aData)
|
|
|
- }
|
|
|
- fmt.Println("被邀请人信息:", aData)
|
|
|
- query := map[string]interface{}{
|
|
|
- "share_uid": userid,
|
|
|
- "share_interests": map[string]interface{}{"$exists": 0},
|
|
|
- }
|
|
|
- //老版用户关联
|
|
|
- bData, _b := db.Mgo.Find("user_share", query, `{"createtime":1}`, nil, false, 0, max)
|
|
|
- if bData != nil && len(*bData) > 0 && _b {
|
|
|
- allShare = append(allShare, *bData...)
|
|
|
- }
|
|
|
- log.Println("老版邀请用户关联信息:", bData)
|
|
|
- //share_interests:不存在为老版本信息 1:赠送超级订阅与剑鱼币, 2赠送剑鱼币
|
|
|
- query["share_interests"] = map[string]interface{}{"$in": []int{1, 2}}
|
|
|
- cData, _s := db.Mgo.Find("user_share", query, "", nil, false, -1, -1)
|
|
|
- if cData != nil && len(*cData) > 0 && _s {
|
|
|
- allShare = append(allShare, *cData...)
|
|
|
- }
|
|
|
- log.Println("新版邀请用户关联信息:", cData)
|
|
|
- var allData []map[string]interface{}
|
|
|
-
|
|
|
- for _, data := range allShare {
|
|
|
- _d := make(map[string]interface{}) //超级订阅数据
|
|
|
- _ds := make(map[string]interface{}) //剑鱼币数据
|
|
|
- if data == nil || len(data) < 1 {
|
|
|
- continue
|
|
|
- }
|
|
|
- _ds["prizeMethods"] = 0
|
|
|
- _ds["createTime"] = data["createtime"]
|
|
|
- _ds["prizeName"] = "500剑鱼币"
|
|
|
- _d["prizeMethods"] = 0
|
|
|
- _d["prizeName"] = "7天超级订阅"
|
|
|
- _d["createTime"] = data["createtime"]
|
|
|
-
|
|
|
- if common.InterfaceToStr(data["share_uid"]) != userid {
|
|
|
- shareStatus = "shared_interests"
|
|
|
- _d["prizeMethods"] = 1
|
|
|
- _ds["prizeMethods"] = 1
|
|
|
- }
|
|
|
- if common.IntAll(data[shareStatus]) == 0 {
|
|
|
- allData = append(allData, _d)
|
|
|
- } else if common.IntAll(data[shareStatus]) == 1 {
|
|
|
- allData = append(allData, _d, _ds)
|
|
|
- } else if common.IntAll(data[shareStatus]) == 2 {
|
|
|
- allData = append(allData, _ds)
|
|
|
- }
|
|
|
- }
|
|
|
- util.SortData(&allData, "createTime", true)
|
|
|
- err := r.Response.WriteJson(g.Map{
|
|
|
- "error_code": 0,
|
|
|
- "error_msg": "",
|
|
|
- "data": allData,
|
|
|
- })
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
-}
|