From f7f5b8e63dd1ada7f0d90602206139c8dfae25ff Mon Sep 17 00:00:00 2001 From: jingrow Date: Sat, 1 Nov 2025 01:48:43 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84condition=5Fcheck.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/nodes/condition_check/condition_check.py | 17 +++++------------ 1 file changed, 5 insertions(+), 12 deletions(-) diff --git a/apps/jingrow/jingrow/ai/nodes/condition_check/condition_check.py b/apps/jingrow/jingrow/ai/nodes/condition_check/condition_check.py index 4706790..54b96a3 100644 --- a/apps/jingrow/jingrow/ai/nodes/condition_check/condition_check.py +++ b/apps/jingrow/jingrow/ai/nodes/condition_check/condition_check.py @@ -1,6 +1,5 @@ import json -from jingrow.utils.jingrow_api import get_field_mapping_from_jingrow -from jingrow.utils.jingrow_api import get_record_list +import jingrow def execute(context=None, inputs=None, config=None, **kwargs): """条件判断节点：检查指定pagetype的记录是否满足条件""" @@ -53,7 +52,7 @@ def execute(context=None, inputs=None, config=None, **kwargs): if k not in available_fields or not available_fields.get(k): available_fields[k] = v - label2field = get_field_mapping_from_jingrow(pagetype) or {} + label2field = jingrow.get_field_mapping_from_jingrow(pagetype) or {} filters = {} @@ -114,15 +113,9 @@ def execute(context=None, inputs=None, config=None, **kwargs): else: filter_array.append([k, "=", v]) - api_res = get_record_list(pagetype, filters=filter_array, fields=["name"], limit=1000) - if api_res.get("success"): - records = api_res.get("data") or [] - record_count = len(records) - condition_met = record_count > 0 - else: - records = [] - record_count = 0 - condition_met = False + records = jingrow.get_list(pagetype, filters=filter_array, fields=["name"], limit=1000) + record_count = len(records) + condition_met = record_count > 0 result = { "success": True,