|
@@ -42,7 +42,7 @@ func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*t
|
|
|
|
|
|
errCount := 0
|
|
|
lsi := l.svcCtx.MessageCenter
|
|
|
-
|
|
|
+ var userIdList []map[string]interface{}
|
|
|
for _, val := range req.SaveData {
|
|
|
msgType_, err := strconv.Atoi(util.ObjToString(val["msgType"]))
|
|
|
msgType := int64(msgType_)
|
|
@@ -61,6 +61,13 @@ func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*t
|
|
|
Link: util.ObjToString(val["link"]),
|
|
|
CiteId: CiteId,
|
|
|
})
|
|
|
+ // todo 记录用户id
|
|
|
+ if resp.Code == int64(1) {
|
|
|
+ userIdList = append(userIdList, map[string]interface{}{
|
|
|
+ "userId":util.ObjToString(val["receiveUserId"]),
|
|
|
+ "msgType":msgType,
|
|
|
+ } )
|
|
|
+ }
|
|
|
log.Println(resp)
|
|
|
if err != nil {
|
|
|
errCount++
|
|
@@ -70,5 +77,6 @@ func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*t
|
|
|
Code: 1,
|
|
|
Message: "保存成功",
|
|
|
ErrCount: int64(errCount),
|
|
|
+ Data: userIdList,
|
|
|
}, nil
|
|
|
}
|