287 lines
11 KiB
C#
287 lines
11 KiB
C#
|
using Admin.NET.Core.Service;
|
|||
|
|
using Admin.NET.Application.Const;
|
|||
|
|
using Admin.NET.Application.Entity;
|
|||
|
|
using Microsoft.AspNetCore.Http;
|
|||
|
|
namespace Admin.NET.Application;
|
|||
|
|
/// <summary>
|
|||
|
|
/// 分销出库服务
|
|||
|
|
/// </summary>
|
|||
|
|
[ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)]
|
|||
|
|
public class DistributorInvoiceService : IDynamicApiController, ITransient
|
|||
|
|
{
|
|||
|
|
private readonly SqlSugarRepository<DistributorInvoice> _rep;
|
|||
|
|
private readonly PrintCodeDetailService _codeDetailService;
|
|||
|
|
private readonly ProductRetrospectService _productRetrospect;
|
|||
|
|
private readonly ReportTableService _reportTableService;
|
|||
|
|
private readonly OutboundService _outboundService;
|
|||
|
|
private readonly OutboundDetailService _outboundDetailService;
|
|||
|
|
private readonly UserManager _userManager;
|
|||
|
|
public DistributorInvoiceService(SqlSugarRepository<DistributorInvoice> rep,
|
|||
|
|
UserManager userManager,
|
|||
|
|
PrintCodeDetailService codeDetailService,
|
|||
|
|
ReportTableService reportTableService,
|
|||
|
|
OutboundService outboundService,
|
|||
|
|
OutboundDetailService outboundDetailService,
|
|||
|
|
ProductRetrospectService productRetrospect)
|
|||
|
|
{
|
|||
|
|
_rep = rep;
|
|||
|
|
_userManager = userManager;
|
|||
|
|
_codeDetailService = codeDetailService;
|
|||
|
|
_productRetrospect = productRetrospect;
|
|||
|
|
_reportTableService = reportTableService;
|
|||
|
|
_outboundService = outboundService;
|
|||
|
|
_outboundDetailService = outboundDetailService;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 分页查询分销出库
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost]
|
|||
|
|
[ApiDescriptionSettings(Name = "Page")]
|
|||
|
|
public async Task<SqlSugarPagedList<DistributorInvoiceOutput>> Page(DistributorInvoiceInput input)
|
|||
|
|
{
|
|||
|
|
var query = _rep.AsQueryable().Where(a => !a.IsDelete)
|
|||
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
|
|||
|
|
u.Distributor.Contains(input.SearchKey.Trim())
|
|||
|
|
|| u.Remarks.Contains(input.SearchKey.Trim())
|
|||
|
|
)
|
|||
|
|
.WhereIF(input.WarehouseId>0, u => u.WarehouseId == input.WarehouseId)
|
|||
|
|
.WhereIF(input.TargetWarehouseId>0, u => u.TargetWarehouseId == input.TargetWarehouseId)
|
|||
|
|
.WhereIF(input.DistributorId>0, u => u.DistributorId == input.DistributorId)
|
|||
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Distributor), u => u.Distributor.Contains(input.Distributor.Trim()))
|
|||
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Remarks), u => u.Remarks.Contains(input.Remarks.Trim()))
|
|||
|
|
.Select<DistributorInvoiceOutput>();
|
|||
|
|
if(input.StartDateRange != null && input.StartDateRange.Count >0)
|
|||
|
|
{
|
|||
|
|
DateTime? start= input.StartDateRange[0];
|
|||
|
|
query = query.WhereIF(start.HasValue, u => u.StartDate > start);
|
|||
|
|
if (input.StartDateRange.Count >1 && input.StartDateRange[1].HasValue)
|
|||
|
|
{
|
|||
|
|
var end = input.StartDateRange[1].Value.AddDays(1);
|
|||
|
|
query = query.Where(u => u.StartDate < end);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 增加分销出库
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost]
|
|||
|
|
[ApiDescriptionSettings(Name = "Add")]
|
|||
|
|
public async Task<long> Add(AddDistributorInvoiceInput input)
|
|||
|
|
{
|
|||
|
|
var entity = input.Adapt<DistributorInvoice>();
|
|||
|
|
await _rep.InsertAsync(entity);
|
|||
|
|
return entity.Id;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除分销出库
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost]
|
|||
|
|
[ApiDescriptionSettings(Name = "Delete")]
|
|||
|
|
public async Task Delete(DeleteDistributorInvoiceInput input)
|
|||
|
|
{
|
|||
|
|
var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|||
|
|
await _rep.FakeDeleteAsync(entity); //假删除
|
|||
|
|
//await _rep.DeleteAsync(entity); //真删除
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 更新分销出库
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost]
|
|||
|
|
[ApiDescriptionSettings(Name = "Update")]
|
|||
|
|
public async Task Update(UpdateDistributorInvoiceInput input)
|
|||
|
|
{
|
|||
|
|
var entity = input.Adapt<DistributorInvoice>();
|
|||
|
|
await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取分销出库
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpGet]
|
|||
|
|
[ApiDescriptionSettings(Name = "Detail")]
|
|||
|
|
public async Task<DistributorInvoice> Detail([FromQuery] QueryByIdDistributorInvoiceInput input)
|
|||
|
|
{
|
|||
|
|
return await _rep.GetFirstAsync(u => u.Id == input.Id);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取分销出库列表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpGet]
|
|||
|
|
[ApiDescriptionSettings(Name = "List")]
|
|||
|
|
public async Task<List<DistributorInvoiceOutput>> List()
|
|||
|
|
{
|
|||
|
|
return await _rep.AsQueryable().Select<DistributorInvoiceOutput>().Where(a => !a.IsDelete).ToListAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 商品出货
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost]
|
|||
|
|
[ApiDescriptionSettings(Name = "ShipmentProduct")]
|
|||
|
|
public async Task ShipmentProduct(AddProductCodeInput input)
|
|||
|
|
{
|
|||
|
|
if (input == null || input.WarehousingTableId == null || input.CodeDatas == null || input.CodeDatas.Count == 0)
|
|||
|
|
{
|
|||
|
|
throw Oops.Oh(ErrorCodeEnum.xg1002);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
var invoice = await Detail(new QueryByIdDistributorInvoiceInput() { Id = input.WarehousingTableId.Value });
|
|||
|
|
if (invoice == null)
|
|||
|
|
{
|
|||
|
|
throw Oops.Oh(ErrorCodeEnum.xg1002);
|
|||
|
|
}
|
|||
|
|
var codes = string.IsNullOrEmpty(input.CodeDatas[0].BarCode) ? input.CodeDatas.ConvertAll(a => a.QrCode) : input.CodeDatas.ConvertAll(a => a.BarCode);
|
|||
|
|
var details = (await _codeDetailService.List()).FindAll(a => !string.IsNullOrEmpty(a.FatherCode));
|
|||
|
|
var repeatCodes = details.Where(a => !a.IsDelete && codes.Any(b => b == a.Code)).ToList();
|
|||
|
|
if (repeatCodes == null || repeatCodes.Count < 1)
|
|||
|
|
{
|
|||
|
|
throw Oops.Oh(ErrorCodeEnum.xg1002);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var userId = _userManager.UserId;
|
|||
|
|
var userName = _userManager.RealName;
|
|||
|
|
var addOutbound = new AddOutboundInput()
|
|||
|
|
{
|
|||
|
|
//BusinessType = invoice.BusinessType,
|
|||
|
|
//CodeNum = invoice.CodeNum,
|
|||
|
|
//Consignee = invoice.Consignee,
|
|||
|
|
CreateTime = invoice.CreateTime,
|
|||
|
|
CreateUserId = userId,
|
|||
|
|
CreateUserName = userName,
|
|||
|
|
SourceCodeNum = invoice.Id.ToString(),
|
|||
|
|
StartDate = invoice.StartDate,
|
|||
|
|
State = 0,
|
|||
|
|
//Warehouse = invoice.Warehouse,
|
|||
|
|
WarehouseId = invoice.WarehouseId,
|
|||
|
|
TenantId = invoice.TenantId,
|
|||
|
|
};
|
|||
|
|
var outbound = await _outboundService.Add(addOutbound);
|
|||
|
|
|
|||
|
|
|
|||
|
|
var codeIds = new List<long>();
|
|||
|
|
var list = new List<PrintCodeDetailOutput>();
|
|||
|
|
foreach (var c1 in repeatCodes)
|
|||
|
|
{
|
|||
|
|
codeIds.Add(c1.Id);
|
|||
|
|
c1.WarehouseID = null;
|
|||
|
|
//c1.FatherCode = null;
|
|||
|
|
//c1.FatherId = null;
|
|||
|
|
await _codeDetailService.UpdateByEntity(c1.Adapt<PrintCodeDetail>());
|
|||
|
|
list.Add(c1);
|
|||
|
|
var child1 = details.Find(a => a.FatherCode == c1.Code);
|
|||
|
|
if (child1 != null)
|
|||
|
|
{
|
|||
|
|
child1.WarehouseID = null;
|
|||
|
|
await _codeDetailService.UpdateByEntity(child1.Adapt<PrintCodeDetail>());
|
|||
|
|
list.Add(child1);
|
|||
|
|
|
|||
|
|
var child2 = details.Find(a => a.FatherCode == c1.Code);
|
|||
|
|
if (child2 != null)
|
|||
|
|
{
|
|||
|
|
child2.WarehouseID = null;
|
|||
|
|
await _codeDetailService.UpdateByEntity(child2.Adapt<PrintCodeDetail>());
|
|||
|
|
list.Add(child2);
|
|||
|
|
|
|||
|
|
var child3 = details.Find(a => a.FatherCode == c1.Code);
|
|||
|
|
if (child3 != null)
|
|||
|
|
{
|
|||
|
|
child3.WarehouseID = null;
|
|||
|
|
await _codeDetailService.UpdateByEntity(child3.Adapt<PrintCodeDetail>());
|
|||
|
|
list.Add(child3);
|
|||
|
|
|
|||
|
|
var child4 = details.Find(a => a.FatherCode == c1.Code);
|
|||
|
|
if (child4 != null)
|
|||
|
|
{
|
|||
|
|
child4.WarehouseID = null;
|
|||
|
|
await _codeDetailService.UpdateByEntity(child4.Adapt<PrintCodeDetail>());
|
|||
|
|
list.Add(child4);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var addOutboundDetail = new AddOutboundDetailInput() { CodeTableIds = string.Join(",", codeIds), OutboundId = outbound };
|
|||
|
|
await _outboundDetailService.Add(addOutboundDetail);
|
|||
|
|
|
|||
|
|
foreach (var item in list)
|
|||
|
|
{
|
|||
|
|
var report = await GetReport(item.ReportTableId);
|
|||
|
|
var retrospect1 = new AddProductRetrospectInput()
|
|||
|
|
{
|
|||
|
|
BaseCount = item.BaseCount,
|
|||
|
|
BaseUnit = item.BaseUnit,
|
|||
|
|
//Batch = report.Batch,
|
|||
|
|
BusinessType = report.ProductType,
|
|||
|
|
CodeType = item.CodeName,
|
|||
|
|
Location = addOutbound.Consignee,
|
|||
|
|
Department = report.ProductionLine,
|
|||
|
|
//WarehouseID = input.WarehouseId,
|
|||
|
|
WarehousingDate = DateTime.Now,
|
|||
|
|
Count = 1,
|
|||
|
|
CreateTime = DateTime.Now,
|
|||
|
|
ScanCodeTime = DateTime.Now,
|
|||
|
|
CreateUserId = userId,
|
|||
|
|
CreateUserName = userName,
|
|||
|
|
MaterialsId = report.MaterialsId,
|
|||
|
|
OddNumber = report.OddNumber,
|
|||
|
|
Receipt = "分销出库单",
|
|||
|
|
SourceId = outbound,
|
|||
|
|
Unit = item.Unit,
|
|||
|
|
Name = item.CodeName,
|
|||
|
|
Code = item.Code,
|
|||
|
|
//Destination = invoice.Consignee
|
|||
|
|
};
|
|||
|
|
await _productRetrospect.Add(retrospect1);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static Dictionary<long, ReportTable> reportDic = new Dictionary<long, ReportTable>();
|
|||
|
|
private async Task<ReportTable> GetReport(long? reportId)
|
|||
|
|
{
|
|||
|
|
if (reportId == null)
|
|||
|
|
{
|
|||
|
|
return new ReportTable();
|
|||
|
|
}
|
|||
|
|
if (reportDic.ContainsKey(reportId.Value))
|
|||
|
|
{
|
|||
|
|
return reportDic[reportId.Value];
|
|||
|
|
}
|
|||
|
|
var report = await _reportTableService.GetBySource(reportId);
|
|||
|
|
if (report == null)
|
|||
|
|
{
|
|||
|
|
return new ReportTable();
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
return report;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|