From 70b7c2d8654231ba7c2a4e37e9f745dadea4ba8b Mon Sep 17 00:00:00 2001
From: zlg <482370576@qq.com>
Date: Tue, 23 Jul 2024 16:14:54 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E9=94=99=E8=AF=AF=E4=BF=AE=E6=AD=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../schisandra/share/mq/comment/CommentLikesConsumer.java  | 7 ++++++-
 .../schisandra/share/mq/comment/DetailLikesConsumer.java   | 7 ++++++-
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java
index 04e30e1..e98e649 100644
--- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java
+++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java
@@ -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);
+        }
+
     }
 
 
diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java
index 583b45c..ff277fb 100644
--- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java
+++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java
@@ -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);
+        }
+
     }
 }