绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
3 天以前 3cba7c6a9c1a9df84bf5289c5a5815fe5eab2261 
 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;




/**


@@ -547,6 +551,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();