doreamon skills

.gitignore

@@ -7,3 +7,6 @@ cache
 public
 resources
 app/view
+
+# Research docs (working notes, not for commit)
+docs/research

app/controller/skillLike.js

@@ -0,0 +1,29 @@
+const Controller = require('egg').Controller;
+
+class SkillLikeController extends Controller {
+    async like() {
+        const { app, ctx } = this;
+        const { slug } = ctx.request.body || {};
+        const ip = ctx.service.skillLike.resolveClientIp();
+        const data = await ctx.service.skillLike.like(slug, ip);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async unlike() {
+        const { app, ctx } = this;
+        const { slug } = ctx.request.body || {};
+        const ip = ctx.service.skillLike.resolveClientIp();
+        const data = await ctx.service.skillLike.unlike(slug, ip);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async getLikeStatus() {
+        const { app, ctx } = this;
+        const { slug } = ctx.query || {};
+        const ip = ctx.service.skillLike.resolveClientIp();
+        const data = await ctx.service.skillLike.getLikeStatus(slug, ip);
+        ctx.body = app.utils.response(true, data);
+    }
+}
+
+module.exports = SkillLikeController;

app/controller/skills.js

@@ -0,0 +1,108 @@
+const Controller = require('egg').Controller;
+const fs = require('fs');
+
+class SkillsController extends Controller {
+    async getSkillList() {
+        const { app, ctx } = this;
+        const params = ctx.query;
+        const data = await ctx.service.skills.querySkillList(params);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async getSkillDetail() {
+        const { app, ctx } = this;
+        const { slug } = ctx.query;
+        const data = await ctx.service.skills.getSkillDetail(slug);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async getRelatedSkills() {
+        const { app, ctx } = this;
+        const { slug, limit = 6 } = ctx.query;
+        const data = await ctx.service.skills.getRelatedSkills(slug, limit);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async getSkillFileContent() {
+        const { app, ctx } = this;
+        const { slug, path: filePath } = ctx.query;
+        const data = await ctx.service.skills.getSkillFileContent(slug, filePath);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async downloadSkillArchive() {
+        const { ctx } = this;
+        const { slug } = ctx.query;
+        const { fileName, content } = await ctx.service.skills.getSkillArchive(slug);
+        ctx.set('Content-Type', 'application/zip');
+        ctx.set('Content-Disposition', `attachment; filename="${encodeURIComponent(fileName)}"`);
+        ctx.body = content;
+    }
+
+    async getSkillInstallMeta() {
+        const { app, ctx } = this;
+        const identifier = ctx.query.installKey || ctx.query.slug;
+        const data = await ctx.service.skills.getInstallMeta(identifier);
+        ctx.body = app.utils.response(true, data);
+    }
+
+    async importSkillFile() {
+        const { app, ctx } = this;
+        const params = ctx.request.body || {};
+        const files = ctx.request.files
+            ? Array.isArray(ctx.request.files)
+                ? ctx.request.files
+                : [ctx.request.files]
+            : [];
+        const file = files[0];
+
+        if (!file) {
+            ctx.throw(400, '缺少上传文件');
+        }
+
+        try {
+            const data = await ctx.service.skills.importSkillFile(params, file);
+            ctx.body = app.utils.response(true, data);
+        } finally {
+            if (file.filepath && fs.existsSync(file.filepath)) {
+                try {
+                    fs.unlinkSync(file.filepath);
+                } catch (error) {
+                    ctx.logger.warn(`[skills] 清理上传文件失败: ${error.message}`);
+                }
+            }
+        }
+    }
+
+    async updateSkill() {
+        const { app, ctx } = this;
+        const params = ctx.request.body || {};
+        const files = ctx.request.files
+            ? Array.isArray(ctx.request.files)
+                ? ctx.request.files
+                : [ctx.request.files]
+            : [];
+        const file = files[0] || null;
+
+        try {
+            const data = await ctx.service.skills.updateSkill(params, file);
+            ctx.body = app.utils.response(true, data, '更新成功');
+        } finally {
+            if (file?.filepath && fs.existsSync(file.filepath)) {
+                try {
+                    fs.unlinkSync(file.filepath);
+                } catch (error) {
+                    ctx.logger.warn(`[skills] 清理更新上传文件失败: ${error.message}`);
+                }
+            }
+        }
+    }
+
+    async deleteSkill() {
+        const { app, ctx } = this;
+        const data = await ctx.service.skills.deleteSkill(ctx.request.body || {});
+        ctx.body = app.utils.response(true, data, '删除成功');
+    }
+}
+
+module.exports = SkillsController;

app/model/skill_like.js

@@ -0,0 +1,41 @@
+module.exports = (app) => {
+    const { INTEGER, STRING, DATE } = app.Sequelize;
+
+    const SkillLike = app.model.define(
+        'skill_like',
+        {
+            id: {
+                type: INTEGER,
+                primaryKey: true,
+                autoIncrement: true,
+            },
+            skill_id: {
+                type: INTEGER,
+                allowNull: false,
+                comment: '技能ID',
+            },
+            ip: {
+                type: STRING(64),
+                allowNull: false,
+                comment: '点赞用户IP',
+            },
+            created_at: {
+                type: DATE,
+                allowNull: false,
+                defaultValue: app.Sequelize.literal('CURRENT_TIMESTAMP'),
+            },
+        },
+        {
+            freezeTableName: true,
+            tableName: 'skill_likes',
+            timestamps: false,
+            indexes: [
+                { fields: ['skill_id', 'ip'], unique: true },
+                { fields: ['skill_id'] },
+                { fields: ['ip'] },
+            ],
+        }
+    );
+
+    return SkillLike;
+};

app/model/skills_file.js

@@ -0,0 +1,77 @@
+module.exports = (app) => {
+    const { INTEGER, STRING, TEXT, DATE, TINYINT } = app.Sequelize;
+
+    const SkillsFile = app.model.define(
+        'skills_file',
+        {
+            id: {
+                type: INTEGER,
+                primaryKey: true,
+                autoIncrement: true,
+            },
+            skill_id: {
+                type: INTEGER,
+                allowNull: false,
+                comment: 'skills_items.id',
+            },
+            file_path: {
+                type: STRING(512),
+                allowNull: false,
+                comment: '文件相对路径',
+            },
+            language: {
+                type: STRING(64),
+                allowNull: false,
+                defaultValue: 'text',
+            },
+            size: {
+                type: INTEGER,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            is_binary: {
+                type: TINYINT,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            encoding: {
+                type: STRING(16),
+                allowNull: false,
+                defaultValue: 'utf8',
+            },
+            content: {
+                type: TEXT('long'),
+                comment: '文本内容或base64内容',
+            },
+            updated_at_remote: {
+                type: DATE,
+                comment: '源仓库文件更新时间',
+            },
+            is_delete: {
+                type: TINYINT,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            created_at: {
+                type: DATE,
+                allowNull: false,
+                defaultValue: app.Sequelize.literal('CURRENT_TIMESTAMP'),
+            },
+            updated_at: {
+                type: DATE,
+                allowNull: false,
+                defaultValue: app.Sequelize.literal('CURRENT_TIMESTAMP'),
+            },
+        },
+        {
+            freezeTableName: true,
+            tableName: 'skills_files',
+            timestamps: true,
+            createdAt: 'created_at',
+            updatedAt: 'updated_at',
+            indexes: [{ fields: ['skill_id'] }],
+        }
+    );
+
+    return SkillsFile;
+};

app/model/skills_item.js

@@ -0,0 +1,112 @@
+module.exports = (app) => {
+    const { INTEGER, STRING, TEXT, DATE, TINYINT } = app.Sequelize;
+
+    const SkillsItem = app.model.define(
+        'skills_item',
+        {
+            id: {
+                type: INTEGER,
+                primaryKey: true,
+                autoIncrement: true,
+            },
+            source_id: {
+                type: INTEGER,
+                allowNull: false,
+                comment: '来源记录ID',
+            },
+            slug: {
+                type: STRING(255),
+                allowNull: false,
+                unique: true,
+                comment: '详情页唯一标识',
+            },
+            name: {
+                type: STRING(255),
+                allowNull: false,
+            },
+            description: {
+                type: TEXT,
+            },
+            category: {
+                type: STRING(64),
+                allowNull: false,
+                defaultValue: '通用',
+            },
+            version: {
+                type: STRING(128),
+                allowNull: false,
+                defaultValue: '',
+                comment: '技能版本号',
+            },
+            tags: {
+                type: TEXT('long'),
+                comment: 'JSON字符串数组',
+            },
+            allowed_tools: {
+                type: TEXT('long'),
+                comment: 'JSON字符串数组',
+            },
+            stars: {
+                type: INTEGER,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            updated_at_remote: {
+                type: DATE,
+                comment: '源仓库文件更新时间',
+            },
+            source_repo: {
+                type: STRING(1000),
+                comment: '仓库地址',
+            },
+            source_path: {
+                type: STRING(1000),
+                comment: '仓库内 skill 相对路径',
+            },
+            skill_md: {
+                type: TEXT('long'),
+                comment: 'SKILL.md 原文',
+            },
+            install_command: {
+                type: TEXT,
+                comment: '推荐安装命令',
+            },
+            file_count: {
+                type: INTEGER,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            is_delete: {
+                type: TINYINT,
+                allowNull: false,
+                defaultValue: 0,
+            },
+            created_at: {
+                type: DATE,
+                allowNull: false,
+                defaultValue: app.Sequelize.literal('CURRENT_TIMESTAMP'),
+            },
+            updated_at: {
+                type: DATE,
+                allowNull: false,
+                defaultValue: app.Sequelize.literal('CURRENT_TIMESTAMP'),
+            },
+        },
+        {
+            freezeTableName: true,
+            tableName: 'skills_items',
+            timestamps: true,
+            createdAt: 'created_at',
+            updatedAt: 'updated_at',
+            indexes: [
+                { unique: true, fields: ['slug'] },
+                { fields: ['source_id'] },
+                { fields: ['category'] },
+                { fields: ['stars'] },
+                { fields: ['updated_at_remote'] },
+            ],
+        }
+    );
+
+    return SkillsItem;
+};