electron-vue-exam-single/electron/service/configService.js

// 导入数据库操作方法
import {
  getConfig,
  setConfig,
  getAllConfigs,
  getConfigById,
  deleteConfig,
} from "../db/config.js";
import argon2 from "argon2";

// 原有接口保持不变
/**
 * 服务层：获取配置项
 * @param {string} key - 配置项键名
 * @returns {Promise<{key: string, value: string} | null>}
 */
export async function fetchConfig(key) {
  try {
    return await getConfig(key);
  } catch (error) {
    console.error("服务层: 获取配置项失败", error);
    throw error;
  }
}

/**
 * 服务层：获取所有配置项
 * @returns {Promise<Array<{id: number, key: string, value: string, protected: number}>>}
 */
export async function fetchAllConfigs() {
  try {
    return await getAllConfigs();
  } catch (error) {
    console.error("服务层: 获取所有配置项失败", error);
    throw error;
  }
}

/**
 * 服务层：通过ID获取配置项
 * @param {number} id - 配置项ID
 * @returns {Promise<{id: number, key: string, value: string, protected: number} | null>}
 */
export async function fetchConfigById(id) {
  try {
    return await getConfigById(id);
  } catch (error) {
    console.error("服务层: 通过ID获取配置项失败", error);
    throw error;
  }
}

/**
 * 服务层：保存配置项
 * @param {string} key - 配置项键名
 * @param {string} value - 配置项值
 * @returns {Promise<void>}
 */
export async function saveConfig(key, value) {
  try {
    await setConfig(key, value);
  } catch (error) {
    console.error("服务层: 保存配置项失败", error);
    throw error;
  }
}

/**
 * 服务层：删除配置项
 * @param {number} id - 配置项ID
 * @returns {Promise<void>}
 */
export async function removeConfig(id) {
  try {
    await deleteConfig(id);
  } catch (error) {
    console.error("服务层: 删除配置项失败", error);
    throw error;
  }
}

/**
 * 获取系统配置并转为Map
 * @returns {Promise<{[key: string]: string}>}
 */
export async function getSystemConfig() {
  try {
    const configs = await getAllConfigs();
    const configMap = {};
    configs.forEach((config) => {
      configMap[config.key] = config.value;
    });
    return configMap;
  } catch (error) {
    console.error("获取系统配置失败:", error);
    throw error;
  }
}

/**
 * 批量更新系统配置
 * @param {{[key: string]: string}} config - 配置对象
 * @returns {Promise<boolean>}
 */
export async function updateSystemConfig(config) {
  try {
    for (const [key, value] of Object.entries(config)) {
      await setConfig(key, value);
    }
    return true;
  } catch (error) {
    console.error("更新系统配置失败:", error);
    throw error;
  }
}

/**
 * 增加题库版本号
 * @returns {Promise<boolean>}
 */
export async function increaseQuestionBankVersion() {
  try {
    const currentVersion = await getConfig("question_bank_version");
    const newVersion = currentVersion ? parseInt(currentVersion.value) + 1 : 1;
    await setConfig("question_bank_version", newVersion.toString());
    return true;
  } catch (error) {
    console.error("增加题库版本号失败:", error);
    throw error;
  }
}

/**
 * 管理员登录验证
 * @param {string} password - 用户输入的密码
 * @returns {Promise<{success: boolean, message: string}>}
 */
export async function verifyAdminPassword(password) {
  try {
    const config = await getConfig("admin_password");
    if (!config || !config.value) {
      return { success: false, message: "管理员密码未设置" };
    }

    const isMatch = await argon2.verify(config.value, password);
    if (isMatch) {
      return { success: true, message: "登录成功" };
    } else {
      return { success: false, message: "密码错误" };
    }
  } catch (error) {
    console.error("验证管理员密码失败:", error);
    return { success: false, message: "验证过程发生错误" };
  }
}

/**
 * 初始化配置相关的IPC处理程序
 * @param {import('electron').IpcMain} ipcMain - IPC主进程实例
 */
export function initConfigIpc(ipcMain) {
  // 管理员登录验证
  ipcMain.handle("admin-login", async (event, credentials) => {
    try {
      return await verifyAdminPassword(credentials.password);
    } catch (error) {
      console.error("Failed to verify admin password:", error);
      return { success: false, message: "验证过程发生错误" };
    }
  });

  // 系统相关
  ipcMain.handle("system-get-config", async () => {
    try {
      return await getSystemConfig();
    } catch (error) {
      console.error("Failed to get system config:", error);
      return null;
    }
  });

  ipcMain.handle("system-update-config", async (event, config) => {
    try {
      return await updateSystemConfig(config);
    } catch (error) {
      console.error("Failed to update system config:", error);
      return false;
    }
  });

  ipcMain.handle("system-increase-question-band-version", async () => {
    try {
      return await increaseQuestionBankVersion();
    } catch (error) {
      console.error("Failed to increase question band version:", error);
      return false;
    }
  });

    // 配置项管理相关IPC
  ipcMain.handle("config-fetch-all", async () => {
    try {
      return await fetchAllConfigs();
    } catch (error) {
      console.error("Failed to fetch all configs:", error);
      throw error;
    }
  });

  ipcMain.handle("config-fetch-by-id", async (event, id) => {
    try {
      return await fetchConfigById(id);
    } catch (error) {
      console.error(`Failed to fetch config by id ${id}:`, error);
      throw error;
    }
  });

  ipcMain.handle("config-save", async (event, { key, value }) => {
    try {
      await saveConfig(key, value);
      return true;
    } catch (error) {
      console.error(`Failed to save config ${key}:`, error);
      throw error;
    }
  });

  ipcMain.handle("config-delete", async (event, id) => {
    try {
      await removeConfig(id);
      return true;
    } catch (error) {
      console.error(`Failed to delete config ${id}:`, error);
      throw error;
    }
  });
}