合肥佳通AGV项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
lss
2025-07-04 3865194441f1e1da34c0be9034d86c8d0d68706c 
 HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs


@@ -210,7 +210,7 @@


        /// <param name="lev">物料等级</param>


        /// <param name="ItemCode">物料编码</param>


        /// <returns></returns>


        internal static List<Location> GetLocByItemCode(string areaCode, string ItemCode, string lev)


        internal static List<Location> GetLocByItemCode(string areaCode, string ItemCode, string lev, string powderType)


        {




            List<Location> locs;


@@ -220,7 +220,7 @@


            var queryable = db.Queryable<Location>()


      .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)


      .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)


      .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode );


      .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode);


            //六位码匹配前六位，其他的全部配置


            if (ItemCode.Trim().Length == 6)


            {


@@ -237,7 +237,7 @@


            //.Skip(targetIndex)  // 跳过高于目标等级的等级


            //.ToList();




            LogHelper.Info($"GetLocByItemCode=>根据库区编码:{areaCode}，物料编码:{ItemCode},物料优先级:{lev}，物料等级计算出有托盘货位{JsonConvert.SerializeObject(queryable.ToList())}");


            LogHelper.Info($"GetLocByItemCode=>根据库区编码:{areaCode}，物料编码:{ItemCode},物料优先级:{lev}，机台型号:{powderType}，物料等级计算出有托盘货位{JsonConvert.SerializeObject(queryable.ToList())}");


            //判断需不需要物料等级查找，并优先出库余料


            if (string.IsNullOrEmpty(lev))


            {


@@ -247,7 +247,14 @@


            {


                locs = queryable.Where((a, b, c) => c.LEV == lev && c.S_BS_TYPE == "余料").ToList();


            }


            //   LogHelper.Info($"GetLocByItemCode=>查找余料,{JsonConvert.SerializeObject(locs)}");


            if (string.IsNullOrEmpty(powderType))


            {


                locs = queryable.Where((a, b, c) => c.S_BS_TYPE == "余料").ToList();


            }


            else


            {


                locs = queryable.Where((a, b, c) => c.S_FLTYPE == powderType && c.S_BS_TYPE == "余料").ToList();


            }




            //没有余料则寻找全部物料


            if (locs.Count == 0)


@@ -255,7 +262,7 @@


                queryable = db.Queryable<Location>()


                    .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)


                    .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)


                    .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode );


                    .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode && c.S_FLTYPE == powderType);


                //六位码匹配前六位，其他的全部配置


                if (ItemCode.Trim().Length == 6)


                {


@@ -276,6 +283,14 @@


                else


                {


                    locs = queryable.Where((a, b, c) => c.LEV == lev).ToList();


                }


                if (string.IsNullOrEmpty(powderType))


                {


                    locs = queryable.ToList();


                }


                else


                {


                    locs = queryable.Where((a, b, c) => c.S_FLTYPE == powderType ).ToList();


                }


                LogHelper.Info($"GetLocByItemCode=>无余料,查找全部{JsonConvert.SerializeObject(locs)}");


            }


@@ -332,7 +347,7 @@


            Dictionary<int, string> dics = new Dictionary<int, string>();


            foreach (var deviceInfo in devices)


            {


                int mst = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("电梯") && state.Contains(a.S_B_STATE)).Count();


                int mst = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("电梯") && state.Contains(a.S_B_STATE) && a.S_END_LOC == deviceInfo.TN_Location).Count();


                dics.Add(mst, deviceInfo.TN_Location);


            }


            if (dics.Count > 0)


@@ -619,6 +634,7 @@


            var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();


            try


            {


                LogHelper.Info($"BindingLoc：开始解绑容器：{JsonConvert.SerializeObject(cntrs)}");


                db.BeginTran();


                var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();


                //if (!string.IsNullOrEmpty(location.S_NOTE) && lcrList.Count > 0)


@@ -634,13 +650,12 @@


                {


                    cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();


                }


                LogHelper.Info($"BindingLoc：开始解绑容器：{cntrs}");


                var count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();


                location.N_CURRENT_NUM = lcrList.Count - count;


                location.S_LOCK_STATE = "无";


                location.N_LOCK_STATE = 0;


                db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();


                LogHelper.Info($"BindingLoc：解绑容器：{cntrs}，成功");


                LogHelper.Info($"BindingLoc：解绑容器：{JsonConvert.SerializeObject(cntrs)}成功");


                db.CommitTran();


                res = true;


            }


@@ -653,6 +668,99 @@


        }




        /// <summary>


        /// 库位清空


        /// </summary>


        /// <param name="loc"></param>


        /// <param name="cntrs"></param>


        /// <returns></returns>


        public static bool Clear(string loc, List<string> cntrs)


        {


            var res = false;


            var db = new SqlHelper<object>().GetInstance();




            try


            {


                var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();


                if (location == null)


                {


                    LogHelper.Info($"Clear：货位：{loc}货位表查询错误，请假查货位表");


                    return res;


                }


                LogHelper.Info($"Clear：开始解绑容器：{JsonConvert.SerializeObject(cntrs)}");


                db.BeginTran();


                var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();


                if (lcrList.Count > 0)


                {


                    cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();


                }


                var count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();


                LogHelper.Info($"Clear：开始删除容器：{JsonConvert.SerializeObject(cntrs)}");


                db.Deleteable<Container>().Where(it => cntrs.Contains(it.S_CODE)).ExecuteCommand();




                location.N_CURRENT_NUM = lcrList.Count - count;


                location.S_LOCK_STATE = "无";


                location.N_LOCK_STATE = 0;


                db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();


                LogHelper.Info($"Clear：开始删除容器物料：{JsonConvert.SerializeObject(cntrs)}");


                var CntrItem = db.Queryable<CntrItemDetail>().Where(a => cntrs.Contains(a.S_CNTR_CODE.Trim())).First();


                if (CntrItem != null)


                {


                    db.Deleteable<CntrItemDetail>().Where(it => cntrs.Contains(it.S_CNTR_CODE)).ExecuteCommand();


                }


                else


                {


                    LogHelper.Info($"Clear=》托盘:{JsonConvert.SerializeObject(cntrs)}无物料数据");




                }


                LogHelper.Info($"BindingLoc：解绑容器：{JsonConvert.SerializeObject(cntrs)}成功");


                db.CommitTran();


                res = true;


            }


            catch (Exception ex)


            {


                LogHelper.Info($"BindingLoc Error:{ex}");


                db.RollbackTran();


            }


            return res;


        }


        /// <summary>


        /// 解锁货位，删除货位托盘


        /// </summary>


        /// <param name="loc"></param>


        /// <returns></returns>


        public static bool UnlockLocDeleteCntrs(string loc)


        {


            var res = false;


            var db = new SqlHelper<object>().GetInstance();


            List<string> cntrs = null; int count = 0;


            var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();


            try


            {


                db.BeginTran();


                var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();


                if (lcrList.Count > 0)


                {


                    cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();


                    LogHelper.Info($"UnlockLocDeleteCntrs：货位{loc}：查询绑定托盘{cntrs}");


                    LogHelper.Info($"UnlockLocDeleteCntrs：开始删除容器：{JsonConvert.SerializeObject(cntrs)}");


                    count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();




                }




                location.N_CURRENT_NUM = lcrList.Count - count;


                location.S_LOCK_STATE = "无";


                location.N_LOCK_STATE = 0;


                db.Updateable(location).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE, it.N_CURRENT_NUM }).ExecuteCommand();


                db.CommitTran();


                res = true;


            }


            catch (Exception ex)


            {


                db.RollbackTran();


            }


            return res;


        }


        /// <summary>


        /// 解锁货位


        /// </summary>


        /// <param name="loc"></param>