diff --git a/internal/wb/products/repository_api.go b/internal/wb/products/repository_api.go index 873bc69..0a425f6 100644 --- a/internal/wb/products/repository_api.go +++ b/internal/wb/products/repository_api.go @@ -58,6 +58,8 @@ func fetchProducts( request.Settings.Value.Filter.SetTo(wbapi.ContentV2GetCardsListPostReqSettingsFilter{}) request.Settings.Value.Filter.Value.WithPhoto.SetTo(-1) + + request.Settings.Value.Sort.Value.Ascending.SetTo(true) currentRetry := 0 for { response, err := client.ContentV2GetCardsListPost(ctx, &request, wbapi.ContentV2GetCardsListPostParams{Locale: wbapi.NewOptString("ru")}) @@ -87,6 +89,8 @@ func fetchProducts( } request.Settings.Value.Cursor.Value.UpdatedAt.SetTo(r.Response.Cursor.Value.UpdatedAt.Value) request.Settings.Value.Cursor.Value.NmID.SetTo(r.Response.Cursor.Value.NmID.Value) + request.Settings.Value.Sort.Value.Ascending.SetTo(true) + case *wbapi.R429Headers: err = wb.SetRateLimitRetry(ctx, sellerId, r.XRatelimitRetry.Value, r.XRatelimitLimit.Value, r.XRatelimitReset.Value) if err != nil { @@ -120,7 +124,6 @@ func (a apiRepository) StreamAllProductsCache(ctx context.Context, marketplaceId err = redis.ReadProtoMessage(ctx, key, &cachedMessage) if err == nil && len(cachedMessage.Products) > 0 { resultChan <- utils.DerefSlice(cachedMessage.Products) - //_ = client.EnqueueFetchProductsTask(types.TypeWbFetchProducts, marketplaceId) return } locker := *redis.Locker