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


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


import cn.lili.cache.CachePrefix;


import cn.lili.common.properties.RocketmqCustomProperties;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.utils.CommonUtil;


import cn.lili.elasticsearch.EsSuffix;


import cn.lili.modules.lmk.constant.RedisKeyExpireConstant;


import cn.lili.modules.lmk.domain.dto.VideoEsUpdateDTO;


@@ -46,6 +47,7 @@


import org.springframework.data.elasticsearch.core.SearchHits;


import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;


import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import lombok.RequiredArgsConstructor;


import cn.lili.utils.PageUtil;


@@ -54,6 +56,8 @@


import org.springframework.util.Assert;




import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.function.Function;


import java.util.stream.Collectors;




/**


@@ -423,6 +427,12 @@


            page.getRecords().forEach(v -> {


                v.setTagList(tagMap.get(v.getId()));


                v.setCoverUrl(cosUtil.getPreviewUrl(v.getCoverUrl()));


                v.getGoodsList().forEach(goods ->{


                    if (StringUtils.isNotBlank(goods.getThumbnail())&&!goods.getThumbnail().contains("http")) {


                        goods.setThumbnail(cosUtil.getPreviewUrl(goods.getThumbnail()));


                    }




                });


            });


        }


        return Result.ok().data(page.getRecords()).total(page.getTotal());


@@ -547,6 +557,9 @@


        switch (query.getVideoFrom()) {


            case "recommend":// 加载推荐视频


                baseMapper.recommendVideo(page, query);


                //推荐视频重新排序


                List<WxVideoVO> records = page.getRecords();


                Collections.shuffle(records);


                break;


            case "author":  // 加载视频主页我发布的视频


                AuthorVideoQuery query1 = new AuthorVideoQuery();