feat(user): 添加用户列表查询功能

- 新增 findUserList 控制器方法，用于查询用户列表
- 创建 Search 模型类，用于处理查询参数
- 在用户仓库中实现 selectUserList 方法，用于数据库查询
- 更新用户服务，添加 find_user_list 方法
- 在路由中注册新的用户列表查询 endpoint

controllers/userController.js

@@ -3,16 +3,30 @@ const userService = require('../services/userService')
 const FetchResult = require('../common/web/fetchResult')
 const messages = require('../config/messages')
 const { HTTP_STATUS } = require('../common/constant/httpStatus')
+const { Search } = require('../models/Search')
 
 exports.getAllUsers = async (res) => {
   try {
     const users = await userService.user_list()
-    return FetchResult.formatResult(res, 200, 'success', users)
+    return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, 'success', users)
   } catch (err) {
     return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
   }
 }
 
+exports.findUserList = async (req, res) => {
+  try {
+    const { page, size, sort } = req.query
+    const search = new Search({ page: page, size: size, sort: sort })
+    const result = await userService.find_user_list(search)
+    return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, 'success', result)
+  } catch (err) {
+    console.log(err)
+
+    return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
+  }
+}
+
 exports.createUser = [
   body('account').isLength({ min: 3 }).withMessage('Account must be at least 3 characters long'),
   body('account').isEmpty().withMessage('Account is required'),

models/Search.js

@@ -0,0 +1,32 @@
+class Search {
+  constructor({ size, page, sort, filters }) {
+    this.size = size
+    this.page = page
+    this.sort = sort
+    this.filters = filters
+  }
+}
+
+class SearchResult {
+  constructor({ list = [], num = 0, size = 0, total = 0 } = {}) {
+    if (typeof list !== 'object' || list === null) {
+      throw new Error('Invalid list parameter')
+    }
+    if (typeof num !== 'number') {
+      throw new Error('Invalid num parameter')
+    }
+    if (typeof size !== 'number') {
+      throw new Error('Invalid size parameter')
+    }
+    if (typeof total !== 'number') {
+      throw new Error('Invalid total parameter')
+    }
+
+    this.list = list
+    this.num = num
+    this.size = size
+    this.total = total
+  }
+}
+
+module.exports = { Search, SearchResult }

repositories/userRepository.js

@@ -1,4 +1,5 @@
 const UserModel = require('../models/userModel')
+const { SearchResult } = require('../models/Search')
 
 exports.startTransaction = async () => {
   const seesion = await UserModel.startSession()
@@ -18,6 +19,44 @@ exports.selectAllUser = async () => {
   return await UserModel.find()
 }
 
+exports.selectUserList = async (search = {}) => {
+  try {
+    const { size = 20, page = 1, sort, filters } = search
+
+    const skip = (page - 1) * size
+    const searchResult = new SearchResult()
+    searchResult.num = page
+    searchResult.size = size
+
+    // 检查 filters，确保只有在 filters 存在时才应用
+    const matchFilters = filters ? { ...filters } : {}
+    const sortObj = sort && typeof sort === 'object' ? sort : { _id: 1 } // 默认按 _id 升序排序
+
+    const result = await UserModel.aggregate([
+      // 应用过滤条件，确保filters存在时才传入
+      { $match: matchFilters },
+      {
+        $facet: {
+          metadata: [{ $count: 'total' }, { $addFields: { total: '$total' } }],
+          data: [{ $sort: sortObj }, { $skip: skip }, { $limit: size }]
+        }
+      }
+    ])
+
+    // 解构 result 并进行必要的空值检查
+    const { metadata = [], data = [] } = result[0] || {}
+
+    // 提取 metadata 中的 total，若不存在则为 0
+    searchResult.total = metadata.length > 0 ? metadata[0].total : 0
+    searchResult.list = data
+
+    return searchResult
+  } catch (error) {
+    console.log(error)
+    throw error
+  }
+}
+
 exports.selectUserById = async (id) => {
   return await UserModel.findById(id)
 }

routes/userRouter.js

@@ -6,5 +6,6 @@ const router = express.Router()
 
 router.get('/', userController.getAllUsers)
 router.post('/', userController.createUser)
+router.get('/list', userController.findUserList)
 
 module.exports = router

services/userService.js

@@ -55,6 +55,14 @@ exports.user_list = async () => {
   }
 }
 
+exports.find_user_list = async (search) => {
+  try {
+    return await userMapper.selectUserList(search)
+  } catch (err) {
+    throw err
+  }
+}
+
 exports.create_user = async (user) => {
   try {
     const { account } = user

utils/loginUtil.js

@@ -1,4 +1,5 @@
 const FetchResult = require('../common/web/fetchResult.js')
+const { HTTP_STATUS } = require('../common/constant/httpStatus.js')
 
 exports.authenticateSession = async (req, res, next) => {
   if (req.session.user) {