From b946684114d097e937b766f986d12c7eea8edce8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 18 九月 2022 17:23:43 +0800
Subject: [PATCH] l2数据计算优化
---
server.py | 14 +++++++++++---
1 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/server.py b/server.py
index 8d532f2..5c52eea 100644
--- a/server.py
+++ b/server.py
@@ -6,11 +6,13 @@
import time
import data_process
+import global_util
import gpcode_manager
import authority
import juejin
import l2_data_manager
import l2_data_util
+import ths_industry_util
import tool
import trade_manager
import l2_code_operate
@@ -103,7 +105,7 @@
self.l2CodeOperate.set_operate_code_state(client, channel, 1)
if gpcode_manager.is_listen(code):
- l2_data_manager.process_data(code, datas, capture_timestamp)
+ l2_data_manager.L2TradeDataProcessor.process(code, datas, capture_timestamp)
except l2_data_manager.L2DataException as l:
# 鍗曚环涓嶇
if l.get_code() == l2_data_manager.L2DataException.CODE_PRICE_ERROR:
@@ -154,8 +156,14 @@
t1.start()
elif type == 2:
# 娑ㄥ仠浠ｇ爜
- codeList = data_process.parseGPCode(_str)
- gpcode_manager.set_limit_up_list(codeList)
+ dataList = data_process.parseGPCode(_str)
+ # 璁剧疆娑ㄥ仠鏃堕棿
+ for d in dataList:
+ _time = d["time"]
+ if _time != "00:00:00":
+ global_util.limit_up_time[d["code"]] = _time
+ gpcode_manager.set_limit_up_list(dataList)
+ ths_industry_util.set_industry_hot_num(dataList)
elif type == 3:
# 浜ゆ槗鎴愬姛淇℃伅
dataList = data_process.parseList(_str)
--
Gitblit v1.8.0