fix：分享有礼我的奖励

services/activity/myPrize.go

@@ -0,0 +1,81 @@
+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
+	)
+	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,
+		"giving_rights": 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)
+	//giving_rights：不存在为老版本信息 1:赠送超级订阅与剑鱼币, 2赠送剑鱼币
+	delete(query, "giving_rights")
+	query["giving_rights"] = 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 {
+			_d["prizeMethods"] = 1
+			_ds["prizeMethods"] = 1
+		}
+		if common.IntAll(data["giving_rights"]) == 0 {
+			allData = append(allData, _d)
+		} else if common.IntAll(data["giving_rights"]) == 1 {
+			allData = append(allData, _d, _ds)
+		} else if common.IntAll(data["giving_rights"]) == 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
+	}
+}

services/init.go

@@ -1,7 +1,8 @@
 package services
 
 import (
-	"app.yhyue.com/moapp/message/services/share"
+	"app.yhyue.com/moapp/message/services/activity"
+	"app.yhyue.com/moapp/message/services/activity/share"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"
 )
@@ -13,5 +14,7 @@ func InitActivityServer() *ghttp.Server {
 
 	//活动
 
+	//我的奖励
+	activityServer.BindObject("/myPrize", new(activity.MyPrize))
 	return activityServer
 }

util/utils.go

@@ -0,0 +1 @@
+package util