视频审核

src/main/java/com/sxtvs/open/api/review/job/VcrJob.java

@@ -32,5 +32,6 @@ public class VcrJob {
     @Scheduled(fixedDelay = 60 * 1000, initialDelay = 3000)
     public void refreshVcrVideoStatus(){
         reviewVideosRecordService.refreshBatchResult();
+        reviewVideosRecordService.push();
     }
 }

src/main/java/com/sxtvs/open/api/review/service/impl/ReviewVideosRecordServiceImpl.java

@@ -106,6 +106,15 @@ public class ReviewVideosRecordServiceImpl extends ServiceImpl<ReviewVideosRecor
 
     }
 
+    public void push(){
+        lambdaQuery().eq(ReviewVideosRecord::getStatus, "SUCCESS").list().forEach(x -> {
+            if(sseService.sendMsg(x.getUid(), "视频" + x.getTitle() + "审核完成")){
+                x.setPushStatus(1);
+                updateById(x);
+            }
+        });
+    }
+
     public void refreshBatchResult(){
         log.info("开始刷新视频审核结果");
         lambdaQuery().in(ReviewVideosRecord::getStatus, Arrays.asList("PROVISIONING", "PREPROCESSING", "PROCESSING")).list().forEach(this::refreshResult);