add workflow 天润Smart-ccc会话数据,dev

dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py

@@ -184,7 +184,7 @@ def load_detail_exp_to_db(id):
 
 if __name__ == "__main__":
     print(f'{formatted2_previous_hour(0)}开始请求会话信息')
-    hour_delta = 48
+    hour_delta = 28
     previous_time = previous_hour_timestamp(hour_delta)
     resL = request_data_signature_get(None)
     # print(resL)
@@ -216,6 +216,8 @@ if __name__ == "__main__":
         actList = []
         ids = []
         j = 0
+        k = 0
+        l = 0
         for data in list:
             try: 
                 id = data['mainUniqueId']
@@ -231,11 +233,14 @@ if __name__ == "__main__":
                 resD = request_detail_signature_get(id)
                 #print(f"请求工单详情结束")
                 if 'records' in resD:
+                    k = k + 1
                     ids.append(id)
                     dataList = resD['records']
                     # detailDataList.append(dataList)
                     detailDataList = detailDataList+dataList
+                    print(f'{j}. deltail: {len(dataList)}')
                 else:
+                    l = l+1
                     error = resD['error']
                     print(f"请求会话详情（id:{id}）失败，错误信息：{error}")
                     load_detail_exp_to_db(id)
@@ -243,7 +248,7 @@ if __name__ == "__main__":
                 print(f'请求会话详情（id:{id}）异常, ）异常信息：{e}')
                 load_detail_exp_to_db(data['id'])
                 print(f'{j}. exp end')
-        print(f'实际加载{j}-{len(actList)}-{len(detailDataList)}条记录')
+        print(f'实际加载{j}-{len(actList)}，{len(detailDataList)} - {k}-{l} 条记录')
         load_data_to_db(actList)
         if len(ids) > 0:
             ids_str = [str(item) for item in ids]