core/Monitor.cs
@@ -23,6 +23,8 @@ /// </summary> internal class Monitor { private static object CreateTaskLocker = new object(); /// <summary> /// 根据作业创建对应任务 /// </summary> @@ -30,8 +32,11 @@ { var db = new SqlHelper<object>().GetInstance(); lock (CreateTaskLocker) { // 获取所有等待中的作业 var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList(); foreach (var operation in operations) { TaskHelper.CreateTask(operation); @@ -39,6 +44,9 @@ } } /// <summary> /// 根据任务状态更新作业状态 /// </summary>