| | |
|---|
| | | # import account_management |
|---|
| | | # 引入日志模块 |
|---|
| | | from strategy.logging_config import get_logger |
|---|
| | | from trade import huaxin_trade_api |
|---|
| | | from trade import huaxin_trade_api, huaxin_trade_data_update, middle_api_protocol |
|---|
| | | from utils import huaxin_util |
|---|
| | | |
|---|
| | | # 获取logger实例 |
|---|
| | | logger = get_logger() |
|---|
| | |
|---|
| | | :param order_info: {'sinfo': 'b_603682_1736312765623', 'securityID': '603682', 'orderLocalID': '8100043081', 'direction': '0', 'orderSysID': '110018100043081', 'insertTime': '13:06:04', 'insertDate': '20250108', 'acceptTime': '13:05:46', 'cancelTime': '', 'limitPrice': 6.45, 'accountID': '00032047', 'orderRef': 130608, 'turnover': 6410.0, 'volume': 1000, 'volumeTraded': 1000, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''} |
|---|
| | | :return: |
|---|
| | | """ |
|---|
| | | print(f"收到订单回调：{order_info}") |
|---|
| | | logger_debug.info(f"收到订单回调：{order_info}") |
|---|
| | | if huaxin_util.is_deal(order_info['orderStatus']): |
|---|
| | | # 成交，需要更新持仓/委托/成交 |
|---|
| | | huaxin_trade_data_update.add_position_list() |
|---|
| | | huaxin_trade_data_update.add_delegate_list("成交") |
|---|
| | | huaxin_trade_data_update.add_deal_list() |
|---|
| | | else: |
|---|
| | | huaxin_trade_data_update.add_money_list() |
|---|
| | | huaxin_trade_data_update.add_delegate_list("订单状态变化") |
|---|
| | | # 推送订单数据 |
|---|
| | | threading.Thread(target=lambda: middle_api_protocol.push( |
|---|
| | | middle_api_protocol.load_push_msg({"type": "order", "data": order_info})), daemon=True).start() |
|---|
| | | |
|---|
| | | queue = multiprocessing.Queue() |
|---|
| | | huaxin_trade_api.run_trade(queue, MyTradeCallback()) |
|---|
