xiaomi

zxx

2025-07-01 5e04278c55e10c245a184057b6ae3bd8238dd93a

 HH.WCS.Mobox3/HH.WCS.Mobox3.XiaoMi/process/TaskProcess.cs

@@ -46,13 +46,32 @@
            {
                Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成，起点解绑容器{mst.S_CNTR_CODE}");
                LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成，起点解绑容器{mst.S_CNTR_CODE}");
                LocationHelper.UnBindingLoc(mst.S_START_LOC, mst.S_CNTR_CODE.Split(',').ToList());
                if (mst.S_FRAME_CODE != null)
                {
                    LocationHelper.UnBindingLocHj(mst.S_START_LOC, mst.S_FRAME_CODE);

                }
                else
                {
                    LocationHelper.UnBindingLoc(mst.S_START_LOC, mst.S_CNTR_CODE.Split(',').ToList());

                }
            }
            else
            {
                Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成，终点绑定容器{mst.S_CNTR_CODE}");
                LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成，终点绑定容器{mst.S_CNTR_CODE}");
                LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());
                //如果货架有值则绑货架
                if (mst.S_FRAME_CODE!=null)
                {
                    LocationHelper.BindingLocHj(mst.S_END_LOC, mst.S_FRAME_CODE);

                }
                else
                {
                    LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());

                }
            }

        }
@@ -380,7 +399,24 @@
            }
            return result;
        }
        //小米货架任务
        public static bool CreateTransportHj(string start, string end, string taskType, string frame, int startLayer, int endLayer, int trayCarryCount = 1, int priority = 1)
        {
            var result = false;
            var trayCodes = frame;
            var taskNo = DateTime.Now.Ticks.ToString();


            var res = WCSHelper.CreateTaskHj(taskNo, start.Trim(), end.Trim(), taskType, priority, trayCodes, trayCarryCount, startLayer, endLayer);
            if (res)
            {
                result = true;
                //任务创建成功，起点货位出库锁定，终点货位入库锁定
                LocationHelper.LockLoc(start, 2);
                LocationHelper.LockLoc(end, 1);
            }
            return result;
        }
        /// <summary>
        /// 创建搬运任务
        /// </summary>
@@ -1834,9 +1870,188 @@

        }

        

        /// <summary>
        /// 小件
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static TaskResponse smallMaterial(smallMaterial model)
        {
            try
            {
                var startLoc = new Location();
                var endLoc = new Location();
                string Message = null;

                if (model.taskType=="自动")
                {
                    
                    autoSmallMaterial(model);


                }
                else if (model.taskType == "人工")
                {
                    artificialSmallMaterial(model);

                }






                    
                var result = new TaskResponse();
                if (Message != null)
                {
                    result = new TaskResponse
                    {
                        header = new ResponseHead { code = 0, desc = Message }
                    };
                }
                else
                {
                    result = new TaskResponse
                    {
                        header = new ResponseHead { code = 200, desc = "SUCCESS" },
                        body = new ResponseBody
                        {
                            msg = "success",
                            app_name = "Guozi client",
                            data = new List<ResponseData> { new ResponseData { in_order_id = model.taskID } },
                            version = ""
                        }
                    };
                }
                return result;

            }
            catch (Exception ex)
            {
                Console.WriteLine("bigMaterial:" + ex.Message + ex.StackTrace);
                LogHelper.Error("bigMaterial:" + ex.Message, ex);
                throw;
            }

        }
        //自动 拆分
        private static string autoSmallMaterial(smallMaterial model) {
            var db = new SqlHelper<Location>().GetInstance();

            string Message = null;

            //拆分成两条任务，一条是料架到指定的缓存区，料架上的托盘到指定的工位（小米wcs传）一对多
            var startFrame = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == model.parameters[0].src).First();

            var startLoc = db.Queryable<Location>().Where(a => a.S_CODE == startFrame.S_FRAME_CODE).First();
            if (startLoc == null || startLoc.N_LOCK_STATE != 0)
            {
                Message = $"{model.parameters[0].src}库位已被锁定!";
            }
            var endReservoirs = Settings.ReservoirAreas.Where(s => s.areaName == model.routeType).FirstOrDefault();
            var endLoc = TaskProcess.InWorkTransport(endReservoirs.areaCode);
            if (endLoc != null)
            {
                //创建到缓存区任务
                var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).First();
                //创建任务
                LogHelper.Info($"创建任务 起点:{startLoc.S_CODE}终点:{endLoc.S_CODE}", model.ts_name);
                var res = TaskProcess.CreateTransportHj(startLoc.S_CODE, endLoc.S_CODE, model.ts_name, locCntrRel.S_FRAME_CODE, 1, 1);
                if (!res)
                {
                    return Message="自动上线任务创建失败";
                }
            }
            //料架上的托盘到指定的工位
            foreach (var parameter in model.parameters)
            {
                var startLocHj = db.Queryable<Location>().Where(a => a.S_CODE == parameter.src).First();
                if (startLocHj == null || startLocHj.N_LOCK_STATE != 0)
                {
                    Message = $"{model.parameters[0].src}库位已被锁定!";
                }
                //货架上的货判断一下货架有没有锁
                var startFrameParent = db.Queryable<LocFrameRel>().Where(a => a.S_LOC_CODE == parameter.src).First();
                if (startFrameParent != null)
                {
                    var startLocParent = db.Queryable<Location>().Where(a => a.S_CODE == startFrameParent.S_FRAME_CODE).First();
                    if (startLocParent == null || startLocParent.N_LOCK_STATE != 0)
                    {
                        Message = $"{startFrameParent.S_FRAME_CODE}库位已被锁定!";
                    }
                }




            }

            return Message;
            //switch (model.ts_name)
            //{
            //    case "p2p":
            //        startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.src).First();
            //        if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
            //        {
            //            Message = $"{model.parameter.src}库位已被锁定!";
            //        }

            //        endLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.dst).First();
            //        if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
            //        {
            //            Message = $"{model.parameter.dst}库位已被锁定!";
            //        }

            //        break;
            //    case "p2a":
            //        startLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.src).First();
            //        if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
            //        {
            //            Message = $"{model.parameter.src}库位已被锁定!";
            //        }
            //        endLoc = InWorkTransport(model.parameter.dst);
            //        if (endLoc == null)
            //        {
            //            Message = $"{model.parameter.dst}库区没有可入货位!";
            //        }
            //        break;
            //    case "a2p":
            //        startLoc = OutWorkTransport(model.parameter.src);
            //        if (startLoc == null)
            //        {
            //            Message = $"{model.parameter.dst}库区没有可出货位!";
            //        }

            //        endLoc = db.Queryable<Location>().Where(a => a.S_CODE == model.parameter.dst).First();
            //        if (startLoc == null || startLoc.N_LOCK_STATE != 0 || startLoc.C_ENABLE != "Y")
            //        {
            //            Message = $"{model.parameter.dst}库位已被锁定!";
            //        }
            //        break;
            //}

            //var locCntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).First();
            ////创建任务
            //LogHelper.Info($"创建任务 起点:{startLoc.S_CODE}终点:{endLoc.S_CODE}", model.ts_name);
            //var res = TaskProcess.CreateTransport(startLoc.S_CODE, endLoc.S_CODE, model.ts_name, locCntrRel.S_CNTR_CODE, 1, 1);
            //if (!res)
            //{
            //    return new TaskResponse
            //    {
            //        header = new ResponseHead { code = 1, desc = Message }
            //    };

            //}
        }
        //人工 不拆分
        private static void artificialSmallMaterial(smallMaterial model)
        {
            var db = new SqlHelper<Location>().GetInstance();


        }


    }