using WIDESEA_Common.StockEnum;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_IRecordService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_RecordService
|
{
|
/// <summary>
|
/// 库存数量变更记录服务实现类
|
/// </summary>
|
public partial class StockQuantityChangeRecordService : ServiceBase<Dt_StockQuantityChangeRecord, IRepository<Dt_StockQuantityChangeRecord>>, IStockQuantityChangeRecordService
|
{
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public StockQuantityChangeRecordService(IRepository<Dt_StockQuantityChangeRecord> baseDal) : base(baseDal)
|
{
|
}
|
|
/// <summary>
|
/// 获取库存数量变更记录仓储接口
|
/// </summary>
|
public IRepository<Dt_StockQuantityChangeRecord> Repository => BaseDal;
|
|
/// <summary>
|
/// 记录库存变更。
|
/// </summary>
|
public async Task<bool> AddChangeRecordAsync(
|
Dt_StockInfo? beforeStock,
|
Dt_StockInfo? afterStock,
|
StockChangeTypeEnum changeType,
|
int? taskNum = null,
|
string? orderNo = null,
|
string? remark = null)
|
{
|
if (beforeStock == null && afterStock == null)
|
return false;
|
|
var beforeQuantity = GetStockQuantity(beforeStock);
|
var afterQuantity = GetStockQuantity(afterStock);
|
var beforeStatus = beforeStock?.StockStatus ?? 0;
|
var afterStatus = afterStock?.StockStatus ?? 0;
|
int? beforeLocationId = beforeStock?.LocationId > 0 ? beforeStock.LocationId : (int?)null;
|
int? afterLocationId = afterStock?.LocationId > 0 ? afterStock.LocationId : (int?)null;
|
var beforeLocationCode = beforeStock?.LocationCode;
|
var afterLocationCode = afterStock?.LocationCode;
|
|
if (beforeQuantity == afterQuantity &&
|
beforeStatus == afterStatus &&
|
beforeLocationId == afterLocationId &&
|
beforeLocationCode == afterLocationCode)
|
{
|
return true;
|
}
|
|
var currentStock = afterStock ?? beforeStock!;
|
Dt_StockQuantityChangeRecord record = new Dt_StockQuantityChangeRecord
|
{
|
StockDetailId = currentStock.Id,
|
PalleCode = currentStock.PalletCode,
|
MaterielCode = GetFirstValue(currentStock.Details?.Select(x => x.MaterielCode)),
|
MaterielName = GetFirstValue(currentStock.Details?.Select(x => x.MaterielName)),
|
BatchNo = GetFirstValue(currentStock.Details?.Select(x => x.BatchNo)),
|
SerilNumber = GetFirstValue(currentStock.Details?.Select(x => x.SerialNumber)),
|
OrderNo = orderNo,
|
TaskNum = taskNum,
|
ChangeType = (int)changeType,
|
ChangeQuantity = afterQuantity - beforeQuantity,
|
BeforeQuantity = beforeQuantity,
|
AfterQuantity = afterQuantity,
|
BeforeStatus = beforeStatus,
|
AfterStatus = afterStatus,
|
BeforeLocationId = beforeLocationId,
|
AfterLocationId = afterLocationId,
|
BeforeLocationCode = beforeLocationCode,
|
AfterLocationCode = afterLocationCode,
|
Remark = remark
|
};
|
|
return await BaseDal.AddDataAsync(record) > 0;
|
}
|
|
private static float GetStockQuantity(Dt_StockInfo? stockInfo)
|
{
|
if (stockInfo?.Details == null || !stockInfo.Details.Any())
|
return 0;
|
|
return stockInfo.Details.Sum(x => x.StockQuantity);
|
}
|
|
private static string GetFirstValue(IEnumerable<string>? values)
|
{
|
return values?.FirstOrDefault() ?? string.Empty;
|
}
|
}
|
}
|
