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

xiangpei

4 天以前 2f68e5600f0b60d6f8d170f4536e1fc410662ea7

 manager-api/src/main/java/cn/lili/controller/lmk/VideoController.java

@@ -1,5 +1,6 @@
package cn.lili.controller.lmk;

import cn.lili.elasticsearch.EsSuffix;
import cn.lili.group.Update;
import cn.lili.group.Add;
import cn.lili.modules.lmk.domain.form.VideoAuditingForm;
@@ -7,6 +8,8 @@
import cn.lili.modules.lmk.domain.form.VideoRecommendForm;
import cn.lili.modules.lmk.domain.form.WxVideoForm;
import cn.lili.modules.lmk.domain.query.ManagerVideoQuery;
import cn.lili.modules.lmk.service.EsService;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.validation.annotation.Validated;
import lombok.RequiredArgsConstructor;
import java.util.List;
@@ -32,17 +35,8 @@

    private final VideoService videoService;

    @PostMapping
    @ApiOperation(value = "添加", notes = "添加")
    public Result add(@RequestBody @Validated(Add.class) WxVideoForm form) {
        return videoService.add(form);
    }

    @PutMapping
    @ApiOperation(value = "修改", notes = "修改")
    public Result update(@RequestBody @Validated(Update.class) WxVideoForm form) {
        return videoService.update(form);
    }
    @Qualifier("videoEsServiceImpl")
    private final EsService esService;

    @DeleteMapping("/{id}")
    @ApiOperation(value = "ID删除", notes = "ID删除")
@@ -97,4 +91,10 @@
    public Result down(@RequestBody @Validated VideoDownForm form) {
        return videoService.down(form);
    }

    @PostMapping("/recreate/es/index")
    @ApiOperation(value = "重建es索引", notes = "重建es索引")
    public Result recreateEsIndex() {
        return videoService.recreateEsIndex();
    }
}