| | |
| | | |
| | | from log_module.log import * |
| | | from trade.huaxin.huaxin_trade_record_manager import TradeOrderIdManager |
| | | from utils import import_util, tool |
| | | from utils import import_util, tool, huaxin_util |
| | | |
| | | trade_gui = import_util.import_lib("trade.trade_gui") |
| | | |
| | |
| | | if constant.TRADE_WAY == constant.TRADE_WAY_JUEJIN: |
| | | trade_juejin.order_volume(code, price, count) |
| | | elif constant.TRADE_WAY == constant.TRADE_WAY_HUAXIN: |
| | | local_order_id = create_local_order_id(code) |
| | | TradeOrderIdManager().add_local_order_id(code, local_order_id) |
| | | trade_huaxin.order_volume(code, price, count, last_data_index, local_order_id=local_order_id) |
| | | order_ref = huaxin_util.create_order_ref() |
| | | TradeOrderIdManager().add_order_ref(code, order_ref) |
| | | trade_huaxin.order_volume(code, price, count, last_data_index, order_ref=order_ref) |
| | | else: |
| | | guiTrade.buy(code, price) |
| | | __place_order_success(code, capture_timestamp, last_data, last_data_index) |
| | |
| | | RedisUtils.realse(redis_l2) |
| | | |
| | | |
| | | # 生成本地订单号 |
| | | def create_local_order_id(code): |
| | | local_order_id = f"l_{code}_{1}_{round(time.time() * 1000)}_{random.randint(0, 999)}" |
| | | return local_order_id |
| | | |
| | | |
| | | |
| | | if __name__ == "__main__": |