dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow partner1site,dev

This commit is contained in:
root 2025-09-30 16:24:11 +08:00
parent 40b4f81a74
commit c042a0330e
2 changed files with 301 additions and 327 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/partner1site/获取POS数据/part_summary_pos_feign.py
View File

@ -139,8 +139,8 @@ def main():
client = Partner1SiteClient(ACCESS_KEY, SECRET_KEY) client = Partner1SiteClient(ACCESS_KEY, SECRET_KEY)
data = client.fetch_all_pages( data = client.fetch_all_pages(
api_name="visits", api_name="pos_datas",
params={'startPosInsertDate':'2025-8-20',} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)} params={'startPosInsertDate':'2000-1-1',} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)}
) )
save_json_to_pg(data, API_ID) save_json_to_pg(data, API_ID)

32
dev/workflow/TK_Cust/partner1site/获取客户联系人数据/part_summary_custome_feign.py
View File

@ -138,39 +138,13 @@ def get_previous_date(days: int = 0) -> str:
def main(): def main():
client = Partner1SiteClient(ACCESS_KEY, SECRET_KEY) client = Partner1SiteClient(ACCESS_KEY, SECRET_KEY)
# ✅ 客户拜访数据（执行）
visits_data = client.fetch_all_pages(
api_name="visits",
params={} # 拉全量，若有默认时间限制可改成 {"startInsertDate":"2000-01-01","endInsertDate":get_previous_date(0)}
)
save_json_to_pg(visits_data, API_ID)
# ❌ 报备数据（暂时注释） data = client.fetch_all_pages(
"""
reports_data = client.fetch_all_pages(
api_name="reports",
params={}
)
save_json_to_pg(reports_data, API_ID)
"""
# ❌ POS 数据（暂时注释）
"""
pos_data = client.fetch_all_pages(
api_name="pos_datas",
params={}
)
save_json_to_pg(pos_data, API_ID)
"""
# ❌ 客户及联系人数据（暂时注释）
"""
cust_contact_data = client.fetch_all_pages(
api_name="customer_and_contact_datas", api_name="customer_and_contact_datas",
params={} params={}
) )
save_json_to_pg(cust_contact_data, API_ID) save_json_to_pg(data, API_ID)
"""
if __name__ == "__main__": if __name__ == "__main__":