HHECS.DAQClient/Services/HttpService.cs

using HHECS.BllModel;
using HHECS.DAQClient.Dto;
using HHECS.DAQClient.Model;
using System.Configuration;
using System.Net.Http;
using System.Text;
using System.Text.Json;
namespace HHECS.DAQClient.Services
{
    internal class HttpService
    {
        private readonly HttpClient _httpClient;
        private readonly JsonSerializerOptions jsonSerializeOptions = new JsonSerializerOptions
        {
            PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
            PropertyNameCaseInsensitive = true
        };
        private readonly JsonSerializerOptions jsonDeserializeOptions = new JsonSerializerOptions
        {
            PropertyNameCaseInsensitive = true
        };
        public HttpService(HttpClient httpClient)
        {
            //HttpClientHandler clientHandler = new HttpClientHandler();
            //clientHandler.ServerCertificateCustomValidationCallback += (sender, cert, chain, sslPolicyErrors) => { return true; };
            //clientHandler.SslProtocols = SslProtocols.None;
            //httpClient = new HttpClient(clientHandler);
            _ = bool.TryParse(ConfigurationManager.AppSettings["IsProductionEnvironment"], out var isProductionEnvironment);
            if (isProductionEnvironment)
            {
                httpClient.BaseAddress = new Uri(ConfigurationManager.AppSettings["ProductionAPI"]!);
            }
            else
            {
                httpClient.BaseAddress = new Uri(ConfigurationManager.AppSettings["TestAPI"]!);
            }
            httpClient.DefaultRequestHeaders.Add("Accept", "application/json");
            httpClient.DefaultRequestHeaders.Add("User-Agent", "HHECS.DAQClient");
            _httpClient = httpClient;
        }
        /// <summary>
        /// 推送设备实时数据
        /// </summary>
        /// <param name="equipmentDataQueues"></param>
        public BllResult SendEquipmentData(IEnumerable<EquipmentDataQueue> equipmentDataQueues)
        {
            try
            {
                var data = equipmentDataQueues.Select(x => new EquipmentDataDto
                {
                    Plmeid = x.Id == Guid.Empty ? Guid.NewGuid() : x.Id,
                    EquipmentSN = x.EquipmentCode,
                    Reported = JsonSerializer.Deserialize<List<TagItem>>(x.Reported),
                    Version = x.Version,
                    Timestamp = x.SourceTimestamp,
                }).ToList();
                var json = JsonSerializer.Serialize(data, jsonSerializeOptions);
                var stringContent = new StringContent(json, Encoding.UTF8, "application/json");
                var result = _httpClient.PostAsync("Equipment/SendEquipmentData", stringContent).Result;
                var resultContent = result.Content.ReadAsStringAsync().Result;
                if (result.IsSuccessStatusCode)
                {
                    return JsonSerializer.Deserialize<BllResult>(resultContent, jsonDeserializeOptions);
                }
                else
                {
                    if (string.IsNullOrEmpty(resultContent))
                    {
                        resultContent = result.ReasonPhrase;
                    }
                    return BllResultFactory.Error($"推送失败：{resultContent}");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(ex.Message);
            }
        }
        /// <summary>
        /// 推送某一时间段的数据
        /// </summary>
        /// <param name="equipmentDataQueues"></param>
        /// <returns></returns>
        public BllResult SendEquipmentDataV2(IEnumerable<EquipmentDataQueue> equipmentDataQueues)
        {
            try
            {
                var data = equipmentDataQueues.Select(x => new EquipmentDataV2Dto
                {
                    Plmeid = x.Id,
                    EquipmentSN = x.EquipmentCode,
                    Reported = JsonSerializer.Deserialize<List<TagItem>>(x.Reported),
                    Version = x.Version,
                    TimestampStart = x.SourceTimestamp,
                    TimestampEnd = (long)(x.SourceTimestamp + (x.Updated.Value - x.Created.Value).TotalMilliseconds),
                });
                var json = JsonSerializer.Serialize(data, jsonSerializeOptions);
                var stringContent = new StringContent(json, Encoding.UTF8, "application/json");
                var result = _httpClient.PostAsync("Equipment/SendEquipmentDataV2", stringContent).Result;
                var resultContent = result.Content.ReadAsStringAsync().Result;
                if (result.IsSuccessStatusCode)
                {
                    return JsonSerializer.Deserialize<BllResult>(resultContent, jsonDeserializeOptions);
                }
                else
                {
                    if (string.IsNullOrEmpty(resultContent))
                    {
                        resultContent = result.ReasonPhrase;
                    }
                    return BllResultFactory.Error($"推送失败：{resultContent}");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(ex.Message);
            }
        }
        public BllResult UpdateClientStatus(Guid clientId)
        {
            try
            {
                var data = new
                {
                    ClientId = clientId,
                };
                var json = JsonSerializer.Serialize(data, jsonSerializeOptions);
                var stringContent = new StringContent(json, Encoding.UTF8, "application/json");
                var result = _httpClient.PostAsync("Equipment/UpdateClientStatus", stringContent).Result;
                var resultContent = result.Content.ReadAsStringAsync().Result;
                if (result.IsSuccessStatusCode)
                {
                    return JsonSerializer.Deserialize<BllResult>(resultContent, jsonDeserializeOptions);
                }
                else
                {
                    if (string.IsNullOrEmpty(resultContent))
                    {
                        resultContent = result.ReasonPhrase;
                    }
                    return BllResultFactory.Error($"推送失败：{resultContent}");
                }
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(ex.Message);
            }
        }
    }
}