ОРРКЕСТРАЦИЯ - Усилить domain-loop business-first каноном для analyst и orchestrator

2026-04-14 17:33:57 +03:00
parent f6a2c8e0a3
commit cb0eb450d7
19 changed files with 813 additions and 66 deletions
@@ -103,6 +103,8 @@ describe("inventory selected-object follow-up", () => {
    expect(result?.debug.extracted_filters?.as_of_date).toBe("2021-03-31");
    expect(result?.debug.extracted_filters?.period_from).toBe("2021-03-01");
    expect(result?.debug.extracted_filters?.period_to).toBe("2021-03-31");
+    expect(result?.debug.capability_id).toBe("inventory_inventory_purchase_provenance_for_item");
+    expect(result?.debug.capability_route_mode).toBe("exact");
    expect(result?.debug.reasons).toContain("period_window_auto_broadened_to_available_data");
    expect(result?.debug.limitations).toContain("period_window_auto_broadened_to_available_data");
    const replyLines = String(result?.reply_text ?? "").split("\n");
@@ -111,4 +113,97 @@ describe("inventory selected-object follow-up", () => {
    expect(replyLines[1]).toContain("По окну 2021-03-01..2021-03-31 строк не найдено");
    expect(executeAddressMcpQueryMock).toHaveBeenCalledTimes(2);
  });
+
+  it("handles selected-object supplier slang 'кто это поставил нам' as provenance follow-up", async () => {
+    executeAddressMcpQueryMock.mockResolvedValueOnce({
+      fetched_rows: 1,
+      matched_rows: 1,
+      raw_rows: [
+        {
+          Period: "2019-02-11T00:00:00Z",
+          Registrator: "Поступление товаров и услуг 00000000077 от 11.02.2019 0:00:00",
+          AccountDt: "41.01",
+          AccountKt: "60.01",
+          Amount: 3724.17,
+          SubcontoDt1: "Столешница 600*3050*26 дуб ниагара",
+          SubcontoDt3: "Основной склад",
+          SubcontoKt1: "Торговый дом \\Союз МСК\\",
+          SubcontoKt2: "Договор поставки № 12 от 01.02.2019",
+          Organization: "ООО \\Альтернатива Плюс\\"
+        }
+      ],
+      rows: [],
+      error: null
+    });
+
+    const service = new AddressQueryService();
+    const result = await service.tryHandle('По выбранному объекту "Столешница 600*3050*26 дуб ниагара": кто это поставил нам', {
+      followupContext: {
+        previous_intent: "inventory_on_hand_as_of_date",
+        previous_filters: {
+          as_of_date: "2019-03-31",
+          period_from: "2019-03-01",
+          period_to: "2019-03-31",
+          warehouse: "Основной склад",
+          organization: "ООО \\Альтернатива Плюс\\"
+        },
+        previous_anchor_type: "unknown",
+        previous_anchor_value: null
+      }
+    });
+
+    expect(result?.handled).toBe(true);
+    expect(result?.response_type).toBe("FACTUAL_SUMMARY");
+    expect(result?.debug.detected_intent).toBe("inventory_purchase_provenance_for_item");
+    expect(result?.debug.extracted_filters?.item).toBe("Столешница 600*3050*26 дуб ниагара");
+    expect(result?.debug.extracted_filters?.as_of_date).toBe("2019-03-31");
+    expect(String(result?.reply_text ?? "")).toContain("Торговый дом \\Союз МСК\\");
+  });
+
+  it("handles selected-object purchase-doc slang 'по каким документам это купили' as exact purchase-doc follow-up", async () => {
+    executeAddressMcpQueryMock.mockResolvedValueOnce({
+      fetched_rows: 1,
+      matched_rows: 1,
+      raw_rows: [
+        {
+          Period: "2019-02-11T00:00:00Z",
+          Registrator: "Поступление товаров и услуг 00000000077 от 11.02.2019 0:00:00",
+          AccountDt: "41.01",
+          AccountKt: "60.01",
+          Amount: 3724.17,
+          SubcontoDt1: "Столешница 600*3050*26 дуб ниагара",
+          SubcontoDt3: "Основной склад",
+          SubcontoKt1: "Торговый дом \\Союз МСК\\",
+          SubcontoKt2: "Договор поставки № 12 от 01.02.2019",
+          Organization: "ООО \\Альтернатива Плюс\\"
+        }
+      ],
+      rows: [],
+      error: null
+    });
+
+    const service = new AddressQueryService();
+    const result = await service.tryHandle('По выбранному объекту "Столешница 600*3050*26 дуб ниагара": по каким документам это купили', {
+      followupContext: {
+        previous_intent: "inventory_purchase_provenance_for_item",
+        previous_filters: {
+          as_of_date: "2019-03-31",
+          period_from: "2019-03-01",
+          period_to: "2019-03-31",
+          item: "Столешница 600*3050*26 дуб ниагара",
+          warehouse: "Основной склад"
+        },
+        previous_anchor_type: "unknown",
+        previous_anchor_value: null
+      }
+    });
+
+    expect(result?.handled).toBe(true);
+    expect(result?.response_type).toBe("FACTUAL_LIST");
+    expect(result?.debug.detected_intent).toBe("inventory_purchase_documents_for_item");
+    expect(result?.debug.selected_recipe).toBe("address_inventory_purchase_documents_for_item_v1");
+    expect(result?.debug.extracted_filters?.item).toBe("Столешница 600*3050*26 дуб ниагара");
+    expect(result?.debug.extracted_filters?.as_of_date).toBe("2019-03-31");
+    expect(String(result?.reply_text ?? "")).toContain("Поступление товаров и услуг 00000000077");
+  });
 });
@@ -173,6 +173,14 @@ describe("address query shape classifier", () => {
    expect(filters.item).toBe("Кромка с клеем 33 альмандин 137 м");
  });

+  it("extracts item anchor from selected-object purchase-doc follow-up without explicit word товар", () => {
+    const filters = extractAddressFilters(
+      'По выбранному объекту "Столешница 600*3050*26 дуб ниагара": по каким документам это купили',
+      "inventory_purchase_documents_for_item"
+    ).extracted_filters;
+    expect(filters.item).toBe("Столешница 600*3050*26 дуб ниагара");
+  });
+
  it("keeps colloquial selected-object supplier follow-up in inventory provenance intent", () => {
    const mode = detectAddressQuestionMode(
      'По выбранному объекту "Кромка с клеем 33 альмандин 137 м": кто поставил этот товар'
@@ -184,6 +192,28 @@ describe("address query shape classifier", () => {
    expect(result.intent).toBe("inventory_purchase_provenance_for_item");
  });

+  it("keeps selected-object supplier slang with 'кто это поставил нам' in inventory provenance intent", () => {
+    const mode = detectAddressQuestionMode(
+      'По выбранному объекту "Столешница 600*3050*26 дуб ниагара": кто это поставил нам'
+    );
+    const result = resolveAddressIntent(
+      'По выбранному объекту "Столешница 600*3050*26 дуб ниагара": кто это поставил нам'
+    );
+    expect(mode.mode).toBe("address_query");
+    expect(result.intent).toBe("inventory_purchase_provenance_for_item");
+  });
+
+  it("keeps selected-object purchase-doc slang with 'по каким документам это купили' in purchase-doc intent", () => {
+    const mode = detectAddressQuestionMode(
+      'По выбранному объекту "Столешница 600*3050*26 дуб ниагара": по каким документам это купили'
+    );
+    const result = resolveAddressIntent(
+      'По выбранному объекту "Столешница 600*3050*26 дуб ниагара": по каким документам это купили'
+    );
+    expect(mode.mode).toBe("address_query");
+    expect(result.intent).toBe("inventory_purchase_documents_for_item");
+  });
+
  it("keeps full supplier anchor with comma suffix for stock-overlap questions", () => {
    const filters = extractAddressFilters(
      "Какие товары от поставщика Гамма-мебель, ООО сейчас еще лежат на складе Основной склад?",
@@ -3874,6 +3904,49 @@ describe("address query limited taxonomy and stage diagnostics", { timeout: 1500
 });

 describe("address decompose stage follow-up carryover", () => {
+  it("promotes selected-object supplier slang follow-up into inventory provenance with inherited date context", () => {
+    const result = runAddressDecomposeStage('По выбранному объекту "Столешница 600*3050*26 дуб ниагара": кто это поставил нам', {
+      previous_intent: "inventory_on_hand_as_of_date",
+      previous_filters: {
+        as_of_date: "2019-03-31",
+        period_from: "2019-03-01",
+        period_to: "2019-03-31",
+        warehouse: "Основной склад"
+      },
+      previous_anchor_type: "unknown",
+      previous_anchor_value: null
+    });
+    expect(result).not.toBeNull();
+    expect(result?.intent.intent).toBe("inventory_purchase_provenance_for_item");
+    expect(result?.filters.extracted_filters.as_of_date).toBe("2019-03-31");
+    expect(
+      result?.baseReasons?.includes("intent_adjusted_to_inventory_followup_context") ||
+        result?.intent.reasons.includes("inventory_selected_object_provenance_signal_detected")
+    ).toBe(true);
+  });
+
+  it("promotes selected-object purchase-doc slang follow-up into inventory purchase documents with inherited date context", () => {
+    const result = runAddressDecomposeStage('По выбранному объекту "Столешница 600*3050*26 дуб ниагара": по каким документам это купили', {
+      previous_intent: "inventory_purchase_provenance_for_item",
+      previous_filters: {
+        as_of_date: "2019-03-31",
+        period_from: "2019-03-01",
+        period_to: "2019-03-31",
+        item: "Столешница 600*3050*26 дуб ниагара"
+      },
+      previous_anchor_type: "unknown",
+      previous_anchor_value: null
+    });
+    expect(result).not.toBeNull();
+    expect(result?.intent.intent).toBe("inventory_purchase_documents_for_item");
+    expect(result?.filters.extracted_filters.item).toBe("Столешница 600*3050*26 дуб ниагара");
+    expect(result?.filters.extracted_filters.as_of_date).toBe("2019-03-31");
+    expect(
+      result?.baseReasons?.includes("intent_adjusted_to_inventory_followup_context") ||
+        result?.intent.reasons.includes("inventory_selected_object_purchase_documents_signal_detected")
+    ).toBe(true);
+  });
+
  it("keeps slang all-customers-all-time wording in address lane via resolved intent fallback", () => {
    const result = runAddressDecomposeStage("выведи всех заков за все время", null);
    expect(result).not.toBeNull();