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

xiangpei

6 天以前 2f68e5600f0b60d6f8d170f4536e1fc410662ea7

 buyer-api/src/main/java/cn/lili/controller/member/FootprintController.java

@@ -2,11 +2,13 @@

import cn.lili.common.enums.ResultUtil;
import cn.lili.common.security.context.UserContext;
import cn.lili.common.utils.StringUtils;
import cn.lili.common.vo.PageVO;
import cn.lili.common.vo.ResultMessage;
import cn.lili.modules.member.entity.dto.FootPrintQueryParams;
import cn.lili.modules.member.service.FootprintService;
import cn.lili.modules.search.entity.dos.EsGoodsIndex;
import cn.lili.utils.COSUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
@@ -36,11 +38,30 @@
    @Autowired
    private FootprintService footprintService;

    @Autowired
    private COSUtil cosUtil;
    @ApiOperation(value = "分页获取")
    @GetMapping
    public ResultMessage<IPage<EsGoodsIndex>> getByPage(FootPrintQueryParams params) {
        params.setMemberId(UserContext.getCurrentUser().getId());
        return ResultUtil.data(footprintService.footPrintPage(params));
        IPage<EsGoodsIndex> indexIPage = footprintService.footPrintPage(params);
        indexIPage.getRecords().forEach(item -> {

            String small = item.getSmall();
            String thumbnail = item.getThumbnail();
            String goodsVideo = item.getGoodsVideo();
            if (StringUtils.isNotBlank(small) && !small.contains("http")) {
                item.setSmall(cosUtil.getPreviewUrl(small));
            }
            if (StringUtils.isNotBlank(thumbnail) && !thumbnail.contains("http")) {
                item.setThumbnail(cosUtil.getPreviewUrl(thumbnail));
            }
            if (StringUtils.isNotBlank(goodsVideo) && !goodsVideo.contains("http")) {
                item.setGoodsVideo(cosUtil.getPreviewUrl(goodsVideo));
            }

        });
        return ResultUtil.data(indexIPage);
    }

    @ApiOperation(value = "根据id删除")