335 lines
15 KiB
C#
335 lines
15 KiB
C#
|
using Infrastructure;
|
|||
|
|
using OpenAuth.App.Base;
|
|||
|
|
using OpenAuth.App.Permission;
|
|||
|
|
using OpenAuth.Repository;
|
|||
|
|
using OpenAuth.Repository.Domain;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using OpenAuth.App.BaseApp.Base;
|
|||
|
|
|
|||
|
|
namespace OpenAuth.App.Import
|
|||
|
|
{
|
|||
|
|
public class ImportApp : SqlSugarBaseApp<Repository.Domain.ExcelImport, SugarDbContext>
|
|||
|
|
{
|
|||
|
|
SysDataItemDetailApp _dataItemDetailApp;
|
|||
|
|
public ImportApp(ISugarUnitOfWork<SugarDbContext> unitWork, SysDataItemDetailApp dataItemDetailApp,
|
|||
|
|
ISimpleClient<Repository.Domain.ExcelImport> repository)
|
|||
|
|
: base(unitWork, repository, null)
|
|||
|
|
{
|
|||
|
|
_dataItemDetailApp = dataItemDetailApp;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取导入的分页数据
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="keyWord">查询关键字</param>
|
|||
|
|
/// <param name="moduleId">菜单id</param>
|
|||
|
|
/// <param name="page"></param>
|
|||
|
|
/// <param name="limit"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<Response<PageInfo<List<ExcelImport>>>> LoadExcelImportPage(string keyWord, string moduleId, int page, int limit)
|
|||
|
|
{
|
|||
|
|
RefAsync<int> totalCount = 0;
|
|||
|
|
var expression = Expressionable.Create<ExcelImport>()
|
|||
|
|
.AndIF(!string.IsNullOrEmpty(keyWord), t => t.Name.Contains(keyWord))
|
|||
|
|
.AndIF(!string.IsNullOrEmpty(moduleId), t => t.ModuleId == moduleId);
|
|||
|
|
var info = await base.Repository.AsQueryable()
|
|||
|
|
.Where(expression.ToExpression())
|
|||
|
|
.ToPageListAsync(page, limit, totalCount);
|
|||
|
|
return new Response<PageInfo<List<ExcelImport>>>
|
|||
|
|
{
|
|||
|
|
Result = new PageInfo<List<ExcelImport>>
|
|||
|
|
{
|
|||
|
|
Items = info,
|
|||
|
|
Total = totalCount
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取表单数据
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id">id</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<ExcelImport> GetEntity(string id)
|
|||
|
|
{
|
|||
|
|
var entity = await base.Repository.AsQueryable()
|
|||
|
|
.Where(t => t.Id == id)
|
|||
|
|
.FirstAsync();
|
|||
|
|
return entity;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取配置字段列表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="importId">配置信息主键</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public Task<List<ExcelImportFileds>> GetFieldList(string importId)
|
|||
|
|
{
|
|||
|
|
return base.Repository.ChangeRepository<SugarRepositiry<Repository.Domain.ExcelImportFileds>>().AsQueryable().Where(t => t.ImportId == importId).ToListAsync();
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取导入配置列表根据模块ID
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="moduleId">功能模块主键</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<List<ExcelImport>> GetModuleList(string moduleId)
|
|||
|
|
{
|
|||
|
|
var expression = Expressionable.Create<ExcelImport>();
|
|||
|
|
expression = expression.And(t => t.ModuleId == moduleId && t.EnabledMark == 1);
|
|||
|
|
return await base.Repository.AsQueryable().Where(expression.ToExpression()).ToListAsync();
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除数据
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="keyValue">主键</param>
|
|||
|
|
public async Task<Response<bool>> DeleteEntity(string keyValue)
|
|||
|
|
{
|
|||
|
|
using (var uow = base.UnitWork.CreateContext())
|
|||
|
|
{
|
|||
|
|
await uow.ExcelImport.DeleteByIdAsync(keyValue);
|
|||
|
|
await uow.ExcelImportFileds.DeleteAsync(a => a.ImportId == keyValue);
|
|||
|
|
|
|||
|
|
var falg = uow.Commit();
|
|||
|
|
return new Response<bool>
|
|||
|
|
{
|
|||
|
|
Result = falg,
|
|||
|
|
Message = (falg == true ? "success" : "error")
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 保存表单（新增、修改）
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="keyValue">主键值</param>
|
|||
|
|
/// <param name="entity">实体数据</param>
|
|||
|
|
/// <param name="filedList">字段列表</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<Response<bool>> SaveEntity(string keyValue, ExcelImport entity, List<ExcelImportFileds> filedList)
|
|||
|
|
{
|
|||
|
|
using (var uow = base.UnitWork.CreateContext())
|
|||
|
|
{
|
|||
|
|
if (!string.IsNullOrEmpty(keyValue))
|
|||
|
|
{
|
|||
|
|
entity.Id = keyValue;
|
|||
|
|
entity.ModifyDate = DateTime.Now;
|
|||
|
|
await uow.ExcelImport.UpdateAsync(entity);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
entity.Id = Guid.NewGuid().ToString();
|
|||
|
|
entity.CreateDate = DateTime.Now;
|
|||
|
|
entity.EnabledMark = 1;
|
|||
|
|
await uow.ExcelImport.InsertAsync(entity);
|
|||
|
|
}
|
|||
|
|
await uow.ExcelImportFileds.DeleteAsync(t => t.ImportId == entity.Id);
|
|||
|
|
foreach (var item in filedList)
|
|||
|
|
{
|
|||
|
|
item.ImportId = entity.Id;
|
|||
|
|
await uow.ExcelImportFileds.InsertAsync(item);
|
|||
|
|
}
|
|||
|
|
var falg = uow.Commit();
|
|||
|
|
return new Response<bool>
|
|||
|
|
{
|
|||
|
|
Result = falg,
|
|||
|
|
Message = (falg == true ? "success" : "error")
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//#region 扩展方法
|
|||
|
|
///// <summary>
|
|||
|
|
///// excel 数据导入（未导入数据写入缓存）
|
|||
|
|
///// </summary>
|
|||
|
|
///// <param name="templateId">导入模板主键</param>
|
|||
|
|
///// <param name="dt">导入数据</param>
|
|||
|
|
///// <returns></returns>
|
|||
|
|
//public async Task<(DataTable elist, int snum, int fnum)> ImportTable(string templateId, DataTable dt)
|
|||
|
|
//{
|
|||
|
|
// int snum = 0;
|
|||
|
|
// int fnum = 0;
|
|||
|
|
// // 创建一个datatable容器用于保存导入失败的数据
|
|||
|
|
// DataTable failDt = new DataTable();
|
|||
|
|
// dt.Columns.Add("导入错误", typeof(string));
|
|||
|
|
// foreach (DataColumn dc in dt.Columns)
|
|||
|
|
// {
|
|||
|
|
// failDt.Columns.Add(dc.ColumnName, dc.DataType);
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
// if (dt.Rows.Count > 0)
|
|||
|
|
// {
|
|||
|
|
// ExcelImport entity = await GetEntity(templateId);
|
|||
|
|
// List<ExcelImportFileds> list = (List<ExcelImportFileds>)await GetFieldList(templateId);
|
|||
|
|
|
|||
|
|
// if (entity != null && list.Count > 0)
|
|||
|
|
// {
|
|||
|
|
// string sqlonly = " select * from " + entity.DbTable + " where 1=1 {LEARUN_SASSID} ";
|
|||
|
|
// // 数据字典数据
|
|||
|
|
// Dictionary<string, List<SysDataItemDetail>> dataItemMap = new Dictionary<string, List<SysDataItemDetail>>();
|
|||
|
|
// Dictionary<string, DataTable> dataSourceMap = new Dictionary<string, DataTable>();
|
|||
|
|
|
|||
|
|
// foreach (DataRow dr in dt.Rows)
|
|||
|
|
// { // 行数据循环
|
|||
|
|
// try
|
|||
|
|
// {
|
|||
|
|
// List<SugarParameter> dbParameters = new List<SugarParameter>();
|
|||
|
|
// foreach (var col in list)
|
|||
|
|
// {
|
|||
|
|
// object paramValue = null;
|
|||
|
|
|
|||
|
|
// switch (col.RelationType)
|
|||
|
|
// {
|
|||
|
|
// case 0://无关联
|
|||
|
|
// paramValue = dr[col.ColName].ToString();
|
|||
|
|
// await IsOnlyOne(col, sqlonly, dr[col.ColName].ToString(), entity.DbId);
|
|||
|
|
// break;
|
|||
|
|
// case 1://GUID
|
|||
|
|
// paramValue = Guid.NewGuid().ToString();
|
|||
|
|
// break;
|
|||
|
|
// case 2://数据字典
|
|||
|
|
// string dataItemName = "";
|
|||
|
|
// if (!dataItemMap.ContainsKey(col.DataItemCode))
|
|||
|
|
// {
|
|||
|
|
// List<SysDataItemDetail> dataItemList = (List<SysDataItemDetail>)await _dataItemDetailApp.Load(col.DataItemCode, "");
|
|||
|
|
// dataItemMap.Add(col.DataItemCode, dataItemList);
|
|||
|
|
// }
|
|||
|
|
// dataItemName = FindDataItemValue(dataItemMap[col.DataItemCode], dr[col.ColName].ToString(), col.ColName);
|
|||
|
|
// paramValue = dataItemName;
|
|||
|
|
// await IsOnlyOne(col, sqlonly, dataItemName, entity.DbId);
|
|||
|
|
// break;
|
|||
|
|
// case 3://数据表
|
|||
|
|
// string v = "";
|
|||
|
|
// try
|
|||
|
|
// {
|
|||
|
|
// //string queryJson = "{" + col.F_DSourceExcelId + ":\"" + dr[col.F_ColName].ToString() + "\"}";
|
|||
|
|
// if (!dataSourceMap.ContainsKey(col.DSourceId))
|
|||
|
|
// {
|
|||
|
|
// //DataTable sourceDt = await _dataSourceIBLL.GetDataTable(col.DSourceId);
|
|||
|
|
// DataTable sourceDt = new DataTable();
|
|||
|
|
// dataSourceMap.Add(col.DSourceId, sourceDt);
|
|||
|
|
// }
|
|||
|
|
// v = FindDataSourceValue(dataSourceMap[col.DSourceId], col.DSourceExcelId.ToLower(), dr[col.ColName].ToString(), col.DSourceDBId.ToLower());
|
|||
|
|
// paramValue = v;
|
|||
|
|
// }
|
|||
|
|
// catch (Exception)
|
|||
|
|
// {
|
|||
|
|
// throw (new Exception("【" + col.ColName + "】 找不到对应的数据"));
|
|||
|
|
// }
|
|||
|
|
// await IsOnlyOne(col, sqlonly, v, entity.DbId);
|
|||
|
|
// break;
|
|||
|
|
// case 4://固定值
|
|||
|
|
// paramValue = col.Value;
|
|||
|
|
// break;
|
|||
|
|
// case 5://操作人ID
|
|||
|
|
// paramValue = "";
|
|||
|
|
// break;
|
|||
|
|
// case 6://操作人名字
|
|||
|
|
// paramValue = "";
|
|||
|
|
// break;
|
|||
|
|
// case 7://操作时间
|
|||
|
|
// paramValue = DateTime.Now;
|
|||
|
|
// break;
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
// dbParameters.Add(new SugarParameter(col.Name, paramValue));
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
// //await excelImportService.BaseRepository(entity.DbId).ExecuteInsert(entity.DbTable, dbParameters);
|
|||
|
|
// _formSchemeApp.ExecuteInsert(entity.DbTable, dbParameters);
|
|||
|
|
// snum++;
|
|||
|
|
// }
|
|||
|
|
// catch (Exception ex)
|
|||
|
|
// {
|
|||
|
|
// fnum++;
|
|||
|
|
// if (entity.ErrorType == 0)// 如果错误机制是终止
|
|||
|
|
// {
|
|||
|
|
// dr["导入错误"] = $"{ex.Message} 【之后数据未被导入】";
|
|||
|
|
// failDt.Rows.Add(dr.ItemArray);
|
|||
|
|
// break;
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// dr["导入错误"] = ex.Message;
|
|||
|
|
// failDt.Rows.Add(dr.ItemArray);
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// return (failDt, snum, fnum);
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
///// <summary>
|
|||
|
|
///// 数据字典查找Value
|
|||
|
|
///// </summary>
|
|||
|
|
///// <param name="dataItemList">数据字典数据</param>
|
|||
|
|
///// <param name="itemName">项目名</param>
|
|||
|
|
///// <param name="colName">列名</param>
|
|||
|
|
///// <returns></returns>
|
|||
|
|
//private string FindDataItemValue(List<SysDataItemDetail> dataItemList, string itemName, string colName)
|
|||
|
|
//{
|
|||
|
|
// SysDataItemDetail dataItem = dataItemList.Find(t => t.ItemName == itemName);
|
|||
|
|
// if (dataItem != null)
|
|||
|
|
// {
|
|||
|
|
// return dataItem.ItemValue;
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// throw (new Exception("【" + colName + "】数据字典找不到对应值"));
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
|
|||
|
|
///// <summary>
|
|||
|
|
///// 获取数据源数据
|
|||
|
|
///// </summary>
|
|||
|
|
///// <param name="dt">数据源</param>
|
|||
|
|
///// <param name="name">名称</param>
|
|||
|
|
///// <param name="value">值</param>
|
|||
|
|
///// <param name="colname">列名</param>
|
|||
|
|
///// <returns></returns>
|
|||
|
|
//private string FindDataSourceValue(DataTable dt, string name, string value, string colname)
|
|||
|
|
//{
|
|||
|
|
|
|||
|
|
// foreach (DataRow dr in dt.Rows)
|
|||
|
|
// {
|
|||
|
|
// if (dr[name].ToString() == value)
|
|||
|
|
// {
|
|||
|
|
// return dr[colname].ToString();
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
// return "";
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
///// <summary>
|
|||
|
|
///// 判断是否数据有重复
|
|||
|
|
///// </summary>
|
|||
|
|
///// <param name="col"></param>
|
|||
|
|
///// <param name="sqlonly"></param>
|
|||
|
|
///// <param name="value"></param>
|
|||
|
|
///// <param name="dbId"></param>
|
|||
|
|
//private async Task IsOnlyOne(ExcelImportFileds col, string sqlonly, string value, string dbId)
|
|||
|
|
//{
|
|||
|
|
// if (col.OnlyOne == 1)
|
|||
|
|
// {
|
|||
|
|
// var dp = new Dictionary<string, string>();
|
|||
|
|
// sqlonly += col.Name + " = @" + col.Name;
|
|||
|
|
// dp.Add(col.Name, value);
|
|||
|
|
// var d = await _formSchemeApp.FindTableNew(sqlonly, dp);
|
|||
|
|
// if (d.Count() > 0)
|
|||
|
|
// {
|
|||
|
|
// throw new Exception("【" + col.ColName + "】此项数据不能重复");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
//#endregion
|
|||
|
|
}
|
|||
|
|
}
|