Display_D_HP/TeamAAS-VM/Services/MesService.cs

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using TeamAAS_VP.Interfaces;
using TeamAAS_VP.Models;

namespace TeamAAS_VP.Services
{
    /// <summary>
    /// 基于 <see cref="HttpClient"/> 的 MES 通信服务实现。
    /// 该服务通过 <see cref="IConfigService"/> 获取设备配置中的 MES 接口地址，
    /// 提供对站点查询（StationGetAsync）和提交（SubmitGetAsync）的 GET 请求封装。
    /// </summary>
    public class MesService : IMesService
    {
        /// <summary>
        /// 用于执行 HTTP 请求的客户端实例。建议在服务生命周期内重用。
        /// </summary>
        private readonly HttpClient _httpClient;

        /// <summary>
        /// 配置服务，用于获取设备信息（包含 MES URL）。
        /// </summary>
        private readonly IConfigService _configService;

        /// <summary>
        /// 标记实例是否已释放，防止重复释放。
        /// </summary>
        private bool _disposed;

        /// <summary>
        /// 使用指定的配置服务创建 <see cref="MesService"/> 实例。
        /// </summary>
        /// <param name="configService">用于获取设备配置信息的实现，不能为空。</param>
        /// <exception cref="ArgumentNullException">当 <paramref name="configService"/> 为 null 时抛出。</exception>
        public MesService(IConfigService configService)
        {
            _configService = configService ?? throw new ArgumentNullException(nameof(configService));
            _httpClient = new HttpClient();
            _disposed = false;
        }

        /// <summary>
        /// 根据基地址和查询参数构建完整 URL。
        /// - 如果 <paramref name="baseUrl"/> 为空或空白，返回 null。
        /// - 如果 <paramref name="queryParameters"/> 为空或不包含元素，返回原始 <paramref name="baseUrl"/>。
        /// - 否则对键和值进行 URL 编码并拼接为查询字符串（以 '?' 或 '&amp;' 作为分隔）。
        /// </summary>
        /// <param name="baseUrl">基础 URL，例如 "http://example.com/api"。</param>
        /// <param name="queryParameters">要附加的查询参数字典，可为 null。</param>
        /// <returns>生成的完整 URL 字符串，或在无效 baseUrl 时返回 null。</returns>
        private static string BuildUrl(string baseUrl, IDictionary<string, string> queryParameters)
        {
            if (string.IsNullOrWhiteSpace(baseUrl)) return null;
            if (queryParameters == null || queryParameters.Count == 0) return baseUrl;
            var sb = new StringBuilder();
            sb.Append(baseUrl);
            if (!baseUrl.Contains("?")) sb.Append('?');
            else if (!baseUrl.EndsWith("?") && !baseUrl.EndsWith("&")) sb.Append('&');
            foreach (var kv in queryParameters)
            {
                sb.Append(Uri.EscapeDataString(kv.Key)).Append('=').Append(Uri.EscapeDataString(kv.Value ?? string.Empty)).Append('&');
            }
            if (sb.Length > 0 && sb[sb.Length - 1] == '&') sb.Length--;
            return sb.ToString();
        }

        /// <summary>
        /// 向配置中指定的 MES 站点 URL 发起 GET 请求（用于过站查询）。
        /// 返回一个元组，<c>IsSuccess</c> 表示 HTTP 状态码是否为成功，<c>Response</c> 包含响应文本或错误信息。
        /// </summary>
        /// <param name="queryParameters">可选的查询参数字典，将附加到 MES 站点 URL 上。</param>
        /// <param name="cancellationToken">用于取消请求的令牌。</param>
        /// <returns>
        /// 异步任务，结果为 (<c>IsSuccess</c>, <c>Response</c>)。
        /// - 当缺少配置或 URL 无效时返回 (false, 错误说明)。
        /// - 当请求被取消时返回 (false, "Canceled")。
        /// - 其他异常返回 (false, 异常消息)。
        /// </returns>
        public async Task<(bool IsSuccess, string Response)> StationGetAsync(IDictionary<string, string> queryParameters = null, CancellationToken cancellationToken = default)
        {
            var device = _configService.GetDeviceInfo();
            if (device == null || string.IsNullOrWhiteSpace(device.MesStationUrl))
                return (false, "Missing MES station URL");

            var url = BuildUrl(device.MesStationUrl, queryParameters);
            if (string.IsNullOrWhiteSpace(url)) return (false, "Invalid station URL");

            try
            {
                using (var rsp = await _httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false))
                {
                    var text = await rsp.Content.ReadAsStringAsync().ConfigureAwait(false);
                    return (rsp.IsSuccessStatusCode, text);
                }
            }
            catch (OperationCanceledException) when (cancellationToken.IsCancellationRequested)
            {
                return (false, "Canceled");
            }
            catch (Exception ex)
            {
                return (false, ex.Message);
            }
        }

        /// <summary>
        /// 向配置中指定的 MES 提交 URL 发起 GET 请求（用于提交数据/记录）。
        /// 返回一个元组，<c>IsSuccess</c> 表示 HTTP 状态码是否为成功，<c>Response</c> 包含响应文本或错误信息。
        /// </summary>
        /// <param name="queryParameters">可选的查询参数字典，将附加到 MES 提交 URL 上。</param>
        /// <param name="cancellationToken">用于取消请求的令牌。</param>
        /// <returns>
        /// 异步任务，结果为 (<c>IsSuccess</c>, <c>Response</c>)。
        /// - 当缺少配置或 URL 无效时返回 (false, 错误说明)。
        /// - 当请求被取消时返回 (false, "Canceled")。
        /// - 其他异常返回 (false, 异常消息)。
        /// </returns>
        public async Task<(bool IsSuccess, string Response)> SubmitGetAsync(IDictionary<string, string> queryParameters = null, CancellationToken cancellationToken = default)
        {
            var device = _configService.GetDeviceInfo();
            if (device == null || string.IsNullOrWhiteSpace(device.MesSubmitUrl))
                return (false, "Missing MES submit URL");

            var url = BuildUrl(device.MesSubmitUrl, queryParameters);
            if (string.IsNullOrWhiteSpace(url)) return (false, "Invalid submit URL");

            try
            {
                using (var rsp = await _httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false))
                {
                    var text = await rsp.Content.ReadAsStringAsync().ConfigureAwait(false);
                    return (rsp.IsSuccessStatusCode, text);
                }
            }
            catch (OperationCanceledException) when (cancellationToken.IsCancellationRequested)
            {
                return (false, "Canceled");
            }
            catch (Exception ex)
            {
                return (false, ex.Message);
            }
        }

        /// <summary>
        /// 释放服务占用的托管资源（当前仅 <see cref="_httpClient"/>）。
        /// 本方法为幂等操作，重复调用不会产生异常。
        /// </summary>
        public void Dispose()
        {
            if (!_disposed)
            {
                _httpClient.Dispose();
                _disposed = true;
            }
        }
    }
}