add workflow 客户地址信息提取,dev

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: