功能完善

admin

2025-01-17 0f9b7eeb8891e62510add7dd91bd21c04a34828c

功能完善

 trade/huaxin_trade_data_update.py

@@ -34,7 +34,6 @@
                try:
                    if type_ == "delegate_list":
                        dataJSON = huaxin_trade_api.get_delegate_list(can_cancel=False, timeout=10)
                        print("获取到的委托：", dataJSON)
                        if dataJSON["code"] == 0:
                            data = dataJSON["data"]
                            huaxin_trade_record_manager.DelegateRecordManager.add(data)
@@ -67,6 +66,8 @@
                            __process_thread_pool.submit(huaxin_trade_record_manager.PositionManager.add, datas)
                    async_log_util.info(hx_logger_trade_debug, f"获取交易数据成功：{type_}")
                except Exception as e1:
                    print("出错：", str(e1))
                    logging.exception(e1)
                    # if str(e1).find("超时") >= 0:
                    #     # 读取结果超时需要重新请求
                    #     trade_data_request_queue.put_nowait({"type": type_})

 trade/huaxin_trade_record_manager.py

@@ -18,6 +18,7 @@

    @classmethod
    def add(cls, datas):
        print("保存委托数据：",  datas)
        mysqldb = mysql_data.Mysqldb()
        try:
            if datas: