视频审核

src/main/java/com/sxtvs/open/api/review/controller/SseController.java

@@ -18,9 +18,10 @@ public class SseController {
 
     @GetMapping(path = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     @LoginRequired
-    public SseEmitter handleSse() {
-        SseEmitter sseEmitter = new SseEmitter(30_000L); // 设置超时时间
+    public SseEmitter handleSse() throws InterruptedException {
+        SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(sseEmitter);
+        Thread.sleep(500);
         return sseEmitter;
     }
 }

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

@@ -101,7 +101,7 @@ public class ReviewImgRecordServiceImpl extends ServiceImpl<ReviewImgRecordMappe
     }
 
     public void refreshBatchResult(){
-        lambdaQuery().in(ReviewImgRecord::getStatus, Arrays.asList("PROVISIONING", "PREPROCESSING", "PROCESSING")).list().forEach(this::refreshResult);
+        lambdaQuery().in(ReviewImgRecord::getStatus, Arrays.asList("PROVISIONING", "PREPROCESSING", "PROCESSING")).ne(ReviewImgRecord::getTaskId, "").list().forEach(this::refreshResult);
     }
 
     public Page<ReviewImgRecord> list(PageReqDTO  pageReqDTO){