From 1dd6f7e9c028c1de4118a199bd25f58e4be79b60 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 22 Jul 2025 11:11:06 +0800
Subject: [PATCH] refactor(mall): 移除 ApiClothesSocialServiceImpl 中的冗余代码

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java |   48 ++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 46 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java
index 6f61c90..7760047 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java
@@ -4,6 +4,7 @@
 import cc.mrbird.febs.common.enumerates.*;
 import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.LoginUserUtil;
+import cc.mrbird.febs.mall.dto.ApiColletDelDto;
 import cc.mrbird.febs.mall.dto.clothes.*;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
@@ -430,8 +431,6 @@
             clothesSocialFollow.setSourceOptionId(dto.getCommentId());
             clothesSocialFollow.setType(SocialTypeEnum.LIKE.getValue());
             clothesSocialFollowMapper.insert(clothesSocialFollow);
-
-            agentProducer.sendAddCollect(socialId);
         }
         return new FebsResponse().success().message("操作成功");
     }
@@ -459,6 +458,8 @@
             clothesSocialFollow.setSourceId(socialId);
             clothesSocialFollow.setType(SocialTypeEnum.COLLECT.getValue());
             clothesSocialFollowMapper.insert(clothesSocialFollow);
+
+            agentProducer.sendAddCollect(socialId);
         }
         return new FebsResponse().success().message("操作成功");
     }
@@ -651,6 +652,49 @@
         return new FebsResponse().success().data(voPage);
     }
 
+    @Override
+    public FebsResponse delCollection(ApiColletDelDto dto) {
+        Long memberId = LoginUserUtil.getLoginUser().getId();
+        List<Long> ids = dto.getIds();
+        if (CollUtil.isEmpty(ids)) {
+            return new FebsResponse().success().message("操作成功");
+        }
+
+        LambdaQueryWrapper<ClothesSocialFollow> delQuery = new LambdaQueryWrapper<>();
+        delQuery.eq(ClothesSocialFollow::getMemberId, memberId);
+        delQuery.eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue());
+        delQuery.in(ClothesSocialFollow::getSourceId, ids);
+        delQuery.eq(ClothesSocialFollow::getType, SocialTypeEnum.COLLECT.getValue());
+        clothesSocialFollowMapper.delete(delQuery);
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public FebsResponse followState(ApiSocialCollectFollowStateDto dto) {
+        Long memberId = LoginUserUtil.getLoginUser().getId();
+        HashMap<String, Object> stringObjectHashMap = new HashMap<>();
+
+        Integer collectState = clothesSocialFollowMapper.selectCount(
+                Wrappers.lambdaQuery(ClothesSocialFollow.class)
+                        .eq(ClothesSocialFollow::getMemberId, memberId)
+                        .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
+                        .eq(ClothesSocialFollow::getSourceId, dto.getSocialId())
+                        .eq(ClothesSocialFollow::getType, SocialTypeEnum.COLLECT.getValue())
+        );
+        stringObjectHashMap.put("collectState", collectState);
+
+        Integer likeState = clothesSocialFollowMapper.selectCount(
+                Wrappers.lambdaQuery(ClothesSocialFollow.class)
+                        .eq(ClothesSocialFollow::getMemberId, memberId)
+                        .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
+                        .eq(ClothesSocialFollow::getSourceId, dto.getSocialId())
+                        .eq(ClothesSocialFollow::getType, SocialTypeEnum.LIKE.getValue())
+        );
+        stringObjectHashMap.put("likeState", likeState);
+
+        return new FebsResponse().success().data(stringObjectHashMap);
+    }
+
     public static void main(String[] args) {
         JSONObject jsonObject = new JSONObject();
         jsonObject.putByPath("text", "123");

--
Gitblit v1.9.1