调整存多条接口

api/internal/logic/multiplesavemsglogic.go

@@ -4,7 +4,6 @@ import (
 	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
 	"app.yhyue.com/moapp/MessageCenter/util"
 	"context"
-	"encoding/json"
 	"log"
 
 	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
@@ -30,19 +29,19 @@ func NewMultipleSaveMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) Mu
 func (l *MultipleSaveMsgLogic) MultipleSaveMsg(req types.MultipleSaveMsgReq) (*types.MultipleSaveMsgResp, error) {
 	// todo: add your logic here and delete this line
 	log.Println("请求参数：", req)
-	var reqData = []map[string]interface{}{}
-	err := json.Unmarshal([]byte(req.SaveData), reqData)
-	if err != nil {
-		return &types.MultipleSaveMsgResp{
-			Code:     0,
-			Message:  "失败",
-			ErrCount: 0,
-		}, nil
-	}
+	//var reqData = []map[string]interface{}{}
+	//err := json.Unmarshal([]byte(req.SaveData), reqData)
+	//if err != nil {
+	//	return &types.MultipleSaveMsgResp{
+	//		Code:     0,
+	//		Message:  "失败",
+	//		ErrCount: 0,
+	//	}, nil
+	//}
 
 	errCount := 0
 	lsi := l.svcCtx.MessageCenter
-	for _, val := range reqData {
+	for _, val := range req.SaveData {
 
 		resp, err := lsi.SendUserMsg(l.ctx, &messageclient.SendMsgRequest{
 			Appid:         util.ObjToString(val["appid"]),

api/internal/types/types.go

@@ -127,7 +127,7 @@ type SendMsgResp struct {
 }
 
 type MultipleSaveMsgReq struct {
-	SaveData string `json:"saveData"`
+	SaveData []map[string]interface{} `json:"saveData"`
 }
 
 type MultipleSaveMsgResp struct {

api/message.api

@@ -125,7 +125,7 @@ type SendMsgResp {
 
 //批量保存消息
 type MultipleSaveMsgReq {
-	SaveData string `json:"saveData"`
+	SaveData []map[string]interface{} `json:"saveData"`
 }
 type MultipleSaveMsgResp {
 	Code     int64  `json:"code"`