From bff7d0923a4efc66de65d0581d01d3a63cd602e6 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 2 Mar 2023 12:07:32 +0800 Subject: [PATCH] proto modify --- internal/msgtransfer/online_history_msg_handler.go | 2 +- pkg/proto/sdkws/ws.proto | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/msgtransfer/online_history_msg_handler.go b/internal/msgtransfer/online_history_msg_handler.go index bb394cd4b..f5fa78599 100644 --- a/internal/msgtransfer/online_history_msg_handler.go +++ b/internal/msgtransfer/online_history_msg_handler.go @@ -115,10 +115,10 @@ func (och *OnlineHistoryRedisConsumerHandler) Run(channelID int) { if len(storageMsgList) > 0 { lastSeq, err := och.msgDatabase.BatchInsertChat2Cache(ctx, msgChannelValue.aggregationID, storageMsgList) if err != nil { + log.NewError(triggerID, "single data insert to redis err", err.Error(), storageMsgList) och.singleMsgFailedCountMutex.Lock() och.singleMsgFailedCount += uint64(len(storageMsgList)) och.singleMsgFailedCountMutex.Unlock() - log.NewError(triggerID, "single data insert to redis err", err.Error(), storageMsgList) } else { och.singleMsgSuccessCountMutex.Lock() och.singleMsgSuccessCount += uint64(len(storageMsgList)) diff --git a/pkg/proto/sdkws/ws.proto b/pkg/proto/sdkws/ws.proto index 7e8e6c84d..28408c77d 100644 --- a/pkg/proto/sdkws/ws.proto +++ b/pkg/proto/sdkws/ws.proto @@ -130,13 +130,13 @@ message FriendRequest{ ///////////////////////////////////base end///////////////////////////////////// -message PullMessageBySeqListReq{ +message PullMessageBySeqsReq{ string userID = 1; repeated int64 seqs = 3; - map groupSeqList = 4; + map groupSeqs = 4; } -message seqList { +message seqs { repeated int64 seqs = 1; } @@ -145,7 +145,7 @@ message MsgDataList { repeated MsgData msgDataList = 1; } -message PullMessageBySeqListResp { +message PullMessageBySeqsResp { int32 errCode = 1; string errMsg = 2; repeated MsgData list = 3; @@ -155,7 +155,7 @@ message PullMessageBySeqListResp { message GetMaxAndMinSeqReq { - repeated string groupIDList = 1; + repeated string groupIDs = 1; string userID = 2; } message MaxAndMinSeq{