直播间数量

fs-admin/src/main/java/com/fs/core/aspectj/LiveControllerAspect.java

@@ -22,7 +22,10 @@ public class LiveControllerAspect {
 
     @AfterReturning(pointcut = "execution(* com.fs.live.controller.LiveController.add(..)) || " +
             "execution(* com.fs.live.controller.LiveController.finishLive(..)) || " +
+            "execution(* com.fs.live.controller.LiveController.handleDeleteSelected(..)) || " +
+            "execution(* com.fs.live.controller.LiveController.handleShelfOrUn(..)) || " +
             "execution(* com.fs.live.controller.LiveController.edit(..)) || " +
+            "execution(* com.fs.live.controller.LiveController.copyLive(..)) || " +
             "execution(* com.fs.live.controller.LiveController.remove(..)) " ,
             returning = "result")
     public void afterLiveControllerMethodExecution(JoinPoint joinPoint,Object result) {

fs-common/src/main/java/com/fs/common/core/redis/RedisUtil.java

@@ -257,6 +257,17 @@ public class RedisUtil {
         return Boolean.TRUE.equals(redisTemplate.opsForZSet().add(key, value, score));
     }
 
+    /**
+     * 向有序集合删除元素
+     *
+     * @param key   有序集合键
+     * @param value 数值
+     * @return 是否添加成功
+     */
+    public void zSetRemove(String key,  Object value) {
+       redisTemplate.opsForZSet().remove(key, value);
+    }
+
     /**
      * 升序获取有序集合指定范围的元素
      *

fs-company/src/main/java/com/fs/core/aspectj/LiveControllerAspect.java

@@ -25,6 +25,8 @@ public class LiveControllerAspect {
     @AfterReturning(pointcut = "execution(* com.fs.company.controller.live.LiveController.add(..)) || " +
             "execution(* com.fs.company.controller.live.LiveController.finishLive(..)) || " +
             "execution(* com.fs.company.controller.live.LiveController.copyLive(..)) || " +
+            "execution(* com.fs.company.controller.live.LiveController.handleShelfOrUn(..)) || " +
+            "execution(* com.fs.company.controller.live.LiveController.handleDeleteSelected(..)) || " +
             "execution(* com.fs.company.controller.live.LiveController.edit(..)) || " +
             "execution(* com.fs.company.controller.live.LiveController.remove(..)) || " +
             "execution(* com.fs.company.controller.live.LiveController.startLive(..))",

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

@@ -102,6 +102,7 @@ public class Task {
                 if (live.getFinishTime() == null) {
                     if (now.isAfter(live.getStartTime().minusSeconds(2L))){
                         if(live.getStatus() != 2){
+                            redisUtil.zSetRemove(LiveKeysConstant.LIVE_HOME_PAGE_LIST, JSON.toJSONString(live));
                             live.setStatus(2);
                             startLiveList.add(live);
                             liveList.add(live);
@@ -116,6 +117,7 @@ public class Task {
                 } else {
                     if (now.isAfter(live.getStartTime().minusSeconds(2L)) && now.isBefore(live.getFinishTime())) {
                         if(live.getStatus() != 2){
+                            redisUtil.zSetRemove(LiveKeysConstant.LIVE_HOME_PAGE_LIST, JSON.toJSONString(live));
                             startLiveList.add(live);
                             live.setStatus(2);
                             liveList.add(live);