From 967abfe26abe09c26df61fe48bab1d64e2253cef Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 20 十一月 2024 15:26:37 +0800
Subject: [PATCH] 添加新接口
---
servers/data_server.py | 41 +++++++++++++++++++++++++++++++++++++++--
1 files changed, 39 insertions(+), 2 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index 2c822f2..5738c7d 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -536,7 +536,8 @@
# 浠ｇ爜,鍚嶇О,娑ㄥ仠鏃堕棿,鏄惁鐐告澘,鏄惁鎯充拱,鏄惁宸茬粡涓嬭繃鍗�,娑ㄥ仠鏃堕棿,鑷敱娴侀�氬競鍊�,鏄惁鍦ㄩ粦鍚嶅崟閲岄潰, 鏄惁鏈夎鲸璇嗗害, 澶у崟鍑�棰�
codes_info.append(
[d[3], d[4], tool.to_time_str(int(d[5])), 1 if d[3] not in now_limit_up_codes else 0, 0, 0, d[12],
- output_util.money_desc(d[13]), 1, 1 if l2_trade_util.is_in_forbidden_trade_codes(d[3]) else 0, 1 if d[3] in special_codes else 0, CodeInMoneyManager().get_money(d[3])])
+ output_util.money_desc(d[13]), 1, 1 if l2_trade_util.is_in_forbidden_trade_codes(d[3]) else 0,
+ 1 if d[3] in special_codes else 0, CodeInMoneyManager().get_money(d[3])])
codes_info.sort(key=lambda x: x[2])
# 鏌ヨ鏄惁涓烘兂涔板崟
green_codes = gpcode_manager.GreenListCodeManager().list_codes_cache()
@@ -767,6 +768,42 @@
response_data = json.dumps({"code": 0, "data": fdata})
except Exception as e:
logger_debug.exception(e)
+ elif url.path == "/get_place_order_records":
+ # 鑾峰彇涓嬪崟璁板綍
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ try:
+ day = ps_dict.get("day")
+ if not day:
+ day = tool.get_now_date_str()
+ records = log_export.load_trade_recod_by_type("place_order", date=day)
+ fdata = []
+ for record in records:
+ print(record)
+ # (涓嬪崟鏃堕棿, 浠ｇ爜, 鍚嶇О, 涓嬪崟妯″紡, 鏉垮潡淇℃伅)
+ fdata.append((record[0], record[1], gpcode_manager.get_code_name(record[1]), record[3]["mode_desc"],
+ record[3].get("block_info")))
+ response_data = json.dumps({"code": 0, "data": fdata})
+ except:
+ pass
+ elif url.path == "/get_blocks_in_money_info":
+ # 鑾峰彇鏉垮潡璧勯噾娴佸叆鐘跺喌
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ type_ = ps_dict.get("type")
+ try:
+ fdatas = []
+ if type_ == 0:
+ fdatas = RealTimeKplMarketData.top_in_list_cache
+ if not fdatas:
+ datas = self.__kplDataManager.get_data(KPLDataType.JINGXUAN_RANK.value)
+ fdatas = datas
+ elif type_ == 1:
+ fdatas = RealTimeKplMarketData.top_out_list_cache
+ if not fdatas:
+ datas = self.__kplDataManager.get_data(KPLDataType.JINGXUAN_RANK_OUT.value)
+ fdatas = datas
+ response_data = json.dumps({"code": 0, "data": fdatas})
+ except:
+ pass
async_log_util.info(logger_request_api, f"缁撴潫璇锋眰{tool.get_thread_id()}-{url}")
self.send_response(200)
@@ -793,7 +830,7 @@
CodeInMoneyManager().set_money(code, d[code])
except Exception as e:
logging.exception(e)
- result_str =json.dumps({"code": 0})
+ result_str = json.dumps({"code": 0})
self.__send_response(result_str)
def __process_kpl_data(self, data_origin):
--
Gitblit v1.8.0