阿里云附件文件流的形式上传、下载

1、View附件上传

@using (Html.BeginForm("StartUpLoad", "ReferenceDocument", new {id = ViewBag.Id}, FormMethod.Post, new {enctype = "multipart/form-data"}))
{
<input type="file" name="filedata" id="fileUpLoad"class="btn btn-success"/><br/>
<input type="submit" value="提交" id="submitFile" class="btn btn-success"/>
<span id="warning" style="color: red; font-size: large;"></span>
}

<script>
var fileTypeBool;
var fileSizeBool;
var file = getNameFromPath($("#fileUpLoad").val());
if (file == null) {
$("#submitFile").attr("disabled", true);
}

//判断文件大小
function GetFileSize(fileid) {
var fileSize = 0;
fileSize = $("#" + fileid)[0].files[0].size;
fileSize = fileSize / 1048576;
return fileSize;
}

//根据路径得到文件名
function getNameFromPath(strFilepath) {
var objRe = new RegExp(/([^\/\\]+)$/);
var strName = objRe.exec(strFilepath);

if (strName == null) {
return null;
} else {
return strName[0];
}
}

//当更换文件时触发Change事件对其文件类型和文件大小进行验证：
$("#fileUpLoad").change(function() {
var file = getNameFromPath($(this).val());

if (file != null) {
var errors = $(document).find(".field-validation-error");
$.each(errors,
function(k, v) {
if ($(v).attr("data-valmsg-for") === "fileUpLoad") {
$(v).hide();
}
});
var extension = file.substr((file.lastIndexOf(‘.‘) + 1));
switch (extension) {
case ‘pdf‘:
fileTypeBool = false;
break;
default:
fileTypeBool = true;
}
}
if (fileTypeBool) {
$("#warning").html("只能上传扩展名为pdf的文件！");
$("#submitFile").attr("disabled", true);
return false;
} else {
var size = GetFileSize(‘fileUpLoad‘);
if (size > 10) {
fileSizeBool = true;
$("#warning").html("上传文件已经超过10兆！");
$("#submitFile").attr("disabled", true);
} else {
fileSizeBool = false;
$("#submitFile").attr("disabled", false);
$("#warning").html("");
}
}
return false;
});

$("#submitFile").submit(function () {
var file = getNameFromPath($(this).val());

alert(fileTypeBool);
alert(fileSizeBool);
if (fileTypeBool || fileSizeBool) {
return false;
}
$("input[type=‘text‘]").each(function(k, v) {
if ($(v).length) {
$(v).siblings("span").hide();
}
});
return false;
});
</script>

2、控制器处理文件流

/// <summary>
/// 1、创建Oss服务实例
/// </summary>
/// <returns></returns>
private static OssClient CreatOssClient()
{
return new OssClient(Config.OssConfig.EndpointUri, Config.OssConfig.AccessKeyId,
Config.OssConfig.AccessKeySecret);
}

/// <summary>
////2、pdf附件上传
/// </summary>
/// <param name="id">唯一标识</param>
/// <param name="filedata"></param>
/// <returns></returns>
[CustomAuthorize]
[HttpPost]
public ActionResult StartUpLoad(long id, HttpPostedFileBase filedata)
{
try
{
#region 判断文件大小、类型

const int maxContentLength = 1024 * 1024 * 10;
if (string.IsNullOrEmpty(filedata?.FileName) || filedata.ContentLength == 0)
{
return HttpNotFound("附件不存在");
}
if (filedata.ContentLength > maxContentLength)
{
throw new Exception($"上传图片过大，不能超过{maxContentLength / 1024}兆");
}
if (!filedata.ContentType.Equals("application/pdf"))
{
throw new Exception("只能上传pdf文件");
}
var user = LoginFactory.GetCurrentLoginUser();
if (user == null) throw new ArgumentException("当前用户未登录");
var fileOssSaveName = $"{Guid.NewGuid().ToString()}.pdf";
var fielSqlSaveName = filedata.FileName;

#endregion

#region 保存文件到阿里云OSS

#region 初始化OSS实例

var bucketName = Config.OssConfig.ClimsBucketName;
var ossClient = CreatOssClient();

#endregion

if (!ossClient.DoesBucketExist(bucketName))
{
throw new ArgumentException($"阿里云存储空间{bucketName}不存在");
}

#region 判断Oss是否存在模拟文件夹（文件名/）

const string folderName = "refdocfiles"; //存储文件的文件夹（refdocfiles/）
if (!ossClient.DoesObjectExist(bucketName, folderName + "/"))
{
using (var stream = new MemoryStream(new byte[0]))
{
ossClient.PutObject(bucketName, folderName + "/", stream);
}
}

#endregion

#region 使用inputStream上传文件

var metadata = new ObjectMetadata
{
ContentEncoding = "utf-8",
ContentType = "application/pdf"
};
var bytes = new byte[filedata.ContentLength];
filedata.InputStream.Read(bytes, 0, bytes.Length);
var putObject = ossClient.PutObject(bucketName, folderName + "/" + fileOssSaveName,
new ByteArrayInputStream(bytes), metadata);

#endregion

#endregion

#endregion

#region 附件上传信息保存数据库

var document = new ReferenceDocument()
{
Id = id,
FileName = fielSqlSaveName,
FilePath = folderName + $"/{fileOssSaveName}", //相对路径
UpLoadUserId = user.UserId,
UpLoadTime = DateTime.Now
};
RequestHelper.PostT("api/UploadRecord", document);

#endregion

return Content("<script>alert(‘技术依据附件上传成功!‘);window.open(‘" +
Url.Content(@"/ReferenceDocument/Index") +
"‘, ‘_self‘);</script>");
}
catch (Exception e)
{
Console.WriteLine(e);
throw new Exception(e.Message);
}
}

#region 附件下载

/// <summary>
/// 附件下载
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[CustomAuthorize]
public FileResult DownFile(long id)
{
try
{
var user = LoginFactory.GetCurrentLoginUser();
if (user == null)
{
throw new ArgumentException("当前用户未登录");
}
var refDoc = ReferenceDocumentBll.Retrieve(id);
if (refDoc == null)
{
throw new ArgumentException("未找到依据");
}

#region 初始化OSSClient实例

var bucketName = Config.OssConfig.ClimsBucketName;
var ossClient = CreatOssClient();
if (!ossClient.DoesObjectExist(bucketName, refDoc.FilePath))
{
throw new ArgumentException("附件不存在");
}

#endregion

#region 文件读取

var fileObject = ossClient.GetObject(bucketName, refDoc.FilePath);
return File(fileObject.Content, "application/octet-stream",
HttpUtility.UrlEncode(refDoc.FileName, Encoding.UTF8));

#endregion
}
catch (Exception ex)
{
throw new Exception(ex.ToString());
}
}

#endregion