From ad73fba998de23b21538a02171116a8235db2194 Mon Sep 17 00:00:00 2001 From: root Date: Tue, 30 Sep 2025 17:17:41 +0800 Subject: [PATCH] add workflow partner1site,dev --- .../partner1site/获取POS数据/part_summary_pos_feign.py | 4 ++-- .../partner1site/获取客户拜访数据/part_summary_visit_feign.py | 4 ++-- .../获取客户联系人数据/part_summary_custome_feign.py | 2 +- .../partner1site/获取报备数据/part_summary_report_feign.py | 4 ++-- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/dev/workflow/TK_Cust/partner1site/获取POS数据/part_summary_pos_feign.py b/dev/workflow/TK_Cust/partner1site/获取POS数据/part_summary_pos_feign.py index 70b3f98..adf1012 100644 --- a/dev/workflow/TK_Cust/partner1site/获取POS数据/part_summary_pos_feign.py +++ b/dev/workflow/TK_Cust/partner1site/获取POS数据/part_summary_pos_feign.py @@ -80,7 +80,7 @@ class Partner1SiteClient: "page": page_num }) - resp = requests.get(base_url, params=params_with_paging, timeout=30) + resp = requests.get(base_url, params=params_with_paging, timeout=120) resp.raise_for_status() data_json = resp.json() @@ -140,7 +140,7 @@ def main(): data = client.fetch_all_pages( api_name="pos_datas", - params={'startPosInsertDate':'2000-1-1',} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} + params={'startPosInsertDate':get_previous_date(7),} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} ) save_json_to_pg(data, API_ID) diff --git a/dev/workflow/TK_Cust/partner1site/获取客户拜访数据/part_summary_visit_feign.py b/dev/workflow/TK_Cust/partner1site/获取客户拜访数据/part_summary_visit_feign.py index f9810fc..a2bd462 100644 --- a/dev/workflow/TK_Cust/partner1site/获取客户拜访数据/part_summary_visit_feign.py +++ b/dev/workflow/TK_Cust/partner1site/获取客户拜访数据/part_summary_visit_feign.py @@ -72,7 +72,7 @@ class Partner1SiteClient: "page": page_num }) - resp = requests.get(base_url, params=params_with_paging, timeout=30) + resp = requests.get(base_url, params=params_with_paging, timeout=120) resp.raise_for_status() data_json = resp.json() @@ -132,7 +132,7 @@ def main(): data = client.fetch_all_pages( api_name="visits", - params={'startInsertDate':'2000-1-1'} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} + params={'startInsertDate':get_previous_date(7),} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} ) save_json_to_pg(data, API_ID) diff --git a/dev/workflow/TK_Cust/partner1site/获取客户联系人数据/part_summary_custome_feign.py b/dev/workflow/TK_Cust/partner1site/获取客户联系人数据/part_summary_custome_feign.py index 8f548f0..2a0be89 100644 --- a/dev/workflow/TK_Cust/partner1site/获取客户联系人数据/part_summary_custome_feign.py +++ b/dev/workflow/TK_Cust/partner1site/获取客户联系人数据/part_summary_custome_feign.py @@ -80,7 +80,7 @@ class Partner1SiteClient: "page": page_num }) - resp = requests.get(base_url, params=params_with_paging, timeout=30) + resp = requests.get(base_url, params=params_with_paging, timeout=120) resp.raise_for_status() data_json = resp.json() diff --git a/dev/workflow/TK_Cust/partner1site/获取报备数据/part_summary_report_feign.py b/dev/workflow/TK_Cust/partner1site/获取报备数据/part_summary_report_feign.py index 37b2258..fcae0d6 100644 --- a/dev/workflow/TK_Cust/partner1site/获取报备数据/part_summary_report_feign.py +++ b/dev/workflow/TK_Cust/partner1site/获取报备数据/part_summary_report_feign.py @@ -72,7 +72,7 @@ class Partner1SiteClient: "page": page_num }) - resp = requests.get(base_url, params=params_with_paging, timeout=30) + resp = requests.get(base_url, params=params_with_paging, timeout=120) resp.raise_for_status() data_json = resp.json() @@ -132,7 +132,7 @@ def main(): data = client.fetch_all_pages( api_name="reports", - params={'startApplyDate':'2000-1-1'} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} + params={'startApplyDate':get_previous_date(7)} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} )