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