| | |
| | | internal class TaskCore |
| | | { |
| | | public static void OperateTaskStatus(AgvTaskState model) { |
| | | |
| | | var wmsTask = TaskHelper.GetTask(model.task_no); |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | |
| | | } |
| | | break; |
| | | case 2: |
| | | TaskHelper.End(wmsTask); |
| | | //空托出或者满托出任务完成判断是否要提高入库优先级 |
| | | |
| | | LogHelper.Info($"任务{wmsTask.S_CODE}完成,判断入库优先级", "入库优先级"); |
| | | TaskProcess.inPri(wmsTask); |
| | | TaskHelper.End(wmsTask); |
| | | break; |
| | | case 7: |
| | | |
| | |
| | | TaskProcess.OperateStatus(wcsTask1, 7); |
| | | } |
| | | } |
| | | |
| | | |
| | | TaskHelper.Fail(wmsTask); |
| | | TaskProcess.OperateStatus(wmsTask, 7); |
| | |
| | | ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); |
| | | ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); |
| | | } |
| | | //出库取消判断接驳位是否有货,有货需要解绑 |
| | | if (!WcsTask.WcsCvstate(wmsTask)) |
| | | { |
| | | LogHelper.Info($"Wcs立库接驳位无货,解绑货位:{wmsTask.S_START_LOC}", "立库"); |
| | | TaskProcess.OperateStatus(wmsTask, 4); |
| | | ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); |
| | | ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); |
| | | } |
| | | break; |
| | | |
| | | //出库取消判断接驳位是否有货,有货需要解绑 |
| | | if (!WcsTask.WcsCvstate(wmsTask)) |
| | | { |
| | | LogHelper.Info($"Wcs立库接驳位无货,解绑货位:{wmsTask.S_START_LOC}", "立库"); |
| | | TaskProcess.OperateStatus(wmsTask, 4); |
| | | ContainerHelper.delCntr(wmsTask.S_CNTR_CODE); |
| | | ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE); |
| | | } |
| | | break; |
| | | |
| | | } |
| | | TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no, model.ext_data); |
| | | |
| | | TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no, model.ext_data); |
| | | } |
| | | else |
| | | { |
| | |
| | | TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no, model.ext_data); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | public static void addAgvActionState(AgvTaskState model) |
| | | { |
| | | var agvAction = new AgvActionState(); |
| | | agvAction.state = model.state; |
| | | agvAction.task_no = model.task_no; |
| | | agvAction.ext_data = model.ext_data; |
| | | agvAction.forklift_no = model.forklift_no; |
| | | |
| | | if (TaskHelper.CreateAgvActionState(agvAction)) |
| | | { |
| | | LogHelper.Info("添加agv动作缓存成功信息" + JsonConvert.SerializeObject(agvAction), "agv动作缓存"); |
| | | } |
| | | else { |
| | | LogHelper.Info("添加agv动作缓存失败信息" + JsonConvert.SerializeObject(agvAction), "agv动作缓存"); |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | /// <summary> |