From 293fbd8bc8b3285d4a27bd5822d93bd203e1aba9 Mon Sep 17 00:00:00 2001
From: Kubbo <390378816@qq.com>
Date: Wed, 24 Dec 2025 23:48:14 +0800
Subject: [PATCH] =?UTF-8?q?feat(server):=20=E6=B7=BB=E5=8A=A0=E8=AE=A4?=
 =?UTF-8?q?=E8=AF=81=E6=8E=88=E6=9D=83=E5=92=8C=E6=97=A5=E5=BF=97=E8=AE=B0?=
 =?UTF-8?q?=E5=BD=95=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 实现了 JWT 认证中间件，支持 token 验证和白名单路由
- 添加了登录接口，支持用户登录和 token 生成
- 集成了 log4js 日志系统，支持 mysql 和 koa 日志分类
- 配置了环境变量支持，添加了 SECRET_KEY 配置
- 重构了 MySQL 连接池配置，添加了查询日志记录
- 集成了 koa 路由和认证中间件，实现接口访问控制
---
 module/server/.env            |  1 +
 module/server/index.js        |  1 +
 module/server/koa/auth.js     | 26 ++++++++++++++++++++++++++
 module/server/koa/index.js    | 12 +++++++-----
 module/server/koa/login.js    | 24 ++++++++++++++++++++++++
 module/server/koa/registry.js |  5 +++++
 module/server/log4js.js       | 15 +++++++++++++++
 module/server/mysql/index.js  | 10 ++++++++--
 module/server/package.json    |  6 ++++--
 9 files changed, 91 insertions(+), 9 deletions(-)
 create mode 100644 module/server/koa/auth.js
 create mode 100644 module/server/koa/login.js
 create mode 100644 module/server/koa/registry.js
 create mode 100644 module/server/log4js.js

diff --git a/module/server/.env b/module/server/.env
index e69de29..61a991e 100644
--- a/module/server/.env
+++ b/module/server/.env
@@ -0,0 +1 @@
+SECRET_KEY=y7Y17cMV8fTzLTp
diff --git a/module/server/index.js b/module/server/index.js
index afbc9d6..8b432bf 100644
--- a/module/server/index.js
+++ b/module/server/index.js
@@ -1,2 +1,3 @@
 import "./mysql/index.js"
 import "./koa/index.js"
+import "./log4js.js"
diff --git a/module/server/koa/auth.js b/module/server/koa/auth.js
new file mode 100644
index 0000000..99a255e
--- /dev/null
+++ b/module/server/koa/auth.js
@@ -0,0 +1,26 @@
+import jwt from "jsonwebtoken";
+import * as log4js from "../log4js.js";
+
+const whiteList = [
+  '/',
+  '/api/login',
+]
+
+async function auth(ctx, next) {
+  try {
+    log4js.koa.debug("接口请求:", ctx.path)
+    if (whiteList.includes(ctx.path)) {
+      await next();
+      return; // 终止后续验证逻辑
+    }
+    const token = ctx.request.headers.authorization?.split(' ')[1];
+    if (!token) throw new Error('无token');
+    ctx.user = jwt.verify(token, process.env.SECRET_KEY);
+    await next();
+  } catch (err) {
+    ctx.status = 401;
+    ctx.body = {msg: 'token无效或过期', code: 401};
+  }
+}
+
+export default auth;
diff --git a/module/server/koa/index.js b/module/server/koa/index.js
index 85ee6d3..b3e33fb 100644
--- a/module/server/koa/index.js
+++ b/module/server/koa/index.js
@@ -2,28 +2,30 @@ import Koa from 'koa';
 import Router from 'koa-router';
 import config from "../config/index.js"
 import koaStatic from 'koa-static';
+import registry from "./registry.js";
+import * as log4js from "../log4js.js";
+import auth from "./auth.js";
 
 const app = new Koa();
 const router = new Router();
 
+
 // 简单的路由示例
 router.get('/', (ctx) => {
   ctx.body = {message: 'Hello from Koa server!'};
 });
 
-router.get('/api/test', (ctx) => {
-  ctx.body = {message: 'This is a test API endpoint'};
-});
-
 router.get('/api/config', (ctx) => {
   ctx.body = {data: config}
 })
+app.use(auth)
 app.use(router.routes());
+app.use(registry)
 app.use(router.allowedMethods());
 app.use(koaStatic('/www'))
 
 const PORT = process.env.PORT || 3001;
 
 app.listen(PORT, () => {
-  console.log(`Koa server is running on port ${PORT}`);
+  log4js.koa.info(`Koa server is running on port ${PORT}`);
 });
diff --git a/module/server/koa/login.js b/module/server/koa/login.js
new file mode 100644
index 0000000..03946d9
--- /dev/null
+++ b/module/server/koa/login.js
@@ -0,0 +1,24 @@
+import Router from 'koa-router';
+import mysql from "../mysql/index.js";
+import jwt from "jsonwebtoken";
+import * as log4js from "../log4js.js";
+
+const router = new Router()
+
+router.post("/api/login", async (ctx) => {
+  const {username, password} = ctx.request.body
+  if (['admin'].includes(username)) return ctx.body = {code: 1, message: "该账户不对外开放"}
+  const [rows] = await mysql.query("SELECT * FROM mir_web.player WHERE username = ? AND password = ?", [username, password])
+  if (rows?.length == 1) {
+    const token = jwt.sign(rows[0], process.env.SECRET_KEY, {expiresIn: '24h'});
+    return ctx.body = {code: 0, message: "登录成功", token}
+  }
+  log4js.koa.error("用户登录失败", username)
+  return ctx.body = {code: 1, message: "用户名或密码错误"}
+})
+
+router.post("/api/enter_game", async (ctx) => {
+
+  const {srvId, account} = ctx.request.body
+})
+export default router.routes()
diff --git a/module/server/koa/registry.js b/module/server/koa/registry.js
new file mode 100644
index 0000000..7bce91c
--- /dev/null
+++ b/module/server/koa/registry.js
@@ -0,0 +1,5 @@
+import Router from 'koa-router';
+const router = new Router()
+
+
+export default router.routes()
diff --git a/module/server/log4js.js b/module/server/log4js.js
new file mode 100644
index 0000000..b747730
--- /dev/null
+++ b/module/server/log4js.js
@@ -0,0 +1,15 @@
+import log4js from "log4js";
+
+export const configure = {
+  appenders: {
+    console: {type: "console"},
+  },
+  categories: {
+    default: {appenders: ["console"], level: "ALL"},
+  },
+}
+log4js.configure(configure)
+export const manager = log4js
+export const mysql = log4js.getLogger("mysql")
+export const koa = log4js.getLogger("koa")
+
diff --git a/module/server/mysql/index.js b/module/server/mysql/index.js
index 4090a51..0dea4b8 100644
--- a/module/server/mysql/index.js
+++ b/module/server/mysql/index.js
@@ -1,12 +1,18 @@
 import mysql from "mysql2";
 import config from "../config/index.js";
+import * as log4js from "../log4js.js";
 
 const pool = mysql.createPool({
-  ...config.mysql,
+  host: config.mysql.host,
+  port: config.mysql.port,
+  user: config.mysql.user,
+  password: config.mysql.password,
+  connectionLimit: 10,
   queryFormat: function (sql, values) {
     const opts = { sql, values }
     this._resolveNamedPlaceholders(opts)
-    return mysql2.format(
+    log4js.mysql.debug(opts.sql, opts.values)
+    return mysql.format(
       opts.sql,
       opts.values,
       this.config.stringifyObjects,
diff --git a/module/server/package.json b/module/server/package.json
index c5dd539..cb24ae7 100644
--- a/module/server/package.json
+++ b/module/server/package.json
@@ -5,13 +5,15 @@
   "main": "koa/index.js",
   "type": "module",
   "scripts": {
-    "start": "node index.js",
-    "dev": "nodemon index.js"
+    "start": "node --env-file=.env index.js",
+    "dev": "nodemon --exec \"node --env-file=.env\"  index.js"
   },
   "dependencies": {
+    "jsonwebtoken": "^9.0.3",
     "koa": "^2.15.0",
     "koa-router": "^12.0.0",
     "koa-static": "^5.0.0",
+    "log4js": "^6.9.1",
     "mysql2": "^3.16.0"
   }
 }