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,