直播申请、点播添加异步注解、修改点播送审时间

王言钊
1 parent 9b7d0aac
Showing 3 changed files with 7 additions and 1 deletions
src/main/java/com/cnlive/shenhe/ShenheApplication.java
src/main/java/com/cnlive/shenhe/job/LiveApplyJob.java
src/main/java/com/cnlive/shenhe/job/VideosJob.java
@@ -19,6 +19,7 @@ import org.springframework.boot.web.servlet.server.ConfigurableServletWebServerF
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.stereotype.Controller;
 import tk.mybatis.spring.annotation.MapperScan;
@@ -29,6 +30,7 @@ import java.util.Map;
 @SpringBootApplication
 @MapperScan(basePackages = {"com.cnlive.shenhe.mapper"})
+@EnableAsync
 public class ShenheApplication extends SpringBootServletInitializer {
     /**
      * url的前缀
@@ -16,6 +16,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import tk.mybatis.mapper.entity.Example;
@@ -29,6 +30,7 @@ import java.util.Map;
  * @author Administrator
  */
 @Component
+@Async
 public class LiveApplyJob {
     private static Logger logger = LoggerFactory.getLogger(LiveApplyJob.class);
@@ -7,6 +7,7 @@ import com.cnlive.shenhe.utils.CommonConstStates;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -16,6 +17,7 @@ import java.util.List;
  * @author Administrator
  */
 @Component
+@Async
 public class VideosJob {
     private static Logger logger = LoggerFactory.getLogger(VideosJob.class);
@@ -49,7 +51,7 @@ public class VideosJob {
      * 机审 、未审核 、抽帧完成 进行送审
      * 每天8点到23点执行，每分钟一次
      */
-    @Scheduled(cron = "0 0/1 8-23 * * ? ")
+    @Scheduled(cron = "0 0/3 8-23 * * ? ")
     public void videofilter() {
         ShyVideos shyVideos = new ShyVideos();
         //审核类型为机审