Browse Source

feat:评论系统改版初步

pull/27/head
zjz1993 5 years ago
parent
commit
2055a27edf
  1. 144
      models-built/new_reply.js
  2. 1
      models-built/new_reply.js.map
  3. 51
      models/new_reply.ts
  4. 86
      modules/discussion.js
  5. 36
      views/article.ejs

144
models-built/new_reply.js

@ -0,0 +1,144 @@
"use strict";
var __extends = (this && this.__extends) || (function () {
var extendStatics = function (d, b) {
extendStatics = Object.setPrototypeOf ||
({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
return extendStatics(d, b);
};
return function (d, b) {
extendStatics(d, b);
function __() { this.constructor = d; }
d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
};
})();
var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
return c > 3 && r && Object.defineProperty(target, key, r), r;
};
var __metadata = (this && this.__metadata) || function (k, v) {
if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
};
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while (_) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
exports.__esModule = true;
var TypeORM = require("typeorm");
var common_1 = require("./common");
var user_1 = require("./user");
var article_1 = require("./article");
var NewReply = /** @class */ (function (_super) {
__extends(NewReply, _super);
function NewReply() {
return _super !== null && _super.apply(this, arguments) || this;
}
NewReply.prototype.loadRelationships = function () {
return __awaiter(this, void 0, void 0, function () {
var _a, _b;
return __generator(this, function (_c) {
switch (_c.label) {
case 0:
_a = this;
return [4 /*yield*/, user_1["default"].findById(this.from_user_id)];
case 1:
_a.user = _c.sent();
_b = this;
return [4 /*yield*/, article_1["default"].findById(this.article_id)];
case 2:
_b.article = _c.sent();
return [2 /*return*/];
}
});
});
};
NewReply.prototype.isAllowedEditBy = function (user) {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, this.loadRelationships()];
case 1:
_a.sent();
return [2 /*return*/, user && (user.is_admin || this.from_user_id === user.id || user.id === this.article.user_id)];
}
});
});
};
NewReply.cache = false;
__decorate([
TypeORM.PrimaryGeneratedColumn(),
__metadata("design:type", Number)
], NewReply.prototype, "id");
__decorate([
TypeORM.Column({ nullable: true, type: "mediumtext" }),
__metadata("design:type", String)
], NewReply.prototype, "content");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "article_id");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "from_user_id");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "to_user_id");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "parent_id");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "public_time");
__decorate([
TypeORM.Column({ nullable: true, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "update_time");
__decorate([
TypeORM.Column({ "default": 0, type: "integer" }),
__metadata("design:type", Number)
], NewReply.prototype, "comments_num");
NewReply = __decorate([
TypeORM.Entity()
], NewReply);
return NewReply;
}(common_1["default"]));
exports["default"] = NewReply;
;
//# sourceMappingURL=new_reply.js.map

1
models-built/new_reply.js.map

@ -0,0 +1 @@
{"version":3,"file":"new_reply.js","sourceRoot":"","sources":["../models/new_reply.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,iCAAmC;AACnC,mCAA6B;AAC7B,+BAA0B;AAC1B,qCAAgC;AAIhC;IAAsC,4BAAK;IAA3C;;IA2CA,CAAC;IAVS,oCAAiB,GAAvB;;;;;;wBACI,KAAA,IAAI,CAAA;wBAAQ,qBAAM,iBAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,CAAC,EAAA;;wBAAlD,GAAK,IAAI,GAAG,SAAsC,CAAC;wBACnD,KAAA,IAAI,CAAA;wBAAW,qBAAM,oBAAO,CAAC,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,EAAA;;wBAAtD,GAAK,OAAO,GAAG,SAAuC,CAAC;;;;;KAC1D;IAEK,kCAAe,GAArB,UAAsB,IAAI;;;;4BACtB,qBAAM,IAAI,CAAC,iBAAiB,EAAE,EAAA;;wBAA9B,SAA8B,CAAC;wBAC/B,sBAAO,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,IAAI,IAAI,CAAC,YAAY,KAAK,IAAI,CAAC,EAAE,IAAI,IAAI,CAAC,EAAE,KAAK,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,EAAC;;;;KACvG;IAxCM,cAAK,GAAG,KAAK,CAAC;IAGrB;QADC,OAAO,CAAC,sBAAsB,EAAE;;gCACtB;IAGX;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,YAAY,EAAE,CAAC;;qCACvC;IAGhB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;wCACjC;IAGnB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;0CAC/B;IAGrB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;wCACjC;IAGnB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;uCAClC;IAGlB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;yCAChC;IAGpB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;yCAChC;IAGpB;QADC,OAAO,CAAC,MAAM,CAAC,EAAE,SAAO,EAAE,CAAC,EAAE,IAAI,EAAE,SAAS,EAAE,CAAC;;0CAC3B;IA5BJ,QAAQ;QAD5B,OAAO,CAAC,MAAM,EAAE;OACI,QAAQ,CA2C5B;IAAD,eAAC;CAAA,AA3CD,CAAsC,mBAAK,GA2C1C;qBA3CoB,QAAQ;AA2C5B,CAAC"}

51
models/new_reply.ts

@ -0,0 +1,51 @@
import * as TypeORM from "typeorm";
import Model from "./common";
import User from "./user";
import Article from "./article";
declare var syzoj: any;
@TypeORM.Entity()
export default class NewReply extends Model {
static cache = false;
@TypeORM.PrimaryGeneratedColumn()
id: number;
@TypeORM.Column({ nullable: true, type: "mediumtext" })
content: string;
@TypeORM.Column({ nullable: true, type: "integer" })
article_id: number;
@TypeORM.Column({ nullable: true, type: "integer" })
from_user_id: number;
@TypeORM.Column({ nullable: true, type: "integer" })
to_user_id: number;
@TypeORM.Column({ nullable: true, type: "integer" })
parent_id: number;
@TypeORM.Column({ nullable: true, type: "integer" })
public_time: number;
@TypeORM.Column({ nullable: true, type: "integer" })
update_time: number;
@TypeORM.Column({ default: 0, type: "integer" })
comments_num: number;
user?: User;
article?: Article;
async loadRelationships() {
this.user = await User.findById(this.from_user_id);
this.article = await Article.findById(this.article_id);
}
async isAllowedEditBy(user) {
await this.loadRelationships();
return user && (user.is_admin || this.from_user_id === user.id || user.id === this.article.user_id);
}
};

86
modules/discussion.js

@ -3,6 +3,7 @@ let Article = syzoj.model('article');
let ArticleComment = syzoj.model('article-comment'); let ArticleComment = syzoj.model('article-comment');
let User = syzoj.model('user'); let User = syzoj.model('user');
let Reply = syzoj.model('reply'); let Reply = syzoj.model('reply');
let NewReply = syzoj.model('new_reply');
app.get('/discussion/:type?', async (req, res) => { app.get('/discussion/:type?', async (req, res) => {
try { try {
@ -75,9 +76,65 @@ app.get('/discussion/problem/:pid', async (req, res) => {
}); });
app.get('/article/:id', async (req, res) => { app.get('/article/:id', async (req, res) => {
// try {
// let id = parseInt(req.params.id);
// let replyQuery = await Reply.createQueryBuilder();
// let article = await Article.findById(id);
// if (!article) throw new ErrorMessage('无此帖子。');
//
// await article.loadRelationships();
// article.allowedEdit = await article.isAllowedEditBy(res.locals.user);
// article.allowedComment = await article.isAllowedCommentBy(res.locals.user);
// article.content = await syzoj.utils.markdown(article.content);
//
// let where = { article_id: id };
// let commentsCount = await ArticleComment.countForPagination(where);
// let paginate = syzoj.utils.paginate(commentsCount, req.query.page, syzoj.config.page.article_comment);
//
// let comments = await ArticleComment.queryPage(paginate, where, {
// public_time: 'DESC'
// });
//
// for (let comment of comments) {
// const commentId = comment.id;
// const reply = await replyQuery.where("comment_id = :commentId", { commentId }).getMany();
// if (reply.length === 0) {
// comment.reply = [];
// } else {
// comment.reply = await reply.mapAsync(async (item) => {
// const replyUserId = item.user_id;
// item.reply_user = await User.findById(replyUserId);
// return item
// });
// }
// comment.content = await syzoj.utils.markdown(comment.content);
// comment.allowedEdit = await comment.isAllowedEditBy(res.locals.user);
// await comment.loadRelationships();
// }
//
// let problem = null;
// if (article.problem_id) {
// problem = await Problem.findById(article.problem_id);
// if (!await problem.isAllowedUseBy(res.locals.user)) {
// throw new ErrorMessage('您没有权限进行此操作。');
// }
// }
// res.render('article', {
// user: res.locals.user,
// article: article,
// comments: comments,
// paginate: paginate,
// problem: problem,
// commentsCount: commentsCount
// });
// } catch (e) {
// syzoj.log(e);
// res.render('error', {
// err: e
// });
// }
try { try {
let id = parseInt(req.params.id); let id = parseInt(req.params.id);
let replyQuery = await Reply.createQueryBuilder();
let article = await Article.findById(id); let article = await Article.findById(id);
if (!article) throw new ErrorMessage('无此帖子。'); if (!article) throw new ErrorMessage('无此帖子。');
@ -87,25 +144,15 @@ app.get('/article/:id', async (req, res) => {
article.content = await syzoj.utils.markdown(article.content); article.content = await syzoj.utils.markdown(article.content);
let where = { article_id: id }; let where = { article_id: id };
let commentsCount = await ArticleComment.countForPagination(where); let commentsCount = await NewReply.countForPagination(where);
let paginate = syzoj.utils.paginate(commentsCount, req.query.page, syzoj.config.page.article_comment); let paginate = syzoj.utils.paginate(commentsCount, req.query.page, syzoj.config.page.article_comment);
let comments = await ArticleComment.queryPage(paginate, where, { let comments = await NewReply.queryPage(paginate, where, {
public_time: 'DESC' public_time: 'DESC'
}); });
console.log(comments);
for (let comment of comments) { for (let comment of comments) {
const commentId = comment.id;
const reply = await replyQuery.where("comment_id = :commentId", { commentId }).getMany();
if (reply.length === 0) {
comment.reply = [];
} else {
comment.reply = await reply.mapAsync(async (item) => {
const replyUserId = item.user_id;
item.reply_user = await User.findById(replyUserId);
return item
});
}
comment.content = await syzoj.utils.markdown(comment.content); comment.content = await syzoj.utils.markdown(comment.content);
comment.allowedEdit = await comment.isAllowedEditBy(res.locals.user); comment.allowedEdit = await comment.isAllowedEditBy(res.locals.user);
await comment.loadRelationships(); await comment.loadRelationships();
@ -239,18 +286,21 @@ app.post('/article/:id/comment', async (req, res) => {
let id = parseInt(req.params.id); let id = parseInt(req.params.id);
let article = await Article.findById(id); let article = await Article.findById(id);
let to_id = article.user_id;
if (!article) { if (!article) {
throw new ErrorMessage('无此帖子。'); throw new ErrorMessage('无此帖子。');
} else { } else {
if (!await article.isAllowedCommentBy(res.locals.user)) throw new ErrorMessage('您没有权限进行此操作。'); if (!await article.isAllowedCommentBy(res.locals.user)) throw new ErrorMessage('您没有权限进行此操作。');
} }
let comment = await ArticleComment.create({ let comment = await NewReply.create({
content: req.body.comment, content: req.body.comment,
article_id: id, article_id: id,
user_id: res.locals.user.id, from_user_id: res.locals.user.id,
public_time: syzoj.utils.getCurrentDate() to_user_id: to_id,
public_time: syzoj.utils.getCurrentDate(),
update_time: syzoj.utils.getCurrentDate(),
comments_num: 1,
}); });
await comment.save(); await comment.save();

36
views/article.ejs

@ -110,42 +110,6 @@
<%}%> <%}%>
</div> </div>
</div> </div>
<% for (let reply of comment.reply) { %>
<div class="comment reply">
<a class="avatar">
<img src="<%= syzoj.utils.gravatar(reply.reply_user.email, 120) %>" alt="">
</a>
<div class="content">
<a class="author" href="<%= syzoj.utils.makeUrl(['user', reply.user_id]) %>"><%= reply.reply_user.username %></a><% if (reply.reply_user.nameplate) { %><%- reply.reply_user.nameplate %><% } %>
<div class="metadata">
<span class="date"><%= syzoj.utils.formatDate(reply.public_time) %></span>
</div>
<div class="text font-content" style="min-height: 19.5px; "><%- reply.content %></div>
<% if (comment.allowedEdit) { %>
<div class="actions"><a onclick="$('#modal-delete-reply-<%= reply.id %>').modal('show')">删除</a></div>
<div class="ui basic modal" id="modal-delete-reply-<%= reply.id %>">
<div class="ui icon header">
<i class="trash icon"></i>
<p style="margin-top: 15px; ">删除回复</p>
</div>
<div class="content" style="text-align: center; ">
<p>确认删除这条回复吗?</p>
</div>
<div class="actions">
<div class="ui red basic cancel inverted button">
<i class="remove icon"></i>
</div>
<a class="ui green ok inverted button" href-post="<%= syzoj.utils.makeUrl(['article', article.id, 'reply', reply.id, 'delete']) %>">
<i class="checkmark icon"></i>
</a>
</div>
</div>
<% } %>
</div>
</div>
<% } %>
<% } %> <% } %>
</div> </div>
<div style="margin-bottom: 50px; "> <div style="margin-bottom: 50px; ">

Loading…
Cancel
Save