using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
using IStation.Bimface;
|
|
namespace IStation
|
{
|
/// <summary>
|
/// 文件上传
|
/// </summary>
|
public sealed partial class BimfaceClient
|
{
|
private const string _normalUploadUrl = @"https://file.bimface.com/upload";//普通文件流上传URL
|
private const string _policyUploadUrl = @"https://file.bimface.com/upload/policy";//文件直传URL
|
|
|
/// <summary>
|
/// 普通文件流上传(不推荐)
|
/// </summary>
|
/// <param name="fullFileName">文件全路径</param>
|
public UploadFileResponse UploadFileGeneral(string fullFileName, string fileName = null)
|
{
|
GetAccessToken();
|
if (string.IsNullOrEmpty(fileName))
|
{
|
var fileInfo = new FileInfo(fullFileName);
|
fileName = fileInfo.Name;
|
}
|
var utf8_fileName = Encoding.UTF8.GetString(Encoding.UTF8.GetBytes(fileName));
|
var url = string.Format("{0}?name={1}", _normalUploadUrl, utf8_fileName);
|
var request = (HttpWebRequest)WebRequest.Create(url);
|
request.Method = WebRequestMethods.Http.Put;
|
var autoHeader = new HttpHeaders().GetBasicAuthorHeader(_accesstoken);
|
request.Headers.Add(autoHeader.Key, autoHeader.Value);
|
byte[] bytes;
|
using (FileStream steam = new FileStream(fullFileName, FileMode.Open, FileAccess.Read))
|
{
|
bytes = new byte[(int)steam.Length];
|
steam.Read(bytes, 0, bytes.Length);
|
}
|
request.ContentLength = bytes.Length;
|
request.AllowWriteStreamBuffering = true;
|
using (Stream stream = request.GetRequestStream())
|
{
|
stream.Write(bytes, 0, bytes.Length);
|
stream.Flush();
|
}
|
var response = request.GetResponse();
|
string responsetext = string.Empty;
|
using (Stream stream = response.GetResponseStream())
|
using (StreamReader reader = new StreamReader(stream))
|
{
|
responsetext = reader.ReadToEnd();
|
}
|
var result = JsonHelper.Json2Object<Result<UploadFileResponse>>(responsetext);
|
if (result.code != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
if (result.data.status != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
return result.data;
|
}
|
|
/// <summary>
|
/// 普通文件流上传Core(不推荐)
|
/// </summary>
|
/// <param name="fullFileName">文件全路径</param>
|
public UploadFileResponse UploadFileGeneralCore(string fullFileName, string fileName = null)
|
{
|
GetAccessToken();
|
if (string.IsNullOrEmpty(fileName))
|
{
|
var fileInfo = new FileInfo(fullFileName);
|
fileName = fileInfo.Name;
|
}
|
var utf8_fileName = Encoding.UTF8.GetString(Encoding.UTF8.GetBytes(fileName));
|
var url = string.Format("{0}?name={1}", _normalUploadUrl, utf8_fileName);
|
using (var httpClient = new HttpClient())
|
using (var request=new HttpRequestMessage(HttpMethod.Put,url))
|
using (var stream= new FileStream(fullFileName, FileMode.Open, FileAccess.Read))
|
{
|
var autoHeader = new HttpHeaders().GetBasicAuthorHeader(_accesstoken);
|
request.Headers.Add(autoHeader.Key, autoHeader.Value);
|
request.Content = new StreamContent(stream);
|
var response = httpClient.SendAsync(request).Result;
|
response.EnsureSuccessStatusCode();
|
var responsetext=response.Content.ReadAsStringAsync().Result;
|
var result = JsonHelper.Json2Object<Result<UploadFileResponse>>(responsetext);
|
if (result.code != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
if (result.data.status != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
return result.data;
|
}
|
}
|
|
/// <summary>
|
/// 文件直传(推荐)
|
/// </summary>
|
/// <param name="fullFileName">文件全路径</param>
|
/// <param name="fileName">文件名称（必须带后缀）</param>
|
public UploadFileResponse UploadFilePolicy(string fullFileName, string fileName = null)
|
{
|
if (string.IsNullOrEmpty(fileName))
|
{
|
var fileInfo = new FileInfo(fullFileName);
|
fileName = fileInfo.Name;
|
}
|
var policyResult = GetFileUploadPolicy(fileName);
|
string boundary = "----" + DateTime.Now.Ticks.ToString("x");// 边界符
|
byte[] beginBoundaryBytes = Encoding.UTF8.GetBytes("--" + boundary + "\r\n"); // 边界符开始。【☆】右侧必须要有 \r\n 。
|
byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n"); // 边界符结束。【☆】两侧必须要有 --\r\n 。
|
var textFormTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n" + "{1}\r\n";//文本模板
|
var fileFormTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\n" + "Content-Type: application/octet-stream\r\n\r\n";//文件模板
|
|
var dic = new Dictionary<string, string>();
|
dic.Add("name", fileName);
|
dic.Add("key", policyResult.objectKey);
|
dic.Add("policy", policyResult.policy);
|
dic.Add("OSSAccessKeyId", policyResult.accessId);
|
dic.Add("success_action_status", "200");
|
dic.Add("callback", policyResult.callbackBody);
|
dic.Add("signature", policyResult.signature);
|
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(policyResult.host);
|
request.ContentType = string.Format("multipart/form-data; boundary={0}", boundary);
|
request.Method = WebRequestMethods.Http.Post;
|
request.AllowWriteStreamBuffering = false;
|
//request.KeepAlive = true;
|
request.Timeout = -1;
|
|
long contentLength = 0;
|
var textBytesList = dic.Select(x =>
|
{
|
var textFormItem = string.Format(textFormTemplate, x.Key, x.Value);
|
byte[] textFormItemBytes = Encoding.UTF8.GetBytes(textFormItem);
|
contentLength += beginBoundaryBytes.Length;
|
contentLength += textFormItemBytes.Length;
|
return textFormItemBytes;
|
}).ToList();
|
|
var fileFormItem = string.Format(fileFormTemplate, "file", fileName);
|
byte[] fileFormItemBytes = Encoding.UTF8.GetBytes(fileFormItem);
|
contentLength += beginBoundaryBytes.Length;
|
contentLength += fileFormItemBytes.Length;
|
|
var fileStream = new FileStream(fullFileName, FileMode.Open, FileAccess.Read);
|
contentLength += fileStream.Length;
|
contentLength += endBoundaryBytes.Length;
|
request.ContentLength = contentLength;
|
var requestStream = request.GetRequestStream();
|
textBytesList.ForEach(x =>
|
{
|
requestStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
|
requestStream.Write(x, 0, x.Length);
|
});
|
requestStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
|
requestStream.Write(fileFormItemBytes, 0, fileFormItemBytes.Length);
|
|
//每次上传4M
|
byte[] buffer = new Byte[checked((uint)Math.Min(4096, (int)fileStream.Length))];
|
int bytesRead = 0;
|
while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
|
{
|
requestStream.Write(buffer, 0, bytesRead);
|
}
|
requestStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
|
|
fileStream.Close();
|
requestStream.Close();
|
|
var response = request.GetResponse();
|
string responsetext = string.Empty;
|
using (Stream stream = response.GetResponseStream())
|
using (StreamReader reader = new StreamReader(stream))
|
{
|
responsetext = reader.ReadToEnd();
|
}
|
|
var result = JsonHelper.Json2Object<Result<UploadFileResponse>>(responsetext);
|
if (result.code != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
if (result.data.status != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
|
return result.data;
|
}
|
|
/// <summary>
|
/// 文件直传Core(推荐)
|
/// </summary>
|
/// <param name="fullFileName">文件全路径</param>
|
/// <param name="fileName">文件名称（必须带后缀）</param>
|
public UploadFileResponse UploadFilePolicyCore(string fullFileName, string fileName = null)
|
{
|
if (string.IsNullOrEmpty(fileName))
|
{
|
var fileInfo = new FileInfo(fullFileName);
|
fileName = fileInfo.Name;
|
}
|
var policyResult = GetFileUploadPolicy(fileName);
|
string responsetext = string.Empty;
|
using (var httpClient = new HttpClient())
|
{
|
httpClient.Timeout = Timeout.InfiniteTimeSpan;
|
var url = policyResult.host;
|
var content = new MultipartFormDataContent();
|
content.Add(new StringContent(fileName),"name");
|
content.Add(new StringContent(policyResult.objectKey), "key");
|
content.Add(new StringContent(policyResult.policy), "policy");
|
content.Add(new StringContent(policyResult.accessId), "OSSAccessKeyId");
|
content.Add(new StringContent("200"), "success_action_status");
|
content.Add(new StringContent(policyResult.callbackBody), "callback");
|
content.Add(new StringContent(policyResult.signature), "signature");
|
using (var fileStream = new FileStream(fullFileName, FileMode.Open, FileAccess.Read))
|
using (var streamContent = new StreamContent(fileStream, 2048))
|
{
|
content.Add(streamContent,"file",fileName);
|
var response = httpClient.PostAsync(url,content).Result;
|
response.EnsureSuccessStatusCode();
|
responsetext = response.Content.ReadAsStringAsync().Result;
|
}
|
}
|
var result = JsonHelper.Json2Object<Result<UploadFileResponse>>(responsetext);
|
if (result.code != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
if (result.data.status != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
|
return result.data;
|
}
|
|
/// <summary>
|
/// 文件直传
|
/// </summary>
|
/// <param name="fullFileName"></param>
|
/// <param name="fileName"></param>
|
/// <returns></returns>
|
public long UploadFilePolicyEx(string fullFileName, string fileName = null)
|
{
|
var response = UploadFilePolicy(fullFileName,fileName);
|
if (response.status != Constants.Success)
|
{
|
return 0;
|
}
|
return response.fileId.Value;
|
}
|
|
//获取文件直传Policy
|
private UploadFilePolicyResponse GetFileUploadPolicy(string fileName)
|
{
|
GetAccessToken();
|
var utf8_fileName = Encoding.UTF8.GetString(Encoding.UTF8.GetBytes(fileName));
|
var url = string.Format("{0}?name={1}", _policyUploadUrl, utf8_fileName);
|
using (var httpClient = new HttpClient())
|
using (var request = new HttpRequestMessage(HttpMethod.Get, _translateUrl))
|
{
|
var autoHeader = new HttpHeaders().GetBasicAuthorHeader(_accesstoken);
|
request.Headers.Add(autoHeader.Key, autoHeader.Value);
|
var response = httpClient.SendAsync(request).Result;
|
response.EnsureSuccessStatusCode();
|
var responsetext = response.Content.ReadAsStringAsync().Result;
|
var result = JsonHelper.Json2Object<Result<UploadFilePolicyResponse>>(responsetext);
|
if (result.code != Constants.Success)
|
{
|
throw new BimfaceException(result.code);
|
}
|
return result.data;
|
}
|
}
|
|
|
}
|
}
|
