bug修复

Administrator

2024-05-23 acabf336db0e36846aab914770bde7c71941a6ed

 main.py

@@ -127,7 +127,7 @@
        for r in results:
            cb_code = r["securityID"]
            underlying_code = target_codes_manager.get_underlying_code(cb_code)
            cb_market = code_market_manager.get_market_info(code)
            cb_market = code_market_manager.get_market_info(cb_code)
            underlying_market = code_market_manager.get_market_info(underlying_code)
            if cb_market:
                r["marketInfo"] = {"code": cb_market.code, "name": r["securityName"],
@@ -180,6 +180,8 @@
    # print("下单：", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True))


__deal_codes = set()

def read_l2_results(trade_call_back_queue):
    while True:
        try:
@@ -188,6 +190,9 @@
                async_log_util.info(logger_trade, f"正股涨停，准备买入可转债：{result}")
                # 获取可以买的代码
                code, trade_time = result[0], result[1]
                if code in __deal_codes:
                    async_log_util.info(logger_trade, f"已经下单过：{result}")
                    continue
                # 获取股票代码的可转债代码
                cb_code = target_codes_manager.get_cb_code(code)
                # 获取可转债的涨停价
@@ -196,6 +201,7 @@
                    async_log_util.info(logger_trade, f"准备下单：{cb_code}-{limit_up_price}")
                    # 买入20股
                    result = huaxin_trade_api.order(1, cb_code, 20, round(float(limit_up_price), 3), blocking=True)
                    __deal_codes.add(code)
                    async_log_util.info(logger_trade, f"可转债下单结果：{result}")
        except Exception as e:
            logger_debug.exception(e)