detail.js 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154
  1. var express = require('express');
  2. var router = express.Router();
  3. const redis = require('../../libs/redis');
  4. const models = require('../../models');
  5. const utils = require('../../libs/utils');
  6. const common = require('./common');
  7. const { getListBuilder } = require('../../libs/pager');
  8. const categories = require('../../config/category');
  9. const { tags } = require('../../config/tag');
  10. const { coloringList } = require('./config');
  11. const CACHE_PREFIX = "art_v2";
  12. // const CACHE_EXPIRES = 60; // 60s刷新一次
  13. const CACHE_EXPIRES = 600;
  14. const artSelect = 'name title desc seoTitle seoDescription width height date publishTime tags lastMod mystery hasSpecial useSpecialThumb publishVersion totalStartCount totalDoneCount completionRate';
  15. // 详情页路由
  16. router.get('/:id', function (req, res, next) {
  17. (async function () {
  18. let id = req.params.id;
  19. utils.validators.validateId(id);
  20. let cacheKey = `${CACHE_PREFIX}_detail_${id}`;
  21. let htmlData = await redis.getAsync(cacheKey);
  22. // htmlData = null;
  23. if (!htmlData) {
  24. // 详情
  25. let doc = await models.Art
  26. .findById(id)
  27. .select(artSelect)
  28. .populate('user', 'username name')
  29. .lean()
  30. .exec();
  31. if (!doc) throw createError(404, 'Art Not Found!');
  32. common.organizeDetail(doc);
  33. // 关联推荐
  34. let mytags = [...doc.tags];
  35. let cates = categories.map(e => e.id);
  36. let alltags = tags.map(e => e.tag);
  37. mytags = mytags.filter(e => !cates.includes(e) && alltags.includes(e));
  38. if (mytags.length == 0) mytags = [...doc.tags];
  39. let query = {
  40. page: req.query.page,
  41. length: req.query.length,
  42. search: req.query.search,
  43. orderBy: 'publishTime',
  44. order: 'desc',
  45. base: { open: true, status: 9000 },
  46. filters: { tags: mytags },
  47. }
  48. let result = await getListBuilder(query, models.Art);
  49. common.organizeData(result.data);
  50. // 填色页合集推荐
  51. const recmCollections = recommendColoringPages(doc, coloringList);
  52. // 评论
  53. const comments = await models.Comment.find({ approved: true, page: doc._id }).sort({ createdAt: -1 });
  54. let data = {
  55. title: `${doc.seoTitle}`,
  56. description: `${doc.seoDescription}`,
  57. detail: doc,
  58. data: result.data,
  59. page: result.page,
  60. pageId: doc._id,
  61. length: result.length,
  62. recordsFiltered: result.recordsFiltered,
  63. recordsTotal: result.recordsTotal,
  64. relates: result.data,
  65. uri: `/coloring-page/${doc._id}`,
  66. imageUrl: doc.thumb,
  67. pageUri: common.replaceUriParams,
  68. comments,
  69. dateFormat: common.dateFormat,
  70. collections: recmCollections,
  71. };
  72. // 渲染EJS模板到内存中
  73. res.render('v2/detail', data, async (err, html) => {
  74. if (err) {
  75. // 如果渲染出错,调用next()传递错误
  76. return next(err);
  77. }
  78. // 渲染成功,存redis, 发送数据到客户端
  79. htmlData = html;
  80. try {
  81. await redis.set(cacheKey, htmlData, 'EX', CACHE_EXPIRES);
  82. } catch (e) {
  83. console.error(e);
  84. }
  85. res.send(htmlData);
  86. });
  87. } else {
  88. // 缓存命中, 直接发送缓存数据
  89. res.set({ 'X-From-Cache': 'true' });
  90. res.send(htmlData);
  91. }
  92. })().catch(next);
  93. });
  94. /**
  95. * 填色页推荐系统 - 根据标签相似度推荐相关填色页合集
  96. * @param {Object} currentPage - 当前填色页对象,包含tags属性
  97. * @param {Array} collections - 所有填色页合集列表
  98. * @returns {Array} - 推荐的3个填色页合集
  99. */
  100. function recommendColoringPages(currentPage, collections) {
  101. // 计算每个候选页与当前页的标签匹配度
  102. const scoredPages = collections.map(page => {
  103. const matchedTags = page.tags.filter(tag =>
  104. currentPage.tags.some(currentTag =>
  105. currentTag.toLowerCase() === tag.toLowerCase()
  106. )
  107. );
  108. return {
  109. ...page,
  110. score: matchedTags.length,
  111. matchedTags
  112. };
  113. });
  114. // 按匹配度降序排序
  115. scoredPages.sort((a, b) => b.score - a.score);
  116. // 收集匹配度大于0的推荐
  117. const tagMatchedRecommendations = scoredPages.filter(page => page.score > 0);
  118. // 如果标签匹配的推荐不足3个,从剩余的合集中随机选取补足
  119. if (tagMatchedRecommendations.length < 3) {
  120. const remainingPages = scoredPages.filter(page => page.score === 0);
  121. // 打乱剩余页面顺序
  122. const shuffledRemaining = remainingPages.sort(() => 0.5 - Math.random());
  123. // 补足到3个推荐
  124. return [...tagMatchedRecommendations, ...shuffledRemaining].slice(0, 3);
  125. }
  126. // 如果标签匹配的推荐超过3个,取前3个
  127. return tagMatchedRecommendations.slice(0, 3);
  128. }
  129. module.exports = router;