diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py b/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py index 4162469..cdb69d2 100644 --- a/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py +++ b/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py @@ -72,11 +72,11 @@ def request_data_signature_get(scrollId): print(f'开始请求会话记录数据') url='https://api-bj.clink.cn/livechat/copy_chat_records' if scrollId is None: - # param={'Timestamp':current_time_utc,'Expires':86400,'date':formatted2_previous_date(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100} - param={'Timestamp':current_time_utc,'Expires':86400,'date':'20240801','AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100} + param={'Timestamp':current_time_utc,'Expires':86400,'date':formatted2_previous_date(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100} + # param={'Timestamp':current_time_utc,'Expires':86400,'date':'20240801','AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100} else: - # param={'Timestamp':current_time_utc,'Expires':86400,'date':formatted2_previous_date(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100,'scrollId':scrollId} - param={'Timestamp':current_time_utc,'Expires':86400,'date':'20240801','AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100,'scrollId':scrollId} + param={'Timestamp':current_time_utc,'Expires':86400,'date':formatted2_previous_date(0),'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100,'scrollId':scrollId} + # param={'Timestamp':current_time_utc,'Expires':86400,'date':'20240801','AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100,'scrollId':scrollId} print(f'param: {param}') url_path = build_query_string(param) url_param = url_path @@ -99,12 +99,13 @@ def request_data_signature_get(scrollId): resText = dataReqL.text i = i + 1 resD=json.loads(resText) + print(dataReqL) return resD def request_detail_signature_get(id): print(f'开始请求会话详情数据:{id}') url='https://api-bj.clink.cn/livechat/list_chat_messages' - param={'Timestamp':current_time_utc,'Expires':86400,'mainUniqueId':id,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177'} + param={'Timestamp':current_time_utc,'Expires':86400,'mainUniqueId':id,'AccessKeyId':'b17759d3a36fba9a2cf522fbf4cbf177','limit':100} print(f'param: {param}') url_path = build_query_string(param) url_param = url_path @@ -184,7 +185,7 @@ def load_detail_exp_to_db(id): if __name__ == "__main__": print(f'{formatted2_previous_hour(0)}开始请求会话信息') - hour_delta = 28 + hour_delta = 1 previous_time = previous_hour_timestamp(hour_delta) resL = request_data_signature_get(None) # print(resL)