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

add workflow 天润Smart-ccc通话记录,dev

This commit is contained in:
root 2025-02-07 17:26:49 +08:00
parent bccc8d0a77
commit dfab5adecb
3 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/smart_ccc_cdr/查询外呼记录列表/cc_cdr_ob_list_feign.py
View File

@ -61,11 +61,12 @@ def build_query_string(params):
) for k, v in sorted_params.items())
return query_string
current_end_time = previous_hour_timestamp(0)
#计算签名，get请求
def request_data_signature_get(offset, pageSize):
print(f'开始请求外呼记录数据,偏移量：{offset}')
url='https://api-bj.clink.cn/cc/list_cdr_ob'
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':previous_hour_timestamp(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':current_end_time,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
# param={'Timestamp':current_time_utc,'Expires':86400,'startTime':1717516800,'startTimeEnd':previous_hour_timestamp(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177'}
print(f'param: {param}')
url_path = build_query_string(param)
@ -177,6 +178,7 @@ if __name__ == "__main__":
print(f'{formatted2_previous_hour(0)}开始请求外呼记录列表')
offset = 0
pageSize = 100
current_end_time = previous_hour_timestamp(0)
resL = request_data_signature_get(offset, pageSize)
print(resL)
if 'error' in resL:

5
dev/workflow/TK_Cust/smart_ccc_cdr/查询客户来电记录列表/cc_cdr_ib_list_feign.py
View File

@ -60,12 +60,14 @@ def build_query_string(params):
urllib.parse.quote_plus(str(v))
) for k, v in sorted_params.items())
return query_string
current_end_time = previous_hour_timestamp(0)
#计算签名，get请求
def request_data_signature_get(offset, pageSize):
print(f'开始请求客服来电记录数据')
url='https://api-bj.clink.cn/cc/list_cdr_ib'
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':previous_hour_timestamp(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':current_end_time,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
# param={'Timestamp':current_time_utc,'Expires':86400,'startTime':1712332800,'startTimeEnd':1714838400,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
print(f'param: {param}')
@ -113,6 +115,7 @@ if __name__ == "__main__":
print(f'{formatted2_previous_hour(0)}开始请求客户来电记录信息')
offset = 0
pageSize = 100
current_end_time = previous_hour_timestamp(0)
resL = request_data_signature_get(offset,pageSize)
print(resL)
if 'error' in resL:

4
dev/workflow/TK_Cust/smart_ccc_cdr/查询座席接听记录列表/cc_cdr_ib_agent_list_feign.py
View File

@ -61,11 +61,12 @@ def build_query_string(params):
) for k, v in sorted_params.items())
return query_string
current_end_time = previous_hour_timestamp(0)
#计算签名，get请求
def request_data_signature_get(offset, pageSize):
print(f'开始请求座席接听记录数据')
url='https://api-bj.clink.cn/cc/list_cdr_ib_agent'
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':previous_hour_timestamp(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
param={'Timestamp':current_time_utc,'Expires':86400,'startTime':previous_hour_timestamp(1),'startTimeEnd':current_end_time,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
# param={'Timestamp':current_time_utc,'Expires':86400,'startTime':1712332800,'startTimeEnd':1714838400,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':pageSize,'offset':offset}
print(f'param: {param}')
@ -116,6 +117,7 @@ if __name__ == "__main__":
print(f'{formatted2_previous_hour(0)}开始请求座席接听记录信息')
offset = 0
pageSize = 100
current_end_time = previous_hour_timestamp(0)
resL = request_data_signature_get(offset, pageSize)
print(resL)
if 'error' in resL: