印尼佳通-硫化流程出入库流程开发

杨前锦

2025-06-11 e0d89637030791ce1e7dd46ca5fdec9979977960

 HH.WCS.Mobox3/HH.WCS.Mobox3.FJJT/api/ApiHelper.cs

@@ -43,22 +43,27 @@
            Location endLoc = LocationHelper.GetLoc(model.endLocCode);
            if (endLoc == null)
            {
                WMSHelper.addAlarmRecord("流程异常", "低", $"WMS系统未查询到终点货位：{model.endLocCode}");
                throw new BusinessException($"WMS系统未查询到终点货位：{model.endLocCode},请检查终点货位编码是否正确");
                WMSHelper.addAlarmRecord("流程异常", "低", $"空工装出库，WMS系统未查询到终点货位：{model.endLocCode}");
                throw new BusinessException($"空工装出库，WMS系统未查询到终点货位：{model.endLocCode},请检查终点货位编码是否正确");
            }
            else if (endLoc.N_LOCK_STATE != 0) 
            {
                WMSHelper.addAlarmRecord("流程异常", "低", $"空工装出库，终点货位：{model.endLocCode}处于锁定状态");
                throw new BusinessException($"空工装出库，终点货位：{model.endLocCode}处于锁定状态");
            }

            var areaCodes = Settings.getRelAreaCodes(endLoc.S_AREA_CODE);
            if (areaCodes.Count == 0) 
            {
                WMSHelper.addAlarmRecord("流程异常", "低", $"未配置库区:{endLoc.S_AREA_CODE}的关联关系");
                throw new BusinessException($"未配置库区:{endLoc.S_AREA_CODE}的关联关系");
                WMSHelper.addAlarmRecord("流程异常", "低", $"空工装出库，未配置库区:{endLoc.S_AREA_CODE}的关联关系");
                throw new BusinessException($"空工装出库，未配置库区:{endLoc.S_AREA_CODE}的关联关系");
            }

            Location startLoc = WMSHelper.getOutStockStartLoc(areaCodes[0], null);
            if (startLoc == null)
            {
                WMSHelper.addAlarmRecord("流程异常", "低", $"库区:{areaCodes[0]}未查询到空工装");
                throw new BusinessException($"未查询到空工装，立库可能缺少空工装");
                WMSHelper.addAlarmRecord("流程异常", "低", $"空工装出库，库区:{areaCodes[0]}未查询到空工装");
                throw new BusinessException($"空工装出库，未查询到空工装，立库可能缺少空工装");
            }

            var locCntrRels = LocationHelper.GetLocCntr(startLoc.S_CODE);
@@ -139,7 +144,7 @@
                    var container = ContainerHelper.GetCntr(request.cntrNo);
                    if (container != null)
                    {
                        if (cst.S_CNTR_CODE == request.cntrNo)
                        if (cst.S_CNTR_CODE != request.cntrNo)
                        {
                            ContainerHelper.UpdateCntrState(cst.S_CNTR_CODE, 1);
                            WMSHelper.addRfidAnomalyRecord(cst.S_CNTR_CODE, 2, request.loc, cst.S_CODE);
@@ -150,6 +155,8 @@
                        ContainerHelper.UpdateCntrState(cst.S_CNTR_CODE, 1);
                        WMSHelper.addRfidAnomalyRecord(cst.S_CNTR_CODE, 1, request.loc, cst.S_CODE);
                    }

                    /*WCSHelper.ActivatePreCreateTask(cst.S_OP_CODE);*/

                    // 方案2 4.如果读取不成功，查看异常区是否有空货位  
                    /* var agvEndLoc = WMSHelper.GetTransfeRelevanceLoc(loc.S_AREA_CODE, "4");
@@ -229,39 +236,23 @@
                var logicConfig = WMSHelper.getLogicConfigByJtCode(model.jtNo);
                if (logicConfig != null)
                {
                    Container container = ContainerHelper.GetCntr(model.cntrNo);
                    if (container == null || !model.isNormal)
                    {
                        ContainerHelper.AddCntr(model.cntrNo);
                        ContainerHelper.UpdateCntrState(model.cntrNo, 1);
                        WMSHelper.addRfidAnomalyRecord(model.cntrNo, 1, model.loc, null);
                    }

                    // 根据物料下线配置信息，判断任务类型是直连下线还是非直连下线
                    if (logicConfig.S_TASK_TYPE == "1" || logicConfig.S_TASK_TYPE == "2")
                    {
                        // 直连下线，需要判断校验RFID
                        LjMesTask mesTask = null;
                        var container = ContainerHelper.GetCntr(model.cntrNo);
                        if (container != null)
                        {
                            mesTask = WMSHelper.getLjMesTaskByCntr(model.cntrNo);
                            if (mesTask == null)
                            {
                                ContainerHelper.UpdateCntrState(model.cntrNo, 1);
                                WMSHelper.addRfidAnomalyRecord(model.cntrNo, 3, model.loc, null);
                            }
                        }
                        else 
                        {
                            model.isNormal = false;
                        }

                        if (!model.isNormal) 
                        {
                            ContainerHelper.AddCntr(model.cntrNo);
                            ContainerHelper.UpdateCntrState(model.cntrNo, 1);
                            WMSHelper.addRfidAnomalyRecord(model.cntrNo, 1, model.loc, null);
                        }
                        triggerItemOffLineFlow(model.loc, model.cntrNo, logicConfig, mesTask);
                        triggerItemOffLineFlow(model.loc, model.cntrNo, logicConfig);
                    }
                    else
                    {
                        // 满料下线（非直连）
                        var mesTask = WMSHelper.getLjMesTaskByLoc(model.loc);
                        triggerItemOffLineFlow4(model.loc, logicConfig,mesTask);
                        triggerItemOffLineFlow4(model.loc, model.cntrNo, logicConfig);
                    }
                }
                else
@@ -278,6 +269,7 @@
            return responseResult;
        }


        /// <summary>
        /// 满料下线（非直连）
        /// 1.创建满料下线作业
@@ -287,52 +279,62 @@
        /// </summary>
        /// <param name="offLineLoc"></param>
        /// <param name="logicConfig"></param>
        /// <param name="cntrNo"></param>
        /// <returns></returns>
        public static bool triggerItemOffLineFlow4(string offLineLoc, LogicConfig logicConfig ,LjMesTask mesTask)
        public static bool triggerItemOffLineFlow4(string offLineLoc,string cntrNo, LogicConfig logicConfig ,LjMesTask mesTask = null)
        {
            bool result = true;
            try
            {
                if (mesTask == null) 
                {
                    mesTask = WMSHelper.getLjMesTaskByCntr(cntrNo);
                }
                
                if (mesTask != null)
                {
                    // 2.判断是否需要补空工装，需要，则创建空工装出库任务
                    // TODO 查询缓存位线体光电++++++
                    bool photoStatus = false;
                    var hcLoc = LocationHelper.GetLoc(logicConfig.S_LKBKHCLOC);
                    if (hcLoc != null)
                    {
                        var transfeRelevance = WMSHelper.GetTransfeRelevance(hcLoc.S_CODE);  // 缓存位关联属性
                        if (transfeRelevance != null)
                        if (hcLoc.N_CURRENT_NUM != 0 && hcLoc.N_LOCK_STATE == 0) 
                        {
                            photoStatus = true;
                            // 方案1，如果非直连的缓存位有光电信号，则查询设备状态判断是否需要补空工装
                            /*var deviceStatusDatas = WCSDispatch.getDeviceStatus(new List<string>() { transfeRelevance.S_DEVICE_NO });
                            if (deviceStatusDatas != null && deviceStatusDatas.Count > 0)
                            hcLoc = LocationHelper.GetEmptyLoc(hcLoc.S_AREA_CODE);
                        }

                        if (hcLoc != null) 
                        {
                            var bufferLocConfig = Settings.GetBufferLocConfig(hcLoc.S_CODE);  // 缓存位关联属性
                            if (bufferLocConfig != null || hcLoc.N_CURRENT_NUM == 0)
                            {
                                var deviceStatus = deviceStatusDatas[0];
                                if (deviceStatus.workStatus == 1 && deviceStatus.manualStatus == 0)
                                {
                                    photoStatus = deviceStatus.photoStatus == 1;
                                }
                                else
                                {
                                    WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{transfeRelevance.S_DEVICE_NO},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                    throw new BusinessException($"设备号:{transfeRelevance.S_DEVICE_NO},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                }
                                photoStatus = true;
                                // 方案1，如果非直连的缓存位有光电信号，则查询设备状态判断是否需要补空工装
                                /*   var deviceStatusDatas = WCSDispatch.getDeviceStatus(new List<string>() { bufferLocConfig.deviceNo });
                                   if (deviceStatusDatas != null && deviceStatusDatas.Count > 0)
                                   {
                                       var deviceStatus = deviceStatusDatas[0];
                                       if (deviceStatus.workStatus == 1 && deviceStatus.manualStatus == 0)
                                       {
                                           photoStatus = deviceStatus.photoStatus == 1;
                                       }
                                       else
                                       {
                                           WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{bufferLocConfig.deviceNo},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                           throw new BusinessException($"设备号:{bufferLocConfig.deviceNo},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                       }
                                   }
                                   else
                                   {
                                       WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{bufferLocConfig.deviceNo},查询设备状态失败，请联系工作人员查看设备是否正常");
                                       throw new BusinessException($"设备号:{bufferLocConfig.deviceNo},查询设备状态失败，请联系工作人员查看设备是否正常");
                                   }*/
                            }
                            else
                            {
                                WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{transfeRelevance.S_DEVICE_NO},查询设备状态失败，请联系工作人员查看设备是否正常");
                                throw new BusinessException($"设备号:{transfeRelevance.S_DEVICE_NO},查询设备状态失败，请联系工作人员查看设备是否正常");
                            }*/

                            // 方案2，如果非直连的缓存位没有光电信号，则根据货位状态进行判断，需要注意：人工取空工装需要解锁

                        }
                        else
                        {
                            WMSHelper.addAlarmRecord("流程异常", "高", $"缓存位:{logicConfig.S_LKBKHCLOC},没有配置属性信息，请联系管理人员配置");
                            throw new BusinessException($"缓存位:{logicConfig.S_LKBKHCLOC},没有配置属性信息，请联系管理人员配置");
                                WMSHelper.addAlarmRecord("流程异常", "高", $"缓存位:{logicConfig.S_LKBKHCLOC},没有配置属性信息，请联系管理人员配置");
                                throw new BusinessException($"缓存位:{logicConfig.S_LKBKHCLOC},没有配置属性信息，请联系管理人员配置");
                            }
                        }
                    }
                    else
@@ -352,12 +354,12 @@
                        if (kgzStartLoc == null)
                        {
                            WMSHelper.addAlarmRecord("流程异常", "高", $"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                            throw new BusinessException($"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                            photoStatus = false;
                        }
                        if (kgzEndLoc == null)
                        {
                            WMSHelper.addAlarmRecord("流程异常", "中", $"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                            throw new BusinessException($"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                            photoStatus = false;
                        }

                        var locCntrRels = LocationHelper.GetLocCntr(kgzStartLoc.S_CODE);
@@ -367,8 +369,8 @@
                        }
                        else
                        {
                            WMSHelper.addAlarmRecord("流程异常", "中", $"空工装补充接驳位:{logicConfig.S_LKKTJBLOC},没有空工装");
                            throw new BusinessException($"空工装补充接驳位:{logicConfig.S_LKKTJBLOC},没有空工装");
                            WMSHelper.addAlarmRecord("流程异常", "中", $"空工装出库站台:{logicConfig.S_LKKTJBLOC},没有空工装");
                            photoStatus = false;
                        }
                    }

@@ -390,7 +392,6 @@
                            S_OP_DEF_CODE = mesTask.ID.ToString(),
                            T_START_TIME = DateTime.Now,
                        };

                        if (WMSHelper.CreateWmsTask(wmsTask))
                        {
                            int priority = 10;
@@ -421,12 +422,12 @@
                                }
                            }

                            // 3.判断容器是否是异常工装，是，则创建异常工装入线边异常区任务；
                            // 否，则创建满料工装入库任务（如需要补空工装，则将任务状态改为预创建，等待补空工装任务完成后触发）
                            // 3.创建满料工装入库任务（如需要补空工装，则将任务状态改为预创建，等待补空工装任务完成后触发）
                            WCSTask wcsTask = new WCSTask()
                            {
                                S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                                S_OP_CODE = wmsTask.S_CODE,
                                S_TYPE = "满料工装入库任务(非直连)",
                                S_CODE = WCSHelper.GenerateTaskNo(),
                                S_CNTR_CODE = wmsTask.S_CNTR_CODE,
                                S_START_LOC = startLoc.S_CODE,
@@ -437,25 +438,7 @@
                                N_PRIORITY = 99,
                                T_START_TIME = DateTime.Now,
                            };
                            Container container = ContainerHelper.GetCntr(cntrCode);
                            if (container.N_E_STATE == 0)
                            {
                                wcsTask.S_TYPE = "满料工装入库任务(非直连)";
                            }
                            else
                            {
                                Location ycgzLoc = null;
                                if (ycgzLoc != null)
                                {
                                    wcsTask.S_TYPE = "异常工装入库线边异常区";
                                    wcsTask.S_END_LOC = ycgzLoc.S_CODE;
                                    wcsTask.S_END_AREA = ycgzLoc.S_AREA_CODE;
                                }
                                else
                                {
                                    wcsTask.S_TYPE = "异常工装入库";
                                }
                            }

                            if (photoStatus)
                            {
                                wcsTask.N_B_STATE = -1;
@@ -467,14 +450,14 @@
                                // 起点、终点加锁
                                LocationHelper.LockLoc(wcsTask.S_START_LOC, 2);
                                LocationHelper.LockLoc(wcsTask.S_END_LOC, 1);

                                // 更新作业任务状态
                                wmsTask.N_B_STATE = 1;
                                WMSHelper.UpdateTaskState(wmsTask);

                                // 4.作业创建完成后，读取中间表，更新中间表状态
                                WMSHelper.readLjMesOffItemTask(wmsTask.S_CODE, mesTask.ID);
                            }

                            // 更新作业任务状态
                            wmsTask.N_B_STATE = 1;
                            WMSHelper.UpdateTaskState(wmsTask);

                            // 4.作业创建完成后，读取中间表，更新中间表状态
                            WMSHelper.readLjMesOffItemTask(wmsTask.S_CODE, mesTask.ID);
                        }
                    }
                    else
@@ -511,10 +494,10 @@
        /// 5.作业创建完成后，读取中间表，更新中间表状态
        /// </summary>
        /// <param name="offLineLoc">下线货位</param>
        /// <param name="cntrCode">下线容器编码</param>
        /// <param name="cntrNo">下线容器编码</param>
        /// <param name="logicConfig">逻辑配置</param>
        /// <returns></returns>
        public static bool triggerItemOffLineFlow(string offLineLoc, string cntrCode, LogicConfig logicConfig ,LjMesTask mesTask) {
        public static bool triggerItemOffLineFlow(string offLineLoc, string cntrNo, LogicConfig logicConfig ) {
            bool result = true;
            try
            {
@@ -523,14 +506,14 @@
                var hcLoc = LocationHelper.GetLoc(logicConfig.S_LKBKHCLOC);
                if (hcLoc != null)
                {
                    var transfeRelevance = WMSHelper.GetTransfeRelevance(hcLoc.S_CODE); // 缓存位关联属性
                    if (transfeRelevance != null)
                    var bufferLocConfig = Settings.GetBufferLocConfig(hcLoc.S_CODE);
                    if (bufferLocConfig != null)
                    {
                        // 测试代码
                        photoStatus = true;

                        // 业务代码，勿删
                        /*var deviceStatusDatas = WCSDispatch.getDeviceStatus(new List<string>() { transfeRelevance.S_DEVICE_NO });
                       /* // 业务代码，勿删
                        var deviceStatusDatas = WCSDispatch.getDeviceStatus(new List<string>() { bufferLocConfig.deviceNo });
                        if (deviceStatusDatas != null && deviceStatusDatas.Count > 0)
                        {
                            var deviceStatus = deviceStatusDatas[0];
@@ -538,16 +521,16 @@
                            {
                                photoStatus = deviceStatus.photoStatus == 1;
                            }
                            else 
                            else
                            {
                                WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{transfeRelevance.S_DEVICE_NO},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                throw new BusinessException($"设备号:{transfeRelevance.S_DEVICE_NO},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{bufferLocConfig.deviceNo},设备当前处于不可用状态，请联系管理人员调整设备状态");
                                throw new BusinessException($"设备号:{bufferLocConfig.deviceNo},设备当前处于不可用状态，请联系管理人员调整设备状态");
                            }
                        }
                        else 
                        else
                        {
                            WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{transfeRelevance.S_DEVICE_NO},查询设备状态失败，请联系工作人员查看设备是否正常");
                            throw new BusinessException($"设备号:{transfeRelevance.S_DEVICE_NO},查询设备状态失败，请联系工作人员查看设备是否正常");
                            WMSHelper.addAlarmRecord("流程异常", "高", $"设备号:{bufferLocConfig.deviceNo},查询设备状态失败，请联系工作人员查看设备是否正常");
                            throw new BusinessException($"设备号:{bufferLocConfig.deviceNo},查询设备状态失败，请联系工作人员查看设备是否正常");
                        }*/
                    }
                    else
@@ -576,133 +559,130 @@
                    throw new BusinessException($"库内没有空余货位");
                }

                Container container = ContainerHelper.GetCntr(cntrCode);
                if (container != null)
                LjMesTask mesTask = WMSHelper.getLjMesTaskByCntr(cntrNo);
                // 1.创建满料下线作业
                var wmsTask = new WMSTask()
                {
                    // 1.创建满料下线作业
                    var wmsTask = new WMSTask()
                    S_CNTR_CODE = cntrNo,
                    S_CODE = WMSHelper.GenerateTaskNo(),
                    S_START_LOC = startLoc.S_CODE,
                    S_START_AREA = startLoc.S_AREA_CODE,
                    S_END_LOC = endLoc.S_CODE,
                    S_END_AREA = endLoc.S_AREA_CODE,
                    S_TYPE = "满料/异常工装入库任务(直连)",
                    S_OP_DEF_NAME = "满料/异常工装入库任务(直连)",
                    S_OP_DEF_CODE = mesTask != null ? mesTask.ID.ToString() : null,
                    T_START_TIME = DateTime.Now,
                };
                if (WMSHelper.CreateWmsTask(wmsTask))
                {
                    int priority = 10;
                    Dictionary<int, WCSTask> taskDic = new Dictionary<int, WCSTask>();

                    // 是否创建空工装出口任务
                    if (photoStatus || true )
                    {
                        S_CNTR_CODE = cntrCode,
                        S_CODE = WMSHelper.GenerateTaskNo(),
                        Location kgzStartLoc = WMSHelper.getOutStockStartLoc(logicConfig.S_AREA_CODE, null);
                        Location kgzEndLoc = LocationHelper.GetLoc(logicConfig.S_LKBKHCLOC);
                        if (kgzStartLoc == null)
                        {
                            WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                            WMSHelper.addAlarmRecord("流程异常", "高", $"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                            throw new BusinessException($"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                        }
                        if (kgzEndLoc == null)
                        {
                            WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                            WMSHelper.addAlarmRecord("流程异常", "中", $"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                            throw new BusinessException($"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                        }

                        var locCntrRels = LocationHelper.GetLocCntr(kgzStartLoc.S_CODE);
                        if (locCntrRels.Count > 0)
                        {
                            string kgzCntrCode = locCntrRels[0].S_CNTR_CODE;
                            // 如是胎侧直连模式，则提高空工装出库任务优先级
                            if (logicConfig.S_TASK_TYPE == "1")
                            {
                                priority = 99;
                            }
                            WCSTask kgzWcsTask = new WCSTask()
                            {
                                S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                                S_OP_CODE = wmsTask.S_CODE,
                                S_CODE = WCSHelper.GenerateTaskNo(),
                                S_CNTR_CODE = kgzCntrCode,
                                S_TYPE = "空工装出库任务",
                                S_START_LOC = kgzStartLoc.S_CODE,
                                S_START_AREA = kgzStartLoc.S_AREA_CODE,
                                S_END_LOC = kgzEndLoc.S_CODE,
                                S_END_AREA = kgzEndLoc.S_AREA_CODE,
                                S_SCHEDULE_TYPE = "WCS",
                                N_PRIORITY = priority,
                                T_START_TIME = DateTime.Now,
                            };
                            taskDic.Add(priority, kgzWcsTask);
                        }
                        else
                        {
                            WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                            WMSHelper.addAlarmRecord("流程异常", "高", $"查询空工装货位错误，货位：{kgzStartLoc.S_CODE}没有空工装");
                            throw new BusinessException($"查询空工装货位错误，货位：{kgzStartLoc.S_CODE}没有空工装");
                        }
                    }

                    // 如是帘布直连模式则，提高满料入库优先级
                    if (logicConfig.S_TASK_TYPE == "2")
                    {
                        priority = 99;
                    }
                    else
                    {
                        priority = 10;
                    }

                    WCSTask wcsTask = new WCSTask()
                    {
                        S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                        S_OP_CODE = wmsTask.S_CODE,
                        S_CODE = WCSHelper.GenerateTaskNo(),
                        S_CNTR_CODE = wmsTask.S_CNTR_CODE,
                        S_TYPE = wmsTask.S_TYPE,
                        S_START_LOC = startLoc.S_CODE,
                        S_START_AREA = startLoc.S_AREA_CODE,
                        S_END_LOC = endLoc.S_CODE,
                        S_END_AREA = endLoc.S_AREA_CODE,
                        S_TYPE = "满料/异常工装入库任务(直连)",
                        S_OP_DEF_NAME = "满料/异常工装入库任务(直连)",
                        S_OP_DEF_CODE = mesTask != null ? mesTask.ID.ToString() : null,
                        S_SCHEDULE_TYPE = "WCS",
                        N_PRIORITY = priority,
                        T_START_TIME = DateTime.Now,
                    };
                    if (WMSHelper.CreateWmsTask(wmsTask))
                    taskDic.Add(priority, wcsTask);

                    var tasks = taskDic.OrderByDescending(a => a.Key).Select(a => a.Value).ToList();
                    foreach (var task in tasks) 
                    {
                        int priority = 10;

                        // 是否创建空工装出口任务
                        if (photoStatus)
                        {
                            Location kgzStartLoc = WMSHelper.getOutStockStartLoc(logicConfig.S_AREA_CODE, null);
                            Location kgzEndLoc = LocationHelper.GetLoc(logicConfig.S_LKBKHCLOC);
                            if (kgzStartLoc == null)
                            {
                                WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                                WMSHelper.addAlarmRecord("流程异常", "高", $"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                                throw new BusinessException($"库区:{logicConfig.S_AREA_CODE},没有可用的空工装");
                            }
                            if (kgzEndLoc == null)
                            {
                                WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                                WMSHelper.addAlarmRecord("流程异常", "中", $"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                                throw new BusinessException($"空工装缓存位:{logicConfig.S_LKBKHCLOC},没有在WMS系统中录入");
                            }

                            var locCntrRels = LocationHelper.GetLocCntr(kgzStartLoc.S_CODE);
                            if (locCntrRels.Count > 0)
                            {
                                string kgzCntrCode = locCntrRels[0].S_CNTR_CODE;
                                // 如是胎侧直连模式，则提高空工装出库任务优先级
                                if (logicConfig.S_TASK_TYPE == "1")
                                {
                                    priority = 99;
                                }
                                WCSTask kgzWcsTask = new WCSTask()
                                {
                                    S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                                    S_OP_CODE = wmsTask.S_CODE,
                                    S_CODE = WCSHelper.GenerateTaskNo(),
                                    S_CNTR_CODE = kgzCntrCode,
                                    S_TYPE = "空工装出库任务",
                                    S_START_LOC = kgzStartLoc.S_CODE,
                                    S_START_AREA = kgzStartLoc.S_AREA_CODE,
                                    S_END_LOC = kgzEndLoc.S_CODE,
                                    S_END_AREA = kgzEndLoc.S_AREA_CODE,
                                    S_SCHEDULE_TYPE = "WCS",
                                    N_PRIORITY = priority,
                                    T_START_TIME = DateTime.Now,
                                };

                                if (WCSHelper.CreateTask(kgzWcsTask))
                                {
                                    // 起点、终点加锁
                                    LocationHelper.LockLoc(kgzWcsTask.S_START_LOC, 2);
                                    LocationHelper.LockLoc(kgzWcsTask.S_END_LOC, 1);
                                }
                            }
                            else
                            {
                                WMSHelper.DeleteWmsTask(wmsTask.S_CODE);
                                WMSHelper.addAlarmRecord("流程异常", "高", $"查询空工装货位错误，货位：{kgzStartLoc.S_CODE}没有空工装");
                                throw new BusinessException($"查询空工装货位错误，货位：{kgzStartLoc.S_CODE}没有空工装");
                            }
                        }

                        // 如是帘布直连模式则，提高满料入库优先级
                        if (logicConfig.S_TASK_TYPE == "2")
                        {
                            priority = 99;
                        }
                        else 
                        {
                            priority = 10;
                        }

                        WCSTask wcsTask = new WCSTask()
                        {
                            S_OP_NAME = wmsTask.S_OP_DEF_NAME,
                            S_OP_CODE = wmsTask.S_CODE,
                            S_CODE = WCSHelper.GenerateTaskNo(),
                            S_CNTR_CODE = wmsTask.S_CNTR_CODE,
                            S_TYPE = wmsTask.S_TYPE,
                            S_START_LOC = startLoc.S_CODE,
                            S_START_AREA = startLoc.S_AREA_CODE,
                            S_END_LOC = endLoc.S_CODE,
                            S_END_AREA = endLoc.S_AREA_CODE,
                            S_SCHEDULE_TYPE = "WCS",
                            N_PRIORITY = priority,
                            T_START_TIME = DateTime.Now,
                        };

                        if (WCSHelper.CreateTask(wcsTask))
                        if (WCSHelper.CreateTask(task))
                        {
                            // 起点、终点加锁
                            LocationHelper.LockLoc(wcsTask.S_START_LOC, 2);
                            LocationHelper.LockLoc(wcsTask.S_END_LOC, 1);
                        }

                        // 更新作业任务状态
                        wmsTask.N_B_STATE = 1;
                        WMSHelper.UpdateTaskState(wmsTask);

                        // 5.作业创建完成后，读取中间表，更新中间表状态
                        if (mesTask != null)
                        {
                            WMSHelper.readLjMesOffItemTask(wmsTask.S_CODE, mesTask.ID);
                            LocationHelper.LockLoc(task.S_START_LOC, 2);
                            LocationHelper.LockLoc(task.S_END_LOC, 1);
                        }
                    }
                }
                else
                {
                    WMSHelper.addAlarmRecord("流程异常", "高", $"未查询到容器为:{cntrCode}的容器");
                    throw new BusinessException($"未查询到容器为:{cntrCode}的容器");

                    // 更新作业任务状态
                    wmsTask.N_B_STATE = 1;
                    WMSHelper.UpdateTaskState(wmsTask);

                    // 5.作业创建完成后，读取中间表，更新中间表状态
                    if (mesTask != null)
                    {
                        WMSHelper.readLjMesOffItemTask(wmsTask.S_CODE, mesTask.ID);
                    }
                    else 
                    {
                        ContainerHelper.UpdateCntrState(cntrNo, 1);
                        WMSHelper.addRfidAnomalyRecord(cntrNo, 3, offLineLoc, null);
                    }
                }
            }
            catch (BusinessException be) 
@@ -1137,6 +1117,7 @@

        /// <summary>
        /// AGV申请终点
        /// 场景：1.余料/空工装入库任务（成型机） 2.满料/空工装入库（机台） 3.满料/空工装出库异常 4.满料/空工装入库异常
        /// </summary>
        /// <param name="applyType">1.正常 2.RFID与任务RFID不匹配 3.物料状态不合格</param>
        /// <param name="loc"></param>
@@ -1283,6 +1264,7 @@
                                    S_SCHEDULE_TYPE = "WCS",
                                    N_PRIORITY = 10,
                                    N_B_STATE = -1,
                                    S_B_STATE = "预创建",
                                    T_START_TIME = DateTime.Now,
                                };
                                if (WCSHelper.CreateTask(wcsTask))
@@ -1313,36 +1295,6 @@
                }
            }

            // 重新发起新任务
            if (applyType != "1")
            {
                var mesTask = WMSHelper.GetLjMesTaskByAgvorderId(mst.S_CODE);
                if (mesTask != null) 
                {
                    if (mst.S_TYPE.Contains("叫料出库任务"))
                    {
                        LogHelper.Info($"叫料出库任务异常，再次发起叫料出库任务", "AGV");
                        callMaterial(mesTask.MATERIAL_CODE, mesTask.POSITION_ID, mesTask.ID);
                        /*againCallMaterial(mst, mesTask.MATERIAL_CODE, mesTask.POSITION_ID, mesTask.ID);*/
                    }

                    // 满料下线（非直连）
                    if (mst.S_TYPE.Contains("满料/异常工装入库任务") && cst.S_TYPE.Contains("空工装出库任务"))
                    {
                        LogHelper.Info($"满料/异常工装入库任务异常，再次发起满料/异常工装入库任务", "AGV");
                        var logicConfig = WMSHelper.getLogicConfigByJtCode(mesTask.EQP);
                        if (logicConfig != null)
                        {
                            triggerItemOffLineFlow4(mesTask.POSITION_ID, logicConfig, mesTask);
                        }
                        else
                        {
                            WMSHelper.addAlarmRecord("流程异常", "高", $"MES任务{mesTask.ID},机台号：{mesTask.EQP},未查询到逻辑线路", "AGV");
                        }
                    }
                }
            }

            if (agvEndLoc != null && wmsEndLoc != null)
            {
                destLoc = agvEndLoc.S_CODE;
@@ -1354,6 +1306,35 @@
                mst.S_END_AREA = wmsEndLoc.S_AREA_CODE;
                WMSHelper.UpdateTaskEnd(mst);
            }

            // 重新发起新任务
            if (applyType != "1")
            {
                var mesTask = WMSHelper.GetLjMesTaskByAgvorderId(mst.S_CODE);
                if (mesTask != null) 
                {
                    if (mst.S_TYPE.Contains("叫料出库任务"))
                    {
                        LogHelper.Info($"叫料出库任务异常，再次发起叫料出库任务", "AGV");
                        callMaterial(mesTask.MATERIAL_CODE, mesTask.POSITION_ID, mesTask.ID);
                    }

                    // 满料下线（非直连）
                    if (mst.S_TYPE.Contains("满料/异常工装入库任务") && cst.S_TYPE.Contains("空工装出库任务"))
                    {
                        LogHelper.Info($"满料/异常工装入库任务异常，再次发起满料/异常工装入库任务", "AGV");
                        var logicConfig = WMSHelper.getLogicConfigByJtCode(mesTask.EQP);
                        if (logicConfig != null)
                        {
                            triggerItemOffLineFlow4(mesTask.POSITION_ID, mst.S_CNTR_CODE, logicConfig ,mesTask);
                        }
                        else
                        {
                            WMSHelper.addAlarmRecord("流程异常", "高", $"MES任务{mesTask.ID},机台号：{mesTask.EQP},未查询到逻辑线路", "AGV");
                        }
                    }
                }
            }
            return destLoc;
        }