ExcelHelper.cs 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154
  1. // Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
  2. //
  3. // 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
  4. //
  5. // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任!
  6. using OfficeOpenXml;
  7. namespace Admin.NET.Core;
  8. public class ExcelHelper
  9. {
  10. /// <summary>
  11. /// 数据导入
  12. /// </summary>
  13. /// <param name="file"></param>
  14. /// <param name="action"></param>
  15. /// <returns></returns>
  16. public static IActionResult ImportData<IN, T>(IFormFile file, Action<List<IN>, Action<StorageableResult<T>, List<IN>, List<T>>> action) where IN : BaseImportInput, new() where T : EntityBaseId, new()
  17. {
  18. try
  19. {
  20. var result = CommonUtil.ImportExcelDataAsync<IN>(file).Result ?? throw Oops.Oh("有效数据为空");
  21. result.ForEach(u => u.Id = YitIdHelper.NextId());
  22. var tasks = new List<Task>();
  23. action.Invoke(result, (storageable, pageItems, rows) =>
  24. {
  25. // 标记校验信息
  26. tasks.Add(Task.Run(() =>
  27. {
  28. if (!storageable.TotalList.Any()) return;
  29. // 通过Id标记校验信息
  30. var itemMap = pageItems.ToDictionary(u => u.Id, u => u);
  31. foreach (var item in storageable.TotalList)
  32. {
  33. var temp = itemMap.GetValueOrDefault(item.Item.Id);
  34. if (temp != null) temp.Error ??= item.StorageMessage;
  35. }
  36. }));
  37. });
  38. // 等待所有标记验证信息任务完成
  39. Task.WhenAll(tasks).GetAwaiter().GetResult();
  40. // 仅导出错误记录
  41. var errorList = result.Where(u => !string.IsNullOrWhiteSpace(u.Error));
  42. return ExportData(errorList.Any() ? errorList : new List<IN>());
  43. }
  44. catch (Exception ex)
  45. {
  46. App.HttpContext.Response.Headers["Content-Type"] = "application/json; charset=utf-8";
  47. throw Oops.Oh(new AdminResult<object>
  48. {
  49. Code = 500,
  50. Message = ex.Message,
  51. Result = null,
  52. Type = "error",
  53. Extras = UnifyContext.Take(),
  54. Time = DateTime.Now
  55. }.ToJson());
  56. }
  57. }
  58. /// <summary>
  59. /// 导出Xlsx数据
  60. /// </summary>
  61. /// <param name="list"></param>
  62. /// <param name="fileName"></param>
  63. /// <returns></returns>
  64. public static IActionResult ExportData(dynamic list, string fileName = "导入记录")
  65. {
  66. var exporter = new ExcelExporter();
  67. var fs = new MemoryStream(exporter.ExportAsByteArray(list).GetAwaiter().GetResult());
  68. return new XlsxFileResult(stream: fs, fileDownloadName: $"{fileName}-{DateTime.Now:yyyy-MM-dd_HHmmss}");
  69. }
  70. /// <summary>
  71. /// 根据类型导出Xlsx模板
  72. /// </summary>
  73. /// <param name="list"></param>
  74. /// <param name="filename"></param>
  75. /// <param name="addListValidationFun"></param>
  76. /// <returns></returns>
  77. public static IActionResult ExportTemplate<T>(IEnumerable<T> list, string filename = "导入模板", Func<ExcelWorksheet, PropertyInfo, IEnumerable<string>> addListValidationFun = null)
  78. {
  79. using var package = new ExcelPackage((ExportData(list, filename) as XlsxFileResult)!.Stream);
  80. var worksheet = package.Workbook.Worksheets[0];
  81. // 创建一个隐藏的sheet,用于添加下拉列表
  82. var dropdownSheet = package.Workbook.Worksheets.Add("下拉数据");
  83. dropdownSheet.Hidden = eWorkSheetHidden.Hidden;
  84. var sysDictTypeService = App.GetService<SysDictTypeService>();
  85. foreach (var prop in typeof(T).GetProperties())
  86. {
  87. var propType = prop.PropertyType;
  88. var headerAttr = prop.GetCustomAttribute<ExporterHeaderAttribute>();
  89. var isNullableEnum = propType.IsGenericType && propType.GetGenericTypeDefinition() == typeof(Nullable<>) && Nullable.GetUnderlyingType(propType).IsEnum();
  90. if (isNullableEnum) propType = Nullable.GetUnderlyingType(propType);
  91. if (headerAttr == null) continue;
  92. // 获取列序号
  93. var columnIndex = 0;
  94. foreach (var item in worksheet.Cells[1, 1, 1, worksheet.Dimension.End.Column])
  95. if (++columnIndex > 0 && item.Text.Equals(headerAttr.DisplayName)) break;
  96. if (columnIndex <= 0) continue;
  97. // 优先从代理函数中获取下列列表,若为空且字段为枚举型,则填充枚举项为下列列表,若为字典字段,则填充字典值value列表为下列列表
  98. var dataList = addListValidationFun?.Invoke(worksheet, prop)?.ToList();
  99. if (dataList == null)
  100. {
  101. // 填充枚举项为下列列表
  102. if (propType.IsEnum())
  103. {
  104. dataList = propType.EnumToList()?.Select(it => it.Describe).ToList();
  105. }
  106. else
  107. {
  108. // 获取字段上的字典特性
  109. var dict = prop.GetCustomAttribute<DictAttribute>();
  110. if (dict != null)
  111. {
  112. // 填充字典值value为下列列表
  113. dataList = sysDictTypeService.GetDataList(new GetDataDictTypeInput { Code = dict.DictTypeCode })
  114. .Result?.Select(x => x.Label).ToList();
  115. }
  116. }
  117. }
  118. if (dataList != null)
  119. {
  120. // 添加下拉列表
  121. AddListValidation(columnIndex, dataList);
  122. dropdownSheet.Cells[1, columnIndex, dataList.Count, columnIndex].LoadFromCollection(dataList);
  123. }
  124. }
  125. package.Save();
  126. package.Stream.Position = 0;
  127. return new XlsxFileResult(stream: package.Stream, fileDownloadName: $"{filename}-{DateTime.Now:yyyy-MM-dd_HHmmss}");
  128. void AddListValidation(int columnIndex, List<string> dataList)
  129. {
  130. var validation = worksheet.DataValidations.AddListValidation(worksheet.Cells[2, columnIndex, 999999, columnIndex].Address);
  131. validation!.Formula.ExcelFormula = "=下拉数据!" + worksheet.Cells[1, columnIndex, dataList.Count, columnIndex].Address;
  132. validation.ShowErrorMessage = true;
  133. validation.ErrorTitle = "无效输入";
  134. validation.Error = "请从列表中选择一个有效的选项";
  135. }
  136. }
  137. }