gp_trade_low_suction.git

			@@ -1,5 +1,6 @@
			import json
			import logging
			import os
			import threading

			from api.outside_api_command_manager import ActionCallback
			@@ -71,6 +72,7 @@
			fdata["real_time_data"] = RealTimeEnvInfo().to_dict()
			# 历史数据
			fdata["history_data"] = {}
			print("获取环境", os.getpid())
			if need_hsitory_data:
			if tool.get_now_time_str() < '16:00:00':
			# 如果在16:00之前采用当前日期

			@@ -1,6 +1,7 @@
			import http
			import json
			import logging
			import os
			import socketserver
			from http.server import BaseHTTPRequestHandler

			@@ -45,13 +46,14 @@
			strategy_manager.low_suction_strtegy.add_big_orders(params)
			# logger_debug.info("upload_big_order_datas:{}", f"{params}")
			RealTimeEnvInfo().big_order_update_time = tool.get_now_time_str()
			print("获取到大单", os.getpid())
			result_str = json.dumps({"code": 0})
			elif url.path == "/upload_block_in_datas":
			# 接收板块流入数据
			params = self.__parse_request()
			strategy_manager.low_suction_strtegy.add_block_in(params)
			# logger_debug.info("upload_block_in_datas:{}", f"{params}")
			RealTimeEnvInfo().block_in=(tool.get_now_time_str(), len(params))
			RealTimeEnvInfo().block_in = (tool.get_now_time_str(), len(params))
			result_str = json.dumps({"code": 0})
			elif url.path == "/upload_limit_up_list":
			params = self.__parse_request()

			@@ -142,8 +142,9 @@
			elif url.path == "/get_codes_by_jx_plates":
			# 根据精选板块获取代码
			plates = ps_dict.get("plates")
			date = ps_dict.get("date")
			plates = set(json.loads(plates))
			sql = " select code, jx_blocks from kpl_code_blocks where " + " and ".join(
			sql = f" select code, jx_blocks from kpl_code_blocks where day = '{date}' and " + " and ".join(
			[f"jx_blocks like '%{p}%'" for p in plates])
			datas = Mysqldb().select_all(sql)
			fdatas = [(x[0], "、".join([ f"<red>{dd}</red>" if dd in plates else dd for dd in json.loads(x[1])])) for x in datas if len(set(json.loads(x[1])) & plates) == len(plates)]

			@@ -70,4 +70,5 @@


			if __name__ == "__main__":
			print(get_history_k_bars("2025-06-04"))
			RealTimeEnvInfo().kpl_current_limit_up = tool.get_now_time_str()
			print(RealTimeEnvInfo().to_dict())

	api/outside_api_callback.py	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	server/data_server.py	4 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	server/local_data_server.py	3 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	strategy/env_info.py	3 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	strategy/time_series_backtest.py	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史