message/rpc/message.go

package rpc

import (
	"fmt"
	"log"

	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
	"app.yhyue.com/moapp/jybase/go-logger/logger"
	"github.com/gogf/gf/v2/os/gcfg"
	"github.com/gogf/gf/v2/os/gctx"
	"github.com/zeromicro/go-zero/core/discov"
	"github.com/zeromicro/go-zero/zrpc"
)

var messageClient zrpc.Client

func init() {
	var err error
	messageClient, err = zrpc.NewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: gcfg.Instance().MustGet(gctx.New(), "etcd.address", nil).Strings(),
			Key:   gcfg.Instance().MustGet(gctx.New(), "etcd.messageKey", nil).String(),
		},
	})
	if err != nil {
		log.Fatalln(err)
	}
}

//新用户注册，发送增送剑鱼币消息
func SendNewUserMsg(userId string) error {
	req := &message.MultipleSaveMsgReq{
		UserIds:    userId,
		Title:      "做任务赚好礼",
		Content:    "7天内完成新手任务，额外赠送超级订阅7天体验。获取更多采购项目信息，快速对接项目联系人！",
		MsgType:    1,
		Link:       "/home/work-bench/app/points/earn,/jy_mobile/points/earn,/jy_mobile/points/earn",
		Appid:      "10000",
		AppPushUrl: "/jy_mobile/points/earn",
		WxPushUrl:  "/jy_mobile/points/earn",
		IosPushUrl: "/jy_mobile/points/earn",
	}
	resp, err := messageclient.NewMessage(messageClient).MultipleSaveMsg(gctx.New(), req)
	if err != nil {
		return fmt.Errorf(fmt.Sprintf("%+v", req), "新用户注册发送增送剑鱼币消息 error", err)
	}
	if resp.Code == 1 {
		logger.Info(fmt.Sprintf("%+v", req), "新用户注册已成功发送增送剑鱼币消息")
		return nil
	} else {
		return fmt.Errorf(fmt.Sprintf("%+v", req), "新用户注册发送增送剑鱼币消息失败")
	}
}