@@ -91,6 +91,7 @@ class CommentController extends controller {
91
91
const result = await this . app . mysql . query ( sql , valus ) ;
92
92
if ( result . affectedRows === 1 ) {
93
93
let selectSql = "" ;
94
+ let values = [ request . parentId , request . offset , request . limit ] ;
94
95
if ( request . typeName === "talkId" ) {
95
96
selectSql = `SELECT visitor_comment.id as id, visitor_comment.be_comment_id as beCommentId,
96
97
visitor_comment.comment as comment, visitor_comment.publish_time as publishTime, visitor_like.id as likeId, visitor_like.visitor_id as likeVisitorId,
@@ -125,14 +126,11 @@ class CommentController extends controller {
125
126
FROM visitor_comment
126
127
LEFT JOIN visitor ON visitor_comment.visitor_id = visitor.id
127
128
LEFT JOIN visitor_like ON visitor_comment.id = visitor_like.comment_id
128
- WHERE about_id = ?
129
+ WHERE about_id IS NOT NULL
129
130
ORDER BY visitor_comment.publish_time DESC LIMIT ?,?` ;
131
+ values = [ request . offset , request . limit ] ;
130
132
}
131
- const selectResults = await this . app . mysql . query ( selectSql , [
132
- request . parentId ,
133
- request . offset ,
134
- request . limit ,
135
- ] ) ;
133
+ const selectResults = await this . app . mysql . query ( selectSql , values ) ;
136
134
if ( selectResults . length > 0 ) {
137
135
/** 获取去重后的id列表 */
138
136
const commentIds = [
@@ -178,6 +176,7 @@ class CommentController extends controller {
178
176
async getComments ( ) {
179
177
const request = this . ctx . request . body ;
180
178
let selectSql = "" ;
179
+ let values = [ request . parentId , request . offset , request . limit ] ;
181
180
if ( request . typeName === "talkId" ) {
182
181
selectSql = `SELECT visitor_comment.id as id, visitor_comment.be_comment_id as beCommentId,
183
182
visitor_comment.comment as comment, visitor_comment.publish_time as publishTime, visitor_like.id as likeId, visitor_like.visitor_id as likeVisitorId,
@@ -214,12 +213,9 @@ class CommentController extends controller {
214
213
LEFT JOIN visitor_like ON visitor_comment.id = visitor_like.comment_id
215
214
WHERE about_id = ?
216
215
ORDER BY visitor_comment.publish_time DESC LIMIT ?,?` ;
216
+ values = [ request . offset , request . limit ] ;
217
217
}
218
- const selectResults = await this . app . mysql . query ( selectSql , [
219
- request . parentId ,
220
- request . offset ,
221
- request . limit ,
222
- ] ) ;
218
+ const selectResults = await this . app . mysql . query ( selectSql , values ) ;
223
219
if ( selectResults ) {
224
220
/** 获取去重后的id列表 */
225
221
const commentIds = [ ...new Set ( selectResults . map ( ( result ) => result . id ) ) ] ;
0 commit comments