admin
2025-03-20 56897a24b0b9b63d62d8df3d11bbae66fe66b1fe
strategy/kpl_api.py
@@ -10,7 +10,8 @@
import requests
import constant
from log_module.log import logger_common, logger_kpl_jingxuan_in
from log_module import async_log_util
from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_Overall_market_strength_score
# import requests
from strategy import data_cache
from strategy import basic_methods
@@ -230,29 +231,29 @@
                               '壳资源', '股权转让', '送转填权']) or ('增长' in plate_name):
            # print(f"{i[1]} 强度:{i[2]}")
            # 通过板块ID获取其下面的个股强度列表
            its_stock = getCodesByPlate(i[0])
            # print(f"======={i[0]}=======")
            its_stock = json.loads(its_stock)
            its_stock = json.loads(getCodesByPlate(i[0]))
            l = its_stock['list'][0]
            # print(f"its_stock['list']  ===  {its_stock['list']}")
            # print(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
            # logger.info(f"its_stock['list']  ===  {its_stock['list']}")
            logger.info(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
            logger.info(f"its_stock['list']  ===》》  {its_stock['list']}")
            # logger.info(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
            its_stock_list_info = its_stock['list'][0]
            # 将板块强度下面对应的个股列表打印到日志中
            # for i in l:
            #     if l[41] != 1:
            # for i in its_stock_list_info:
            #     if i[0] != 1:
            #         logger.info(
            #             f"l === 个股代码:{l[0]},公司名称:{l[1]},主力资金推测:{l[2]},未知0值:{l[3]},概念:{l[4]},最新价:{l[5]},当日当时涨幅:{l[6]}%,"
            #             f"成交额:{round(l[7] / 100000000, 2)} 亿,实际换手率:{l[8]}%,未知0值:{l[9]},实际流通:{round(l[10] / 100000000, 2)}亿,"
            #             f"主力买:{round(l[11] / 100000000, 2)}亿,"
            #             f"主力卖:{round(l[12] / 100000000, 2)}亿,"
            #             f"主力净额:{round(l[13] / 10000, 2)}万,买成占比:{l[14]}%,卖成占比:{l[15]}%,净成占比:{l[16]}%,买流占比:{l[17]}%,卖流占比:{l[18]}%,净流占比:{l[19]}%,"
            #             f"区间涨幅:{l[20]}%,量比:{l[21]},未知0:{l[22]},上板情况:{l[23]},上板排名:{l[24]},换手率:{l[25]}%,"
            #             f"未知空值:{l[26]},未知零值:{l[27]},收盘封单:{l[28]},最大封单:{l[29]},未知空值?:{l[30]},"
            #             f"?:{l[30]}%,?:{l[31]},??:{l[32]},振幅:{l[33]}%,未知0????:{l[34]},未知0?????:{l[35]},"
            #             f"?=:{l[36]},?总市值:{l[37]},?流通市值:{l[38]},最终归属概念(收盘后出数据?):{l[39]},领涨次数:{l[40]},"
            #             f"41未知1值:{l[41]},第三季度机构持仓【str数据勿用运算符】:{l[42]}万,?年预测净利润:{l[43]},上年预测净利润:{l[44]},年内预测净利润:{l[45]}"
            #             f"l === 个股代码:{i[0]},公司名称:{i[1]},主力资金推测:{i[2]},未知0值:{i[3]},概念:{i[4]},最新价:{i[5]},当日当时涨幅:{i[6]}%,"
            #             f"成交额:{round(i[7] / 100000000, 2)} 亿,实际换手率:{i[8]}%,未知0值:{i[9]},实际流通:{round(i[10] / 100000000, 2)}亿,"
            #             f"主力买:{round(i[11] / 100000000, 2)}亿,"
            #             f"主力卖:{round(i[12] / 100000000, 2)}亿,"
            #             f"主力净额:{round(i[13] / 10000, 2)}万,买成占比:{i[14]}%,卖成占比:{i[15]}%,净成占比:{i[16]}%,买流占比:{i[17]}%,卖流占比:{i[18]}%,净流占比:{i[19]}%,"
            #             f"区间涨幅:{i[20]}%,量比:{i[21]},未知0:{i[22]},上板情况:{i[23]},上板排名:{i[24]},换手率:{i[25]}%,"
            #             f"未知空值:{i[26]},未知零值:{i[27]},收盘封单:{i[28]},最大封单:{i[29]},未知空值?:{i[30]},"
            #             f"?:{i[30]}%,?:{i[31]},??:{i[32]},振幅:{i[33]}%,未知0????:{i[34]},未知0?????:{i[35]},"
            #             f"?=:{i[36]},?总市值:{i[37]},?流通市值:{i[38]},最终归属概念(收盘后出数据?):{i[39]},领涨次数:{i[40]},"
            #             f"41未知1值:{i[41]},第三季度机构持仓【str数据勿用运算符】:{i[42]}万,?年预测净利润:{i[43]},上年预测净利润:{i[44]},年内预测净利润:{i[45]}"
            #         )
            # 获取该概念板块的的子版块
@@ -744,11 +745,17 @@
                    data_cache.real_time_market_strong = get_market_strong()
                    # data_cache.time_sharing_market_strong_dirt = time_sharing_market_strong_dirt.update({now: data_cache.real_time_market_strong})
                    logger.info(f"大盘行情情绪综合强度 [分数]==={data_cache.real_time_market_strong}分")
                    # 大盘综合强度分数 的 异步日志
                    logger_Overall_market_strength_score.info(data_cache.real_time_market_strong)
                    async_log_util.info(logger_Overall_market_strength_score, f"大盘行情情绪综合强度 [分数]==={data_cache.real_time_market_strong}分")
                    usefulMoney = data_cache.account_finance_dict[0].get('usefulMoney', 0)
                    logger.info(f"账户可用资金==={usefulMoney}元")
                    # 低迷情绪比例
                    low_emotion_mood_ratio = 1
                    if data_cache.real_time_market_strong <= 33:
                    # 33分是个两级分化阶梯不好,目前不好拿捏,暂时不用
                    # if data_cache.real_time_market_strong <= 33:
                    if data_cache.real_time_market_strong <= 20:
                        low_emotion_mood_ratio = 0.1
                        if data_cache.real_time_market_strong <= 10:
                            low_emotion_mood_ratio = 0