diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/INVOICE_SERVICE.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/INVOICE_SERVICE.cs index 3e1c6510..f6cbf570 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/INVOICE_SERVICE.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/INVOICE_SERVICE.cs @@ -1,9 +1,14 @@ using System; +using System.Collections; using System.Collections.Generic; using System.ComponentModel.DataAnnotations; +using System.DirectoryServices.ActiveDirectory; using System.Linq; using System.Reflection; +using System.Security.Policy; using System.Threading.Tasks; +using DocumentFormat.OpenXml.Drawing; +using DocumentFormat.OpenXml.Wordprocessing; using EFCore.BulkExtensions; using Magicodes.ExporterAndImporter.Core; using Magicodes.ExporterAndImporter.Csv; @@ -11,6 +16,7 @@ using Magicodes.ExporterAndImporter.Excel; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; +using Microsoft.CodeAnalysis.Operations; using Microsoft.OpenApi.Writers; using SettleAccount.Domain.BQ; using ShardingCore.Extensions; @@ -27,11 +33,20 @@ using Win.Sfs.SettleAccount.Bases; using Win.Sfs.SettleAccount.Bases.DomainServices; using Win.Sfs.SettleAccount.CommonManagers; using Win.Sfs.SettleAccount.Constant; +using Win.Sfs.SettleAccount.Customers; using Win.Sfs.SettleAccount.Entities.BQ.Dtos; using Win.Sfs.SettleAccount.Entities.BQ.Managers; +using Win.Sfs.SettleAccount.Entities.BQ.Syncs; +using Win.Sfs.SettleAccount.Entities.BQ.Temp; +using Win.Sfs.SettleAccount.Entities.Invoices; +using Win.Sfs.SettleAccount.EntityFrameworkCore; using Win.Sfs.SettleAccount.ExcelImporter; using Win.Sfs.SettleAccount.ExportReports; +using Win.Sfs.SettleAccount.Suppliers; +using Win.Sfs.Shared; using Win.Sfs.Shared.RepositoryBase; +using static Dm.parser.LVal; +using static LinqToDB.Sql; namespace Win.Sfs.SettleAccount.Entities.BQ { @@ -39,6 +54,19 @@ namespace Win.Sfs.SettleAccount.Entities.BQ [Route("api/settleaccount/[controller]/[action]")] public class INVOICE_SERVICE : BASE_SERVICE { + /// + /// 数据上下文 + /// + private readonly SettleAccountDbContext _settleAccountDbContext; + /// + /// WMS数据上下文 + /// + private readonly WMSBJBMPTDbContext _wmsBJBMPTContext; + /// + /// 数据中心S数据上下文 + /// + private readonly ExChangeCenterDbContext _exChangeCenterDbContext; + private readonly INormalEfCoreRepository _repository; private readonly INormalEfCoreRepository _wRepository; private readonly INormalEfCoreRepository _sRepository; @@ -49,7 +77,11 @@ namespace Win.Sfs.SettleAccount.Entities.BQ private readonly HBPO_CAN_SA_MNG _hbpoMng; private readonly INV_MNG _invMng; private readonly BaseDomainService _baseservice; - public INVOICE_SERVICE(IExcelImportAppService excelImportService, + public INVOICE_SERVICE( + SettleAccountDbContext settleAccountDbContext, + WMSBJBMPTDbContext wmsBJBMPTContext, + ExChangeCenterDbContext exChangeCenterDbContext, + IExcelImportAppService excelImportService, ISnowflakeIdGenerator snowflakeIdGenerator, ICommonManager commonManager, INormalEfCoreRepository repository, @@ -65,6 +97,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ ) : base(excelImportService, snowflakeIdGenerator, commonManager) { + _settleAccountDbContext = settleAccountDbContext; + _wmsBJBMPTContext = wmsBJBMPTContext; + _exChangeCenterDbContext = exChangeCenterDbContext; _baseservice = baseservice; _repository = repository; _wRepository = wRepository; @@ -77,6 +112,116 @@ namespace Win.Sfs.SettleAccount.Entities.BQ _invMng = invMng; } + /// + /// 提交到QAD + /// + /// + /// 已扣减发票提交到QAD + /// + [HttpPost] + public virtual async Task SubmitToQad(List invbillNums) + { + var invoiceGrps = _settleAccountDbContext.Set() + .Where(t => invbillNums.Contains(t.InvbillNum)) + .Where(t => t.State == SettleBillState.已扣减) + .ToList(); + + invbillNums = invoiceGrps.Select(t => t.InvbillNum).ToList(); + + var invoiceGrpDetails = _settleAccountDbContext.Set() + .Where(t => invbillNums.Contains(t.InvbillNum)) + .ToList(); + + var taskId = GuidGenerator.Create(); + var teaTaskSub = new TEA_TASK_SUB() + { + GUID = taskId, + TaskState = 0, + TaskID = taskId, + TableName = "TED_SA_INV", + Creator = "SAS", + Subscriber = "QAD", + Domain = "BJBMPT", + Site = "BJ02", + CreateTime = DateTime.Now, + UpdateTime = DateTime.Now, + }; + + var tedSaInvs = invoiceGrpDetails.Join(invoiceGrps, x => x.InvbillNum, y => y.InvbillNum, (x, y) => + { + return new TED_SA_INV() + { + GUID = GuidGenerator.Create(), + TaskID = taskId, + InvoiceNumber = y.RealnvBillNum, + SASInvoiceNumber = y.InvbillNum, + Customer = y.ClientCode, + BillTo = y.ClientCode, + InvoiceDate = y.CreationTime, + Site = "BJ02", + TYPE = default, + PartNumber = x.LU, + InvoiceQuatity = x.Qty, + Price = x.PRICE, + Supplier = default, + Remark = default, + InvoiceNetAmount = x.Amt, + InvoiceTaxAmount = x.Amt * 0.13m, + TaxRate = 0.13m, + Location = $"C{y.ClientCode}", + InvoiceNet = default, + InvoiceTax = default, + begintime = x.BeginDate, + endtime = x.EndDate, + Domain = "BJBMPT" + }; + }).ToList(); + + var invoiceGrpTedSaInvs = invoiceGrps.Select(t => + { + return new TED_SA_INV() + { + GUID = GuidGenerator.Create(), + TaskID = taskId, + UID = default, + InvoiceNumber = t.RealnvBillNum, + SASInvoiceNumber = t.InvbillNum, + Customer = t.ClientCode, + BillTo = t.ClientCode, + InvoiceDate = t.CreationTime, + Site = "BJ02", + TYPE = default, + PartNumber = default, + InvoiceQuatity = default, + Price = default, + Supplier = default, + Remark = default, + InvoiceNetAmount = default, + InvoiceTaxAmount = default, + TaxRate = 0.13m, + Location = $"C{t.ClientCode}", + InvoiceNet = t.Amt, + InvoiceTax = default, + begintime = default, + endtime = default, + Domain = "BJBMPT" + }; + }); + + tedSaInvs.AddRange(invoiceGrpTedSaInvs); + if (tedSaInvs.Any()) + { + await _exChangeCenterDbContext.Set().AddAsync(teaTaskSub).ConfigureAwait(false); + await _exChangeCenterDbContext.Set().AddRangeAsync(tedSaInvs).ConfigureAwait(false); + await _exChangeCenterDbContext.SaveChangesAsync().ConfigureAwait(false); + invoiceGrps.ForEach(t => t.State = SettleBillState.已提交QAD); + await _settleAccountDbContext.SaveChangesAsync().ConfigureAwait(false); + } + + await Task.CompletedTask.ConfigureAwait(false); + return new OkResult(); + } + /// /// 通过审核 /// @@ -196,24 +341,24 @@ namespace Win.Sfs.SettleAccount.Entities.BQ { INVOICE_WAIT_DETAIL_BJ_DTO bj = new INVOICE_WAIT_DETAIL_BJ_DTO(); bj.LU = itm.LU; - bj.InvbillNum=itm.InvbillNum; + bj.InvbillNum = itm.InvbillNum; bj.PRICE = itm.PRICE; - // bj.InvGroupNum = itm.InvGroupNum; - bj.DeliveryIndexNumber =itm.GetProperty("DeliveryIndexNumber",""); + // bj.InvGroupNum = itm.InvGroupNum; + bj.DeliveryIndexNumber = itm.GetProperty("DeliveryIndexNumber", ""); bj.Qty = itm.Qty; bj.PRICE = itm.PRICE; bj.Amt = Math.Round(itm.PRICE * itm.Qty, 2); bj.RealAmt = Math.Round(Math.Round(itm.PRICE * itm.Qty, 2) * 0.13m, 2); bj.TaxAmt = Math.Round(itm.PRICE * itm.Qty, 2) + Math.Round(Math.Round(itm.PRICE * itm.Qty, 2) * 0.13m, 2); - bj.Extend1=itm.Extend1;//合同号 - bj.VendorCode = itm.GetProperty("VendorCode","");//供应商代码 - bj.VendorName = itm.GetProperty("VendorName","");//供应商名称 - bj.DeliveryNumber = itm.GetProperty("DeliveryNumber","");//交货号; - bj.PN = itm.GetProperty("PN","");// - bj.PO= itm.GetProperty("PO",""); - bj.ProductionGroup = itm.GetProperty("PartGroup",""); + bj.Extend1 = itm.Extend1;//合同号 + bj.VendorCode = itm.GetProperty("VendorCode", "");//供应商代码 + bj.VendorName = itm.GetProperty("VendorName", "");//供应商名称 + bj.DeliveryNumber = itm.GetProperty("DeliveryNumber", "");//交货号; + bj.PN = itm.GetProperty("PN", "");// + bj.PO = itm.GetProperty("PO", ""); + bj.ProductionGroup = itm.GetProperty("PartGroup", ""); bj.LineCode = itm.LineCode; - bj.BeginDate=itm.BeginDate; + bj.BeginDate = itm.BeginDate; bj.EndDate = itm.EndDate; //bj.DeliveryNumber = itm.GetProperty("DeliveryNumber", "");//交货号 //bj.InvbillNum = itm.GetProperty("InvoiceNumber", "");//发票号 @@ -242,8 +387,8 @@ namespace Win.Sfs.SettleAccount.Entities.BQ //InvGroupNum = itm.InvGroupNum, LU = itm.LU, //PartCode = itm.PartCode, - PO=itm.PO, - PN=itm.PN, + PO = itm.PO, + PN = itm.PN, PRICE = itm.PRICE, Qty = itm.Qty, Amt = itm.Amt, @@ -251,18 +396,18 @@ namespace Win.Sfs.SettleAccount.Entities.BQ VendorCode = itm.VendorCode, VendorName = itm.VendorName, // PurchaseOrderNumber = itm.PurchaseOrderNumber, - DeliveryIndexNumber = itm.DeliveryIndexNumber , + DeliveryIndexNumber = itm.DeliveryIndexNumber, Extend1 = itm.Extend1, BeginDate = itm.BeginDate, EndDate = itm.EndDate, - RealAmt=itm.RealAmt, - TaxAmt=itm.TaxAmt, + RealAmt = itm.RealAmt, + TaxAmt = itm.TaxAmt, SettleDate = itm.SettleDate, - ProductionGroup=itm.ProductionGroup, - LineCode=itm.LineCode - + ProductionGroup = itm.ProductionGroup, + LineCode = itm.LineCode + }; - entity.INVOICE_WAIT_DETAIL_BJ = bjquery.OrderBy(p=>p.LineCode).ToList(); + entity.INVOICE_WAIT_DETAIL_BJ = bjquery.OrderBy(p => p.LineCode).ToList(); } else @@ -364,41 +509,42 @@ namespace Win.Sfs.SettleAccount.Entities.BQ .Select(p => new JIT_UNSETTLED_DETAIL_DTO { LU = p.Key.LU, GroupNum = p.Key.SettleGroupNum, Qty = p.Sum(itm => itm.Qty.Value) }); entity.JIT_UNSETTLED_DETAIL = unsettledList.ToList().OrderBy(p => p.GroupNum).ThenBy(p => p.LU).ToList(); } - if (first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType==EnumBusinessType.ZhiGongJianHBPO) + if (first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType == EnumBusinessType.ZhiGongJianHBPO) { entity.INVOICE_MAP_GROUP = lscompare.ToList().OrderBy(p => p.SettleGroupNum).ToList();//包含不可结结算分组号 } - if (first.BusinessType == EnumBusinessType.MaiDanJianHBPO ) + if (first.BusinessType == EnumBusinessType.MaiDanJianHBPO) { //List maidan = new List(); var maiquery = from itm in m - join itm1 in invs on itm.InvbillNum equals itm1.InvbillNum - select - new MAIDAN_HBPO_INVOICE_MAP_GROUP_DTO() - { - Extend1 = itm.Extend1, - InvGroupNum = itm.InvGroupNum, - SettleGroupNum = itm.SettleGroupNum, - InvbillNum = itm.InvbillNum, - RealInvBillNum = itm1.RealnvBillNum - }; + join itm1 in invs on itm.InvbillNum equals itm1.InvbillNum + select + new MAIDAN_HBPO_INVOICE_MAP_GROUP_DTO() + { + Extend1 = itm.Extend1, + InvGroupNum = itm.InvGroupNum, + SettleGroupNum = itm.SettleGroupNum, + InvbillNum = itm.InvbillNum, + RealInvBillNum = itm1.RealnvBillNum + }; entity.MAIDAN_HBPO_INVOICE_MAP_GROUP = maiquery.ToList(); List unsettle = new List(); foreach (var itm in sdtos) { - unsettle.Add(new MAIDAN_HBPO_UNSETTLED_DETAIL_DTO() { - GroupNum=itm.SettleGroupNum, - LU=itm.LU, - PN=itm.Extend1, - + unsettle.Add(new MAIDAN_HBPO_UNSETTLED_DETAIL_DTO() + { + GroupNum = itm.SettleGroupNum, + LU = itm.LU, + PN = itm.Extend1, + }); } entity.MAIDAN_HBPO_UNSETTLED_DETAIL = unsettle; } - - entity.ADJ_DETAIL = adjQuery.ToList().OrderBy(p=>p.GroupNum).ThenBy(p=>p.LU).ToList(); + + entity.ADJ_DETAIL = adjQuery.ToList().OrderBy(p => p.GroupNum).ThenBy(p => p.LU).ToList(); return entity; } [HttpPost] @@ -482,7 +628,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ #endregion // 发票分组 - if (first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType==EnumBusinessType.ZhiGongJianHBPO) + if (first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType == EnumBusinessType.ZhiGongJianHBPO) { if (m != null) { @@ -512,12 +658,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ } } //jis业务，发票分组对应关系，未结数据，调整数据 - if (first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType==EnumBusinessType.ZhiGongJianHBPO) + if (first.BusinessType == EnumBusinessType.JisBBAC || first.BusinessType == EnumBusinessType.JisHBPO || first.BusinessType == EnumBusinessType.ZhiGongJianHBPO) { foreach (var itm in entities) { var mgroup = m.Where(p => p.InvbillNum == itm.InvbillNum).ToList(); - var adjp = adj.Where(p => p.InvBillNum == itm.InvbillNum).ToList(); + var adjp = adj.Where(p => p.InvBillNum == itm.InvbillNum).ToList(); var nolist = not.Where(p => p.InvBillNum == itm.InvbillNum).ToList(); var lsC = nolist.Where(p => p.Extend1 == "可结算") .GroupBy(p => new diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIS_RECORD.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIS_RECORD.cs index d580d9d8..a5f9eddf 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIS_RECORD.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIS_RECORD.cs @@ -5,11 +5,12 @@ using System.ComponentModel.DataAnnotations.Schema; namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs { -#if DEBUG + //#if DEBUG + // [Table("TM_BJBMPT_JIS_RECORD")] + //#else + // [Table("EX_BJBMPT_JIS_RECORD")] + //#endif [Table("TM_BJBMPT_JIS_RECORD")] -#else - [Table("EX_BJBMPT_JIS_RECORD")] -#endif public class TM_BJBMPT_JIS_RECORD { [Key] diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIT_RECORD.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIT_RECORD.cs index 8c6214a7..87e2aad5 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIT_RECORD.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_JIT_RECORD.cs @@ -8,11 +8,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs /// /// Jis小件 /// -#if DEBUG + //#if DEBUG + // [Table("TM_BJBMPT_JIT_RECORD")] + //#else + // [Table("EX_BJBMPT_JIT_RECORD")] + //#endif [Table("TM_BJBMPT_JIT_RECORD")] -#else - [Table("EX_BJBMPT_JIT_RECORD")] -#endif public class TM_BJBMPT_JIT_RECORD { [Key] diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_OTHER_RECORD.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_OTHER_RECORD.cs index 22c7245f..d2785a80 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_OTHER_RECORD.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Syncs/TM_BJBMPT_OTHER_RECORD.cs @@ -8,11 +8,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs /// /// Jit(非Jis) /// -#if DEBUG +//#if DEBUG +// [Table("TM_BJBMPT_OTHER_RECORD")] +//#else +// [Table("EX_BJBMPT_OTHER_RECORD")] +//#endif [Table("TM_BJBMPT_OTHER_RECORD")] -#else - [Table("EX_BJBMPT_OTHER_RECORD")] -#endif public class TM_BJBMPT_OTHER_RECORD { [Key] diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TEA_TASK_SUB.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TEA_TASK_SUB.cs new file mode 100644 index 00000000..55796744 --- /dev/null +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TEA_TASK_SUB.cs @@ -0,0 +1,31 @@ +using System; +using System.ComponentModel.DataAnnotations; +using System.ComponentModel.DataAnnotations.Schema; + +namespace Win.Sfs.SettleAccount.Entities.BQ +{ + public class TEA_TASK_SUB + { + [Key] + public Guid GUID { get; set; } + public int TaskState { get; set; } + public Guid TaskID { get; set; } + public string TableName { get; set; } + public string TableName2 { get; set; } + public string TableName3 { get; set; } + public string Creator { get; set; } + public int DataCount { get; set; } + public string Subscriber { get; set; } + public int FailedCount { get; set; } + public string FailedInfo { get; set; } + public string Domain { get; set; } + public string Site { get; set; } + [DatabaseGenerated(DatabaseGeneratedOption.Identity)] + public int UID { get; set; } + public string CreateUser { get; set; } + public DateTime CreateTime { get; set; } + public string Remark { get; set; } + public string UpdateUser { get; set; } + public DateTime UpdateTime { get; set; } + } +} diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TED_SA_INV.cs b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TED_SA_INV.cs index 14d3d4e9..c778cc19 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TED_SA_INV.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/TED_SA_INV.cs @@ -1,14 +1,16 @@ using System; +using System.ComponentModel.DataAnnotations; +using System.ComponentModel.DataAnnotations.Schema; namespace Win.Sfs.SettleAccount.Entities.BQ { public class TED_SA_INV { - + [Key] public Guid GUID { set; get; } public Guid TaskID { set; get; } - + [DatabaseGenerated(DatabaseGeneratedOption.Identity)] public int UID { set; get; } /// diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/ExChangeCenterDbContext.cs b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/ExChangeCenterDbContext.cs index 3031bda8..0f98d446 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/ExChangeCenterDbContext.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/ExChangeCenterDbContext.cs @@ -9,10 +9,11 @@ namespace Win.Sfs.SettleAccount.EntityFrameworkCore public class ExChangeCenterDbContext : DbContext { + public DbSet TEA_TASK_SUB { get; set; } public DbSet TED_SA_INV { set; get; } - public ExChangeCenterDbContext(DbContextOptions options) : base(options) - { + public ExChangeCenterDbContext(DbContextOptions options) : base(options) + { } diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountEntityFrameworkCoreModule.cs b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountEntityFrameworkCoreModule.cs index 28176f61..ef722c22 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountEntityFrameworkCoreModule.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/SettleAccountEntityFrameworkCoreModule.cs @@ -1,4 +1,6 @@ +using System.Configuration; using Microsoft.EntityFrameworkCore; +using Microsoft.Extensions.Configuration; using Microsoft.Extensions.DependencyInjection; using Volo.Abp.AuditLogging.EntityFrameworkCore; using Volo.Abp.Dapper; @@ -45,6 +47,7 @@ namespace Win.Sfs.SettleAccount private static void ConfigureRepository(ServiceConfigurationContext context) { + var configuration = context.Services.GetConfiguration(); context.Services.AddAbpDbContext(options => { options.AddDefaultRepositories(); @@ -59,13 +62,13 @@ namespace Win.Sfs.SettleAccount context.Services.AddDbContext(options => { - //IConfiguration config = new ConfigurationBuilder() - // .SetBasePath(Directory.GetCurrentDirectory()) - // .AddJsonFile("appsettings.json") - // .Build(); - //var ConnectStr = config.GetConnectionString("WMSBJBMPT"); - //optionsBuilder.UseSqlServer(ConnectStr); - options.UseSqlServer("Server=dev.ccwin-in.com,6208;Database=WMS_BJBMPT_2;User ID=sa;Password=ChangkeTec@2021;Trusted_Connection=False;TrustServerCertificate=True;"); + options.UseSqlServer(configuration.GetConnectionString("WMSBJBMPT")); + //options.UseSqlServer("Server=dev.ccwin-in.com,6208;Database=WMS_BJBMPT_2;User ID=sa;Password=ChangkeTec@2021;Trusted_Connection=False;TrustServerCertificate=True;"); + }); + + context.Services.AddDbContext(options => + { + options.UseSqlServer(configuration.GetConnectionString("ExChangeCenterService")); }); // context.Services.AddTransient(typeof(IInventoryDetailRepository), diff --git a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/WMSBJBMPTDbContext.cs b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/WMSBJBMPTDbContext.cs index 42b35fd7..e5d47f3c 100644 --- a/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/WMSBJBMPTDbContext.cs +++ b/code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/EntityFrameworkCore/WMSBJBMPTDbContext.cs @@ -19,19 +19,6 @@ namespace Win.Sfs.SettleAccount.EntityFrameworkCore { } - //protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) - //{ - // if (!optionsBuilder.IsConfigured) - // { - // IConfiguration config = new ConfigurationBuilder() - // .SetBasePath(Directory.GetCurrentDirectory()) - // .AddJsonFile("appsettings.json") - // .Build(); - // var ConnectStr = config.GetConnectionString("WMSBJBMPT"); - // optionsBuilder.UseSqlServer(ConnectStr); - // } - //} - protected override void OnModelCreating(ModelBuilder modelBuilder) { base.OnModelCreating(modelBuilder);