WCSNet6.git - Gitblit

			@@ -1,6 +1,7 @@

			using Dm.filter;
			using DocumentFormat.OpenXml.Bibliography;
			using DocumentFormat.OpenXml.Drawing.Charts;
			using Elastic.Clients.Elasticsearch.Tasks;
			using Furion.Logging;
			using IoTClient;
			@@ -13,10 +14,14 @@
			using System.Reflection.Emit;
			using WCS.Application.Entity;
			using WCS.Application.Util;
			using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinExpressIntracityUpdateStoreRequest.Types;
			using static SKIT.FlurlHttpClient.Wechat.Api.Models.NontaxInsertBillRequest.Types.CardExtra.Types.BillCard.Types;

			namespace WCS.Application;
			public static class PLCService
			{
			private static readonly object OLock = new object();

			private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);

			public static void OnChangeEvent(object sender, EventArgs e)
			@@ -58,13 +63,14 @@
			private static void StackingMachine(WcsDeviceDto modDevice)
			{
			var plcConn = modDevice.PLCUtil;
			string ledText = "";
			switch (modDevice.Value.ToString())
			{
			case "820":
			// 跺机空闲，获取出库任务、移库任务
			{
			// 获取任务信息
			var modTask = _db.Queryable<WcsTask>().OrderBy(m => m.CreateTime).OrderBy(m => m.Levels, OrderByType.Asc)
			var modTask = _db.Queryable<WcsTask>().OrderBy(m => m.Levels, OrderByType.Asc).OrderBy(m => m.CreateTime)
			.First(s => s.Status == TaskStatusEnum.Wait && (s.TaskType == TaskTypeEnum.Out \|\| s.TaskType == TaskTypeEnum.Move)
			&& s.StartRoadway == modDevice.StationNum);
			if (modTask == null)
			@@ -80,7 +86,7 @@
			PlcTaskInfo taskInfo = new PlcTaskInfo();
			if (modTask.TaskType == TaskTypeEnum.Move)
			{
			taskInfo = PLCCommon.GetEndPai(modTask.EndLocate.Substring(1, 2), modTask.EndLocate.Substring(2, 2),
			taskInfo = PLCCommon.GetEndPai(modTask.EndRoadway.Substring(1, 2), modTask.EndLocate.Substring(2, 2),
			modTask.EndLocate.Substring(0, 2), modTask.EndLocate.Substring(4, 2),
			modTask.EndLocate.Substring(6, 2));

			@@ -203,8 +209,15 @@
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			//下发任务日志
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());

			//修改led屏信息
			//LedDisplay(modDevice.LedIP, "工位:" + modTask.EndLocate, "出库中 " + $"储位地址：{modTask.StartLocate}", "托盘号:" + modTask.PalletNo);
			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == taskInfo.EndStation && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business);
			ledText += $"任务类型:{modTask.TaskType.GetDescription()}\n\n";
			ledText += $"任务号:{modTask.TaskNo}\n";
			ledText += $"托盘号:{modTask.PalletNo}\n\n";
			ledText += $"起始位:{modTask.StartRoadway + " " + modTask.StartLocate}\n";
			ledText += $"目标位:{modTask.EndRoadway + " " + modTask.EndLocate}";
			LedDisplay(ledDevice.LedIP, ledText);
			}
			}
			break;
			@@ -356,8 +369,6 @@
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}

			//修改led屏信息
			//LedDisplay(modDevice.LedIP, "工位:" + modTask.EndLocate, "出库中 " + $"储位地址：{modTask.StartLocate}", "托盘号:" + modTask.PalletNo);
			}
			}
			break;
			@@ -371,7 +382,7 @@
			{
			string tasknoVal = val.ToString();
			var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
			if (modTask == null)
			if (modTask == null)
			{
			Log.Error(string.Format("跺机控制字860:未找到对应的任务。"));
			break;
			@@ -422,7 +433,7 @@
			}
			else
			{
			Log.Error(string.Format("任务反馈失败：StatusCode：{0};Msg：{1}", modResponseTask.StatusCode, modResponseTask.Msg));
			Log.Error(string.Format("c：StatusCode：{0};Msg：{1}", modResponseTask.StatusCode, modResponseTask.Msg));
			}
			}
			// 根据任务号获取起始工位地址，根据起始工位地址获取LEDIP 推送到LED屏幕。
			@@ -434,8 +445,16 @@
			HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());

			// led显示内容
			LedDisplay(modDevice.LedIP, "工位:" + modTask.StartLocate, "入库完成 " + $"任务完成:{modTask.TaskNo}", "托盘号:" + modTask.PalletNo);
			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modTask.StartLocate && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business);
			ledText += $"入库完成\n\n";

			ledText += $"任务号:{modTask.TaskNo}\n";
			ledText += $"托盘号:{modTask.PalletNo}\n\n";

			ledText += $"起始位:{modTask.StartRoadway + " " + modTask.StartLocate}\n";
			ledText += $"目标位:{modTask.EndRoadway + " " + modTask.EndLocate}";

			LedDisplay(ledDevice.LedIP, ledText);
			// 此处添加不空跑业务
			}
			break;
			@@ -500,13 +519,6 @@
			_db.Insertable(modcTaskMonitor).ExecuteCommand();
			//下发任务日志
			HubUtil.PublicTaskMonitor(modcTaskMonitor.Adapt<WcsTaskMonitorOutput>());

			// 根据任务号获取起始工位地址，根据起始工位地址获取LEDIP 推送到LED屏幕。
			var taskModel = _db.Queryable<WcsTask>().First(w => w.TaskNo == modTask.TaskNo);
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskModel.EndLocate).Select(s => s.LedIP).First();

			// led显示内容
			LedDisplay(modDevice.LedIP, "工位:" + modDevice.StationNum, "出库中 ", "托盘号:" + modTask.PalletNo);

			break;
			}
			@@ -890,6 +902,7 @@
			{
			return;
			}
			var ledText = "";
			switch (modDevice.Value.ToString())
			{
			case "320":
			@@ -897,11 +910,7 @@
			// 申请巷道
			string strMsg = "";
			string taskModel = "";
			// 判断是否演示模式
			//if (PLCTaskAction.boDemo)
			//{
			// taskModel = "1";// 演示模式
			//}

			// 获取工位托盘码信息
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var (res, palletVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			@@ -909,6 +918,52 @@
			{
			break;
			}
			var modPosEndLocat = modDevice.listStation.FirstOrDefault(s => s.Text == "目的工位");


			//判断入库锁定是否打开
			if (PLCTaskAction.boEnterLock)
			{
			var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (res350.IsSucceed && palletVal350 != "350")
			{
			ledText += $"申请入库失败\n\n";
			ledText += $"托盘号:{palletVal}\n";
			ledText += $"入库任务已锁定，请解锁后重试!\n";
			LedDisplay(modDevice.LedIP, ledText);
			}

			// 写入输送线退回指令
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum);
			if (ret.IsSucceed)
			{
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350");
			}

			break;
			}

			if (palletVal == null)
			{
			var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (res350.IsSucceed && palletVal350 != "350")
			{
			ledText += $"申请入库失败\n\n";
			ledText += $"托盘号:{palletVal}\n";
			ledText += $"扫描托盘号失败!\n";
			LedDisplay(modDevice.LedIP, ledText);
			}

			// 写入输送线退回指令
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum);
			if (ret.IsSucceed)
			{
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350");
			}

			break;
			}

			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			strMsg = http.RequestRoadWay(palletVal, modDevice.StationNum, taskModel, louCeng, ref EndLocate, ref TaskNo);
			@@ -943,14 +998,43 @@
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			// led显示内容
			LedDisplay(modDevice.LedIP, "工位:" + modDevice.StationNum, "申请入库 " + $"目标巷道：{EndLocate}", "托盘号:" + palletVal);
			try
			{
			ledText += $"任务类型:{taskInfo.TaskType.GetDescription()}\n\n";

			ledText += $"任务号:{taskInfo.TaskNo}\n";
			ledText += $"托盘号:{taskInfo.PalletNo}\n\n";

			ledText += $"起始位:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n";
			ledText += $"目标位:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}";
			LedDisplay(modDevice.LedIP, ledText);

			}
			catch (Exception ex)
			{
			Log.Error(ex.Message);
			}

			}

			}
			else
			{
			// 申请巷道失败！LED显示
			Log.Error(string.Format($"申请巷道失败:{strMsg},读写plc错误"));
			var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (res350.IsSucceed && palletVal350 != "350")
			{
			ledText += $"申请入库失败\n\n";
			ledText += $"托盘号:{palletVal}\n";
			ledText += $"{strMsg}\n";
			LedDisplay(modDevice.LedIP, ledText);
			}

			// 写入输送线退回指令
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum);
			if (ret.IsSucceed)
			{
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350");
			}
			}
			}
			break;
			@@ -1033,8 +1117,6 @@
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());

			// led显示内容
			LedDisplay(modDevice.LedIP, "工位:" + modDevice.StationNum, "入库中 " + $"目标巷道：{endLocatVlue}", "托盘号:" + palletVal);
			}
			}

			@@ -1099,14 +1181,25 @@

			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			// led显示内容
			LedDisplay(modDevice.LedIP, "工位:" + modDevice.StationNum, "入库中 " + $"申请储位地址:{strMsg}", "托盘号:" + palletVal);

			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business);
			ledText += $"任务类型:{taskInfo.TaskType.GetDescription()}\n\n";
			ledText += $"任务号:{taskInfo.TaskNo}\n";
			ledText += $"托盘号:{taskInfo.PalletNo}\n\n";
			ledText += $"起始位:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n";
			ledText += $"目标位:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}";
			LedDisplay(modDevice.LedIP, ledText);
			}
			}
			else
			{
			// 申请储位失败！LED显示
			Log.Error(string.Format($"申请储位失败:{strMsg},读写plc错误"));
			// led显示内容
			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business);
			ledText += $"申请入库失败\n\n";
			ledText += $"{strMsg}\n";
			LedDisplay(modDevice.LedIP, ledText);
			}

			}
			@@ -1154,7 +1247,7 @@
			break;
			}

			// 转换目标工位排列层
			// 转换目标工位排列层 03010301
			var paiVal = PLCCommon.GetDjAdress(modTask.EndRoadway.Substring(1, 2), endLocate.Substring(0, 2), endLocate.Substring(6, 2));
			string pai = paiVal.ToString();
			string lie = int.Parse(endLocate.Substring(2, 2)).ToString();
			@@ -1293,7 +1386,15 @@
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.EndLocate).Select(s => s.LedIP).First();

			// led显示内容
			LedDisplay(modDevice.LedIP, "到达工位:" + modDevice.StationNum, "出库完成 " + $"储位地址：{modInsertTaskMonitor.StartLocat}", "托盘号:" + palletVal);
			// 根据目标工位号获取对应的LEDIP地址
			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId == modDevice.PlcId);

			ledText += $"出库完成\n\n";
			ledText += $"任务号:{taskInfo.TaskNo}\n";
			ledText += $"托盘号:{taskInfo.PalletNo}\n\n";
			ledText += $"起始位:{taskInfo.StartRoadway + " " + taskInfo.StartLocate}\n";
			ledText += $"目标位:{taskInfo.EndRoadway + " " + taskInfo.EndLocate}";
			LedDisplay(ledDevice.LedIP, ledText);
			}
			// 反馈WMS出库完成
			//TaskReques taskReques = new TaskReques();
			@@ -1337,7 +1438,7 @@
			TaskNo = modTask.TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令450：{modDevice.StationNum}拣选完成,托盘离开工位",
			InteractiveMsg = $"写入指令450：{modDevice.StationNum}出库完成",
			PalletNo = palletVal,
			Status = TaskStatusEnum.Complete,
			StartLocat = starVal.ToString(),
			@@ -1371,8 +1472,14 @@
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			// led显示内容
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.EndLocate).Select(s => s.LedIP).First();
			LedDisplay(modDevice.LedIP, "工位:" + modTask.StartLocate, $"拣选完成，托盘离开工位", "托盘号:" + modTask.PalletNo);
			var ledDevice = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId == modDevice.PlcId);

			ledText += $"出库完成\n\n";
			ledText += $"任务号:{modTask.TaskNo}\n";
			ledText += $"托盘号:{modTask.PalletNo}\n\n";
			ledText += $"起始位:{modTask.StartRoadway + " " + modTask.StartLocate}\n";
			ledText += $"目标位:{modTask.EndRoadway + " " + modTask.EndLocate}";
			LedDisplay(ledDevice.LedIP, ledText);
			}
			#endregion
			}
			@@ -1421,7 +1528,7 @@
			var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
			if (modTask == null)
			{
			Log.Error(string.Format($"工位号：{modDevice.StationNum}空托盘到达，未找到对应的任务!任务号{tasknoVal};"));
			//Log.Error(string.Format($"工位号：{modDevice.StationNum}空托盘到达，未找到对应的任务!任务号{tasknoVal};"));
			break;
			}
			// 写入plc流程字90
			@@ -1598,7 +1705,7 @@
			}
			}
			// 根据箱内品种号获取码躲绑定工位及对应的分道号
			var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo);
			var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo && w.Status == "1");
			if (checkTaskInfo == null)
			{
			// 绑定信息为null写入剔除通道号
			@@ -1617,7 +1724,7 @@
			else
			{
			// 与plc交互写入分道号和流程控制字
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.RoboatNo);
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.LineNo);
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			@@ -1696,16 +1803,17 @@
			string boxNo = boxVal.ToString();
			if (string.IsNullOrEmpty(boxNo))
			{
			Log.Error(string.Format("码垛工位{0}，箱码为null插码失败!请人工强制结批。"), modDevice.StationNum);
			Log.Error($"码垛工位{modDevice.StationNum}，箱码为null插码失败!请人工强制结批。" );
			// 写入插入结果 2：插码失败
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");

			break;
			}
			// 验证箱码表是否存在此箱码
			var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNo);
			if (boxInfo == null)
			var boxInfo = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.BoxNo == boxNo).ToList();
			if (boxInfo.Count == 0)
			{
			Log.Error(string.Format("码垛工位{0}，箱码{1}不存在!请人工强制结批。"), modDevice.StationNum,boxNo);
			Log.Error($"码垛工位{modDevice.StationNum}，箱码{boxNo}不存在!请人工强制结批。");
			// 写入插入结果 2：插码失败
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
			break;
			@@ -1724,200 +1832,220 @@
			break;
			}
			// 修改插码表
			boxInfo.PalletNo = palletNo;
			boxInfo.UpdateTime = DateTime.Now;
			foreach (WcsBoxInfo item in boxInfo)
			{
			item.PalletNo = palletNo;
			item.UpdateTime = DateTime.Now;
			}

			var rowCount = _db.Updateable(boxInfo).ExecuteCommand();
			if (rowCount > 0)
			{
			// 插码成功
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1");

			//是否结批箱
			if (boxInfo[0].EndLotFlag == "1" && retVal.IsSucceed)
			{
			// 触发结批解绑分道
			AutoEndLot(boxInfo[0].LotNo, plcConn, "0");
			}
			}
			else
			{
			// 插码失败
			Log.Error(string.Format("箱码{0};码垛工位{1}，插码失败，请强制结批"),boxNo,modDevice.StationNum);
			Log.Error($"箱码{boxNo};码垛工位{modDevice.StationNum}，插码失败，请强制结批");
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
			if (retVal.IsSucceed)
			{
			// 触发结批不解绑分道
			AutoEndLot(boxInfo[0].LotNo, plcConn, "1");
			}
			}
			}
			}
			break;
			case "40":
			// 请求组托，申请入库
			{
			// 根据工位号，获取托盘号
			var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
			// 根据工位号获取托盘线该工位号的配置信息
			var numModel = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId != modDevice.PlcId);
			var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "目的工位" && m.IsDelete == false);
			if (checkTaskMedel == null)
			{
			lock (OLock)
			{
			Log.Error(string.Format("组托失败根据码垛工位{0}，获取托盘号失败!", modDevice.StationNum));

			// 写入交互工位目标地址
			var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
			if (retVal.IsSucceed)
			// 根据工位号，获取托盘号
			var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
			// 根据工位号获取托盘线该工位号的配置信息
			var numModel = PLCTaskAction.plcDevices.First(m => m.StationNum == modDevice.StationNum && m.IsDelete == false && m.DeviceType == DeviceTypeEnum.Business && m.PlcId != modDevice.PlcId);
			var posModel = PLCTaskAction.plcPositions.First(m => m.DeviceId == numModel.Id && m.Text == "目的工位" && m.IsDelete == false);
			if (checkTaskMedel == null)
			{
			// 写入组托回复流程字
			retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			}
			break;
			}

			// 码垛工位托盘号
			string palletNo = checkTaskMedel.PalletNo;

			// 是否演示模式
			if (PLCTaskAction.boDemo)
			{
			// 直接箱wms申请巷道
			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			string strMsg = http.RequestRoadWay(palletNo, modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo);
			if (strMsg.Contains("-1"))
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0};原因{1}", modDevice.StationNum, strMsg));
			break;
			}
			else
			{
			// 获取入库任务信息
			var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && (m.Status == TaskStatusEnum.Wait \|\| m.Status == TaskStatusEnum.Doing));
			if (taskModel != null)
			{
			// 获取入库取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");

			var listResult = new List<Result>();

			// 写入托盘输送线码垛工位目的工位、任务号，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 目标工位
			var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务号" && s.IsDelete == false);
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
			var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务类型" && s.IsDelete == false);
			var taskTypeStr = (int)taskModel.TaskType;
			listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));

			if (listResult.All(s => s.IsSucceed))
			{
			// 写入组托回复流程字
			var retVal1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			if (retVal1.IsSucceed)
			{
			// 将入库任务由正在执行改为正在执行
			taskModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(taskModel).ExecuteCommand();

			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令50：申请巷道成功",
			PalletNo = palletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = modDevice.StationNum,
			EndLocat = strMsg,
			};
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			}

			//// 写入托盘输送线码垛工位目的工位，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			//var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue);
			//if (retVal.IsSucceed)
			//{
			// // 写入码垛交互-组托回复流程字
			// retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");

			// // 将入库任务由正在执行改为正在执行
			// taskModel.Status = TaskStatusEnum.Doing;
			// _db.Updateable(taskModel).ExecuteCommand();
			//}
			}
			}
			}
			else
			{
			// 根据托盘号，将组托信息插入boxinfolog表并删除boxinfo表数据
			var boxInfoList = await _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToListAsync();
			if (boxInfoList.Count <= 0)
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0}，箱码信息不存在", modDevice.StationNum));
			Log.Error(string.Format("组托失败根据码垛工位{0}，获取托盘号失败!", modDevice.StationNum));

			// 写入交互工位目标地址
			var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
			if (retVal.IsSucceed)
			if (retVal.IsSucceed)
			{
			// 写入组托回复流程字
			retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			}
			break;
			}
			string sqlStr = $"insert into WCSBoxInfoLog select * from WCSBoxInfo where IsDelete=0 and PalletNo='{palletNo}'";
			int insertCount = _db.Ado.ExecuteCommand(sqlStr);
			if (insertCount > 0)

			// 码垛工位托盘号
			string palletNo = checkTaskMedel.PalletNo;

			// 是否演示模式
			if (PLCTaskAction.boDemo)
			{
			string sqlStr2 = $"delete from WCSBoxInfo where IsDelete=0 and PalletNo='{palletNo}'";
			_db.Ado.ExecuteCommand(sqlStr2);
			}
			// 向WMS申请巷道
			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			string strMsg = http.BindRequestRoadWay(checkTaskMedel.OrderNo,palletNo, checkTaskMedel.BoxCount.ToDecimal(),"0", checkTaskMedel.SkuNo, checkTaskMedel.LotNo, "","", boxInfoList,
			modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo);
			if (!strMsg.Contains("-1"))
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0};原因{1}", modDevice.StationNum, strMsg));
			break;
			}
			else
			{
			// 获取入库任务信息
			var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && m.Status == TaskStatusEnum.Wait);
			if (taskModel != null)
			// 直接箱wms申请巷道
			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			string strMsg = http.RequestRoadWay(palletNo, modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo);
			if (strMsg.Contains("-1"))
			{
			// 获取入库取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");
			Log.Error(string.Format("申请巷道失败，码垛工位{0};原因{1}", modDevice.StationNum, strMsg));
			break;
			}
			else
			{
			// 获取入库任务信息
			var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && (m.Status == TaskStatusEnum.Wait \|\| m.Status == TaskStatusEnum.Doing));
			if (taskModel != null)
			{
			// 获取入库取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");

			var listResult = new List<Result>();
			// 写入托盘输送线码垛工位目的工位、任务号，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 目标工位
			var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务号" && s.IsDelete == false);
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
			var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务类型" && s.IsDelete == false);
			var taskTypeStr = (int)taskModel.TaskType;
			listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
			var listResult = new List<Result>();

			if (listResult.All(s => s.IsSucceed))
			// 写入托盘输送线码垛工位目的工位、任务号，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 目标工位
			var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务号" && s.IsDelete == false);
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
			var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务类型" && s.IsDelete == false);
			var taskTypeStr = (int)taskModel.TaskType;
			listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));

			if (listResult.All(s => s.IsSucceed))
			{
			// 写入组托回复流程字
			var retVal1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			if (retVal1.IsSucceed)
			{
			// 将入库任务由正在执行改为正在执行
			taskModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(taskModel).ExecuteCommand();

			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令50：申请巷道成功",
			PalletNo = palletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = modDevice.StationNum,
			EndLocat = strMsg,
			};
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			}

			//// 写入托盘输送线码垛工位目的工位，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			//var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue);
			//if (retVal.IsSucceed)
			//{
			// // 写入码垛交互-组托回复流程字
			// retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");

			// // 将入库任务由正在执行改为正在执行
			// taskModel.Status = TaskStatusEnum.Doing;
			// _db.Updateable(taskModel).ExecuteCommand();
			//}
			}
			}
			}
			else
			{
			// 根据托盘号，将组托信息插入boxinfolog表并删除boxinfo表数据
			var boxInfoList = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToList();
			if (boxInfoList.Count <= 0)
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0}，箱码信息不存在", modDevice.StationNum));

			// 写入交互工位目标地址
			var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
			if (retVal.IsSucceed)
			{
			// 写入组托回复流程字
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			if (retVal.IsSucceed)
			{
			// 将入库任务由正在执行改为正在执行
			taskModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(taskModel).ExecuteCommand();
			retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			}
			break;
			}
			string sqlStr = $"insert into WCSBoxInfoLog select * from WCSBoxInfo where IsDelete=0 and PalletNo='{palletNo}'";
			int insertCount = _db.Ado.ExecuteCommand(sqlStr);
			if (insertCount > 0)
			{
			// 组托成功后将信息存到log表
			string sqlStr2 = $"delete from WCSBoxInfoLog where IsDelete=0 and PalletNo='{palletNo}'";
			_db.Ado.ExecuteCommand(sqlStr2);
			}
			// 向WMS申请巷道
			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			string strMsg = http.BindRequestRoadWay(checkTaskMedel.OrderNo,palletNo, checkTaskMedel.BoxCount.ToDecimal(),"0", checkTaskMedel.SkuNo, checkTaskMedel.LotNo, "","", boxInfoList,
			modDevice.StationNum, "1", "2", ref EndLocate, ref TaskNo);
			if (strMsg.Contains("-1"))
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0};原因{1}", modDevice.StationNum, strMsg));
			break;
			}
			else
			{
			// 获取入库任务信息
			var taskModel = _db.Queryable<WcsTask>().First(m => m.TaskNo == TaskNo && m.IsDelete == false && m.Status == TaskStatusEnum.Wait);
			if (taskModel != null)
			{
			// 获取入库取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");

			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			var listResult = new List<Result>();
			// 写入托盘输送线码垛工位目的工位、任务号，写入交互流程组托成功执行入库{若需要可以写入任务号等等其他信息}
			listResult.Add(plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, endLocatVlue)); // 目标工位
			var modPosTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务号" && s.IsDelete == false);
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, numModel.DbNumber, modPosTask.PlcPos, TaskNo));
			var modPosTaskType = PLCTaskAction.plcPositions.First(s => s.DeviceId == numModel.Id && s.Text == "任务类型" && s.IsDelete == false);
			var taskTypeStr = (int)taskModel.TaskType;
			listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, numModel.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));

			if (listResult.All(s => s.IsSucceed))
			{
			// 写入组托回复流程字
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			if (retVal.IsSucceed)
			{
			TaskNo = TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令50：申请巷道成功",
			PalletNo = palletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = modDevice.StationNum,
			EndLocat = strMsg,
			};
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			// 将入库任务由正在执行改为正在执行
			taskModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(taskModel).ExecuteCommand();

			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令50：申请巷道成功",
			PalletNo = palletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = modDevice.StationNum,
			EndLocat = strMsg,
			};
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			}
			}
			}
			@@ -1963,7 +2091,81 @@
			LedDll Led = new LedDll();
			Led.LEDstr(ip, top, content, foot);
			}
			catch { }
			catch (Exception ex)
			{
			Log.Error(ex.Message);
			}
			}
			/// <summary>
			/// LED信息展示
			/// </summary>
			/// <param name="ip"></param>
			/// <param name="text"></param>
			private static void LedDisplay(string ip,string text)
			{
			try
			{
			LedDll Led = new LedDll();
			Led.ConsoleLeds(ip, text);
			// 设置实例
			//Led.ConsoleLeds("10.18.51.238", $"任务类型:{TaskTypeEnum.Move.GetDescription()}\n\n任务号:TK2024102100001\n托盘号:LN000145\n\n起始位:033\n目标位:R01-02010102");
			}
			catch (Exception ex)
			{
			Log.Error(ex.Message);
			}
			}

			/// <summary>
			/// 自动结批并解绑分道
			/// </summary>
			/// <param name="lotNo">批次号</param>
			/// <param name="plcConn">Plc连接</param>
			/// <param name="status">是否解绑分道 0：解绑 1：绑定</param>
			private static void AutoEndLot(string lotNo,PLCUtil plcConn,string status)
			{
			try
			{
			if (string.IsNullOrWhiteSpace(lotNo))
			{
			Console.WriteLine("批次号为nul");
			}
			var checkTaskList = _db.Queryable<WcsCheckTask>().Where(w => w.LotNo == lotNo && w.Status == "1").ToList();
			if (checkTaskList.Count <= 0)
			{
			Console.WriteLine("未找到分道绑定信息");
			}
			foreach (var item in checkTaskList)
			{
			#region#给PLC写入结批批次号
			// 写入结批信号
			var ret = plcConn.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "1");
			// 分道解绑，抓箱品种写入0
			var ret1 = plcConn.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PlcPos, "0");
			if (ret.IsSucceed)
			{
			//写入流程字成功后更新分拣任务 liudl 最后一托盘申请完入库才可清空
			//item.OrderNo = "";
			//item.TaskNo = "";
			//item.LotNo = "";
			//item.SkuNo = "";
			//item.SkuName = "";
			//item.BoxType = "";
			//item.Qty = 0;
			item.PZNo = "";
			item.Status = status; // 绑定分道 0：解绑 1：绑定

			//更新分拣任务
			_db.Updateable(item).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
			}
			#endregion
			}
			}
			catch (Exception ex)
			{
			Log.Error(ex.Message);
			throw;
			}
			}

			private static void Test(WcsDeviceDto modDevice)