using System.Data.Common; using TaskManager.Contracts.Dtos; using TaskManager.Controllers; using TaskManager.Entity; using TaskManager.Entity.Entitys; using TaskManager.EntityFramework; using TaskManager.EntityFramework; namespace TaskManager.Controllers { /// /// 日物料需求计划 /// public class CherySupplierMrpDataService : CheryRecurringJobOutPageController { public CherySupplierMrpDataService(HttpClient httpClient, JobDbContext jobDbContext, LogController log, IRepository repository) : base(httpClient, jobDbContext, log, repository) { } protected override async Task ConfirmDataInsertAsync(List plist, JobDbContext dbContext, DbTransaction dbTransaction) { if (plist.Count > 0) { List list = new List(); plist.ForEach(p => { var con = new SUPPLIER_CON_DATE(); con.Id=p.Id; con.SupplierCode = "8EG"; con.ReleaseEdition = p.ReleaseEdition; con.MaterialCode = p.MaterialCode; con.PlantId = p.PlantId; con.FeedbackResults = ""; con.VentureType = ""; con.VentureSpecific = ""; con.Measures = ""; con.StartDate = p.StartDate; con.QuantityMeet1 =p.QuantityDemand1==null? p.QuantityDemand1.Value : 0 ; con.QuantityMeet2 = p.QuantityDemand2 == null ? p.QuantityDemand2.Value : 0; con.QuantityMeet3 =p.QuantityDemand3 ; con.QuantityMeet4 =p.QuantityDemand4 ; con.QuantityMeet5 =p.QuantityDemand5 ; con.QuantityMeet6 =p.QuantityDemand6 ; con.QuantityMeet7 =p.QuantityDemand7 ; con.QuantityMeet8 =p.QuantityDemand8 ; con.QuantityMeet9 =p.QuantityDemand9 ; con.QuantityMeet10 =p.QuantityDemand10 ; con.QuantityMeet11 =p.QuantityDemand11 ; con.QuantityMeet12 =p.QuantityDemand12 ; con.QuantityMeet13 =p.QuantityDemand13 ; con.QuantityMeet14 =p.QuantityDemand14 ; con.QuantityMeet15 =p.QuantityDemand15 ; con.QuantityMeet16 =p.QuantityDemand16 ; con.QuantityMeet17 =p.QuantityDemand17 ; con.QuantityMeet18 =p.QuantityDemand18 ; con.QuantityMeet19 =p.QuantityDemand19 ; con.QuantityMeet20 =p.QuantityDemand20 ; con.QuantityMeet21 =p.QuantityDemand21 ; con.QuantityMeet22 =p.QuantityDemand22 ; con.QuantityMeet23 =p.QuantityDemand23 ; con.QuantityMeet24 =p.QuantityDemand24 ; con.QuantityMeet25 =p.QuantityDemand25 ; con.QuantityMeet26 =p.QuantityDemand26 ; con.QuantityMeet27 =p.QuantityDemand27 ; con.QuantityMeet28 =p.QuantityDemand28 ; con.QuantityMeet29 =p.QuantityDemand29 ; con.QuantityMeet30 =p.QuantityDemand30 ; con.QuantityMeet31 = p.QuantityDemand31; list.Add(con); }); await dbContext.BulkInsertAsync(list, options => { options.Transaction = dbTransaction; options.UseTableLock = false; }); } return; } } }