0720

海波 张

1 天以前 61ece19b5b178d1b23bed16c733b01af1185f838

 core/Monitor.cs

@@ -14,6 +14,7 @@
using System.Threading;
using System.Threading.Tasks;
using System.Web.Services.Description;
using Top.Api;
using static HH.WCS.ZhongCeJinTan.api.ApiModel;

namespace HH.WCS.ZhongCeJinTan.core
@@ -197,28 +198,59 @@
                                        LogHelper.Info($"任务{wmsTask.S_CODE}完成，判断入库优先级", "入库优先级");
                                        TaskProcess.inPri(wmsTask);
                                        TaskHelper.End(wmsTask);
                                       
                                        break;
                                    case 7:
                                        if (!LocationHelper.GetErroArea(wmsTask.S_END_AREA)) {
                                            TaskHelper.opMesTask(wmsTask, 3);
                                        }
                                        TaskHelper.Fail(wmsTask);
                                        TaskProcess.OperateStatus(wmsTask, 7);
                                        
                                        
                                        WmsTaskAction ac4 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "4");
                                        //已经取货完成
                                        if (ac4 != null)
                                        { 
                                            
                                        var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
                                        }

                                            var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
                                            if (wcsTask1 != null)
                                            {
                                                //agv执行通知 wcs取消  
                                                WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
                                                if (wcsTask1.S_B_STATE.Trim() != "取消" && wcsTask1.S_B_STATE.Trim() != "失败" && wcsTask1.S_B_STATE.Trim() != "完成")
                                                {
                                                    TaskHelper.Fail(wcsTask1);
                                                    TaskProcess.OperateStatus(wcsTask1, 7);
                                                }
                                                    if (wmsTask.S_TYPE.Contains("出库"))
                                                    {
                                                        WmsTaskAction ac1101 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "1101");
                                                        WmsTaskAction ac1102 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "1102");
                                                        if ((ac1101 != null))
                                                        {
                                                            if (ac1102 == null)
                                                            {
                                                                //agv执行通知 wcs取消  
                                                                WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
                                                            }
                                                        }
                                                    }
                                                    else
                                                    {
                                                        WmsTaskAction ac1103 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "1103");
                                                        WmsTaskAction ac1104 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "1104");
                                                        if ((ac1103 != null))
                                                        {
                                                            if (ac1104 == null)
                                                            {
                                                                //agv执行通知 wcs取消  
                                                                WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
                                                            }
                                                        }
                                                    }
                                                  }
                                            }
                                        

                                        TaskHelper.Fail(wmsTask);
                                        TaskProcess.OperateStatus(wmsTask, 7);
                                       
                                        //入库或者回库任务取消删除托盘物料
                                        if (wmsTask.S_TYPE.Contains("入库") || wmsTask.S_TYPE.Contains("回库"))
                                        {
@@ -228,19 +260,32 @@
                                        }
                                        else {
                                            //出库取消判断接驳位是否有货，有货需要解绑
                                            if (!WcsTask.WcsCvstate(wmsTask))
                                            var wmsWork = TaskHelper.GetWmsWork(wmsTask.S_OP_CODE);
                                            if (wmsWork != null)
                                            {
                                                LogHelper.Info($"Wcs立库接驳位无货，解绑货位:{wmsTask.S_START_LOC}", "立库");
                                                TaskProcess.OperateStatus(wmsTask, 4);
                                                ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
                                                ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
                                                if (!string.IsNullOrEmpty(wmsWork.CONNECTION))
                                                {
                                                    var agvTask = LocationHelper.GetConnectionTask(wmsWork.CONNECTION, "agv",wmsTask.T_CREATE);
                                                    LogHelper.Info($"取消任务{wmsTask.S_CODE}，当前接驳位{wmsWork.CONNECTION}，第一个agv任务信息" + JsonConvert.SerializeObject(agvTask), "agv动作缓存");
                                                    if (agvTask != null)
                                                    {
                                                        WmsTaskAction qh = TaskHelper.GetActionRecord(agvTask.S_CODE, "4");
                                                        //已经取货完成
                                                        if (qh != null)
                                                        {
                                                            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);
                            }