bug修改

Administrator

2024-07-05 a568565a80e7ded5f36cfb2a10d94c8304660802

bug修改

 main.py

@@ -1,6 +1,7 @@
"""
可转债入口函数
"""
import datetime
import json
import logging
import multiprocessing
@@ -178,6 +179,7 @@
                                       "buy1Money": output_util.money_desc(
                                           cb_market.buy1_price * cb_market.buy1_volume),
                                       "preClosePrice": cb_market.pre_close_price}
                r["createTime"] = int(datetime.datetime.strptime(r["createTime"], "%Y-%m-%d %H:%M:%S").timestamp())
                if underlying_market:
                    if not gpcode_manager.CodesNameManager().get_code_name(underlying_market.code):
                        # 异步请求名称
@@ -277,7 +279,6 @@
        try:
            result = trade_call_back_queue.get()
            if result:
                async_log_util.info(logger_trade, f"正股涨停，准备买入可转债：{result}")
                # 获取可以买的代码
                code, trade_time = result[0], result[1]
                buy_infos = result[3]
@@ -288,7 +289,6 @@
                        # 获取股票代码的可转债代码
                        cb_code = target_codes_manager.get_cb_code(code)
                        if CodeTradeStateManager().get_trade_state(cb_code, strategy_type) == CodeTradeStateManager.TRADE_STATE_ALREADY_BUY:
                            async_log_util.info(logger_trade, f"已经下单过：{result}")
                            continue
                        # 获取可转债的涨停价
                        market_info = code_market_manager.get_market_info(cb_code)

 test/test_position.py

New file
@@ -0,0 +1,10 @@
import datetime

from records import huaxin_trade_record_manager
from utils import tool

if __name__ == "__main__":
    results = huaxin_trade_record_manager.PositionManager().list_by_day(tool.get_now_date_str("%Y%m%d"))
    for r in results:
        print(datetime.datetime.strptime(r["createTime"], "%Y-%m-%d %H:%M:%S").timestamp())
    print(results)