mirror of
https://gitlab.com/cief-data/data-management.git
synced 2026-08-19 04:13:57 +00:00
Yam ZhengLim
70 lines
2.9 KiB
Python
70 lines
2.9 KiB
Python
from crisp_api import Crisp
|
|
import general_function
|
|
import pandas as pd
|
|
|
|
def connect_crisp(config):
|
|
try:
|
|
client = Crisp()
|
|
client.set_tier("plugin")
|
|
client.authenticate(config["identifier"], config["key"])
|
|
return client
|
|
except Exception as e:
|
|
print(e)
|
|
print("[FUNCTION_ERROR]-connect_crisp")
|
|
return False
|
|
|
|
def get_operators_csv(website_id, client, path, filename):
|
|
try:
|
|
output_location = path + filename
|
|
operators_list_json = client.website.list_website_operators(website_id)
|
|
operators_list_df = general_function.json_normalize_to_df(operators_list_json)
|
|
operators_list_df.to_csv(output_location, sep='|', encoding='utf-8-sig', header='true', quotechar= '"', index=False)
|
|
print("[Download Complete]",filename)
|
|
except Exception as e:
|
|
print(e)
|
|
print("[FUNCTION_ERROR]-get_operators_csv")
|
|
return False
|
|
|
|
def get_peoples_csv(website_id, client, path, filename):
|
|
try:
|
|
output_location = path + filename
|
|
peoples_list_df = pd.DataFrame()
|
|
peoples_data_df = pd.DataFrame()
|
|
loop_flag = True
|
|
page_number = 1
|
|
|
|
while loop_flag == True:
|
|
peoples_list_json = client.website.list_people_profiles(website_id, page_number)
|
|
temp_df = general_function.json_normalize_to_df(peoples_list_json)
|
|
peoples_list_df = pd.concat([temp_df,peoples_list_df], ignore_index=True)
|
|
if not peoples_list_json:
|
|
loop_flag = False
|
|
else:
|
|
page_number += 1
|
|
|
|
# Get marking by CustomerService Operator
|
|
for people_id in peoples_list_df.people_id:
|
|
print(people_id)
|
|
people_data_json = client.website.get_people_data(website_id, people_id)
|
|
temp_df = general_function.json_normalize_to_df(people_data_json)
|
|
temp_df['people_id'] = people_id
|
|
peoples_data_df = pd.concat([temp_df,peoples_data_df], ignore_index=True)
|
|
|
|
peoples_list_df = peoples_list_df.merge(peoples_data_df, on='people_id', how='left')
|
|
|
|
# Get email subscription status
|
|
for people_id in peoples_list_df.people_id:
|
|
people_subscription_status_json = client.website.get_people_subscription_status(website_id, people_id)
|
|
temp_df = general_function.json_normalize_to_df(people_subscription_status_json)
|
|
temp_df['people_id'] = people_id
|
|
people_subscription_status_df = pd.concat([temp_df,people_subscription_status_json], ignore_index=True)
|
|
|
|
peoples_list_df = peoples_list_df.merge(people_subscription_status_df, on='people_id', how='left')
|
|
|
|
peoples_list_df.to_csv(output_location, sep='|', encoding='utf-8-sig', header='true', quotechar= '"', index=False)
|
|
print("[Download Complete]",filename)
|
|
|
|
except Exception as e:
|
|
print(e)
|
|
print("[FUNCTION_ERROR]-get_peoples_csv")
|
|
return False |