WMSPrjInstance/HH-0164_LinZhiNongFu.git

			@@ -9,6 +9,7 @@
			using System.Text;
			using System.Threading;
			using System.Threading.Tasks;
			using static HH.WCS.Mobox3.NFLZ.wms.WMSHelper.AddChangeModel;
			using static System.Runtime.CompilerServices.RuntimeHelpers;

			namespace HH.WCS.Mobox3.NFLZ.core
			@@ -60,10 +61,11 @@
			if (locInfo != null)
			{
			LogHelper.Info($"【瓶盖满托转运】瓶坯接驳位查询到需入库的瓶坯，货位编码：{locInfo.S_CODE}");
			if (locInfo.LocCntrRel != null)
			string cntrCode = getCntrCode(db, locInfo);
			if (string.IsNullOrEmpty(cntrCode))
			{
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "接驳位入库", locInfo.LocCntrRel.S_CNTR_CODE, "瓶盖");
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "接驳位入库", cntrCode, "瓶盖");
			}
			else
			{
			@@ -77,15 +79,23 @@
			}
			#endregion

			#region 瓶坯空托入库
			#region 瓶盖空托入库
			areaInfo = Settings.areaInfos.Where(a => a.areaName == "瓶盖非即产空框" && a.enable == 1).FirstOrDefault();
			if(areaInfo != null)
			{
			var locInfo = db.Queryable<Location>().Where(a => a.S_AREA_CODE == areaInfo.areaCode && a.N_CURRENT_NUM == a.N_CAPACITY && a.S_LOCK_STATE == "无").Includes(a => a.LocCntrRel).First();
			if(locInfo != null && locInfo.LocCntrRel != null)
			var locInfo = db.Queryable<Location>().Where(a => a.S_AREA_CODE == areaInfo.areaCode && a.N_CURRENT_NUM == a.N_CAPACITY && a.S_LOCK_STATE == "无").First();
			if(locInfo != null)
			{
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "瓶盖空托入库", locInfo.LocCntrRel.S_CNTR_CODE, "瓶盖");
			string cntrCode = getCntrCode(db, locInfo);
			if (string.IsNullOrEmpty(cntrCode))
			{
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "瓶盖空托入库", cntrCode, "瓶盖");
			}
			else
			{
			LogHelper.Info($"【瓶盖空托转运】当前货位未绑定托盘码，货位编码：{locInfo.S_CODE}");
			}
			}
			}
			else
			@@ -101,18 +111,16 @@
			var locInfo = db.Queryable<Location>().Where(a => a.S_AREA_CODE == areaInfo.areaCode && a.N_CURRENT_NUM == a.N_CAPACITY && a.S_LOCK_STATE == "无").First();
			if (locInfo != null)
			{
			string cntr = "";
			var cntrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == locInfo.S_CODE).ToList();
			if (cntrList.Count > 0)
			string cntrCode = getCntrCode(db, locInfo);
			if (!string.IsNullOrEmpty(cntrCode))
			{
			foreach (var a in cntrList)
			{
			cntr = cntr + a.S_CNTR_CODE + ",";
			}
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "接驳位入库", cntrCode, "瓶坯");
			}
			cntr = cntr.TrimEnd(',');
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "接驳位入库", cntr, "瓶坯");
			else
			{
			LogHelper.Info($"【瓶胚满托转运】当前货位未绑定托盘码，货位编码：{locInfo.S_CODE}");
			}
			}
			}
			else
			@@ -121,90 +129,175 @@
			}

			#endregion

			}

			/// <summary>
			/// 半成品工单监控
			/// 瓶坯翻斗机非急产满框区补满托
			/// </summary>
			/// <exception cref="NotImplementedException"></exception>
			internal static void BCPWorkSurveillance()
			internal static void PPFDFullIn()
			{
			//瓶盖翻斗机工单
			//开启，查询瓶盖非急产急用物料是否满，不满则补充物料
			//关闭， 1、查询瓶盖空托是否还有托盘，有则入库 2、查询瓶盖非即产即用是否有物料，有则入库
			//瓶坯翻斗机
			//开启，查询是否为非即产即用，如果为非即产即用，则判断瓶坯非即产即用库区是否满，不满则补空物料
			//关闭，查询瓶坯非即产即用瓶坯即产即用A 瓶坯即产即用B 是否有物料，有则入库
			//瓶坯注塑机
			//开启，查询瓶坯空托是否空托数量大于3托，如果不大于，则补空托
			//关闭，查询瓶坯空托是否有空托，有则入库



			//判断当前半成品工单是否有执行中的任务
			//工单类型： 1、农夫林芝-瓶坯机 2、农夫林芝-瓶盖翻斗机 3、农夫林芝-瓶坯翻斗机
			bool PPZUUSE = false; //瓶坯机是否使用
			bool PPFDUSE = false; //瓶坯翻斗机是否使用
			bool PGFDUSE = false; //瓶盖翻斗机是否使用

			//产线号：农夫林芝-1号瓶坯翻斗机
			var db = new SqlHelper<object>().GetInstance();
			var workList = db.Queryable<LinZhiBCPWorkOrder>().Where(a => a.S_WorkState == "执行中").ToList();
			if (workList.Count > 0)
			var bcpWorkList = db.Queryable<LinZhiBCPWorkOrder>().Where(a => a.S_PLineNo.Contains("瓶坯翻斗机") && a.S_UsingNow == "N" && a.S_WorkState == "执行中").ToList();
			if(bcpWorkList.Count > 0)
			{
			foreach (var a in workList)
			bcpWorkList.ForEach(a =>
			{
			if (a.S_PLineNo == "农夫林芝-瓶坯机")
			string areaName = a.S_PLineNo.Split('-')[1].Substring(0, 1) + "号瓶胚翻斗机非即产满框";
			var areaInfo = Settings.areaInfos.Where(b => b.areaName == areaName && b.enable == 1).FirstOrDefault();
			if(areaInfo != null)
			{
			PPZUUSE = true;
			}
			else if (a.S_PLineNo == "农夫林芝-瓶盖翻斗机")
			{
			PGFDUSE = true;
			var locInfo = db.Queryable<Location>().Where(b => b.S_AREA_CODE == areaInfo.areaCode && b.N_CURRENT_NUM == 0 && b.S_LOCK_STATE == "无").First();
			if(locInfo != null)
			{
			//生成任务
			Location location = TaskProcess.BCPInOrOut(db, false, "瓶坯库区", a.S_ItemCode);
			if(location != null)
			{
			string cntrCode = getCntrCode(db,location);
			//创建作业
			WMSHelper.CreateOpTask(location.S_CODE, locInfo.S_CODE, "入库", "瓶坯非急产补满框", cntrCode, "瓶坯");
			}
			}
			}
			else
			{
			PPFDUSE = true;
			LogHelper.Info($"{areaName}未配置");
			}
			}
			});
			}

			//瓶坯机使用，则从瓶坯库区补充空托到瓶坯空托，未使用，则将瓶坯空托的空托移到瓶坯库区
			//瓶坯翻斗机使用，则从瓶坯库区补充空托到瓶坯即产即用/瓶坯非即产即用，未使用，则将瓶坯即产即用/瓶坯非即产即用的空托移到瓶坯库区
			//瓶盖翻斗机使用，则从瓶盖库区补充空托到瓶坯非即产即用，未使用，则将瓶坯非即产即用的空托移到瓶盖库区

			TaskProcess.BCPYiKu(PPZUUSE, "瓶坯注塑机");
			TaskProcess.BCPYiKu(PPFDUSE, "瓶坯翻斗机");
			TaskProcess.BCPYiKu(PGFDUSE, "瓶盖翻斗机");

			}

			internal static void JBDEIN()
			private static string getCntrCode(SqlSugar.SqlSugarClient db, Location location)
			{
			var db = new SqlHelper<object>().GetInstance();
			var areaInfo = Settings.areaInfos.Where(a => a.areaName == "瓶胚入库接驳" && a.enable == 1).FirstOrDefault();
			if(areaInfo != null)
			string cntr = "";
			var cntrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == location.S_CODE).OrderBy(a => a.T_CREATE).ToList();
			if(cntrList.Count > 0)
			{
			var locInfo = db.Queryable<Location>().Where(a => a.S_AREA_CODE == areaInfo.areaCode && a.N_CURRENT_NUM == a.N_CAPACITY && a.S_LOCK_STATE == "无").First();
			if(locInfo != null)
			foreach(var a in cntrList)
			{
			string cntr = "";
			var cntrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == locInfo.S_CODE).ToList();
			if(cntrList.Count > 0)
			{
			foreach(var a in cntrList)
			{
			cntr = cntr + a.S_CNTR_CODE + ",";
			}
			}
			cntr = cntr.TrimEnd(',');
			//创建作业
			WMSHelper.CreateOpTask(locInfo.S_CODE, "", "入库", "接驳位入库", cntr, "瓶坯");
			cntr = cntr + a.S_CNTR_CODE + ",";
			}
			}
			else
			cntr = cntr.TrimEnd(',');
			return cntr;
			}

			internal static void PGFDFullIn()
			{
			//产线号：农夫林芝-1号瓶盖翻斗机
			//瓶盖翻斗机共用一个库区，需要区分几种情况（注：现场已确认，三个翻斗机不会有三种物料）
			//1、如果三个翻斗机物料相同，则瓶盖非即产满框有空货位就补
			//2、如果三个翻斗机有两种不同的物料，则瓶盖非即产满框有空位的补充改库区没有的物料
			var db = new SqlHelper<object>().GetInstance();
			string itemList = "";
			var bcpWorkList = db.Queryable<LinZhiBCPWorkOrder>().Where(a => a.S_PLineNo.Contains("瓶盖翻斗机") && a.S_UsingNow == "N" && a.S_WorkState == "执行中").ToList();
			if (bcpWorkList.Count > 0)
			{
			LogHelper.Info("瓶胚入库接驳未配置");
			bcpWorkList.ForEach(a =>
			{
			if (string.IsNullOrEmpty(itemList))
			{
			itemList = itemList + a.S_ItemCode + ",";
			}
			else
			{
			if (!itemList.Contains(a.S_ItemCode))
			{
			itemList = itemList + a.S_ItemCode + ",";
			}
			}
			});
			}
			if (!string.IsNullOrEmpty(itemList))
			{
			itemList = itemList.TrimEnd(',');
			List<string> itemCount = itemList.Split(',').ToList();
			if(itemCount.Count > 0)
			{
			var areaInfo = Settings.areaInfos.Where(b => b.areaName == "瓶盖非即产满框" && b.enable == 1).FirstOrDefault();
			if (areaInfo != null)
			{
			var locInfo = db.Queryable<Location>().Where(b => b.S_AREA_CODE == areaInfo.areaCode && b.N_CURRENT_NUM == 0 && b.S_LOCK_STATE == "无").First();
			if (locInfo != null)
			{
			if (itemCount.Count == 1)
			{
			//只有一种物料
			//生成任务
			Location location = TaskProcess.BCPInOrOut(db, false, "瓶盖库区", itemCount[0]);
			if (location != null)
			{
			string cntrCode = getCntrCode(db, location);
			//创建作业
			WMSHelper.CreateOpTask(location.S_CODE, locInfo.S_CODE, "入库", "瓶盖非急产补满框", cntrCode, "瓶盖");
			}
			}
			if (itemCount.Count == 2)
			{
			//两种物料

			//判断库区是否有货位数量大于0或者有入库锁的，如果有，则判断物料，如果没有，则生成第一个物料的任务
			var locInfo2 = db.Queryable<Location>().Where(b => b.S_AREA_CODE == areaInfo.areaCode && (b.N_CURRENT_NUM > 0 \|\| b.S_LOCK_STATE == "入库锁")).First();
			if(locInfo2 != null)
			{
			string itemCode = "";
			if(locInfo2.N_CURRENT_NUM > 0)
			{
			var cntrInfo = db.Queryable<LocCntrRel>().Where(b => b.S_LOC_CODE == locInfo2.S_CODE).First();
			if(cntrInfo != null)
			{
			var itemInfo = db.Queryable<CntrItemRel>().Where(b => b.S_CNTR_CODE == cntrInfo.S_CNTR_CODE).First();
			if(itemInfo != null)
			{
			itemCode = itemInfo.S_ITEM_CODE;
			}
			}
			}
			if(locInfo2.S_LOCK_STATE == "入库锁")
			{
			var taskInfo = db.Queryable<WMSTask>().Where(b => b.S_END_LOC == locInfo2.S_CODE && b.S_STATE != "完成" && b.S_STATE != "取消").First();
			if(taskInfo != null)
			{
			string cntrCode = taskInfo.S_CNTR_CODE.Split(',')[0];
			var itemInfo = db.Queryable<CntrItemRel>().Where(b => b.S_CNTR_CODE == cntrCode).First();
			if (itemInfo != null)
			{
			itemCode = itemInfo.S_ITEM_CODE;
			}
			}
			}

			if (itemCode != "")
			{
			itemCode = itemCode == itemCount[0] ? itemCount[1] : itemCount[0];
			Location location = TaskProcess.BCPInOrOut(db, false, "瓶盖库区", itemCode);
			if (location != null)
			{
			string cntrCode = getCntrCode(db, location);
			//创建作业
			WMSHelper.CreateOpTask(location.S_CODE, locInfo.S_CODE, "入库", "瓶盖非急产补满框", cntrCode, "瓶盖");
			}
			}
			}
			else
			{
			Location location = TaskProcess.BCPInOrOut(db, false, "瓶盖库区", itemCount[0]);
			if (location != null)
			{
			string cntrCode = getCntrCode(db, location);
			//创建作业
			WMSHelper.CreateOpTask(location.S_CODE, locInfo.S_CODE, "入库", "瓶盖非急产补满框", cntrCode, "瓶盖");
			}
			}
			}
			}
			}
			else
			{
			LogHelper.Info($"瓶盖非即产满框未配置");
			}
			}
			}
			}
			}