日志调整

admin

2025-03-05 4e78594dbe033cff000a0cc0b8f74e516151acb5

日志调整

 strategy/buying_strategy.py

@@ -153,6 +153,9 @@
            limit_up_block_names = list(set(data_cache.limit_up_block_names))
            # 在循环监测个股瞬时行情时进入涨幅视界的情况  *************************************************************【涨幅视界】********************************************************
            if tick_growth is not None and tick_growth >= 0.3:
                logger.info(f"上证指数 开盘涨幅 ====》》》 {round(data_cache.Shanghai_open_growth, 4)}%")
                logger.info(f"深证指数 开盘涨幅 ====》》》 {round(data_cache.Shenzhen_open_growth, 4)}%")
                logger.info(f"创业板指 开盘涨幅 ====》》》 {round(data_cache.TSXV_open_growth, 4)}%")
                now = datetime.datetime.now()
                logger.info(
                    f"获取时间========================================={current_created_at}=========================================")

 strategy/data_cache.py

@@ -226,7 +226,27 @@

# 股票指数字典 例如：{"000001":（指数, 量, 额, 昨日收盘价）}
stock_index_dict = {}
# 上证指数 瞬时涨幅
Shanghai_tick_growth = 0
# 上证指数 当日涨幅
Shanghai_today_growth = 0
# 上证指数 开盘涨幅
Shanghai_open_growth = 0

# 深证指数 瞬时涨幅
Shenzhen_tick_growth = 0
# 深证指数 当日涨幅
Shenzhen_today_growth = 0
# 深证指数 开盘涨幅
Shenzhen_open_growth = 0

# 创业板指 瞬时涨幅
TSXV_tick_growth = 0
# 创业板指 当日涨幅
TSXV_today_growth = 0
# 创业板指 开盘涨幅
TSXV_open_growth = 0

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")
# 获取当前进程的PID



 strategy/index_market_trend_strategy.py

@@ -47,17 +47,32 @@
        TSXV_Yesterday_closing_index = round(TSXV_index_data[3], 2)  # 深证指数 昨日收盘指数
        logger.info(f"创业板 指数：{TSXV_index}   昨日收盘指数：{TSXV_Yesterday_closing_index}  成交量------------{TSXV_index_volume}亿 手   成交额------------{TSXV_index_turnover}亿 元")
        # 调用涨幅公式计算对应的股票tick瞬时涨幅
        Shanghai_tick_growth = basic_methods.tick_growth('000001', Shanghai_index)
        Shanghai_today_growth = basic_methods.intraday_growth(Shanghai_index, Shanghai_Yesterday_closing_index)
        logger.info(f"上证指数 瞬时涨幅 ---- {round(Shanghai_tick_growth, 4)}%")
        logger.info(f"上证指数 今日涨幅 ==== {round(Shanghai_today_growth, 4)}%")
        data_cache.Shanghai_tick_growth = basic_methods.tick_growth('000001', Shanghai_index)
        data_cache.Shanghai_today_growth = basic_methods.intraday_growth(Shanghai_index, Shanghai_Yesterday_closing_index)
        logger.info(f"上证指数 瞬时涨幅 ---- {round(data_cache.Shanghai_tick_growth, 4)}%")
        logger.info(f"上证指数 当日涨幅 ==== {round(data_cache.Shanghai_today_growth, 4)}%")
        # 调用涨幅公式计算对应的股票tick瞬时涨幅
        Shenzhen_tick_growth = basic_methods.tick_growth('399001', Shanghai_index)
        Shenzhen_today_growth = basic_methods.intraday_growth(Shenzhen_index, Shenzhen_Yesterday_closing_index)
        logger.info(f"深证指数 瞬时涨幅 ---- {round(Shenzhen_tick_growth, 4)}%")
        logger.info(f"深证指数 今日涨幅 ==== {round(Shenzhen_today_growth, 4)}%")
        data_cache.Shenzhen_tick_growth = basic_methods.tick_growth('399001', Shanghai_index)
        data_cache.Shenzhen_today_growth = basic_methods.intraday_growth(Shenzhen_index, Shenzhen_Yesterday_closing_index)
        logger.info(f"深证指数 瞬时涨幅 ---- {round(data_cache.Shenzhen_tick_growth, 4)}%")
        logger.info(f"深证指数 当日涨幅 ==== {round(data_cache.Shenzhen_today_growth, 4)}%")
        # 调用涨幅公式计算对应的股票tick瞬时涨幅
        TSXV_tick_growth = basic_methods.tick_growth('399006', Shanghai_index)
        TSXV_today_growth = basic_methods.intraday_growth(TSXV_index, TSXV_Yesterday_closing_index)
        logger.info(f"创业板指 瞬时涨幅 ---- {round(TSXV_tick_growth, 4)}%")
        logger.info(f"创业板指 今日涨幅 ==== {round(TSXV_today_growth, 4)}%")
        data_cache.TSXV_tick_growth = basic_methods.tick_growth('399006', Shanghai_index)
        data_cache.TSXV_today_growth = basic_methods.intraday_growth(TSXV_index, TSXV_Yesterday_closing_index)
        logger.info(f"创业板指 瞬时涨幅 ---- {round(data_cache.TSXV_tick_growth, 4)}%")
        logger.info(f"创业板指 当日涨幅 ==== {round(data_cache.TSXV_today_growth, 4)}%")

        # 在集合竞价时更新一下 各个指数的开盘涨幅
        now_time = datetime.datetime.now().strftime("%H:%M:%S")
        # 9:25:30 < now_time < 9:26:00
        if data_cache.later_open_bidding_time < now_time < data_cache.after_open_bidding_time:
            data_cache.Shanghai_open_growth = data_cache.Shanghai_today_growth
            data_cache.Shenzhen_open_growth = data_cache.Shenzhen_today_growth
            data_cache.TSXV_open_growth = data_cache.TSXV_today_growth

        logger.info(f"上证指数 开盘涨幅 ==== {round(data_cache.Shanghai_open_growth, 4)}%")
        logger.info(f"深证指数 开盘涨幅 ==== {round(data_cache.Shenzhen_open_growth, 4)}%")
        logger.info(f"创业板指 开盘涨幅 ==== {round(data_cache.TSXV_open_growth, 4)}%")




 strategy/order_methods.py

@@ -30,8 +30,10 @@
    logger.info(f"buy_order===={buy_order}")
    orderStatusMsg = buy_order['data'].get('orderStatusMsg', None)
    statusMsg = buy_order['data'].get('statusMsg', None)
    logger.info(f"orderStatusMsg==={orderStatusMsg}")
    logger.info(f"statusMsg==={statusMsg}")
    # orderStatusMsg 不在buy_order的下单回调中，那么才认为下单成功
    if orderStatusMsg is not None or (statusMsg is not None and statusMsg != ''):
    if statusMsg is not None and statusMsg == '':
        logger.info(f"买票 下单成功：【{sec_name}】")
        # 每一次成功下单后要更新一下 缓存 的持仓数据
        account_management.position_management()
@@ -82,8 +84,10 @@
    logger.info(f"sell_order===={sell_order}")
    orderStatusMsg = sell_order['data'].get('orderStatusMsg', None)
    statusMsg = sell_order['data'].get('statusMsg', None)
    logger.info(f"orderStatusMsg==={orderStatusMsg}")
    logger.info(f"statusMsg==={statusMsg}")
    # orderStatusMsg 不在buy_order的下单回调中，那么才认为下单成功
    if orderStatusMsg is not None or (statusMsg is not None and statusMsg != ''):
    if statusMsg is not None and statusMsg == '':
        logger.info(f"卖票 下单成功：【{sec_name}】")
        # 每一次成功下单后要更新一下 缓存 的持仓数据
        account_management.position_management()