注释掉测试

Administrator

2023-09-01 499ce9a713763445d7797c321722e74797fac13e

注释掉测试

 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: