| | |
|---|
| | | ########华鑫配置######## |
|---|
| | | if not is_windows() or True: |
|---|
| | | # 下单1手 |
|---|
| | | BUY_MONEY_PER_CODE = 500 if constant.IS_A else 1000 |
|---|
| | | BUY_MONEY_PER_CODE = 500 if constant.IS_A else 15000 |
|---|
| | | L2_SOURCE_TYPE = L2_SOURCE_TYPE_HUAXIN |
|---|
| | | JUEJIN_LOCAL_API = False |
|---|
| | | TRADE_WAY = TRADE_WAY_HUAXIN |
|---|
| | |
|---|
| | | # 初始化参数 |
|---|
| | | server.global_data_loader.init() |
|---|
| | | |
|---|
| | | # 测试 |
|---|
| | | # # 数据服务 |
|---|
| | | # t1 = threading.Thread(target=server_util.run_data_server, name="createDataServer", daemon=True) |
|---|
| | | # t1.start() |
|---|
| | | # |
|---|
| | | # 数据服务 |
|---|
| | | t1 = threading.Thread(target=server_util.run_data_server, name="createDataServer", daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | # 交易接口服务 |
|---|
| | | t1 = threading.Thread(target=huaxin_trade_api_server.run, name="trade_api_server", |
|---|
| | | args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w_), |
|---|
| | |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.exception(e) |
|---|
| | | logger_system.error(f"端口服务器：{laddr[1]} 启动失败") |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__1': |
|---|
