2023-11-10

2023-11-10 15:21:35 +08:00
parent 71dca3c416
commit 13cfea61ed
10 changed files with 370 additions and 72 deletions
@@ -257,7 +257,23 @@ namespace BLL
                Funs.DB.SubmitChanges();
            }
        }
-
+        /// <summary>
+        /// 重置费用信息
+        /// </summary>
+        /// <param name="newtable"></param>
+        public static void RestSetComparison(string id)
+        {
+            var table = Funs.DB.PHTGL_ContractTrack.FirstOrDefault(x => x.Id == id);
+            if (table != null)
+            {
+                
+                table.EstimatedQuantity = string.Empty;
+                table.EstimatedAmount = 0m;
+                table.SettledQuantity = string.Empty;
+                table.SettledAmount = 0m; 
+                Funs.DB.SubmitChanges();
+            }
+        }
        public static void DeletePHTGL_ContractTrackById(string id)
        {
            PhtglContracttrackprogressService.DeleteModleByContractTrackId(id);
@@ -125,6 +125,11 @@ namespace BLL
                }
            }
        }
+        /// <summary>
+        /// 根据导入合格价格信息数据来创建进度检测数据
+        /// </summary>
+        /// <param name="contractTrackList"></param>
+        /// <param name="projectid"></param>
        public static void CreateTemplateByContractList(List<PHTGL_ContractTrack> contractTrackList,string projectid)
        {
            var dbcontractTrack=(from x in  Funs.DB.PHTGL_ContractTrack  where x.ProjectId==projectid select x).ToList();
@@ -141,11 +146,12 @@ namespace BLL
            {
                splitLists = Funs.SplitList(contractTrackList, 1);
            } 
-            ConcurrentBag<PHTGL_ContractTrackProgress> contractTrackProgressList = new ConcurrentBag<PHTGL_ContractTrackProgress>();//用于批量新增的数据
+            ConcurrentBag<PHTGL_ContractTrackProgress> contractTrackProgressList = new ConcurrentBag<PHTGL_ContractTrackProgress>();//用于批量新增的数据（无序集合）

            ParallelOptions parallelOptions = new ParallelOptions();
            parallelOptions.MaxDegreeOfParallelism = Environment.ProcessorCount;

+            ///使用多线程开启并行任务，操作拆分后的list  同时进行数据处理
            Parallel.ForEach(splitLists, parallelOptions, sublist =>
            {