|
@@ -100,7 +100,7 @@ public class ReviewVideosRecordServiceImpl extends ServiceImpl<ReviewVideosRecor
|
|
updateById(reviewVideosRecord);
|
|
updateById(reviewVideosRecord);
|
|
|
|
|
|
if(sseService.sendMsg(reviewVideosRecord.getUid(),
|
|
if(sseService.sendMsg(reviewVideosRecord.getUid(),
|
|
- ImmutableMap.of("type", "IMG", "msg",
|
|
|
|
|
|
+ ImmutableMap.of("type", "VIDEO", "msg",
|
|
"视频" + reviewVideosRecord.getTitle() + "审核完成")
|
|
"视频" + reviewVideosRecord.getTitle() + "审核完成")
|
|
)){
|
|
)){
|
|
reviewVideosRecord.setPushStatus(1);
|
|
reviewVideosRecord.setPushStatus(1);
|
|
@@ -112,7 +112,7 @@ public class ReviewVideosRecordServiceImpl extends ServiceImpl<ReviewVideosRecor
|
|
public void push(){
|
|
public void push(){
|
|
lambdaQuery().eq(ReviewVideosRecord::getStatus, "SUCCESS").eq(ReviewVideosRecord::getPushStatus, 0).list().forEach(x -> {
|
|
lambdaQuery().eq(ReviewVideosRecord::getStatus, "SUCCESS").eq(ReviewVideosRecord::getPushStatus, 0).list().forEach(x -> {
|
|
if(sseService.sendMsg(x.getUid(),
|
|
if(sseService.sendMsg(x.getUid(),
|
|
- ImmutableMap.of("type", "IMG", "msg", "视频" + x.getTitle() + "审核完成")
|
|
|
|
|
|
+ ImmutableMap.of("type", "VIDEO", "msg", "视频" + x.getTitle() + "审核完成")
|
|
)){
|
|
)){
|
|
x.setPushStatus(1);
|
|
x.setPushStatus(1);
|
|
updateById(x);
|
|
updateById(x);
|