资源检查

MicroServices/Business/Business.Application/ReplenishmentManagement/ReplenishmentAppService.cs

@@ -3237,7 +3237,7 @@ namespace Business.Replenishment
                 });
                 await _businessDbContext.AddRangeAsync(workOrdDetails);
             }
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
             await PlanOrderResourceCheck(moList.OrderBy(a => a.moentry_sys_stime).ToList(), moentryList, bang_id, "", false, false);
 
             var examine_resultList = _mysql_examine_result.GetListAsync(a => a.bangid == bang_id).Result;
@@ -3275,7 +3275,7 @@ namespace Business.Replenishment
                 }
             });
             await _businessDbContext.AddRangeAsync(weekPlan);
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
             return "OK";
         }
 
@@ -3655,7 +3655,7 @@ namespace Business.Replenishment
             //}
             //await _mysql_bom_child_examine.HardDeleteAsync(a => examine_result.Select(b => b.Id).ToList().Contains(a.examine_id.Value) && a.factory_id == input.factory_id);
             //await _mysql_examine_result.HardDeleteAsync(examine_result);
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
             await PlanOrderResourceCheck(moListCheck.OrderBy(a => a.moentry_sys_stime).ToList(), moEntryListCheck, bang_id, "", false, true);
 
             var examine_resultList = _mysql_examine_result.GetListAsync(a => a.bangid == bang_id).Result;
@@ -3696,7 +3696,7 @@ namespace Business.Replenishment
             });
 
             _businessDbContext.UpdateRange(weekplanList);
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
             return "OK";
         }
 
@@ -4195,7 +4195,7 @@ namespace Business.Replenishment
                 _workOrdRouting.Update(itemRoutingUpdate);
                 _businessDbContext.UpdateRange(itemMesmorderList);
                 _businessDbContext.UpdateRange(itemMesmorderEntryList);
-                await _businessBangDbContext.SaveChangesAsync();
+                await _businessDbContext.SaveChangesAsync();
             }
 
             //DOP运行资源检查每个原材料SKU的可用库存，当可用库存<=修正后ROP时，自动生成月度采购申请（Purchase request，PR46年月日4位流水号）=EOP；可用库存为没有被其他SO和PO占用的（合格原材料库存+在途库存）；
@@ -4380,7 +4380,7 @@ namespace Business.Replenishment
                 a.GenerateNewId(help.NextId());
             });
             await _businessDbContext.AddRangeAsync(prList);
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
             return "OK";
         }
 
@@ -6234,31 +6234,31 @@ namespace Business.Replenishment
                 {
                     if (examineList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(examineList);
+                        await _businessBangDbContext.AddRangeAsync(examineList);
                     }
                     if (bomExamineList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(bomExamineList.OrderBy(s => s.num_order).ToList());
+                        await _businessBangDbContext.AddRangeAsync(bomExamineList.OrderBy(s => s.num_order).ToList());
                     }
                     if (mooccupyList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(mooccupyList);
+                        await _businessBangDbContext.AddRangeAsync(mooccupyList);
                     }
                     if (moorderList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(moorderList);
+                        await _businessBangDbContext.AddRangeAsync(moorderList);
                     }
                     if (ooderList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(ooderList);
+                        await _businessBangDbContext.AddRangeAsync(ooderList);
                     }
                     if (purchaseList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(purchaseList);
+                        await _businessBangDbContext.AddRangeAsync(purchaseList);
                     }
                     if (purchaseoccupyList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(purchaseoccupyList);
+                        await _businessBangDbContext.AddRangeAsync(purchaseoccupyList);
                     }
                     await unitOfWork.CompleteAsync();
                 }
@@ -7493,7 +7493,7 @@ namespace Business.Replenishment
                 await _businessDbContext.AddRangeAsync(needAddList);
             }
             _businessDbContext.UpdateRange(needupdList);
-            await _businessBangDbContext.SaveChangesAsync();
+            await _businessDbContext.SaveChangesAsync();
         }
 
         public async Task<string> DeleteWeekPlan(long weekplanid, string productorder, long factory_id)

MicroServices/Business/Business.Application/ResourceExamineManagement/ResourceExamineAppService.cs

@@ -1158,31 +1158,31 @@ namespace Business.ResourceExamineManagement
                 {
                     if (examineList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(examineList);
+                       await _businessBangDbContext.AddRangeAsync(examineList);
                     }
                     if (bomExamineList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(bomExamineList.OrderBy(s => s.num_order).ToList());
+                        await _businessBangDbContext.AddRangeAsync(bomExamineList.OrderBy(s => s.num_order).ToList());
                     }
                     if (mooccupyList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(mooccupyList);
+                        await _businessBangDbContext.AddRangeAsync(mooccupyList);
                     }
                     if (moorderList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(moorderList);
+                        await _businessBangDbContext.AddRangeAsync(moorderList);
                     }
                     if (ooderList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(ooderList);
+                        await _businessBangDbContext.AddRangeAsync(ooderList);
                     }
                     if (purchaseList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(purchaseList);
+                        await _businessBangDbContext.AddRangeAsync(purchaseList);
                     }
                     if (purchaseoccupyList.Any())
                     {
-                        _businessBangDbContext.BulkInsert(purchaseoccupyList);
+                        await _businessBangDbContext.AddRangeAsync(purchaseoccupyList);
                     }
                     await unitOfWork.CompleteAsync();
                 }
@@ -3917,17 +3917,17 @@ namespace Business.ResourceExamineManagement
             }
             if (examineList.Any())
             {
-                _businessBangDbContext.BulkInsert(examineList);
+                await _businessBangDbContext.AddRangeAsync(examineList);
             }
             if (daybulletinboards.Any())
             {
-                _businessBangDbContext.BulkInsert(daybulletinboards);
+                await _businessBangDbContext.AddRangeAsync(daybulletinboards);
             }
             if (orderDetails.Any())
             {
-                _businessBangDbContext.BulkInsert(orderDetails);
+                await _businessBangDbContext.AddRangeAsync(orderDetails);
             }
-
+            await _businessBangDbContext.SaveChangesAsync();
         }
 
         /// <summary>
@@ -4420,7 +4420,7 @@ namespace Business.ResourceExamineManagement
                     if (mainWorkOrdDetails.Any())
                     {
                         await _businessDbContext.AddRangeAsync(mainWorkOrdDetails);
-                        await _businessBangDbContext.SaveChangesAsync();
+                        await _businessDbContext.SaveChangesAsync();
                     }
                     if (workOrdRoutings.Any())
                     {
@@ -4429,7 +4429,7 @@ namespace Business.ResourceExamineManagement
                     if (mainWorkOrdRoutings.Any())
                     {
                         await _businessDbContext.AddRangeAsync(mainWorkOrdRoutings);
-                        await _businessBangDbContext.SaveChangesAsync();
+                        await _businessDbContext.SaveChangesAsync();
                     }
                 }
             }
@@ -6923,7 +6923,7 @@ namespace Business.ResourceExamineManagement
                     _businessDbContext.UpdateRange(pooccuypUpdList);
                 }
                 MRPmorder.AddRange(moIstList);
-                _businessBangDbContext.SaveChanges();
+                _businessDbContext.SaveChanges();
                 if (MRPmorder.Any())
                 {
                     var rtn = await OrderKittingCheck(MRPmorder, true);
@@ -7457,7 +7457,7 @@ namespace Business.ResourceExamineManagement
                     }
                 }
                 await _businessDbContext.AddRangeAsync(ds);
-                await _businessBangDbContext.SaveChangesAsync();
+                await _businessDbContext.SaveChangesAsync();
                 return "ok";
             }
             catch (Exception e)

MicroServices/Business/QuartzSettings/logs/logs.txt

@@ -4714,3 +4714,15 @@
 {"TaskName":"长周期物料PR","GroupName":"systemquartzjob","BeginDate":"2025-12-26T15:35:11.8036027+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
 {"TaskName":"TestTimeOut","GroupName":"systemquartzjob","BeginDate":"2025-12-26T15:35:11.808755+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
 {"TaskName":"BOM预处理自动任务","GroupName":"BOM预处理自动任务","BeginDate":"2025-12-26T15:35:11.8111864+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时同步WMS物料订单等基础数据到MySQL","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:16:09.8696958+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时创建NLog日志按月分表","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:16:09.9131042+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时同步MySQL基础数据到MongoDB","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:16:09.916141+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"长周期物料PR","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:16:09.9179777+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"TestTimeOut","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:16:09.9226114+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"BOM预处理自动任务","GroupName":"BOM预处理自动任务","BeginDate":"2025-12-29T10:16:09.9245425+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时同步WMS物料订单等基础数据到MySQL","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:32:51.5161912+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时创建NLog日志按月分表","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:32:51.5513481+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"定时同步MySQL基础数据到MongoDB","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:32:51.5543084+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"长周期物料PR","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:32:51.5559965+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"TestTimeOut","GroupName":"systemquartzjob","BeginDate":"2025-12-29T10:32:51.5600099+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}
+{"TaskName":"BOM预处理自动任务","GroupName":"BOM预处理自动任务","BeginDate":"2025-12-29T10:32:51.5618045+08:00","EndDate":null,"Msg":"任务初始化启动成功:6","id":0,"timeflag":null,"changetime":null}