|
|
@ -172,7 +172,7 @@ func (c *msgCache) GetMessagesBySeq(ctx context.Context, conversationID string,
|
|
|
|
|
|
|
|
|
|
|
|
msg := &sdkws.MsgData{}
|
|
|
|
msg := &sdkws.MsgData{}
|
|
|
|
msgString, ok := value.(string)
|
|
|
|
msgString, ok := value.(string)
|
|
|
|
fmt.Sprintf("get result", "seq", seq, "msg string", msgString)
|
|
|
|
fmt.Println("get result", "seq", seq, "msg string", msgString)
|
|
|
|
if !ok || msgprocessor.String2Pb(msgString, msg) != nil {
|
|
|
|
if !ok || msgprocessor.String2Pb(msgString, msg) != nil {
|
|
|
|
failedSeqs = append(failedSeqs, seq)
|
|
|
|
failedSeqs = append(failedSeqs, seq)
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|