.Net 基于MiniExcel的导入功能接口示例

1. /// <summary>
2. /// 导入
3. /// </summary>
4. /// <param name="formFile"></param>
5. /// <returns></returns>
6. [HttpPost("Import")]
7. public async Task<ExecResult> Import(IFormFile formFile)
8. {
9.      try
10.      {
11.          if (formFile == null) throw new Exception("请选择文件导入!");
12.          var fileExt = Path.GetExtension(formFile.FileName);
13.          if (fileExt != ".xlsx") throw new Exception("请导入后缀名为.xlsx的Excel文件!");
15.          using var stream = new MemoryStream();
16.          formFile.CopyTo(stream);
17.          var maintainItems = new List<TpmMaintainItem>();
18.          var allItems = await _dbcontext.TpmMaintainItems.ToListAsync();
19.          var equipments = await _dbcontext.Equipment.ToListAsync();
20.          int num = 1;
21.          StringBuilder sb = new StringBuilder();
22.          foreach (IDictionary<string, object> row in stream.Query(true))
23.          {
24.              var equipmentCode = row["设备编码"];
25.              var name = row["维保项名称"];
26.              var cycle = row["维保项周期(天)"];
27.              var content = row["维保项内容"];
28.              var isMustCheck = row["是否必检"];
29.              var advanceDays = row["提前天数"];
30.              if (equipmentCode == null) sb.AppendLine($"第{num}行设备编码不存在!");
31.              if (name == null) sb.AppendLine($"第{num}行维保项名称不能为空!");
32.              if (cycle == null) sb.AppendLine($"第{num}行维保项周期(天)不能为空!");
33.              if (content == null) sb.AppendLine($"第{num}行维保项内容不能为空!");
34.              if (isMustCheck == null)
35.              {
36.                  sb.AppendLine($"第{num}行是否必检不能为空!");
37.              }
38.              else if(!(isMustCheck.ToString() == "是" || isMustCheck.ToString() == "否"))
39.              {
40.                  sb.AppendLine($"第{num}行是否必检为非法字符，只能填写是或否!");
41.              }
42.              if (advanceDays == null) sb.AppendLine($"第{num}行提前天数不能为空!");
44.              var equipment = equipments.FirstOrDefault(s=>s.EquipmentCode == equipmentCode.ToString());
45.              if(equipment == null) sb.AppendLine($"第{num}行设备编码:{equipmentCode}不存在!");
46.              var maintainItem = new TpmMaintainItem()
47.              {
48.                  EquipmentId = Convert.ToInt32(equipment?.EquipmentID),
49.                  Name = name.ToString(),
50.                  Cycle = Convert.ToInt32(cycle),
51.                  Content = content.ToString(),
52.                  IsMustCheck = string.Equals(isMustCheck.ToString(), "是") ? true : false,
53.                  AdvanceDays = Convert.ToInt32(advanceDays),
54.                  CreateTime = DateTime.Now
55.              };
56.              if (allItems.Any(s => s.Name == maintainItem.Name))
57.                  sb.AppendLine($"第{num}行数据已存在!");
58.              if(maintainItems.Any(s => s.Name == maintainItem.Name))
59.                  sb.AppendLine($"第{num}行数据重复!");
60.              maintainItems.Add(maintainItem);
61.              num++;
62.          }
63.          if(sb.Length > 0)
64.          {
65.              throw new Exception(sb.ToString());
66.          }
67.          else
68.          {
69.              await _dbcontext.TpmMaintainItems.AddRangeAsync(maintainItems);
70.              await _dbcontext.SaveChangesAsync();
71.          }
73.          return new ExecResult(true, "");
74.      }
75.      catch (Exception ex)
76.      {
77.          _logger.LogError(ex, "");
78.          return new ExecResult(false, "", ex.Message);
79.      }
80. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。