|
|
@ -4,6 +4,7 @@ import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"encoding/json"
|
|
|
|
"encoding/json"
|
|
|
|
"github.com/dtm-labs/rockscache"
|
|
|
|
"github.com/dtm-labs/rockscache"
|
|
|
|
|
|
|
|
"github.com/openimsdk/tools/log"
|
|
|
|
"github.com/redis/go-redis/v9"
|
|
|
|
"github.com/redis/go-redis/v9"
|
|
|
|
"golang.org/x/sync/singleflight"
|
|
|
|
"golang.org/x/sync/singleflight"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
@ -49,6 +50,7 @@ func batchGetCache2[K comparable, V any](ctx context.Context, rcClient *rockscac
|
|
|
|
}
|
|
|
|
}
|
|
|
|
values, err := fn(ctx, queryIds)
|
|
|
|
values, err := fn(ctx, queryIds)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
|
|
|
|
log.ZError(ctx, "batchGetCache query database failed", err, "keys", keys, "queryIds", queryIds)
|
|
|
|
return nil, err
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if len(values) == 0 {
|
|
|
|
if len(values) == 0 {
|
|
|
|