feat(mall): 为社交活动添加点赞和收藏功能

Administrator

2025-07-22 48e926f7f767a6d65cab2b52a057d345c2ee7e0e

 src/main/java/cc/mrbird/febs/mall/service/impl/ApiClothesSocialServiceImpl.java

@@ -10,6 +10,7 @@
import cc.mrbird.febs.mall.service.ApiClothesSocialService;
import cc.mrbird.febs.mall.vo.activity.ApiScCategoryInfoVo;
import cc.mrbird.febs.mall.vo.clothes.*;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSON;
@@ -61,6 +62,7 @@
    private final ClothesLocationRemarkMapper clothesLocationRemarkMapper;
    private final ClothesPatternRemarkMapper clothesPatternRemarkMapper;
    private final ClothesSocialCommentMapper clothesSocialCommentMapper;
    private final AgentProducer agentProducer;


    @Override
@@ -120,32 +122,32 @@
        // 调用Mapper方法获取活动分页数据
        Page<ApiAllSocialVo> voPage = clothesSocialMapper.selectPageInSocial(page, dto);

        List<ApiAllSocialVo> vos = voPage.getRecords();
        if (CollUtil.isNotEmpty(vos)) {
            Set<Long> socialIds = vos.stream()
                    .map(ApiAllSocialVo::getId)
                    .filter(Objects::nonNull)
                    .collect(Collectors.toSet());

            if (CollUtil.isNotEmpty(socialIds)) {
                List<ClothesSocialFollow> clothesSocialFollows = clothesSocialFollowMapper.selectList(
                        Wrappers.lambdaQuery(ClothesSocialFollow.class)
                                .select(ClothesSocialFollow::getId, ClothesSocialFollow::getSourceId)
                                .in(ClothesSocialFollow::getSourceId, socialIds)
                                .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
                );

                Map<Long, Long> likeCountBySocialIdMap = new HashMap<>();
                if (CollUtil.isNotEmpty(clothesSocialFollows)) {
                    likeCountBySocialIdMap = clothesSocialFollows.stream()
                            .collect(Collectors.groupingBy(ClothesSocialFollow::getSourceId, Collectors.counting()));
                }

                for (ApiAllSocialVo item : vos){
                    item.setLikeCnt(likeCountBySocialIdMap.getOrDefault(item.getId(), 0L).intValue());
                }
            }
        }
//        List<ApiAllSocialVo> vos = voPage.getRecords();
//        if (CollUtil.isNotEmpty(vos)) {
//            Set<Long> socialIds = vos.stream()
//                    .map(ApiAllSocialVo::getId)
//                    .filter(Objects::nonNull)
//                    .collect(Collectors.toSet());
//
//            if (CollUtil.isNotEmpty(socialIds)) {
//                List<ClothesSocialFollow> clothesSocialFollows = clothesSocialFollowMapper.selectList(
//                        Wrappers.lambdaQuery(ClothesSocialFollow.class)
//                                .select(ClothesSocialFollow::getId, ClothesSocialFollow::getSourceId)
//                                .in(ClothesSocialFollow::getSourceId, socialIds)
//                                .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
//                );
//
//                Map<Long, Long> likeCountBySocialIdMap = new HashMap<>();
//                if (CollUtil.isNotEmpty(clothesSocialFollows)) {
//                    likeCountBySocialIdMap = clothesSocialFollows.stream()
//                            .collect(Collectors.groupingBy(ClothesSocialFollow::getSourceId, Collectors.counting()));
//                }
//
//                for (ApiAllSocialVo item : vos){
//                    item.setLikeCnt(likeCountBySocialIdMap.getOrDefault(item.getId(), 0L).intValue());
//                }
//            }
//        }

        return new FebsResponse().success().data(voPage);
    }
@@ -165,6 +167,8 @@
            apiSocialInfoVo.setContent(clothesSocial.getContent());
            apiSocialInfoVo.setCreatedTime(clothesSocial.getCreatedTime());
            apiSocialInfoVo.setCommentState(clothesSocial.getCommentState());
            apiSocialInfoVo.setLikeCnt(clothesSocial.getLikeCnt());
            apiSocialInfoVo.setCollectCnt(clothesSocial.getCollectCnt());

            List<ClothesSocialFile> clothesSocialFiles = clothesSocialFileMapper.selectList(
                    Wrappers.lambdaQuery(ClothesSocialFile.class)
@@ -249,19 +253,24 @@

                apiSocialInfoVo.setMuse(apiSocialMuseVo);

                List<ClothesSocialFollow> clothesSocialFollows = clothesSocialFollowMapper.selectList(
                        Wrappers.lambdaQuery(ClothesSocialFollow.class)
                                .select(ClothesSocialFollow::getType)
                                .eq(ClothesSocialFollow::getSourceId, socialId)
                                .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
                );
                if (CollUtil.isNotEmpty(clothesSocialFollows)){

                    Map<Integer, Long> collect = clothesSocialFollows.stream()
                            .collect(Collectors.groupingBy(ClothesSocialFollow::getType, Collectors.counting()));
                    apiSocialInfoVo.setLikeCnt(collect.getOrDefault(SocialTypeEnum.LIKE.getValue(), 0L).intValue());
                    apiSocialInfoVo.setCollectCnt(collect.getOrDefault(SocialTypeEnum.COLLECT.getValue(), 0L).intValue());
                }
//                Integer likeCnt = clothesSocial.getLikeCnt();
//                Integer collectCnt = clothesSocial.getCollectCnt();
//
//                List<ClothesSocialFollow> clothesSocialFollows = clothesSocialFollowMapper.selectList(
//                        Wrappers.lambdaQuery(ClothesSocialFollow.class)
//                                .select(ClothesSocialFollow::getType)
//                                .eq(ClothesSocialFollow::getSourceId, socialId)
//                                .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
//                );
//                if (CollUtil.isNotEmpty(clothesSocialFollows)){
//
//                    Map<Integer, Long> collect = clothesSocialFollows.stream()
//                            .collect(Collectors.groupingBy(ClothesSocialFollow::getType, Collectors.counting()));
//                    likeCnt = likeCnt + collect.getOrDefault(SocialTypeEnum.LIKE.getValue(), 0L).intValue();
//                    collectCnt = collectCnt + collect.getOrDefault(SocialTypeEnum.COLLECT.getValue(), 0L).intValue();
//                }
//                apiSocialInfoVo.setLikeCnt(likeCnt);
//                apiSocialInfoVo.setCollectCnt(collectCnt);

                List<ClothesSocialComment> clothesSocialComments = clothesSocialCommentMapper.selectList(
                        Wrappers.lambdaQuery(ClothesSocialComment.class)
@@ -402,6 +411,8 @@
            clothesSocialFollow.setSourceId(socialId);
            clothesSocialFollow.setType(SocialTypeEnum.LIKE.getValue());
            clothesSocialFollowMapper.insert(clothesSocialFollow);

            agentProducer.sendAddLike(socialId);
        }
        return new FebsResponse().success().message("操作成功");
    }
@@ -419,6 +430,8 @@
            clothesSocialFollow.setSourceOptionId(dto.getCommentId());
            clothesSocialFollow.setType(SocialTypeEnum.LIKE.getValue());
            clothesSocialFollowMapper.insert(clothesSocialFollow);

            agentProducer.sendAddCollect(socialId);
        }
        return new FebsResponse().success().message("操作成功");
    }
@@ -430,6 +443,16 @@
        Long socialId = dto.getSocialId();
        ClothesSocial clothesSocial = clothesSocialMapper.selectById(socialId);
        if(ObjectUtil.isNotNull(clothesSocial)){
            List<ClothesSocialFollow> clothesSocialFollows = clothesSocialFollowMapper.selectList(
                    Wrappers.lambdaQuery(ClothesSocialFollow.class)
                            .eq(ClothesSocialFollow::getMemberId, memberId)
                            .eq(ClothesSocialFollow::getSourceType, SocialSourceTypeEnum.SOCIAL.getValue())
                            .eq(ClothesSocialFollow::getSourceId, socialId)
                            .eq(ClothesSocialFollow::getType, SocialTypeEnum.COLLECT.getValue())
            );
            if (CollUtil.isNotEmpty(clothesSocialFollows)){
                return new FebsResponse().success().message("已收藏");
            }
            ClothesSocialFollow clothesSocialFollow = new ClothesSocialFollow();
            clothesSocialFollow.setMemberId(memberId);
            clothesSocialFollow.setSourceType(SocialSourceTypeEnum.SOCIAL.getValue());