| | |
|---|
| | | |
|---|
| | | # 活动时间 |
|---|
| | | from log_module import log_export |
|---|
| | | from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_buy_no |
|---|
| | | from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_buy_no, \ |
|---|
| | | logger_local_huaxin_g_cancel |
|---|
| | | |
|---|
| | | order_detail_upload_active_time_dict = {} |
|---|
| | | transaction_upload_active_time_dict = {} |
|---|
| | |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | temp = trading_canceled_queue.get() |
|---|
| | | upload_data(temp[0], "trading_order_canceled", temp[1]) |
|---|
| | | if temp: |
|---|
| | | logger_local_huaxin_g_cancel.info(f"准备上报：{temp}") |
|---|
| | | upload_data(temp[0], "trading_order_canceled", temp[1]) |
|---|
| | | logger_local_huaxin_g_cancel.info(f"上报成功：{temp}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_local_huaxin_l2_error.exception(e) |
|---|
| | | logger_local_huaxin_l2_error.error(f"上传普通数据出错：{str(e)}") |
|---|
