更新当前直播间数据缓存

fs-live-socket/src/main/java/com/fs/live/task/Task.java

@@ -164,7 +164,6 @@ public class Task {
         String key = "live:auto_task:";
         if (!startLiveList.isEmpty()) {
             for (Live live : startLiveList) {
-                redisUtil.zSetAdd(LiveKeysConstant.LIVE_HOME_PAGE_LIST, JSON.toJSONString(live), live.getCreateTime().getTime());
                 SendMsgVo sendMsgVo = new SendMsgVo();
                 sendMsgVo.setMsg("开始直播");
                 sendMsgVo.setCmd("live_start");
@@ -180,6 +179,8 @@ public class Task {
                     });
                 }
             }
+            // 重新更新所有在直播的缓存
+            liveService.asyncToCache();
         }
         if (!endLiveList.isEmpty()) {
             for (Live live : endLiveList) {
@@ -197,6 +198,8 @@ public class Task {
                 }
                 webSocketServer.removeLikeCountCache(live.getLiveId());
             }
+            // 重新更新所有在直播的缓存
+            liveService.asyncToCache();
         }
         if(!liveList.isEmpty()){
             for (Live live : liveList) {