确认服务更新

API/Wood.Service/Controllers/CherySupplierConDateService.cs

@@ -1,4 +1,7 @@
-using TaskManager.Contracts.Dtos;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore.Storage;
+using TaskManager.Contracts.Dtos;
+using TaskManager.Entity;
 using TaskManager.Entity.Entitys;
 using TaskManager.EntityFramework;
 
@@ -9,6 +12,61 @@ namespace TaskManager.Controllers
         public SupplierConDateService(HttpClient httpClient, JobDbContext jobDbContext, LogController log, IRepository<SUPPLIER_CON_DATE> repository) : base(httpClient, jobDbContext, log, repository)
         {
         }
+        /// <summary>
+        /// 审批通过
+        /// </summary>
+        /// <param name="entites"></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult> Confirm([FromBody] List<SUPPLIER_CON_DATE> entites)
+        {
+
+            var taskId = Guid.NewGuid();
+            var task = new TaskSub();
+            task.TaskId = taskId;
+            task.TaskName = TaskName;
+            task.Subscriber = Client;
+            task.TableName = "SUPPLIER_CON_DATE";
+            task.DataCount = entites.Count;
+            task.Domain = "1";
+            task.Site = "1";
+            task.FailedCount = 0;
+            task.CreateTime = DateTime.Now;
+            task.CreateUser = "admin";
+            task.CreationTime = DateTime.Now;
+            task.SyncedPageCount = 0;
+
+            entites.ForEach(p =>
+            {
+                p.ReadState = true;
+                p.TaskId = taskId;
+
+
+            });
+
+            using (var transaction = await _jobDbContext.Database.BeginTransactionAsync())
+            {
+                var tran = transaction.GetDbTransaction();
+                try
+                {
+                    await _jobDbContext.BulkUpdateAsync(entites, options => { options.Transaction = tran; });
+                    await _jobDbContext.AddAsync(task);
+                    _jobDbContext.SaveChanges();
+
+                    // 提交事务
+                    await transaction.CommitAsync();
+                }
+                catch (Exception ex)
+                {
+                    await transaction.RollbackAsync();
+                    new JsonResult(new { Code = 400, Message = ex.Message });
+                }
+            }
+
+            return new JsonResult(new { Code = 200, Message = "修改成功!" });
+
+
+        }
 
 
 

API/Wood.Service/Controllers/CherySupplierMrpDataService.cs

@@ -1,6 +1,8 @@
-using TaskManager.Contracts.Dtos;
+using System.Data.Common;
+using TaskManager.Contracts.Dtos;
 using TaskManager.Controllers;
 using TaskManager.Entity;
+using TaskManager.Entity.Entitys;
 using TaskManager.EntityFramework;
 using TaskManager.EntityFramework;
 
@@ -12,5 +14,63 @@ namespace TaskManager.Controllers
         public CherySupplierMrpDataService(HttpClient httpClient, JobDbContext jobDbContext, LogController log, IRepository<SUPPLIER_MRP_DATE> repository) : base(httpClient, jobDbContext, log, repository)
         {
         }
+        protected override async Task ConfirmDataInsertAsync(List<SUPPLIER_MRP_DATE> plist, JobDbContext dbContext, DbTransaction dbTransaction)
+        {
+            if (plist.Count > 0)
+            {
+                List<SUPPLIER_CON_DATE> list = new List<SUPPLIER_CON_DATE>();
+                plist.ForEach(p =>
+                {
+                    var con = new SUPPLIER_CON_DATE();
+                    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.ToString();
+                    con.QuantityMeet1   =p.QuantityDemand1    ;
+                    con.QuantityMeet2   =p.QuantityDemand2    ;
+                    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;
+        }
+
+
+
     }
 }