视频审核

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

@@ -93,20 +93,16 @@ public class ReviewVideosRecordServiceImpl extends ServiceImpl<ReviewVideosRecor
                     evidence.setThumbnail(ossService.vcr2local(evidence.getThumbnail(), reviewVideosRecord.getTaskId()));
                 }
             }));
+            sseService.sendMsg(reviewVideosRecord.getUid(),
+                    ImmutableMap.of("type", "VIDEO", "msg",
+                            "视频" + reviewVideosRecord.getTitle() + "审核完成")
+            );
         }
 
         reviewVideosRecord.setResult(JSON.toJSONString(body));
 
         updateById(reviewVideosRecord);
 
-        if(sseService.sendMsg(reviewVideosRecord.getUid(),
-                ImmutableMap.of("type", "VIDEO", "msg",
-                        "视频" + reviewVideosRecord.getTitle() + "审核完成")
-        )){
-            reviewVideosRecord.setPushStatus(1);
-            updateById(reviewVideosRecord);
-        }
-
     }
 
     public void push(){

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

@@ -38,7 +38,7 @@ public class SSEService {
                 sseEmitter.send(SseEmitter.event().name("message").data(msg));
                 return true;
             } catch (IOException e) {
-                throw new BizException("推送消息失败");
+                return false;
             }
         }
         return false;