Sunji-posv-net/pos/JwKdsV.Core/Utils/HttpClientUtils.cs

using JwKdsV.Core.HttpApi;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Management;
using System.Net;
using System.Net.Http;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace JwKdsV.Core.Utils
{
    public class HttpClientUtils
    {
        private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();

        private static object _lock = new object();

        private static Dictionary<ApiType, HttpClient> _clients = new Dictionary<ApiType, HttpClient>();

        private static HttpClient GetHttpClient(OpenApi api)
        {
            HttpClient httpClient = null;
            lock (_lock)
            {
                if (!_clients.ContainsKey(api.ApiType))
                {
                    var handler = new HttpClientHandler();
                    if (handler.SupportsAutomaticDecompression)
                    {
                        handler.AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate;
                    }

                    handler.Proxy = null;
                    handler.UseProxy = false;
                    handler.UseDefaultCredentials = false;

                    OpenApi apis = OpenApiUtils.Instance.NextApi(ApiType.Business);

                    Interlocked.CompareExchange(ref httpClient, new HttpClient(handler) { BaseAddress = new Uri(apis.Url) }, null);

                    httpClient.DefaultRequestHeaders.Connection.Add("Keep-Alive");
                    httpClient.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/51.0.2704.106 Safari/537.36");
                    httpClient.DefaultRequestHeaders.Add("Accept", "*/*");
                    httpClient.DefaultRequestHeaders.Add("Accept-Encoding", "gzip, deflate"); //声明给服务器，客户端支持gzip解压
                    httpClient.DefaultRequestHeaders.Add("Accept-Language", "zh-cn,en-us;q=0.7,en;q=0.3");
                    httpClient.DefaultRequestHeaders.Add("Pragma", "no-cache");
                    httpClient.DefaultRequestHeaders.Add("Cache-Control", "no-cache");

                    httpClient.Timeout = TimeSpan.FromMilliseconds(10000);

                    _clients[api.ApiType] = httpClient;
                }
                else
                {
                    httpClient = _clients[api.ApiType];
                }
            }
            return httpClient;
        }

        /// <summary>
        /// 指示开放平台是否可用
        /// </summary>
        /// <returns></returns>
        public static bool IsAvailable(ApiType apiType)
        {
            try
            {
                Stopwatch watch = Stopwatch.StartNew();

                bool isConnected = NetworkAvailable();
                //如果网络可用，检测开放平台
                if (isConnected)
                {
                    isConnected = OpenAvailable(apiType);
                }

                logger.Info("网络检测耗时<{0}>毫秒,结果<{1}>", watch.ElapsedMilliseconds, isConnected);

                return isConnected;
            }
            catch (Exception ex)
            {
                logger.Error(ex, "无法连接" + apiType + "开放平台");
                return false;
            }

        }

        public static bool NetworkAvailable()
        {
            //是否有可用网卡
            var networkLinkTask = Task.Factory.StartNew<bool>(() => { return NetworkUtils.IsNetworkLink(); });
            //是否连接互联网
            var connectedTask = Task.Factory.StartNew<bool>(() => { return NetworkUtils.IsConnectedToInternet(); });
            //判断是否有可用的网络
            Task.WaitAll(networkLinkTask, connectedTask);
            //网络可用:a)网卡工作;b)可以联网
            bool isConnected = networkLinkTask.Result && connectedTask.Result;
            return isConnected;
        }

        /// <summary>
        /// 开放平台sayhello
        /// </summary>
        /// <returns></returns>
        public static bool OpenAvailable(ApiType apiType)
        {
            OpenApi apis = OpenApiUtils.Instance.NextApi(apiType);
            var httpClient = GetHttpClient(apis);
            SortedList<string, string> parameters = OpenApiUtils.Instance.NewParameters(apis);
            parameters.Add("method", "common.sayhello");
            parameters.Add("sign", OpenApiUtils.Instance.Sign(apis, parameters));

            var task = httpClient.PostAsync(apis.Url, new FormUrlEncodedContent(parameters));

            task.Result.EnsureSuccessStatusCode();
            return task.Result.IsSuccessStatusCode;

        }

        public static string PostAsync(OpenApi api, string url, SortedList<string, string> parameters)
        {
            Stopwatch watch = Stopwatch.StartNew();
            try
            {
                var httpClient = GetHttpClient(api);

                var task = httpClient.PostAsync(url, new FormUrlEncodedContent(parameters));
                HttpResponseMessage response = task.Result.EnsureSuccessStatusCode();
                var result = response.Content.ReadAsStringAsync();
                return result.Result;
            }
            catch (Exception ex)
            {
                string message = "调用PostAsync方法发生错误";
                if (parameters != null && parameters.ContainsKey("method"))
                {
                    message = "调用<" + parameters["method"] + ">发生错误";
                }
                logger.Error(ex, message);

                throw new Exception(message);
            }
            finally
            {
                string methodName = "NoDefined";
                if (parameters != null && parameters.ContainsKey("method"))
                {
                    methodName = parameters["method"];
                }
                logger.Info("调用<{0}>方法,耗时<{1}>毫秒", methodName, watch.ElapsedMilliseconds);
            }
        }

        public static void PosMonitor()
        {

            try
            {
                if (Global.Instance.Online && Global.Instance.StoreInfo != null)
                {

                    Stopwatch watch = Stopwatch.StartNew();

                    OpenApi api = OpenApiUtils.Instance.NextApi(ApiType.Business);
                    SortedList<string, string> parameters = OpenApiUtils.Instance.NewParameters(api);

                    parameters.Add("method", "pos.monitor");

                    parameters.Add("storeId", Global.Instance.StoreInfo.StoreId);
                    parameters.Add("posNo", Global.Instance.StoreInfo.PosNo);

                    string osVersionName = GetOsVersion(Environment.OSVersion.Version);
                    string servicePack = Environment.OSVersion.ServicePack;
                    osVersionName = osVersionName + " " + servicePack;
                    parameters.Add("os", osVersionName);

                    bool is64Os = Environment.Is64BitOperatingSystem;
                    parameters.Add("osType", is64Os ? "64" : "32");
                    parameters.Add("softwareVersion", Application.ProductVersion.ToString());
                    parameters.Add("memoryTotalSize", GetPhisicalMemory().ToString());
                    parameters.Add("memoryFreeSize", GetFreePhysicalMemory().ToString());

                    string baseDir = AppDomain.CurrentDomain.BaseDirectory;
                    string diskName = baseDir.Substring(0, 1).ToUpper();//取首字母并转为大写

                    parameters.Add("diskName", diskName + ":");
                    parameters.Add("diskTotalSize", GetHardDiskSpace(diskName).ToString());
                    parameters.Add("diskFreeSize", GetHardDiskFreeSpace(diskName).ToString());
                    parameters.Add("cpuSize", Environment.ProcessorCount.ToString());

                    var ignoreParameters = new List<string>();
                    ignoreParameters.Add("os");
                    ignoreParameters.Add("osType");
                    ignoreParameters.Add("softwareVersion");
                    ignoreParameters.Add("memoryTotalSize");
                    ignoreParameters.Add("memoryFreeSize");
                    ignoreParameters.Add("diskName");
                    ignoreParameters.Add("diskTotalSize");
                    ignoreParameters.Add("diskFreeSize");
                    ignoreParameters.Add("cpuSize");

                    parameters.Add("sign", OpenApiUtils.Instance.Sign(api, parameters, ignoreParameters));


                    var response = PostAsync(api, api.Url, parameters);
                    if (Constant.IsSuccessful(response))
                    {

                    }
                    else
                    {

                    }

                    logger.Info("<pos.monitor>方法调用耗时<{0}>毫秒", watch.ElapsedMilliseconds);

                }


            }
            catch (Exception ex)
            {
                logger.Error(ex, "POS监控异常");
            }
        }

        /// <summary>
        /// 获取指定驱动器的空间总大小(单位为M) 
        /// </summary>
        /// <param name="diskName"></param>
        /// <returns></returns>
        public static long GetHardDiskSpace(string diskName)
        {
            long totalSize = new long();
            diskName = diskName + ":\\";
            System.IO.DriveInfo[] drives = System.IO.DriveInfo.GetDrives();
            foreach (System.IO.DriveInfo drive in drives)
            {
                if (drive.Name == diskName)
                {
                    totalSize = drive.TotalSize / (1024 * 1024);
                }
            }
            return totalSize;
        }

        /// <summary>
        /// 获取指定驱动器的剩余空间总大小(单位为M) 
        /// </summary>
        /// <param name="diskName"></param>
        /// <returns></returns>
        public static long GetHardDiskFreeSpace(string diskName)
        {
            long freeSpace = new long();
            diskName = diskName + ":\\";
            System.IO.DriveInfo[] drives = System.IO.DriveInfo.GetDrives();
            foreach (System.IO.DriveInfo drive in drives)
            {
                if (drive.Name == diskName)
                {
                    freeSpace = drive.TotalFreeSpace / (1024 * 1024);
                }
            }
            return freeSpace;
        }

        /// <summary>
        /// 获取空闲内存(单位为M) 
        /// </summary>
        /// <returns></returns>
        public static int GetFreePhysicalMemory()
        {
            long availablebytes = 0;
            try
            {


                ManagementClass mos = new ManagementClass("Win32_OperatingSystem");
                foreach (ManagementObject mo in mos.GetInstances())
                {
                    if (mo["FreePhysicalMemory"] != null)
                    {
                        availablebytes = long.Parse(mo["FreePhysicalMemory"].ToString());
                    }
                }
            }
            catch
            {
                availablebytes = 0;
            }



            return (int)(availablebytes / 1024);
        }

        /// <summary>
        /// 获取系统内存大小(单位M)
        /// </summary>
        /// <returns>内存大小</returns>
        private static int GetPhisicalMemory()
        {
            ManagementObjectSearcher searcher = new ManagementObjectSearcher();   //用于查询一些如系统信息的管理对象 
            searcher.Query = new SelectQuery("Win32_PhysicalMemory ", "", new string[] { "Capacity" });//设置查询条件 
            ManagementObjectCollection collection = searcher.Get();   //获取内存容量 
            ManagementObjectCollection.ManagementObjectEnumerator em = collection.GetEnumerator();

            long capacity = 0;
            while (em.MoveNext())
            {
                ManagementBaseObject baseObj = em.Current;
                if (baseObj.Properties["Capacity"].Value != null)
                {
                    try
                    {
                        capacity += long.Parse(baseObj.Properties["Capacity"].Value.ToString());
                    }
                    catch
                    {
                        return 0;
                    }
                }
            }
            return (int)(capacity / 1024 / 1024);
        }

        private static string GetOsVersion(Version ver)
        {
            string strClient = "";
            if (ver.Major == 5 && ver.Minor == 0)
            {
                strClient = "Win2000";
            }
            else if (ver.Major == 5 && ver.Minor == 1)
            {
                strClient = "WinXP";
            }
            else if (ver.Major == 6 && ver.Minor == 0)
            {
                strClient = "WinVista";
            }
            else if (ver.Major == 6 && ver.Minor == 1)
            {
                strClient = "Win7";
            }
            else if (ver.Major == 6 && ver.Minor == 2)
            {
                strClient = "Win8+";
            }
            else if (ver.Major == 10 && ver.Minor == 0)
            {
                strClient = "Win10";
            }
            else
            {
                strClient = "未知";
            }
            return strClient;
        }

        /// <summary>
        /// 操作系统类型
        /// </summary>
        /// <returns></returns> 
        public static string GetSystemType()
        {
            string st = "";
            ManagementClass mc = new ManagementClass("Win32_ComputerSystem");
            ManagementObjectCollection moc = mc.GetInstances();
            foreach (ManagementObject mo in moc)
            {
                st = mo["SystemType"].ToString();
            }
            return st;
        }
    }
}