Framework版本：.Net Framework 4
1、FileInfo实体
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using MongoDB.Bson;
using ReligionServer.util;
using ReligionServer.constant; namespace ReligionServer.Model
{
//为什么会有多余的get set方法，因为测试写的，没有删
//封装的一个文件类, 文件基本信息
public class FileInfo
{ public ObjectId _id; public String FileCode { get; set; }//目前还没有研究出ObjectId序列化的最好解决方式, 所以暂时使用FileCode替代Id
public String Name { get; set; }
public String Type { get; set; }
public String Desc { get; set; }
public String Path { get; set; }
public int Access { get; set; }
public String ForeignKey { get; set; }
public DateTime CreateTime { get; set; }
public String TypeCode { get; set; }//辅助字段 public FileInfo() { } public void set_Id(ObjectId id)
{
this._id = id;
} public ObjectId get_Id()
{
return this._id;
} public void setFileCode()
{
this.FileCode = CommonUtil.CreateId();
} public String getFileCode()
{
return this.FileCode;
} public void setName(String name)
{
this.Name = name;
} public String getName()
{
return this.Name;
} public void setType(String type)
{
this.Type = FileTypeConstant.GetType(type);
} public String getType()
{
return this.Type;
} public void setDesc(String desc)
{
this.Desc = desc;
} public String getDesc()
{
return this.Desc;
} public void setPath(String path)
{
this.Path = path;
} public String getPath()
{
return this.Path;
} public void setAccess(int access)
{
this.Access = access;
} public int getAccess()
{
return this.Access;
} public void setForeignKey()
{
this.ForeignKey = CommonUtil.CreateId();
} public String getForeignKey()
{
return this.ForeignKey;
} public void setCreateTime()
{
this.CreateTime = DateTime.Now;
} public DateTime getCreateTime()
{
return this.CreateTime; } public void setTypeCode(String code)
{
this.TypeCode = code;
} public String getTypeCode()
{
return this.TypeCode;
} }
}
2、Handler具体实现
using System; using System.IO;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using ReligionServer.util;
using ReligionServer.Model;
using ReligionServer.service;
using System.Text.RegularExpressions; namespace ReligionServer.handler
{
/// <summary>
/// FileHandler 的摘要说明
/// 处理文件请求
/// </summary>
public class FileHandler : BaseHandler, IHttpHandler
{ private FileInfoService fileInfoService = new FileInfoService();
private readonly String targetSavePath = "~/ReligionFile/"; public void ProcessRequest(HttpContext context)
{
base.InitAction(context);
}
#region 文件上传
//和第三方表关联的文件上传初始化逻辑
public void Upload_Foreign(HttpContext context)
{
Model.FileInfo fileInfo = InitFileInfo(context, );
if (CommonUtil.IsEmpty(fileInfo.getForeignKey()))
{
NoParams<Model.FileInfo>(context, "关联外键为空, 还请检测关联属性是否上传成功, 外键是否为空");
}
else if (base.IsEmpty(fileInfo.getTypeCode()))
{
fileInfo.setTypeCode("");
NoParams<Model.FileInfo>(context, "TypeCode is null or '' ...");
}
else
{
List<Model.FileInfo> uploadFileList = FileInsert(context, InitFileInfo(context, ));
if (uploadFileList.Count == )
{
Error<String>(context, new List<String>() { "上传失败: 后台获取文件信息失败" });
}
else
{
int errorCount = (int)context.Items["FileUploadErrorCount"];
int successCount = uploadFileList.Count - errorCount;
Success<String>(context, new List<String>() { "一共上传 " + uploadFileList.Count + "个文件，其中成功 " + successCount + "个，失败" + errorCount + "个" });
}
} } //文件上传初始化逻辑
public void Upload(HttpContext context)
{
Model.FileInfo fileInfo = InitFileInfo(context, );
if (base.IsEmpty(fileInfo.getTypeCode()))
{
fileInfo.setTypeCode("");
NoParams<Model.FileInfo>(context, "TypeCode is null or '' ...");
}
else {
List<Model.FileInfo> uploadFileList = FileInsert(context, fileInfo);
if (uploadFileList.Count == )
{
Error<String>(context, new List<String>() { "上传失败: 后台获取文件信息失败" });
}
else
{
int errorCount = (int)context.Items["FileUploadErrorCount"];
int successCount = uploadFileList.Count - errorCount;
Success<String>(context, new List<String>() { "一共上传 " + uploadFileList.Count + "个文件，其中成功 " + successCount + "个，失败" + errorCount + "个" });
}
}
} /// <summary>
/// 供类相互调用的文件上传
/// </summary>
/// <param name="context"></param>
/// <param name="foreignKey"></param>
/// <returns></returns>
public List<Model.FileInfo> Upload_Invoke(HttpContext context, String foreignKey) {
if (!base.IsEmpty(foreignKey)) {
Model.FileInfo fileInfo = InitFileInfo(context, );
fileInfo.ForeignKey = foreignKey;
List<Model.FileInfo> uploadFileList = FileInsert(context, fileInfo);
return uploadFileList;
}
return new List<Model.FileInfo>();
} //执行文件转存以及数据库记录插入的方法
private List<Model.FileInfo> FileInsert(HttpContext context, Model.FileInfo fileInfo)
{
List<Model.FileInfo> fileInfoList = new List<Model.FileInfo>(); //List<Model.FileInfo> fileInfoList = new List<Model.FileInfo>();
String directoryName = DateUtil.CurrentDateTimeValue();//文件夹名称
//HttpContext.Current.Request.PhysicalApplicationPath 获取当前正在执行的服务器应用程序的根目录的物理文件系统路径
String targetPhysicalFilePath = HttpContext.Current.Request.PhysicalApplicationPath + "ReligionFile/" + directoryName;
//不存在就创建
if (!Directory.Exists(targetPhysicalFilePath))
{
Directory.CreateDirectory(targetPhysicalFilePath);
} //获取上传文件集合
HttpFileCollection fileCollection = context.Request.Files;
//HttpPostedFile temp = context.Request.Files["regfile"];//测试
//String tempe = context.Request.Params["regfile"];
//HttpPostedFileWrapper fileWrapper = context.Request.Files[0]; Model.FileInfo tempFileInfo = null;
if (fileCollection.Count > )
{
HttpPostedFile item = null;
for (int i = ; i < fileCollection.Count; i++)
{
item = fileCollection[i];
String suffix = item.FileName.Split('.')[item.FileName.Split('.').Length - ];//获取文件的后缀名
tempFileInfo = new Model.FileInfo();
tempFileInfo = (Model.FileInfo)BeanUtil.PropCopy(fileInfo, tempFileInfo);
//tempFileInfo.set_Id(CommonUtil.CreateObjectId());这样设置Id是无效的
tempFileInfo.setName(item.FileName);//存的是以前的文件名, 是否有意义
tempFileInfo.setFileCode();
tempFileInfo.setType(suffix);
tempFileInfo.setCreateTime();
suffix = "." + suffix;
if (suffix.ToLower().Equals(".txt"))
{
suffix = ".doc";//这里是否有必要? 这是个问题
}
String realFileName = Guid.NewGuid().ToString() + suffix;
tempFileInfo.setTypeCode(tempFileInfo.getTypeCode() + ":" + "ReligionFile/" + directoryName + "/" + realFileName);
tempFileInfo.setPath("ReligionFile/" + directoryName + "/" + realFileName);
item.SaveAs(context.Server.MapPath(targetSavePath + directoryName + "/" + realFileName));//文件转存 必须是文件的根目录, 而且不能使虚拟目录
fileInfoList.Add(tempFileInfo);
}
//foreach (String key in fileCollection) {
//这里前台只有一个文件选择框, 那么多文件时keys都是相同的,
// HttpPostedFile item = fileCollection[key];
// String suffix = item.FileName.Split('.')[item.FileName.Split('.').Length - 1];//获取文件的后缀名
// fileInfo.setName(item.FileName);
// fileInfo.setFileCode();
// fileInfo.setType(suffix);
// fileInfo.setCreateTime();
// suffix = "." + suffix;
// if (suffix.ToLower().Equals(".txt")) {
// suffix = ".doc";//这里是否有必要? 这是个问题
// }
// String realFileName = Guid.NewGuid().ToString() + suffix;
// fileInfo.setTypeCode(fileInfo.getTypeCode() + ":" + "ReligionFile/" + directoryName + realFileName);
// item.SaveAs(context.Server.MapPath(targetSavePath + directoryName + "/" + realFileName));//文件转存 必须是文件的根目录, 而且不能使虚拟目录
// fileInfoList.Add(fileInfo);
//}
int errorCount = fileInfoService.InsertBatchFileInfo(fileInfoList);//文件信息批量入表, 返回失败个数
context.Items.Add("FileUploadErrorCount", errorCount); } return fileInfoList; } /// <summary>
/// Base64格式的图片上传
/// </summary>
/// <param name="context"></param>
public void Insert_Base64_Img(HttpContext context)
{
vo.Base64Image base64Image = base.GetInstance<vo.Base64Image>(context, new vo.Base64Image());
if (base.IsEmpty(base64Image.Base64String))
{
NoParams<vo.Base64Image>(context, "上传参数存在空值");
}
else
{
List<Model.FileInfo> fileInfoList = util.ImageUtil.Base64ImageInsertBatch(context, util.ArrraysUtil.PurifyArrays<String>(Regex.Split(base64Image.Base64String, "c#", RegexOptions.IgnoreCase)));
if (fileInfoList.Count > )
{
int errorCount = fileInfoService.InsertBatchFileInfo(fileInfoList);
int successCount = fileInfoList.Count - errorCount;
Success<String>(context, new List<String>() { "一共上传 " + fileInfoList.Count + "个文件，其中成功 " + successCount + "个，失败" + errorCount + "个" });
}
else
{
Error<String>(context, new List<String>() { "上传失败: 后台将Base64转存时失败" });
}
}
} #endregion #region 文件删除 /// <summary>
/// 根据ObjectId删除指定的文件信息
/// </summary>
/// <param name="context"></param>
public void Del_ObjectId(HttpContext context)
{
//暂时不做
} /// <summary>
/// 根据FileCode删除指定的文件信息
/// </summary>
/// <param name="context"></param>
public void Del_FileCode(HttpContext context)
{
Model.FileInfo fileInfo = this.InitFileInfo(context, -);
fileInfo = fileInfoService.FindFileInfoByFileCode(fileInfo.getFileCode());
if (fileInfo != null)
{
if (fileInfoService.RemoveFileInfoByFileCode(fileInfo.getFileCode()))
{
RemoveLocalFile(fileInfo);
Success<Model.FileInfo>(context, new List<Model.FileInfo>() { fileInfo });
}
else
{
Error<Model.FileInfo>(context, new List<Model.FileInfo>() { fileInfo });
}
}
else
{
NoParams<Model.FileInfo>(context, "该条记录不存在，无法删除");
}
} /// <summary>
/// 根据外键ForeignKey删除所关联的文件信息
/// </summary>
/// <param name="context"></param>
public void Del_ForeignKey(HttpContext context)
{ } /// <summary>
/// 根据传递进来的FileInfo的path字段删除服务器上对应的文件
/// </summary>
/// <param name="fileInfo"></param>
private void RemoveLocalFile(Model.FileInfo fileInfo)
{
System.Diagnostics.Debug.WriteLine(HttpContext.Current.Request.PhysicalApplicationPath + fileInfo.getPath());
//FileUtil.RemoveFile(context.Request.PhysicalApplicationPath + fileInfo.getPath());
FileUtil.RemoveFile(HttpContext.Current.Request.PhysicalApplicationPath + fileInfo.getPath());
} #endregion #region 文件修改 /// <summary>
/// 根据FileCode修改指定的文件信息
/// </summary>
/// <param name="context"></param>
public void Update_FileCode(HttpContext context)
{
Model.FileInfo target = InitFileInfo(context, -);
String fileCode = target.getFileCode();
List<Model.FileInfo> list = null;
if (CommonUtil.IsEmpty(target.getForeignKey()) || CommonUtil.IsEmpty(target.getFileCode()))
{
NoParams<Model.FileInfo>(context, "关联外键ForeignKey或FileCode为空");
}
else
{
list = FileInsert(context, InitFileInfo(context, ));
}
if (null != list)
{
target = list[];
target.FileCode = fileCode;
Model.FileInfo source = fileInfoService.FindFileInfoByFileCode(target.getFileCode());
if (null != source)
{
target._id = source._id;
target.Access = source.Access;
target.ForeignKey = source.ForeignKey;
if (fileInfoService.UpdateAllByFileCode(target))
{
RemoveLocalFile(source);//如果上传成功, 就将原来的文件删除
Success<Model.FileInfo>(context, new List<Model.FileInfo>() { fileInfoService.FindFileInfoByFileCode(target.FileCode) });
}
else
{
Error<Model.FileInfo>(context, new List<Model.FileInfo>() { target });
RemoveLocalFile(target);//如果更新失败, 就将上传的文件删除
}
}
else
{
Init<Model.FileInfo>(context, "", "", new List<Model.FileInfo>() { });
}
}
} #endregion #region 文件查找 /// <summary>
/// 根据FileCode查找指定的文件信息
/// </summary>
/// <param name="context"></param>
public void Query_FileCode(HttpContext context)
{
Model.FileInfo fileInfo = fileInfoService.FindFileInfoByFileCode(this.InitFileInfo(context, -).FileCode);
if (fileInfo == null)
{
NoParams<Model.FileInfo>(context, "该记录不存在");
}
else
{
Success<Model.FileInfo>(context, new List<Model.FileInfo>() { fileInfo });
}
} /// <summary>
/// 根据ForeignKey查询所有的文件信息
/// </summary>
/// <param name="context"></param>
public void Query_Foreign(HttpContext context)
{
//Model.FileInfo info = this.InitFileInfo(context, -1);
List<Model.FileInfo> list = fileInfoService.FindFileInfoListByForeignKey(this.InitFileInfo(context, -).ForeignKey);
//if (list == null || list.Count == 0) {
// NoParams<Model.FileInfo>(context, "没有匹配的记录");
//} else {
// Success<Model.FileInfo>(context, list);
//}
Success<Model.FileInfo>(context, list);
} #endregion
//初始化FileInfo
private Model.FileInfo InitFileInfo(HttpContext context, int access)
{
Model.FileInfo fileInfo = ParametersUtil.GetInstanceFormRequest<Model.FileInfo>(context, new Model.FileInfo());//这里主要是获取ForeignKey if (access != -)
{
fileInfo.setAccess(access);//设置文件资源类型 {0表示关联; 1表示独立资源,没有关联} -1表示不作处理
}
return fileInfo;
} public bool IsReusable
{
get
{
return false;
}
}
}
}