bug修复

admin

2024-01-15 bdb34b3cbdf27b717942a4b8b2c9d73ff77e3340

bug修复

 middle_server.py

@@ -164,7 +164,11 @@
                                        if builtins.type(args) == tuple or builtins.type(args) == list:
                                            args = list(args)
                                            if cmd == "setex":
                                                args_.append(json.dumps(args))
                                                args_.append(args[0])
                                                if type(args[1]) == list:
                                                    args_.append(json.dumps(args[1]))
                                                else:
                                                    args_.append(args[1])
                                            else:
                                                for a in args:
                                                    args_.append(a)
@@ -190,7 +194,11 @@
                                            if builtins.type(args) == tuple or builtins.type(args) == list:
                                                args = list(args)
                                                if cmd == "setex":
                                                    args_.append(json.dumps(args))
                                                    args_.append(args[0])
                                                    if type(args[1]) == list:
                                                        args_.append(json.dumps(args[1]))
                                                    else:
                                                        args_.append(args[1])
                                                else:
                                                    for a in args:
                                                        args_.append(a)
@@ -270,12 +278,11 @@
                            sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
                            pass
                        elif data_json["type"] == "push_msg":
                            data = data_json["data"]
                            data = data["data"]
                            data = data_json["data"]["data"]
                            _type = data["type"]
                            data = data.get("data")
                            logger_debug.info(f"推送消息：{data_json}")
                            push_msg_manager.__push_msg(_type, data)
                            push_msg_manager.push_msg(_type, data)
                            result_str = json.dumps({"code": 0, "data": {}})
                            sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
                    finally:

 output/push_msg_manager.py

@@ -40,7 +40,7 @@


# 添加消息
def __push_msg(msg_type, data=None):
def push_msg(msg_type, data=None):
    fdata = {"type": msg_type}
    if data:
        fdata["data"] = data