IDataSyncService.cs 2.27 KB
using System;
using System.Threading;
using System.Threading.Tasks;
using Rcs.Domain.Entities;

namespace Rcs.Application.Services
{
    /// <summary>
    /// 数据同步服务接口 - 负责将地图和机器人数据同步到Redis缓存
    /// @author zzy
    /// </summary>
    public interface IDataSyncService
    {
        /// <summary>
        /// 同步所有地图数据到Redis
        /// @author zzy
        /// </summary>
        Task SyncMapsAsync(CancellationToken cancellationToken = default);

        /// <summary>
        /// 同步单个地图数据到Redis(通过ID从数据库查询,适用于数据已持久化的场景)
        /// @author zzy
        /// </summary>
        /// <param name="mapId">地图ID</param>
        /// <param name="cancellationToken">取消令牌</param>
        Task SyncMapAsync(Guid mapId, CancellationToken cancellationToken = default);

        /// <summary>
        /// 直接将地图实体同步到Redis(适用于数据尚未持久化、需要用内存中实体热加载的场景)
        /// @author zzy
        /// </summary>
        /// <param name="map">地图实体(需包含完整关联数据:Nodes/Edges/Resources)</param>
        Task SyncMapAsync(Map map);

        /// <summary>
        /// 同步所有机器人数据到Redis
        /// @author zzy
        /// </summary>
        Task SyncRobotsAsync(CancellationToken cancellationToken = default);

        /// <summary>
        /// 同步单个机器人数据到Redis(通过ID从数据库查询,适用于数据已持久化的场景)
        /// @author zzy
        /// </summary>
        /// <param name="robotId">机器人ID</param>
        /// <param name="cancellationToken">取消令牌</param>
        Task SyncRobotAsync(Guid robotId, CancellationToken cancellationToken = default);

        /// <summary>
        /// 直接将机器人实体同步到Redis(适用于数据尚未持久化、需要用内存中实体热加载的场景)
        /// @author zzy
        /// </summary>
        /// <param name="robot">机器人实体</param>
        Task SyncRobotAsync(Robot robot);

        /// <summary>
        /// 同步所有数据到Redis
        /// @author zzy
        /// </summary>
        Task SyncAllAsync(CancellationToken cancellationToken = default);
    }
}