From 45090ceb2232154511561170869ae7a0b06a201a Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Mon, 8 Dec 2025 19:01:12 +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         | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py
index c9d9bf5..5070ee0 100644
--- a/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py
+++ b/dev/workflow/TK_Cust/address_complete/客户地址城市解析/address_complete.py
@@ -319,13 +319,21 @@ def main():
         if flag:
             # 初始化
             db_manager = DatabaseManager(db_config)
+#             custom_query = """
+# 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)
+# """
+
             custom_query = """
 select 
-dw_account as id ,
+account_id as id ,
 prov_name || '-' || city_name as city,
-address_detail as address 
-from p99_temp.address_city_1 
-where dw_account not in (select account_id from  p70_ai_intelligence.agent_address_complete)
+address as address 
+from p99_temp.address_city_1
 """
             
             try: