绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
4 天以前 134f5b1aedeb90b9f7a71dc41e8f08e96bcb3f85 
 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,16 @@


        switch (query.getVideoFrom()) {


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


                baseMapper.recommendVideo(page, query);


                //推荐视频重新排序


                WxVideoVO wxVideoVO = null;


                if (StringUtils.isNotBlank(query.getVideoId())) {


                    wxVideoVO  = baseMapper.recommendVideoByVideoId(query);


                }


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


                Collections.shuffle(records);


                if (wxVideoVO!=null) {


                    records.set(0, wxVideoVO);


                }


                break;


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


                AuthorVideoQuery query1 = new AuthorVideoQuery();