Administrator
2023-08-21 6f375ad20b52a8e71333c1b344711068819b9439
华鑫本地/系统订单号管理独立
1个文件已修改
31 ■■■■ 已修改文件
db/redis_manager_delegate.py 31 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
db/redis_manager_delegate.py
@@ -176,20 +176,23 @@
            try:
                data = cls.__async_task_queue.get()
                if data:
                    db = data[0]
                    method_name = data[1]
                    args = data[2]
                    _redis = RedisManager(db).getRedisNoPool()
                    method = getattr(RedisUtils, method_name)
                    if type(args) == tuple:
                        args = list(args)
                        args.insert(0, _redis)
                        args = tuple(args)
                        result = method(*args)
                    else:
                        args = tuple([_redis, args])
                        result = method(*args)
                    try:
                        db = data[0]
                        method_name = data[1]
                        args = data[2]
                        _redis = RedisManager(db).getRedisNoPool()
                        method = getattr(RedisUtils, method_name)
                        if type(args) == tuple:
                            args = list(args)
                            args.insert(0, _redis)
                            args = tuple(args)
                            result = method(*args)
                        else:
                            args = tuple([_redis, args])
                            result = method(*args)
                    except Exception as e2:
                        logging.exception(e2)
                        logging.error(data)
            except Exception as e1:
                logging.exception(e1)
                pass