JC34WCS.git - Gitblit

			@@ -1,8 +1,11 @@
			using Admin.NET.Core.Service;
			using AngleSharp.Io;
			using COSXML.Network;
			using DocumentFormat.OpenXml.Bibliography;
			using DocumentFormat.OpenXml.Drawing;
			using DocumentFormat.OpenXml.Spreadsheet;
			using DocumentFormat.OpenXml.Wordprocessing;
			using Elastic.Clients.Elasticsearch.Snapshot;
			using Furion.Logging;
			using IoTClient;
			using NewLife.Reflection;
			@@ -25,6 +28,7 @@
			try
			{
			var mod = sender as WcsDeviceDto;

			//Console.WriteLine($"{mod.Text}值为" + mod.Value);
			switch (mod.Type)
			{
			@@ -70,7 +74,7 @@
			TaskNo = _taskService.GetTaskCode(),
			TaskType = TaskTypeEnum.Move,
			Type = PLCTypeEnum.AGV,
			StartLocate = AGVStorageUtil.GetPalletOutStorage(),
			StartLocate = "",
			EndLocate = AGVStaionEnum.D1.ToString(),
			PalletNo = "",
			Status = TaskStatusEnum.Wait,
			@@ -190,6 +194,7 @@
			{
			TaskNo = carTask.TaskNo,
			PlcName = modDevice.Text,
			Status = TaskStatusEnum.Complete,
			InteractiveMsg = $"穿梭车反馈任务完成"
			};
			_db.Insertable(taskMonitor).ExecuteCommand();
			@@ -202,10 +207,88 @@
			//总任务下没有其他未执行小车的任务变更总任务信息
			if (carTaskNext == null && modFinshTask != null && modFinshTask.Status != TaskStatusEnum.Complete)
			{
			modFinshTask.Status = TaskStatusEnum.Complete;
			modFinshTask.FinishDate = DateTime.Now;
			_db.Updateable(modFinshTask).ExecuteCommand();

			if (modFinshTask.TaskType == TaskTypeEnum.Out)
			{
			//#region 任务变更成输送线任务
			//modFinshTask.Status = TaskStatusEnum.Wait;
			//modFinshTask.Type = PLCTypeEnum.ConveyorLine;
			//_db.Updateable(modFinshTask).ExecuteCommand();

			//#endregion

			#region 输送线写入PLC 740

			var text = "";
			var devStation = ""; //工位
			var endLocate = modFinshTask.EndRoadway;
			var carcon = new carConverModel();
			if ( carcon.conveyorBei.Keys.Contains(endLocate))
			{
			text = "输送线北";
			devStation = carcon.conveyorBei[endLocate];
			}
			else if (carcon.conveyorNan.Keys.Contains(endLocate))
			{
			text = "输送线南";
			devStation = carcon.conveyorNan[endLocate];
			}
			if (text != "")
			{
			var modPlc = PLCTaskAction.plcs.FirstOrDefault(s => s.Text == text);
			var modConn = new PLCUtil(modPlc);

			var modDeviceConver = PLCTaskAction.plcDevices.First(s => s.StationNum == devStation);
			var (plcResult, palletVal) = modConn.GetPlcDBValue(modDeviceConver.PosType, modDeviceConver.DbNumber, modDeviceConver.PlcPos);
			if (!plcResult.IsSucceed \|\| Convert.ToInt32(palletVal) != 730)
			{
			modConn.Close();
			return;//放货工位没有读取成功或不是空闲
			}

			var plcResult2 = modConn.SetPlcDBValue(modDeviceConver.PosType, modDeviceConver.DbNumber, modDeviceConver.WcsPos, "740");
			if (!plcResult.IsSucceed)
			{
			modConn.Close();
			return;
			}
			//添加任务明细
			var taskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modFinshTask.TaskNo,
			PlcName = modDevice.Text,
			Status = TaskStatusEnum.Complete,
			InteractiveMsg = $"写入指令740：托盘到达{modFinshTask.EndRoadway}"
			};
			_db.Insertable(taskMonitor).ExecuteCommand();
			modConn.Close();
			}


			#endregion
			}
			else
			{
			modFinshTask.Status = TaskStatusEnum.Complete;
			modFinshTask.FinishDate = DateTime.Now;
			_db.Updateable(modFinshTask).ExecuteCommand();
			//反馈WMS系统任务完成
			if (modFinshTask.Origin == "WMS")
			{
			HttpService httpService = new HttpService();
			var requestMode = new TaskRequestWMS()
			{
			TaskNo = modFinshTask.TaskNo,
			PalletNo = modFinshTask.PalletNo,
			TaskType = ((int)modFinshTask.TaskType).ToString(),
			TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
			};
			var modResponseTask = httpService.RequestTask(requestMode).Result;
			modFinshTask.IsSuccess = TaskSuccessEnum.Success;
			_db.Updateable(modFinshTask).ExecuteCommand();
			HubUtil.PublicTask(modFinshTask.Adapt<WcsTaskOutput>());
			}
			}

			//判断任务是否充电任务,下发开始充电命令
			if (modFinshTask.Levels == 888)
			{
			@@ -214,20 +297,7 @@
			plcConn.SetDBValue(modCd.PosType, modCd.PlcPos.ToString(), "2");
			}

			//反馈WMS系统任务完成
			//HttpService httpService = new HttpService();
			//var requestMode = new TaskRequestWMS()
			//{
			// TaskNo = modFinshTask.TaskNo,
			// PalletNo = modFinshTask.PalletNo,
			// TaskType = ((int)modFinshTask.TaskType).ToString(),
			// TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
			//};
			//var modResponseTask = httpService.RequestTask(requestMode).Result;
			//modFinshTask.IsSuccess = TaskSuccessEnum.Success;
			//_db.Updateable(modFinshTask).ExecuteCommand();
			HubUtil.PublicTask(modFinshTask.Adapt<WcsTaskOutput>());


			}
			}
			}
			@@ -268,11 +338,11 @@
			var endLocateCar = "";
			if (valuez == 1)
			{
			endLocateCar = "210401";
			endLocateCar = "011201";
			}
			else if (valuez == 2)
			{
			endLocateCar = "210402"; //011202
			endLocateCar = "011202"; //
			}
			else
			{
			@@ -281,22 +351,26 @@
			var getCdTask = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.Levels == 888 && m.EndLocate == endLocateCar && m.Type == PLCTypeEnum.ShuttleCar && m.Status <= TaskStatusEnum.Doing);
			if (getCdTask == null)
			{
			//添加小车充电位置
			WcsTask modCarTask = new WcsTask()
			var (resultDlLock, valueDlLock) = plcConn.GetDBValue(modDevice.PosType, modDevice.PlcPos);
			if (resultDlLock.IsSucceed && valueDlLock!=3 && carXYZ != endLocateCar)
			{
			TaskNo = _taskService.GetTaskCode(),
			TaskType = TaskTypeEnum.Move,
			Type = PLCTypeEnum.ShuttleCar,
			StartLocate = carXYZ,
			EndLocate = endLocateCar,
			PalletNo = "",
			Status = TaskStatusEnum.Wait,
			Levels = 888, //充电等级优先任务等级
			Origin = "WCS",
			CarIp = modDevice.PlcIdIP
			};
			_db.Insertable(modCarTask).ExecuteCommand();
			HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>());
			//添加小车充电位置
			WcsTask modCarTask = new WcsTask()
			{
			TaskNo = _taskService.GetTaskCode(),
			TaskType = TaskTypeEnum.Move,
			Type = PLCTypeEnum.ShuttleCar,
			StartLocate = carXYZ,
			EndLocate = endLocateCar,
			PalletNo = "",
			Status = TaskStatusEnum.Wait,
			Levels = 888, //充电等级优先任务等级
			Origin = "WCS",
			CarIp = modDevice.PlcIdIP
			};
			_db.Insertable(modCarTask).ExecuteCommand();
			HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>());
			}
			}

			}
			@@ -331,11 +405,11 @@
			var endLocateCar = "";
			if (valuez == 1)
			{
			endLocateCar = "210401";
			endLocateCar = "011201";
			}
			else if (valuez == 2)
			{
			endLocateCar = "210402";
			endLocateCar = "011202";
			}
			else
			{
			@@ -344,22 +418,27 @@
			var getCdTask = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.Levels == 888 && m.EndLocate == endLocateCar && m.Type == PLCTypeEnum.ShuttleCar && m.Status <= TaskStatusEnum.Doing);
			if (getCdTask == null)
			{
			//添加小车充电位置
			WcsTask modCarTask = new WcsTask()
			var (resultDlLock, valueDlLock) = plcConn.GetDBValue(modDevice.PosType, modDevice.PlcPos);
			if (resultDlLock.IsSucceed && valueDlLock != 3 && carXYZ != endLocateCar)
			{
			TaskNo = _taskService.GetTaskCode(),
			TaskType = TaskTypeEnum.Move,
			Type = PLCTypeEnum.ShuttleCar,
			StartLocate = carXYZ,
			EndLocate = endLocateCar,
			PalletNo = "",
			Status = TaskStatusEnum.Wait,
			Levels = 888, //充电等级优先任务等级
			Origin = "WCS",
			CarIp = modDevice.PlcIdIP
			};
			_db.Insertable(modCarTask).ExecuteCommand();
			HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>());
			//添加小车充电位置
			WcsTask modCarTask = new WcsTask()
			{
			TaskNo = _taskService.GetTaskCode(),
			TaskType = TaskTypeEnum.Move,
			Type = PLCTypeEnum.ShuttleCar,
			StartLocate = carXYZ,
			EndLocate = endLocateCar,
			PalletNo = "",
			Status = TaskStatusEnum.Wait,
			Levels = 888, //充电等级优先任务等级
			Origin = "WCS",
			CarIp = modDevice.PlcIdIP
			};
			_db.Insertable(modCarTask).ExecuteCommand();
			HubUtil.PublicTask(modCarTask.Adapt<WcsTaskOutput>());
			}

			}

			}
			@@ -465,6 +544,76 @@
			}
			if (listResult.All(s => s.IsSucceed))
			{
			if (modTask.TaskType == TaskTypeEnum.Out)
			{
			#region 输送线写入PLC 730

			var text = "";
			var devStation = "";
			var endLocate = modTask.EndRoadway;
			var carcon = new carConverModel();
			if (carcon.conveyorBei.Keys.Contains(endLocate))
			{
			text = "输送线北";
			devStation = carcon.conveyorBei[endLocate];
			}
			else if (carcon.conveyorNan.Keys.Contains(endLocate))
			{
			text = "输送线南";
			devStation = carcon.conveyorNan[endLocate];
			}
			if (text != "")
			{
			var modPlc = PLCTaskAction.plcs.FirstOrDefault(s => s.Text == text);
			var modConn = new PLCUtil(modPlc);

			var modDeviceConver = PLCTaskAction.plcDevices.First(s => s.StationNum == devStation);
			var (plcResult, palletVal) = modConn.GetPlcDBValue(modDeviceConver.PosType, modDeviceConver.DbNumber, modDeviceConver.PlcPos);
			if (!plcResult.IsSucceed \|\| Convert.ToInt32(palletVal) != 720)
			{
			modConn.Close();
			return;//放货工位没有读取成功或不是空闲
			}
			var listResultcon = new List<Result>();

			//任务号与托盘条码
			var modPosConverTask = PLCTaskAction.plcPositions.First(s => s.DeviceId == modDeviceConver.Id && s.Text == "任务号");
			listResultcon.Add(modConn.SetPlcDBValueRepeat(modPosConverTask.PosType, modDeviceConver.DbNumber, modPosConverTask.PlcPos, modTask.TaskId.ToString()));
			var modPosConverPallet = PLCTaskAction.plcPositions.First(s => s.DeviceId == modDeviceConver.Id && s.Text == "托盘条码");
			listResultcon.Add(modConn.SetPlcDBValueRepeat(modPosConverPallet.PosType, modDeviceConver.DbNumber, modPosConverPallet.PlcPos, modTask.PalletNo.ToString()));

			// 起始工位、目的工位
			var modPosConverStrLocat = PLCTaskAction.plcPositions.FirstOrDefault(s => s.DeviceId == modDeviceConver.Id && s.Text == "起始工位");
			listResultcon.Add(modConn.SetPlcDBValueRepeat(modPosConverStrLocat.PosType, modDeviceConver.DbNumber, modPosConverStrLocat.PlcPos, modDeviceConver.StationNum));
			var modPosConverEndLocat = PLCTaskAction.plcPositions.FirstOrDefault(s => s.DeviceId == modDeviceConver.Id && s.Text == "目的工位");
			listResultcon.Add(modConn.SetPlcDBValueRepeat(modPosConverEndLocat.PosType, modDeviceConver.DbNumber, modPosConverEndLocat.PlcPos, modTask.EndLocate));

			if (listResultcon.All(s => s.IsSucceed))
			{
			var plcResult2 = modConn.SetPlcDBValue(modDeviceConver.PosType, modDeviceConver.DbNumber, modDeviceConver.WcsPos, "730");
			if (!plcResult.IsSucceed)
			{
			modConn.Close();
			return;
			}
			//添加任务明细
			var taskMonitor2 = new WcsTaskMonitor()
			{
			TaskNo = carTaskNext.TaskNo,
			PlcName = modDevice.Text,
			Status = TaskStatusEnum.Complete,
			InteractiveMsg = $"写入指令730：工位是{modDeviceConver.StationNum}"
			};
			_db.Insertable(taskMonitor2).ExecuteCommand();
			}

			modConn.Close();
			}


			#endregion
			}

			var modStart = modDevice.listStation.FirstOrDefault(s => s.Text == "启动命令");
			var result = plcConn.SetDBValue(modStart.PosType, modStart.PlcPos, "1");
			if (result.IsSucceed)
			@@ -472,6 +621,9 @@
			carTaskNext.Status = TaskStatusEnum.Doing;
			carTaskNext.CarTaskNo = carTaskNo;
			_db.Updateable(carTaskNext).ExecuteCommand();



			//清除小车空闲时间
			var carTimeClear = _db.Queryable<WcsCarTime>().First(m=>m.IsDelete == false && m.CarIp == modDevice.PlcIdIP);
			if (carTimeClear!= null)
			@@ -484,6 +636,7 @@
			{
			TaskNo = carTaskNext.TaskNo,
			PlcName = modDevice.Text,
			Status = TaskStatusEnum.Complete,
			InteractiveMsg = $"向穿梭车下发任务{carTaskNext.TaskNo}"
			};
			_db.Insertable(taskMonitor).ExecuteCommand();
			@@ -558,14 +711,38 @@
			var ledText = "";
			switch (modDevice.Value.ToString())
			{
			case "120": //空闲，AGV可放货
			{
			var task = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.Status == TaskStatusEnum.Doing && m.IsComple == "1");
			if (task != null)
			{
			//没有出库业务
			var res = new HttpService().GenAgvContinueTask(task.TaskNo).Result;
			if (res.code == "0")
			{
			var modTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = task.TaskNo,
			PlcId = modDevice.modPlc.Id,
			PlcName = modDevice.modPlc.IP,
			InteractiveMsg = "向AGV小车下发继续执行任务"
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();

			//下发任务日志
			HubUtil.PublicTask(task.Adapt<WcsTaskOutput>());
			HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			}
			}
			break;
			case "320":
			{
			// 申请密集库组
			string strMsg = "";
			string taskModel = "";

			// 获取工位托盘码信息
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘条码");
			var (res, palletVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (!res.IsSucceed)
			{
			@@ -586,7 +763,7 @@
			}

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

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

			var http = new HttpService();
			string TaskNo = "", EndLocate = "";
			strMsg = http.RequestRoadWay(palletVal, modDevice.StationNum, taskModel, "1", ref EndLocate, ref TaskNo);
			strMsg = http.RequestRoadWay(palletVal, modDevice.StationNum, ref EndLocate, ref TaskNo);
			if (!strMsg.Contains("-1"))
			{
			// 根据任务号获取起始工位地址，根据起始工位地址获取LEDIP 推送到LED屏幕。
			@@ -682,7 +859,7 @@
			}

			// 写入输送线退回指令
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum);
			var ret = plcConn.SetPlcDBValueRepeat(modDevice.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, modDevice.StationNum);
			if (ret.IsSucceed)
			{
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350");
			@@ -693,7 +870,7 @@
			case "330":
			{
			// 获取工位托盘码信息
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘条码");
			var (res, palletVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (!res.IsSucceed)
			{
			@@ -719,7 +896,7 @@
			}

			// 获取四项车取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(modTask.EndRoadway, modDevice.StationNum);
			string endLocatVlue = PLCCommon.RoadwayToStationNum(modTask.EndRoadway, modDevice.StationNum.PadLeft(3,'0'));



			@@ -727,17 +904,17 @@
			var listResult = new List<Result>();
			// 任务号、任务类型、托盘号
			var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "任务号");
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskId.ToString()));
			listResult.Add(plcConn.SetPlcDBValueRepeat(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskId.ToString()));
			var modPosTaskType = modDevice.listStation.FirstOrDefault(s => s.Text == "任务类型");
			var taskTypeStr = (int)modTask.TaskType;
			listResult.Add(plcConn.SetPlcDBValue(modPosTaskType.PosType, modDevice.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
			var modPosPalletNo = modDevice.listStation.FirstOrDefault(s => s.Text == "托盘码");
			listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
			listResult.Add(plcConn.SetPlcDBValueRepeat(modPosTaskType.PosType, modDevice.DbNumber, modPosTaskType.PlcPos, taskTypeStr.ToString()));
			var modPosPalletNo = modDevice.listStation.FirstOrDefault(s => s.Text == "托盘条码");
			listResult.Add(plcConn.SetPlcDBValueRepeat(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
			// 起始工位、目的工位
			var modPosStrLocat = modDevice.listStation.FirstOrDefault(s => s.Text == "起始工位");
			listResult.Add(plcConn.SetPlcDBValue(modPosStrLocat.PosType, modDevice.DbNumber, modPosStrLocat.PlcPos, modDevice.StationNum));
			listResult.Add(plcConn.SetPlcDBValueRepeat(modPosStrLocat.PosType, modDevice.DbNumber, modPosStrLocat.PlcPos, modDevice.StationNum));
			var modPosEndLocat = modDevice.listStation.FirstOrDefault(s => s.Text == "目的工位");
			listResult.Add(plcConn.SetPlcDBValue(modPosEndLocat.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, endLocatVlue));
			listResult.Add(plcConn.SetPlcDBValueRepeat(modPosEndLocat.PosType, modDevice.DbNumber, modPosEndLocat.PlcPos, endLocatVlue));


			if (listResult.All(s => s.IsSucceed))
			@@ -782,25 +959,25 @@
			{
			// 申请储位更新入库任务(储位地址) 630
			var strMsg = "";
			var taskModel = "";

			//// 根据工位号获取巷道号
			//var roadway = PLCCommon.GetRoadwayByStation(modDevice.StationNum);
			//if (roadway == "")
			//{
			// break;
			//}
			// 获取工位任务号信息
			var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "任务号");
			var (resTask, taskVal) = plcConn.GetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos);
			if (!resTask.IsSucceed)
			{
			break;
			}
			// 获取工位托盘码信息
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘条码");
			var (res, palletVal) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (!res.IsSucceed)
			{
			break;
			}
			var http = new HttpService();

			string TaskNo = "";
			// 向WMS申请储位信息
			strMsg = http.RequestLocate(palletVal, modDevice.StationNum, taskModel, "roadway", ref TaskNo);
			strMsg = new HttpService().RequestLocate(palletVal, taskVal,ref TaskNo);

			if (!strMsg.Contains("-1"))
			{
			@@ -1007,31 +1184,64 @@
			{
			var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "任务号");
			var (res, taskVal) = plcConn.GetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos);
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘条码");
			var (res2, palletVal) = plcConn.GetPlcDBValue(modPosPallet.PosType, modDevice.DbNumber, modPosPallet.PlcPos);
			var modPosStarStationNum = modDevice.listStation.FirstOrDefault(m => m.Text == "起始工位");
			var (res3, starVal) = plcConn.GetPlcDBValue(modPosStarStationNum.PosType, modDevice.DbNumber, modPosStarStationNum.PlcPos);

			int taskNoVal = Convert.ToInt32(taskVal);
			var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskId == taskNoVal && w.TaskType == TaskTypeEnum.Out);
			if (taskInfo == null)
			{
			Log.Error(string.Format("输送线430:未找到对应的任务。"));
			break;
			}
			// 改变任务状态
			taskInfo.Status = TaskStatusEnum.Complete;
			taskInfo.FinishDate = DateTime.Now;
			//modTask.Levels = 999;
			_db.Updateable(taskInfo).ExecuteCommand();
			HubUtil.PublicTask(taskInfo.Adapt<WcsTaskOutput>());
			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = taskVal,
			TaskNo = taskInfo.TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令430：托盘到达{modDevice.StationNum}工位",
			PalletNo = palletVal,
			Status = TaskStatusEnum.Complete,
			StartLocat = starVal,
			StartLocat = Convert.ToString(starVal),
			EndLocat = modDevice.StationNum,
			};

			if (taskInfo.Origin == "WMS")
			{
			// 反馈WMS
			var requestMode = new TaskRequestWMS()
			{
			TaskNo = taskInfo.TaskNo,
			PalletNo = taskInfo.PalletNo,
			TaskType = ((int)taskInfo.TaskType).ToString(),
			TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
			};
			HttpService httpService = new HttpService();
			var modResponseTask = httpService.RequestTask(requestMode).Result;
			if (modResponseTask.StatusCode == 0)
			{
			modInsertTaskMonitor.InteractiveMsg += "，返回给WMS任务完成";
			}
			else
			{
			Log.Error(string.Format("任务反馈失败：StatusCode：{0};Msg：{1}", modResponseTask.StatusCode, modResponseTask.Msg));
			}
			}

			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();

			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());

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

			// led显示内容
			@@ -1057,78 +1267,45 @@
			case "440":
			{
			#region 拣选完成,托盘离开工位

			var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "任务号");
			var (res, taskVal) = plcConn.GetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos);
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘条码");
			var (res2, palletVal) = plcConn.GetPlcDBValue(modPosPallet.PosType, modDevice.DbNumber, modPosPallet.PlcPos);
			var modPosStarStationNum = modDevice.listStation.FirstOrDefault(m => m.Text == "起始工位");
			var (res3, starVal) = plcConn.GetPlcDBValue(modPosStarStationNum.PosType, modDevice.DbNumber, modPosStarStationNum.PlcPos);

			// 写入450
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "450");
			if (ret.IsSucceed)
			{
			var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "任务号");
			var (res, taskVal) = plcConn.GetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos);
			var modPosPallet = modDevice.listStation.FirstOrDefault(m => m.Text == "托盘码");
			var (res2, palletVal) = plcConn.GetPlcDBValue(modPosPallet.PosType, modDevice.DbNumber, modPosPallet.PlcPos);
			var modPosStarStationNum = modDevice.listStation.FirstOrDefault(m => m.Text == "起始工位");
			var (res3, starVal) = plcConn.GetPlcDBValue(modPosStarStationNum.PosType, modDevice.DbNumber, modPosStarStationNum.PlcPos);


			string tasknoVal = taskVal.ToString();
			var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
			int tasknoVal = Convert.ToInt32(taskVal);
			var modTask = _db.Queryable<WcsTask>().First(m => m.IsDelete == false && m.TaskId == tasknoVal);
			if (modTask == null)
			{
			Log.Error(string.Format("输送线440:未找到对应的任务。"));
			break;
			}
			// 改变任务状态
			modTask.Status = TaskStatusEnum.Complete;
			modTask.FinishDate = DateTime.Now;
			modTask.Levels = 999;
			_db.Updateable(modTask).ExecuteCommand();
			HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());

			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			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(),
			EndLocat = modDevice.StationNum,
			};
			if (modTask.Origin == "WMS")
			{
			// 反馈WMS
			var requestMode = new TaskRequestWMS()
			{
			TaskNo = modTask.TaskNo + modTask.EndLocate,
			PalletNo = modTask.PalletNo,
			TaskType = ((int)TaskTypeEnum.Out).ToString(),
			TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
			};
			HttpService httpService = new HttpService();
			var modResponseTask = httpService.RequestTask(requestMode).Result;
			if (modResponseTask.StatusCode == 0)
			{
			modInsertTaskMonitor.InteractiveMsg += "，返回给WMS任务完成";
			}
			else
			{
			Log.Error(string.Format("任务反馈失败：StatusCode：{0};Msg：{1}", modResponseTask.StatusCode, modResponseTask.Msg));
			}
			}

			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();

			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			// led显示内容
			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
			}
			@@ -1146,56 +1323,76 @@
			private static void AGV(WcsDeviceDto modDevice)
			{

			//这里找出来AGV待执行的任务、按照优先级下发一个任务给AGV
			var listTask = _db.Queryable<WcsTask>().Where(s => (s.Status == TaskStatusEnum.Wait \|\| s.Status == TaskStatusEnum.Doing) && s.Type == PLCTypeEnum.AGV).OrderBy(s => s.Levels).ToList();
			if (listTask.Count == 0)
			//这里找出来AGV待执行的任务、按照优先级、创建时间下发一个任务给AGV
			var modTask = _db.Queryable<WcsTask>().Where(s => s.Status == TaskStatusEnum.Wait && s.Type == PLCTypeEnum.AGV).OrderBy(s => new { s.Levels ,s.CreateTime}).First();
			if (modTask == null)
			{
			return;
			}

			foreach (var modTask in listTask)

			if (_db.Queryable<WcsTask>().Any(s => s.EndLocate == modTask.EndLocate && s.IsDelete == false && s.Status == TaskStatusEnum.Doing && s.Type == PLCTypeEnum.AGV ))
			{
			if (_db.Queryable<WcsTask>().Any(s => s.EndLocate == modTask.EndLocate && s.IsDelete == false && s.Status == TaskStatusEnum.Doing && s.Type == PLCTypeEnum.AGV ))
			{
			continue; // 有目的位置一致且正在执行的任务
			}

			//下发AGV任务
			AgvTaskInput input = new AgvTaskInput()
			{
			ReqCode = modTask.Id.ToString(),
			TaskCode = modTask.TaskNo,
			CtnrCode = modTask.PalletNo,
			PositionCodePath = new List<PositionCodePathItem>()
			{
			new PositionCodePathItem(){ PositionCode = modTask.StartLocate },
			new PositionCodePathItem(){ PositionCode = modTask.EndLocate }
			}
			};
			input.TaskTyp = "1" + modTask.StartLocate.Substring(0, 1) + modTask.EndLocate.Substring(0, 1);
			var response = new HttpService().GenAgvSchedulingTask(input).Result;
			if (response.code == "0")
			{
			AGVStatus = true;
			modTask.Status = TaskStatusEnum.Doing;
			_db.Updateable(modTask).ExecuteCommand();
			var modTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modTask.TaskNo,
			PlcId = modDevice.modPlc.Id,
			PlcName = modDevice.modPlc.IP,
			InteractiveMsg = "向AGV小车下发任务"
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();
			return; // 有目的位置一致且正在执行的任务
			}

			//下发任务日志
			HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());
			HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			Console.WriteLine(response.ToJson());
			//下发AGV任务
			var taskTypeModel = AGVStorageUtil.GetTaskModle(modTask.StartLocate, modTask.EndLocate,out string type1,out string type2, out string jiebo);
			if (string.IsNullOrWhiteSpace(taskTypeModel))
			{
			Console.WriteLine("获取AGV任务模板失败：请核实任务起始目标储位是否正确");
			return;
			}
			AgvTaskSend taskModel = new AgvTaskSend();
			taskModel.robotTaskCode = modTask.TaskNo;
			taskModel.taskType = taskTypeModel;
			if (jiebo == "")
			{
			taskModel.targetRoute = new List<targetRoute>()
			{
			new targetRoute(){seq = 0,type = type1,code = modTask.StartLocate},
			new targetRoute(){seq = 1,type = type2,code = modTask.EndLocate}
			};
			}
			else
			{
			taskModel.targetRoute = new List<targetRoute>()
			{
			new targetRoute(){seq = 0,type = type1,code = modTask.StartLocate},
			new targetRoute(){seq = 1,type = "ZONE",code = jiebo},
			new targetRoute(){seq = 2,type = type2,code = modTask.EndLocate}
			};
			}

			taskModel.extra = new extra()
			{
			carrierInfo = new List<carrierInfo>()
			{
			new carrierInfo(){ carrierType = "TP",carrierCode = modTask.PalletNo}
			}
			};
			var response = new HttpService().GenAgvSendTask(taskModel).Result;
			if (response.code == "SUCCESS")
			{
			modTask.Status = TaskStatusEnum.Doing;
			_db.Updateable(modTask).ExecuteCommand();
			var modTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modTask.TaskNo,
			PlcId = modDevice.modPlc.Id,
			PlcName = modDevice.modPlc.IP,
			InteractiveMsg = "向AGV小车下发任务"
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();

			//下发任务日志
			HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());
			HubUtil.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			//Console.WriteLine(response.ToJson());
			Thread.Sleep(3000);
			return;

			}

			/// <summary>
			@@ -1240,6 +1437,11 @@

			private static void Test(WcsDeviceDto modDevice)
			{

			var ledText = $"申请入库失败\n\n";
			ledText += $"托盘号:T2300001\n";
			ledText += $"入库任务已锁定，请解锁后重试!\n";
			LedDisplay("10.26.254.31", ledText);
			//卷帘门2申请打开
			//var result = modDevice.PLCUtil.SetPlcDBValue(PLCDataTypeEnum.Short, "DB1000", "1152", "10");
			//卷帘门2申请关闭
			@@ -1251,7 +1453,7 @@
			//var result = modDevice.PLCUtil.SetPlcDBValue(PLCDataTypeEnum.Short, "DB1000", "1154", "30");

			//C口AGV放托盘完成申请入库
			var result = modDevice.PLCUtil.SetPlcDBValue(PLCDataTypeEnum.Short, "DB1000", "1156", "100");
			//var result = modDevice.PLCUtil.SetPlcDBValue(PLCDataTypeEnum.Short, "DB1000", "1156", "100");

			////写死测试读string
			//var (res, val) = modDevice.PLCUtil.GetPlcDBValue(PLCDataTypeEnum.String, "DB100", "64");