From 499ce9a713763445d7797c321722e74797fac13e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 01 九月 2023 15:40:35 +0800
Subject: [PATCH] 注释掉测试
---
third_data/data_server.py | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index 6feb510..4a26292 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -1,6 +1,7 @@
import http
import json
import socketserver
+import threading
import time
from http.server import BaseHTTPRequestHandler
import dask
@@ -477,16 +478,16 @@
self.__send_response(result_str)
def __process_kpl_data(self, data):
- def do_limit_up(result_list):
- if result_list:
+ def do_limit_up(result_list_):
+ if result_list_:
# 淇濆瓨娑ㄥ仠鏃堕棿
- for d in result_list:
+ for d in result_list_:
code = d[0]
if code.find("00") == 0 or code.find("60") == 0:
limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2]))
code_price_manager.Buy1PriceManager().set_limit_up_time(code, limit_up_time)
- kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list)
- self.__kplDataManager.save_data(type_, result_list)
+ kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list_)
+ self.__kplDataManager.save_data(type_, result_list_)
type_ = data["type"]
print("寮�鐩樺暒type:", type_)
@@ -505,8 +506,7 @@
self.__kplDataManager.save_data(type_, result_list)
elif type_ == KPLDataType.LIMIT_UP.value:
result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP)
- do_limit_up(result_list)
-
+ threading.Thread(target=lambda :do_limit_up(result_list),daemon=True).start()
elif type_ == KPLDataType.OPEN_LIMIT_UP.value:
result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP)
if result_list:
--
Gitblit v1.8.0