using Newtonsoft.Json;
using WIDESEAWCS_Common;
using WIDESEAWCS_Core.Caches;
using WIDESEAWCS_QuartzJob;

namespace WIDESEAWCS_Tasks
{
    /// <summary>
    /// 机械手状态管理器 - 负责RobotSocketState的安全更新和克隆
    /// </summary>
    public class RobotStateManager
    {
        private readonly ICacheService _cache;

        public RobotStateManager(ICacheService cache)
        {
            _cache = cache;
        }

        /// <summary>
        /// 安全更新RobotSocketState缓存，防止并发覆盖
        /// </summary>
        /// <param name="ipAddress">设备IP地址</param>
        /// <param name="updateAction">更新状态的委托（传入当前状态，返回修改后的新状态）</param>
        /// <returns>是否更新成功</returns>
        public bool TryUpdateStateSafely(string ipAddress, Func<RobotSocketState, RobotSocketState> updateAction)
        {
            var cacheKey = GetCacheKey(ipAddress);
            var currentState = _cache.Get<RobotSocketState>(cacheKey);

            if (currentState == null)
            {
                return false;
            }

            // 使用当前存储的版本号作为期望版本
            var expectedVersion = currentState.Version;

            // 创建状态副本进行修改（避免修改原对象引用）
            var stateCopy = CloneState(currentState);
            var newState = updateAction(stateCopy);
            newState.Version = DateTime.UtcNow.Ticks;

            return _cache.TrySafeUpdate(
                cacheKey,
                newState,
                expectedVersion,
                s => s.Version
            );
        }

        /// <summary>
        /// 安全更新RobotSocketState缓存（简单版本）
        /// </summary>
        /// <param name="ipAddress">设备IP地址</param>
        /// <param name="newState">新状态（会被更新Version字段）</param>
        /// <returns>是否更新成功</returns>
        public bool TryUpdateStateSafely(string ipAddress, RobotSocketState newState)
        {
            var cacheKey = GetCacheKey(ipAddress);
            var currentState = _cache.Get<RobotSocketState>(cacheKey);

            if (currentState == null)
            {
                // 当前不存在，直接添加
                newState.Version = DateTime.UtcNow.Ticks;
                _cache.AddObject(cacheKey, newState);
                return true;
            }

            // 使用当前存储的版本号作为期望版本
            var expectedVersion = currentState.Version;

            // 更新新状态的版本号为最新时间戳
            newState.Version = DateTime.UtcNow.Ticks;

            return _cache.TrySafeUpdate(
                cacheKey,
                newState,
                expectedVersion,
                s => s.Version
            );
        }

        /// <summary>
        /// 克隆RobotSocketState对象（创建深拷贝）
        /// </summary>
        public RobotSocketState CloneState(RobotSocketState source)
        {
            // 使用序列化/反序列化进行深拷贝
            var json = JsonConvert.SerializeObject(source);
            return JsonConvert.DeserializeObject<RobotSocketState>(json) ?? new RobotSocketState { IPAddress = source.IPAddress };
        }

        /// <summary>
        /// 获取Redis缓存键
        /// </summary>
        public static string GetCacheKey(string ipAddress)
        {
            return $"{RedisPrefix.Code}:{RedisName.SocketDevices}:{ipAddress}";
        }

        /// <summary>
        /// 从缓存获取状态
        /// </summary>
        public RobotSocketState? GetState(string ipAddress)
        {
            return _cache.Get<RobotSocketState>(GetCacheKey(ipAddress));
        }

        /// <summary>
        /// 获取或创建状态
        /// </summary>
        public RobotSocketState GetOrCreateState(string ipAddress, RobotCraneDevice robotCrane)
        {
            return _cache.GetOrAdd(GetCacheKey(ipAddress), _ => new RobotSocketState
            {
                IPAddress = ipAddress,
                RobotCrane = robotCrane
            });
        }
    }
}