Merge branch 'master' of http://192.168.1.222:3000/zhengbingbing/ZLJ_API_V6.0

代码/System.Model/T_Bus_OrderDetail.cs

@@ -13,7 +13,7 @@ namespace System.Model
 		private string _f_id;
 		private int _f_sort = 1;
 		private string _f_orderid;
-		private int _f_productid;
+		private string _f_productid;
 		private string _f_productname = "";
 		private decimal _f_price;
 		private decimal _f_dealprice;
@@ -51,7 +51,7 @@ namespace System.Model
 		/// <summary>
 		/// 产品编号
 		/// </summary>
-		public int F_ProductId
+		public string F_ProductId
 		{
 			set { _f_productid = value; }
 			get { return _f_productid; }

代码/System.Model/T_Bus_Product.cs

@@ -10,7 +10,7 @@ namespace System.Model
 		public T_Bus_Product()
 		{ }
 		#region Model
-		private int _f_productid;
+		private string _f_productid;
 		private string _f_productnumber="";
 		private string _f_productname;
 		private string _f_productshortname="";
@@ -50,7 +50,7 @@ namespace System.Model
 		/// <summary>
 		/// 产品编号ID
 		/// </summary>
-		public int F_ProductId
+		public string F_ProductId
 		{
 			set { _f_productid = value; }
 			get { return _f_productid; }

代码/System.Model/T_Bus_StockLog.cs

@@ -12,7 +12,7 @@ namespace System.Model
 		#region Model
 		private string _f_id;
 		private string _f_orderid = "";
-		private int _f_productid = 0;
+		private string _f_productid = "";
 		private string _f_stock = "";
 		private int _f_num = 0;
 		private DateTime _f_addtime;
@@ -44,7 +44,7 @@ namespace System.Model
 		/// <summary>
 		/// 产品Id
 		/// </summary>
-		public int F_ProductId
+		public string F_ProductId
 		{
 			set { _f_productid = value; }
 			get { return _f_productid; }
@@ -90,7 +90,7 @@ namespace System.Model
 			get { return _f_username; }
 		}
 		/// <summary>
-		/// 变动结果  1成功  0失败
+		/// 变动结果0未开始  1成功  2失败
 		/// </summary>
 		public int F_State
 		{

代码/System.Model/eBoss/GetStock.cs

@@ -0,0 +1,35 @@
+using System;
+using System.Collections.Generic;
+
+namespace System.Model
+{
+	/// <summary>
+	///  订单表
+	/// </summary>
+	[Serializable]
+	public partial class GetStock
+	{
+		public GetStock()
+		{ }
+		public bool success { get; set; }
+		public List<EBossStock> stocks { get; set; }
+		
+	}
+
+	/// <summary>
+	///  亿博士库存返回对象
+	/// </summary>
+	[Serializable]
+	public  class EBossStock
+	{
+		public EBossStock()
+		{ }
+		public string store { get; set; }
+		public string sku { get; set; }
+
+		public int qty { get; set; }
+		public int qtyout { get; set; }
+		public int qtyin { get; set; }
+	}
+}
+

代码/System.Model/eBoss/SetStock.cs

@@ -0,0 +1,60 @@
+using System;
+using System.Collections.Generic;
+
+namespace System.Model
+{
+	/// <summary>
+	///  亿博士更新库存
+	/// </summary>
+	[Serializable]
+	public partial class SetStockModel
+	{
+		public SetStockModel()
+		{ }
+		public string appid { get; set; }
+		
+		public string appkey { get; set; }
+		public string method { get; set; } = "eboss.drp.adj.add";
+		public string adjtype { get; set; } = "正常调整";
+		/// <summary>
+		/// 不超过22位
+		/// </summary>
+		public string masterid { get; set; }
+		public string billdate { get; set; }
+		public string store { get; set; }
+		public string remark { get; set; }
+		public string createid { get; set; } = "000";
+
+		public List<StockChangeModel> dts { get; set; }
+		public List<StockChangeMSModel> ms { get; set; }
+
+	}
+
+	/// <summary>
+	///  亿博士库存返回对象
+	/// </summary>
+	[Serializable]
+	public  class StockChangeModel
+	{
+		public StockChangeModel()
+		{ }
+
+		public string sku { get; set; }
+
+		public int qty { get; set; }
+
+	}
+	[Serializable]
+	public class StockChangeMSModel
+	{
+		public StockChangeMSModel()
+		{ }
+
+		public string sku { get; set; }
+		public string mastercode { get; set; }
+		public string mastercode2 { get; set; }
+
+	}
+
+}
+

代码/System.Utility/Http/HttpHelper.cs

@@ -0,0 +1,146 @@
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace System.Utility.Http
+{
+    public class HttpHelper
+    {
+        /// <summary>
+        /// 同步GET请求
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="headers"></param>
+        /// <param name="timeout">请求响应超时时间，单位/s(默认100秒)</param>
+        /// <returns></returns>
+        public static string HttpGet(string url, Dictionary<string, string> headers = null, int timeout = 0)
+        {
+            using (HttpClient client = new HttpClient())
+            {
+                if (headers != null)
+                {
+                    foreach (KeyValuePair<string, string> header in headers)
+                    {
+                        client.DefaultRequestHeaders.Add(header.Key, header.Value);
+                    }
+                }
+                if (timeout > 0)
+                {
+                    client.Timeout = new TimeSpan(0, 0, timeout);
+                }
+                Byte[] resultBytes = client.GetByteArrayAsync(url).Result;
+                return Encoding.UTF8.GetString(resultBytes);
+            }
+        }
+
+        /// <summary>
+        /// 异步GET请求
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="headers"></param>
+        /// <param name="timeout">请求响应超时时间，单位/s(默认100秒)</param>
+        /// <returns></returns>
+        public static async Task<string> HttpGetAsync(string url, Dictionary<string, string> headers = null, int timeout = 0)
+        {
+            using (HttpClient client = new HttpClient())
+            {
+                if (headers != null)
+                {
+                    foreach (KeyValuePair<string, string> header in headers)
+                    {
+                        client.DefaultRequestHeaders.Add(header.Key, header.Value);
+                    }
+                }
+                if (timeout > 0)
+                {
+                    client.Timeout = new TimeSpan(0, 0, timeout);
+                }
+                Byte[] resultBytes = await client.GetByteArrayAsync(url);
+                return Encoding.Default.GetString(resultBytes);
+            }
+        }
+
+
+        /// <summary>
+        /// 同步POST请求
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="postData"></param>
+        /// <param name="headers"></param>
+        /// <param name="contentType"></param>
+        /// <param name="timeout">请求响应超时时间，单位/s(默认100秒)</param>
+        /// <param name="encoding">默认UTF8</param>
+        /// <returns></returns>
+        public static string HttpPost(string url, string postData, Dictionary<string, string> headers = null, string contentType = null, int timeout = 0, Encoding encoding = null)
+        {
+            using (HttpClient client = new HttpClient())
+            {
+                if (headers != null)
+                {
+                    foreach (KeyValuePair<string, string> header in headers)
+                    {
+                        client.DefaultRequestHeaders.Add(header.Key, header.Value);
+                    }
+                }
+                if (timeout > 0)
+                {
+                    client.Timeout = new TimeSpan(0, 0, timeout);
+                }
+                using (HttpContent content = new StringContent(postData ?? "", encoding ?? Encoding.UTF8))
+                {
+                    if (contentType != null)
+                    {
+                        content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(contentType);
+                    }
+                    using (HttpResponseMessage responseMessage = client.PostAsync(url, content).Result)
+                    {
+                        Byte[] resultBytes = responseMessage.Content.ReadAsByteArrayAsync().Result;
+                        return Encoding.UTF8.GetString(resultBytes);
+                    }
+                }
+            }
+        }
+
+        /// <summary>
+        /// 异步POST请求
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="postData"></param>
+        /// <param name="headers"></param>
+        /// <param name="contentType"></param>
+        /// <param name="timeout">请求响应超时时间，单位/s(默认100秒)</param>
+        /// <param name="encoding">默认UTF8</param>
+        /// <returns></returns>
+        public static async Task<string> HttpPostAsync(string url, string postData, Dictionary<string, string> headers = null, string contentType = null, int timeout = 0, Encoding encoding = null)
+        {
+            using (HttpClient client = new HttpClient())
+            {
+                if (headers != null)
+                {
+                    foreach (KeyValuePair<string, string> header in headers)
+                    {
+                        client.DefaultRequestHeaders.Add(header.Key, header.Value);
+                    }
+                }
+                if (timeout > 0)
+                {
+                    client.Timeout = new TimeSpan(0, 0, timeout);
+                }
+                using (HttpContent content = new StringContent(postData ?? "", encoding ?? Encoding.UTF8))
+                {
+                    if (contentType != null)
+                    {
+                        content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(contentType);
+                    }
+                    using (HttpResponseMessage responseMessage = await client.PostAsync(url, content))
+                    {
+                        Byte[] resultBytes = await responseMessage.Content.ReadAsByteArrayAsync();
+                        return Encoding.UTF8.GetString(resultBytes);
+                    }
+                }
+            }
+        }
+    }
+}

代码/System.Utility/Http/HttpMethods.cs

@@ -0,0 +1,532 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Net.Http;
+using System.Net.Security;
+using System.Security.Cryptography.X509Certificates;
+using System.Text;
+
+namespace System.Utility
+{
+    public class HttpMethods
+    {
+        #region POST
+        /// <summary>
+        /// HTTP POST方式请求数据
+        /// </summary>
+        /// <param name="url">URL.</param>
+        /// <param name="param">POST的数据</param>
+        /// <returns></returns>
+        public static string HttpPost(string url, string param = null)
+        {
+            HttpWebRequest request;
+
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
+                request = WebRequest.Create(url) as HttpWebRequest;
+                request.ProtocolVersion = HttpVersion.Version10;
+            }
+            else
+            {
+                request = WebRequest.Create(url) as HttpWebRequest;
+            }
+
+            request.Method = "POST";
+            request.ContentType = "application/x-www-form-urlencoded";
+            request.Accept = "*/*";
+            request.Timeout = 15000;
+            request.AllowAutoRedirect = false;
+
+
+
+            StreamWriter requestStream = null;
+            WebResponse response = null;
+            string responseStr = null;
+
+            try
+            {
+                requestStream = new StreamWriter(request.GetRequestStream());
+                requestStream.Write(param);
+                requestStream.Close();
+
+                response = request.GetResponse();
+                if (response != null)
+                {
+                    StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
+                    responseStr = reader.ReadToEnd();
+                    reader.Close();
+                }
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+            finally
+            {
+                request = null;
+                requestStream = null;
+                response = null;
+            }
+
+            return responseStr;
+        }
+
+
+        private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
+        {
+            return true; //总是接受  
+        }
+        public static string BuildRequest(string strUrl, Dictionary<string, string> dicPara, string fileName)
+        {
+            string contentType = "image/jpeg";
+            //待请求参数数组
+            FileStream Pic = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
+            byte[] PicByte = new byte[Pic.Length];
+            Pic.Read(PicByte, 0, PicByte.Length);
+            int lengthFile = PicByte.Length;
+
+            //构造请求地址
+
+            //设置HttpWebRequest基本信息
+            HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(strUrl);
+            //设置请求方式：get、post
+            request.Method = "POST";
+            //设置boundaryValue
+            string boundaryValue = DateTime.Now.Ticks.ToString("x");
+            string boundary = "--" + boundaryValue;
+            request.ContentType = "\r\nmultipart/form-data; boundary=" + boundaryValue;
+            //设置KeepAlive
+            request.KeepAlive = true;
+            //设置请求数据，拼接成字符串
+            StringBuilder sbHtml = new StringBuilder();
+            foreach (KeyValuePair<string, string> key in dicPara)
+            {
+                sbHtml.Append(boundary + "\r\nContent-Disposition: form-data; name=\"" + key.Key + "\"\r\n\r\n" + key.Value + "\r\n");
+            }
+            sbHtml.Append(boundary + "\r\nContent-Disposition: form-data; name=\"pic\"; filename=\"");
+            sbHtml.Append(fileName);
+            sbHtml.Append("\"\r\nContent-Type: " + contentType + "\r\n\r\n");
+            string postHeader = sbHtml.ToString();
+            //将请求数据字符串类型根据编码格式转换成字节流
+            Encoding code = Encoding.GetEncoding("UTF-8");
+            byte[] postHeaderBytes = code.GetBytes(postHeader);
+            byte[] boundayBytes = Encoding.ASCII.GetBytes("\r\n" + boundary + "--\r\n");
+            //设置长度
+            long length = postHeaderBytes.Length + lengthFile + boundayBytes.Length;
+            request.ContentLength = length;
+
+            //请求远程HTTP
+            Stream requestStream = request.GetRequestStream();
+            Stream myStream = null;
+            try
+            {
+                //发送数据请求服务器
+                requestStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
+                requestStream.Write(PicByte, 0, lengthFile);
+                requestStream.Write(boundayBytes, 0, boundayBytes.Length);
+                HttpWebResponse HttpWResp = (HttpWebResponse)request.GetResponse();
+                myStream = HttpWResp.GetResponseStream();
+            }
+            catch (WebException e)
+            {
+                //LogResult(e.Message);
+                return "";
+            }
+            finally
+            {
+                if (requestStream != null)
+                {
+                    requestStream.Close();
+                }
+            }
+
+            //读取处理结果
+            StreamReader reader = new StreamReader(myStream, code);
+            StringBuilder responseData = new StringBuilder();
+
+            String line;
+            while ((line = reader.ReadLine()) != null)
+            {
+                responseData.Append(line);
+            }
+            myStream.Close();
+            Pic.Close();
+
+            return responseData.ToString();
+        }
+        #endregion
+
+        #region Put
+        /// <summary>
+        /// HTTP Put方式请求数据.
+        /// </summary>
+        /// <param name="url">URL.</param>
+        /// <returns></returns>
+        public static string HttpPut(string url, string param = null)
+        {
+            HttpWebRequest request;
+
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
+                request = WebRequest.Create(url) as HttpWebRequest;
+                request.ProtocolVersion = HttpVersion.Version10;
+            }
+            else
+            {
+                request = WebRequest.Create(url) as HttpWebRequest;
+            }
+            request.Method = "PUT";
+            request.ContentType = "application/x-www-form-urlencoded";
+            request.Accept = "*/*";
+            request.Timeout = 15000;
+            request.AllowAutoRedirect = false;
+
+            StreamWriter requestStream = null;
+            WebResponse response = null;
+            string responseStr = null;
+
+            try
+            {
+                requestStream = new StreamWriter(request.GetRequestStream());
+                requestStream.Write(param);
+                requestStream.Close();
+
+                response = request.GetResponse();
+                if (response != null)
+                {
+                    StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
+                    responseStr = reader.ReadToEnd();
+                    reader.Close();
+                }
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+            finally
+            {
+                request = null;
+                requestStream = null;
+                response = null;
+            }
+
+            return responseStr;
+        }
+        #endregion
+
+        #region Delete
+        /// <summary>
+        /// HTTP Delete方式请求数据.
+        /// </summary>
+        /// <param name="url">URL.</param>
+        /// <returns></returns>
+        public static string HttpDelete(string url, string param = null)
+        {
+            HttpWebRequest request;
+
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
+                request = WebRequest.Create(url) as HttpWebRequest;
+                request.ProtocolVersion = HttpVersion.Version10;
+            }
+            else
+            {
+                request = WebRequest.Create(url) as HttpWebRequest;
+            }
+            request.Method = "Delete";
+            request.ContentType = "application/x-www-form-urlencoded";
+            request.Accept = "*/*";
+            request.Timeout = 15000;
+            request.AllowAutoRedirect = false;
+
+            StreamWriter requestStream = null;
+            WebResponse response = null;
+            string responseStr = null;
+
+            try
+            {
+                requestStream = new StreamWriter(request.GetRequestStream());
+                requestStream.Write(param);
+                requestStream.Close();
+
+                response = request.GetResponse();
+                if (response != null)
+                {
+                    StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
+                    responseStr = reader.ReadToEnd();
+                    reader.Close();
+                }
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+            return responseStr;
+        }
+        #endregion
+
+        #region Get
+        /// <summary>
+        /// HTTP GET方式请求数据.
+        /// </summary>
+        /// <param name="url">URL.</param>
+        /// <returns></returns>
+        public static string HttpGet(string url, Hashtable headht = null)
+        {
+            HttpWebRequest request;
+
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
+                request = WebRequest.Create(url) as HttpWebRequest;
+                request.ProtocolVersion = HttpVersion.Version10;
+            }
+            else
+            {
+                request = WebRequest.Create(url) as HttpWebRequest;
+            }
+            request.Method = "GET";
+            //request.ContentType = "application/x-www-form-urlencoded";
+            request.Accept = "*/*";
+            request.Timeout = 15000;
+            request.AllowAutoRedirect = false;
+            WebResponse response = null;
+            string responseStr = null;
+            if (headht != null)
+            {
+                foreach (DictionaryEntry item in headht)
+                {
+                    request.Headers.Add(item.Key.ToString(), item.Value.ToString());
+                }
+            }
+
+            try
+            {
+                response = request.GetResponse();
+
+                if (response != null)
+                {
+                    StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
+                    responseStr = reader.ReadToEnd();
+                    reader.Close();
+                }
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+            return responseStr;
+        }
+        public static string HttpGet(string url, Encoding encodeing, Hashtable headht = null)
+        {
+            HttpWebRequest request;
+
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
+                request = WebRequest.Create(url) as HttpWebRequest;
+                request.ProtocolVersion = HttpVersion.Version10;
+            }
+            else
+            {
+                request = WebRequest.Create(url) as HttpWebRequest;
+            }
+            request.Method = "GET";
+            //request.ContentType = "application/x-www-form-urlencoded";
+            request.Accept = "*/*";
+            request.Timeout = 15000;
+            request.AllowAutoRedirect = false;
+            WebResponse response = null;
+            string responseStr = null;
+            if (headht != null)
+            {
+                foreach (DictionaryEntry item in headht)
+                {
+                    request.Headers.Add(item.Key.ToString(), item.Value.ToString());
+                }
+            }
+
+            try
+            {
+                response = request.GetResponse();
+
+                if (response != null)
+                {
+                    StreamReader reader = new StreamReader(response.GetResponseStream(), encodeing);
+                    responseStr = reader.ReadToEnd();
+                    reader.Close();
+                }
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+            return responseStr;
+        }
+        #endregion
+
+        #region Post With Pic
+        private string HttpPost(string url, IDictionary<object, object> param, string filePath)
+        {
+            string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
+            byte[] boundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
+
+            HttpWebRequest wr = (HttpWebRequest)WebRequest.Create(url);
+            wr.ContentType = "multipart/form-data; boundary=" + boundary;
+            wr.Method = "POST";
+            wr.KeepAlive = true;
+            wr.Credentials = System.Net.CredentialCache.DefaultCredentials;
+
+            Stream rs = wr.GetRequestStream();
+            string responseStr = null;
+
+            string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}";
+            foreach (string key in param.Keys)
+            {
+                rs.Write(boundarybytes, 0, boundarybytes.Length);
+                string formitem = string.Format(formdataTemplate, key, param[key]);
+                byte[] formitembytes = System.Text.Encoding.UTF8.GetBytes(formitem);
+                rs.Write(formitembytes, 0, formitembytes.Length);
+            }
+            rs.Write(boundarybytes, 0, boundarybytes.Length);
+
+            string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: {2}\r\n\r\n";
+            string header = string.Format(headerTemplate, "pic", filePath, "text/plain");
+            byte[] headerbytes = System.Text.Encoding.UTF8.GetBytes(header);
+            rs.Write(headerbytes, 0, headerbytes.Length);
+
+            FileStream fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read);
+            byte[] buffer = new byte[4096];
+            int bytesRead = 0;
+            while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
+            {
+                rs.Write(buffer, 0, bytesRead);
+            }
+            fileStream.Close();
+
+            byte[] trailer = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");
+            rs.Write(trailer, 0, trailer.Length);
+            rs.Close();
+
+            WebResponse wresp = null;
+            try
+            {
+                wresp = wr.GetResponse();
+                Stream stream2 = wresp.GetResponseStream();
+                StreamReader reader2 = new StreamReader(stream2);
+                responseStr = reader2.ReadToEnd();
+                //logger.Debug(string.Format("File uploaded, server response is: {0}", responseStr));
+            }
+            catch (Exception ex)
+            {
+                //logger.Error("Error uploading file", ex);
+                if (wresp != null)
+                {
+                    wresp.Close();
+                    wresp = null;
+                }
+                throw;
+            }
+            return responseStr;
+        }
+        #endregion
+
+        #region Post With Pic
+        /// <summary>
+        /// HTTP POST方式请求数据(带图片)
+        /// </summary>
+        /// <param name="url">URL</param>        
+        /// <param name="param">POST的数据</param>
+        /// <param name="fileByte">图片</param>
+        /// <returns></returns>
+        public static string HttpPost(string url, IDictionary<object, object> param, byte[] fileByte)
+        {
+            string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
+            byte[] boundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
+
+            HttpWebRequest wr = (HttpWebRequest)WebRequest.Create(url);
+            wr.ContentType = "multipart/form-data; boundary=" + boundary;
+            wr.Method = "POST";
+            wr.KeepAlive = true;
+            wr.Credentials = System.Net.CredentialCache.DefaultCredentials;
+
+            Stream rs = wr.GetRequestStream();
+            string responseStr = null;
+
+            string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}";
+            foreach (string key in param.Keys)
+            {
+                rs.Write(boundarybytes, 0, boundarybytes.Length);
+                string formitem = string.Format(formdataTemplate, key, param[key]);
+                byte[] formitembytes = System.Text.Encoding.UTF8.GetBytes(formitem);
+                rs.Write(formitembytes, 0, formitembytes.Length);
+            }
+            rs.Write(boundarybytes, 0, boundarybytes.Length);
+
+            string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: {2}\r\n\r\n";
+            string header = string.Format(headerTemplate, "pic", fileByte, "text/plain");//image/jpeg
+            byte[] headerbytes = System.Text.Encoding.UTF8.GetBytes(header);
+            rs.Write(headerbytes, 0, headerbytes.Length);
+
+            rs.Write(fileByte, 0, fileByte.Length);
+
+            byte[] trailer = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");
+            rs.Write(trailer, 0, trailer.Length);
+            rs.Close();
+
+            WebResponse wresp = null;
+            try
+            {
+                wresp = wr.GetResponse();
+                Stream stream2 = wresp.GetResponseStream();
+                StreamReader reader2 = new StreamReader(stream2);
+                responseStr = reader2.ReadToEnd();
+                // logger.Error(string.Format("File uploaded, server response is: {0}", responseStr));
+            }
+            catch (Exception ex)
+            {
+                //logger.Error("Error uploading file", ex);
+                if (wresp != null)
+                {
+                    wresp.Close();
+                    wresp = null;
+                }
+                throw;
+            }
+            return responseStr;
+        }
+        #endregion
+
+        #region HttpsClient
+        /// <summary>
+        /// 创建HttpClient
+        /// </summary>
+        /// <returns></returns>
+        public static HttpClient CreateHttpClient(string url)
+        {
+            HttpClient httpclient;
+            //如果是发送HTTPS请求  
+            if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
+            {
+                ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, sslPolicyErrors) => true;
+                httpclient = new HttpClient();
+            }
+            else
+            {
+                httpclient = new HttpClient();
+            }
+            return httpclient;
+        }
+        #endregion
+    }
+}

代码/TVShoppingCallCenter_ZLJ/Controllers/Marketing/MarketingController.cs

@@ -266,7 +266,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Marketing
                     if (split != null)
                         foreach (var iv in split)
                         {
-                            var data = await _productRepository.GetSingle(x => x.F_ProductId == int.Parse(iv));
+                            var data = await _productRepository.GetSingle(x => x.F_ProductId ==iv);
                             if (data != null)
                             {
                                 if (marketing.F_GiftName == "")

代码/TVShoppingCallCenter_ZLJ/Controllers/MediaCente/MediaCenteController.cs

@@ -310,9 +310,9 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.MediaCente
                     foreach (var ib in spritcom)
                     {
                         if (MediaCente.F_CommodityName == "")
-                            MediaCente.F_CommodityName = _productRepository.GetSingle(x => x.F_ProductId == int.Parse(ib)).Result.F_ProductName;
+                            MediaCente.F_CommodityName = _productRepository.GetSingle(x => x.F_ProductId ==ib).Result.F_ProductName;
                         else
-                            MediaCente.F_CommodityName+=","+ _productRepository.GetSingle(x => x.F_ProductId == int.Parse(ib)).Result.F_ProductName;
+                            MediaCente.F_CommodityName+=","+ _productRepository.GetSingle(x => x.F_ProductId ==ib).Result.F_ProductName;
                     }
                 }
                 catch

代码/TVShoppingCallCenter_ZLJ/Controllers/Product/ProductController.cs

@@ -289,7 +289,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Product
                 return Error("请输入正确会员价");
             if (input.SpecialPrice <= 0)
                 return Error("请输入正确特惠价");
-            if (input.ProductId <= 0)
+            if (string.IsNullOrEmpty(input.ProductId))
                 return Error("请输入正确产品编码");
             if (string.IsNullOrEmpty(input.PinyinShort))
                 return Error("请输入正确拼音简码");
@@ -403,8 +403,8 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Product
                 return Error("请输入正确会员价");
             if (input.SpecialPrice <= 0)
                 return Error("请输入正确特惠价");
-            if (input.ProductId <= 0)
-                return Error("产品ID必须大于0");
+            if (string.IsNullOrEmpty(input.ProductId))
+                return Error("产品ID不能为空");
             if (string.IsNullOrEmpty(input.PinyinShort))
                 return Error("请输入正确拼音简码");
             #endregion
@@ -660,9 +660,9 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Product
 
             conModels.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumDelState.Enabled).ToString() });
 
-            if (input.ProductId > 0)
+            if (!string.IsNullOrEmpty(input.ProductId))
             {
-                conModels.Add(new ConditionalModel() { FieldName = "F_ProductId", ConditionalType = ConditionalType.Equal, FieldValue = input.ProductId.ToString() });
+                conModels.Add(new ConditionalModel() { FieldName = "F_ProductId", ConditionalType = ConditionalType.Equal, FieldValue = input.ProductId });
             }
             //指定分类
             if (input.ClassId > 0)
@@ -775,7 +775,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Product
 
             foreach (ProductInput m in input)
             {
-                if (m.ProductId <= 0)
+                if (string.IsNullOrEmpty(m.ProductId))
                     return Error("参数缺失产品id");
 
                 T_Bus_Product model = await _productRepository.GetSingle(a => a.F_ProductId == m.ProductId);
@@ -797,10 +797,10 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Product
 
             #endregion
             //此字段更新单独字段
-            if (await _productRepository.UpdateListToColumns(listmodel, it => new { it.F_Stock, it.F_FreezeStock, it.F_Stock1, it.F_FreezeStock1, }))
+            //if (await _productRepository.UpdateListToColumns(listmodel, it => new { it.F_Stock, it.F_FreezeStock, it.F_Stock1, it.F_FreezeStock1, }))
                 return Success("更新库存成功");
-            else
-                return Success("更新库存失败");
+            //else
+            //    return Success("更新库存失败");
         }
 
 

代码/TVShoppingCallCenter_ZLJ/Models/Inputs/OrderDetailInput.cs

@@ -13,7 +13,7 @@ namespace TVShoppingCallCenter_ZLJ.Models.Inputs
 		private string _f_id;
 		private int _f_sort = 1;
 		private string _f_orderid;
-		private int _f_productid;
+		private string _f_productid;
 		private string _f_productname = "";
 		private decimal _f_price;
 		private decimal _f_dealprice;
@@ -62,7 +62,7 @@ namespace TVShoppingCallCenter_ZLJ.Models.Inputs
 		/// <summary>
 		/// 产品编号
 		/// </summary>
-		public int F_ProductId
+		public string F_ProductId
 		{
 			set { _f_productid = value; }
 			get { return _f_productid; }

代码/TVShoppingCallCenter_ZLJ/Models/Inputs/ProductInput.cs

@@ -9,7 +9,7 @@ namespace TVShoppingCallCenter_ZLJ.Models.Inputs
     {
 
         #region Model
-        private int _f_productid;
+        private string _f_productid;
         private string _f_productnumber;
         private string _f_productname;
         private string _f_productshortname;
@@ -49,7 +49,7 @@ namespace TVShoppingCallCenter_ZLJ.Models.Inputs
         /// <summary>
         /// 产品编号ID
         /// </summary>
-        public int ProductId
+        public string ProductId
         {
             set { _f_productid = value; }
             get { return _f_productid; }

代码/TVShoppingCallCenter_ZLJ/appsettings.json

@@ -1,5 +1,12 @@
 {
   "Cors": "",
+  "eBoss": {
+    "url": "http://36.99.164.148/eboss_yun/ebossapi.ashx?",
+    "appid": "180702",
+    "appkey": "9E9672CE87224A8CB825ABAF8DD4B7B8",
+    "stock": "WLZZ0001",
+    "stock1": "WLZZ0001"
+  },
   "ConnectionStrings": {
     "DefaultConnection": "Data Source=192.168.8.3;User ID=sa;pwd=800100;Initial Catalog=TVCallCenter_ZLJ;"
   },