diff --git a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java
index 266e455f..173e354c 100644
--- a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java
+++ b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java
@@ -213,6 +213,9 @@ public class UserHeartbeatListener implements MessageListener {
       log.warn("没有找到房间ID: {}", event.getSessionId());
       return;
     }
+    if (Objects.nonNull(event.getSysOrigin())) {
+      roomProfile.setSysOrigin(event.getSysOrigin().name());
+    }
 
     UserProfileDTO actualUserProfile = ensureUserProfile(userProfile);
     AgoraChannelStateDTO channelState = agoraRoomStateService.getChannelState(roomId);
diff --git a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/client/TaskCenterGoClient.java b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/client/TaskCenterGoClient.java
index 909f0d8f..d48eb505 100644
--- a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/client/TaskCenterGoClient.java
+++ b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/client/TaskCenterGoClient.java
@@ -109,9 +109,21 @@ public class TaskCenterGoClient {
       }
 
       int status = connection.getResponseCode();
+      String responseBody = readResponse(connection);
       if (status < 200 || status >= 300) {
         log.warn("Task center go report failed. status={}, body={}, eventId={}",
-            status, readResponse(connection), request.getEventId());
+            status, responseBody, request.getEventId());
+        return;
+      }
+      TaskCenterEventResult result = parseEventResult(responseBody);
+      if (Objects.nonNull(result) && !Boolean.TRUE.equals(result.getProcessed())) {
+        log.warn("Task center go report ignored. eventId={}, eventType={}, userId={}, updated={}, reason={}, body={}",
+            request.getEventId(),
+            request.getEventType(),
+            request.getUserId(),
+            result.getUpdated(),
+            result.getReason(),
+            responseBody);
       }
     } catch (Exception e) {
       log.warn("Task center go report error. eventId={}", request.getEventId(), e);
@@ -135,6 +147,18 @@ public class TaskCenterGoClient {
     }
   }
 
+  private TaskCenterEventResult parseEventResult(String responseBody) {
+    try {
+      TaskCenterResponse response = JSON.parseObject(responseBody, TaskCenterResponse.class);
+      if (Objects.isNull(response)) {
+        return null;
+      }
+      return Objects.nonNull(response.getBody()) ? response.getBody() : response.getData();
+    } catch (Exception e) {
+      return null;
+    }
+  }
+
   private String trimRightSlash(String value) {
     while (value.endsWith("/")) {
       value = value.substring(0, value.length() - 1);
@@ -153,4 +177,17 @@ public class TaskCenterGoClient {
     private String occurredAt;
     private Map<String, Object> payload;
   }
+
+  @Data
+  private static class TaskCenterResponse {
+    private TaskCenterEventResult body;
+    private TaskCenterEventResult data;
+  }
+
+  @Data
+  private static class TaskCenterEventResult {
+    private Boolean processed;
+    private Integer updated;
+    private String reason;
+  }
 }
diff --git a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/LiveMicCacheService.java b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/LiveMicCacheService.java
index f4e836d3..57a5c002 100644
--- a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/LiveMicCacheService.java
+++ b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/LiveMicCacheService.java
@@ -82,11 +82,16 @@ public interface LiveMicCacheService {
    */
   List<LiveMicrophone> listLiveMicrophone(Long roomId, Long userId);
 
-  /**
-   * 刷新移除不活跃用户.
-   *
-   * @return true 有刷新掉用户
-   */
-  boolean refreshNotActiveUser(Long roomId);
-
-}
+  /**
+   * 刷新移除不活跃用户.
+   *
+   * @return true 有刷新掉用户
+   */
+  boolean refreshNotActiveUser(Long roomId);
+
+  /**
+   * 刷新移除不活跃用户, 返回被移除的麦位.
+   */
+  List<LiveMicrophone> refreshNotActiveUserAndReturn(Long roomId);
+
+}
diff --git a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/impl/LiveMicCacheServiceImpl.java b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/impl/LiveMicCacheServiceImpl.java
index f838e727..2b0dad6e 100644
--- a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/impl/LiveMicCacheServiceImpl.java
+++ b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/database/cache/service/impl/LiveMicCacheServiceImpl.java
@@ -58,16 +58,15 @@ public class LiveMicCacheServiceImpl implements LiveMicCacheService {
     return !redisService.hashHasKey(LiveMicKey.SEAT.getKey(roomId), Objects.toString(index));
   }
 
-  @Override
-  public void goUp(Long roomId, Integer index, LiveMicrophone microphone) {
-//    if (Objects.isNull(microphone.getRefreshTime())) {
-//      microphone.updateLastActivityTime();
-//    }
-    microphone.updateLastActivityTime();
-    log.info("用户上麦 index = {} microphone = {} ", index, JSON.toJSONString(microphone));
-    redisService.hashPut(LiveMicKey.SEAT.getKey(roomId),
-        Objects.toString(index),
-        microphone);
+  @Override
+  public void goUp(Long roomId, Integer index, LiveMicrophone microphone) {
+    if (Objects.isNull(microphone.getRefreshTime())) {
+      microphone.updateLastActivityTime();
+    }
+    log.info("用户上麦 index = {} microphone = {} ", index, JSON.toJSONString(microphone));
+    redisService.hashPut(LiveMicKey.SEAT.getKey(roomId),
+        Objects.toString(index),
+        microphone);
   }
 
   @Override
@@ -120,27 +119,40 @@ public class LiveMicCacheServiceImpl implements LiveMicCacheService {
         .toList();
   }
 
-  @Override
-  public boolean refreshNotActiveUser(Long roomId) {
-    setExpire(roomId);
-
-    List<LiveMicrophone> liveMicrophone = listLiveMicrophone(roomId);
-    if (CollectionUtils.isEmpty(liveMicrophone)) {
-      return false;
-    }
-
-    String[] index =
-        liveMicrophone.stream().filter(LiveMicrophone::checkInactiveExpire)
-            .map(LiveMicrophone::getMicIndex)
-            .map(Objects::toString)
-            .toArray(String[]::new);
-
-    log.info("清除不活跃的用户入参 = {} ", JSON.toJSONString(index));
-    Long size = redisService.hashDelete(LiveMicKey.SEAT.getKey(roomId), index);
-    log.info("清除不活跃的用户结果 = {} ", size);
-
-    return Objects.nonNull(size) && size > 0;
-  }
+  @Override
+  public boolean refreshNotActiveUser(Long roomId) {
+    return CollectionUtils.isNotEmpty(refreshNotActiveUserAndReturn(roomId));
+  }
+
+  @Override
+  public List<LiveMicrophone> refreshNotActiveUserAndReturn(Long roomId) {
+    setExpire(roomId);
+
+    List<LiveMicrophone> liveMicrophone = listLiveMicrophone(roomId);
+    if (CollectionUtils.isEmpty(liveMicrophone)) {
+      return CollectionUtils.newArrayList();
+    }
+
+    List<LiveMicrophone> inactiveMicrophones =
+        liveMicrophone.stream().filter(LiveMicrophone::checkInactiveExpire).toList();
+    String[] index =
+        inactiveMicrophones.stream()
+            .map(LiveMicrophone::getMicIndex)
+            .map(Objects::toString)
+            .toArray(String[]::new);
+    if (index.length == 0) {
+      return CollectionUtils.newArrayList();
+    }
+
+    log.info("清除不活跃的用户入参 = {} ", JSON.toJSONString(index));
+    Long size = redisService.hashDelete(LiveMicKey.SEAT.getKey(roomId), index);
+    log.info("清除不活跃的用户结果 = {} ", size);
+
+    if (Objects.isNull(size) || size <= 0) {
+      return CollectionUtils.newArrayList();
+    }
+    return inactiveMicrophones;
+  }
 
 
   private void setExpire(Long roomId) {
diff --git a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java
index 026d2b02..0cc95f14 100644
--- a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java
+++ b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java
@@ -181,7 +181,7 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
       ResponseAssert.notNull(UserErrorCode.USER_INFO_NOT_FOUND, liveMicrophone.getUser());
 
       if (liveMicCacheService.checkEqSelf(roomId, micIndex, userId)) {
-        liveMicCacheService.refreshNotActiveUser(roomId);
+        refreshNotActiveUserAndReport(roomProfile);
         return micUserChangeNotice(roomProfile);
       }
 
@@ -213,7 +213,7 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
       micUpdated = true;
 
       // 清理活跃用户
-      liveMicCacheService.refreshNotActiveUser(roomId);
+      refreshNotActiveUserAndReport(roomProfile);
 
       // 发送通知
       return micUserChangeNotice(roomProfile);
@@ -307,8 +307,8 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
     // 下麦克风
     liveMicCacheService.goDown(roomId, micIndex);
     // 清理活跃用户
-    liveMicCacheService.refreshNotActiveUser(roomId);
-    // 发送通知
+    refreshNotActiveUserAndReport(roomProfile);
+    // 发送通知
     micUserChangeNotice(roomProfile);
   }
 
@@ -379,9 +379,9 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
       liveMicCacheService.goDown(roomId, mickIndex);
       reportMicDuration(roomProfile, roomId, liveMicrophone, "MIC_LOCK");
       // 清理活跃用户
-      liveMicCacheService.refreshNotActiveUser(roomId);
-      // 发送通知
-      micUserChangeNotice(roomProfile, settingSeat);
+      refreshNotActiveUserAndReport(roomProfile);
+      // 发送通知
+      micUserChangeNotice(roomProfile, settingSeat);
     } finally {
       micOpsUnlock(roomId, mickIndex);
     }
@@ -760,12 +760,25 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
     });
   }
 
-  @Override
-  public void refreshNotActiveUser(RoomProfileDTO roomProfile) {
-    if (liveMicCacheService.refreshNotActiveUser(roomProfile.getId())) {
-      micUserChangeNotice(roomProfile);
-    }
-  }
+  @Override
+  public void refreshNotActiveUser(RoomProfileDTO roomProfile) {
+    if (refreshNotActiveUserAndReport(roomProfile)) {
+      micUserChangeNotice(roomProfile);
+    }
+  }
+
+  private boolean refreshNotActiveUserAndReport(RoomProfileDTO roomProfile) {
+    if (Objects.isNull(roomProfile) || Objects.isNull(roomProfile.getId())) {
+      return false;
+    }
+    List<LiveMicrophone> removedMicrophones =
+        liveMicCacheService.refreshNotActiveUserAndReturn(roomProfile.getId());
+    if (CollectionUtils.isEmpty(removedMicrophones)) {
+      return false;
+    }
+    reportMicDuration(roomProfile, roomProfile.getId(), removedMicrophones, "INACTIVE_CLEANUP");
+    return true;
+  }
 
   /**
    * 获取缓存房间roomAccount