1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
| from log_module import async_log_util
| from strategy.place_order_queue_manager import PlaceOrderRecordManager
| from trade import trade_record_log_util
| from trade.trade_manager import DealCodesManager, logger_trade
| from utils import tool, huaxin_util
|
| if __name__=="__main__":
| id_ = '2025-07-07_000333_093032_8162'
| # (ID,代码,板块信息, 大单信息, 时间, 价格, 涨幅)
| record = PlaceOrderRecordManager(tool.get_now_date_str()).get_not_process_record_by_id(id_)
| if not record:
| result_json = {"code": 1, "msg": '记录不存在'}
| else:
| PlaceOrderRecordManager(tool.get_now_date_str()).set_buy(record[0])
| code = record[1]
| # 可以下单
| # 判断是否可以买
| order_ref = huaxin_util.create_order_ref()
| price = tool.get_buy_max_price(record[5])
| volume = 100
| DealCodesManager().place_order(set(record[2].keys()), record[1], order_ref, price, volume)
| trade_record_log_util.add_place_order_log(code, trade_record_log_util.PlaceOrderInfo(code=code,
| time_str=record[4],
| price=record[5],
| rate=record[6],
| plates=record[
| 2].keys(),
| plates_info=
| record[2],
| info=record[3]
| ))
| async_log_util.info(logger_trade, f"{code}下单，板块：{record[2].keys()}")
|
|
