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;
@@ -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)
                {
@@ -277,6 +284,14 @@
                {
                    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)}");
            }
@@ -293,11 +308,11 @@
            Location loc = new Location();
            var db = new SqlHelper<object>().GetInstance();
            string CntrCodeWith = "";
            if (type.Trim() == "PM")
            if (type.Trim().Contains("MA"))
            {
                CntrCodeWith = "MA";
            }
            else if (type.Trim() == "PN")
            else if (type.Trim().Contains("NA"))
            {
                CntrCodeWith = "NA";
            }
@@ -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,13 +634,123 @@
            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)
                //{
                //    if (location.S_NOTE == "叠盘" || location.S_NOTE.Trim() == "片胶堆叠位")
                //    {
                //        LogHelper.Info("叠盘货位删除托盘");
                //        cntrs = lcrList.Select(a => a.S_CNTR_CODE).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();
                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:解绑容器:{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>
        /// <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;
            }
@@ -635,7 +760,6 @@
            }
            return res;
        }
        /// <summary>
        /// 解锁货位
        /// </summary>