refactor: 重构代码以提高可维护性和可扩展性

- 新增 GlobalConfig 类以集中配置
- 重构 MyMongo 类以使用新的配置类
- 修改 dump.py 中的类和函数以适应新配置
- 重构 main.py 中的配置加载和处理逻辑- 删除不必要的代码和注释，简化代码结构

Author: izerui

src/base.py

@@ -161,12 +161,9 @@ def create_indexes_on_target(self, database_name: str, indexes_info: Dict[str, L
                 target_collection = target_db[collection_name]
 
                 if not indexes:
-                    print(f"   📄 集合 {collection_name}: 无索引需要创建")
                     results[collection_name] = True
                     continue
 
-                print(f"   📄 集合 {collection_name}: 准备创建 {len(indexes)} 个索引")
-
                 # 准备索引模型
                 index_models = []
                 for index_info in indexes:

src/manager.py

@@ -109,10 +109,8 @@ def dump_and_restore(self):
                         db_name, success, duration, export_time, import_time = future.result()
                         if success:
                             successful_dbs.append((db_name, duration, export_time, import_time))
-                            print(f' 🎉 数据库 {db_name} 处理完成 (耗时: {duration:.2f}秒)')
                         else:
                             failed_dbs.append((db_name, duration, export_time, import_time))
-                            print(f' 💥 数据库 {db_name} 处理失败 (耗时: {duration:.2f}秒)')
 
                     except KeyboardInterrupt:
                         print(f" ⚠️  用户中断处理数据库: {db_name}")
@@ -157,8 +155,6 @@ def dump_and_restore(self):
         else:
             print(f"   并行效率: N/A")
 
-        print(f' 🎯 所有数据库操作完成，总耗时: {total_time:.2f}秒')
-
         # 如果有失败的数据库，打印错误信息
         if failed_dbs:
             print("⚠️  部分数据库处理失败，请检查日志")

src/restore.py

@@ -51,9 +51,10 @@ def restore_db(self, database: str) -> None:
                 for i, shard_file in enumerate(shard_files):
                     import_tasks.append(('sharded', original_name, shard_file))
 
-            # 先删除原始集合（仅针对分片集合）
+            # 先重建原始集合（仅针对分片集合）
             for original_name in sharded_collections:
                 self.client[database][original_name].drop()
+                self.client[database].create_collection(original_name)
 
             # 普通任务：每个普通集合单独导入
             for collection_name in normal_collections:
@@ -108,9 +109,6 @@ def restore_db(self, database: str) -> None:
                 if errors:
                     raise Exception(f"导入过程中出现 {len(errors)} 个错误:\n" + "\n".join(errors))
 
-                print(f'✅ 数据库 {database} 并发导入完成')
-
-            print(f'✅ 数据库 {database} 并发导入完成')
 
         except Exception as e:
             print(f'❌ 导入数据库 {database} 失败: {e}')