index.mjs 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. import Router from '@koa/router';
  2. import { koaBody } from 'koa-body';
  3. import { copyFile, rm } from 'node:fs/promises';
  4. import { UPLOAD_DIR, STATIC } from '../app.config.mjs';
  5. const router = new Router();
  6. // 通过router实例的一些方法 比如 get、post等去定义 对应请求方法的路由
  7. router
  8. .get('/', (ctx) => {
  9. ctx.body = 'Koa App.';
  10. })
  11. .put(
  12. '/upload',
  13. koaBody({
  14. multipart: true,
  15. formidable: {
  16. keepExtensions: true,
  17. uploadDir: UPLOAD_DIR, // 设置上传文件的最终位置
  18. },
  19. onError(err, ctx) {
  20. ctx.body = {
  21. code: 1,
  22. msg: err,
  23. };
  24. },
  25. }),
  26. async (ctx) => {
  27. let filename = ctx.request.files.file.newFilename;
  28. let srcFile = `./${UPLOAD_DIR}/${filename}`;
  29. let destFile = srcFile;
  30. // 获取 请求体 中 除了file文件之外的其他数据
  31. const { folder } = ctx.request.body;
  32. // 如果用户在上传文件时 指定了目标文件夹
  33. if (folder) {
  34. // 1 将默认上传位置的文件 拷贝到 目标的文件夹下
  35. destFile = `./${UPLOAD_DIR}/${folder}/${filename}`;
  36. try {
  37. // 先确保destFile的文件夹都真实存在
  38. await copyFile(srcFile, destFile);
  39. // 2 成功后 删除默认位置的文件
  40. await rm(srcFile);
  41. } catch (error) {
  42. console.error(error);
  43. }
  44. }
  45. // 给客户端响应数据
  46. ctx.body = {
  47. code: 0,
  48. data: {
  49. path: `${UPLOAD_DIR.replace(STATIC, '')}/${folder}/${filename}`,
  50. filename,
  51. },
  52. msg: '上传成功',
  53. };
  54. }
  55. );
  56. export default router;