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替代Idpublic 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;}}
}

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, 0);if (CommonUtil.IsEmpty(fileInfo.getForeignKey())){NoParams<Model.FileInfo>(context, "关联外键为空, 还请检测关联属性是否上传成功, 外键是否为空");}else if (base.IsEmpty(fileInfo.getTypeCode())){fileInfo.setTypeCode("0");NoParams<Model.FileInfo>(context, "TypeCode is null or  '' ...");}else{List<Model.FileInfo> uploadFileList = FileInsert(context, InitFileInfo(context, 0));if (uploadFileList.Count == 0){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, 1);if (base.IsEmpty(fileInfo.getTypeCode())){fileInfo.setTypeCode("0");NoParams<Model.FileInfo>(context, "TypeCode is null or  '' ...");}else {List<Model.FileInfo> uploadFileList = FileInsert(context, fileInfo);if (uploadFileList.Count == 0){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, 0);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 > 0){HttpPostedFile item = null;for (int i = 0; i < fileCollection.Count; i++){item = fileCollection[i];String suffix = item.FileName.Split('.')[item.FileName.Split('.').Length - 1];//获取文件的后缀名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 > 0){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, -1);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, -1);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, 0));}if (null != list){target = list[0];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, "300", "", 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, -1).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, -1).ForeignKey);//if (list == null || list.Count == 0) {//    NoParams<Model.FileInfo>(context, "没有匹配的记录");//} else {//    Success<Model.FileInfo>(context, list);//}Success<Model.FileInfo>(context, list);}#endregion//初始化FileInfoprivate Model.FileInfo InitFileInfo(HttpContext context, int access){Model.FileInfo fileInfo = ParametersUtil.GetInstanceFormRequest<Model.FileInfo>(context, new Model.FileInfo());//这里主要是获取ForeignKeyif (access != -1){fileInfo.setAccess(access);//设置文件资源类型  {0表示关联; 1表示独立资源,没有关联} -1表示不作处理
            }return fileInfo;}public bool IsReusable{get{return false;}}}
}