using Autofac.Core;
|
using System.Net;
|
using System.Threading.Channels;
|
using WIDESEA_Common.StockEnum;
|
using WIDESEA_Core;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_IStockService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_StockService
|
{
|
/// <summary>
|
/// 库存服务
|
/// </summary>
|
public class StockSerivce : IStockService
|
{
|
public IStockInfoDetailService StockInfoDetailService { get; }
|
public IStockInfoService StockInfoService { get; }
|
public IStockInfoDetail_HtyService StockInfoDetail_HtyService { get; }
|
public IStockInfo_HtyService StockInfo_HtyService { get; }
|
|
|
|
public StockSerivce(
|
IStockInfoDetailService stockInfoDetailService,
|
IStockInfoService stockInfoService,
|
IStockInfoDetail_HtyService stockInfoDetail_HtyService,
|
IStockInfo_HtyService stockInfo_HtyService)
|
{
|
StockInfoDetailService = stockInfoDetailService;
|
StockInfoService = stockInfoService;
|
StockInfoDetail_HtyService = stockInfoDetail_HtyService;
|
StockInfo_HtyService = stockInfo_HtyService;
|
}
|
|
/// <summary>
|
/// 组盘
|
/// </summary>
|
public async Task<bool> GroupPalletAsync(StockDTO stock)
|
{
|
var now = DateTime.Now;
|
var details = stock.Details.Select(item => new Dt_StockInfoDetail
|
{
|
MaterielCode = "电芯",
|
MaterielName = "电芯",
|
StockQuantity = item.Quantity,
|
Unit = "PCS",
|
Creater = "system",
|
OrderNo = "111",
|
ProductionDate = now.ToString(),
|
EffectiveDate = now.AddYears(1).ToString(),
|
SerialNumber = item.CellBarcode,
|
InboundOrderRowNo = item.Channel,
|
Status = StockStatusEmun.组盘暂存.GetHashCode(),
|
}).ToList();
|
|
var existingStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
|
if (existingStock != null)
|
{
|
details.ForEach(d => d.StockId = existingStock.Id);
|
return await StockInfoDetailService.Repository.AddDataAsync(details) > 0;
|
}
|
|
var entity = new Dt_StockInfo
|
{
|
PalletCode = stock.TargetPalletNo,
|
WarehouseId = 1,
|
StockStatus = 1,
|
Creater = "system",
|
Details = details
|
};
|
|
return StockInfoService.Repository.AddData(entity, x => x.Details);
|
}
|
|
/// <summary>
|
/// 换盘
|
/// </summary>
|
public async Task<bool> ChangePalletAsync(StockDTO stock)
|
{
|
if (stock == null ||
|
string.IsNullOrWhiteSpace(stock.TargetPalletNo) ||
|
string.IsNullOrWhiteSpace(stock.SourcePalletNo) ||
|
string.Equals(stock.SourcePalletNo, stock.TargetPalletNo, StringComparison.OrdinalIgnoreCase))
|
{
|
return false;
|
}
|
|
var sourceStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
|
if (sourceStock == null) return false;
|
|
var targetStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
|
if (targetStock == null)
|
{
|
var newStock = new Dt_StockInfo
|
{
|
PalletCode = stock.TargetPalletNo,
|
WarehouseId = sourceStock.WarehouseId,
|
StockStatus = sourceStock.StockStatus,
|
Creater = "system"
|
};
|
|
var newId = StockInfoService.Repository.AddData(newStock);
|
if (newId <= 0) return false;
|
|
targetStock = newStock;
|
targetStock.Id = newId;
|
}
|
|
var serialNumbers = stock.Details.Select(d => d.CellBarcode).Distinct().ToList();
|
if (!serialNumbers.Any()) return false;
|
|
var detailEntities = StockInfoDetailService.Repository.QueryData(
|
d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.SerialNumber));
|
if (!detailEntities.Any()) return false;
|
|
if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "换盘")) <= 0)
|
return false;
|
|
if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock, targetStock }, "换盘")) <= 0)
|
return false;
|
|
detailEntities.ForEach(d => d.StockId = targetStock.Id);
|
return await StockInfoDetailService.Repository.UpdateDataAsync(detailEntities);
|
}
|
|
/// <summary>
|
/// 拆盘
|
/// </summary>
|
public async Task<bool> SplitPalletAsync(StockDTO stock)
|
{
|
if (stock == null || string.IsNullOrWhiteSpace(stock.SourcePalletNo))
|
return false;
|
|
var sourceStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
|
if (sourceStock == null) return false;
|
|
var serialNumbers = stock.Details.Select(d => d.CellBarcode).Distinct().ToList();
|
if (!serialNumbers.Any())
|
{
|
serialNumbers = sourceStock.Details
|
.Where(x => stock.Details.Any(d => d.Channel == x.InboundOrderRowNo))
|
.Select(x => x.SerialNumber)
|
.ToList();
|
}
|
|
var detailEntities = StockInfoDetailService.Repository.QueryData(
|
d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.SerialNumber));
|
if (!detailEntities.Any()) return false;
|
|
if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "拆盘")) <= 0)
|
return false;
|
|
if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock }, "拆盘")) <= 0)
|
return false;
|
|
return await StockInfoDetailService.Repository.DeleteDataAsync(detailEntities);
|
}
|
|
/// <summary>
|
/// 堆垛机换盘后更新库存信息（清空库位信息）
|
/// </summary>
|
/// <param name="stock"></param>
|
/// <returns></returns>
|
public async Task<WebResponseContent> UpdateStockInfoAsync(StockInfoDTO stock)
|
{
|
WebResponseContent content = new WebResponseContent();
|
if (string.IsNullOrWhiteSpace(stock.PalletCode)) return content.Error("托盘号不能为空");
|
|
var existingStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.PalletCode);
|
if (existingStock == null) return content.Error("托盘信息不存在");
|
|
existingStock.LocationCode = "";
|
existingStock.LocationId = 0;
|
|
var result = await StockInfoService.Repository.UpdateDataAsync(existingStock);
|
if (!result) return content.Error("更新库存信息失败");
|
return content.OK("更新库存信息成功");
|
}
|
|
private static List<Dt_StockInfoDetail_Hty> CreateDetailHistory(IEnumerable<Dt_StockInfoDetail> details, string operateType)
|
{
|
var now = DateTime.Now;
|
return details.Select(d => new Dt_StockInfoDetail_Hty
|
{
|
SourceId = d.Id,
|
OperateType = operateType,
|
InsertTime = now,
|
StockId = d.StockId,
|
MaterielCode = d.MaterielCode,
|
MaterielName = d.MaterielName,
|
OrderNo = d.OrderNo,
|
BatchNo = d.BatchNo,
|
ProductionDate = d.ProductionDate,
|
EffectiveDate = d.EffectiveDate,
|
SerialNumber = d.SerialNumber,
|
StockQuantity = d.StockQuantity,
|
OutboundQuantity = d.OutboundQuantity,
|
Status = d.Status,
|
Unit = d.Unit,
|
InboundOrderRowNo = d.InboundOrderRowNo,
|
Remark = d.Remark,
|
Creater = d.Creater,
|
CreateDate = d.CreateDate,
|
Modifier = d.Modifier,
|
ModifyDate = d.ModifyDate
|
}).ToList();
|
}
|
|
private static List<Dt_StockInfo_Hty> CreateStockHistory(IEnumerable<Dt_StockInfo> stocks, string operateType)
|
{
|
var now = DateTime.Now;
|
return stocks.Select(s => new Dt_StockInfo_Hty
|
{
|
SourceId = s.Id,
|
OperateType = operateType,
|
InsertTime = now,
|
PalletCode = s.PalletCode,
|
PalletType = s.PalletType,
|
LocationCode = s.LocationCode,
|
WarehouseId = s.WarehouseId,
|
StockStatus = s.StockStatus,
|
Remark = s.Remark,
|
Creater = s.Creater,
|
CreateDate = s.CreateDate,
|
Modifier = s.Modifier,
|
ModifyDate = s.ModifyDate
|
}).ToList();
|
}
|
|
}
|
}
|
