|
|
@@ -0,0 +1,162 @@
|
|
|
+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 编码并拼接为查询字符串（以 '?' 或 '&' 作为分隔）。
|
|
|
+ /// </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;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
