|
@@ -6,6 +6,7 @@ import (
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
|
|
"app.yhyue.com/moapp/MessageCenter/util"
|
|
"app.yhyue.com/moapp/MessageCenter/util"
|
|
"context"
|
|
"context"
|
|
|
|
+ "encoding/json"
|
|
"github.com/tal-tech/go-zero/core/logx"
|
|
"github.com/tal-tech/go-zero/core/logx"
|
|
"log"
|
|
"log"
|
|
)
|
|
)
|
|
@@ -39,7 +40,7 @@ func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*t
|
|
errCount := 0
|
|
errCount := 0
|
|
lsi := l.svcCtx.MessageCenter
|
|
lsi := l.svcCtx.MessageCenter
|
|
msgInfo := req.MsgInfo
|
|
msgInfo := req.MsgInfo
|
|
- log.Println("###############", int64(util.IntAll(msgInfo["msgLogId"])))
|
|
|
|
|
|
+ showBuoyValue, _ := msgInfo["showBuoy"].(json.Number).Int64()
|
|
_, err := lsi.MultipleSaveMsg(l.ctx, &messageclient.MultipleSaveMsgReq{
|
|
_, err := lsi.MultipleSaveMsg(l.ctx, &messageclient.MultipleSaveMsgReq{
|
|
Appid: util.ObjToString(msgInfo["appid"]),
|
|
Appid: util.ObjToString(msgInfo["appid"]),
|
|
SendUserId: util.ObjToString(msgInfo["sendUserId"]),
|
|
SendUserId: util.ObjToString(msgInfo["sendUserId"]),
|
|
@@ -52,7 +53,7 @@ func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*t
|
|
UserIds: req.UserIds,
|
|
UserIds: req.UserIds,
|
|
UserNames: req.UserNames,
|
|
UserNames: req.UserNames,
|
|
MsgLogId: int64(util.IntAll(msgInfo["msgLogId"])),
|
|
MsgLogId: int64(util.IntAll(msgInfo["msgLogId"])),
|
|
- ShowBuoy: int64(util.IntAll(msgInfo["showBuoy"])),
|
|
|
|
|
|
+ ShowBuoy: showBuoyValue,
|
|
ShowContent: util.ObjToString(msgInfo["showContent"]),
|
|
ShowContent: util.ObjToString(msgInfo["showContent"]),
|
|
})
|
|
})
|
|
if err != nil {
|
|
if err != nil {
|