380 lines
16 KiB
C#
380 lines
16 KiB
C#
using DOAN.Model.BZFM;
|
||
using DOAN.Model.BZFM.Dto;
|
||
using DOAN.Repository;
|
||
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
|
||
{
|
||
/// <summary>
|
||
/// 入库记录表Service业务层处理
|
||
/// </summary>
|
||
[AppService(
|
||
ServiceType = typeof(IMmRecordInboundService),
|
||
ServiceLifetime = LifeTime.Transient
|
||
)]
|
||
public class MmRecordInboundService : BaseService<MmRecordInbound>, IMmRecordInboundService
|
||
{
|
||
/// <summary>
|
||
/// 查询入库记录表列表
|
||
/// </summary>
|
||
/// <param name="parm"></param>
|
||
/// <returns></returns>
|
||
public PagedInfo<MmRecordInboundDto> GetList(MmRecordInboundQueryDto parm)
|
||
{
|
||
var predicate = QueryExp(parm);
|
||
|
||
var response = Queryable()
|
||
.Where(predicate.ToExpression())
|
||
.OrderByDescending(it => it.CreatedTime)
|
||
.ToPage<MmRecordInbound, MmRecordInboundDto>(parm);
|
||
|
||
return response;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取详情
|
||
/// </summary>
|
||
/// <param name="Id"></param>
|
||
/// <returns></returns>
|
||
public MmRecordInbound GetInfo(int Id)
|
||
{
|
||
var response = Queryable().Where(x => x.Id == Id).First();
|
||
|
||
return response;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加入库记录表
|
||
/// </summary>
|
||
/// <param name="model"></param>
|
||
/// <returns></returns>
|
||
public MmRecordInbound AddMmRecordInbound(MmRecordInbound model)
|
||
{
|
||
return Insertable(model).ExecuteReturnEntity();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 修改入库记录表
|
||
/// </summary>
|
||
/// <param name="model"></param>
|
||
/// <returns></returns>
|
||
public int UpdateMmRecordInbound(MmRecordInbound model)
|
||
{
|
||
return Update(model, true);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询导出表达式
|
||
/// </summary>
|
||
/// <param name="parm"></param>
|
||
/// <returns></returns>
|
||
private static Expressionable<MmRecordInbound> QueryExp(MmRecordInboundQueryDto parm)
|
||
{
|
||
if (parm.CreatedTime != null && parm.CreatedTime.Length > 0)
|
||
{
|
||
parm.CreatedTime[0] = DOANConvertDate.ConvertLocalDate(parm.CreatedTime[0]);
|
||
parm.CreatedTime[1] = DOANConvertDate.ConvertLocalDate(parm.CreatedTime[1]);
|
||
parm.CreatedTime[0] = parm.CreatedTime[0].Date;
|
||
parm.CreatedTime[1] = parm.CreatedTime[1].Date;
|
||
}
|
||
var predicate = Expressionable
|
||
.Create<MmRecordInbound>()
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.SupplierCode),
|
||
it => it.SupplierCode.Contains(parm.SupplierCode)
|
||
)
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.Operator),
|
||
it => it.Operator.Contains(parm.Operator)
|
||
)
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.MaterialCode),
|
||
it => it.MaterialCode.Contains(parm.MaterialCode)
|
||
)
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.StoveCode),
|
||
it => it.StoveCode.Contains(parm.StoveCode)
|
||
)
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.InboundNo),
|
||
it => it.InboundNo.Contains(parm.InboundNo)
|
||
)
|
||
.AndIF(
|
||
!string.IsNullOrEmpty(parm.TransactionType),
|
||
it => it.TransactionType.Contains(parm.TransactionType)
|
||
)
|
||
.AndIF(
|
||
parm.CreatedTime != null && parm.CreatedTime[0] > DateTime.MinValue,
|
||
it => it.CreatedTime >= parm.CreatedTime[0]
|
||
)
|
||
.AndIF(
|
||
parm.CreatedTime != null && parm.CreatedTime[1] > DateTime.MinValue,
|
||
it => it.CreatedTime <= parm.CreatedTime[1]
|
||
);
|
||
;
|
||
|
||
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);
|
||
}
|
||
}
|
||
}
|