push

yd-communication-api/src/main/java/com/yd/communication/api/service/impl/ApiCoSessionServiceImpl.java

@@ -216,6 +216,15 @@ public class ApiCoSessionServiceImpl implements ApiCoSessionService {
         session.setUpdaterId(participantId);
         iCoSessionService.updateById(session);
 
+        //更新 Redis 缓存，更新控制权字段信息
+        RoomRedisInfoDTO roomRedisInfoDTO = redisUtil.getCacheObject(RedisEnum.ROOM.getPrefix() + session.getRoomId());
+        if (roomRedisInfoDTO != null) {
+            roomRedisInfoDTO.setControlHolderType(session.getControlHolderType());
+            roomRedisInfoDTO.setControlHolderId(session.getControlHolderId());
+            redisUtil.setCacheObject(RedisEnum.ROOM.getPrefix() + session.getRoomId(), roomRedisInfoDTO,
+                    RedisEnum.ROOM.getTimeout(), RedisEnum.ROOM.getTimeUnit());
+        }
+
         //添加操作日志，协同-操作日志表 TODO
         return session;
     }