| | |
|---|
| | | import cn.lili.rocketmq.tags.CommentTagsEnum; |
|---|
| | | import cn.lili.rocketmq.tags.VideoTagsEnum; |
|---|
| | | import cn.lili.utils.COSUtil; |
|---|
| | | import cn.lili.utils.TencentCdnUtil; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
|---|
| | | import cn.lili.modules.lmk.mapper.VideoMapper; |
|---|
| | |
|---|
| | | private final RocketMQTemplate rocketMQTemplate; |
|---|
| | | private final ThumbsUpRecordService thumbsUpRecordService; |
|---|
| | | private final ElasticsearchOperations restTemplate; |
|---|
| | | private final TencentCdnUtil cdnUtil; |
|---|
| | | |
|---|
| | | @Qualifier("videoEsServiceImpl") |
|---|
| | | private final EsService esService; |
|---|
| | |
|---|
| | | video.setAuditPassTime(new Date()); |
|---|
| | | |
|---|
| | | fields.put("status", VideoStatusEnum.PUBLISHED.getValue()); |
|---|
| | | |
|---|
| | | // 调cdn预热 |
|---|
| | | cdnUtil.pushUrlsCache(new String[]{video.getCoverUrl(), video.getVideoFileKey()}); |
|---|
| | | } else { |
|---|
| | | video.setStatus(VideoStatusEnum.REJECT.getValue()); |
|---|
| | | fields.put("status", VideoStatusEnum.REJECT.getValue()); |
|---|
| | |
|---|
| | | dto.setFields(fields); |
|---|
| | | String destination = rocketmqCustomProperties.getVideoTopic() + ":" + VideoTagsEnum.ES_DOC_UPDATE_SOME_FIELD.name(); |
|---|
| | | rocketMQTemplate.asyncSend(destination, JSON.toJSONString(dto), RocketmqSendCallbackBuilder.commonCallback()); |
|---|
| | | |
|---|
| | | return Result.ok(); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * |
|---|
| | | * @param page |
|---|
| | | * @param videoId videoId推荐的视频id |
|---|
| | | */ |
|---|
