读取文件的方法
// 读取文件的工具方法
const fs = require('fs')
module.exports.getFileJsonData = (filePath) => {
// 根据文件的路径, 读取文件的内容
return new Promise((resolve, reject) => {
fs.readFile(filePath, 'utf-8', (error, data) => {
if(error) {
// 读取文件失败
reject(error)
} else {
// 读取文件成功
resolve(data)
}
})
})
}
未进行鉴权
前期简单安装一些依赖
在middleware文件夹下创建autmiddlewarjs文件
在controller文件夹中创建文件，如：department.controller.js
const departmentService = require('../service/department.service')
class DepartmentController {
async list(ctx, next) {
// 1.获取数据(offset/size)
const {
offset,
size
} = ctx.query;
// 2.查询列表
const {
result,
count
} = await departmentService.getDepartmentList(offset, size);
ctx.body = {
code: 200,
data: result,
totalCount: count[0].total
};
}
async create(ctx, next) {
// 获取用户请求传递的参数
const department = ctx.request.body;
// 查询数据库 -> 抽离到service
const result = await departmentService.create(department);
// 返回结果
ctx.body = {
code: 200,
data: result
};
}
async update(ctx, next) {
const {
departmentId
} = ctx.params;
const {
departmentName,
principal,
adviser,
departmentTotal
} = ctx.request.body;
const result = await departmentService.update(departmentName, principal, adviser, departmentTotal, departmentId);
ctx.body = {
code: 200,
data: result
};
}
async remove(ctx, next) {
// 1.
const {
departmentId
} = ctx.params;
// 2.删除内容
const result = await departmentService.remove(departmentId);
ctx.body = {
code: 200,
data: result
};
}
}
module.exports = new DepartmentController();
习惯性依次的创建xxx.router.js、xxx.middlewarjs、xxx.controller.js、xxx.servicjs这几个文件，当然xxx.middlewarjs这个可根据需求决定是否需要创建，或者引用已经创建好的中间件文件事例如下：
写接口的步骤
在router文件夹中创建文件，如：department.router.js
// 请求路径 中间件处理的 映射
const Router = require('koa-router');
// 中间件
// 具体的处理逻辑 增删改查
const {
list,
create,
update,
remove
} = require('../controller/department.controller');
// 前缀：
const deportmentRouter = new Router({
prefix: '/api/department'
});
deportmentRouter.post('/', create);
deportmentRouter.get('/list', list);
deportmentRouter.patch('/:departmentId', update);
deportmentRouter.delete('/:departmentId', remove);
// 导出
module.exports = deportmentRouter;
app文件夹中的一些内容
const Koa = require('koa');
// 导入bodyParser中间件，解析json
const bodyParser = require('koa-bodyparser')
// 导入错误信息处置方法
const errorHandler = require('./error-handle');
// 导入路由 升级版 动态加载路由
const useRoutes = require('../router');
const app = new Koa();
app.use(bodyParser());
useRoutes(app);
app.on('error', errorHandler);
module.exports = app;
const mysql = require('mysql2');
const config = require('./config');
// 创建连接池，与数据库进行连接
const connections = mysql.createPool({
host: config.MYSQL_HOST,
port: config.MYSQL_PORT,
database: config.MYSQL_DATABASE,
user: config.MYSQL_USER,
password: config.MYSQL_PASSWORD
});
// 测试
connections.getConnection((err, conn) => {
// err为空即为成功
conn.connect((err) => {
if (err) {
console.log('数据库连接失败', err)
} else {
console.log('数据库连接成功')
}
})
});
// 通过promise操作数据库
module.exports = connections.promise();
const errorType = require('../constants/error-types');
const errorHandler = (error, ctx) => {
let status, message;
switch (error.message) {
case errorType.NAME_OR_PASSWORD_IS_REQUIRED:
status = 400; // Bad Request
message = '用户名或者密码不能为空！';
break;
case errorType.USER_ALREADY_EXISTS:
status = 409; // Conflict 冲突
message = '用户名已存在！';
break;
case errorType.USER_DOES_NOT_EXISTS:
status = 400; // 参数错误
message = '用户名不存在！';
break;
case errorType.PASSWORD_IS_INCORRENT:
status = 400; // 参数错误
message = '密码错误！';
break;
case errorType.UNAUTHORIZATION:
status = 401; // 参数错误
message = '无效的token！';
break;
case errorType.UNPERMISSION:
status = 401; // 参数错误
message = '你不具备操作权限！';
break;
default:
status = 404;
message = 'NOT FOUND';
}
ctx.status = status;
ctx.body = message;
}
module.exports = errorHandler;
在service文件夹下创建department.servicjs文件
const connection = require('../app/database');
class DeportmentService {
async getDepartmentList(offset, size) {
const statement = `
SELECT
d.id id, d.department_name departmentName, d.principal principal, d.adviser adviser, d.department_total departmentTotal, d.createAt createAt, d.updateAt updateAt
FROM department d
LIMIT ?, ?;
`;
const state = `SELECT COUNT(*) total FROM department`;
const [result] = await connection.execute(statement, [offset, size]);
const [count] = await connection.execute(state);
return {
result,
count
};
}
async create(deportment) {
const {
departmentName,
principal,
adviser,
departmentTotal
} = deportment;
// 使用sql语句将user存储到数据库中
const statement = `INSERT INTO department (department_name, principal, adviser, department_total) VALUES (?, ?, ?, ?);`;
const result = await connection.execute(statement, [departmentName, principal, adviser, departmentTotal]);
return result[0];
}
async update(departmentName, principal, adviser, departmentTotal, deportmentId) {
const statement = `UPDATE department SET department_name = ?, principal = ?, adviser = ?, department_total = ? WHERE id = ?;`;
const [result] = await connection.execute(statement, [departmentName, principal, adviser, departmentTotal, deportmentId]);
return result;
}
async remove(deportmentId) {
const statement = `DELETE FROM department WHERE id = ?;`;
const [result] = await connection.execute(statement, [deportmentId]);
return result;
}
}
module.exports = new DeportmentService();
srcapp：主体部分constants：放一些常量controller：控制器，写一些逻辑操作，比如，获取我们输入的信息，再调用service中操作数据库的方法middleware：中间件，比如验证授权、验证输入的账号密码是否正确/存在、验证token是否已过期等router：路由层，在这个文件夹中写路由service：service层，就是操作数据库的一些方法utils：放一些可以用到的方法，比如读取文件的方法maijs：程序的入口，这个入口，越简单越好.env：一些不能写死的环境变量，比如，服务端口port，数据库的一些信息，抽离到这个文件中
文章为作者独立观点，不代表股票交易接口观点
股民评论