绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
4 天以前 6fb006c40ff90a615fa3c3a55a65c99b55acc03d 
 framework/src/main/java/cn/lili/modules/lmk/service/impl/MyCollectServiceImpl.java


@@ -6,6 +6,7 @@


import cn.lili.modules.goods.entity.vos.GoodsVO;


import cn.lili.modules.lmk.domain.query.AuthorVideoQuery;


import cn.lili.modules.lmk.domain.vo.*;


import cn.lili.modules.lmk.service.MySubscribeService;


import cn.lili.modules.lmk.service.VideoService;


import cn.lili.rocketmq.RocketmqSendCallbackBuilder;


import cn.lili.rocketmq.tags.CommentTagsEnum;


@@ -24,6 +25,7 @@


import com.xkcoding.http.util.StringUtil;


import org.apache.rocketmq.spring.core.RocketMQTemplate;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.annotation.Lazy;


import org.springframework.stereotype.Service;


import lombok.RequiredArgsConstructor;


import cn.lili.utils.PageUtil;


@@ -52,14 +54,8 @@


    private final RocketmqCustomProperties rocketmqCustomProperties;


    private final LmkFileServiceImpl fileService;


    private final RocketMQTemplate rocketMQTemplate;


    private VideoService videoService; // 移除了final


    private COSUtil cOSUtil;


    private final VideoServiceMakeUpImpl serviceMakeUp;




    @Autowired


    public void setVideoService(VideoService videoService) {


        // 这里可以添加额外的初始化逻辑


        this.videoService = videoService;


    }






    /**


@@ -202,24 +198,7 @@


            videoQuery.setPageSize(query.getPageSize());




            videoQuery.setPageNumber(query.getPageNumber());


            Result result = videoService.getAuthorCollectVideoPage(videoQuery);


            List<WxVideoVO> list = Optional.ofNullable(result.get("data"))


                    .filter(data -> data instanceof List<?>)


                    .map(data -> (List<?>) data)


                    .orElse(Collections.emptyList())


                    .stream()


                    .filter(WxVideoVO.class::isInstance)


                    .map(WxVideoVO.class::cast)


                    .collect(Collectors.toList());


            for (WxVideoVO wxVideoVO : list){


                if (!CollectionUtils.isEmpty(wxVideoVO.getImgs())){


                    List<String> newImages = wxVideoVO


                            .getImgs().stream().map(item -> cOSUtil.getPreviewUrl(item)).collect(Collectors.toList());


                    wxVideoVO.setImgs(newImages);


                }




            }


            return result;


            return serviceMakeUp.getAuthorCollectVideoPage(videoQuery);


        }else if (CollectTypeEnum.goods.getType().equals(query.getType())) {


            baseMapper.getGoodsCollectPage(page, userId);