MOD:新增vod接口

2023-06-15 15:55:53 +08:00
parent f3b147d470
commit 08fe94f020
8 changed files with 454 additions and 1 deletions
@@ -0,0 +1,28 @@
+package com.leosam.tvbox.mv.controller;
+
+import com.leosam.tvbox.mv.data.VodResult;
+import com.leosam.tvbox.mv.service.MvService;
+import com.leosam.tvbox.mv.utils.NumberUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author admin
+ * @since 2023/6/11 18:54
+ */
+@RestController
+public class VodController {
+
+    @Autowired
+    private MvService mvService;
+
+    @RequestMapping(value = {"/mv/vod"})
+    public VodResult searchVod(String wd, String ac, String ids, String maxCount) throws Exception {
+        int max = Math.min(Math.max(NumberUtils.toInt(maxCount, 100), 10), 1000);
+        String query = StringUtils.hasText(wd) ? wd : ids;
+        return mvService.searchVod(query, max);
+    }
+
+}
@@ -0,0 +1,94 @@
+package com.leosam.tvbox.mv.data;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @author admin
+ * @since 2023/6/11 18:58
+ */
+public class Vod {
+
+    @JsonProperty("vod_id")
+    private String vodId;
+
+    @JsonProperty("vod_name")
+    private String vodName;
+
+    @JsonProperty("vod_actor")
+    private String vodActor;
+
+    @JsonProperty("vod_play_from")
+    private String vodPlayFrom;
+
+    @JsonProperty("vod_pic")
+    private String vodPic;
+
+    @JsonProperty("vod_play_url")
+    private String vodPlayUrl;
+
+    public String getVodId() {
+        return vodId;
+    }
+
+    public Vod setVodId(String vodId) {
+        this.vodId = vodId;
+        return this;
+    }
+
+    public String getVodName() {
+        return vodName;
+    }
+
+    public Vod setVodName(String vodName) {
+        this.vodName = vodName;
+        return this;
+    }
+
+    public String getVodActor() {
+        return vodActor;
+    }
+
+    public Vod setVodActor(String vodActor) {
+        this.vodActor = vodActor;
+        return this;
+    }
+
+    public String getVodPlayFrom() {
+        return vodPlayFrom;
+    }
+
+    public Vod setVodPlayFrom(String vodPlayFrom) {
+        this.vodPlayFrom = vodPlayFrom;
+        return this;
+    }
+
+    public String getVodPic() {
+        return vodPic;
+    }
+
+    public Vod setVodPic(String vodPic) {
+        this.vodPic = vodPic;
+        return this;
+    }
+
+    public String getVodPlayUrl() {
+        return vodPlayUrl;
+    }
+
+    public Vod setVodPlayUrl(String vodPlayUrl) {
+        this.vodPlayUrl = vodPlayUrl;
+        return this;
+    }
+
+    @Override
+    public String toString() {
+        return "Vod{" +
+                "vodId='" + vodId + '\'' +
+                ", vodName='" + vodName + '\'' +
+                ", vodActor='" + vodActor + '\'' +
+                ", vodPlayFrom='" + vodPlayFrom + '\'' +
+                ", vodPic='" + vodPic + '\'' +
+                ", vodPlayUrl='" + vodPlayUrl + '\'' +
+                '}';
+    }
+}
@@ -0,0 +1,79 @@
+package com.leosam.tvbox.mv.data;
+
+import java.util.List;
+
+/**
+ * @author admin
+ * @since 2023/6/11 18:57
+ */
+public class VodResult {
+
+    private int code;
+    private int page;
+    private int pagecount;
+    private int limit;
+    private int total;
+    private List<Vod> list;
+
+    public void init() {
+        this.code = 1;
+        this.page = 1;
+        this.pagecount = 1;
+        this.limit = 1;
+        this.total = 1;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public VodResult setCode(int code) {
+        this.code = code;
+        return this;
+    }
+
+    public int getPage() {
+        return page;
+    }
+
+    public VodResult setPage(int page) {
+        this.page = page;
+        return this;
+    }
+
+    public int getPagecount() {
+        return pagecount;
+    }
+
+    public VodResult setPagecount(int pagecount) {
+        this.pagecount = pagecount;
+        return this;
+    }
+
+    public int getLimit() {
+        return limit;
+    }
+
+    public VodResult setLimit(int limit) {
+        this.limit = limit;
+        return this;
+    }
+
+    public int getTotal() {
+        return total;
+    }
+
+    public VodResult setTotal(int total) {
+        this.total = total;
+        return this;
+    }
+
+    public List<Vod> getList() {
+        return list;
+    }
+
+    public VodResult setList(List<Vod> list) {
+        this.list = list;
+        return this;
+    }
+}
@@ -2,6 +2,8 @@ package com.leosam.tvbox.mv.service;

 import com.leosam.tvbox.mv.data.MvContent;
 import com.leosam.tvbox.mv.data.MvResult;
+import com.leosam.tvbox.mv.data.Vod;
+import com.leosam.tvbox.mv.data.VodResult;
 import com.leosam.tvbox.mv.lucene.MvIndex;
 import com.leosam.tvbox.mv.lucene.MvSearcher;
 import com.leosam.tvbox.mv.utils.ClassPathReaderUtils;
@@ -15,12 +17,17 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 import org.springframework.util.StopWatch;
 import org.springframework.util.StringUtils;

 import java.io.File;
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.LinkedHashSet;
 import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
 import java.util.concurrent.atomic.AtomicInteger;

 /**
@@ -80,6 +87,34 @@ public class MvService implements InitializingBean {
        return result;
    }

+    public VodResult searchVod(String wd, int max) throws Exception {
+        MvResult search = search(wd, max);
+        if (CollectionUtils.isEmpty(search.getList())) {
+            return new VodResult();
+        }
+        Vod vod = new Vod();
+        vod.setVodId(wd);
+        vod.setVodName(wd);
+        vod.setVodPlayFrom("mv");
+        vod.setVodPic("http://m4.auto.itc.cn/auto/content/20230611/45d65d8a001f0c5aa008030f41c98666.jpeg");
+        List<String> playUrlList = new LinkedList<>();
+        Set<String> vodActorList = new LinkedHashSet<>();
+        for (MvContent content : search.getList()) {
+            playUrlList.add(content.getName() + "$" + content.getUrl());
+            if (vodActorList.size() < 5 && StringUtils.hasText(content.getSongUser())) {
+                vodActorList.add(content.getSongUser());
+            }
+        }
+        vod.setVodPlayUrl(String.join("#", playUrlList));
+        vod.setVodActor(String.join(",", vodActorList));
+
+        VodResult vodResult = new VodResult();
+        vodResult.init();
+        vodResult.setList(new ArrayList<>()).getList().add(vod);
+        // logger.debug("searchVod , wd{}, vodResult={}", wd, JsonUtils.writeValue(vodResult));
+        return vodResult;
+    }
+
    @Override
    public void afterPropertiesSet() throws Exception {
        // 重建索引
@@ -151,4 +186,6 @@ public class MvService implements InitializingBean {
        stopWatch.stop();
        logger.info("重建索引中....完成,耗时 {} 毫秒, 索引位置：{}", stopWatch.getTotalTimeMillis(), file.getPath());
    }
+
+
 }
@@ -0,0 +1,93 @@
+package com.leosam.tvbox.mv.utils;
+
+
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.HashMap;
+
+/**
+ *
+ */
+public class JsonUtils {
+
+    private static final Logger LOG = LoggerFactory.getLogger(JsonUtils.class);
+    private static final TypeReference<HashMap<String, String>> TYPE_MAP =
+            new TypeReference<HashMap<String, String>>() {
+            };
+
+    public static ObjectMapper objectMapper = new ObjectMapper();
+
+    static {
+        objectMapper.registerModule(new Jdk8Module());
+        objectMapper.enable(JsonParser.Feature.ALLOW_COMMENTS);
+    }
+
+    public static String writeValue(Object o) {
+        try {
+            return writeValueThrowException(o);
+        } catch (Exception e) {
+            return "";
+        }
+    }
+
+    public static String writeValuePrettyPrinter(Object o) {
+        try {
+            return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(o);
+        } catch (Exception e) {
+            LOG.error("exception occur when Json serializePretty", e);
+            return "";
+        }
+    }
+
+
+    public static String writeValueThrowException(Object o) throws JsonProcessingException {
+        try {
+            return objectMapper.writeValueAsString(o);
+        } catch (Exception e) {
+            LOG.error("exception occur when Json serialize", e);
+            throw e;
+        }
+    }
+
+    public static <T> T readValue(String json, Class<T> clazz) {
+        try {
+            return readValueThrowException(json, clazz);
+        } catch (IOException e) {
+            return null;
+        }
+    }
+
+    public static <T> T readValueThrowException(String json, Class<T> clazz) throws IOException {
+        try {
+            return objectMapper.readValue(json, clazz);
+        } catch (IOException e) {
+            LOG.warn("Failed to deserialize from JSON string", e);
+            throw e;
+        }
+    }
+
+    public static <T> T readValue(String json, TypeReference<T> typeReference) {
+        try {
+            return readValueThrowException(json, typeReference);
+        } catch (IOException e) {
+            return null;
+        }
+    }
+
+    public static <T> T readValueThrowException(String json, TypeReference<T> typeReference) throws IOException {
+        try {
+            return objectMapper.readValue(json, typeReference);
+        } catch (IOException e) {
+            LOG.warn("Failed to deserialize from JSON string", e);
+            throw e;
+        }
+    }
+
+}
@@ -0,0 +1,40 @@
+package com.leosam.tvbox.mv.view;
+
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.servlet.HandlerInterceptor;
+
+/**
+ * @author admin
+ * @since 2023/6/11 20:03
+ */
+public class MyTimeInterceptor implements HandlerInterceptor {
+
+    private static final Logger logger = LoggerFactory.getLogger(MyTimeInterceptor.class);
+    /**
+     * 线程变量 - 开始执行时间
+     */
+    private final ThreadLocal<Long> startTime = new ThreadLocal<>();
+
+    @Override
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
+        startTime.set(System.nanoTime());
+        return true;
+    }
+
+    @Override
+    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
+        if (startTime.get() == null) {
+            return;
+        }
+        long processTime = System.nanoTime() - startTime.get();
+        if (logger.isInfoEnabled()) {
+            logger.info("RequestURL[{}], Referer[{}], TIME[{} ms]", request.getRequestURL().toString(), request.getHeader("Referer"), String.format("%.3f", (processTime / 1_000_000.0)));
+        }
+        startTime.remove();
+    }
+
+}
+
@@ -0,0 +1,27 @@
+package com.leosam.tvbox.mv.view;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+/**
+ * @author admin
+ */
+@Configuration
+public class MyWebMvcConfig implements WebMvcConfigurer {
+
+    @Override
+    public void addResourceHandlers(ResourceHandlerRegistry registry) {
+        registry.addResourceHandler("/static/**").addResourceLocations("classpath:/static/");
+    }
+
+    @Override
+    public void addInterceptors(InterceptorRegistry registry) {
+        // 页面运行时间统计
+        registry.addInterceptor(new MyTimeInterceptor())
+                .addPathPatterns("/**")
+                .excludePathPatterns("/static/**")
+                .excludePathPatterns("/favicon.ico");
+    }
+}