--------------------------------------------------------------后台代码------------------------------------------
public JsonResult ImportPDF(Int64
id)
{
try
{
Guid currentGuid =
Guid.NewGuid();
if
(Request.Files["FileData"].HasFile())
{
HttpPostedFileBase file =
Request.Files["FileData"];
//if (file.InputStream.Length >
16*1024*1024)
//{
// throw new
Exception("文件过大，导入不成功！");
//}
CreateFolder();
string path =
Server.MapPath("/Ebook");
string fileName =
"1.pdf";
//Directory.CreateDirectory(path);
file.SaveAs(string.Format(@"{0}\{1}", path,
fileName));
PDFText(string.Format(@"{0}\{1}", path, fileName), id,
currentGuid);
}
return Json(currentGuid.ToString(),
JsonRequestBehavior.AllowGet);
}
catch
(Exception
ex)
{
throw ex;
}
}
///
<summary>
///
获取导入PDF的进度
///
</summary>
///
<returns></returns>
public JsonResult GetPdfProgress(string
guidStr)
{
try
{
Guid guid = new
Guid(guidStr.Trim(‘"‘));
if
(pdfProDic.ContainsKey(guid))
{
return Json(new { guidKey = guidStr, proVal = pdfProDic[guid] },
JsonRequestBehavior.AllowGet);
}
return Json(new {guidKey = guidStr},
JsonRequestBehavior.AllowGet);
}
catch
(Exception
ex)
{
throw ex;
}
}
//注意要使用静态(字典与GUID为了应对多人同时访问)
static Dictionary<Guid,int> pdfProDic=new Dictionary<Guid, int>();
public void PDFText(string
fileName, Int64 id,Guid guid)
{
System.Threading.Tasks.Task.Factory.StartNew(user
=>
{
try
{
pdfProDic.Add(guid,0);
Domain.UserModel.User currentUser = user as
Domain.UserModel.User;
if (user !=
null)
{
#region
执行pdf导入数据库
//注意加载PDF文件过大会出错
PDDocument doc =
PDDocument.load(fileName);
PDFTextStripper pdfStripper = new
PDFTextStripper();
short currentPage =
GetMaxPageNumber(id);
if (currentPage <
10000)
currentPage =
10000;
float j =
0;
int progress =
0;
for (int i = 0; i < doc.getNumberOfPages();
i++)
{
currentPage++;
//索引是从0开始，第一页表示0~1
pdfStripper.setStartPage(i);
pdfStripper.setEndPage(i +
1);
String pdfStr =
pdfStripper.getText(doc);
var target = EntAppFrameWorkContext.Application.ExtenedT<Ebook, Int64,
EbookAppExt>().
CreatePage(
id,
currentPage,
pdfStr,
currentUser);
j =
i+1;
progress = (int)((j / doc.getNumberOfPages()) *
100);
if (Convert.ToInt32(j) >=
doc.getNumberOfPages())
{
progress =
100;
//为了性能的提升，这时候进行排序
EntAppFrameWorkContext.Application.ExtenedT<Ebook,Int64,EbookAppExt>().InitEbookPage(id);
}
pdfProDic[guid] =
progress;
}
doc.close();
#endregion
}
}
catch (Exception
ex)
{
throw
ex;
}
},
base.CurrentUser);
}