华鑫托管改造初步设计

Administrator

2023-08-14 31823d638d8d824bb6240e5b0fe11c54d97473a7

 output/kp_client_msg_manager.py

@@ -10,6 +10,7 @@
from log_module import log, log_export
from db.redis_manager import RedisManager, RedisUtils
from log_module.log import logger_kp_msg
from utils import middle_api_protocol, tool

CLIENT_IDS = ["zjb", "hxh"]

@@ -41,13 +42,17 @@


# 添加消息
@tool.async_call
def add_msg(code, msg):
    # 根据代码获取名称
    name = gpcode_manager.get_code_name(code)
    msg = f"【{name}({code})】{msg}"
    __temp_msg_queue.put_nowait(msg)
    # 添加到日志
    logger_kp_msg.info(msg)
    fdata = middle_api_protocol.load_kp_msg(msg)
    middle_api_protocol.request(fdata)
    #
    # __temp_msg_queue.put_nowait(msg)
    # # 添加到日志
    # logger_kp_msg.info(msg)


def read_msg(client_id):