货位禁用添加，国自安全交互流程变更

lss

2025-06-18 83109bffe17f4cf877bb9546065723835a3c6b7d

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

@@ -38,12 +38,12 @@


        public static object _lockCreateTask = new object();
        public static object _lockCreateItem = new object();
        /// <summary>
        /// 立库任务下发=》创建任务
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>

        internal static Result Createtask(CreateTask model)
        {
            Result result = new Result() { code = "0", msg = "创建成功" };
@@ -170,10 +170,10 @@
                        if (startloc != null)
                        {
                            Start = startloc.S_CODE;
                            var CntrRel = LocationHelper.GetLocCntrRel(startloc.S_CODE).FirstOrDefault();
                            var CntrRel = LocationHelper.GetLocCntrRel(startloc.S_CODE).OrderBy(a => a.T_CREATE).FirstOrDefault();
                            if (CntrRel != null)
                            {
                                if (CntrRel.S_CNTR_CODE!= partData.rfid)
                                if (CntrRel.S_CNTR_CODE != partData.rfid)
                                {
                                    result.code = "1";
                                    result.msg = $"根据起点：{Start}获取托盘:{CntrRel.S_CNTR_CODE}与下发托盘：{partData.rfid}不一致，请检查托盘码是否正确";
@@ -184,7 +184,7 @@
                                {
                                    CntrCode = CntrRel.S_CNTR_CODE;
                                }
                                   

                            }
                            //else
                            //{
@@ -693,23 +693,63 @@
            try
            {
                string[] state = new string[] { "取消", "失败", "错误", "完成" };
                //找到任务
                var task = db.Queryable<WCSTask>().Where(a => a.S_EQ_NO.Trim() == model.task_no && !state.Contains(a.S_B_STATE)).First();
                if (task != null)
                if (model.type == "1")
                {
                    if (model.type == "1" || model.type == "2")
                    //找到任务
                    var task = db.Queryable<WCSTask>().Where(a => a.S_START_LOC.Trim() == model.loc && !state.Contains(a.S_B_STATE)).ToList();
                    if (task.Count > 0)
                    {
                        NDCApi.ChangeOrderParam(task.S_CODE.Trim(), 6, "1");
                        foreach (var item in task)
                        {
                            var taskAction = db.Queryable<TaskAction>().Where(a => a.S_TASK_CODE == item.S_CODE).OrderByDescending(a => a.T_CREATE).First();
                            if (taskAction.N_ACTION_CODE == 1101)
                            {
                                NDCApi.ChangeOrderParam(item.S_CODE.Trim(), 6, "1");
                                return result;
                            }
                            result.code = "1";
                            result.msg = $"根据下发货位{model.loc}未找到对应申请取货状态任务";
                            AddErrorInfo("未找到任务", result.msg, "", model.task_no);
                            return result;
                        }
                    }

                    else
                    {
                        result.code = "1";
                        result.msg = $"根据下发货位{model.loc}未找到对应任务";
                        AddErrorInfo("未找到任务", result.msg, "", model.task_no);
                        return result;
                    }
                }
                else
                else if (model.type == "2")
                {
                    result.code = "1";
                    result.msg = $"根据下发任务号{model.task_no}未找到对应任务";
                    AddErrorInfo("未找到任务", result.msg, "", model.task_no);
                    return result;
                    //找到任务
                    var task = db.Queryable<WCSTask>().Where(a => a.S_END_LOC.Trim() == model.loc && !state.Contains(a.S_B_STATE)).ToList();
                    if (task.Count > 0)
                    {
                        foreach (var item in task)
                        {
                            var taskAction = db.Queryable<TaskAction>().Where(a => a.S_TASK_CODE == item.S_CODE).OrderByDescending(a => a.T_CREATE).First();
                            if (taskAction.N_ACTION_CODE == 1103)
                            {
                                NDCApi.ChangeOrderParam(item.S_CODE.Trim(), 6, "1");
                                return result;
                            }
                        }
                        result.code = "1";
                        result.msg = $"根据下发货位{model.loc}未找到对应申请卸货状态任务";
                        AddErrorInfo("未找到任务", result.msg, "", model.task_no);
                        return result;
                    }
                    else
                    {
                        result.code = "1";
                        result.msg = $"根据下发货位{model.loc}未找到对应任务";
                        AddErrorInfo("未找到任务", result.msg, "", model.task_no);
                        return result;
                    }
                }

                return result;
            }
            catch (Exception ex)
@@ -729,6 +769,7 @@
        /// <returns></returns>
        internal static Result TrayItembind(TrayItembind model)
        {

            Result result = new Result() { code = "200", msg = "产出信息下发成功" };
            if (model == null)
            {
@@ -737,29 +778,34 @@
                AddErrorInfo("参数为空", result.msg);
                return result;
            }
            try
            lock (_lockCreateItem)
            {
                //创建托盘数据绑定关系
                if (ContainerHelper.CreateCntrItem(model.Rfid, model.PartNumber, model.PartDesc, model.LotNumber, model.Weight, model.Qty, model.ProductionTime, model.MaturityTime))
                try
                {
                    //创建成功流程
                }
                else
                {
                    result.code = "1";
                    result.msg = "产出信息下发失败，托盘物料绑定关系创建失败";
                    AddErrorInfo("创建绑定关系失败", result.msg, "Mes");

                    //创建托盘数据绑定关系
                    if (ContainerHelper.CreateCntrItem(model.Rfid, model.PartNumber, model.PartDesc, model.LotNumber, model.Weight, model.Qty, model.ProductionTime, model.MaturityTime))
                    {
                        //创建成功流程
                    }
                    else
                    {
                        result.code = "1";
                        result.msg = "产出信息下发失败，托盘物料绑定关系创建失败";
                        AddErrorInfo("创建绑定关系失败", result.msg, "Mes");
                        return result;
                    }
                    return result;
                }
                return result;
                catch (Exception ex)
                {
                    result.code = "1";
                    result.msg = ex.ToString();
                    LogHelper.Error("TrayItembind Error：" + ex.ToString(), ex);
                    return result;
                }
            }
            catch (Exception ex)
            {
                result.code = "1";
                result.msg = ex.ToString();
                LogHelper.Error("TrayItembind Error：" + ex.ToString(), ex);
                return result;
            }



        }
@@ -874,13 +920,8 @@
                        return result;
                    }

                    //判断有无相同物料排
                    loc = StorageCompute(itemcode, areacode);
                    //if (loc == null)
                    //{
                    //    //无相同物料排找空排
                    //    loc = emptyRow(areacode);
                    //}

                    if (loc != null)
                    {
                        End = loc.S_CODE;
@@ -1219,7 +1260,7 @@
                        if (startloc.N_LAYER == 3)
                        {
                            //叠盘货位计算叠盘货位
                            var dploc = db.Queryable<Location>().Where(a => a.S_NOTE.Trim() == "叠盘" && a.N_LAYER == startloc.N_LAYER && a.S_WH_CODE.Trim() == startloc.S_WH_CODE).ToList();
                            var dploc = db.Queryable<Location>().Where(a => a.S_NOTE.Trim() == "叠盘" && a.N_LAYER == startloc.N_LAYER && a.S_WH_CODE.Trim() == startloc.S_WH_CODE && a.C_ENABLE == "Y").ToList();
                            if (dploc.Count > 0)
                            {
                                // LogHelper.Info($"获取叠盘货位:{JsonConvert.SerializeObject(dploc)}");
@@ -1250,7 +1291,7 @@
                        else if (startloc.S_NOTE == "PB")
                        {
                            //找块胶堆叠区
                            var KjDploc = db.Queryable<Location>().Where(a => a.S_NOTE.Trim() == "片胶堆叠位" && a.S_WH_CODE.Trim() == startloc.S_WH_CODE).ToList();
                            var KjDploc = db.Queryable<Location>().Where(a => a.S_NOTE.Trim() == "片胶堆叠位" && a.S_WH_CODE.Trim() == startloc.S_WH_CODE && a.C_ENABLE == "Y").ToList();
                            if (KjDploc.Count > 0)
                            {
                                loc = KjDploc.FindAll(a => a.N_LOCK_STATE == 0 && a.N_CURRENT_NUM < 6).OrderByDescending(a => a.N_CURRENT_NUM).FirstOrDefault();
@@ -1644,7 +1685,7 @@
                    }
                    else
                    {
                        if (db.Updateable(new LocCntrRel() { S_CNTR_CODE = model.Rfid, S_LOC_CODE = Start }).UpdateColumns().ExecuteCommand() <= 0)
                        if (db.Insertable(new LocCntrRel() { S_CNTR_CODE = model.Rfid, S_LOC_CODE = Start }).ExecuteCommand() <= 0)
                        {
                            result.code = "1";
                            result.msg = $"创建任务失败，托盘:{model.Rfid}绑定货位{Start}失败";
@@ -1703,7 +1744,6 @@
                            {
                                //loc =  EndLocs.Find(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0);
                                loc = FindEndcolByLocList(EndLocs);


                            }
                            else
@@ -2094,7 +2134,7 @@

                var startloc = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == model.Data.start_loc_code).First();

                var endloc = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == model.Data.end_loc_code && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0).First();
                var endloc = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == model.Data.end_loc_code && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y").First();


                //判断楼层是否相等，如果不相同需要生成分段任务进行电梯调用
@@ -2153,8 +2193,8 @@
                        Z_TYPE = 6
                    };

                
                    if (WCSHelper.CreateTask(wcsTask) )

                    if (WCSHelper.CreateTask(wcsTask))
                    {
                        LogHelper.Info("创建任务成功");
                        var device = Settings.deviceInfos.Where(a => a.TN_Location == startloc.S_CODE).FirstOrDefault();
@@ -2167,7 +2207,7 @@
                        {
                            LogHelper.Info($"根据任务起点:{endloc.S_CODE},未找到对应货位");
                        }
                        if (device!=null&&loc!=null)
                        if (device != null && loc != null)
                        {
                            int value = 0;
                            if (loc.N_LAYER == 1) value = 1;
@@ -2177,10 +2217,10 @@
                            ModbusHelper.WriteSingleRegister(40089, value, device.address, 1024);
                            ModbusHelper.WriteSingleRegister(40102, 1, device.address, 1024);
                        }
                       

                        //LocationHelper.LockLoc(startloc.S_CODE, 2);
                        //LocationHelper.LockLoc(endloc.S_CODE, 1);
                     

                    }
                    else
                    {
@@ -2298,54 +2338,59 @@
            }
            string loc = model.LocationNum;
            var db = new SqlHelper<object>().GetInstance();
            try
            lock (_lockCreateItem)
            {
                var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
                if (location != null)
                try
                {
                    var loccntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).First();

                    if (loccntr != null)
                    var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
                    if (location != null)
                    {
                        string cntrcode = loccntr.S_CNTR_CODE;
                        var CntrItem = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE.Trim() == cntrcode).First();
                        if (CntrItem != null)
                        var loccntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).First();

                        if (loccntr != null)
                        {
                            //清除托盘物料绑定关系
                            db.Deleteable<CntrItemDetail>().Where(it => it.S_CNTR_CODE.Trim() == CntrItem.S_CNTR_CODE).ExecuteCommand();
                            string cntrcode = loccntr.S_CNTR_CODE;
                            var CntrItem = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE.Trim() == cntrcode).First();
                            if (CntrItem != null)
                            {
                                //清除托盘物料绑定关系
                                db.Deleteable<CntrItemDetail>().Where(it => it.S_CNTR_CODE.Trim() == CntrItem.S_CNTR_CODE).ExecuteCommand();
                            }
                            else
                            {
                                LogHelper.Info($"ClearLocCntr 托盘{cntrcode}无物料绑定关系");
                            }
                            if (LocationHelper.UnBindingLoc(loc, new List<string>() { cntrcode }))
                            {
                                LogHelper.Info($"清除托盘货位关系成功");
                            }

                        }
                        else
                        {
                            LogHelper.Info($"ClearLocCntr 托盘{cntrcode}无物料绑定关系");
                            LogHelper.Info($"ClearLocCntr 货位{loc}无托盘货位绑定关系");
                        }
                        if (LocationHelper.UnBindingLoc(loc, new List<string>() { cntrcode }))
                        {
                            LogHelper.Info($"清除托盘货位关系成功");
                        }

                    }
                    else
                    {
                        LogHelper.Info($"ClearLocCntr 货位{loc}无托盘货位绑定关系");
                        result.code = "1";
                        result.msg = $"根据货位:{loc}找不到货位关系";
                        AddErrorInfo("货位为空", result.msg, Source);
                        return result;
                    }
                }
                else
                catch (Exception ex)
                {
                    LogHelper.Info($"ClearLocCntr Error：{ex}");
                    db.Ado.CommitTran();
                    result.code = "1";
                    result.msg = $"根据货位:{loc}找不到货位关系";
                    AddErrorInfo("货位为空", result.msg, Source);
                    result.msg = $"Error：{ex}";
                    return result;

                }
            }
            catch (Exception ex)
            {
                LogHelper.Info($"ClearLocCntr Error：{ex}");
                db.Ado.CommitTran();
                result.code = "1";
                result.msg = $"Error：{ex}";
                return result;

            }
          
        

            return result;
        }
@@ -2542,7 +2587,7 @@
        internal static Location StorageCompute(string itemcode, string areacode)
        {
            var db = new SqlHelper<object>().GetInstance();
            Location result = db.Queryable<Location>().Where(a => a.N_CURRENT_NUM == 0 && a.S_AREA_CODE.Trim() == areacode && a.N_LOCK_STATE == 0).First();
            Location result = db.Queryable<Location>().Where(a => a.N_CURRENT_NUM == 0 && a.S_AREA_CODE.Trim() == areacode && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y").First();
            //查询所有有托盘的排没锁的排
            // var list = db.Queryable<Location>().Where(a => a.N_CURRENT_NUM > 0 && a.S_AREA_CODE.Trim() == areacode && a.N_LOCK_STATE == 0).OrderByDescending(a => a.N_COL).Take(1).PartitionBy(a => a.N_ROW).ToList();
            // if (list.Count > 0)
@@ -2739,7 +2784,7 @@

            lock (_lockLocation)
            {
                var loc = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == jtcode.Trim() && a.S_NOTE == cntrType && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无").First();
                var loc = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == jtcode.Trim() && a.S_NOTE == cntrType && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y").First();
                if (loc != null)
                {
                    End = loc;
@@ -2812,7 +2857,7 @@
                        Location other = null;
                        //当前排没有锁并且有空位置
                        //先找满位，然后后面一层要么是空，要么不存在
                        other = rowList.OrderBy(a => a.N_COL).Where(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0).FirstOrDefault();
                        other = rowList.OrderBy(a => a.N_COL).Where(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y").FirstOrDefault();
                        //if (full == null)
                        //{
                        //    //没有满位，那就找最小的空位