zengzy / hhrcs_service · Files

using Rcs.Domain.Enums;

namespace Rcs.Application.Services.PathFind.Models;

/// <summary>
/// 网络动作执行上下文（用于Redis缓存）
/// @author zzy
/// </summary>
public class NetActionExecutionContext
{
    /// <summary>
    /// 上下文ID（唯一标识）
    /// </summary>
    public string ContextId { get; set; } = string.Empty;

    /// <summary>
    /// 机器人ID
    /// </summary>
    public Guid RobotId { get; set; }

    /// <summary>
    /// 任务ID
    /// </summary>
    public Guid TaskId { get; set; }

    /// <summary>
    /// 子任务ID
    /// </summary>
    public Guid SubTaskId { get; set; }

    /// <summary>
    /// 当前路口段索引
    /// </summary>
    public int JunctionIndex { get; set; }

    /// <summary>
    /// 当前资源段索引
    /// </summary>
    public int ResourceIndex { get; set; }

    /// <summary>
    /// 网络动作ID
    /// </summary>
    public Guid NetActionId { get; set; }

    /// <summary>
    /// 动作在节点中的位置（Start=起点, End=终点）
    /// </summary>
    public NetActionPosition ActionPosition { get; set; }

    /// <summary>
    /// 执行状态
    /// </summary>
    public NetActionExecutionStatus ExecutionStatus { get; set; }

    /// <summary>
    /// 响应等待类型
    /// </summary>
    public ResponseWaitType ResponseWaitType { get; set; }

    /// <summary>
    /// 创建时间
    /// </summary>
    public DateTime CreatedAt { get; set; }

    /// <summary>
    /// 执行时间
    /// </summary>
    public DateTime? ExecutedAt { get; set; }

    /// <summary>
    /// 完成时间
    /// </summary>
    public DateTime? CompletedAt { get; set; }

    /// <summary>
    /// 执行结果消息
    /// </summary>
    public string? ResultMessage { get; set; }

    /// <summary>
    /// 是否成功
    /// </summary>
    public bool? IsSuccess { get; set; }

    /// <summary>
    /// 异步回调令牌（用于异步响应验证）
    /// </summary>
    public string? AsyncCallbackToken { get; set; }

    /// <summary>
    /// 过期时间（用于自动清理）
    /// </summary>
    public TimeSpan Expiry { get; set; } = TimeSpan.FromMinutes(30);

    /// <summary>
    /// 异步回调超时时间（秒），超过此时间未收到回调则视为超时
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public int AsyncTimeoutSeconds { get; set; } = 300;

    /// <summary>
    /// 重试次数
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public int RetryCount { get; set; } = 0;

    /// <summary>
    /// 最大重试次数（来自网络动作配置的RepeatCount，-1表示无限重试）
    /// @author zzy
    /// 2026-02-07 更新：使用网络动作配置
    /// </summary>
    public int MaxRetryCount { get; set; } = 3;

    /// <summary>
    /// 重试间隔时间（毫秒，来自网络动作配置的IntervalTimeMs）
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public int RetryIntervalMs { get; set; } = 5000;

    /// <summary>
    /// 上次重试时间
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public DateTime? LastRetryAt { get; set; }

    /// <summary>
    /// 检查是否已超时
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public bool IsTimeout => ExecutionStatus == NetActionExecutionStatus.WaitingAsyncResponse
        && ExecutedAt.HasValue
        && DateTime.UtcNow > ExecutedAt.Value.AddSeconds(AsyncTimeoutSeconds);

    /// <summary>
    /// 检查是否可以重试（考虑重试间隔）
    /// @author zzy
    /// 2026-02-07 新增
    /// </summary>
    public bool CanRetry
    {
        get
        {
            // 检查是否达到最大重试次数（-1表示无限重试）
            if (MaxRetryCount != -1 && RetryCount >= MaxRetryCount)
            {
                return false;
            }

            // 检查重试间隔
            if (LastRetryAt.HasValue)
            {
                var nextRetryTime = LastRetryAt.Value.AddMilliseconds(RetryIntervalMs);
                if (DateTime.UtcNow < nextRetryTime)
                {
                    return false;
                }
            }

            return true;
        }
    }
}

/// <summary>
/// 网络动作在节点中的位置
/// @author zzy
/// </summary>
public enum NetActionPosition
{
    /// <summary>
    /// 起始节点动作
    /// </summary>
    Start = 1,

    /// <summary>
    /// 终止节点动作
    /// </summary>
    End = 2
}

/// <summary>
/// 网络动作执行状态
/// @author zzy
/// </summary>
public enum NetActionExecutionStatus
{
    /// <summary>
    /// 待执行
    /// </summary>
    Pending = 0,

    /// <summary>
    /// 执行中
    /// </summary>
    Executing = 1,

    /// <summary>
    /// 等待异步响应
    /// </summary>
    WaitingAsyncResponse = 2,

    /// <summary>
    /// 执行成功
    /// </summary>
    Success = 3,

    /// <summary>
    /// 执行失败
    /// </summary>
    Failed = 4,

    /// <summary>
    /// 已取消
    /// </summary>
    Cancelled = 5
}

/// <summary>
/// 网络动作执行请求
/// @author zzy
/// </summary>
public class NetActionExecuteRequest
{
    /// <summary>
    /// 网络动作ID
    /// </summary>
    public Guid NetActionId { get; set; }

    /// <summary>
    /// 上下文ID
    /// </summary>
    public string ContextId { get; set; } = string.Empty;

    /// <summary>
    /// 机器人ID
    /// </summary>
    public Guid RobotId { get; set; }

    /// <summary>
    /// 机器人编码
    /// </summary>
    public string RobotCode { get; set; } = string.Empty;

    /// <summary>
    /// 任务ID
    /// </summary>
    public Guid TaskId { get; set; }

    /// <summary>
    /// 任务编码
    /// </summary>
    public string TaskCode { get; set; } = string.Empty;

    /// <summary>
    /// 子任务ID
    /// </summary>
    public Guid SubTaskId { get; set; }

    /// <summary>
    /// 当前节点编码
    /// </summary>
    public string NodeCode { get; set; } = string.Empty;

    /// <summary>
    /// 当前节点ID
    /// </summary>
    public Guid NodeId { get; set; }
}

/// <summary>
/// 网络动作执行结果
/// @author zzy
/// </summary>
public class NetActionExecuteResult
{
    /// <summary>
    /// 是否成功
    /// </summary>
    public bool Success { get; set; }

    /// <summary>
    /// 消息
    /// </summary>
    public string Message { get; set; } = string.Empty;

    /// <summary>
    /// 是否需要等待异步响应
    /// </summary>
    public bool IsAsyncWaiting { get; set; }

    /// <summary>
    /// 上下文ID（用于异步回调关联）
    /// </summary>
    public string ContextId { get; set; } = string.Empty;
}

/// <summary>
/// 异步回调请求模型（固定格式，供第三方系统回调使用）
/// @author zzy
/// </summary>
public class NetActionCallbackRequest
{
    /// <summary>
    /// 上下文ID（由RCS生成，第三方系统原样返回）
    /// </summary>
    public string ContextId { get; set; } = string.Empty;

    /// <summary>
    /// 回调令牌（用于验证回调合法性）
    /// </summary>
    public string CallbackToken { get; set; } = string.Empty;

    /// <summary>
    /// 执行结果（true=成功, false=失败）
    /// </summary>
    public bool Success { get; set; }

    /// <summary>
    /// 结果消息
    /// </summary>
    public string? Message { get; set; }

    /// <summary>
    /// 业务数据（可选，由第三方系统返回的业务相关数据）
    /// </summary>
    public Dictionary<string, object>? BusinessData { get; set; }

    /// <summary>
    /// 时间戳（ISO 8601格式）
    /// </summary>
    public string Timestamp { get; set; } = DateTime.UtcNow.ToString("O");
}

/// <summary>
/// 异步回调响应模型
/// @author zzy
/// </summary>
public class NetActionCallbackResponse
{
    /// <summary>
    /// 是否成功接收回调
    /// </summary>
    public bool Success { get; set; }

    /// <summary>
    /// 响应消息
    /// </summary>
    public string Message { get; set; } = string.Empty;

    /// <summary>
    /// 处理后的动作（如：Continue=继续下发下一段, Retry=重试当前动作, Abort=中止任务）
    /// </summary>
    public string Action { get; set; } = "Continue";
}

/// <summary>
/// 路径段网络动作检查请求
/// @author zzy
/// </summary>
public class SegmentNetActionCheckRequest
{
    /// <summary>
    /// 机器人ID
    /// </summary>
    public Guid RobotId { get; set; }

    /// <summary>
    /// 任务ID
    /// </summary>
    public Guid TaskId { get; set; }

    /// <summary>
    /// 子任务ID
    /// </summary>
    public Guid SubTaskId { get; set; }

    /// <summary>
    /// 当前路口段索引
    /// </summary>
    public int JunctionIndex { get; set; }

    /// <summary>
    /// 当前资源段索引
    /// </summary>
    public int ResourceIndex { get; set; }

    /// <summary>
    /// 路径段
    /// </summary>
    public List<PathSegmentWithCode> Segments { get; set; } = new();
}

/// <summary>
/// 路径段网络动作检查结果
/// @author zzy
/// </summary>
public class SegmentNetActionCheckResult
{
    /// <summary>
    /// 是否有网络动作需要执行
    /// </summary>
    public bool HasNetAction { get; set; }

    /// <summary>
    /// 上下文ID（如果有网络动作）
    /// </summary>
    public string ContextId { get; set; } = string.Empty;

    /// <summary>
    /// 是否可以继续发送下一段
    /// </summary>
    public bool CanContinue { get; set; }

    /// <summary>
    /// 需要等待异步响应
    /// </summary>
    public bool IsWaitingAsync { get; set; }

    /// <summary>
    /// 消息
    /// </summary>
    public string Message { get; set; } = string.Empty;
}