""" 代码信息对外输出 """ # score_info 得分信息 # 下单参数信息 # 选股宝 # 市场热度 import os import sys import time import code_volumn_manager import constant import global_data_loader import global_util import gpcode_manager import juejin import limit_up_time_manager import log import tool from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager from third_data import kpl_data_manager, kpl_util, kpl_api, block_info from third_data.kpl_data_manager import KPLLimitUpDataRecordManager, KPLDataManager from trade import first_code_score_manager, l2_trade_factor, trade_manager, l2_trade_util from trade.l2_trade_factor import L2TradeFactorUtil import trade.deal_big_money_manager from jinja2 import Environment, FileSystemLoader base_output_content = {} __kplDataManager = kpl_data_manager.KPLDataManager() def __get_base_html_content(): print("路径", sys.path[0]) if base_output_content.get('css') is None: __base_html_content = "" with open("./output/css/style.css", mode='r') as f: lines = f.readlines() for line in lines: __base_html_content += line base_output_content['css'] = __base_html_content return f"" def render(params): env = Environment(loader=FileSystemLoader('D:/workspace/trade/output')) css = env.get_template('css/index.css') params["css"] = css.render() template = env.get_template('index.html') html_content = template.render(params) return html_content def get_output_html(code): return render(get_output_params(code)) def money_desc(money): if money > 100000000: return f"{round(money / 100000000, 2)}亿" else: return f"{round(money / 10000, 2)}万" def get_output_params(code): params = { "base_url": "http://192.168.3.252/kp/", } day = tool.get_now_date_str() is_target_code = gpcode_manager.FirstCodeManager.is_in_first_record(code) code_extra_infos = [] if l2_trade_util.BlackListCodeManager.is_in(code): code_extra_infos.append("黑名单") if l2_trade_util.WhiteListCodeManager.is_in(code): code_extra_infos.append("白名单") # 获取白名单,黑名单 if trade_manager.gpcode_manager.WantBuyCodesManager.is_in(code): code_extra_infos.append("想买单") params["code"] = code params["code_name"] = f"{gpcode_manager.get_code_name(code)} {code} （{','.join(code_extra_infos)}）" score_info = None buy_params_info = None xgb_infos = None total_datas = l2_data_util.local_today_datas.get(code) if total_datas is None: l2_data_util.load_l2_data(code) total_datas = l2_data_util.local_today_datas.get(code) if is_target_code: params["score_data"] = {} limit_up_price = gpcode_manager.get_limit_up_price(code) limit_up_time = limit_up_time_manager.get_limit_up_time(code) volume_rate, volume_info = code_volumn_manager.get_volume_rate(code, True) (score, score_list), score_source_list = first_code_score_manager.get_score(code, volume_rate, limit_up_time, True) ################################买前评分################################ # ["换手量能", "竞价强度", "资金力度", "K线形态", "历史股性", "板块热度", "上板时间", "市值大小","股价大小"] # 换手量能 # 获取当前量信息 max_60, yest = code_volumn_manager.get_histry_volumn(code) today = code_volumn_manager.get_today_volumn(code) params["score_data"]["volume"] = {"score": score_list[6], "now": f"{round(int(today) / 1000000, 2)}", "high": {"num": round(max_60[0] / 1000000, 2), "date": max_60[1]}, "rate": round(score_source_list[6] * 100, 2)} # 竞价强度 params["score_data"]["bidding"] = {"score": score_list[2], "money": (score_source_list[2] if score_source_list[2] else 0)} # 资金力度 deal_indexes = trade.deal_big_money_manager.get_traded_indexes(code) deal_info = "" params["score_data"]["deal_big_money"] = {"score": score_list[8], "money": score_source_list[8][0] // 10000, "base_money": score_source_list[8][1] // 10000, "rate": round(score_source_list[8][0] / score_source_list[8][1], 2)} if deal_indexes: temps = [] for index in deal_indexes: temps.append(int(index)) temps.sort() start_index = temps[0] end_index = temps[-1] deal_info = f"【{total_datas[start_index]['val']['time']}&{total_datas[start_index]['val']['num']}手-{total_datas[end_index]['val']['time']}&{total_datas[end_index]['val']['num']}手】," params["score_data"]["deal_big_money"]["start"] = {"time": total_datas[start_index]['val']['time'], "num": total_datas[start_index]['val']['num']} params["score_data"]["deal_big_money"]["end"] = {"time": total_datas[end_index]['val']['time'], "num": total_datas[end_index]['val']['num']} # K线形态 k_score = 0 k_source = [] for k in score_list[3]: k_score += k # (15个交易日是否涨幅24.9%,是否破前高，是否超跌，是否接近前高，是否N,是否V) for k in range(0, len(score_source_list[3])): if k == 0: if score_source_list[3][k][0]: k_source.append(("涨幅过高", score_list[3][k])) elif k == 1: if score_source_list[3][k][0]: k_source.append(("突破前高", score_list[3][k])) elif k == 2: if score_source_list[3][k][0]: k_source.append(("超跌补涨", score_list[3][k])) elif k == 3: if score_source_list[3][k][0]: k_source.append((f"逼近前高-{score_source_list[3][k][1]}】", score_list[3][k])) elif k == 4: if score_source_list[3][k][0]: k_source.append(("N字型", score_list[3][k])) elif k == 5: if score_source_list[3][k][0]: k_source.append(("V字型", score_list[3][k])) elif k == 6: if not score_source_list[3][k][0]: k_source.append(("不满足任何形态", score_list[3][k])) elif k == 7: if score_source_list[3][k][0]: k_source.append(("天量大阳", score_list[3][k])) params["score_data"]["k_form"] = {"score": k_score, "datas": k_source} # 历史股性 nature_score = 0 nature_source = [] for k in score_list[4]: nature_score += k code_nature_datas = {"score": nature_score, "limit_up_count": score_source_list[4][0]} for n in range(0, len(score_source_list[4])): if n == 0: nature_source.append(f"涨停次数【{score_source_list[4][n]}】") elif n == 1: if score_source_list[4][n]: nature_source.append(f"首板溢价率【{round(score_source_list[4][n], 2)}】") code_nature_datas["first_limit_up_yijia"] = round(score_source_list[4][1], 2) else: nature_source.append(f"无首板") code_nature_datas["first_limit_up_yijia"] = "无首板" elif n == 2: if score_source_list[4][n]: nature_source.append(f"首板炸板溢价率【{round(score_source_list[4][n], 2)}】") code_nature_datas["first_open_limit_up_yijia"] = round(score_source_list[4][2], 2) else: nature_source.append(f"无首板炸板") code_nature_datas["first_open_limit_up_yijia"] = "无首板炸板" params["score_data"]["code_nature"] = code_nature_datas # 板块热度 hot_block_score = 0 for k in score_list[5]: hot_block_score += k hot_block_source_data = score_source_list[5] for k in hot_block_source_data: hot_block = { # 目标板块信息（板块名称,板块涨幅,历史板块出现次数） "target_block_info": ("无板块", 0, 0), # 涨停顺序 "limit_up_index": 0, # 涨停代码数量 "limit_up_codes_count": 0, # 板块代码涨幅信息 "block_codes_rates_info": (0, 0), # 炸板代码数量 "break_size": 0, # 炸板回封数量 "re_limit_up_size": 0, # 高位版信息 "high_block_infos": [], } params["score_data"]["hot_block"] = {"score": hot_block_score, "limit_up_index": hot_block_source_data['limit_up_index'] + 1, "block_name": hot_block_source_data['target_block_info'][0], "limit_up_count": hot_block_source_data['limit_up_codes_count'], "block_history_count": hot_block_source_data['target_block_info'][2], "open_limit_up_count": hot_block_source_data['break_size']} # 上板时间 params["score_data"]["limit_up_time"] = {"score": score_list[7], "time": score_source_list[7]} # 市值大小 params["score_data"]["zyltgb"] = {"score": score_list[0], "value": round(score_source_list[0] / 100000000, 2)} # 股价大小 params["score_data"]["limit_up_price"] = {"score": score_list[1], "price": score_source_list[1]} params["score_data"]["total_score"] = score # zyltgb, limit_price, bidding, k_form, code_nature, hot_block, volume_rate, limit_up_time, # deal_big_money ###############################下单信息############################### params["trade_data"] = {} # 获取买入意愿 volume_rate = score_source_list[6] __L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, True, volume_rate, code_volumn_manager.get_volume_rate_index( volume_rate), ( (score, score_list), score_source_list)) __base_L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, False, volume_rate, code_volumn_manager.get_volume_rate_index( volume_rate), ((score, score_list), score_source_list)) if -1 < __L2PlaceOrderParamsManager.score_index < 3: params["trade_data"]["star"] = {"desc": "主动买入"} if __L2PlaceOrderParamsManager.score_index == 0: params["trade_data"]["star"]["count"] = 3 elif __L2PlaceOrderParamsManager.score_index == 1: params["trade_data"]["star"]["count"] = 2 else: params["trade_data"]["star"]["count"] = 1 elif __L2PlaceOrderParamsManager.score_index < 0: params["trade_data"]["star"] = {"desc": "不执行买入", "count": 0} else: params["trade_data"]["star"] = {"desc": "被动买入", "count": 0} # 安全笔数 safe_count = __L2PlaceOrderParamsManager.get_safe_count() base_safe_count, min_count, max_count = L2TradeFactorUtil.get_safe_buy_count(code, True) params["trade_data"]["safe_count"] = {"base": base_safe_count, "now": safe_count} # 动态M值 m = __L2PlaceOrderParamsManager.get_m_val() zyltgb = global_util.zyltgb_map.get(code) if zyltgb is None: global_data_loader.load_zyltgb() zyltgb = global_util.zyltgb_map.get(code) base_m = L2TradeFactorUtil.get_base_safe_val(zyltgb) params["trade_data"]["m_val"] = {"base": base_m // 10000, "now": m[0] // 10000} # 买前大单 big_num = __L2PlaceOrderParamsManager.get_big_num_count() base_big_num = __base_L2PlaceOrderParamsManager.get_big_num_count() params["trade_data"]["big_num"] = {"base": base_big_num, "now": big_num} # 成交进度 trade_progress, is_default = transaction_progress.TradeBuyQueue().get_traded_index(code) if trade_progress is None or trade_progress < 0 or is_default: # buy_params_info.append("未识别") pass else: data = total_datas[trade_progress] params["trade_data"]["trade_progress"] = {"time": data['val']['time'], "num": data['val']['num'], "money": round( data['val']['num'] * float(data['val']['price']) * 100 / 10000, 1)} # 买入信号 buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager.get_buy_compute_start_data( code) if buy_single_index is None: # buy_params_info.append("无信号") pass else: data = total_datas[buy_single_index] params["trade_data"]["buy_single"] = {"time": data['val']['time'], "num": data['val']['num'], "money": round(data['val']['num'] * float( data['val']['price']) * 100 / 10000, 1)} if buy_exec_index is None or buy_exec_index < 0: # buy_params_info.append("未下单") pass else: data = total_datas[buy_exec_index] params["trade_data"]["buy_exec"] = {"time": data['val']['time'], "num": data['val']['num'], "money": round(data['val']['num'] * float( data['val']['price']) * 100 / 10000, 1)} params["trade_data"]["trade_state"] = {} trade_state = trade_manager.get_trade_state(code) if trade_state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER or trade_state == trade_manager.TRADE_STATE_BUY_DELEGATED: params["trade_data"]["trade_state"]["order"] = True params["trade_data"]["trade_state"]["desc"] = "已下单" else: params["trade_data"]["trade_state"]["order"] = False if trade_state == trade_manager.TRADE_STATE_NOT_TRADE: params["trade_data"]["trade_state"]["desc"] = "未交易" elif trade_state == trade_manager.TRADE_STATE_BUY_CANCEL_ING: params["trade_data"]["trade_state"]["desc"] = "撤单中" elif trade_state == trade_manager.TRADE_STATE_BUY_CANCEL_SUCCESS: params["trade_data"]["trade_state"]["desc"] = "撤单成功" elif trade_state == trade_manager.TRADE_STATE_BUY_SUCCESS: params["trade_data"]["trade_state"]["desc"] = "已成交" ##############################主动买，被动买################################## # 返回主动买,被动买,不买的列表(代码, 名称, 得分, 是否涨停) codes_score = __load_codes_scores() params["initiative_buy_codes"] = [] for d in codes_score[0]: params["initiative_buy_codes"].append( {"name": d[1], "code": d[0], "score": d[2], "limit_up": d[3], "open_limit_up": d[4]}) params["passive_buy_codes"] = [] for d in codes_score[1]: params["passive_buy_codes"].append( {"name": d[1], "code": d[0], "score": d[2], "limit_up": d[3], "open_limit_up": d[4]}) # 主动买与被动买不能超过11行 initiative_count = len(params["initiative_buy_codes"]) passive_count = len(params["passive_buy_codes"]) buy_row = 0 buy_row += initiative_count // 3 if initiative_count % 3 > 0: buy_row += 1 max_passive_count = (10 - buy_row) * 3 if max_passive_count < 0: max_passive_count = 0 params["passive_buy_codes"] = params["passive_buy_codes"][:max_passive_count] trade_info = __load_trade_record(code, total_datas) params["trade_record"] = {"open_limit_up": trade_info[0], "records": trade_info[2]} ##############################开盘啦相关信息################################## params["kpl_code_info"] = {"industry":global_util.code_industry_map.get(code)} # 获取开盘啦板块 plate_info = kpl_api.getStockIDPlate(code) if plate_info: plate_info.sort(key=lambda x: x[2]) plate_info.reverse() params["kpl_code_info"]["plate"] = plate_info # 获取代码的历史涨停数据,(涨停原因,日期,板块) params["kpl_code_info"]["code_records"] = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2] if not KPLLimitUpDataRecordManager.total_datas: KPLLimitUpDataRecordManager.load_total_datas() for d in KPLLimitUpDataRecordManager.total_datas: if d[3] == code: # 获取今日 params["kpl_code_info"]["today"] = (d[2], d[1], d[6]) break return params def __load_codes_scores(): # 获取所有监听中的代码 codes = gpcode_manager.get_first_gp_codes() scores = {} # l2_data_manager_new.L2TradeDataProcessor.get_code_scores() for code in codes: if code not in scores: # 获取分数 try: limit_up_time = limit_up_time_manager.get_limit_up_time(code) volume_rate, volume_info = code_volumn_manager.get_volume_rate(code, True) (score, score_list), score_source_list = first_code_score_manager.get_score(code, volume_rate, limit_up_time, True) scores[code] = score except: pass # 筛选180分以上的代码 scores_list = [] for code in scores: code_name = gpcode_manager.get_code_name(code) # 获取现价，判断是否涨停 current_price_info = global_util.cuurent_prices.get(code) limit_up_info = code_price_manager.Buy1PriceManager.get_limit_up_info(code) is_limit_up = True open_limit_up = limit_up_info[0] and limit_up_info[1] if current_price_info is not None and not current_price_info[1]: is_limit_up = False else: is_limit_up = True scores_list.append((code, code_name, scores[code], is_limit_up, open_limit_up)) scores_list.sort(key=lambda x: x[2], reverse=True) fscores_list = [[], [], []] for score in scores_list: if score[2] >= constant.BUY_SCORE_RANK_1: fscores_list[0].append(score) elif score[2] >= constant.BUY_SCORE_RANK_0: fscores_list[1].append(score) else: fscores_list[2].append(score) return fscores_list def __load_trade_record(code, total_datas): def format_l2_data(item): return f"{item['val']['time']}#{item['val']['num']}手#{round(item['val']['num'] * float(item['val']['price']) * 100 / 10000, 1)}万" # 获取炸板信息 limit_up_info = code_price_manager.Buy1PriceManager.get_limit_up_info(code) break_time = limit_up_info[1] records = [] try: records = log.load_buy_score_recod(code) except: pass records_new = [] records_new_data = [] index = 0 if records: try: for record in records: time_ = record[0] type = record[1] data = record[2] if type == '下单': index += 1 temp = f"第{index}次下单：【{time_}】&【{data['score']}分】,{data.get('desc')}" records_new.append(temp) records_new_data.append({"type": 1, "index": index, "time": time_, "score": data['score']}) elif type == 'S撤': # index':378 , 'rate':0.51 , 'target_rate':0.49 pass elif type == 'S撤范围': start = format_l2_data(total_datas[data['start_index']]) end = format_l2_data(total_datas[data['end_index']]) range_seconds = data['range_seconds'] temp = f"第{index}次撤单：S撤囊括范围：【起始位:{start}】至【截止位:{end}】囊括时间【{range_seconds}】秒" elif type == 'H撤范围': start = format_l2_data(total_datas[data['start_index']]) end = format_l2_data(total_datas[data['end_index']]) count = data['count'] temp = f"H撤囊括范围：【起始位:{start}】至【截止位:{end}】物理笔数共【{count}】笔" elif type == 'H撤': # 'start_index':339,'end_index':464, 'count':17 pass elif type == '撤单': temp = f"第{index}次撤单：【{time_}】{data['msg']}" records_new.append(temp) records_new_data.append({"type": 0, "time": time_, "desc": data['msg']}) except: pass return break_time, records_new, records_new_data if __name__ == '__main__': datas = { "base_url": "http://192.168.3.122/kp/", "code_name": "天域生态 002255", "score_data": {"volume": {"score": 20, "now": "12", "high": {"num": "56", "date": "2023-04-13"}}, "bidding": {"score": 10, "money": "4563"}, "deal_big_money": {"score": 10, "money": 0, "base_money": 456.5, "start": {"time": "09:00:00", "num": 1456}, "end": {"time": "09:00:00", "num": 1456}}, "k_form": {"score": 10, "datas": ["破前高", "超跌补涨", "涨幅过高"]}, "code_nature": {"score": 10, "data_desc": "涨停次数2次"}, "hot_block": {"score": 10, "block_name": "影视", "limit_up_count": 10, "open_limit_up_count": 2}, "limit_up_time": {"score": 10, "time": "09:56:00"}, "zyltgb": {"score": 10, "value": "12.5"}, "limit_up_price": {"score": 10, "price": "6.35"}, "total_score": "210" }, "trade_data": {"star": {"desc": "被动买入", "count": 0}, "safe_count": {"base": 12, "now": 2}, "m": {"base": 1200, "now": 1000}, "big_num": {"base": 10, "now": 2}, "trade_progress": {"time": "09:12:12", "num": 1111, "money": "12.56"}, "buy_single": {"time": "09:12:12", "num": 1111, "money": "12.56"}, "buy_exec": {"time": "09:12:12", "num": 1111, "money": "12.56"}, }, "xgb_code_infos": [{"date": "今天", "blocks": [ {"name": "影视", "limit_up_count": 2, "index": 1, "price": "12.00", "rate": "+10.00%"}, {"name": "文旅", "limit_up_count": 3, "index": 2, "price": "12.00", "rate": "+10.00%"}, ]}], "initiative_buy_codes": [ {"name": "测试1", "code": "000123", "score": 125, "limit_up": True, "open_limit_up": True}, {"name": "测试2", "code": "000123", "score": 125, "limit_up": False, "open_limit_up": True}, {"name": "测试2", "code": "000123", "score": 125, "limit_up": False, "open_limit_up": True}, {"name": "测试2", "code": "000123", "score": 125, "limit_up": False, "open_limit_up": False} ], "passive_buy_codes": [{"name": "测试1", "code": "000123", "score": 125}, {"name": "测试2", "code": "000123", "score": 125}, {"name": "测试2", "code": "000123", "score": 125}, {"name": "测试2", "code": "000123", "score": 125} ], "trade_record": {"open_limit_up": "10:00:03", "records": [ {"type": 1, "index": 1, "time": "11:00:00", "score": 12}, {"type": 0, "time": "11:26:00", "desc": "H撤撤单"} ]}, "xgb_infos": [{"block": {"name": "测试1", "rate": "+12.00%", "limit_up_count": 10}, "codes": [ {"limit_up": True, "name": "测试代码", "code": "000654"}, {"limit_up": True, "name": "测试代码", "code": "000654"}, {"limit_up": True, "name": "测试代码", "code": "000654"}, {"limit_up": False, "name": "测试代码", "code": "000654"}, ]}] } print(render(datas))