fix: 错误修正
This commit is contained in:
@@ -29,7 +29,12 @@ public class CommentLikesConsumer implements RocketMQListener<SchisandraUserLike
|
||||
String id = message.getCommentId();
|
||||
Boolean likes = message.getLike();
|
||||
schisandraShareCommentReplyDomainService.updateCommentsLikes(id, likes);
|
||||
schisandraUserLikesCommentDomainService.add(message);
|
||||
if (likes) {
|
||||
schisandraUserLikesCommentDomainService.add(message);
|
||||
}else {
|
||||
schisandraUserLikesCommentDomainService.delete(message);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
@@ -27,6 +27,11 @@ public class DetailLikesConsumer implements RocketMQListener<SchisandraUserLikes
|
||||
String id = message.getDetailId();
|
||||
Boolean likes = message.getLike();
|
||||
schisandraShareDetailDomainService.updateDetailLikes(id, likes);
|
||||
schisandraUserLikesDetailDomainService.add(message);
|
||||
if (likes) {
|
||||
schisandraUserLikesDetailDomainService.add(message);
|
||||
}else {
|
||||
schisandraUserLikesDetailDomainService.delete(message);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user