Simon
/
Tiobon.Web.Core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增Excel数据导入接口

Browse Source
master
xiaochanghai 1 year ago
parent 5411524e14
commit 2c4fa252eb
6 changed files with 825 additions and 24 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 16
      Tiobon.Core.Api/Controllers/CommonController.cs
  2. 10
      Tiobon.Core.Api/Tiobon.Core.xml
  3. 791
      Tiobon.Core.DataAccess/ReportHelper.cs
  4. 5
      Tiobon.Core.IServices/ICommonServices.cs
  5. 8
      Tiobon.Core.Services/BASE/BaseServices.cs
  6. 19
      Tiobon.Core.Services/CommonServices.cs

16
Tiobon.Core.Api/Controllers/CommonController.cs
Unescape View File

@ -87,4 +87,20 @@ public class CommonController : BaseApiController
return await _commonServices.DownImportTemplateAsync(param);
}
#endregion
#region Excel导入
/// <summary>
/// Excel导入
/// </summary>
/// <param name="file">文件</param>
/// <param name="menuName">菜单编号</param>
/// <param name="userId">用户ID</param>
/// <param name="langId">多语</param>
/// <returns></returns>
[HttpPost, Route("ImportExcel")]
public async Task<ServiceResult<QueryExportReturn>> ImportExcelAsync(IFormFile file, string menuName, int userId, int langId = 1)
{
return await _commonServices.ImportExcelAsync(file, menuName, langId, userId);
}
#endregion
}

10
Tiobon.Core.Api/Tiobon.Core.xml
Unescape View File

@ -272,6 +272,16 @@
<param name="param"></param>
<returns></returns>
</member>
<member name="M:Tiobon.Core.Controllers.CommonController.ImportExcelAsync(Microsoft.AspNetCore.Http.IFormFile,System.String,System.Int32,System.Int32)">
<summary>
Excel导入
</summary>
<param name="file">文件</param>
<param name="menuName">菜单编号</param>
<param name="userId">用户ID</param>
<param name="langId">多语</param>
<returns></returns>
</member>
<member name="M:Tiobon.Core.Controllers.DbFirstController.#ctor(SqlSugar.ISqlSugarClient,Microsoft.AspNetCore.Hosting.IWebHostEnvironment)">
<summary>
构造函数

791
Tiobon.Core.DataAccess/ReportHelper.cs
Unescape View File

@ -1,4 +1,5 @@
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Data;
@ -7,8 +8,6 @@ using System.Linq;
using System.Linq.Dynamic.Core;
using System.Text;
using System.Threading.Tasks;
using Google.Protobuf.Collections;
using Microsoft.AspNetCore.Mvc.ModelBinding;
using NPOI.HSSF.UserModel;
using NPOI.OpenXmlFormats.Spreadsheet;
using NPOI.SS.UserModel;
@ -16,7 +15,6 @@ using NPOI.SS.Util;
using NPOI.XSSF.UserModel;
using SqlSugar;
using Tiobon.Core.Common;
using Tiobon.Core.Common.DB.Dapper;
using Tiobon.Core.Common.Extensions;
using Tiobon.Core.Model.Models;
@ -294,22 +292,6 @@ public static class ReportHelper
}
}
////月排班维护写入下拉数据
//if (menuName == "F_SchedulePeriodSetup")
//{
// string listSql = @" select ParaDetailNo 日期类别编号,ParaDetailName 日期类别名称 from Ghrs_ParaDetail where ParaMasterNo = 'DateType' and IsEnable = 1;
// select ShiftNo 班次编号,ShiftName 班次名称 from Ghrb_Shift where IsEnable = 1;
// select ShiftGroupNo 班组编号,ShiftGroupName 班组名称 from Ghrb_ShiftGroup where IsEnable = 1; ";
// InsertExcelList(sheet2, listSql);
//}
//// 生成部门Sheet
//if (tableColumn.Rows.Cast<DataRow>().Any(x => x["dataSource"].ToString().StartsWith("OrgTreeWith")))
//{
// ISheet sheetDept = fileWorkbook.CreateSheet("部门数据");
// string listSql = @" select DeptNo 部门编号,DeptName 部门名称 from Ghro_Dept where IsEnable = 1 and convert(date,getdate()) between BeginDate and ISNULL(EndDate,'2099-12-31') ";
// InsertExcelList(sheetDept, listSql);
//}
// Sheet 更改列为自适应宽度
for (int col = 0; col <= ColNums; col++)
{
@ -523,6 +505,726 @@ public static class ReportHelper
return IsBool;
}
/// <summary>
/// 是否隐藏首行
/// </summary>
public static bool IsHideTopRow = false;
/// <summary>
/// 读取Excel写入临时表，逻辑在存储过程里写
/// </summary>
/// <returns></returns>
public static async Task<string> ExcelToDataTable(ISqlSugarClient Db, string FilePath, string menuName, int LangID, int UserID, string doType = null, string procName = null)
{
string result = string.Empty;
int ErrorNum = 0;
int SuccessNum = 0;
DataTable mydt = GetDataTable(FilePath, 0, null);
if (mydt.Columns["Comments"] == null)
{
mydt.Columns.Add("Comments", typeof(string));
}
mydt.Rows[0]["Comments"] = "提示信息";
//从第二行开始读取
int FirstI = 1;
IsHideTopRow = true;
//创建GUID;
string guidN = Guid.NewGuid().ToString("N");
DataTable edt = new DataTable();
edt.Columns.Add("ExcelNums", typeof(int));//
edt.Columns.Add("GID", typeof(string));//
edt.Columns.Add("LangID", typeof(int));//
edt.Columns.Add("UserID", typeof(int));//
edt.Columns.Add("DoType", typeof(string));//
edt.Columns.Add("ProcName", typeof(string));//
edt.Columns.Add("MenuName", typeof(string));//
edt.Columns.Add("JsonColumns", typeof(string));//
// 获取对应的字段设定
DataSet ds = new DataSet();
if (menuName != "F_SchedulePeriodSetup")
ds = await GetTableColumn(Db, LangID, UserID, menuName, null);
DataTable tableColumn = ds.Tables.Count > 0 ? ds.Tables[0] : new DataTable();
List<DataSourceList> dataSourceLists = new List<DataSourceList>();
foreach (DataRow dr in tableColumn.Rows)
{
// 验证导入列是否一致
if (!mydt.Columns.Contains(dr["field"].ToString()) && doType != "Update")
{
throw new Exception("导入模板不匹配或模板字段已更新，请重新下载导入模板");
}
string dataSource = dr["dataSource"].ToString();
string field = dr["field"].ToString();
if (!string.IsNullOrEmpty(dataSource))
{
List<DataSourceList> dataSourceList = GetDataSourceLists(Db, field, dataSource);
dataSourceLists.AddRange(dataSourceList);
}
}
int AllNums = 0;
// 判断是否为流程，流程直接返回对应信息
string IsFlow = "N";
StringBuilder jsonListBuilder = new StringBuilder();
jsonListBuilder.Append("[");
//循环读取的Excel行
for (int i = FirstI; i < mydt.Rows.Count; i++)
{
AllNums++;
StringBuilder jsonBuilder = new StringBuilder();
jsonBuilder.Append("{");
string errorMsg = string.Empty;
//// 遍历列
foreach (DataColumn dc in mydt.Columns)
{
if (dc.ColumnName != "Process" && dc.ColumnName != "Comments" && dc.ColumnName != "" && dc.ColumnName != "ExcelNums")
{
string value = mydt.Rows[i][dc.ColumnName].ToString();
string value_label = value;
//判断对应的字段设定
DataRow[] rows = ds.Tables.Count > 0 ? tableColumn.Select(" field = '" + dc.ColumnName + "' ") : null;
if (rows != null && rows.Length > 0)
{
DataRow fieldRow = rows[0];
// 必填字段为空
if (fieldRow["required"].ToString() == "true" && string.IsNullOrEmpty(value))
{
errorMsg = errorMsg + fieldRow["label"].ToString() + "不能为空；";
}
string dataSource = fieldRow["dataSource"].ToString();
//下拉数据反读值
//if (!string.IsNullOrEmpty(dataSource) && !string.IsNullOrEmpty(value)
// // 默认值处理
// && !(value == "*" && menuName.StartsWith("F_StaffChange")))
//{
// //// Dept
// if (dataSource.StartsWith("OrgTreeWith"))
// {
// string DeptID = string.Empty;
// // 部门需要一级一级写入，不判断父级层级
// if (menuName != "F_AllDept" && menuName != "F_Dept")
// {
// try
// {
// //验证部门编号填写是否错误
// string DeptTest = string.Format(@"select STUFF((select ','+value
// from dbo.Fs1_GHR30_SplitString('{0}',',')
// where value != '' and value not in (select DeptNo from Ghro_Dept where ISEnable=1)
// for XML path(''),type).value('.','nvarchar(max)'),1,1,'');",
// value);
// DeptTest = DataAccess.SelectSingleValueNotKey("SqlGhr30" + "Demo", DeptTest).ToString();
// if (!String.IsNullOrEmpty(DeptTest))
// {
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值(" + DeptTest + ")错误；";
// }
// else
// {
// string deptExists = string.Format(@"select stuff((select ',' + CONVERT(nvarchar(10),DeptID)
// from Ghro_Dept
// where IsEnable=1
// and DeptNo in (select value from dbo.Fs1_GHR30_SplitString('{0}',','))
// for XML path(''),type).value('.','nvarchar(max)'),1,1,'');",
// value);
// DeptID = DataAccess.SelectSingleValueNotKey("SqlGhr30" + "Demo", deptExists).ToString();
// value = DeptID;
// //if (String.IsNullOrEmpty(value))
// // errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// }
// }
// catch (Exception)
// {
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// }
// }
// }
// //// Staff
// else if (dataSource.StartsWith("StaffWith"))
// {
// string StaffID = string.Empty;
// try
// {
// //验证工号填写是否错误
// string StaffTest = string.Format(@"select STUFF((select ','+value
// from dbo.Fs1_GHR30_SplitString('{0}',',')
// where value != '' and value not in (select StaffNo from Ghra_Staff where ISEnable=1)
// for XML path(''),type).value('.','nvarchar(max)'),1,1,'');",
// value);
// StaffTest = DataAccess.SelectSingleValueNotKey("SqlGhr30" + "Demo", StaffTest).ToString();
// if (!String.IsNullOrEmpty(StaffTest))
// {
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值(" + StaffTest + ")错误；";
// }
// else
// {
// string staffExists = string.Format(@"select stuff((select ',' + CONVERT(nvarchar(10),StaffID)
// from Ghra_Staff
// where IsEnable=1
// and StaffNo in (select value from dbo.Fs1_GHR30_SplitString('{0}',','))
// for XML path(''),type).value('.','nvarchar(max)'),1,1,'');",
// value);
// StaffID = DataAccess.SelectSingleValueNotKey("SqlGhr30" + "Demo", staffExists).ToString();
// value = StaffID;
// if (String.IsNullOrEmpty(value))
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// }
// }
// catch (Exception)
// {
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// }
// }
// else
// {
// try
// {
// // 多选
// if (fieldRow["elementType"].ToString().LastIndexOf("multiple") == -1)
// {
// DataSourceList nList = dataSourceLists.First(t => t.name == value && t.field == dc.ColumnName);
// if (nList != null)
// {
// if (String.IsNullOrEmpty(nList.id))
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// else
// value = nList.id;
// }
// }
// else
// {
// string errorValue = string.Empty;
// string newValue = "[";
// foreach (var sp in value.Split(','))
// {
// DataSourceList nList = dataSourceLists.First(t => t.name == sp && t.field == dc.ColumnName);
// if (nList != null)
// {
// if (String.IsNullOrEmpty(nList.id))
// errorValue = errorValue + fieldRow["label"].ToString() + ",";
// else
// newValue = newValue + "\"" + nList.id + "\",";
// }
// else
// {
// errorValue = errorValue + fieldRow["label"].ToString() + ",";
// }
// }
// if (!string.IsNullOrEmpty(errorValue))
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值(" + errorValue + ")错误；";
// else
// value = newValue.TrimEnd(',') + "]";
// }
// }
// catch (Exception)
// {
// errorMsg = errorMsg + fieldRow["label"].ToString() + "输入值错误；";
// value = "0";
// }
// }
//}
// 部门需要一级一级写入，不判断父级层级
if (menuName != "F_AllDept" && menuName != "F_Dept"
&& fieldRow["field"].ToString().IndexOf("ParentDeptID") > 0
&& !(value == "*" && menuName.StartsWith("F_StaffChange"))
)
{
// 是否输入整型
if (fieldRow["dataType"].ToString() == "int" && !string.IsNullOrEmpty(value))
{
int nums1;
if (!int.TryParse(value, out nums1))
errorMsg = errorMsg + fieldRow["label"].ToString() + "需为整数；";
}
// 是否输入数值
if ((fieldRow["dataType"].ToString() == "decimal" || fieldRow["dataType"].ToString() == "number")
&& !string.IsNullOrEmpty(value))
{
double nums2;
if (!double.TryParse(value, out nums2))
errorMsg = errorMsg + fieldRow["label"].ToString() + "需为数值；";
}
}
// 是否输入日期
if (fieldRow["dataType"].ToString().StartsWith("date")
&& !(value == "*" && menuName.StartsWith("F_StaffChange"))
)
{
if (!string.IsNullOrEmpty(value))
{
try
{
DateTime date1;
if (!DateTime.TryParse(value, out date1))
errorMsg = errorMsg + fieldRow["label"].ToString() + "需为日期格式；";
else if (fieldRow["dataType"].ToString() == "date")
{
value = date1.ToString("yyyy-MM-dd");
}
}
catch (Exception)
{
errorMsg = errorMsg + fieldRow["label"].ToString() + "(" + value + ")需为日期格式；";
}
}
else
{
}
}
if (fieldRow["elementType"].ToString().LastIndexOf("multiple") == -1)
{
jsonBuilder.AppendFormat("\"{0}\":\"{1}\",",
dc.ColumnName, value.Replace('"', '‘').Replace("'", "‘").Trim());
}
else
{
jsonBuilder.AppendFormat("\"{0}\":{1},",
dc.ColumnName, string.IsNullOrEmpty(value.Trim()) ? "null" : value.Trim());
}
}
else
{
jsonBuilder.AppendFormat("\"{0}\":\"{1}\",",
dc.ColumnName, value.Replace('"', '‘').Replace("'", "‘").Trim());
}
// ESS申请 下拉返回label 值
if (IsFlow == "Y")
{
jsonBuilder.AppendFormat("\"{0}\":\"{1}\",",
dc.ColumnName + "_Label", value_label.Trim());
}
}
}
if (jsonBuilder.Length > 1)
jsonBuilder.Remove(jsonBuilder.Length - 1, 1);
jsonBuilder.Append("}");
//判断 是否有错误
if (!string.IsNullOrEmpty(errorMsg))
{
mydt.Rows[i]["Comments"] = errorMsg;
ErrorNum++;
}
else
{
DataRow ndr = edt.NewRow();
ndr["ExcelNums"] = mydt.Rows[i]["ExcelNums"].ToString();
ndr["GID"] = guidN;
ndr["LangID"] = LangID;
ndr["UserID"] = UserID;
ndr["DoType"] = doType;
ndr["ProcName"] = procName;
ndr["MenuName"] = menuName;
ndr["JsonColumns"] = jsonBuilder.ToString();
edt.Rows.Add(ndr);
// 写入正确的json
jsonListBuilder.Append(jsonBuilder);
jsonListBuilder.Append(",");
}
}
if (jsonListBuilder.Length > 1)
jsonListBuilder.Remove(jsonListBuilder.Length - 1, 1);
jsonListBuilder.Append("]");
// 写入Excel待读取
string createTempSQL = "ExcelNums int,GID nvarchar(100),LangID int,UserID int,DoType nvarchar(200),ProcName nvarchar(200),MenuName nvarchar(200),JsonColumns nvarchar(max)";
string updateSQL = @"insert into [dbo].[Ghrs_ExcelImportWait]
([GID],[LangID],[UserID],[DoType], [ProcName], [MenuName], [JsonColumns],[SortNo])
select[GID],[LangID],[UserID],[DoType], [ProcName],[MenuName] ,[JsonColumns],ExcelNums
from #CTemplateTable";
Other.BulkUpdateData("SqlGhr30" + "Demo", edt, createTempSQL, updateSQL);
//Db.Ado.GetDataTable("SqlGhr30" + "Demo", edt, createTempSQL, updateSQL);
string EssResult = string.Empty;
//调用存储过程
// GHR 导入
if (IsFlow == "N")
{
string ReadSQL = string.Format(@"exec[dbo].[PT_GHR30_ReadExcelData] '{0}',{1},{2} ", guidN, LangID, UserID);
await Db.Ado.ExecuteCommandAsync("SqlGhr30" + "Demo", ReadSQL);
string resultSQL = string.Format(@"select SortNo,ErrorMsg,WarningMsg,SuccessMsg
from Ghrs_ExcelImportResult
where GID = '{0}'
and ISNULL(ErrorMsg,'') != '' ", guidN);
DataTable resultDt = await Db.Ado.GetDataTableAsync(resultSQL);
//写入错误信息
foreach (DataRow resultDR in resultDt.Rows)
{
string SortNo = resultDR["SortNo"].ToString();
string ErrorMsg = "";
ErrorMsg = resultDR["ErrorMsg"].ToString();
mydt.Select(@"ExcelNums = '" + SortNo + "'")[0]["Comments"] = ErrorMsg;
ErrorNum++;
}
}
else
{
string ReadSQL = string.Format(@"exec[dbo].[PT_GHR30_EssFlowReadExcelData] '{0}',{1},{2} ", guidN, LangID, UserID);
DataTable resultDt = await Db.Ado.GetDataTableAsync(ReadSQL);
StringBuilder jsonBuilder = new StringBuilder();
jsonBuilder.Append("[");
foreach (DataRow resultDR in resultDt.Rows)
{
jsonBuilder.Append(resultDR["ResultJson"].ToString() + ",");
string SortNo = resultDR["SortNo"].ToString();
string ErrorMsg = "";
ErrorMsg = resultDR["FlowApplyDetailInfo"].ToString();
if (ErrorMsg != String.Empty)
{
ErrorNum++;
mydt.Select(@"ExcelNums = '" + SortNo + "'")[0]["Comments"] = ErrorMsg;
}
}
if (jsonBuilder.Length > 1)
jsonBuilder.Remove(jsonBuilder.Length - 1, 1);
jsonBuilder.Append("]");
EssResult = jsonBuilder.ToString();
}
SuccessNum = AllNums - ErrorNum;
File.Delete(FilePath); //先删除，再保存。
//将写入结果导出为Excel
GetExcelByDataTable(mydt, FilePath);
// 流程直接返回读取信息
if (IsFlow == "Y")
{ // 流程直接返回读取信息
return EssResult;
}
try
{
DataTable ErrorTable = mydt;// GetNewDataTable(mydt, "Process = '' ", "");
//DataRow[] foundRow;
//foundRow = ErrorTable.Select("Comments != ''");
//if (foundRow != null && foundRow.Count() > 0)
//{
// foreach (DataRow row in foundRow)
// {
// ErrorTable.Rows.Remove(row);
// }
//}
//ErrorTable.AcceptChanges();//对DataTable（全部）操作完之后，一定要执行这一步，否则结果不保存
//if (ErrorTable.Rows.Count > 0)
//result = GHR.Common.DBCommon.ToJson(ErrorTable);
}
catch (Exception ex)
{
result = "[{\"readerror\":\"" + ex.Message + "\"}]";
}
return result;
}
/// <summary>
/// 根据Excel和Sheet返回DataTable
/// </summary>
/// <param name="filePath">Excel文件地址</param>
/// <param name="sheetIndex">Sheet索引</param>
/// <returns>DataTable</returns>
public static DataTable GetDataTable(string filePath, int sheetIndex, Dictionary<string, object> NameContrast)
{
return GetDataSet(filePath, sheetIndex, NameContrast).Tables[0];
}
/// <summary>
/// 根据Excel返回DataSet
/// </summary>
/// <param name="filePath">Excel文件地址</param>
/// <param name="sheetIndex">Sheet索引，可选，默认返回所有Sheet</param>
/// <returns>DataSet</returns>
public static DataSet GetDataSet(string filePath, int? sheetIndex, Dictionary<string, object> NameContrast)
{
DataSet ds = new DataSet();
IWorkbook fileWorkbook;
string FileExt = Path.GetExtension(filePath);
using (FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
{
if (FileExt == ".xls")
{
try
{
//fileWorkbook = new HSSFWorkbook(fs);
fileWorkbook = new NPOI.HSSF.UserModel.HSSFWorkbook(fs);
}
catch (Exception ex)
{
throw ex;
}
}
else if (FileExt == ".xlsx")
{
try
{
fileWorkbook = new NPOI.XSSF.UserModel.XSSFWorkbook(fs);
}
catch (Exception ex)
{
throw ex;
}
}
else fileWorkbook = null;
}
for (int i = 0; i < fileWorkbook.NumberOfSheets; i++)
{
if (sheetIndex != null && sheetIndex != i)
continue;
DataTable dt = new DataTable();
ISheet sheet = fileWorkbook.GetSheetAt(i);
//表头
IRow header = sheet.GetRow(sheet.FirstRowNum);
List<int> columns = new List<int>();
for (int j = 0; j < header.LastCellNum; j++)
{
object obj = new object();
if (FileExt == ".xls")
{
obj = GetValueTypeForXLS(header.GetCell(j) as HSSFCell);
}
else if (FileExt == ".xlsx")
{
obj = GetValueTypeForXLS(header.GetCell(j) as XSSFCell);
}
else { obj = null; }
if (obj == null || obj.ToString() == string.Empty)
{
dt.Columns.Add(new DataColumn("Columns" + j.ToString()));
}
else
{
dt.Columns.Add(new DataColumn(obj.ToString()));
//try
//{
// dt.Columns.Add(new DataColumn(NameContrast[obj.ToString()].ToString()));
//}
//catch (Exception)
//{
// dt.Columns.Add(new DataColumn(obj.ToString()));
//}
}
columns.Add(j);
}
//数据
IEnumerator rows = sheet.GetEnumerator();
int n = sheet.FirstRowNum + 1;
while (rows.MoveNext())
{
DataRow dr = dt.NewRow();
bool hasValue = false;
foreach (int K in columns)
{
try
{
dr[K] = GetValueTypeForXLS(sheet.GetRow(n).GetCell(K) as HSSFCell);
if (FileExt == ".xls")
{
dr[K] = GetValueTypeForXLS(sheet.GetRow(n).GetCell(K) as HSSFCell);
}
else if (FileExt == ".xlsx")
{
dr[K] = GetValueTypeForXLS(sheet.GetRow(n).GetCell(K) as XSSFCell);
}
else dr[K] = null;
if (dr[K] != null && dr[K].ToString() != string.Empty)
{
hasValue = true;
}
}
catch
{
hasValue = false;
}
}
if (hasValue)
{
dt.Rows.Add(dr);
}
n++;
}
ds.Tables.Add(dt);
}
return ds;
}
/// <summary>
/// 根据DataTable导出Excel
/// </summary>
/// <param name="dt">DataTable</param>
/// <param name="file">保存地址</param>
public static bool GetExcelByDataTable(DataTable dt, string file)
{
DataSet ds = new DataSet();
DataTable NewDT = dt.Copy();
ds.Tables.Add(NewDT);
return GetExcelByDataSet(ds, file);
}
/// <summary>
/// 根据DataSet导出Excel
/// </summary>
/// <param name="ds">DataSet</param>
/// <param name="file">保存地址</param>
public static bool GetExcelByDataSet(DataSet ds, string file)
{
try
{
IWorkbook fileWorkbook;
if (Path.GetExtension(file) == ".xls")
{
fileWorkbook = new HSSFWorkbook();
}
else
{
fileWorkbook = new XSSFWorkbook();
}
int index = 0;
foreach (DataTable dt in ds.Tables)
{
index++;
ISheet sheet = fileWorkbook.CreateSheet("Sheet" + index);
//表头
IRow row = sheet.CreateRow(0);
for (int i = 0; i < dt.Columns.Count; i++)
{
ICell cell = row.CreateCell(i);
cell.SetCellValue(dt.Columns[i].ColumnName);
}
// 隐藏首行
if (IsHideTopRow)
row.HeightInPoints = 1;
//数据
for (int i = 0; i < dt.Rows.Count; i++)
{
IRow row1 = sheet.CreateRow(i + 1);
for (int j = 0; j < dt.Columns.Count; j++)
{
ICell cell = row1.CreateCell(j);
cell.SetCellValue(dt.Rows[i][j].ToString());
}
}
}
//转为字节数组
MemoryStream stream = new MemoryStream();
fileWorkbook.Write(stream);
var buf = stream.ToArray();
//保存为Excel文件
using (FileStream fs = new FileStream(file, FileMode.Create, FileAccess.Write))
{
fs.Write(buf, 0, buf.Length);
fs.Flush();
}
return true;
}
catch (Exception ex)
{
return false;
}
}
/// <summary>
/// 获取新增表的字段设定(导入需要)
/// </summary>
/// <param name="menuName"></param>
/// <returns></returns>
public static async Task<DataSet> GetTableColumn(ISqlSugarClient Db, int langId, int userId, string menuName, string jsonParam)
{
string SQL = String.Format(@"exec [PT_GHR30_GetExcelEditColumn] '{1}',0,{2},{3}, '{0}','Import'", menuName, jsonParam, langId, userId);
// 第一张表 表头设定
// 第二张表 写入默认值
DataSet ds = await Db.Ado.GetDataSetAllAsync("SqlGhr30" + "Demo", SQL);
return ds;
}
/// <summary>
/// 根据单元格将内容返回为对应类型的数据
/// </summary>
/// <param name="cell">单元格</param>
/// <returns>数据</returns>
private static object GetValueTypeForXLS(HSSFCell cell)
{
if (cell == null)
return null;
switch (cell.CellType)
{
case CellType.Blank: //BLANK:
return null;
case CellType.Boolean: //BOOLEAN:
return cell.BooleanCellValue;
case CellType.Numeric: //NUMERIC:
{
if (DateUtil.IsCellDateFormatted(cell))
return cell.DateCellValue.Value.ToString("yyyy-MM-dd HH:mm");
else
return cell.NumericCellValue;
}
case CellType.String: //STRING:
return cell.StringCellValue;
case CellType.Error: //ERROR:
return cell.ErrorCellValue;
case CellType.Formula: //FORMULA:
default:
return "=" + cell.CellFormula;
}
}
/// <summary>
/// 根据单元格将内容返回为对应类型的数据
/// </summary>
/// <param name="cell">单元格</param>
/// <returns>数据</returns>
private static object GetValueTypeForXLS(XSSFCell cell)
{
if (cell == null)
return null;
switch (cell.CellType)
{
case CellType.Blank: //BLANK:
return null;
case CellType.Boolean: //BOOLEAN:
return cell.BooleanCellValue;
case CellType.Numeric: //NUMERIC:
{
if (DateUtil.IsCellDateFormatted(cell))
return cell.DateCellValue.Value.ToString("yyyy-MM-dd HH:mm");
else
return cell.NumericCellValue;
}
case CellType.String: //STRING:
return cell.StringCellValue;
case CellType.Error: //ERROR:
return cell.ErrorCellValue;
case CellType.Formula: //FORMULA:
default:
return "=" + cell.CellFormula;
}
}
#region 其他
public class Other
@ -558,6 +1260,57 @@ public static class ReportHelper
return Num2ABCletter(front) + Level[remainder];
}
}
/// <summary>
/// SqlBulkCopy 批量更新数据
/// </summary>
/// <param name="dataTable">数据集</param>
/// <param name="crateTemplateSql">临时表创建字段</param>
/// <param name="updateSql">更新语句</param>
public static void BulkUpdateData(string con, DataTable dataTable, string crateTemplateSql, string updateSql)
{
// ConfigurationManager.OpenExeConfiguration(ConfigurationUserLevel.PerUserRoamingAndLocal);
//using (var conn = new SqlConnection(ConfigurationManager.ConnectionStrings[con].ConnectionString))
//{
// using (var command = new SqlCommand("", conn))
// {
// try
// {
// conn.Open();
// //数据库并创建一个临时表来保存数据表的数据
// Random ran = new Random();
// int n = ran.Next(100, 1000);
// command.CommandText = String.Format(" CREATE TABLE #CTemplateTable" + n.ToString() + " ({0})", crateTemplateSql);
// command.ExecuteNonQuery();
// //使用SqlBulkCopy 加载数据到临时表中
// using (var bulkCopy = new SqlBulkCopy(conn))
// {
// foreach (DataColumn dcPrepped in dataTable.Columns)
// {
// bulkCopy.ColumnMappings.Add(dcPrepped.ColumnName, dcPrepped.ColumnName);
// }
// bulkCopy.BulkCopyTimeout = 660;
// bulkCopy.DestinationTableName = "#CTemplateTable" + n.ToString();
// bulkCopy.WriteToServer(dataTable);
// bulkCopy.Close();
// }
// updateSql = updateSql.Replace("#CTemplateTable", "#CTemplateTable" + n.ToString());
// // 执行Command命令 使用临时表的数据去更新目标表中的数据 然后删除临时表
// command.CommandTimeout = 300;
// command.CommandText = updateSql;
// command.ExecuteNonQuery();
// }
// finally
// {
// conn.Close();
// }
// }
//}
}
}
#endregion

5
Tiobon.Core.IServices/ICommonServices.cs
Unescape View File

@ -1,4 +1,5 @@
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Tiobon.Core.Common;
using Tiobon.Core.IServices.BASE;
using Tiobon.Core.Model;
@ -26,4 +27,6 @@ public interface ICommonServices : IBaseServices<RootEntityTkey<int>>
Task<ServiceResult<QueryExportReturn>> ExportExcelAsync(QueryExport param);
Task<ServiceResult<QueryExportReturn>> DownImportTemplateAsync(QueryExport param);
Task<ServiceResult<QueryExportReturn>> ImportExcelAsync(IFormFile file, string menuName, int langId, int userId);
}

8
Tiobon.Core.Services/BASE/BaseServices.cs
Unescape View File

@ -347,7 +347,7 @@ public class BaseServices<TEntity, TEntityDto, TInsertDto, TEditDto> : IBaseServ
/// <summary>
/// 更新实体数据
/// </summary>
/// <param name="entity">博文实体类</param>
/// <param name="entity">实体类</param>
/// <returns></returns>
public async Task<bool> Update(long Id, TEditDto editModel)
{
@ -393,7 +393,7 @@ public class BaseServices<TEntity, TEntityDto, TInsertDto, TEditDto> : IBaseServ
/// <summary>
/// 更新实体数据
/// </summary>
/// <param name="entity">博文实体类</param>
/// <param name="entity">实体类</param>
/// <returns></returns>
public async Task<bool> Update(List<TEntity> listEntity)
{
@ -434,7 +434,7 @@ public class BaseServices<TEntity, TEntityDto, TInsertDto, TEditDto> : IBaseServ
/// <summary>
/// 根据实体删除一条数据
/// </summary>
/// <param name="entity">博文实体类</param>
/// <param name="entity">实体类</param>
/// <returns></returns>
public async Task<bool> Delete(TEntity entity)
{
@ -732,7 +732,7 @@ public class BaseServices<TEntity, TEntityDto, TInsertDto, TEditDto> : IBaseServ
/// <summary>
/// 根据实体删除一条数据
/// </summary>
/// <param name="entity">博文实体类</param>
/// <param name="entity">实体类</param>
/// <returns></returns>
public async Task<bool> DeleteSplit(TEntity entity, DateTime dateTime)
{

19
Tiobon.Core.Services/CommonServices.cs
Unescape View File

@ -1282,4 +1282,23 @@ public partial class CommonServices : BaseServices<RootEntityTkey<int>>, ICommon
}
#endregion
#region Excel数据导入
public async Task<ServiceResult<QueryExportReturn>> ImportExcelAsync(IFormFile file, string menuName, int langId, int userId)
{
var fid = SnowFlakeSingle.Instance.NextId();
var path = $"{$"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}upload{Path.DirectorySeparatorChar}{fid}{Path.DirectorySeparatorChar}"}";
if (!Directory.Exists(path))
Directory.CreateDirectory(path);
using (var stream = new FileStream(path + file.FileName, FileMode.Create))
{
await file.CopyToAsync(stream);
}
var result = new QueryExportReturn();
await ReportHelper.ExcelToDataTable(Db, path, menuName, langId, userId);
return new ServiceResult<QueryExportReturn>() { Success = true, Message = "查询成功", Data = result, };
}
#endregion
}

Write Preview
Loading…
Cancel
Save