|
@@ -11,6 +11,7 @@ import (
|
|
"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
|
|
"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
|
|
"github.com/microcosm-cc/bluemonday"
|
|
"github.com/microcosm-cc/bluemonday"
|
|
|
|
|
|
|
|
+ "github.com/gogf/gf/v2/util/gconv"
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
)
|
|
)
|
|
|
|
|
|
@@ -40,7 +41,14 @@ func init() {
|
|
}
|
|
}
|
|
|
|
|
|
func (l *MessageAddLogic) MessageAdd(req *types.MessageEntity) (*types.CommonRes, error) {
|
|
func (l *MessageAddLogic) MessageAdd(req *types.MessageEntity) (*types.CommonRes, error) {
|
|
-
|
|
|
|
|
|
+ receiverIds := []int64{}
|
|
|
|
+ for _, v := range req.ReceiverIds {
|
|
|
|
+ receiverIds = append(receiverIds, gconv.Int64(encrypt.SE.Decode4Hex(v)))
|
|
|
|
+ }
|
|
|
|
+ groupIds := []int64{}
|
|
|
|
+ for _, v := range req.GroupIds {
|
|
|
|
+ groupIds = append(groupIds, gconv.Int64(encrypt.SE.Decode4Hex(v)))
|
|
|
|
+ }
|
|
resp, err := l.svcCtx.Message.SaveMessage(l.ctx, &messagecenter.MessageEntity{
|
|
resp, err := l.svcCtx.Message.SaveMessage(l.ctx, &messagecenter.MessageEntity{
|
|
OwnType: req.OwnType,
|
|
OwnType: req.OwnType,
|
|
Title: req.Title,
|
|
Title: req.Title,
|
|
@@ -54,8 +62,8 @@ func (l *MessageAddLogic) MessageAdd(req *types.MessageEntity) (*types.CommonRes
|
|
ReceiveId: quitl.Int64All(encrypt.SE.Decode4Hex(req.ReceiveId)),
|
|
ReceiveId: quitl.Int64All(encrypt.SE.Decode4Hex(req.ReceiveId)),
|
|
NewUserId: req.NewUserId,
|
|
NewUserId: req.NewUserId,
|
|
EntUserId: req.EntUserId,
|
|
EntUserId: req.EntUserId,
|
|
- ReceiverIds: req.ReceiverIds,
|
|
|
|
- GroupIds: req.GroupIds,
|
|
|
|
|
|
+ ReceiverIds: receiverIds,
|
|
|
|
+ GroupIds: groupIds,
|
|
})
|
|
})
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, err
|
|
return nil, err
|