| | |
| | | /// </summary> |
| | | internal class Monitor |
| | | { |
| | | private static object CreateTaskLocker = new object(); |
| | | |
| | | /// <summary> |
| | | /// 根据作业创建对应任务 |
| | | /// </summary> |
| | |
| | | { |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | | // 获取所有等待中的作业 |
| | | var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList(); |
| | | foreach (var operation in operations) |
| | | lock (CreateTaskLocker) |
| | | { |
| | | TaskHelper.CreateTask(operation); |
| | | // 获取所有等待中的作业 |
| | | var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList(); |
| | | |
| | | foreach (var operation in operations) |
| | | { |
| | | TaskHelper.CreateTask(operation); |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | |