gp-server.git - Gitblit

			@@ -20,7 +20,10 @@
			import log
			import tool
			from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager
			from l2.cancel_buy_strategy import HourCancelBigNumComputer
			import l2.l2_data_manager_new
			from third_data import kpl_data_manager, kpl_util, kpl_api, block_info
			from third_data.code_plate_key_manager import RealTimeKplMarketData
			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
			@@ -59,13 +62,21 @@


			def money_desc(money):
			if money > 100000000:
			if abs(money) > 100000000:
			return f"{round(money / 100000000, 2)}亿"
			else:
			return f"{round(money / 10000, 2)}万"


			def get_output_params(code):
			def get_output_params(code, jingxuan_cache_dict, industry_cache_dict):
			def format_plate_output(_plat):
			if _plat in jingxuan_cache_dict:
			return _plat, money_desc(jingxuan_cache_dict[_plat][3])
			elif _plat in industry_cache_dict:
			return _plat, money_desc(industry_cache_dict[_plat][3])
			else:
			return _plat, ''

			params = {
			"base_url": "http://192.168.3.252/kp/",
			}
			@@ -97,6 +108,7 @@
			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线形态", "历史股性", "板块热度", "上板时间", "市值大小","股价大小"]

			@@ -246,6 +258,14 @@
			(
			(score, score_list),
			score_source_list))
			# 是否可以买入的信息
			can_buy_info = l2.l2_data_manager_new.L2TradeDataProcessor.can_buy_first(code, limit_up_price, __L2PlaceOrderParamsManager.score_index,
			__L2PlaceOrderParamsManager.score,
			__L2PlaceOrderParamsManager.score_info,
			(volume_rate,
			code_volumn_manager.get_volume_rate_index(volume_rate)))
			params["trade_data"]["can_buy_info"] = can_buy_info

			__base_L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, False, volume_rate,
			code_volumn_manager.get_volume_rate_index(
			volume_rate),
			@@ -328,6 +348,26 @@
			elif trade_state == trade_manager.TRADE_STATE_BUY_SUCCESS:
			params["trade_data"]["trade_state"]["desc"] = "已成交"

			# H撤监听范围
			if trade_state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER or trade_state == trade_manager.TRADE_STATE_BUY_DELEGATED or trade_state == trade_manager.TRADE_STATE_BUY_SUCCESS:
			hcancel_datas_dict, cancel_indexes_set = HourCancelBigNumComputer.get_watch_index_dict(code)
			# 根据日志读取实时的计算数据
			h_cancel_latest_compute_info = log.get_h_cancel_compute_info(code)
			if hcancel_datas_dict:
			temp_list = [(k, hcancel_datas_dict[k][0]) for k in hcancel_datas_dict]
			canceled_indexs = set([int(k.split("-")[0]) for k in cancel_indexes_set])
			temp_list.sort(key=lambda x: x[0])
			params["trade_data"]["h_cancel"] = {
			"computed_info": list(h_cancel_latest_compute_info) if h_cancel_latest_compute_info else None,
			"datas": []}
			for i in range(0, len(temp_list)):
			temp = temp_list[i]
			val = total_datas[temp[0]]["val"]
			canceled = temp[0] in canceled_indexs
			params["trade_data"]["h_cancel"]["datas"].append(
			(val["time"], val["num"], money_desc(val["num"] * float(val["price"]) * 100),
			(1 if canceled else 0)))

			##############################主动买，被动买##################################
			# 返回主动买,被动买,不买的列表(代码, 名称, 得分, 是否涨停)
			codes_score = __load_codes_scores()
			@@ -340,39 +380,38 @@
			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]

			params["passive_buy_codes"] = params["passive_buy_codes"]

			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)}
			industry = global_util.code_industry_map.get(code)
			params["kpl_code_info"] = {
			"industry": format_plate_output(industry)}
			# 获取开盘啦板块
			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"]["plate"] = [(k[0], k[1], k[2], format_plate_output(k[1])[1]) for k in plate_info]

			# 获取代码的历史涨停数据,(涨停原因,日期,板块)
			params["kpl_code_info"]["code_records"] = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2]
			code_records = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2]
			if code_records:
			code_records = [(format_plate_output(k[0]), k[1], [format_plate_output(k1) for k1 in k[2].split("、")]) for k in
			code_records]
			params["kpl_code_info"]["code_records"] = code_records

			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])
			plates = d[6].split("、")
			plates = [format_plate_output(p) for p in plates]
			params["kpl_code_info"]["today"] = (format_plate_output(d[2]), d[1], plates)
			break

			return params