| | |
|---|
| | | import time |
|---|
| | | import datetime |
|---|
| | | |
|---|
| | | import dask |
|---|
| | | import requests |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_Overall_market_strength_score, \ |
|---|
| | | logger_stock_of_markets_plate, logger_debug |
|---|
| | | # import requests |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy import basic_methods |
|---|
| | | |
|---|
| | | from strategy.logging_config import get_logger |
|---|
| | | from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager |
|---|
| | | from trade import middle_api_protocol |
|---|
| | | from utils import hx_qc_value_util |
|---|
| | | from utils import hx_qc_value_util, tool |
|---|
| | | |
|---|
| | | # 获取logger实例 |
|---|
| | | logger = get_logger() |
|---|
| | | logger = logger_common |
|---|
| | | |
|---|
| | | now = time.time() |
|---|
| | | print(f"kpl_api开始运行--{now}") |
|---|
| | |
|---|
| | | DABAN_TYPE_EVER_LIMIT_DOWN = 5 |
|---|
| | | |
|---|
| | | |
|---|
| | | def __base_request(url, data, timeout=10): |
|---|
| | | def __base_request(url, data, timeout=10): |
|---|
| | | DELEGATE = True |
|---|
| | | if not DELEGATE: |
|---|
| | | headers = { |
|---|
| | |
|---|
| | | return __base_request("https://apphq.longhuvip.com/w1/api/index.php", data=data) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取概念中的板块中的子板块 |
|---|
| | | def getSonPlate(plate_code): |
|---|
| | | data = f"a=SonPlate_Info&apiv=w32&c=ZhiShuRanking&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e23&VerSion=5.8.0.2&PlateID={plate_code}&" |
|---|
| | |
|---|
| | | return json.dumps({"errcode": 0, "list": fresults}) |
|---|
| | | |
|---|
| | | |
|---|
| | | # if __name__ == "__main__": |
|---|
| | | |
|---|
| | | |
|---|
| | | # print(f"打板列表t(pidType)====={daBanList(2)}") |
|---|
| | | # print(f"获取个股代码的板块==={getStockIDPlate('002766')}") |
|---|
| | | # print((f"获取个股代码的精选板块==={getCodeJingXuanBlocks('002878')}")) |
|---|
| | | # print(f"获取该概念下的个股代码及其他====={getCodesByPlate(885500)}") 《《《《《《《《《《 |
|---|
| | | # print(f"获取概念中的板块中的子板块====={json.loads(getSonPlate(801085))}") |
|---|
| | | # 获取涨停信息数据 |
|---|
| | | def get_limit_up_info(): |
|---|
| | | # 获取涨停信息列表 |
|---|
| | | limit_up_info = json.loads(getLimitUpInfoNew())['list'] |
|---|
| | | return limit_up_info |
|---|
| | | |
|---|
| | | # print(f"获取概念中的板块强度====={getSonPlate(getCodesByPlate(getCodeJingXuanBlocks('002452')[2][0]))}") |
|---|
| | | # print(f"市场行情-行业板块 数==={len(getMarketIndustryRealRankingInfo(True))}") |
|---|
| | | # print(f"市场行情-行业板块==={json.loads(getMarketIndustryRealRankingInfo(True))}") |
|---|
| | | |
|---|
| | | # 返回格式：['板块ID','板块名称','强度','涨幅','未知','成交额','''''''''强度','未知'] |
|---|
| | | # print(f"市场行情-精选板块 数==={getMarketJingXuanRealRankingInfo(True)}") |
|---|
| | | # print(f"市场行情-精选板块==={json.loads(getMarketJingXuanRealRankingInfo(True))}") |
|---|
| | | # print(f"股票代码：{Market_situation_selected_sectors_No1[0]}") |
|---|
| | | # jingxuanbankuai = json.loads(getMarketJingXuanRealRankingInfo(True)) |
|---|
| | | # print(f"jingxuanbankuai==={type(jingxuanbankuai)}") |
|---|
| | | # print(f"板块代码：{jingxuanbankuai['list'][0][0]}，板块名称：{jingxuanbankuai['list'][0][1]}，强度：{jingxuanbankuai['list'][0][2]}，涨幅：{jingxuanbankuai['list'][0][3]}，未知：{jingxuanbankuai['list'][0][4]}，成交额：{round(jingxuanbankuai['list'][0][5]/100000000)}亿，主力净额：{round(jingxuanbankuai['list'][0][6]/100000000,2)}亿，主买：{round(jingxuanbankuai['list'][0][7]/100000000,2)}亿，主卖：{round(jingxuanbankuai['list'][0][8]/100000000,2)}亿，未知：{jingxuanbankuai['list'][0][9]}，流通值：{round(jingxuanbankuai['list'][0][10]/100000000,2)}亿，未知/或为最大涨跌幅：{round(jingxuanbankuai['list'][0][11],2)}，未知：{round(jingxuanbankuai['list'][0][12]/100000000,2)}亿，总市值：{round(jingxuanbankuai['list'][0][13]/100000000,2)}亿，第一季度机构持仓：{round(jingxuanbankuai['list'][0][14]/100000000,2)}亿，未知：{round(jingxuanbankuai['list'][0][15],2)}，未知：{round(jingxuanbankuai['list'][0][16],2)}，强度：{round(jingxuanbankuai['list'][0][17],2)}") |
|---|
| | | # # 部分板块没有子板块 |
|---|
| | | # print(f"获取概念中的板块中的子板块====={json.loads(getSonPlate(801248))}") |
|---|
| | | # 获取市场情绪综合强度【完整】 |
|---|
| | | def changeStatistics(): |
|---|
| | | """ |
|---|
| | | 获取市场强度 |
|---|
| | | :return: |
|---|
| | | """ |
|---|
| | | result = __base_request("https://apphwhq.longhuvip.com/w1/api/index.php", |
|---|
| | | f"a=ChangeStatistics&apiv=w35&c=HomeDingPan&PhoneOSNew=1&UserID=0&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9774&VerSion=5.13.0.0&Token=0&") |
|---|
| | | # data = result.text |
|---|
| | | data = json.loads(result) |
|---|
| | | return data["info"][0] |
|---|
| | | |
|---|
| | | # print(f"自由流通市值==={getZYLTAmount('603319')}") |
|---|
| | | # print((f"获取个股代码的精选板块列表==={getCodeJingXuanBlocks('002452')}")) |
|---|
| | | # print((f"获取个股代码的精选第一板块代码==={getCodeJingXuanBlocks('002452')[0][0]}")) |
|---|
| | | # print(f"获取该概念下的个股代码及其他====={json.loads(getCodesByPlate(getCodeJingXuanBlocks('002452')[0][0]))}") |
|---|
| | | # print(f"获取该概念下的个股代码及其他dddddd====={json.loads(its_strongest_sector_situation)}") |
|---|
| | | # print(f"涨停列表及概念板块={json.loads(getLimitUpInfoNew())['list']}") |
|---|
| | | |
|---|
| | | ######################################################################################################################################################################################################################## |
|---|
| | | # 获取市场情绪综合强度 |
|---|
| | | def get_market_strong(): |
|---|
| | | """ |
|---|
| | | 获取市场强度 |
|---|
| | | :return: |
|---|
| | | """ |
|---|
| | | result = __base_request("https://apphwhq.longhuvip.com/w1/api/index.php", |
|---|
| | | f"a=DiskReview&apiv=w35&c=HomeDingPan&VerSion=5.13.0.0&PhoneOSNew=1&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9773&") |
|---|
| | | data = json.loads(result) |
|---|
| | | return int(data["info"]["strong"]) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 市场情绪--涨跌统计 |
|---|
| | | # 数据格式： |
|---|
| | | # SJZT:实际涨停 SJDT:实际跌停 SZJS:涨数量 ZT:涨停 DT:跌停 XDJS:跌数量 sign:人气概述 |
|---|
| | | def getMarketFelling(): |
|---|
| | | result = __base_request("https://apphwhq.longhuvip.com/w1/api/index.php", |
|---|
| | | f"a=ZhangFuDetail&apiv=w35&c=HomeDingPan&PhoneOSNew=1&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9774&VerSion=5.13.0.0&") |
|---|
| | | data = json.loads(result) |
|---|
| | | return data["info"] |
|---|
| | | # market_strong = get_market_strong() |
|---|
| | | # print(f"market_strong==={market_strong}") |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | MarketFelling = getMarketFelling() |
|---|
| | | print(f"MarketFelling==={MarketFelling}") |
|---|
| | | changeStatistics = changeStatistics() |
|---|
| | | print(f"changeStatistics==={changeStatistics}") |
|---|
| | | |
|---|
| | | # -------------------------------------------------------------------------------------------------------------------------------------------------------------- |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取行情精选板块 强度排名 |
|---|
| | | def get_market_sift_plate_its_stock_power(): |
|---|
| | | @dask.delayed |
|---|
| | | def batch_get_plate_codes(fs): |
|---|
| | | return fs |
|---|
| | | |
|---|
| | | @dask.delayed |
|---|
| | | def request_plate_codes(i): |
|---|
| | | plate_name = i[1] |
|---|
| | | log_data = None |
|---|
| | | its_stock = json.loads(getCodesByPlate(i[0])) |
|---|
| | | now_time_str = tool.get_now_time_str() |
|---|
| | | if data_cache.OPENING_TIME < now_time_str < data_cache.NOON_MARKET_TIME: |
|---|
| | | log_data = {plate_name: its_stock['list']} |
|---|
| | | # 尝试过滤掉无意义的概念板块(plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革','超跌', '壳资源', '股权转让', '送转填权']) and '增长' in plate_name |
|---|
| | | if (plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革', '超跌', |
|---|
| | | '壳资源', '股权转让', '送转填权']) or ('增长' in plate_name): |
|---|
| | | |
|---|
| | | # print(f"{i[1]} 强度:{i[2]}") |
|---|
| | | # 通过板块ID获取其下面的个股强度列表 |
|---|
| | | # print(f"======={i[0]}=======") |
|---|
| | | |
|---|
| | | # its_stock_list_info = its_stock['list'] |
|---|
| | | # logger.info(f"its_stock_list_info==={its_stock_list_info}") |
|---|
| | | # 将板块强度下面对应的个股列表打印到日志中 |
|---|
| | | # for i in its_stock_list_info: |
|---|
| | | # if i[0] != 1: |
|---|
| | | # logger.info( |
|---|
| | | # 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]}" |
|---|
| | | # ) |
|---|
| | | |
|---|
| | | # 初始化股票强度列表 |
|---|
| | | stock_power_list = [] |
|---|
| | | for s in its_stock['list']: |
|---|
| | | # 过滤掉涨幅大于 and s[6] < 6.5 且小于0%的 和 名称中包含ST的 和 涨速小于等于0%的 和 只要昨日未涨停 和 上证或深证的正股 and s[9] > 0.0025 |
|---|
| | | if s[6] > 0 and s[1].find("ST") < 0 and s[1].find("XD") < 0 and s[23].find("板") < 0 and s[24].find("板") < 0 and (s[0].startswith('60') or s[0].startswith('00')) and s[9] > 1: |
|---|
| | | # print(f"{s[1]}，个股代码：{s[0]}， 涨幅：{s[6]}% 涨速：{s[9]}% 概念：{s[4]} 主力资金推测：{s[2]} 领涨次数：{s[40]} 今日第几板：{s[23]} 是否破版{s[24]}") |
|---|
| | | # 对个股强度 主要 属性列表进行装填 |
|---|
| | | its_stock_power = [s[1], s[0], s[6], s[9], s[4], s[2], s[40]] |
|---|
| | | # 逐个选择性添加its_stock中的元素到个股强度列表中 |
|---|
| | | # print(f"its_stock_power===={its_stock_power}") |
|---|
| | | # 整体将添加完善的个股强度列表添加到股票列表中 |
|---|
| | | stock_power_list.append(its_stock_power) |
|---|
| | | # print(f"stock_power_list===={stock_power_list}") |
|---|
| | | # 过滤掉没有瞬时高强度个股的空概念 |
|---|
| | | if len(stock_power_list) != 0: |
|---|
| | | # 将对应板块的股票强度列表新建一个字典 |
|---|
| | | stock_power_item = {i[1]: stock_power_list} |
|---|
| | | # 并更新到精选板块个股字典中 |
|---|
| | | market_sift_plate_stock_dict.update(stock_power_item) |
|---|
| | | return log_data |
|---|
| | | |
|---|
| | | data = (getMarketJingXuanRealRankingInfo()) |
|---|
| | | market_sift_plate = json.loads(data) |
|---|
| | | # logger_kpl_jingxuan_in 打印的日志专用于开盘了数据的存储分析，不能轻易删除 |
|---|
| | | # print(f"market_sift_plate 数 ======{len(market_sift_plate['list'])}") |
|---|
| | | # 行情》精选板块》排名前20中》对应个股》符合条件的个股 |
|---|
| | | # logger.info(f"market_sift_plate['list']======{market_sift_plate['list']}") |
|---|
| | | # logger.info(f"market_sift_plate['list'][0] ======{market_sift_plate['list'][0]}") |
|---|
| | | # 初始化精选板块对应个股字典 |
|---|
| | | market_sift_plate_stock_dict = {} |
|---|
| | | if 'list' in market_sift_plate: |
|---|
| | | for i in market_sift_plate['list']: |
|---|
| | | plate_name = i[1] |
|---|
| | | # 尝试过滤掉无意义的概念板块(plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革','超跌', '壳资源', '股权转让', '送转填权']) and '增长' in plate_name |
|---|
| | | if (plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革', '超跌', |
|---|
| | | '壳资源', '股权转让', '送转填权']) or ('增长' in plate_name): |
|---|
| | | # print(f"{i[1]} 强度:{i[2]}") |
|---|
| | | # 通过板块ID获取其下面的个股强度列表 |
|---|
| | | its_stock = getCodesByPlate(i[0]) |
|---|
| | | its_stock = json.loads(its_stock) |
|---|
| | | # print(f"its_stock['list'] === {its_stock['list']}") |
|---|
| | | # print(f"its_stock['list'][0] === {its_stock['list'][0]}") |
|---|
| | | # 获取该概念板块的的子版块 |
|---|
| | | # its_son_plate = json.loads(getSonPlate(i[0])) |
|---|
| | | # logger.info(f"its_son_plate=={its_son_plate['List']}") |
|---|
| | | # if its_son_plate['List'][0][2] > 0: |
|---|
| | | # print(f"its_son_plate=={its_son_plate['List'][0]}") |
|---|
| | | # for son in its_son_plate['List']: |
|---|
| | | # if son[2] > 0: |
|---|
| | | # print(f"son===={son}") |
|---|
| | | # 初始化股票强度列表 |
|---|
| | | stock_power_list = [] |
|---|
| | | for s in its_stock['list']: |
|---|
| | | # 过滤掉涨幅大于 and s[6] < 6.5 且小于0%的 和 名称中包含ST的 和 涨速小于等于0%的 和 只要昨日未涨停 和 上证或深证的正股 and s[9] > 0.0025 |
|---|
| | | if s[6] > 0 and s[1].find("ST") < 0 and s[1].find("XD") < 0 and s[23].find("板") < 0 and s[24].find( |
|---|
| | | "板") < 0 and (s[0].startswith('60') or s[0].startswith('00')) and s[9] > 1: |
|---|
| | | # print(f"{s[1]}，个股代码：{s[0]}， 涨幅：{s[6]}% 涨速：{s[9]}% 概念：{s[4]} 主力资金推测：{s[2]} 领涨次数：{s[40]} 今日第几板：{s[23]} 是否破版{s[24]}") |
|---|
| | | # 对个股强度属性列表进行初始化 |
|---|
| | | its_stock_power = [s[1], s[0], s[6], s[9], s[4], s[2], s[40]] |
|---|
| | | # 逐个选择性添加its_stock中的元素到个股强度列表中 |
|---|
| | | # print(f"its_stock_power===={its_stock_power}") |
|---|
| | | # 整体将添加完善的个股强度列表添加到股票列表中 |
|---|
| | | stock_power_list.append(its_stock_power) |
|---|
| | | # print(f"stock_power_list===={stock_power_list}") |
|---|
| | | # 过滤掉没有瞬时高强度个股的空概念 |
|---|
| | | if len(stock_power_list) != 0: |
|---|
| | | # 将对应板块的股票强度列表新建一个字典 |
|---|
| | | stock_power_item = {i[1]: stock_power_list} |
|---|
| | | # 并更新到精选板块个股字典中 |
|---|
| | | market_sift_plate_stock_dict.update(stock_power_item) |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | ds = [] |
|---|
| | | for d in market_sift_plate['list']: |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | compute_results = dask_result.compute() |
|---|
| | | log_datas = {} |
|---|
| | | for r in compute_results: |
|---|
| | | if not r: |
|---|
| | | continue |
|---|
| | | for b in r: |
|---|
| | | log_datas[b] = r[b] |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.NOON_MARKET_TIME: |
|---|
| | | # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | KPLStockOfMarketsPlateLogManager().add_log(market_sift_plate['list'], log_datas) |
|---|
| | | |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | try: |
|---|
| | | # now = time.time() |
|---|
| | | # print(f"kpl_limit_up_process开始了{now}") |
|---|
| | | its_stock_power = get_market_sift_plate_its_stock_power() |
|---|
| | | callback(its_stock_power) |
|---|
| | | # print(f"精选板块拉升个股更新===={its_stock_power}") |
|---|
| | | start_time = time.time() |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | its_stock_power = get_market_sift_plate_its_stock_power() |
|---|
| | | time_str = datetime.datetime.now().strftime("%H%M%S") |
|---|
| | | if 92900 < int(time_str) < 95000: |
|---|
| | | logger_kpl_jingxuan_in.info(f"耗时：{time.time() - start_time} 数据：{its_stock_power}") |
|---|
| | | callback(its_stock_power) |
|---|
| | | # print(f"精选板块拉升个股更新===={its_stock_power}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | logger.error(f"开盘啦板块强度线程报错An error occurred: {e}") |
|---|
| | | finally: |
|---|
| | | time.sleep(2) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取涨停信息数据 |
|---|
| | | def get_limit_up_info(): |
|---|
| | | # 获取涨停信息列表 |
|---|
| | | limit_up_info = json.loads(getLimitUpInfoNew())['list'] |
|---|
| | | return limit_up_info |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取市场行情情绪综合强度 |
|---|
| | | def get_market_strong(): |
|---|
| | | """ |
|---|
| | | 获取市场强度 |
|---|
| | | :return: |
|---|
| | | """ |
|---|
| | | result = __base_request("https://apphwhq.longhuvip.com/w1/api/index.php", |
|---|
| | | f"a=DiskReview&apiv=w35&c=HomeDingPan&VerSion=5.13.0.0&PhoneOSNew=1&DeviceID=d6f20ce9-fa08-31c9-a493-536ebb8e9773&") |
|---|
| | | data = json.loads(result) |
|---|
| | | return int(data["info"]["strong"]) |
|---|
| | | |
|---|
| | | # market_strong = get_market_strong() |
|---|
| | | # print(f"market_strong==={market_strong}") |
|---|
| | | |
|---|
| | | # 获取涨停板块名称列表并存储本地的函数 |
|---|
| | | def get_limit_up_block_names(): |
|---|
| | | # 获取涨停信息列表 |
|---|
| | | limit_up_info = get_limit_up_info() |
|---|
| | | # print(f"limit_up_info=={limit_up_info}") |
|---|
| | | data_cache.limit_up_info = get_limit_up_info() |
|---|
| | | # 提取涨停列表中的板块名称 |
|---|
| | | limit_up_block_names = [] |
|---|
| | | # 设定当前时间点 |
|---|
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
|---|
| | | # 循环添加涨停概念 |
|---|
| | | for i in limit_up_info: |
|---|
| | | limit_up_block_names.append(i[5]) |
|---|
| | | # print(f"limit_up_block_names==={limit_up_block_names}") |
|---|
| | | # return limit_up_block_names |
|---|
| | | # # 使用Counter计算每个元素的出现次数 |
|---|
| | | # counter = Counter(limit_up_block_names) |
|---|
| | | # # 找出出现次数最多的元素及其次数 |
|---|
| | | # most_common_element, most_common_count = counter.most_common(1)[0] |
|---|
| | | # # 打印出现次数最多的元素 |
|---|
| | | # print(f"主线概念：{most_common_element}，出现了 {most_common_count} 次") |
|---|
| | | if now_time > data_cache.after_closing_time: |
|---|
| | | # print(f"收盘结束，记录当前涨停板块") |
|---|
| | | # 将获取到的涨停概念板块转JSON格式并存储在本地文件夹中 |
|---|
| | | # 将字典转换为JSON格式的字符串 |
|---|
| | | json_data = json.dumps(limit_up_block_names) |
|---|
| | | # print(f"json_data=={json_data}") |
|---|
| | | if len(json_data) != 0: |
|---|
| | | # 写入文件 |
|---|
| | | with open(constant.KPL_LIMIT_UP_BLOCK_NAMES_PATH, 'w', encoding='utf-8') as f: |
|---|
| | | f.write(json_data) |
|---|
| | | return limit_up_block_names |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | # print(f"now_time===={now_time}") |
|---|
| | | if data_cache.SERVER_RESTART_TIME < now_time < data_cache.UPDATE_DATA_TIME: |
|---|
| | | # print(f"在时间内使用--------------------------") |
|---|
| | | # 获取涨停信息列表 |
|---|
| | | limit_up_info = get_limit_up_info() |
|---|
| | | # print(f"limit_up_info=={limit_up_info}") |
|---|
| | | data_cache.limit_up_info = get_limit_up_info() |
|---|
| | | # 提取涨停列表中的板块名称 |
|---|
| | | limit_up_block_names = [] |
|---|
| | | # 循环添加涨停概念 |
|---|
| | | for i in limit_up_info: |
|---|
| | | limit_up_block_names.append(i[5]) |
|---|
| | | # print(f"limit_up_block_names==={limit_up_block_names}") |
|---|
| | | # return limit_up_block_names |
|---|
| | | # # 使用Counter计算每个元素的出现次数 |
|---|
| | | # counter = Counter(limit_up_block_names) |
|---|
| | | # # 找出出现次数最多的元素及其次数 |
|---|
| | | # most_common_element, most_common_count = counter.most_common(1)[0] |
|---|
| | | # # 打印出现次数最多的元素 |
|---|
| | | # print(f"主线概念：{most_common_element}，出现了 {most_common_count} 次") |
|---|
| | | |
|---|
| | | return limit_up_block_names |
|---|
| | | |
|---|
| | | |
|---|
| | | # 为开盘啦接口获取的涨停列表概念板块单独开一个进程 形参(callback) |
|---|
| | |
|---|
| | | # 将日期和data_to_append转换为JSON格式的字符串 |
|---|
| | | json_line = json.dumps({current_date: data_to_append}, ensure_ascii=False) + '\n' |
|---|
| | | # 打开文件并追加JSON行 |
|---|
| | | with open(self.file_path, 'a', encoding='utf-8') as file:file.write(json_line) |
|---|
| | | with open(self.file_path, 'a', encoding='utf-8') as file: |
|---|
| | | file.write(json_line) |
|---|
| | | else: |
|---|
| | | logger.info(f"（当日日期已存在于文件的最后一行了，不再重复追加写入）") |
|---|
| | | else: |
|---|
| | |
|---|
| | | data_cache.daily_limit_up_info = history_limit_up_info.arrange_limit_up_info() |
|---|
| | | # logger.info(f"读本地的日更的历史涨停数据=={data_cache.daily_limit_up_info}") |
|---|
| | | |
|---|
| | | |
|---|
| | | # print(f"daily_limit_up_info 类型==={type(data_cache.daily_limit_up_info)}") |
|---|
| | | # 统计每日主线 |
|---|
| | | daily_limit_up_info_len = len(data_cache.daily_limit_up_info) |
|---|
| | |
|---|
| | | sorted_plate_ranking_list = sorted(plate_ranking_list, key=lambda x: list(x.values())[0], reverse=True) |
|---|
| | | # logger.info(f"{key}=====>>>>{sorted_plate_ranking_list}") |
|---|
| | | history_sorted_plate_ranking_list.append(sorted_plate_ranking_list) |
|---|
| | | |
|---|
| | | # print(f"history_sorted_plate_ranking_list={history_sorted_plate_ranking_list}") |
|---|
| | | # for ranking_list in history_sorted_plate_ranking_list: |
|---|
| | | # print(f"ranking_list={ranking_list}") |
|---|
| | |
|---|
| | | # the_same_class_amount = pre_trading_day_limit_up_info[0][20] |
|---|
| | | # logger.info(f"同概念涨停数量=={the_same_class_amount}") |
|---|
| | | |
|---|
| | | |
|---|
| | | # get_handling_limit_up_info() |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | logger.info(f"个股有历史K线但概念为空的有：{plate_are_null_list}") |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取全部个股的精选板块并存储的函数 |
|---|
| | | def stocks_list_selected_blocks(min_stocks): |
|---|
| | | stocks_selected_block_data = [] |
|---|
| | |
|---|
| | | print(f"写入精选板块文件完成！::{now_time}") |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取实时大盘行情情绪综合强度 [分数] 函数 |
|---|
| | | def get_real_time_market_strong(): |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | if data_cache.position_automatic_management_switch is True: |
|---|
| | | # 初始化分时市场情绪分数列表数据列表 |
|---|
| | | time_sharing_market_strong_dirt = {} |
|---|
| | | now = datetime.datetime.now() # 获取本机时间 |
|---|
| | | 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}分") |
|---|
| | | usefulMoney = data_cache.account_finance_dict[0].get('usefulMoney', 0) |
|---|
| | | logger.info(f"账户可用资金==={usefulMoney}元") |
|---|
| | | # 机械版 |
|---|
| | | # if data_cache.real_time_market_strong >= 70: |
|---|
| | | # data_cache.have_plate_buy_money = 30000 |
|---|
| | | # data_cache.have_strength_buy_money = 30000 |
|---|
| | | # elif 60 <= data_cache.real_time_market_strong < 70: |
|---|
| | | # data_cache.have_plate_buy_money = 20000 |
|---|
| | | # data_cache.have_strength_buy_money = 20000 |
|---|
| | | # elif 50 <= data_cache.real_time_market_strong < 60: |
|---|
| | | # data_cache.have_plate_buy_money = 10000 |
|---|
| | | # data_cache.have_strength_buy_money = 10000 |
|---|
| | | # elif 30 <= data_cache.real_time_market_strong < 50: |
|---|
| | | # data_cache.have_plate_buy_money = 3000 |
|---|
| | | # data_cache.have_strength_buy_money = 3000 |
|---|
| | | # elif data_cache.real_time_market_strong < 30: |
|---|
| | | # data_cache.have_plate_buy_money = 1000 |
|---|
| | | # data_cache.have_strength_buy_money = 1000 |
|---|
| | | |
|---|
| | | # 获取计算今天新增的持仓数量 |
|---|
| | | addition_position_number = len(data_cache.addition_position_symbols_set) |
|---|
| | | # 定义一个今日的剩余新增持仓数量的变量 |
|---|
| | | Unfinished_opening_plan_number = 3 - addition_position_number |
|---|
| | | # 根据账户可用金额 计算今日计划下单金额 |
|---|
| | | # (账户可用金额/今日最大新增持仓票数) * （大盘综合强度份数 * 0.01） |
|---|
| | | data_cache.today_planned_order_amount = (usefulMoney / Unfinished_opening_plan_number) * (data_cache.real_time_market_strong * 0.01) |
|---|
| | | except Exception as error: |
|---|
| | | logger.error(f"获取实时大盘行情情绪综合强度[分数] 函数报错: {error}") |
|---|
| | | finally: |
|---|
| | | time.sleep(3) |
|---|
| | | |
|---|
| | | # kpl_stocks_list_selected_blocks_process() #在 kpl_api.py中可以调用 |
|---|
| | | |
|---|
| | | # stocks_list_selected_blocks(min_stocks) #在 kpl_api.py中可以调用 |
|---|
| | | |
|---|
| | | # list = ['SHSE.600805','SHSE.600804'] |
|---|
| | | # |
|---|
| | | # all_stocks_plate_dict(list) |
|---|
| | | |
|---|
