| | |
| | | /// </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); |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | |
| | |
| | | { |
| | | ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); |
| | | ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); |
| | | ContainerHelper.delCntrLoc(wmsTask.S_CNTR_CODE); |
| | | } |
| | | else { |
| | | //出库取消判断接驳位是否有货,有货需要解绑 |