From 1dffc3f0ebeea5fcff1b48f0fd6f5f2c52b6557d Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Fri, 31 May 2024 19:12:46 +0800 Subject: [PATCH] refactor: delete message and message batch use lua. --- pkg/common/storage/cache/redis/msg.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/common/storage/cache/redis/msg.go b/pkg/common/storage/cache/redis/msg.go index 8362ded2f..034a831c9 100644 --- a/pkg/common/storage/cache/redis/msg.go +++ b/pkg/common/storage/cache/redis/msg.go @@ -172,6 +172,7 @@ func (c *msgCache) GetMessagesBySeq(ctx context.Context, conversationID string, msg := &sdkws.MsgData{} msgString, ok := value.(string) + fmt.Sprintf("get result", "seq", seq, "msg string", msgString) if !ok || msgprocessor.String2Pb(msgString, msg) != nil { failedSeqs = append(failedSeqs, seq) continue