using HH.AutoBom.Core;
using HH.WMS.Common;
using HH.WMS.Entitys;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Web;
using System.Web.Mvc;

namespace HH.WMS.WebUI.Controllers
{
    public class BaseController : Controller
    {
        #region 获得WebApi的地址
        /// <summary>
        /// 获得webapi的地址  不包括后面的控制器等
        /// </summary>
        /// <returns></returns>
        private static string GetWMSAddress()
        {
            //获得配置文件中ERP的IP和端口
            //string wmsAddress = System.Configuration.ConfigurationManager.AppSettings["wms_ipAddress"].ToString();
            string url = "http://" + Constants.SysConfig.WMS_API + "/";
            return url;
        }
        #endregion


        /// <summary>
        /// Post请求
        /// </summary>
        /// <param name="apiPath"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static string HttpWMS_Post(string apiPath, string data)
        {
            //string url = GetWMSAddress() + apiPath;
            string url = "http://" + Constants.SysConfig.WMS_API + "/" + apiPath;
            return Post(url, data);
        }

        /// <summary>
        /// Get请求
        /// </summary>
        /// <param name="apiPath"></param>
        /// <param name="paramStr"></param>
        /// <returns></returns>
        public static string HttpWMS_Get(string apiPath, string paramStr = "")
        {
            //string url = GetWMSAddress() + apiPath;
            string url = "http://" + Constants.SysConfig.WMS_API + "/" + apiPath;
            return Get(url, paramStr);
        }


        /// <summary>
        /// Get请求
        /// </summary>
        /// <param name="apiPath"></param>
        /// <param name="paramStr"></param>
        /// <returns></returns>
        public static string HttpAutobom_Post(string apiPath, string data)
        {
            string url = "http://" + Constants.SysConfig.AUTOBOM + "/" + apiPath;
            return Post(url, data);
        }

        private static string Post(string url, string data)
        {
            string returnStr = "";
            var loginer = FormsAuth.GetUserData<LoginerBase>();
            try
            {
                //对所有代码产生的垃圾资源进行强制回收-慎用
                //System.GC.Collect();
                //请求地址获取用户授权信息
                WebRequest webRequest = System.Net.WebRequest.Create(url);
                webRequest.Timeout = 1000000;//设置请求超时时间10秒

                HttpWebRequest httpRequest = webRequest as System.Net.HttpWebRequest;
                httpRequest.Method = "post";
                httpRequest.Headers.Add("tokenId", loginer.Extend1);
                httpRequest.ContentType = "application/json";
                httpRequest.KeepAlive = false;//设置不是常连接

                System.Text.Encoding encoding = System.Text.Encoding.UTF8;
                byte[] bytesToPost = encoding.GetBytes(data);
                httpRequest.ContentLength = bytesToPost.Length;
                System.IO.Stream requestStream = httpRequest.GetRequestStream();
                requestStream.Write(bytesToPost, 0, bytesToPost.Length);
                requestStream.Close();

                HttpWebResponse response = (HttpWebResponse)webRequest.GetResponse();
                Stream stream = response.GetResponseStream();
                StreamReader Reader = new StreamReader(stream, Encoding.UTF8);
                returnStr = Reader.ReadToEnd();
                if (!string.IsNullOrEmpty(returnStr) && returnStr.StartsWith("\""))
                {
                    returnStr = returnStr.Replace("\\", "");
                    returnStr = returnStr.TrimEnd('\"');
                    returnStr = returnStr.TrimStart('\"');
                }

                if (webRequest != null)
                {
                    webRequest.Abort();
                }
                if (httpRequest != null)
                {
                    httpRequest.Abort();
                }
                if (response != null)
                {
                    response.Dispose();
                    response.Close();
                }
                if (stream != null)
                {
                    stream.Dispose();
                    stream.Close();
                }
                if (Reader != null)
                {
                    Reader.Dispose();
                    Reader.Close();
                }
            }
            catch (WebException ex)
            {
                return JsonConvert.SerializeObject(OperateResult.Error("网络异常:" + url + "-------" + ex.Message));
            }
            catch (Exception ex)
            {
                return JsonConvert.SerializeObject(OperateResult.Error(ex.Message));
            }
            return returnStr;
        }

        private static string Get(string url, string paramStr = "")
        {
            var loginer = FormsAuth.GetUserData<LoginerBase>();

            string Data = url + (paramStr == "" ? "" : "?") + paramStr;


            //if (Data.IndexOf("?") > 0)
            //{
            //    //包含参数
            //    Data += "&tokenId=" + loginer.Extend1;
            //}
            //else
            //{
            //    Data += "?tokenId=" + loginer.Extend1;
            //}

            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Data);
            request.Method = "GET";
            request.Headers.Add("tokenId", loginer.Extend1);
            request.ContentType = "application/json";
            request.KeepAlive = false;//设置不是常连接

            try
            {
                HttpWebResponse response = (HttpWebResponse)request.GetResponse();
                Stream myResponseStream = response.GetResponseStream();
                StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
                string retString = myStreamReader.ReadToEnd();
                if (!string.IsNullOrEmpty(retString))
                {
                    retString = retString.Replace("\\", "");
                    retString = retString.TrimEnd('\"');
                    retString = retString.TrimStart('\"');
                }

                myStreamReader.Close();

                myResponseStream.Close();
                if (request != null)
                {
                    request.Abort();
                }
                if (response != null)
                {
                    response.Dispose();
                    response.Close();
                }
                if (myResponseStream != null)
                {
                    myResponseStream.Dispose();
                    myResponseStream.Close();
                }
                if (myStreamReader != null)
                {
                    myStreamReader.Dispose();
                    myStreamReader.Close();
                }

                return retString;
            }
            catch (WebException ex)
            {
                return JsonConvert.SerializeObject(OperateResult.Error("网络异常:" + url + "-------" + ex.Message));
            }
            catch (Exception ex)
            {
                return JsonConvert.SerializeObject(OperateResult.Error(ex.Message));
            }
        }

        #region wms 同步post
        /// <summary>
        /// wms 同步post
        /// </summary>
        /// <param name="requestUri"></param>
        /// <param name="paramObj"></param>
        /// <returns></returns>
        public static string HttpWMS_Post(string requestUri, object paramObj)
        {
            try
            {
                var client = new System.Net.Http.HttpClient { BaseAddress = new Uri(GetWMSAddress()) };
                var jsonPara = paramObj != null ? JsonConvert.SerializeObject(paramObj) : string.Empty;
                System.Net.Http.HttpContent httpContent = new System.Net.Http.StringContent(jsonPara);
                httpContent.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
                var result = client.PostAsync(requestUri, httpContent);
                return result.Result.Content.ReadAsStringAsync().Result;
            }
            catch (Exception ex)
            {
                return ex.Message;
            }
        }
        #endregion

        /// <summary>
        /// 货位autobom中的编码
        /// </summary>
        /// <param name="ruleName">编码名称</param>
        /// <returns></returns>
        public string GetCode(string ruleName)
        {
            var loginer = FormsAuth.GetUserData<LoginerBase>();
            string postData = "{\"appCode\":\"AutoWMS\",\"ruleName\":\"" + ruleName + "\",\"orgId\":\"" + loginer.ParentOrgCode + "\",\"orgFlag\":\"" + loginer.OrgFlag + "\"}";
            return HttpAutobom_Post("api/BillRule/GenBillNo", postData);
        }

        public string GetTokenId()
        {
            var loginer = FormsAuth.GetUserData<LoginerBase>();
            return loginer.Extend1;
        }

        public string GetRequestBodyString()
        {
            return new StreamReader(Request.InputStream).ReadToEnd();
        }
    }
}