增加日志记录

Administrator

2023-12-26 b244e58281eb648b020ac6c4c17b070b80752cb8

增加日志记录

 third_data/data_server.py

@@ -8,7 +8,7 @@
import dask

from code_attribute.gpcode_manager import BlackListCodeManager
from log_module.log import logger_system, logger_debug
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up
from utils import global_util, tool, data_export_util
from code_attribute import gpcode_manager
from log_module import log, log_analyse, log_export
@@ -655,6 +655,8 @@
        elif type_ == KPLDataType.LIMIT_UP.value:
            result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP)
            self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list))
            # 记录涨停日志
            logger_kpl_limit_up.info(result_list)
        elif type_ == KPLDataType.OPEN_LIMIT_UP.value:
            result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP)
            if result_list:

 third_data/kpl_data_manager.py

@@ -395,7 +395,6 @@
        requests.post("http://127.0.0.1:9004/upload_kpl_data", json.dumps(root_data))

    def get_limit_up():
        last_time = 0
        while True:
            if tool.is_trade_time():
                try:
@@ -403,11 +402,6 @@
                    result = json.loads(results)
                    start_time = time.time()
                    __upload_data("limit_up", result)
                    if start_time - last_time >= 60:
                        last_time = time.time()
                        # 记录涨停数据
                        logger_kpl_limit_up.info(result)
                    # logger_kpl_limit_up_reason_change.info("上传耗时：{}", time.time() - start_time)
                except Exception as e:
                    logging.exception(e)
            time.sleep(3)

 utils/data_export_util.py

@@ -150,7 +150,7 @@
                try:
                    left_num = data["val"]["num"] - cancel_data["val"]["num"]
                    if left_num > 0:
                        cancel_info = f"{left_num}手未撤:{cancel_data['index']}"
                        cancel_info = f"成交:{left_num} 序号:{cancel_data['index']}"
                    else:
                        cancel_info = "{}-{}".format(cancel_data["index"], f"{cancel_data['val']['time']}") + (
                            f".{cancel_data['val']['tms']}" if "tms" in cancel_data["val"] else '')