1.充分交易量公式 修改参数 2.策略中新增且打印有意购买列表 3.GUI新增及修改 行情板块强度模块 的 日志数据整理 与 data_server ...

admin

2025-05-27 cbf0eb16d93a5c7ebfa5196c012cde695166647a

1.充分交易量公式 修改参数
2.策略中新增且打印有意购买列表
3.GUI新增及修改 行情板块强度模块 的 日志数据整理 与 data_server 相关的响应修改
4.

 data_server.py

@@ -17,7 +17,7 @@
from log_module import log_export, async_log_util
from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api
from strategy import data_cache
from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager, KPLMarketStockHeatLogManager
from strategy.kpl_data_manager import KPLMarketsSiftPlateLogManager, KPLMarketStockHeatLogManager
from strategy.trade_setting import TradeSetting
from trade import huaxin_trade_api, huaxin_trade_data_update
from trade.huaxin_trade_record_manager import DelegateRecordManager, DealRecordManager, MoneyManager, PositionManager
@@ -195,7 +195,7 @@
        # 获取板块强度数据
        elif url.path == "/load_get_kpl_market_sift_plate":
            # 加载数据
            KPLStockOfMarketsPlateLogManager().load_data()
            KPLMarketsSiftPlateLogManager().load_data()
            response_data = json.dumps({"code": 0, "msg": "暂无内容"})
        elif url.path == "/get_kpl_market_sift_plate":
            # 获取开盘啦流入板块详细信息
@@ -204,7 +204,7 @@
                time_str = params_dict.get("time")
                if not time_str:
                    time_str = tool.get_now_time_str()
                fdatas = KPLStockOfMarketsPlateLogManager().get_filter_log_datas()
                fdatas = KPLMarketsSiftPlateLogManager().get_filter_log_datas()
                response_data = json.dumps({"code": 1, "msg": "暂无内容"})
                for i in range(len(fdatas) - 1, -1, -1):
                    if fdatas[i][0] <= time_str:

 main.py

@@ -243,7 +243,8 @@


    # 加载开盘啦板块日志数据
    kpl_data_manager.KPLStockOfMarketsPlateLogManager()
    kpl_data_manager.KPLMarketsSiftPlateLogManager()
    kpl_data_manager.KPLMarketStockHeatLogManager()

    # 启动异步日志
    threading.Thread(target=async_log_util.run_sync, daemon=True).start()

 strategy/basic_methods.py

@@ -211,10 +211,10 @@
# 充分交易量公式 用于计算日内涨幅段理论的安全交易量值
def sufficient_volume(current_volume, yesterday_volume, today_growth):
    if today_growth > 0:
        if current_volume < yesterday_volume * today_growth:
            return False
        else:
        if current_volume > yesterday_volume * 0.8 * today_growth:
            return True
        else:
            return False


# 计算 委买和委卖的比例函数(获取买盘强度数据)【掘金数据结构】

 strategy/buying_strategy.py

@@ -384,6 +384,8 @@
                                            logger_info(
                                                f"【不利】当日成交量小于昨日成交量的{ratios}倍！不买！！公司名称：{k_line_data[0]['sec_name']}，当日当时总成交量:{current_volume},最新价: {current_price}")
                                            return
                                        data_cache.willing_buy_list.add_buy_code(k_line_data[0]['sec_name'])
                                        logger_info(f"当前有意购买：{k_line_data[0]['sec_name']}，有意购买列表：{data_cache.willing_buy_list}")
                                        if len(intersection_plate) > 0:
                                            logger_info(
                                                f"【不利】同概念只买一次，不买了，公司名称：{k_line_data[0]['sec_name']}，重复相交概念==={intersection_plate}")

 strategy/data_cache.py

@@ -273,7 +273,10 @@
# 最新成交价格
latest_deal_price_dict = {}

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")

# 大单成交数据: {"代码":[大单数据1,大单数据2,...]}
big_order_deal_dict = {}

# 有意购买的股票名称列表
willing_buy_list = []

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")

 strategy/kpl_api.py

@@ -15,7 +15,7 @@

from strategy import data_cache
from strategy import basic_methods
from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager
# from strategy.kpl_data_manager import KPLMarketsSiftPlateLogManager
from trade import middle_api_protocol
from utils import hx_qc_value_util, tool


 strategy/kpl_data_manager.py

@@ -2,9 +2,9 @@
from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
from utils import tool

# 开盘啦个股强度日志管理
# 开盘啦板块强度日志管理
@tool.singleton
class KPLStockOfMarketsPlateLogManager:
class KPLMarketsSiftPlateLogManager:
    """
    精选流入板块与板块代码日志管理
    """
@@ -15,12 +15,12 @@

    def __load_data(self):
        if tool.get_now_time_str() > '13:10:00':
            logger_debug.info("KPLMarketStockHeatLogManager 开始加载数据")
            logger_debug.info("KPLMarketsSiftPlateLogManager 开始加载数据")
            datas = log_export.load_market_stock_heat()
            for data in datas:
                # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)})
                self.__filter_log_datas.append(self.__filter_origin_data(data))
            logger_debug.info("KPLMarketStockHeatLogManager 数据加载完成：{}", len(self.__filter_log_datas))
            logger_debug.info("KPLMarketsSiftPlateLogManager 数据加载完成：{}", len(self.__filter_log_datas))

    def load_data(self):
        self.__load_data()
@@ -72,4 +72,4 @@


if __name__ == '__main__':
    KPLStockOfMarketsPlateLogManager()
    KPLMarketStockHeatLogManager()