From 4c745301656a7e4082fb88820448699b23437115 Mon Sep 17 00:00:00 2001 From: R2m1liA <15258427350@163.com> Date: Fri, 5 Dec 2025 08:02:20 +0000 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=B8=BAhook/endpoint=E8=A1=A5=E5=85=A8?= =?UTF-8?q?=E6=9D=A1=E7=9B=AE=E7=8A=B6=E6=80=81=E8=BF=87=E6=BB=A4=E6=9C=BA?= =?UTF-8?q?=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/meilisearch_endpoint/index.ts | 11 +++++++- src/meilisearch_hook/index.ts | 45 ++++++++++++++++++++++++------- 2 files changed, 46 insertions(+), 10 deletions(-) diff --git a/src/meilisearch_endpoint/index.ts b/src/meilisearch_endpoint/index.ts index a95204a..cc181c4 100644 --- a/src/meilisearch_endpoint/index.ts +++ b/src/meilisearch_endpoint/index.ts @@ -131,7 +131,16 @@ export default defineEndpoint({ const queryFields = buildQueryFields(fields); const itemService = new ItemsService(cfg.collection_name, { schema }); - const items = await itemService.readByQuery({ fields: queryFields, limit: -1 }); + const items = await itemService.readByQuery({ + fields: queryFields, + filter: { + _or: [ + { status: { _neq: 'archived' } }, + { status: { _null: true } } + ] + }, + limit: -1, + }); // 为每种语言重建索引 for (const lang of availableLanguages) { diff --git a/src/meilisearch_hook/index.ts b/src/meilisearch_hook/index.ts index f79c679..f1c5fd6 100644 --- a/src/meilisearch_hook/index.ts +++ b/src/meilisearch_hook/index.ts @@ -157,15 +157,15 @@ export default defineHook(async ({ init, filter, action, schedule }, { services, const queryFields = buildQueryFields(fields); const itemService = new ItemsService(cfg.collection_name, { schema }); - const items = await itemService.readByQuery({ + const items = await itemService.readByQuery({ fields: queryFields, - filter: { + filter: { _or: [ - { status: { _null: true }}, - { status: { _neq: 'archived'}}, - ] + { status: { _neq: 'archived' } }, + { status: { _null: true } }, + ] }, - limit: -1 + limit: -1 }); // 为每种语言重建索引 @@ -238,7 +238,16 @@ export default defineHook(async ({ init, filter, action, schedule }, { services, const queryFields = buildQueryFields(fields); const itemService = new ItemsService(cfg.collection_name, { schema }); - const items = await itemService.readByQuery({ fields: queryFields, limit: -1 }); + const items = await itemService.readByQuery({ + fields: queryFields, + filter: { + _or: [ + { status: { _neq: 'archived' } }, + { status: { _null: true } }, + ] + }, + limit: -1 + }); // 为每种语言重建索引 for (const lang of availableLanguages) { @@ -310,7 +319,16 @@ export default defineHook(async ({ init, filter, action, schedule }, { services, const queryFields = buildQueryFields(fields); const itemService = new ItemsService(cfg.collection_name, { schema }); - const items = await itemService.readByQuery({ fields: queryFields, limit: -1 }); + const items = await itemService.readByQuery({ + fields: queryFields, + filter: { + _or: [ + { status: { _neq: 'archived' } }, + { status: { _null: true } }, + ] + }, + limit: -1 + }); // 为每种语言重建索引 for (const lang of availableLanguages) { @@ -386,7 +404,16 @@ export default defineHook(async ({ init, filter, action, schedule }, { services, const queryFields = buildQueryFields(fields); const itemService = new ItemsService(cfg.collection_name, { schema }); - const items = await itemService.readByQuery({ fields: queryFields, limit: -1 }); + const items = await itemService.readByQuery({ + fields: queryFields, + filter: { + _or: [ + { status: { _neq: 'archived' } }, + { status: { _null: true } }, + ] + }, + limit: -1 + }); // 为每种语言重建索引 for (const lang of availableLanguages) {