refactor: 完成 0.4.0 版本更新

完成 0.4.0 版本更新, 为了消除此前提交消息风格不一致与错误提交超大文件的问题, 维持代码统计数据的准确性和提交消息风格的一致性, 重新初始化仓库; 旧的提交历史在 HeurAMS-legacy 仓库(https://gitea.imwangzhiyu.xyz/ajax/HeurAMS-legacy)

src/heurams/kernel/particles/__init__.py

@@ -0,0 +1,29 @@
+"""
+Particle 模块 - 粒子对象系统
+
+提供闪卡所需对象, 使用物理学粒子的领域驱动设计
+"""
+
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+logger.debug("粒子模块已加载")
+
+from .electron import Electron
+from .nucleon import Nucleon
+from .orbital import Orbital
+from .atom import Atom, atom_registry
+from .probe import probe_all, probe_by_filename
+from .loader import load_nucleon, load_electron
+
+__all__ = [
+    "Electron",
+    "Nucleon",
+    "Orbital",
+    "Atom",
+    "probe_all",
+    "probe_by_filename",
+    "load_nucleon",
+    "load_electron",
+    "atom_registry",
+]

src/heurams/kernel/particles/atom.py

@@ -0,0 +1,238 @@
+from .electron import Electron
+from .nucleon import Nucleon
+from .orbital import Orbital
+from typing import TypedDict
+import pathlib
+import typing
+import toml
+import json
+import bidict
+from heurams.context import config_var
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+
+
+class AtomRegister_runtime(TypedDict):
+    locked: bool  # 只读锁定标识符
+    min_rate: int  # 最低评分
+    newact: bool # 新激活
+
+
+class AtomRegister(TypedDict):
+    nucleon: Nucleon
+    nucleon_path: pathlib.Path
+    nucleon_fmt: str
+    electron: Electron
+    electron_path: pathlib.Path
+    electron_fmt: str
+    orbital: Orbital
+    orbital_path: pathlib.Path
+    orbital_fmt: str
+    runtime: AtomRegister_runtime
+
+
+class Atom:
+    """
+    统一处理一系列对象的所有信息与持久化:
+        关联电子 (算法数据)
+        关联核子 (内容数据)
+        关联轨道 (策略数据)
+        以及关联路径
+    """
+
+    def __init__(self, ident=""):
+        logger.debug("创建 Atom 实例, ident: '%s'", ident)
+        self.ident = ident
+        atom_registry[ident] = self
+        logger.debug("Atom 已注册到全局注册表, 当前注册表大小: %d", len(atom_registry))
+        # self.is_evaled = False
+        self.registry: AtomRegister = {  # type: ignore
+            "nucleon": None,
+            "nucleon_path": None,
+            "nucleon_fmt": "toml",
+            "electron": None,
+            "electron_path": None,
+            "electron_fmt": "json",
+            "orbital": None,
+            "orbital_path": None,  # 允许设置为 None, 此时使用 nucleon 文件内的推荐配置
+            "orbital_fmt": "toml",
+            "runtime": {"locked": False, "min_rate": 0x3F3F3F3F, "newact": False},
+        }
+        self.do_eval()
+        logger.debug("Atom 初始化完成")
+
+    def link(self, key, value):
+        logger.debug("Atom.link: key='%s', value type: %s", key, type(value).__name__)
+        if key in self.registry.keys():
+            self.registry[key] = value
+            logger.debug("键 '%s' 已链接, 触发 do_eval", key)
+            self.do_eval()
+            if key == 'electron':
+                if self.registry['electron'].is_activated() == 0:
+                    self.registry['runtime']['newact'] = True
+        else:
+            logger.error("尝试链接不受支持的键: '%s'", key)
+            raise ValueError("不受支持的原子元数据链接操作")
+
+    def minimize(self, rating):
+        """效果等同于 self.registry['runtime']['min_rate'] = min(rating, self.registry['runtime']['min_rate'])
+
+        Args:
+            rating (int): 评分
+        """
+        self.registry["runtime"]["min_rate"] = min(
+            rating, self.registry["runtime"]["min_rate"]
+        )
+
+    def lock(self, locked=-1):
+        logger.debug(f"锁定参数 {locked}")
+        """锁定, 效果等同于 self.registry['runtime']['locked'] = locked 或者返回是否锁定"""
+        if locked == 1:
+            self.registry["runtime"]["locked"] = True
+            return 1
+        elif locked == 0:
+            self.registry["runtime"]["locked"] = False
+            return 1
+        elif locked == -1:
+            return self.registry["runtime"]["locked"]
+        return 0
+
+    def revise(self):
+        """执行最终评分
+        PuzzleWidget 的 handler 除了测试, 严禁直接执行 Electron 的 revisor 函数, 否则造成逻辑混乱
+        """
+        if self.registry["runtime"]["locked"]:
+            logger.debug(f"允许总评分: {self.registry['runtime']['min_rate']}")
+            self.registry["electron"].revisor(self.registry["runtime"]["min_rate"], is_new_activation=self.registry["runtime"]["newact"])
+        else:
+            logger.debug("禁止总评分")
+
+    def do_eval(self):
+        """
+        执行并以结果替换当前单元的所有 eval 语句
+        TODO: 带有限制的 eval, 异步/多线程执行避免堵塞
+        """
+        logger.debug("Atom.do_eval 开始")
+
+        # eval 环境设置
+        def eval_with_env(s: str):
+            # 初始化默认值
+            nucleon = self.registry["nucleon"]
+            default = {}
+            metadata = {}
+            try:
+                default = config_var.get()["puzzles"]
+                metadata = nucleon.metadata
+            except Exception:
+                # 如果无法获取配置或元数据, 使用空字典
+                logger.debug("无法获取配置或元数据, 使用空字典")
+                pass
+            try:
+                eval_value = eval(s)
+                if isinstance(eval_value, (list, dict)):
+                    ret = eval_value
+                else:
+                    ret = str(eval_value)
+                logger.debug(
+                    "eval 执行成功: '%s' -> '%s'",
+                    s,
+                    str(ret)[:50] + "..." if len(ret) > 50 else ret,
+                )
+            except Exception as e:
+                ret = f"此 eval 实例发生错误: {e}"
+                logger.warning("eval 执行错误: '%s' -> %s", s, e)
+            return ret
+
+        def traverse(data, modifier):
+            if isinstance(data, dict):
+                for key, value in data.items():
+                    data[key] = traverse(value, modifier)
+                return data
+            elif isinstance(data, list):
+                for i, item in enumerate(data):
+                    data[i] = traverse(item, modifier)
+                return data
+            elif isinstance(data, tuple):
+                return tuple(traverse(item, modifier) for item in data)
+            else:
+                if isinstance(data, str):
+                    if data.startswith("eval:"):
+                        logger.debug("发现 eval 表达式: '%s'", data[5:])
+                        return modifier(data[5:])
+                return data
+
+        # 如果 nucleon 存在且有 do_eval 方法, 调用它
+        nucleon = self.registry["nucleon"]
+        if nucleon is not None and hasattr(nucleon, "do_eval"):
+            nucleon.do_eval()
+            logger.debug("已调用 nucleon.do_eval")
+
+        # 如果 electron 存在且其 algodata 包含 eval 字符串, 遍历它
+        electron = self.registry["electron"]
+        if electron is not None and hasattr(electron, "algodata"):
+            traverse(electron.algodata, eval_with_env)
+            logger.debug("已处理 electron algodata eval")
+
+        # 如果 orbital 存在且是字典, 遍历它
+        orbital = self.registry["orbital"]
+        if orbital is not None and isinstance(orbital, dict):
+            traverse(orbital, eval_with_env)
+            logger.debug("orbital eval 完成")
+
+        logger.debug("Atom.do_eval 完成")
+
+    def persist(self, key):
+        logger.debug("Atom.persist: key='%s'", key)
+        path: pathlib.Path | None = self.registry[key + "_path"]
+        if isinstance(path, pathlib.Path):
+            path = typing.cast(pathlib.Path, path)
+            logger.debug("持久化路径: %s, 格式: %s", path, self.registry[key + "_fmt"])
+            path.parent.mkdir(parents=True, exist_ok=True)
+            if self.registry[key + "_fmt"] == "toml":
+                with open(path, "r+") as f:
+                    f.seek(0)
+                    f.truncate()
+                    toml.dump(self.registry[key], f)
+                logger.debug("TOML 数据已保存到: %s", path)
+            elif self.registry[key + "_fmt"] == "json":
+                with open(path, "r+") as f:
+                    origin = json.load(f)
+                    f.seek(0)
+                    f.truncate()
+                    origin[self.ident] = self.registry[key].algodata
+                    json.dump(origin, f, indent=2, ensure_ascii=False)
+                logger.debug("JSON 数据已保存到: %s", path)
+            else:
+                logger.error("不受支持的持久化格式: %s", self.registry[key + "_fmt"])
+                raise KeyError("不受支持的持久化格式")
+        else:
+            logger.error("路径未初始化: %s_path", key)
+            raise TypeError("对未初始化的路径对象操作")
+
+    def __getitem__(self, key):
+        logger.debug("Atom.__getitem__: key='%s'", key)
+        if key in self.registry:
+            value = self.registry[key]
+            logger.debug("返回 value type: %s", type(value).__name__)
+            return value
+        logger.error("不支持的键: '%s'", key)
+        raise KeyError(f"不支持的键: {key}")
+
+    def __setitem__(self, key, value):
+        logger.debug(
+            "Atom.__setitem__: key='%s', value type: %s", key, type(value).__name__
+        )
+        if key in self.registry:
+            self.registry[key] = value
+            logger.debug("键 '%s' 已设置", key)
+        else:
+            logger.error("不支持的键: '%s'", key)
+            raise KeyError(f"不支持的键: {key}")
+
+    @staticmethod
+    def placeholder():
+        return (Electron.placeholder(), Nucleon.placeholder(), {})
+
+
+atom_registry: bidict.bidict[str, Atom] = bidict.bidict()

src/heurams/kernel/particles/electron.py

@@ -0,0 +1,151 @@
+import heurams.services.timer as timer
+from heurams.context import config_var
+from heurams.kernel.algorithms import algorithms
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+
+
+class Electron:
+    """电子: 记忆分析元数据及算法"""
+
+    def __init__(self, ident: str, algodata: dict = {}, algo_name: str = "supermemo2"):
+        """初始化电子对象 (记忆数据)
+
+        Args:
+            ident: 算法的唯一标识符, 用于区分不同的算法实例, 使用 algodata[ident] 获取
+            algodata: 算法数据字典, 包含算法的各项参数和设置
+            algo: 使用的算法模块标识
+        """
+        logger.debug(
+            "创建 Electron 实例, ident: '%s', algo_name: '%s'", ident, algo_name
+        )
+        self.algodata = algodata
+        self.ident = ident
+        self.algo = algorithms[algo_name]
+        logger.debug("使用的算法类: %s", self.algo.__name__)
+
+        if self.algo not in self.algodata.keys():
+            self.algodata[self.algo.algo_name] = {}
+            logger.debug("算法键 '%s' 不存在, 已创建空字典", self.algo)
+        if not self.algodata[self.algo.algo_name]:
+            logger.debug("算法数据为空, 使用默认值初始化")
+            self._default_init(self.algo.defaults)
+        else:
+            logger.debug("算法数据已存在, 跳过默认初始化")
+        logger.debug(
+            "Electron 初始化完成, algodata keys: %s", list(self.algodata.keys())
+        )
+
+    def _default_init(self, defaults: dict):
+        """默认初始化包装"""
+        logger.debug(
+            "Electron._default_init: 使用默认值, keys: %s", list(defaults.keys())
+        )
+        self.algodata[self.algo.algo_name] = defaults.copy()
+
+    def activate(self):
+        """激活此电子"""
+        logger.debug("Electron.activate: 激活 ident='%s'", self.ident)
+        self.algodata[self.algo.algo_name]["is_activated"] = 1
+        self.algodata[self.algo.algo_name]["last_modify"] = timer.get_timestamp()
+        logger.debug("电子已激活, is_activated=1")
+
+    def modify(self, var: str, value):
+        """修改 algodata[algo] 中子字典数据"""
+        logger.debug("Electron.modify: var='%s', value=%s", var, value)
+        if var in self.algodata[self.algo.algo_name]:
+            self.algodata[self.algo.algo_name][var] = value
+            self.algodata[self.algo.algo_name]["last_modify"] = timer.get_timestamp()
+            logger.debug("变量 '%s' 已修改, 更新 last_modify", var)
+        else:
+            logger.warning("'%s' 非已知元数据字段", var)
+            print(f"警告: '{var}' 非已知元数据字段")
+
+    def is_due(self):
+        """是否应该复习"""
+        logger.debug("Electron.is_due: 检查 ident='%s'", self.ident)
+        result = self.algo.is_due(self.algodata)
+        logger.debug("is_due 结果: %s", result)
+        return result and self.is_activated()
+
+    def is_activated(self):
+        result = self.algodata[self.algo.algo_name]["is_activated"]
+        logger.debug("Electron.is_activated: ident='%s', 结果: %d", self.ident, result)
+        return result
+
+    def get_rate(self):
+        "评价"
+        try:
+            logger.debug("Electron.rate: ident='%s'", self.ident)
+            result = self.algo.rate(self.algodata)
+            logger.debug("rate 结果: %s", result)
+            return result
+        except:
+            return 0
+
+    def nextdate(self) -> int:
+        logger.debug("Electron.nextdate: ident='%s'", self.ident)
+        result = self.algo.nextdate(self.algodata)
+        logger.debug("nextdate 结果: %d", result)
+        return result
+
+    def revisor(self, quality: int = 5, is_new_activation: bool = False):
+        """算法迭代决策机制实现
+
+        Args:
+            quality (int): 记忆保留率量化参数 (0-5)
+            is_new_activation (bool): 是否为初次激活
+        """
+        logger.debug(
+            "Electron.revisor: ident='%s', quality=%d, is_new_activation=%s",
+            self.ident,
+            quality,
+            is_new_activation,
+        )
+        self.algo.revisor(self.algodata, quality, is_new_activation)
+        logger.debug(
+            "revisor 完成, 更新后的 algodata: %s", self.algodata.get(self.algo, {})
+        )
+
+    def __str__(self):
+        return (
+            f"记忆单元预览 \n"
+            f"标识符: '{self.ident}' \n"
+            f"算法: {self.algo} \n"
+            f"易度系数: {self.algodata[self.algo.algo_name]['efactor']:.2f} \n"
+            f"已经重复的次数: {self.algodata[self.algo.algo_name]['rept']} \n"
+            f"下次间隔: {self.algodata[self.algo.algo_name]['interval']} 天 \n"
+            f"下次复习日期时间戳: {self.algodata[self.algo.algo_name]['next_date']}"
+        )
+
+    def __eq__(self, other):
+        if self.ident == other.ident:
+            return True
+        return False
+
+    def __hash__(self):
+        return hash(self.ident)
+
+    def __getitem__(self, key):
+        if key == "ident":
+            return self.ident
+        if key in self.algodata[self.algo.algo_name]:
+            return self.algodata[self.algo.algo_name][key]
+        else:
+            raise KeyError(f"键 '{key}' 未在 algodata[self.algo] 中")
+
+    def __setitem__(self, key, value):
+        if key == "ident":
+            raise AttributeError("ident 应为只读")
+        self.algodata[self.algo.algo_name][key] = value
+        self.algodata[self.algo.algo_name]["last_modify"] = timer.get_timestamp()
+
+    def __len__(self):
+        """仅返回当前算法的配置数量"""
+        return len(self.algodata[self.algo.algo_name])
+
+    @staticmethod
+    def placeholder():
+        """生成一个电子占位符"""
+        return Electron("电子对象样例内容", {})

src/heurams/kernel/particles/loader.py

@@ -0,0 +1,71 @@
+from .nucleon import Nucleon
+from .electron import Electron
+import heurams.services.hasher as hasher
+import pathlib
+import toml
+import json
+from copy import deepcopy
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+
+
+def load_nucleon(path: pathlib.Path, fmt="toml"):
+    logger.debug("load_nucleon: 加载文件 %s, 格式: %s", path, fmt)
+    with open(path, "r") as f:
+        dictdata = dict()
+        dictdata = toml.load(f)  # type: ignore
+        logger.debug("TOML 解析成功, keys: %s", list(dictdata.keys()))
+        lst = list()
+        nested_data = dict()
+        # 修正 toml 解析器的不管嵌套行为
+        for key, value in dictdata.items():
+            if "__metadata__" in key:  # 以免影响句号
+                if "." in key:
+                    parts = key.split(".")
+                    current = nested_data
+                    for part in parts[:-1]:
+                        if part not in current:
+                            current[part] = {}
+                        current = current[part]
+                    current[parts[-1]] = value
+                logger.debug("处理元数据键: %s", key)
+            else:
+                nested_data[key] = value
+        logger.debug("嵌套数据处理完成, keys: %s", list(nested_data.keys()))
+        # print(nested_data)
+        for item, attr in nested_data.items():
+            if item == "__metadata__":
+                continue
+            logger.debug("处理项目: %s", item)
+            lst.append(
+                (
+                    Nucleon(item, attr, deepcopy(nested_data["__metadata__"])),
+                    deepcopy(nested_data["__metadata__"]["orbital"]),
+                )
+            )
+        logger.debug("load_nucleon 完成, 加载了 %d 个 Nucleon 对象", len(lst))
+        return lst
+
+
+def load_electron(path: pathlib.Path, fmt="json") -> dict:
+    """从文件路径加载电子对象
+
+    Args:
+        path (pathlib.Path): 路径
+        fmt (str): 文件格式(可选, 默认 json)
+
+    Returns:
+        dict: 键名是电子对象名称, 值是电子对象
+    """
+    logger.debug("load_electron: 加载文件 %s, 格式: %s", path, fmt)
+    with open(path, "r") as f:
+        dictdata = dict()
+        dictdata = json.load(f)  # type: ignore
+        logger.debug("JSON 解析成功, keys: %s", list(dictdata.keys()))
+        dic = dict()
+        for item, attr in dictdata.items():
+            logger.debug("处理电子项目: %s", item)
+            dic[item] = Electron(item, attr)
+        logger.debug("load_electron 完成, 加载了 %d 个 Electron 对象", len(dic))
+        return dic

src/heurams/kernel/particles/nucleon.py

@@ -0,0 +1,104 @@
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+
+
+class Nucleon:
+    """原子核: 材料元数据"""
+
+    def __init__(self, ident: str, payload: dict, metadata: dict = {}):
+        """初始化原子核 (记忆内容)
+
+        Args:
+            ident: 唯一标识符
+            payload: 记忆内容信息
+            metadata: 可选元数据信息
+        """
+        logger.debug(
+            "创建 Nucleon 实例, ident: '%s', payload keys: %s, metadata keys: %s",
+            ident,
+            list(payload.keys()) if payload else [],
+            list(metadata.keys()) if metadata else [],
+        )
+        self.metadata = metadata
+        self.payload = payload
+        self.ident = ident
+        logger.debug("Nucleon 初始化完成")
+
+    def __getitem__(self, key):
+        logger.debug("Nucleon.__getitem__: key='%s'", key)
+        if key == "ident":
+            logger.debug("返回 ident: '%s'", self.ident)
+            return self.ident
+        if key in self.payload:
+            value = self.payload[key]
+            logger.debug(
+                "返回 payload['%s'], value type: %s", key, type(value).__name__
+            )
+            return value
+        else:
+            logger.error("键 '%s' 未在 payload 中找到", key)
+            raise KeyError(f"Key '{key}' not found in payload.")
+
+    def __iter__(self):
+        yield from self.payload.keys()
+
+    def __len__(self):
+        return len(self.payload)
+
+    def __hash__(self):
+        return hash(self.ident)
+
+    def do_eval(self):
+        """
+        执行并以结果替换当前单元的所有 eval 语句
+        TODO: 带有限制的 eval, 异步/多线程执行避免堵塞
+        """
+        logger.debug("Nucleon.do_eval 开始")
+
+        # eval 环境设置
+        def eval_with_env(s: str):
+            try:
+                nucleon = self
+                eval_value = eval(s)
+                if isinstance(eval_value, (int, float)):
+                    ret = str(eval_value)
+                else:
+                    ret = eval_value
+                logger.debug(
+                    "eval 执行成功: '%s' -> '%s'",
+                    s,
+                    str(ret)[:50] + "..." if len(ret) > 50 else ret,
+                )
+            except Exception as e:
+                ret = f"此 eval 实例发生错误: {e}"
+                logger.warning("eval 执行错误: '%s' -> %s", s, e)
+            return ret
+
+        def traverse(data, modifier):
+            if isinstance(data, dict):
+                for key, value in data.items():
+                    data[key] = traverse(value, modifier)
+                return data
+            elif isinstance(data, list):
+                for i, item in enumerate(data):
+                    data[i] = traverse(item, modifier)
+                return data
+            elif isinstance(data, tuple):
+                return tuple(traverse(item, modifier) for item in data)
+            else:
+                if isinstance(data, str):
+                    if data.startswith("eval:"):
+                        logger.debug("发现 eval 表达式: '%s'", data[5:])
+                        return modifier(data[5:])
+                return data
+
+        traverse(self.payload, eval_with_env)
+        traverse(self.metadata, eval_with_env)
+        logger.debug("Nucleon.do_eval 完成")
+
+    @staticmethod
+    def placeholder():
+        """生成一个占位原子核"""
+        logger.debug("创建 Nucleon 占位符")
+        return Nucleon("核子对象样例内容", {})

src/heurams/kernel/particles/orbital.py

@@ -0,0 +1,29 @@
+from typing import TypedDict
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+logger.debug("Orbital 类型定义模块已加载")
+
+
+class OrbitalSchedule(TypedDict):
+    quick_review: list
+    recognition: list
+    final_review: list
+
+
+class Orbital(TypedDict):
+    schedule: OrbitalSchedule
+    puzzles: dict
+
+
+"""一份示例
+["__metadata__.orbital.puzzles"] # 谜题定义
+"Recognition" = { __origin__ = "recognition", __hint__ = "", primary = "eval:nucleon['content']", secondery = ["eval:nucleon['keyword_note']", "eval:nucleon['note']"], top_dim = ["eval:nucleon['translation']"] }
+"SelectMeaning" = { __origin__ = "mcq", __hint__ = "eval:nucleon['content']", jammer = "eval:nucleon['keyword_note']", max_riddles_num = "eval:default['mcq']['max_riddles_num']", prefix = "选择正确项: " }
+"FillBlank" = { __origin__ = "cloze", __hint__ = "", text = "eval:nucleon['content']", delimiter = "eval:metadata['formation']['delimiter']", min_denominator = "eval:default['cloze']['min_denominator']"}
+
+["__metadata__.orbital.schedule"] # 内置的推荐学习方案
+quick_review = [["FillBlank", "1.0"], ["SelectMeaning", "0.5"], ["recognition", "1.0"]]
+recognition = [["recognition", "1.0"]]
+final_review = [["FillBlank", "0.7"], ["SelectMeaning", "0.7"], ["recognition", "1.0"]]
+"""

src/heurams/kernel/particles/probe.py

@@ -0,0 +1,61 @@
+from heurams.context import config_var
+import pathlib
+from heurams.services.logger import get_logger
+
+logger = get_logger(__name__)
+
+
+def probe_by_filename(filename):
+    """探测指定文件 (无扩展名) 的所有信息"""
+    logger.debug("probe_by_filename: 探测文件 '%s'", filename)
+    paths: dict = config_var.get().get("paths")
+    logger.debug("配置路径: %s", paths)
+    formats = ["toml", "json"]
+    result = {}
+    for item, attr in paths.items():
+        for i in formats:
+            attr: pathlib.Path = pathlib.Path(attr) / filename + "." + i
+            if attr.exists():
+                logger.debug("找到文件: %s", attr)
+                result[item.replace("_dir", "")] = str(attr)
+            else:
+                logger.debug("文件不存在: %s", attr)
+    logger.debug("probe_by_filename 结果: %s", result)
+    return result
+
+
+def probe_all(is_stem=1):
+    """依据目录探测所有信息
+
+    Args:
+        is_stem (boolean): 是否**删除**文件扩展名
+
+    Returns:
+        dict: 有三项, 每一项的键名都是文件组类型, 值都是文件组列表, 只包含文件名
+    """
+    logger.debug("probe_all: 开始探测, is_stem=%d", is_stem)
+    paths: dict = config_var.get().get("paths")
+    logger.debug("配置路径: %s", paths)
+    result = {}
+    for item, attr in paths.items():
+        attr: pathlib.Path = pathlib.Path(attr)
+        result[item.replace("_dir", "")] = list()
+        logger.debug("扫描目录: %s", attr)
+        file_count = 0
+        for i in attr.iterdir():
+            if not i.is_dir():
+                file_count += 1
+                if is_stem:
+                    result[item.replace("_dir", "")].append(str(i.stem))
+                else:
+                    result[item.replace("_dir", "")].append(str(i.name))
+        logger.debug("目录 %s 中找到 %d 个文件", attr, file_count)
+    logger.debug("probe_all 完成, 结果 keys: %s", list(result.keys()))
+    return result
+
+
+if __name__ == "__main__":
+    import os
+
+    print(os.getcwd())
+    print(probe_all())