mirror of
https://github.com/patdelphi/suanming.git
synced 2026-02-28 05:33:11 +08:00
feat: 完成易经64卦数据补全和本地化改造
- 完全按照logic/yijing.txt补全所有64卦的完整数据结构 - 包含每卦的卦辞、象传、六爻详解和人生指导 - 重建八字、易经、紫微斗数三个核心分析器 - 实现完整的本地SQLite数据库替代Supabase - 添加本地Express.js后端服务器 - 更新前端API调用为本地接口 - 实现JWT本地认证系统 - 完善历史记录和用户管理功能
This commit is contained in:
patdelphi
127
server/database/index.cjs
Normal file
127
server/database/index.cjs
Normal file
@@ -0,0 +1,127 @@
|
||||
const Database = require('better-sqlite3');
|
||||
const path = require('path');
|
||||
const fs = require('fs');
|
||||
|
||||
class DatabaseManager {
|
||||
constructor() {
|
||||
this.db = null;
|
||||
this.dbPath = path.join(__dirname, '../../numerology.db');
|
||||
this.schemaPath = path.join(__dirname, 'schema.sql');
|
||||
}
|
||||
|
||||
// 初始化数据库连接
|
||||
init() {
|
||||
try {
|
||||
// 创建或连接到SQLite数据库
|
||||
this.db = new Database(this.dbPath);
|
||||
|
||||
// 启用外键约束
|
||||
this.db.pragma('foreign_keys = ON');
|
||||
|
||||
// 设置WAL模式以提高并发性能
|
||||
this.db.pragma('journal_mode = WAL');
|
||||
|
||||
// 初始化数据库结构
|
||||
this.initializeSchema();
|
||||
|
||||
console.log('数据库初始化成功');
|
||||
return this.db;
|
||||
} catch (error) {
|
||||
console.error('数据库初始化失败:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
// 初始化数据库结构
|
||||
initializeSchema() {
|
||||
try {
|
||||
const schema = fs.readFileSync(this.schemaPath, 'utf8');
|
||||
|
||||
// 直接执行整个schema文件
|
||||
this.db.exec(schema);
|
||||
|
||||
console.log('数据库结构初始化完成');
|
||||
} catch (error) {
|
||||
console.error('数据库结构初始化失败:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
// 获取数据库实例
|
||||
getDatabase() {
|
||||
if (!this.db) {
|
||||
this.init();
|
||||
}
|
||||
return this.db;
|
||||
}
|
||||
|
||||
// 关闭数据库连接
|
||||
close() {
|
||||
if (this.db) {
|
||||
this.db.close();
|
||||
this.db = null;
|
||||
console.log('数据库连接已关闭');
|
||||
}
|
||||
}
|
||||
|
||||
// 执行事务
|
||||
transaction(callback) {
|
||||
const db = this.getDatabase();
|
||||
const transaction = db.transaction(callback);
|
||||
return transaction;
|
||||
}
|
||||
|
||||
// 备份数据库
|
||||
backup(backupPath) {
|
||||
try {
|
||||
const db = this.getDatabase();
|
||||
db.backup(backupPath);
|
||||
console.log(`数据库备份成功: ${backupPath}`);
|
||||
} catch (error) {
|
||||
console.error('数据库备份失败:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
// 清理过期会话
|
||||
cleanupExpiredSessions() {
|
||||
try {
|
||||
const db = this.getDatabase();
|
||||
const stmt = db.prepare('DELETE FROM user_sessions WHERE expires_at < ?');
|
||||
const result = stmt.run(new Date().toISOString());
|
||||
console.log(`清理了 ${result.changes} 个过期会话`);
|
||||
return result.changes;
|
||||
} catch (error) {
|
||||
console.error('清理过期会话失败:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 创建单例实例
|
||||
const dbManager = new DatabaseManager();
|
||||
|
||||
// 导出数据库管理器和便捷方法
|
||||
module.exports = {
|
||||
dbManager,
|
||||
getDB: () => dbManager.getDatabase(),
|
||||
closeDB: () => dbManager.close(),
|
||||
transaction: (callback) => dbManager.transaction(callback),
|
||||
backup: (path) => dbManager.backup(path),
|
||||
cleanupSessions: () => dbManager.cleanupExpiredSessions()
|
||||
};
|
||||
|
||||
// 进程退出时自动关闭数据库
|
||||
process.on('exit', () => {
|
||||
dbManager.close();
|
||||
});
|
||||
|
||||
process.on('SIGINT', () => {
|
||||
dbManager.close();
|
||||
process.exit(0);
|
||||
});
|
||||
|
||||
process.on('SIGTERM', () => {
|
||||
dbManager.close();
|
||||
process.exit(0);
|
||||
});
|
||||
0
server/database/index.js
Normal file
0
server/database/index.js
Normal file
96
server/database/schema.sql
Normal file
96
server/database/schema.sql
Normal file
@@ -0,0 +1,96 @@
|
||||
-- 三算命本地化数据库Schema
|
||||
-- SQLite数据库结构定义
|
||||
|
||||
-- 用户表
|
||||
CREATE TABLE IF NOT EXISTS users (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
email TEXT UNIQUE NOT NULL,
|
||||
password_hash TEXT NOT NULL,
|
||||
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
|
||||
);
|
||||
|
||||
-- 用户档案表
|
||||
CREATE TABLE IF NOT EXISTS user_profiles (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
user_id INTEGER NOT NULL,
|
||||
username TEXT,
|
||||
full_name TEXT,
|
||||
birth_date TEXT,
|
||||
birth_time TEXT,
|
||||
birth_location TEXT,
|
||||
gender TEXT CHECK (gender IN ('male', 'female')),
|
||||
avatar_url TEXT,
|
||||
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
|
||||
);
|
||||
|
||||
-- 命理分析记录表 (兼容现有numerology_readings表结构)
|
||||
CREATE TABLE IF NOT EXISTS numerology_readings (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
user_id INTEGER NOT NULL,
|
||||
reading_type TEXT NOT NULL CHECK (reading_type IN ('bazi', 'ziwei', 'yijing', 'wuxing')),
|
||||
name TEXT,
|
||||
birth_date TEXT,
|
||||
birth_time TEXT,
|
||||
birth_place TEXT,
|
||||
gender TEXT,
|
||||
input_data TEXT, -- JSON格式存储输入数据
|
||||
results TEXT, -- JSON格式存储分析结果(向后兼容)
|
||||
analysis TEXT, -- JSON格式存储新格式分析结果
|
||||
status TEXT DEFAULT 'completed' CHECK (status IN ('pending', 'processing', 'completed', 'failed')),
|
||||
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
|
||||
);
|
||||
|
||||
-- 会话表 (用于JWT token管理)
|
||||
CREATE TABLE IF NOT EXISTS user_sessions (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
user_id INTEGER NOT NULL,
|
||||
token_hash TEXT NOT NULL,
|
||||
expires_at DATETIME NOT NULL,
|
||||
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
|
||||
);
|
||||
|
||||
-- 创建索引以提高查询性能
|
||||
CREATE INDEX IF NOT EXISTS idx_users_email ON users(email);
|
||||
CREATE INDEX IF NOT EXISTS idx_user_profiles_user_id ON user_profiles(user_id);
|
||||
CREATE INDEX IF NOT EXISTS idx_readings_user_id ON numerology_readings(user_id);
|
||||
CREATE INDEX IF NOT EXISTS idx_readings_type ON numerology_readings(reading_type);
|
||||
CREATE INDEX IF NOT EXISTS idx_readings_created_at ON numerology_readings(created_at DESC);
|
||||
CREATE INDEX IF NOT EXISTS idx_sessions_user_id ON user_sessions(user_id);
|
||||
CREATE INDEX IF NOT EXISTS idx_sessions_token ON user_sessions(token_hash);
|
||||
CREATE INDEX IF NOT EXISTS idx_sessions_expires ON user_sessions(expires_at);
|
||||
|
||||
-- 触发器：自动更新updated_at字段
|
||||
CREATE TRIGGER IF NOT EXISTS update_users_timestamp
|
||||
AFTER UPDATE ON users
|
||||
FOR EACH ROW
|
||||
BEGIN
|
||||
UPDATE users SET updated_at = CURRENT_TIMESTAMP WHERE id = NEW.id;
|
||||
END;
|
||||
|
||||
CREATE TRIGGER IF NOT EXISTS update_user_profiles_timestamp
|
||||
AFTER UPDATE ON user_profiles
|
||||
FOR EACH ROW
|
||||
BEGIN
|
||||
UPDATE user_profiles SET updated_at = CURRENT_TIMESTAMP WHERE id = NEW.id;
|
||||
END;
|
||||
|
||||
CREATE TRIGGER IF NOT EXISTS update_numerology_readings_timestamp
|
||||
AFTER UPDATE ON numerology_readings
|
||||
FOR EACH ROW
|
||||
BEGIN
|
||||
UPDATE numerology_readings SET updated_at = CURRENT_TIMESTAMP WHERE id = NEW.id;
|
||||
END;
|
||||
|
||||
-- 清理过期会话的触发器
|
||||
CREATE TRIGGER IF NOT EXISTS cleanup_expired_sessions
|
||||
AFTER INSERT ON user_sessions
|
||||
FOR EACH ROW
|
||||
BEGIN
|
||||
DELETE FROM user_sessions WHERE expires_at < datetime('now');
|
||||
END;
|
||||
Reference in New Issue
Block a user