Teams/kunshan-bzfm-mes-backend
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

入库记录导入导出

Browse Source 
库存导入导出
This commit is contained in:
Carl
2026-01-09 10:53:37 +08:00
parent fdcb5b5200
commit 29ced372cb
9 changed files with 719 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
DOAN.Service/MES/Material/IService/IMmInventoryService.cs
View File

@@ -1,5 +1,6 @@
using DOAN.Model.BZFM.Dto;
using DOAN.Model.BZFM;
using DOAN.Model.BZFM.Dto;
using Microsoft.AspNetCore.Http;
namespace DOAN.Service.BZFM.IBZFMService
{
@@ -39,7 +40,14 @@ namespace DOAN.Service.BZFM.IBZFMService
/// </summary>
string CreateOutboundReceipt(OutboundReceiptDto parm);
/// <summary>
/// 导入
/// </summary>
/// <param name="inventory"></param>
/// <returns></returns>
ImportResultDto ImportInventory(IFormFile formFile, string username);
public PagedInfo<MmInventoryExcelDto> SelectInventoryList(MmInventoryQueryDto inventory, PagerInfo pager);
}
}

10
DOAN.Service/MES/Material/IService/IMmRecordInboundService.cs
View File

@@ -1,5 +1,6 @@
using DOAN.Model.BZFM.Dto;
using DOAN.Model.BZFM;
using DOAN.Model.BZFM.Dto;
using Microsoft.AspNetCore.Http;
namespace DOAN.Service.BZFM.IBZFMService
{
@@ -16,6 +17,13 @@ namespace DOAN.Service.BZFM.IBZFMService
MmRecordInbound AddMmRecordInbound(MmRecordInbound parm);
int UpdateMmRecordInbound(MmRecordInbound parm);
/// <summary>
/// 导入
/// </summary>
/// <param name="recordinbound"></param>
/// <returns></returns>
ImportResultDto ImportRecordinbound(IFormFile formFile, string username);
public PagedInfo<MmRecordinboundExcelDto> SelectRecordinboundList(MmRecordInboundQueryDto recordinbound, PagerInfo pager);
}
}

217
DOAN.Service/MES/Material/MmInventoryService.cs
View File

@@ -5,6 +5,10 @@ using DOAN.Repository;
using DOAN.Service.BZFM.IBZFMService;
using Infrastructure.Attribute;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Http;
using Microsoft.IdentityModel.Tokens;
using NPOI.SS.UserModel;
using NPOI.XSSF.UserModel;
namespace DOAN.Service.BZFM
{
@@ -421,5 +425,218 @@ namespace DOAN.Service.BZFM
return baseNo + "001";
}
}
/// <summary>
/// 导入数据
/// </summary>
/// <param name="formFile"></param>
/// <returns></returns>
public ImportResultDto ImportInventory(IFormFile formFile, string username)
{
string message = "导入成功";
List<MmInventoryExcelDto> inventoryList = new();
using (var stream = formFile.OpenReadStream())
{
try
{
IWorkbook workbook = new XSSFWorkbook(stream);
ISheet sheet = workbook.GetSheetAt(0);
#region 读取excel
// 遍历每一行
for (int row = 1; row <= sheet.LastRowNum; row++)
{
IRow currentRow = sheet.GetRow(row);
if (currentRow != null) // 确保行不为空
{
MmInventoryExcelDto inventory = new MmInventoryExcelDto();
//00 ID
NPOI.SS.UserModel.ICell currentCell_00 = currentRow.GetCell(0);
inventory.Id = (int)currentCell_00?.NumericCellValue;
//02物料编码
NPOI.SS.UserModel.ICell currentCell_01 = currentRow.GetCell(1);
inventory.MaterialCode = currentCell_01?.ToString();
if (
currentCell_01 == null
|| string.IsNullOrEmpty(inventory.MaterialCode)
)
{
message = $"物料编码不可为空，第{row + 1}行";
break;
}
//03批次号
NPOI.SS.UserModel.ICell currentCell_02 = currentRow.GetCell(2);
inventory.BatchNo = currentCell_02?.ToString() ?? string.Empty;
//04当前库存量
NPOI.SS.UserModel.ICell currentCell_03 = currentRow.GetCell(3);
string currentQtyStr = currentCell_03?.ToString();
if (currentCell_03 == null || string.IsNullOrWhiteSpace(currentQtyStr))
{
message = $"当前库存量不可为空，第{row + 1}行";
break;
}
// 尝试转换为decimal
if (!decimal.TryParse(currentQtyStr, out decimal currentQty))
{
message = $"当前库存量格式错误（必须是数字），第{row + 1}行";
break;
}
// 验证数值范围（可根据业务需求调整）
//if (currentQty < 0)
//{
// message = $"当前库存量不能为负数，第{row + 1}行";
// break;
//}
inventory.CurrentQty = currentQty;
//05 仓库编码
NPOI.SS.UserModel.ICell currentCell_04 = currentRow.GetCell(4);
inventory.WarehouseCode = currentCell_04?.ToString();
if (
currentCell_04 == null
|| string.IsNullOrEmpty(inventory.WarehouseCode)
)
{
message = $"仓库编码不可为空，第{row + 1}行";
break;
}
//06 仓库名称
NPOI.SS.UserModel.ICell currentCell_05 = currentRow.GetCell(5);
inventory.WarehouseName = currentCell_05?.ToString();
if (
currentCell_05 == null
|| string.IsNullOrEmpty(inventory.WarehouseName)
)
{
message = $"仓库名称不可为空，第{row + 1}行";
break;
}
//07 库位编码
NPOI.SS.UserModel.ICell currentCell_06 = currentRow.GetCell(6);
inventory.LocationCode = currentCell_06?.ToString();
if (
currentCell_06 == null
|| string.IsNullOrEmpty(inventory.LocationCode)
)
{
message = $"仓库编码不可为空，第{row + 1}行";
break;
}
//08 库位名称
NPOI.SS.UserModel.ICell currentCell_07 = currentRow.GetCell(7);
inventory.LocationName = currentCell_07?.ToString();
if (
currentCell_07 == null
|| string.IsNullOrEmpty(inventory.LocationName)
)
{
message = $"库位名称不可为空，第{row + 1}行";
break;
}
//09 创建时间
NPOI.SS.UserModel.ICell currentCell_08 = currentRow.GetCell(8);
inventory.CreatedTime = currentCell_08?.DateCellValue ?? DateTime.Now;
inventoryList.Add(inventory);
}
}
#endregion
}
catch (Exception ex)
{
return null;
}
}
// TODO 3.调用SplitInsert方法实现导入操作,注意主键列的配置(建议优化为，ID相同则修改，不同则新增)
var x = Context
.Storageable(inventoryList)
//.SplitInsert(it => !it.Any())
//.WhereColumns(it => it.Id) //如果不是主键可以这样实现（多字段it=>new{it.x1,it.x2}）
.ToStorage();
var result = x.AsInsertable.ExecuteCommand();
var result2 = x.AsUpdateable.IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand(); //插入可插入部分;
var importResult = new ImportResultDto
{
Message = message,
Inserted = x.InsertList.Count,
Updated = x.UpdateList.Count,
ErrorCount = x.ErrorList.Count,
IgnoredCount = x.IgnoreList.Count,
Deleted = x.DeleteList.Count,
Total = x.TotalList.Count,
};
//输出统计
Console.WriteLine(importResult);
// 4.收集错误与忽略信息，返回导入结果ImportResultDto 提示，需要修改IServer相关返回格式
foreach (var item in x.ErrorList)
{
importResult.Errors.Add(
new ImportErrorDto
{
MaterialCode = item.Item.MaterialCode,
Message = item.StorageMessage,
}
);
}
foreach (var item in x.IgnoreList)
{
importResult.Ignored.Add(
new ImportErrorDto
{
MaterialCode = item.Item.MaterialCode,
Message = item.StorageMessage,
}
);
}
return importResult;
}
/// <summary>
/// 导出物料表列表
/// </summary>
/// <returns></returns>
public PagedInfo<MmInventoryExcelDto> SelectInventoryList(
MmInventoryQueryDto inventory,
PagerInfo pager
)
{
// Use the same predicate builder as GetList to support consistent filtering
var predicate = QueryExp(inventory);
var query = Queryable()
.Where(predicate.ToExpression())
.Select(it => new MmInventoryExcelDto
{
Id = it.Id,
MaterialCode = it.MaterialCode,
BatchNo = it.BatchNo,
CurrentQty = it.CurrentQty,
WarehouseCode = it.WarehouseCode,
WarehouseName = it.WarehouseName,
LocationCode = it.LocationCode,
LocationName = it.LocationName,
CreatedTime = it.CreatedTime,
});
return query.ToPage(pager);
}
}
}

257
DOAN.Service/MES/Material/MmRecordInboundService.cs
View File

@@ -5,7 +5,10 @@ using DOAN.Service.BZFM.IBZFMService;
using Infrastructure.Attribute;
using Infrastructure.Converter;
using Infrastructure.Extensions;
using Microsoft.AspNetCore.Http;
using Microsoft.IdentityModel.Tokens;
using NPOI.SS.UserModel;
using NPOI.XSSF.UserModel;
namespace DOAN.Service.BZFM
{
@@ -99,5 +102,259 @@ namespace DOAN.Service.BZFM
return predicate;
}
/// <summary>
/// 导入数据
/// </summary>
/// <param name="formFile"></param>
/// <returns></returns>
public ImportResultDto ImportRecordinbound(IFormFile formFile, string username)
{
string message = "导入成功";
List<MmRecordinboundExcelDto> recordinboundList = new();
using (var stream = formFile.OpenReadStream())
{
try
{
IWorkbook workbook = new XSSFWorkbook(stream);
ISheet sheet = workbook.GetSheetAt(0);
#region 读取excel
// 遍历每一行
for (int row = 1; row <= sheet.LastRowNum; row++)
{
IRow currentRow = sheet.GetRow(row);
if (currentRow != null) // 确保行不为空
{
MmRecordinboundExcelDto recordinbound = new MmRecordinboundExcelDto();
//00 ID
NPOI.SS.UserModel.ICell currentCell_00 = currentRow.GetCell(0);
recordinbound.Id = (int)currentCell_00?.NumericCellValue;
//01 创建时间
NPOI.SS.UserModel.ICell currentCell_01 = currentRow.GetCell(1);
recordinbound.CreatedTime = currentCell_01?.DateCellValue ?? DateTime.Now;
//02 入库单号
NPOI.SS.UserModel.ICell currentCell_02 = currentRow.GetCell(2);
recordinbound.InboundNo = currentCell_02?.ToString();
if (
currentCell_02 == null
|| string.IsNullOrEmpty(recordinbound.InboundNo)
)
{
message = $"入库单号不可为空，第{row + 1}行";
break;
}
//03 物料编码
NPOI.SS.UserModel.ICell currentCell_03 = currentRow.GetCell(3);
recordinbound.MaterialCode = currentCell_03?.ToString();
if (
currentCell_03 == null
|| string.IsNullOrEmpty(recordinbound.MaterialCode)
)
{
message = $"物料编码不可为空，第{row + 1}行";
break;
}
//04 物料名称
NPOI.SS.UserModel.ICell currentCell_04 = currentRow.GetCell(4);
recordinbound.MaterialName = currentCell_04?.ToString();
if (
currentCell_04 == null
|| string.IsNullOrEmpty(recordinbound.MaterialName)
)
{
message = $"物料名称不可为空，第{row + 1}行";
break;
}
//05 库位编码
NPOI.SS.UserModel.ICell currentCell_05 = currentRow.GetCell(5);
recordinbound.LocationCode = currentCell_05?.ToString();
if (
currentCell_05 == null
|| string.IsNullOrEmpty(recordinbound.LocationCode)
)
{
message = $"库位编码不可为空，第{row + 1}行";
break;
}
//06 库位名称
NPOI.SS.UserModel.ICell currentCell_06 = currentRow.GetCell(6);
recordinbound.LocationName = currentCell_06?.ToString();
if (
currentCell_06 == null
|| string.IsNullOrEmpty(recordinbound.LocationName)
)
{
message = $"库位名称不可为空，第{row + 1}行";
break;
}
//07 入库数量
NPOI.SS.UserModel.ICell currentCell_07 = currentRow.GetCell(7);
string QuantityStr = currentCell_07?.ToString();
if (currentCell_07 == null || string.IsNullOrWhiteSpace(QuantityStr))
{
message = $"入库数量不可为空，第{row + 1}行";
break;
}
// 尝试转换为decimal
if (!decimal.TryParse(QuantityStr, out decimal Quantity))
{
message = $"入库数量格式错误（必须是数字），第{row + 1}行";
break;
}
//验证数值范围（可根据业务需求调整）
if (Quantity < 0)
{
message = $"入库数量不能为负数，第{row + 1}行";
break;
}
recordinbound.Quantity = Quantity;
//08 入库类型
NPOI.SS.UserModel.ICell currentCell_08 = currentRow.GetCell(8);
recordinbound.TransactionType = currentCell_08?.ToString();
if (
currentCell_08 == null
|| string.IsNullOrEmpty(recordinbound.TransactionType)
)
{
message = $"入库类型不可为空，第{row + 1}行";
break;
}
//09 仓库编码
NPOI.SS.UserModel.ICell currentCell_09 = currentRow.GetCell(9);
recordinbound.WarehouseCode = currentCell_09?.ToString();
if (
currentCell_09 == null
|| string.IsNullOrEmpty(recordinbound.WarehouseCode)
)
{
message = $"仓库编码不可为空，第{row + 1}行";
break;
}
//10 批次号
NPOI.SS.UserModel.ICell currentCell_10 = currentRow.GetCell(10);
recordinbound.BatchNo = currentCell_10?.ToString() ?? string.Empty;
//11 操作员
NPOI.SS.UserModel.ICell currentCell_11 = currentRow.GetCell(11);
recordinbound.Operator = currentCell_11?.ToString() ?? string.Empty;
//12 供应商编码
NPOI.SS.UserModel.ICell currentCell_12 = currentRow.GetCell(12);
recordinbound.SupplierCode = currentCell_12?.ToString() ?? string.Empty;
//13 供应商名称
NPOI.SS.UserModel.ICell currentCell_13 = currentRow.GetCell(13);
recordinbound.SupplierName = currentCell_13?.ToString() ?? string.Empty;
recordinboundList.Add(recordinbound);
}
}
#endregion
}
catch (Exception ex)
{
return null;
}
}
// TODO 3.调用SplitInsert方法实现导入操作,注意主键列的配置(建议优化为，ID相同则修改，不同则新增)
var x = Context
.Storageable(recordinboundList)
//.SplitInsert(it => !it.Any())
//.WhereColumns(it => it.Id) //如果不是主键可以这样实现（多字段it=>new{it.x1,it.x2}）
.ToStorage();
var result = x.AsInsertable.ExecuteCommand();
var result2 = x.AsUpdateable.IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand(); //插入可插入部分;
var importResult = new ImportResultDto
{
Message = message,
Inserted = x.InsertList.Count,
Updated = x.UpdateList.Count,
ErrorCount = x.ErrorList.Count,
IgnoredCount = x.IgnoreList.Count,
Deleted = x.DeleteList.Count,
Total = x.TotalList.Count,
};
//输出统计
Console.WriteLine(importResult);
// 4.收集错误与忽略信息，返回导入结果ImportResultDto 提示，需要修改IServer相关返回格式
foreach (var item in x.ErrorList)
{
importResult.Errors.Add(
new ImportErrorDto
{
MaterialCode = item.Item.MaterialCode,
Message = item.StorageMessage,
}
);
}
foreach (var item in x.IgnoreList)
{
importResult.Ignored.Add(
new ImportErrorDto
{
MaterialCode = item.Item.MaterialCode,
Message = item.StorageMessage,
}
);
}
return importResult;
}
/// <summary>
/// 导出入库记录列表
/// </summary>
/// <returns></returns>
public PagedInfo<MmRecordinboundExcelDto> SelectRecordinboundList(
MmRecordInboundQueryDto recordinbound,
PagerInfo pager
)
{
// Use the same predicate builder as GetList to support consistent filtering
var predicate = QueryExp(recordinbound);
var query = Queryable()
.Where(predicate.ToExpression())
.Select(it => new MmRecordinboundExcelDto
{
Id = it.Id,
CreatedTime = it.CreatedTime,
InboundNo = it.InboundNo,
MaterialCode = it.MaterialCode,
MaterialName = it.MaterialName,
LocationCode = it.LocationCode,
LocationName = it.LocationName,
Quantity = it.Quantity,
TransactionType = it.TransactionType,
WarehouseCode = it.WarehouseCode,
BatchNo = it.BatchNo,
Operator = it.Operator,
SupplierCode = it.SupplierCode,
SupplierName = it.SupplierName,
});
return query.ToPage(pager);
}
}
}