| | |
| | | from code_attribute import gpcode_manager |
| | | from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer |
| | | from l2.huaxin import huaxin_target_codes_manager |
| | | from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \ |
| | | hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_l2_market_data, logger_l2_trade_buy_queue |
| | | from trade import deal_big_money_manager |
| | |
| | | sell_1_price, sell_1_volume // 100) |
| | | hx_logger_l2_market_data.info(f"{code}#{data}") |
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
| | | elif data_json["type"] == "l2_subscript_codes": |
| | | data = data_json["data"] |
| | | datas = data["data"] |
| | | # 订阅的代码 |
| | | huaxin_target_codes_manager.save_subscript_codes(datas) |
| | | else: |
| | | # 断开连接 |
| | | break |