愛比的新手筆記

using MailProcess.Entity;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading;
using System.Web;

namespace MailProcess.Utility
{
    static class IQBotTool
    {
        private static List<Instance> instances;//實例清單
        private static string Server;//server url
        private static string InstancesPath;//Instance儲存位置
        private static int RetryGet;//重下載幾次
        private static int WaitTranning;//等待解析秒數
        /// <summary>
        /// 先初始化參數才能使用本Tool
        /// </summary>
        /// <param name="server">server url</param>
        /// <param name="instancePath">Instance儲存位置</param>
        /// <param name="retryGet">重下載幾次</param>
        /// <param name="tranningSec">等待解析秒數</param>
        public static void Init(string server, string instancePath, int retryGet, int tranningSec)
        {
            Server = server;
            InstancesPath = instancePath;
            RetryGet = retryGet;
            WaitTranning = tranningSec * 1000;
        }

        /// <summary>
        /// 產生IQ BOT的api元件
        /// </summary>
        /// <param name="Token">認證用(有時效性)</param>
        /// <returns></returns>
        private static HttpClient CreateClient(string Token = null)
        {
            HttpClient client = new HttpClient
            {
                BaseAddress = new Uri(Server)
            };
            if (Token != null)
                client.DefaultRequestHeaders.Add("x-authorization", Token);
            return client;
        }

        /// <summary>
        /// 取得Token
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="PW"></param>
        /// <returns></returns>
        public static string GetToken(string ID, string PW)
        {
            using (var client = CreateClient())
            {
                client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                var user = new
                {
                    username = ID,
                    password = PW
                };
                HttpResponseMessage response = client.PostAsJsonAsync("v1/authentication", user).Result;
                if (response.IsSuccessStatusCode)
                {
                    dynamic rslt = response.Content.ReadAsAsync<dynamic>().Result;
                    return rslt["token"];
                }
                throw new Exception(response.StatusCode.ToString());
            }
        }

        /// <summary>
        /// 取得已存儲在本機的實例ID
        /// </summary>
        /// <param name="InstanceName">實例名稱</param>
        /// <returns></returns>
        private static string GetInstanceID(string InstanceName)
        {
            string prjId = (from Instance data in GetInstancets()
                            where data.name == InstanceName
                            select data.id).First();
            return prjId;
        }

        /// <summary>
        /// 取得實例ID
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="PW"></param>
        /// <param name="InstanceName">實例名稱</param>
        /// <param name="GetNew">true:從Web重新下載</param>
        /// <returns></returns> 
        public static string GetInstanceID(string ID, string PW, string InstanceName, bool GetNew = false)
        {
            if (!GetNew && GetInstancets() != null)
                return GetInstanceID(InstanceName);
            return GetInstanceID(GetToken(ID, PW), InstanceName, GetNew);
        }

        /// <summary>
        /// 取得實例ID
        /// </summary>
        /// <param name="Token">認證用(有時效性)</param>
        /// <param name="InstanceName">實例名稱</param>
        /// <param name="GetNew">true:從Web重新下載</param>
        /// <returns></returns>
        public static string GetInstanceID(string Token, string InstanceName, bool GetNew = false)
        {
            GetInstances(Token, GetNew);
            return GetInstanceID(InstanceName);
        }

        /// <summary>
        /// 取得已存儲在本機的實例清單
        /// </summary>
        /// <returns></returns>
        private static List<Instance> GetInstancets()
        {
            //暫存檔沒有的話讀檔
            if (instances == null)
            {
                string json = File.ReadAllText(InstancesPath);
                instances = JsonConvert.DeserializeObject<List<Instance>>(json);
            }
            return instances;
        }

        /// <summary>
        /// 取得實例清單
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="PW"></param>
        /// <param name="GetNew">true:重新抓最新的清單</param>
        /// <returns></returns>
        public static List<Instance> GetInstances(string ID, string PW, bool GetNew = false)
        {
            if (!GetNew && GetInstancets() != null)
                return GetInstancets();
            return GetInstances(GetToken(ID, PW), GetNew);
        }

        /// <summary>
        /// 取得實例清單
        /// </summary>
        /// <param name="Token">認證用(有時效性)</param>
        /// <param name="GetNew">true:重新抓最新的清單</param>
        /// <returns></returns>
        public static List<Instance> GetInstances(string Token, bool GetNew = false)
        {
            if (instances == null && !File.Exists(InstancesPath))
                GetNew = true;
            //抓清單
            if (GetNew)
                using (var client = CreateClient(Token))
                {
                    instances = null;
                    HttpResponseMessage response = client.GetAsync("IQBot/api/reporting/projects").Result;
                    if (response.IsSuccessStatusCode)
                    {
                        Instances prj = response.Content.ReadAsAsync<Instances>().Result;
                        string json = JsonConvert.SerializeObject(prj.data);
                        File.WriteAllText(InstancesPath, json);
                    }
                    else
                        throw new Exception(response.StatusCode.ToString());
                }
            return GetInstancets();
        }

        /// <summary>
        /// 上傳解析文件, 並下載到指定位置
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="PW"></param>
        /// <param name="InstanceName">實例名稱</param>
        /// <param name="Upload">上傳完整路徑</param>
        /// <param name="Download">下載完整路徑</param>
        /// <returns>true:成功</returns>
        public static bool Training(string ID, string PW, string InstanceName, string Upload, string Download)
        {
            string token = GetToken(ID, PW);
            string prjId = (from Instance data in GetInstances(token)
                            where data.name == InstanceName
                            select data.id).First();
            return Training(token, prjId, Upload, Download, out string file);
        }

        /// <summary>
        /// 上傳解析文件, 並下載到指定位置
        /// </summary>
        /// <param name="Token">認證用(有時效性)</param>
        /// <param name="InstanceId">實例ID</param>
        /// <param name="Upload">上傳完整路徑</param>
        /// <param name="Download">下載完整路徑</param>
        /// <param name="FileId">下載ID</param>
        /// <returns>true:成功</returns>
        public static bool Training(string Token, string InstanceId, string Upload, string Download, out string FileId)
        {
            using (var client = CreateClient(Token))
            {
                using (var content = new MultipartFormDataContent())
                {
                    var fileStreamContent = new StreamContent(File.OpenRead(Upload));
                    string contentType = MimeMapping.GetMimeMapping(Path.GetFileName(Upload));
                    fileStreamContent.Headers.Add("Content-Type", contentType);
                    content.Add(fileStreamContent, "files", Path.GetFileName(Upload));
                    HttpResponseMessage response = client.PostAsync($"IQBot/gateway/organizations/1/projects/{InstanceId}/files/upload/1", content).Result;
                    if (response.IsSuccessStatusCode)
                    {
                        dynamic rslt = response.Content.ReadAsAsync<dynamic>().Result;
                        FileId = rslt["data"]["uploadedFiles"][0]["fileId"];
                        return GetTraining(Token, InstanceId, FileId, Download);
                    }
                    throw new Exception("上傳錯誤:" + response.StatusCode.ToString());
                }
            }
        }

        /// <summary>
        /// 下載解析結果
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="PW"></param>
        /// <param name="InstanceId">實例ID</param>
        /// <param name="FileId">下載的ID</param>
        /// <param name="Download">下載完整路徑</param>
        /// <returns>true:成功</returns>
        public static bool GetTraining(string ID, string PW, string InstanceId, string FileId, string Download)
        {
            return GetTraining(GetToken(ID, PW), InstanceId, FileId, Download);
        }

        /// <summary>
        /// 下載解析結果
        /// </summary>
        /// <param name="Token">認證用(有時效性)</param>
        /// <param name="InstanceId">實例ID</param>
        /// <param name="FileId">下載的ID</param>
        /// <param name="Download">下載完整路徑</param>
        /// <returns>true:成功;false:沒取到;失敗:丟exception</returns>
        public static bool GetTraining(string Token, string InstanceId, string FileId, string Download)
        {
            using (var client = CreateClient(Token))
            {
                string err = string.Empty;
                for (int i = RetryGet; i > 0; i--)
                {
                    Thread.Sleep(WaitTranning);
                    #region 抓狀態
                    HttpResponseMessage response = client.GetAsync($"IQBot/gateway/learning-instances/{InstanceId}/filestatus/fileid/{FileId}").Result;
                    if (response.IsSuccessStatusCode)
                    {
                        dynamic rslt = response.Content.ReadAsAsync<dynamic>().Result;
                        string success = rslt["success"];
                        if (success.ToLower() == "true")
                        {
                            string status = rslt["data"]["status"];
                            switch (status.ToUpper())
                            {
                                case "IN_VALIDATOR"://需登入control-room人工解析檔案
                                    return false;
                                case "INVALID":
                                    throw new FormatException($"無法解析檔案");
                                case "SUCCESS"://完成
                                    break;
                                default://處理中: YET_TO_BE_CLASSIFIED, CLASSIFIED
                                    continue;
                            }
                        }
                        else
                            throw new FormatException($"解析檔案失敗:{rslt["errors"]}");
                    }
                    else
                        throw new Exception($"抓取檔案狀態失敗:{response.StatusCode}");
                    #endregion

                    #region 抓檔案
                    response = client.GetAsync($"IQBot/api/backups/{FileId}/download").Result;
                    if (response.IsSuccessStatusCode)
                    {
                        string media = response.Content.Headers?.ContentType?.MediaType;
                        if (media != "text/plain" && !string.IsNullOrEmpty(media))
                            throw new FormatException($"下載檔案為{response.Content.Headers.ContentType.MediaType}檔");
                        string data = response.Content.ReadAsStringAsync().Result;
                        Directory.CreateDirectory(Path.GetDirectoryName(Download));
                        File.WriteAllText(Download, data, Encoding.GetEncoding(950));
                        return true;
                    }
                    #endregion
                }
                return false;
            }
        }
    }
}

using System.Collections.Generic;

namespace MailProcess.Entity
{
    class Instances
    {
        public List<Instance> data { get; set; }
    }
    class Instance
    {
        public string name { get; set; }
        public string id { get; set; }
    }
}

Taiwan is a country. 臺灣是我的國家