using System.Net;
using System.Text;
using Newtonsoft.Json.Linq;

namespace MES.Service.service.PLM;

#region 1.根据文档物理文件id获取文档流数据

public class WarehouseDownloadDoc
{
    private readonly string _cloudUrl = "http://122.227.249.70:5050/k3cloud";

    private readonly string
        _warehouse = "http://192.168.1.90/CloudPLMWarehouse";

    #region 文档服务器上下文

    private string WarehouseCTX
    {
        get
        {
            var json = "{\"ap1\":{ \"AcctID\":\"" + "6654201b47f099" +
                       "\",\"Username\":\"Administrator\",\"Password\":\"Lts88666*\",\"Lcid\":2052,\"AuthenticateType\":1,\"PasswordIsEncrypted\":\"false\",\"ClientInfo\":{\"ClientType\":8}}";
            var resp = GetResponse(
                "http://122.227.249.70:5050/k3cloud/Kingdee.BOS.ServiceFacade.ServicesStub.User.UserService.ValidateLoginInfo.common.kdsvc",
                json, new Dictionary<string, string>());
            var ret = new StreamReader(resp.GetResponseStream(), Encoding.UTF8)
                .ReadToEnd();
            var result = JObject.Parse(ret)["Context"];
            var token = result["UserToken"].ToString();
            var warehouseCtx =
                string.Format("LoginUrl={0}&KDServiceSessionId={1}", _cloudUrl,
                    JObject.Parse(ret)["KDSVCSessionId"]); //安全新方式
            return Convert.ToBase64String(Encoding.UTF8.GetBytes(warehouseCtx));
            /*string json = "{\"ap1\":{ \"AcctID\":\"" + "6654201b47f099" + "\",\"Username\":\"Administrator\",\"Password\":\"Lts88666*\",\"Lcid\":2052,\"AuthenticateType\":1,\"PasswordIsEncrypted\":\"false\",\"ClientInfo\":{\"ClientType\":8}}";
            var resp = GetResponse("http://122.227.249.70:5050/k3cloud/Kingdee.BOS.ServiceFacade.ServicesStub.User.UserService.ValidateLoginInfo.common.kdsvc", json, new Dictionary<string, string>());
            string ret = (new StreamReader(resp.GetResponseStream(), Encoding.UTF8)).ReadToEnd();
            var result = JObject.Parse(ret)["Context"];
            string token = result["UserToken"].ToString();
            var warehouseCtx = string.Format("LoginUrl={0}/&UserToken={1}", _cloudUrl, token);
            return Convert.ToBase64String(Encoding.UTF8.GetBytes(warehouseCtx));*/
        }
    }

    #endregion

    #region 电子仓访问凭证

    private string Token
    {
        get
        {
            var token = Guid.NewGuid().ToString();
            return token;
        }
    }

    #endregion

    #region 物理文件id

    private string GetFileId(string fileId)
    {
        return Convert.ToBase64String(Encoding.UTF8.GetBytes(fileId));
    }

    #endregion

    #region 发送请求

    public Stream SendRequest(string op, string fileId)
    {
        var header = new Dictionary<string, string>
        {
            { "FileID", GetFileId(fileId) },
            { "CTX", WarehouseCTX },
            { "token", Token },
            { "PLM_ACCESS_TYPE", "pure" }
        };
        return PostDataViaHttpWebRequest(RequestUrl(op), string.Empty, header,
            !op.Equals("Download"));
    }

    #endregion

    #region 请求的URL

    private string RequestUrl(string op)
    {
        return _warehouse + "/" + op;
    }

    #endregion

    #region 获取响应

    private HttpWebResponse GetResponse(string url, string bodyJson,
        Dictionary<string, string> header)
    {
        var data = Encoding.UTF8.GetBytes(bodyJson);

        var request = (HttpWebRequest)WebRequest.Create(url);
        request.Method = WebRequestMethods.Http.Post;
        request.ContentType = "application/json";
        request.ContentLength = data.Length;
        if (header != null)
            foreach (var p in header)
                request.Headers.Add(p.Key, p.Value);

        using (var reqStream = request.GetRequestStream())
        {
            reqStream.Write(data, 0, data.Length);
            reqStream.Close();
        }

        HttpWebResponse resp = null;
        try
        {
            resp = (HttpWebResponse)request.GetResponse();
        }
        catch (WebException ex)
        {
            var res = ex.Response;
            if (res != null)
            {
                var statusBase64 =
                    ((HttpWebResponse)ex.Response)
                    .StatusDescription; //base64编码后的报错信息
            }
        }

        return resp;
    }

    #endregion

    #region 返回文件流给前端

    private Stream PostDataViaHttpWebRequest(string url, string bodyJson,
        Dictionary<string, string> header, bool isGetContent)
    {
        var resp = GetResponse(url, bodyJson, header);
        Console.WriteLine(resp.GetResponseStream());
        return resp.GetResponseStream(); // 直接返回响应流
    }

    #endregion

    #region 保存文件到本地

    /* private void PostDataViaHttpWebRequest(string url, string bodyJson, Dictionary<string, string> header, bool isGetContent)
     {

         var resp = GetResponse(url, bodyJson, header);
         var resultJson = string.Empty;
         Stream stream = File.Open("D://DownloadDocDemo.pdf", FileMode.OpenOrCreate);
         int packageSize = 1024 * 1024;
         byte[] buffer = new byte[packageSize];
         using (stream)
         {
             using (Stream outputStream = resp.GetResponseStream())
             {
                 int readLength = 0;
                 while ((readLength = outputStream.Read(buffer, 0, packageSize)) > 0)
                 {
                     stream.Write(buffer, 0, readLength);
                     stream.Flush();
                 }
                 outputStream.Close();
             }
             stream.Close();
         }
     }*/

    #endregion
}

#endregion