using DS.Module.Core; using DS.Module.Core.Enums; using DS.Module.Core.Extensions; using DS.WMS.Core.Application.Dtos; using DS.WMS.Core.Application.Entity; using DS.WMS.Core.Application.Method; using DS.WMS.Core.Fee.Entity; using DS.WMS.Core.Invoice.Dto; using DS.WMS.Core.Invoice.Dtos; using DS.WMS.Core.Invoice.Interface; using DS.WMS.Core.Sys.Entity; using DS.WMS.Core.Sys.Interface; using Microsoft.Extensions.DependencyInjection; using SqlSugar; namespace DS.WMS.Core.Invoice.Method { /// /// 发票服务基类 /// /// public class InvoiceService : ApplicationServiceBase, IInvoiceService where TEntity : Entity.Invoice, new() { readonly Lazy CommonService; /// /// 初始化 /// /// public InvoiceService(IServiceProvider provider) : base(provider) { CommonService = new Lazy(provider.GetRequiredService()); } /// /// 获取分页列表 /// /// /// public async Task>> GetListAsync(PageRequest request) { var query = TenantDb.Queryable() .Select(i => new InvoiceDto { Id = i.Id, InvoiceNO = i.InvoiceNO, BillNO = i.BillNO, InvoiceDate = i.InvoiceDate, CustomerId = i.CustomerId, CustomerName = i.CustomerName, Type = i.Type, Category = i.Category, InvoiceHeader = i.InvoiceHeader, TaxID = i.TaxID, CustomerAddTel = i.CustomerAddTel, CustomerBank = i.CustomerBank, AutualCustomerName = i.AutualCustomerName, Currency = i.Currency, ReceiptCurrency = i.ReceiptCurrency, ApplyAmount = i.ApplyAmount, InvoiceAmount = i.InvoiceAmount, OperatorId = i.OperatorId, IsLocked = i.IsLocked, LockUserId = i.LockUserId, LockTime = i.LockTime, TaxRate = i.TaxRate, OrgId = i.OrgId, SaleDeptId = i.SaleDeptId, IsCancelled = i.IsCancelled, CancelUserId = i.CancelUserId, CancelTime = i.CancelTime, CreateTime = i.CreateTime, CreateBy = i.CreateBy, InvoiceApplicationList = SqlFunc.Subqueryable().InnerJoin((d, a) => d.ApplicationId == i.Id && d.Category == DetailCategory.InvoiceIssuance && d.RefId == a.Id) .GroupBy((d, a) => a.ApplicationNO).ToList((d, a) => a.ApplicationNO) }); if (!request.OtherQueryCondition.IsNullOrEmpty()) { query = query.Where(i => i.InvoiceApplicationList.Contains(request.OtherQueryCondition)); } var whereList = request.GetConditionalModels(Db); var result = await query.Where(whereList).ToQueryPageAsync(request.PageCondition); if (result.Data.Count > 0) { var userIds = result.Data.Select(x => x.CreateBy) .Union(result.Data.Where(x => x.LockUserId.HasValue).Select(x => x.LockUserId.Value)) .Union(result.Data.Where(x => x.OperatorId.HasValue).Select(x => x.OperatorId.Value)) .Distinct(); var users = await Db.Queryable().Where(x => userIds.Contains(x.Id)).Select(x => new { x.Id, x.UserName }).ToListAsync(); var orgIds = result.Data.Where(x => x.SaleDeptId.HasValue).Select(x => x.SaleDeptId.Value) .Union(result.Data.Where(x => x.OrgId.HasValue).Select(x => x.OrgId.Value)) .Distinct(); var orgs = await Db.Queryable().Where(x => orgIds.Contains(x.Id)).Select(x => new { x.Id, x.OrgName }).ToListAsync(); foreach (var item in result.Data) { item.CreateByName = users.Find(x => x.Id == item.CreateBy)?.UserName; item.LockUserName = users.Find(x => x.Id == item.LockUserId)?.UserName; item.OperatorName = users.Find(x => x.Id == item.OperatorId)?.UserName; item.SaleDeptName = orgs.Find(x => x.Id == item.SaleDeptId)?.OrgName; item.OrgName = orgs.Find(x => x.Id == item.OrgId)?.OrgName; } } return result; } /// /// 获取发票详情 /// /// 发票ID /// public async Task> GetAsync(long id) { var invoice = await TenantDb.Queryable().Select().FirstAsync(x => x.Id == id); if (invoice != null) { invoice.Details = await CreateApplicationDetailQuery((d, f, s) => d.ApplicationId == id && d.Category == DetailCategory.InvoiceIssuance) .Select(x => new ApplicationDetailDto { Id = x.Id, ApplicationId = x.ApplicationId, RecordId = x.RecordId, FeeName = x.FeeName, FeeType = x.FeeType, ApplyAmount = x.ApplyAmount, ExchangeRate = x.ExchangeRate, Currency = x.Currency, OriginalAmount = x.OriginalAmount, OriginalCurrency = x.OriginalCurrency, OriginalRate = x.OriginalRate, CustomerNo = x.CustomerNo, MBLNO = x.MBLNO, ClientName = x.ClientName, ETD = x.ETD, SaleName = x.SaleName, SourceName = x.SourceName, LoadPort = x.LoadPort, Vessel = x.Vessel, Voyage = x.Voyage, }).ToListAsync(); invoice.Summary = invoice.Details.GroupBy(x => new { x.FeeType, x.Currency }).Select(x => new SummaryItem { FeeType = x.Key.FeeType, Currency = x.Key.Currency, Amount = x.Sum(y => y.ApplyAmount) }).ToList(); invoice.InvoiceDetails = await TenantDb.Queryable().Where( x => x.ApplicationId == id && x.Category == DetailCategory.InvoiceIssuance).ToListAsync(); } return DataResult.Success(invoice); } #pragma warning disable CS4014 /// /// 提交发票开票 /// /// 请求参数 /// public async Task> SaveAsync(InvoiceRequest request) { var invoice = request.Invoice; if (invoice.InvoiceDate == default) invoice.InvoiceDate = DateTime.Now; if (invoice.Currency.IsNullOrEmpty()) invoice.Currency = RMB_CODE; TEntity? dbValue = default; if (request.Invoice.Id > 0) { dbValue = await TenantDb.Queryable().Select(x => new TEntity { Id = x.Id, IsLocked = x.IsLocked, Type = x.Type, }).FirstAsync(x => x.Id == request.Invoice.Id); } var result = EnsureSettlement(request.Invoice, dbValue); if (!result.Succeeded) return DataResult.Failed(result.Message, result.MultiCode); //按发票申请 if (request.Applications != null && request.Applications.Count > 0) { var ids = request.Applications.Select(x => x.ApplicationId); var details = await TenantDb.Queryable() .InnerJoin((x, y) => x.ApplicationId == y.Id) .Where((x, y) => ids.Contains(x.ApplicationId) && x.Category == DetailCategory.InvoiceApplication) .Select((x, y) => new { x.Id, x.ApplicationId, x.RecordId, x.CustomerName, x.FeeId, x.FeeType, x.FeeName, x.ApplyAmount, x.OriginalAmount, x.Currency, x.OriginalCurrency, x.ProcessedAmount, x.OriginalProcessedAmount, y.CustomerId }).ToListAsync(); invoice.Details = new List(details.Count); foreach (var item in details) { if (request.Invoice.CustomerId == 0) { request.Invoice.CustomerId = item.CustomerId; request.Invoice.CustomerName = item.CustomerName; } else if (request.Invoice.CustomerId != item.CustomerId) //校验开票单位是否一致 { return DataResult.FailedWithDesc(nameof(MultiLanguageConst.InvoiceCustomerOnlyOne)); } //需转换为费用明细 var detail = new ApplicationDetail { ApplicationId = request.Invoice.Id, RefId = item.ApplicationId, DetailId = item.Id, RecordId = item.RecordId, Category = DetailCategory.InvoiceIssuance, CustomerName = item.CustomerName, FeeId = item.FeeId, FeeName = item.FeeName, FeeType = item.FeeType, Currency = RMB_CODE, OriginalCurrency = item.Currency, ApplyAmount = item.ApplyAmount - item.ProcessedAmount, OriginalAmount = item.OriginalAmount - item.OriginalProcessedAmount }; var app = request.Applications.Find(x => x.ApplicationId == item.ApplicationId); if (app != null && app.Currency != invoice.Currency) detail.ExchangeRate = app.ExchangeRate; else detail.ExchangeRate = 1m; if (detail.ExchangeRate.HasValue) detail.ApplyAmount = detail.ApplyAmount * detail.ExchangeRate.Value; invoice.Details.Add(detail); } } //自由申请 if (request.Details?.Count > 0) { if (invoice.Id == 0 && invoice.CustomerId == 0) { var first = request.Details[0]; invoice.CustomerId = first.CustomerId.GetValueOrDefault(); invoice.CustomerName = first.CustomerName; } //将请求明细转换为数据库的费用明细 invoice.Details = request.Details.Select(x => new ApplicationDetail { ApplicationId = x.ApplicationId, RefId = x.RefId, DetailId = x.Id == 0 ? null : x.Id, RecordId = x.RecordId, Category = DetailCategory.InvoiceIssuance, CustomerName = x.CustomerName ?? invoice.CustomerName, FeeId = x.FeeId, FeeName = x.FeeName, FeeType = x.FeeType, ApplyAmount = x.Amount, Currency = x.Currency, ExchangeRate = x.ExchangeRate, OriginalAmount = x.OriginalAmount, OriginalCurrency = x.OriginalCurrency ?? (invoice.Currency.IsNullOrEmpty() ? x.Currency : invoice.Currency), }).ToList(); } if (invoice.Details?.Count > 0) { //金额禁止为0 if (invoice.Details.Any(x => x.ApplyAmount == 0 || x.OriginalAmount == 0)) return DataResult.FailedWithDesc(nameof(MultiLanguageConst.AmountCannotBeZero)); if (invoice.Details.Any(x => x.OriginalCurrency.IsNullOrEmpty())) return DataResult.FailedWithDesc(nameof(MultiLanguageConst.OriginalCurrencyCanNotNull)); if (invoice.Details.Any(x => x.Currency != invoice.Currency && x.ExchangeRate == null)) return DataResult.FailedWithDesc(nameof(MultiLanguageConst.NeedExchangeRate)); result = await PreSaveAsync(invoice); if (!result.Succeeded) return DataResult.Failed(result.Message, result.MultiCode); invoice.ApplyAmount = invoice.Details.Sum(x => x.ApplyAmount); invoice.AmountUppercase = new Money(invoice.ApplyAmount).ToString(); invoice.OriginalAmount = invoice.Details.Sum(x => x.OriginalAmount); invoice.OtherInvoiceAmount = invoice.Details.Where(x => x.Currency != RMB_CODE).Sum(x => x.OriginalAmount); } await TenantDb.Ado.BeginTranAsync(); try { if (invoice.Id == 0)//新增 { //创建时需要生成申请单编号 var sequence = CommonService.Value.GetSequenceNext(); if (!sequence.Succeeded) { return DataResult.Failed(sequence.Message, MultiLanguageConst.SequenceSetNotExist); } invoice.BillNO = sequence.Data; //关联导航属性插入 await TenantDb.InsertNav(invoice).Include(x => x.Details).ExecuteCommandAsync(); } else//编辑 { if (invoice.Details?.Count > 0) { await TenantDb.Insertable(invoice.Details).ExecuteCommandAsync(); ////因需要重新生成明细,所以要先清空现有发票明细 //await TenantDb.Deleteable().Where(x => x.ApplicationId == invoice.Id).ExecuteCommandAsync(); } else if (invoice.InvoiceDetails?.Count > 0) { //更新发票明细 await TenantDb.Updateable(invoice.InvoiceDetails).IgnoreColumns(x => new { x.Category }).ExecuteCommandAsync(); } await TenantDb.Updateable(invoice).IgnoreColumns(x => new { x.BillNO, x.IsLocked, x.CreateBy, x.CreateTime, x.Deleted, x.DeleteBy, x.DeleteTime }).ExecuteCommandAsync(); } if (invoice.Details?.Count > 0) { //更新费用记录的已开票金额 var fees = invoice.Details.Select(x => new FeeRecord { Id = x.RecordId, InvoiceAmount = x.OriginalAmount }).ToList(); await TenantDb.Updateable(fees) .PublicSetColumns(x => x.InvoiceAmount, "+") .UpdateColumns(x => new { x.InvoiceAmount }) .ExecuteCommandAsync(); await BuildInvoiceDetailAsync([invoice]); if (invoice.InvoiceDetails?.Count > 0) await TenantDb.Insertable(invoice.InvoiceDetails).ExecuteCommandAsync(); } await OnSaveAsync(invoice); await TenantDb.Ado.CommitTranAsync(); PostSaveAsync(invoice); return DataResult.Success(invoice); } catch (Exception ex) { await TenantDb.Ado.RollbackTranAsync(); await ex.LogAsync(Db); return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } } /// /// 用于发票的状态检查 /// /// 提交的发票 /// 数据库值,新增时为null /// protected virtual DataResult EnsureSettlement(TEntity invoice, TEntity? dbValue) { if (dbValue != null && dbValue.IsLocked) return DataResult.FailedWithDesc(nameof(MultiLanguageConst.InvoiceIsLocked)); return DataResult.Success; } /// /// 在保存前调用 /// /// 发票 /// protected virtual Task PreSaveAsync(TEntity invoice) => Task.FromResult(DataResult.Success); /// /// 在保存时调用 /// /// 要保存的发票 /// protected virtual Task OnSaveAsync(TEntity invoice) => Task.CompletedTask; /// /// 在保存完成后调用 /// /// 发票 protected virtual Task PostSaveAsync(TEntity invoice) => Task.CompletedTask; /// /// 删除发票 /// /// 发票ID /// public async Task DeleteAsync(params long[] ids) { var apps = await TenantDb.Queryable().Where(x => ids.Contains(x.Id)).Select(x => new TEntity { Id = x.Id, IsLocked = x.IsLocked }).ToListAsync(); var details = await TenantDb.Queryable().Where(x => ids.Contains(x.ApplicationId)).Select( x => new ApplicationDetail { Id = x.Id, ApplicationId = x.ApplicationId, DetailId = x.DetailId, RefId = x.RefId, RecordId = x.RecordId, ApplyAmount = x.ApplyAmount, OriginalAmount = x.OriginalAmount }).ToListAsync(); foreach (var app in apps) app.Details = details.FindAll(x => x.ApplicationId == app.Id); await TenantDb.Ado.BeginTranAsync(); var result = PreDelete(apps); if (!result.Succeeded) return result; try { await OnDeleteDetailAsync(apps, DeleteOption.Entire); await TenantDb.DeleteNav(x => ids.Contains(x.Id)).Include(x => x.Details).ExecuteCommandAsync(); await TenantDb.Ado.CommitTranAsync(); PostDeleteAsync(apps, DeleteOption.Entire); return DataResult.Success; } catch (Exception ex) { await TenantDb.Ado.RollbackTranAsync(); await ex.LogAsync(Db); return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } } /// /// 删除发票费用明细 /// /// 明细ID /// public async Task DeleteDetailAsync(params long[] ids) { var details = await TenantDb.Queryable().Where(x => ids.Contains(x.Id)).Select( x => new ApplicationDetail { Id = x.Id, ApplicationId = x.ApplicationId, DetailId = x.DetailId, RefId = x.RefId, RecordId = x.RecordId, ApplyAmount = x.ApplyAmount, OriginalAmount = x.OriginalAmount }).ToListAsync(); var appIds = details.Select(x => x.ApplicationId).Distinct().ToList(); var apps = await TenantDb.Queryable().Where(x => appIds.Contains(x.Id)).Select(x => new TEntity { Id = x.Id, IsLocked = x.IsLocked }).ToListAsync(); foreach (var app in apps) app.Details = details.FindAll(x => x.ApplicationId == app.Id); var result = PreDelete(apps); if (!result.Succeeded) return result; await TenantDb.Ado.BeginTranAsync(); try { await OnDeleteDetailAsync(apps, DeleteOption.DetailOnly); await TenantDb.Deleteable(details).ExecuteCommandAsync(); await TenantDb.Ado.CommitTranAsync(); PostDeleteAsync(apps, DeleteOption.Entire); return DataResult.Success; } catch (Exception ex) { await TenantDb.Ado.RollbackTranAsync(); await ex.LogAsync(Db); return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } } /// /// 删除发票明细 /// /// 发票明细ID /// public async Task DeleteInvoiceDetailAsync(params long[] ids) { int rows = await TenantDb.Deleteable().Where(x => ids.Contains(x.Id)).ExecuteCommandAsync(); return rows > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } /// /// 在删除发票或其明细之前调用,用于检查状态 /// /// 发票 /// protected virtual DataResult PreDelete(List invoices) { if (invoices.Any(x => x.IsLocked)) return DataResult.FailedWithDesc(nameof(MultiLanguageConst.InvoiceIsLocked)); return DataResult.Success; } /// /// 在执行删除发票或其明细时调用 /// /// 发票及其明细 /// 发票删除选项 /// protected virtual async Task OnDeleteDetailAsync(List invoices, DeleteOption deleteOption) { var excludeIds = invoices.SelectMany(x => x.Details).Select(x => x.Id).ToList(); //await TenantDb.Deleteable().Where(x => excludeIds.Contains(x.Id)).ExecuteCommandAsync(); if (deleteOption == DeleteOption.DetailOnly) { var appIds = invoices.Select(x => x.Id).ToList(); var details = await TenantDb.Queryable().Where(x => appIds.Contains(x.ApplicationId) && !excludeIds.Contains(x.Id)) .Select(x => new ApplicationDetail { Id = x.Id, ApplicationId = x.ApplicationId, RecordId = x.RecordId, FeeId = x.FeeId, ApplyAmount = x.ApplyAmount }).ToListAsync(); foreach (var item in invoices) { //重新设置申请明细与总金额 item.Details = details.FindAll(x => x.ApplicationId == item.Id); item.ApplyAmount = item.Details.Sum(x => x.ApplyAmount); item.AmountUppercase = new Money(item.ApplyAmount).ToString(); } ////删除明细需要同时变更发票明细 //await CreateInvoiceDetailsAsync(invoices); //var invDetails = invoices.SelectMany(x => x.InvoiceDetails).ToList(); //if (invDetails.Count > 0) // await TenantDb.Insertable(invDetails).ExecuteCommandAsync(); await TenantDb.Updateable(invoices).UpdateColumns(x => new { x.ApplyAmount, x.AmountUppercase }).ExecuteCommandAsync(); } //还原费用表的已开票金额 var fees = invoices.SelectMany(x => x.Details).Select(x => new FeeRecord { Id = x.RecordId, InvoiceAmount = x.OriginalAmount }).ToList(); await TenantDb.Updateable(fees) .PublicSetColumns(it => it.InvoiceAmount, "-").UpdateColumns(x => new { x.InvoiceAmount }) .ExecuteCommandAsync(); } /// /// 在删除完成后调用 /// /// 发票及其明细 /// 发票删除选项 protected virtual Task PostDeleteAsync(List invoices, DeleteOption deleteOption) => Task.CompletedTask; /// /// 生成发票明细 /// /// /// protected async Task BuildInvoiceDetailAsync(IEnumerable invoices) { foreach (var invoice in invoices) { if (invoice.Details?.Count > 0 && (invoice.InvoiceDetails == null || invoice.InvoiceDetails.Count == 0)) { var ids = invoice.Details.Select(x => x.RecordId).ToList(); var feesCodes = await TenantDb.Queryable().InnerJoin((f, c) => f.FeeId == c.Id && ids.Contains(f.Id)) .Select((f, c) => new { FeeId = c.Id, c.GoodName }).ToListAsync(); var list = feesCodes.GroupBy(x => x.GoodName).Select(x => new { Name = x.Key, FeeIds = x.Select(y => y.FeeId) }).ToList(); invoice.InvoiceDetails = new List(list.Count); foreach (var item in list) { var invDetail = new InvoiceDetail { ApplicationId = invoice.Id, Name = item.Name, TaxRate = invoice.TaxRate, TaxUnitPrice = invoice.Details.FindAll(x => item.FeeIds.Contains(x.FeeId)).Sum(x => x.ApplyAmount), Category = DetailCategory.InvoiceIssuance }; invDetail.TaxAmount = invDetail.TaxUnitPrice * invoice.TaxRate; invDetail.UnitPrice = invDetail.TaxUnitPrice - invDetail.TaxAmount; invoice.InvoiceDetails.Add(invDetail); invoice.InvoiceAmount = invoice.InvoiceDetails.Sum(x => x.TaxUnitPrice); } } } } /// /// 设置发票的锁定状态 /// /// 是否锁定 /// 发票ID /// public async Task SetLockAsync(bool isLocked, params long[] ids) { var dt = DateTime.Now; var userId = long.Parse(User.UserId); var list = ids.Select(x => new TEntity { Id = x, IsLocked = isLocked, LockTime = isLocked ? dt : null, LockUserId = isLocked ? userId : null }).ToList(); int rows = await TenantDb.Updateable(list) .UpdateColumns(x => new { x.IsLocked, x.LockTime, x.LockUserId }).ExecuteCommandAsync(); return rows > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } /// /// 设置发票的作废状态 /// /// 是否锁定 /// 发票ID /// public async Task SetCancelAsync(bool isCancelled, params long[] ids) { var dt = DateTime.Now; var userId = long.Parse(User.UserId); var list = ids.Select(x => new TEntity { Id = x, IsCancelled = isCancelled, CancelTime = isCancelled ? dt : null, CancelUserId = isCancelled ? userId : null }).ToList(); int rows = await TenantDb.Updateable(list) .UpdateColumns(x => new { x.IsCancelled, x.CancelTime, x.CancelUserId }).ExecuteCommandAsync(); return rows > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed)); } } }