Merge remote-tracking branch 'refs/remotes/origin/dev'
This commit is contained in:
@@ -27,6 +27,7 @@ public class CommentLikesConsumer implements RocketMQListener<SchisandraUserLike
|
|||||||
public void onMessage(SchisandraUserLikesCommentBO message) {
|
public void onMessage(SchisandraUserLikesCommentBO message) {
|
||||||
log.info("收到消息:{}", message);
|
log.info("收到消息:{}", message);
|
||||||
String id = message.getCommentId();
|
String id = message.getCommentId();
|
||||||
|
String userId=message.getUserId();
|
||||||
Boolean likes = message.getLike();
|
Boolean likes = message.getLike();
|
||||||
schisandraShareCommentReplyDomainService.updateCommentsLikes(id, likes);
|
schisandraShareCommentReplyDomainService.updateCommentsLikes(id, likes);
|
||||||
if (likes) {
|
if (likes) {
|
||||||
|
@@ -47,7 +47,7 @@ public class SchisandraUserLikesCommentDomainServiceImpl implements SchisandraUs
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Boolean deleteReal(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO) {
|
public Boolean deleteReal(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO) {
|
||||||
return schisandraUserLikesCommentService.deleteById(schisandraUserLikesCommentBO.getId());
|
return schisandraUserLikesCommentService.deleteById(schisandraUserLikesCommentBO.getUserId(),schisandraUserLikesCommentBO.getCommentId());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@@ -47,7 +47,7 @@ public class SchisandraUserLikesDetailDomainServiceImpl implements SchisandraUse
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Boolean deleteReal(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO) {
|
public Boolean deleteReal(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO) {
|
||||||
return schisandraUserLikesDetailService.deleteById(schisandraUserLikesDetailBO.getId());
|
return schisandraUserLikesDetailService.deleteById(schisandraUserLikesDetailBO.getUserId(),schisandraUserLikesDetailBO.getDetailId());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -40,7 +40,7 @@ public interface SchisandraUserLikesCommentService {
|
|||||||
* @param id 主键
|
* @param id 主键
|
||||||
* @return 是否成功
|
* @return 是否成功
|
||||||
*/
|
*/
|
||||||
boolean deleteById(String id);
|
boolean deleteById(String userId,String commentId);
|
||||||
|
|
||||||
SchisandraUserLikesComment queryByuserIdAndCommentId(String commentId, String userId);
|
SchisandraUserLikesComment queryByuserIdAndCommentId(String commentId, String userId);
|
||||||
}
|
}
|
||||||
|
@@ -40,7 +40,7 @@ public interface SchisandraUserLikesDetailService {
|
|||||||
* @param id 主键
|
* @param id 主键
|
||||||
* @return 是否成功
|
* @return 是否成功
|
||||||
*/
|
*/
|
||||||
boolean deleteById(String id);
|
boolean deleteById(String userId,String detailId);
|
||||||
|
|
||||||
SchisandraUserLikesDetail selectLike(String Id,String userId);
|
SchisandraUserLikesDetail selectLike(String Id,String userId);
|
||||||
|
|
||||||
|
@@ -54,15 +54,12 @@ public class SchisandraUserLikesCommentServiceImpl implements SchisandraUserLike
|
|||||||
return this.schisandraUserLikesCommentDao.update(schisandraUserLikesComment,true);
|
return this.schisandraUserLikesCommentDao.update(schisandraUserLikesComment,true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过主键删除数据
|
|
||||||
*
|
|
||||||
* @param id 主键
|
|
||||||
* @return 是否成功
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public boolean deleteById(String id) {
|
public boolean deleteById(String userId,String commentId) {
|
||||||
return this.schisandraUserLikesCommentDao.deleteById(id) > 0;
|
return this.schisandraUserLikesCommentDao.deleteByCondition(
|
||||||
|
SchisandraUserLikesCommentTableDef.SCHISANDRA_USER_LIKES_COMMENT.COMMENT_ID.eq(commentId)
|
||||||
|
.and(SchisandraUserLikesCommentTableDef.SCHISANDRA_USER_LIKES_COMMENT.USER_ID.eq(userId))) > 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@@ -54,15 +54,11 @@ public class SchisandraUserLikesDetailServiceImpl implements SchisandraUserLikes
|
|||||||
return this.schisandraUserLikesDetailDao.update(schisandraUserLikesDetail,true);
|
return this.schisandraUserLikesDetailDao.update(schisandraUserLikesDetail,true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过主键删除数据
|
|
||||||
*
|
|
||||||
* @param id 主键
|
|
||||||
* @return 是否成功
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public boolean deleteById(String id) {
|
public boolean deleteById(String userId,String detailId) {
|
||||||
return this.schisandraUserLikesDetailDao.deleteById(id) > 0;
|
return this.schisandraUserLikesDetailDao.deleteByCondition(SchisandraUserLikesDetailTableDef.SCHISANDRA_USER_LIKES_DETAIL.USER_ID.eq(userId)
|
||||||
|
.and(SchisandraUserLikesDetailTableDef.SCHISANDRA_USER_LIKES_DETAIL.DETAIL_ID.eq(detailId))) > 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Reference in New Issue
Block a user