视频es处理通过mq异步执行

xiangpei

6 天以前 2f68e5600f0b60d6f8d170f4536e1fc410662ea7

 framework/src/main/java/cn/lili/modules/lmk/mapper/VideoMapper.java

@@ -1,6 +1,7 @@
package cn.lili.modules.lmk.mapper;

import cn.lili.modules.lmk.domain.entity.Video;
import cn.lili.modules.lmk.domain.es.VideoIndex;
import cn.lili.modules.lmk.domain.query.*;
import cn.lili.modules.lmk.domain.vo.*;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
@@ -47,6 +48,9 @@
    IPage recommendVideo(IPage page, @Param("query") VideoQuery query);

    IPage recommendHealthVideo(IPage page, @Param("query") WxHealthVideoQuery query);


    IPage wxKitchenVideoQuery(IPage page, @Param("query") WxKitchenVideoQuery query);

    /**
     * 批量更新视频收藏数量
@@ -127,4 +131,13 @@
     * @return
     */
    List<VideoGoodsDetailVO> getVideoGoods(@Param("id") String videoId);

    /**
     * es同步查询视频数据
     *
     * @param start 开始位置
     * @param pageSize 每页条数
     * @return
     */
    List<VideoIndex> getEsPage(@Param("start") int start, @Param("pageSize") int pageSize);
}