gp-server.git - Gitblit

			@@ -60,7 +60,6 @@
			diff_codes = set(want_codes) - set(codes)
			if diff_codes:
			# 想买单的代码还没有在目标代码中
			zyltgb_list = []
			for code in diff_codes:
			# 获取涨停价
			_limit_up_price = gpcode_manager.get_limit_up_price(code)
			@@ -74,52 +73,15 @@
			dataList.append({"code": code, "price": f"{_limit_up_price}", "volume": "0",
			"volumeUnit": 0, "time": "00:00:00", "zyltgb": "100",
			"zyltgbUnit": 0})
			# 强制更新自由流通股本
			if zyltgb_list:
			ZYLTGBUtil.save_list(zyltgb_list)
			# 将保存的数据更新到内存中
			for z in zyltgb_list:
			val = ZYLTGBUtil.get(z["code"])
			if val:
			global_util.zyltgb_map[z["code"]] = val

			# ---保存未筛选的首板代码
			new_add_codes = gpcode_first_screen_manager.set_target_no_screen_codes(codes)
			# 保存自由流通股本，暂时不保存
			# if dataList:
			# zyltgb_list = []
			# for data in dataList:
			# code = data["code"]
			# if code in global_util.zyltgb_map:
			# continue
			# zyltgb_list.append(
			# {"code": code, "zyltgb": data["zyltgb"], "zyltgb_unit": data["zyltgbUnit"]})
			# if zyltgb_list:
			# ZYLTGBUtil.save_list(zyltgb_list)
			# global_data_loader.load_zyltgb()

			# 获取昨日收盘价
			need_get_limit_up_codes = set()
			for code in codes:
			# 如果涨停价是空值就需要设置昨日收盘价格
			if gpcode_manager.get_limit_up_price(code) is None:
			init_data_util.re_set_price_pres([code], True)

			# 板块关键字准备暂时删除
			# for code in codes:
			# if __CodesPlateKeysManager.get_history_limit_up_reason(code) is None:
			# # 从数据库加载历史涨停原因
			# __CodesPlateKeysManager.set_history_limit_up_reason(code,
			# KPLLimitUpDataRecordManager.get_latest_blocks_set(
			# code))
			# if __CodesPlateKeysManager.get_blocks(code) is None:
			# try:
			# results = kpl_api.getStockIDPlate(code)
			# bs = [r[1] for r in results]
			# __CodesPlateKeysManager.set_blocks(code, bs)
			# except Exception as e:
			# logging.exception(e)
			# pass

			need_get_limit_up_codes.add(code)
			if need_get_limit_up_codes:
			init_data_util.re_set_price_pres(list(need_get_limit_up_codes), True)
			logger_l2_codes_subscript.info(f"{request_id}加载l2代码涨停价结束")
			# 获取60天最大记录
			for code in codes:
			need_get_volumn = False
			@@ -135,17 +97,19 @@
			continue
			try:
			volumes_data = init_data_util.get_volumns_by_code(code, 150)
			volumes = init_data_util.parse_max_volume(volumes_data[:90],
			code_nature_analyse.is_new_top(
			limit_up_price,
			volumes_data[:90]) or code_nature_analyse.is_near_top(
			volumes = init_data_util.parse_max_volume(code, volumes_data[:90],
			code_nature_analyse.is_new_top(code,
			limit_up_price,
			volumes_data[
			:90]) or code_nature_analyse.is_near_top(
			code,
			limit_up_price,
			volumes_data[:90]))
			logger_first_code_record.info("{} 获取到首板60天最大量：{}", code, volumes)
			code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2], volumes[3])

			# 保存K线形态
			k_format = code_nature_analyse.get_k_format(limit_up_price, volumes_data)
			k_format = code_nature_analyse.get_k_format(code, limit_up_price, volumes_data)
			code_nature_analyse.CodeNatureRecordManager().save_k_format(code, k_format)

			# 是否具有辨识度
			@@ -163,13 +127,13 @@
			l2_trade_util.forbidden_trade(code,
			f"无辨识度，涨停价({limit_up_price})>50")
			continue
			if code_nature_analyse.is_price_too_high_in_days(volumes_data, limit_up_price)[0]:
			if code_nature_analyse.is_price_too_high_in_days(code, volumes_data, limit_up_price)[0] and code.find("30")!=0:
			# 判断是否太高
			l2_trade_util.forbidden_trade(code, "6天内股价长得太高")
			continue
			pass

			if code_nature_analyse.is_continue_limit_up_not_enough_fall_dwon(volumes_data):
			if code_nature_analyse.is_continue_limit_up_not_enough_fall_dwon(code, volumes_data):
			# 判断是否太高
			l2_trade_util.forbidden_trade(code, "回踩不够")
			continue
			@@ -178,17 +142,17 @@
			l2_trade_util.forbidden_trade(code, "最近5天有ST/非正常状态")
			continue

			if code_nature_analyse.is_up_too_high_in_10d_with_limit_up(volumes_data):
			if code_nature_analyse.is_up_too_high_in_10d_with_limit_up(code, volumes_data):
			# 判断是否太高
			HighIncreaseCodeManager().add_code(code)

			if code_nature_analyse.is_up_too_high_in_120d(volumes_data):
			if code_nature_analyse.is_up_too_high_in_120d(code, volumes_data):
			# 判断是否太高
			# l2_trade_util.forbidden_trade(code, "120天内股价长得太高")
			# HighIncreaseCodeManager().add_code(code)
			pass

			if code_nature_analyse.is_have_latest_max_volume(volumes_data, 2):
			if code_nature_analyse.is_have_latest_max_volume(code, volumes_data, 2):
			# 最近2天是否是最高量
			code_nature_analyse.LatestMaxVolumeManager().set_has_latest_max_volume(code)

			@@ -208,24 +172,13 @@
			except Exception as e:
			logger_first_code_record.error(f"{code}:{str(e)}")
			logger_first_code_record.exception(e)

			logger_l2_codes_subscript.info(f"{request_id}加载l2代码K线结束")

			gpcode_manager.FirstCodeManager().add_record(codes)
			# 初始化板块信息，暂时删除
			# for code in codes:
			# block_info.init_code(code)

			if new_add_codes:
			gpcode_manager.FirstGPCodesManager().set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes,
			fields="symbol,sec_name,sec_type,sec_level"))
			# 加入首板历史记录
			logger_first_code_record.info("新增首板：{}", new_add_codes)

			# 移除代码
			if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS:
			listen_codes = gpcode_manager.get_listen_codes()
			for lc in listen_codes:
			if not gpcode_manager.is_in_gp_pool(lc):
			# 移除代码
			l2_code_operate.L2CodeOperate.get_instance().add_operate(0, lc, "代码被移除")
			# 保存现价
			if dataList:
			situation = MarketSituationManager().get_situation_cache()
			@@ -279,7 +232,7 @@
			limit_up_time = None
			if code not in limit_up_price_dict:
			continue
			is_limit_up = abs(float(limit_up_price_dict[code]) - float(price)) < 0.01
			is_limit_up = abs(float(limit_up_price_dict[code]) - float(price)) < 0.001
			# 纠正数据
			if is_limit_up and limit_up_time is None:
			limit_up_time = tool.get_now_time_str()