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()}")