ExcelDynamicReader.cs 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. using ClosedXML.Excel;
  2. using ExcelORM.Models;
  3. namespace ExcelORM;
  4. public class ExcelDynamicReader
  5. {
  6. private readonly IXLWorkbook xlWorkbook;
  7. public bool SkipHidden { get; set; }
  8. public bool ObeyFilter { get; set; }
  9. public ExcelDynamicReader(string? path)
  10. {
  11. xlWorkbook = new XLWorkbook(path);
  12. }
  13. private IEnumerable<List<DynamicCell>> ProcessRows(IEnumerable<IXLRow> rows, List<DynamicCell> mapping)
  14. {
  15. foreach (var row in rows)
  16. {
  17. if (SkipHidden && row.IsHidden) continue;
  18. var dynamicRow = new List<DynamicCell>();
  19. foreach (var item in mapping)
  20. {
  21. var cell = row.Cell(item.Position);
  22. if (cell == null || cell.Value.IsBlank) continue;
  23. var cellItem = item with
  24. {
  25. Value = cell.Value.ToObject()
  26. };
  27. dynamicRow.Add(cellItem);
  28. }
  29. yield return dynamicRow;
  30. }
  31. }
  32. public IEnumerable<List<DynamicCell>> Read(string? worksheetName, uint startFrom = 1, uint skip = 0)
  33. {
  34. var worksheet = xlWorkbook.Worksheets.FirstOrDefault(x => x.Name.Equals(worksheetName, StringComparison.InvariantCultureIgnoreCase));
  35. if (worksheet == null) yield break;
  36. var firstRow = worksheet.Row((int)startFrom);
  37. if (firstRow.IsEmpty())
  38. firstRow = worksheet.RowsUsed().First(x => x.RowNumber() > startFrom && !x.IsEmpty());
  39. var mapping = DynamicCell.MapHeader(firstRow.CellsUsed());
  40. if (mapping == null || mapping.Count == 0) yield break;
  41. var rowsToProcess = (ObeyFilter && worksheet.AutoFilter.IsEnabled) switch
  42. {
  43. true => worksheet.AutoFilter.VisibleRows
  44. .Where(x => x.RowNumber() > firstRow.RowNumber())
  45. .Select(x => x.WorksheetRow()),
  46. false => worksheet.RowsUsed().Where(x => x.RowNumber() > firstRow.RowNumber())
  47. };
  48. rowsToProcess = rowsToProcess
  49. .Skip((int)skip);
  50. foreach (var item in ProcessRows(rowsToProcess, mapping))
  51. yield return item;
  52. }
  53. }