message/rpc/message.go

package rpc

import (
	"fmt"
	"log"
	"strconv"
	"time"

	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
	"app.yhyue.com/moapp/jybase/go-logger/logger"
	. "app.yhyue.com/moapp/message/config"
	. "bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
	"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 {
	wxUrl := "/front/sess/" + Se.EncodeString(userId+",_id,identityKeep,") + "__" + Se.EncodeString(PushConfig.Messages.NewUser.MobileUrl)
	appUrl := "/jyapp/free/sess/" + Se.EncodeString(userId+",_id,"+strconv.Itoa(int(time.Now().Unix()))+",") + "__" + Se.EncodeString(PushConfig.Messages.NewUser.MobileUrl)
	req := &message.MultipleSaveMsgReq{
		UserIds:    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,
	}
	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), "新用户注册发送增送剑鱼币消息失败")
	}
}