发送站内信修改

handler/activity/newUserAward.go

@@ -1,6 +1,7 @@
 package activity
 
 import (
+	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"github.com/gogf/gf/v2/os/gtime"
 	"strconv"
 	"time"
@@ -29,7 +30,7 @@ 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{
+		err := rpc.SendMsg("新用户注册", &message.MultipleSaveMsgReq{
 			UserIds:    msg.E_userId,
 			Title:      PushConfig.Messages.NewUser.Title,
 			Content:    PushConfig.Messages.NewUser.Content,
@@ -40,7 +41,10 @@ func NewUserActivity(msg *model.Message) {
 			WxPushUrl:  PushConfig.Webdomain + wxUrl,
 			IosPushUrl: appUrl,
 		})
-		rpc.SendMsg("新用户注册", &message.MultipleSaveMsgReq{
+		if err != nil {
+			logger.Info("SendMsg Fail ", err)
+		}
+		err = rpc.SendMsg("新用户注册", &message.MultipleSaveMsgReq{
 			UserIds: msg.E_userId,
 			Title:   gcfg.Instance().MustGet(gctx.New(), "newUserAward.message.title", nil).String(),
 			Content: gcfg.Instance().MustGet(gctx.New(), "newUserAward.message.content", nil).String(),
@@ -54,6 +58,9 @@ func NewUserActivity(msg *model.Message) {
 			WxPushUrl:  gcfg.Instance().MustGet(gctx.New(), "newUserAward.message.mobileUrl", nil).String(),
 			IosPushUrl: gcfg.Instance().MustGet(gctx.New(), "newUserAward.message.mobileUrl", nil).String(),
 		})
+		if err != nil {
+			logger.Info("SendMsg Fail ", err)
+		}
 	}()
 	_ = award.GivenPoints(msg.E_userId, award.Points{
 		Num:          gcfg.Instance().MustGet(gctx.New(), "newUserAward.points", nil).Int64(),