141 lines
3.6 KiB
JavaScript
141 lines
3.6 KiB
JavaScript
/**
|
||
* 用户对应的二级路由
|
||
*/
|
||
|
||
const express = require("express");
|
||
const router = express.Router();
|
||
|
||
// 引入业务层方法
|
||
const {
|
||
loginService,
|
||
addUserService,
|
||
deleteUserService,
|
||
updateUserService,
|
||
findUserByPageService,
|
||
findUserByIdService,
|
||
userIsExistService,
|
||
passwordcheckService,
|
||
findUserByPointsRankService,
|
||
} = require("../services/userService");
|
||
|
||
const { formatResponse, analysisToken } = require("../utils/tools");
|
||
const { ValidationError } = require("../utils/errors");
|
||
|
||
/**
|
||
* 用户登录
|
||
*/
|
||
router.post("/login", async function (req, res, next) {
|
||
console.log(req.body.captcha, "req.body.captcha");
|
||
console.log(req.session.captcha, "req.session.captcha");
|
||
|
||
// 首先应该有一个验证码的验证
|
||
if (req.body.captcha.toLowerCase() !== req.session.captcha.toLowerCase()) {
|
||
// 如果进入此 if，说明是有问题的，用户输入的验证码不正确
|
||
next(new ValidationError("验证码错误"));
|
||
return;
|
||
}
|
||
const result = await loginService(req.body);
|
||
// 对返回数据进行格式化
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 用户恢复登录
|
||
*/
|
||
router.get("/whoami", async function (req, res, next) {
|
||
// 1. 从客户端请求头的 Authorization 字段拿到 token，然后进行解析
|
||
const token = analysisToken(req.get("Authorization"));
|
||
// 查看解析 token 是否成功
|
||
if (token) {
|
||
// 2. 返回给客户端解析结果
|
||
res.send(
|
||
formatResponse(0, "", {
|
||
_id: token._id,
|
||
loginId: token.loginId,
|
||
})
|
||
);
|
||
} else {
|
||
next(new ValidationError("登录过期，请重新登录"));
|
||
}
|
||
});
|
||
|
||
/**
|
||
* 根据分页查找用户
|
||
*/
|
||
router.get("/", async function (req, res) {
|
||
const result = await findUserByPageService(req.query);
|
||
// 对返回数据进行格式化
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
router.get("/pointsrank", async function (req, res) {
|
||
const result = await findUserByPointsRankService();
|
||
// 对返回数据进行格式化
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 新增用户（用户注册）
|
||
*/
|
||
router.post("/", async function (req, res, next) {
|
||
// 首先应该有一个验证码的验证
|
||
// 但是如果是后台系统新增，则不需要验证码
|
||
if (
|
||
req.body.type !== "background" &&
|
||
req.body.captcha.toLowerCase() !== req.session.captcha.toLowerCase()
|
||
) {
|
||
// 如果进入此 if，说明是有问题的，用户输入的验证码不正确
|
||
next(new ValidationError("验证码错误"));
|
||
return;
|
||
}
|
||
const result = await addUserService(req.body);
|
||
if (result && result._id) {
|
||
res.send(formatResponse(0, "", result));
|
||
} else {
|
||
next(result);
|
||
}
|
||
});
|
||
|
||
/**
|
||
* 根据 id 删除用户
|
||
*/
|
||
router.delete("/:id", async function (req, res) {
|
||
const result = await deleteUserService(req.params.id);
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 根据 id 查找用户
|
||
*/
|
||
router.get("/:id", async function (req, res) {
|
||
const result = await findUserByIdService(req.params.id);
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 根据 id 修改用户
|
||
*/
|
||
router.patch("/:id", async function (req, res) {
|
||
const result = await updateUserService(req.params.id, req.body);
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 根据 loginId 来查找用户是否存在
|
||
*/
|
||
router.get("/userIsExist/:loginId", async function (req, res) {
|
||
const result = await userIsExistService(req.params.loginId);
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
/**
|
||
* 确认密码是否正确
|
||
*/
|
||
router.post("/passwordcheck", async function (req, res, next) {
|
||
const result = await passwordcheckService(req.body);
|
||
res.send(formatResponse(0, "", result));
|
||
});
|
||
|
||
module.exports = router;
|
||
|