byChannelAndOnLevelChild.ts 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. import { defineEventHandler, EventHandlerRequest } from 'h3';
  2. import { DB } from '~~/server/db/DB';
  3. import { createErrorResponse, createSuccessResponse, IResponse } from '~~/server/utils/response';
  4. import { CommonPageResult } from '~~/server/db/CommonModel';
  5. import type { IArticle } from './[id]';
  6. import { IChannel } from '../channel/[id]';
  7. export default defineEventHandler<EventHandlerRequest, Promise<IResponse<CommonPageResult<IArticle>>>>(async (event) => {
  8. try {
  9. const query = getQuery(event);
  10. const page = query.page as string;
  11. const pageSize = query.pageSize as string;
  12. const channelId = query.channelId as string;
  13. if (!channelId)
  14. return createErrorResponse('分类ID不能为空');
  15. const childChannels = await DB.table('pr_cms_channel')
  16. .where('parent_id', channelId)
  17. .select('id')
  18. .get() as IChannel[];
  19. const articles = await DB.table('pr_cms_archives')
  20. .whereIn('channel_id', [...childChannels.map(item => item.id), channelId])
  21. .whereNull('deletetime')
  22. .where('status', 'normal')
  23. .orderBy('weigh', 'desc')
  24. .orderBy('publishtime', 'desc')
  25. .orderBy('createtime', 'desc')
  26. .orderBy('id', 'asc')
  27. .paginate(Number(page), Number(pageSize));
  28. if (!articles)
  29. return createErrorResponse('文章不存在');
  30. return createSuccessResponse(articles);
  31. } catch (error) {
  32. return createErrorResponse(error);
  33. }
  34. });