diff --git a/pkg/service/asChat/handler.go b/pkg/service/asChat/handler.go index d6191a5..1f67223 100644 --- a/pkg/service/asChat/handler.go +++ b/pkg/service/asChat/handler.go @@ -263,6 +263,7 @@ func (cr ChatHandler) MessageList(c *gin.Context) { // return // } //} + // 启用或禁用缓存 //messages := cr.cache.GetChatRecord(request.SessionId) messages := []*accountFiee.ChatRecordData{} var returnDataIdList = make([]int64, 0) @@ -280,6 +281,7 @@ func (cr ChatHandler) MessageList(c *gin.Context) { } } } + fmt.Println("defer CoverChatRecord , message len:", len(messages)) err := cr.cache.CoverChatRecord(request.SessionId, messages) if err != nil { log.Print("设置消息已读失败", zap.Error(err)) @@ -305,6 +307,7 @@ func (cr ChatHandler) MessageList(c *gin.Context) { return } messages = recordResp.List + fmt.Println("GetChatRecordList len:", len(messages)) err = cr.cache.CoverChatRecord(request.SessionId, messages) if err != nil { log.Print("覆盖聊天记录失败", zap.Error(err)) @@ -370,8 +373,6 @@ func (cr ChatHandler) MessageList(c *gin.Context) { resp[i].Message.Media = []dto.MessageMedia{} } } - if accessUser.Role == 1 { - } service.Success(c, resp) }