| | |
|---|
| | | async_log_util.info(logger_debug, f"收到订单回调：{order_info}") |
|---|
| | | if huaxin_util.is_deal(order_info['orderStatus']): |
|---|
| | | if order_info["direction"] == '0': |
|---|
| | | data_cache.position_symbols_set.add(order_info["securityID"]) |
|---|
| | | data_cache.addition_position_symbols_set.add(order_info["securityID"]) |
|---|
| | | # 买入成交 |
|---|
| | | TodayBuyCodeManager().add_deal_code(order_info["securityID"], order_info.get("orderRef")) |
|---|
| | | # 成交，需要更新持仓/委托/成交 |
|---|
| | |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | from huaxin_client import huaxin_sinfo_util |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import hx_logger_trade_debug, hx_logger_trade_loop, hx_logger_trade_callback, logger_trade, \ |
|---|
| | | logger_system |
|---|
| | |
|---|
| | | """ |
|---|
| | | timestamp = round(time.time() * 1000) |
|---|
| | | if not sinfo: |
|---|
| | | sinfo = f"b_{code}_{timestamp}" |
|---|
| | | sinfo = huaxin_sinfo_util.create_place_order_sinfo(code, direction == 1, False) |
|---|
| | | if not order_ref: |
|---|
| | | order_ref = huaxin_util.create_order_ref() |
|---|
| | | if not request_id: |
|---|
