From 3e0792e49d2ee3ead33028781824d6aaa8912cb3 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 8 Dec 2025 10:21:32 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=AE=A2=E6=88=B7=E5=9C=B0?= =?UTF-8?q?=E5=9D=80=E4=BF=A1=E6=81=AF=E6=8F=90=E5=8F=96,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../客户地址城市解析/address_complete.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py index c2b4db3..8f74fde 100644 --- a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py +++ b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py @@ -257,7 +257,8 @@ def process_single_item(api_client, item, type, item_index, total_count): # item 是字典，包含 id 和 address inputs_data = { 'id': f"{item.get('id', '')}", - 'address': f"{item.get('address', '')}" + 'address': f"{item.get('address', '')}", + 'city':f"{item.get('city', '')}" } result = api_client.call_api_with_inputs(inputs_data) @@ -319,9 +320,12 @@ def main(): # 初始化 db_manager = DatabaseManager(db_config) custom_query = """ -select dw_account as id ,address_detail as address from p99_temp.address_city +select +dw_account as id , +prov_name || '-' || city_name as city, +address_detail as address +from p99_temp.address_city where dw_account not in (select account_id from p70_ai_intelligence.agent_address_complete) - """ try: