message/handler/activity/newUserAward.go

package activity

import (
	"strconv"
	"time"

	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
	. "app.yhyue.com/moapp/message/config"
	"app.yhyue.com/moapp/message/handler/award"
	"app.yhyue.com/moapp/message/model"
	"app.yhyue.com/moapp/message/rpc"
	. "bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
	"github.com/gogf/gf/v2/os/gcfg"
	"github.com/gogf/gf/v2/os/gctx"
)

/*
新用户注册奖励
活动详情
非邀请注册新用户可获得500剑鱼币奖励
*/

const (
	NewUserAwardActivityName = "newUserAward"
)

func NewUserActivity(msg *model.Message) {
	go func() {
		wxUrl := "/front/sess/" + Se.EncodeString(msg.E_userId+",_id,identityKeep,") + "__" + Se.EncodeString(PushConfig.Messages.NewUser.MobileUrl)
		appUrl := "/jyapp/free/sess/" + Se.EncodeString(msg.E_userId+",_id,"+strconv.Itoa(int(time.Now().Unix()))+",") + "__" + Se.EncodeString(PushConfig.Messages.NewUser.MobileUrl)
		rpc.SendMsg("新用户注册", &message.MultipleSaveMsgReq{
			UserIds:    msg.E_userId,
			Title:      PushConfig.Messages.NewUser.Title,
			Content:    PushConfig.Messages.NewUser.Content,
			MsgType:    PushConfig.Messages.NewUser.MsgType,
			Link:       PushConfig.Messages.NewUser.PcUrl + "," + PushConfig.Messages.NewUser.MobileUrl + "," + PushConfig.Messages.NewUser.MobileUrl,
			Appid:      PushConfig.Messages.NewUser.Appid,
			AppPushUrl: appUrl,
			WxPushUrl:  PushConfig.Webdomain + wxUrl,
			IosPushUrl: appUrl,
		})
	}()
	_ = award.GivenPoints(msg.E_userId, award.Points{
		Num:          gcfg.Instance().MustGet(gctx.New(), "newUserAward.points", nil).Int64(),
		Type:         1002,
		ActivityCode: NewUserAwardActivityName,
		Date:         msg.E_time,
		Desc:         "新用户注册奖励",
	})
}