导入excel-uploadify+npoi
总结:
- 导入文件时一定要给database设置栏位
- 虚拟表的栏位名称可以与数据库表不一致,但顺序一定要一致,因为它是按照顺序依次插入的
- sheet.FirstRowNum = 0; sheet.FirstCellNum = 1; getRow、getCell从0开始
- 设置的虚拟表字段不赋值时默认为空null
- 虚拟表字段为空时,dt.Rows[i][j].Tostring()="";
前台代码
//第一步:定义按钮
<a class="mini-button" iconcls="icon-upload" onclick="uploadExcel()">导入</a>
//第二步:定义弹出框
<div id="win" class="mini-window" title="Window"style="width:300px;height:200px;"showmodal="true">
<div id="case_0"></div>//导入所需容器
<div id="case_1"> //菜单容器
<a href="javascript:$('#file_upload').uploadify('upload', '*')">上传</a>
<a href="#">|</a>
<a href="javascript:leading_in()">导入</a>
<a href="#">|</a>
<a href="javascript:clear()">清空队列</a>
</div>
</div>
//第三步:js按钮触发事件
function onclick() {
win.setTitle("请选择上传文件");
win.show();
$("#case_0").empty();
$("#case_0").append("<input type='file' id='file_upload' />");
$("#case_1").hide();
initSendFile();
}
//第四步:初始化上传控件
var file_name = null;
function initSendFile() {
$("#file_upload").uploadify({
'swf': '../../Scripts/uploadify-v3.1/uploadify.swf',
'uploader': '/Equipment/Upload',
buttonText: '请选择上传文件',
fileTypeExts: '*.xls;*.xlsx;',
auto: false,
multi: false,
uploadLimit: 1,
'onUploadSuccess': function (file, data, response) {
if (response == true) {
mini.alert("上传成功");
var data = mini.decode(data);
file_name = data.SaveName;
}
},
'removeCompleted': false,
'onDialogClose': function (queueData) {
if (queueData.filesQueued !='0') {
$("#repeat2").show();
}
},
'onCancel': function (file) {
$("#repeat2").hide();
}
});
}
//第五步:上传文件到服务器指定位置
public JsonResult Upload(HttpPostedFileBase fileData){
if (fileData != null)
{
try
{
string saveName = Guid.NewGuid().ToString();
string filePath = Server.MapPath("~/Uploads/UploadExcel/" + saveName);
if (!Directory.Exists(filePath)){ Directory.CreateDirectory(filePath);}
string fileName = Path.GetFileName(fileData.FileName);// 原始文件名称
string fileExtension = Path.GetExtension(fileName); // 文件扩展名
fileData.SaveAs(filePath+"\\" + saveName + fileExtension);//将fileData保存到指定路径后两个参数指定文件名
return Json(new { Success = true, FileName = fileName, SaveName = saveName },JsonRequestBehavior.AllowGet);
}
catch (Exception ex)
{
LogHelper.WriteLog("EquipmentController.Upload",ex);
return Json(new { Success = false, Message = ex.Message }, JsonRequestBehavior.AllowGet);
}
}
else { return Json(new { Success = false, Message = "请选择要上传的文件!" }, JsonRequestBehavior.AllowGet); }
}
//第六步:(1)将上传到服务器的文件导入数据库-js部分
function toDB() {
$.ajax({
type: 'post',
async: false,
data: { file_name: file_name },
url: '/Equipment/toDB',
success: function (result) {
var result = mini.decode(result);
if (result.Success == true) {
mini.alert(result.Message);
win3.hide();
dg.reload();
tree.reload();
file_name = null;
} else {
mini.alert(result.Message);
}
},
error: function () {
mini.alert("导入失败!");
file_name = null;
}
});
}
//第六步:(2)将上传到服务器的文件导入数据库-控制器部分
public ActionResult toDB( string file_name )
{
if (file_name != null)
{
try
{
string filePath = Server.MapPath("~/Uploads/uploadExcel/" + file_name);
if (!Directory.Exists(filePath)) { Directory.CreateDirectory(filePath); }
string[] filelist = Directory.GetFiles(filePath);//将导入的文件
string fileName = Path.GetFileName(filelist[0]);//将导入的文件名称
Jxd.Mvc.Domain.Model.FileInfo filedate = new Jxd.Mvc.Domain.Model.FileInfo();
filedate.AnnexName = fileName;
filedate.AnnexPath = filePath+"\\" + fileName;
this.EquipmentService.toDB(filedate, filePath);
return Json(new { Success = true ,Message = "导入成功"},JsonRequestBehavior.AllowGet);
}
catch (Exception ex)
{
LogHelper.WriteLog("ExceptionController.toDB", ex);
return Json(new { Success = false,Message = "请确保单元格内容正确!"});
}
}
else { return Json(new { Success = false, Message = "没有可导入的文件!"},JsonRequestBehavior.AllowGet); }
}
//第七步:将上传到服务器的文件导入数据库-dao层部分
public void toDB(Jxd.Mvc.Domain.Model.FileInfo filedate,string filePath)
{
try
{
//第1步:定义文件输入流
string path = filedate.AnnexPath;
FileStream stream = new FileStream(path, FileMode.Open, FileAccess.Read);
//第二步:判断excel的版本,创建工作簿,工作表
string fileName = filedate.AnnexName;
if (fileName.IndexOf(".xlsx") > 0){ workbook = new XSSFWorkbook(stream); }
else if ( fileName.IndexOf(".xls" ) > 0) { workbook = new HSSFWorkbook(stream); }
if (sheet == null) { sheet = workbook.GetSheetAt(0); }
//第三步:设置虚拟表栏位
DataTable dt = new DataTable();
DataColumn field = null;
field = new DataColumn("栏位一"); dt.Columns.Add(field);
field = new DataColumn("栏位二"); dt.Columns.Add(field);
//第四步:创建字典用于渲染字段
//第五步:数据插入虚拟表
for (int i = sheet.FirstRowNum + 3; i <= sheet.LastRowNum; i++){
IRow ergodic_row = sheet.GetRow(i);
int num = ergodic_row.LastCellNum;
DataRow dataRow_1 = dt.NewRow();
dataRow_1[0] = Guid.NewGuid().ToString();
dataRow_1[1] = ergodic_row.GetCell(3).ToString();
dataRow_1[2] = ergodic_row.GetCell(8).StringCellValue;
string b = @"^[0-9]+(\\.[0-9]+)?$";
RegexStringValidator regex = new RegexStringValidator(b);
if (ergodic_row.GetCell(10) != null){
try
{
regex.Validate(ergodic_row.GetCell(10).ToString());
dataRow_1[13] = ergodic_row.GetCell(10).ToString();
}
catch
{
continue;
}
}
//第六步:将虚拟表导入数据库
string connString = ConfigurationManager.AppSettings["SqlConnection"];
SqlConnection conn = new SqlConnection(connString);
conn.Open();
SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(conn);
sqlbulkcopy.DestinationTableName = "TB_BASEEQ_EQUIPMENT";
sqlbulkcopy.NotifyAfter = dt.Rows.Count;//有几行数据
sqlbulkcopy.WriteToServer(dt);//数据导入数据库
sqlbulkcopy.Close();//关闭连接
if (Directory.Exists(filePath)) { Directory.Delete(filePath, true); }
}
}
catch(Exception ex){
throw ex;
}
}
最新文章
- EntityFramework 7 Left Join Where Select 奇怪问题
- Mysql中的Prepared Statement与Stored Precedure学习
- JS中遍历普通数组和字典数组的区别
- normalization归一化
- leetcode: sortlist之四种方法
- 【深圳,武汉】一加科技(One Plus)招聘,寻找不...
- 使用ServletFileUpload实现上传
- Jekyll报&#39;Tag was never closed&#39;错误
- prism silverlight
- 【Android Developers Training】 31. 序言:共享简单数据
- Mego开发文档 - 保存关系数据
- int i=0;i=i++
- Tomcat虚拟路径访问本地图片失败的问题
- 一个强大的VS代码搜索工具
- kali linux 安装wps office
- Unity Shader Graph(一)初次尝试
- nodeJS实现一个在线填表应用
- Javascript 闭包(Closures)
- Django框架----视图函数补充
- jQuery控制a标签不可用
热门文章
- Nginx-rtmp点播之complex handshake
- Python 之类与对象及继承
- FinalShell Mac OS版,Linux版安装及教程(Mac下的xshell)
- ubuntu下如何高速下载?
- UI的流畅度优化
- __linux__、__POSIX__宏
- 看日志有没有 出现错误的字段 (如 crash ) 查找app闪退
- zabbix(1)基础知识
- Rxjava2实战--第四章 Rxjava的线程操作
- Rxjava2实战--第三章 创建操作符