jingrowlocal/jingrow-framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

重构get_record_name/get_record_name.py

Browse Source
This commit is contained in:
jingrow 2025-11-01 01:53:26 +08:00
parent f7f5b8e63d
commit a4cce52bf1
1 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
apps/jingrow/jingrow/ai/nodes/get_record_name/get_record_name.py
View File

@ -2,8 +2,7 @@ import sys
import os
import json
# 导入utils
from jingrow.utils.jingrow_api import get_field_mapping_from_jingrow, get_record_list
import jingrow
def execute(context=None, inputs=None, config=None, **kwargs):
"""
@ -73,7 +72,7 @@ def execute(context=None, inputs=None, config=None, **kwargs):
# 构造查询条件
try:
label2field = get_field_mapping_from_jingrow(pagetype) or {}
label2field = jingrow.get_field_mapping_from_jingrow(pagetype) or {}
filters = []
for cond in filter_conditions or []:
if not isinstance(cond, dict):
@ -114,13 +113,10 @@ def execute(context=None, inputs=None, config=None, **kwargs):
return {"success": False, "error": f"构造查询条件失败: {str(e)}"}
# 查询第一条记录 name
api_res = get_record_list(pagetype, filters=filters, fields=["name"], limit=1)
if not api_res.get("success"):
return {"success": False, "error": api_res.get("error", "查询失败"), "pagetype": pagetype, "query_filters": filters}
data = api_res.get("data") or []
if not data:
records = jingrow.get_list(pagetype, filters=filters, fields=["name"], limit=1)
if not records:
return {"success": False, "error": "未找到记录", "pagetype": pagetype, "query_filters": filters}
name = (data[0] or {}).get("name")
name = (records[0] or {}).get("name")
if not name:
return {"success": False, "error": "记录缺少name字段", "pagetype": pagetype, "query_filters": filters}