| | |
|---|
| | | cls.pipe_l2.send( |
|---|
| | | json.dumps({"type": "set_l2_codes", "data": _data})) |
|---|
| | | else: |
|---|
| | | t1 = threading.Thread(target=lambda: cls.__process_command(_type, None, _data), daemon=True) |
|---|
| | | t1 = threading.Thread(target=lambda: cls.__process_command(_type, None, val), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | |
|---|
| | | l2_log.debug(code, "开始执行买入") |
|---|
| | | trade_manager.start_buy(code, capture_timestamp, last_data, |
|---|
| | | last_data_index) |
|---|
| | | l2_log.debug(code, "执行买入成功") |
|---|
| | | ################下单成功处理################ |
|---|
| | | trade_result_manager.real_buy_success(code) |
|---|
| | | l2_log.debug(code, "执行买入成功") |
|---|
| | | l2_log.debug(code, "处理买入成功") |
|---|
| | | params_desc = cls.__l2PlaceOrderParamsManagerDict[code].get_buy_rank_desc() |
|---|
| | | l2_log.debug(code, params_desc) |
|---|
| | | l2_log.trade_record(code, "下单", |
|---|
