WCSNet6.git - Gitblit

			@@ -147,7 +147,7 @@
			if (listResult.All(s => s.IsSucceed))
			{
			// 写入跺机任务下发完成
			plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "10");
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "10");

			// 将出库任务待执行改为正在执行
			_db.Updateable<WcsTask>()
			@@ -246,7 +246,7 @@
			var res = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, taskNo);
			if (!res.IsSucceed)
			break;
			res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "20");
			res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "20");
			if (!res.IsSucceed)
			break;
			// 根据跺机号确认取货工位
			@@ -304,7 +304,7 @@
			var res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, taskNo);
			if (!res.IsSucceed)
			break;
			res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "30");
			res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
			if (!res.IsSucceed)
			break;
			//修改任务状态
			@@ -354,77 +354,129 @@
			}
			break;
			case TaskTypeEnum.Out://出库
			// 从出库任务获取巷道号
			string num = ""; // 放货工位号
			if (modTask.StartRoadway == "R01")
			{
			num = "11"; //交互工位
			}
			else if (modTask.StartRoadway == "R02")
			{
			num = "7"; //交互工位
			}
			var modDevice2 = modDevice.listDevice.FirstOrDefault(s => s.StationNum == num);
			if (modDevice2 == null)
			{
			Log.Error($"【跺机】找不到工位{num}设备信息");
			break;
			}
			// 根据目标口获取目标工位
			string outCode = modTask.EndLocate.IsNullOrEmpty() ? "-1" : modTask.EndLocate;

			var listStation = _db.Queryable<WcsPosition>().Where(s => s.DeviceId == modDevice2.Id).ToList();
			//给PLC写入任务数据
			var listResult = new List<Result>();
			//任务号
			var modPosTask = listStation.FirstOrDefault(s => s.Text == "TaskNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
			//托盘号
			var modPosPalletNo = listStation.FirstOrDefault(s => s.Text == "PalletNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
			//起始工位
			var modPosLocatNo = listStation.FirstOrDefault(s => s.Text == "StartLocatNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, num));
			// 目标工位
			var modPosEndLocatNo = listStation.FirstOrDefault(s => s.Text == "EndLocatNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
			//全部写入成功
			if (listResult.All(s => s.IsSucceed))
			{
			// 写入工位wcs控制字
			var res = plcConn.SetPlcDBValue(modDevice2.PosType, modDevice2.DbNumber, modDevice2.WcsPos, "120");
			if (!res.IsSucceed)
			break;
			//写入plc任务号
			var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
			res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, modTask.TaskNo);
			if (!res.IsSucceed)
			break;
			//写入跺机wcs控制字流程30 返回垛机执行完成
			res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "30");
			if (!res.IsSucceed)
			break;
			//记录任务明细
			var modTaskMonitor = new WcsTaskMonitor()
			// 从出库任务获取巷道号
			string num = ""; // 放货工位号
			if (modTask.StartRoadway == "R01")
			{
			TaskNo = modTask.TaskNo,
			PlcId = modDevice2.PlcId,
			PlcName = modDevice2.Text,
			InteractiveMsg = $"写入指令：收到跺机放货完成；放货{num}工位===》{outCode}出库口",
			PalletNo = modTask.PalletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = num, //起始位置
			EndLocat = outCode, //目标工位
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();
			num = "11"; //交互工位
			}
			else if (modTask.StartRoadway == "R02")
			{
			num = "7"; //交互工位
			}
			var modDevice2 = modDevice.listDevice.FirstOrDefault(s => s.StationNum == num);
			if (modDevice2 == null)
			{
			Log.Error($"【跺机】找不到工位{num}设备信息");
			break;
			}
			// 根据目标口获取目标工位
			string outCode = modTask.EndLocate.IsNullOrEmpty() ? "-1" : modTask.EndLocate;

			//下发任务日志
			_taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			//todo:垛机出库不空跑
			var listStation = _db.Queryable<WcsPosition>().Where(s => s.DeviceId == modDevice2.Id).ToList();
			//给PLC写入任务数据
			var listResult = new List<Result>();
			//任务号
			var modPosTask = listStation.FirstOrDefault(s => s.Text == "TaskNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
			//托盘号
			var modPosPalletNo = listStation.FirstOrDefault(s => s.Text == "PalletNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
			//起始工位
			var modPosLocatNo = listStation.FirstOrDefault(s => s.Text == "StartLocatNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, num));
			// 目标工位
			var modPosEndLocatNo = listStation.FirstOrDefault(s => s.Text == "EndLocatNo");
			listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
			//全部写入成功
			if (listResult.All(s => s.IsSucceed))
			{
			// 写入工位wcs控制字
			var res = plcConn.SetPlcDBValue(modDevice2.PosType, modDevice2.DbNumber, modDevice2.WcsPos, "120");
			if (!res.IsSucceed)
			break;
			//写入plc任务号
			var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
			res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, modTask.TaskNo);
			if (!res.IsSucceed)
			break;
			//写入跺机wcs控制字流程30 返回垛机执行完成
			res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
			if (!res.IsSucceed)
			break;
			//记录任务明细
			var modTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modTask.TaskNo,
			PlcId = modDevice2.PlcId,
			PlcName = modDevice2.Text,
			InteractiveMsg = $"写入指令：收到跺机放货完成；放货{num}工位===》{outCode}出库口",
			PalletNo = modTask.PalletNo,
			Status = TaskStatusEnum.Complete,
			StartLocat = num, //起始位置
			EndLocat = outCode, //目标工位
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();

			//下发任务日志
			_taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			//todo:垛机出库不空跑
			}
			}

			break;
			case TaskTypeEnum.Move:
			{
			//移库任务
			var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
			// 写入plc任务号
			var res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, taskNo);
			if (!res.IsSucceed)
			break;
			//写入plc控制字
			res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
			if (!res.IsSucceed)
			break;
			modTask.Status = TaskStatusEnum.Complete;
			_db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
			var modTaskRequest = modTask.Adapt<TaskRequest>();
			HttpService httpService = new HttpService();
			var modResponseTask = httpService.RequestTask(modTaskRequest).Result;
			if (modResponseTask.StatusCode == "0")
			{
			//请求成功
			modTask.IsSuccess = TaskSuccessEnum.Success;
			_db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
			//todo:修改储位信息任务类型执行状态起始位置目标位置
			//

			//记录任务明细
			var modTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modTask.TaskNo,
			PlcId = modDevice.PlcId,
			PlcName = modDevice.Text,
			InteractiveMsg = "任务完成，返回给WMS任务完成",
			StartLocat = modTask.StartLocate,
			EndLocat = modTask.EndLocate,
			PalletNo = modTask.PalletNo,
			Status = TaskStatusEnum.Complete
			};
			_db.Insertable(modTaskMonitor).ExecuteCommand();
			//下发任务日志
			_taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			else
			{
			//请求失败
			modTask.IsSuccess = TaskSuccessEnum.Fail;
			modTask.Information = modResponseTask.Message;
			_db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
			}

			//todo:LED屏

			}

			break;
			default:
			@@ -432,6 +484,99 @@
			}
			}
			break;
			case "100":
			{
			//空取货异常
			var modPosPlcTask = modDevice.listStation.FirstOrDefault(s => s.Text == "PlcTaskNo");
			var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
			var (result, TaskNo) = plcConn.GetPlcDBValue(modPosPlcTask.PosType, modDevice.DbNumber, modPosPlcTask.PlcPos);
			if (!result.IsSucceed)
			break;
			string taskNo = Convert.ToString(TaskNo);
			var modTask = _db.Queryable<WcsTask>().First(s => s.TaskNo == taskNo && s.Status == TaskStatusEnum.Doing);
			if (modTask == null)
			{
			Log.Error($"【跺机】当前任务号不存在对应的任务，任务号：{modTask.TaskNo}");
			break;
			}
			var res = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, taskNo);
			if (!res.IsSucceed)
			break;
			res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "100");
			if (!res.IsSucceed)
			break;
			modTask.Status = TaskStatusEnum.Exception;
			_db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
			Log.Information($"【跺机】wcs任务变更空取异常，任务号：{modTask.TaskNo}");
			var modTaskRequest = modTask.Adapt<TaskRequest>();
			HttpService httpService = new HttpService();
			var modResponseTask = httpService.RequestEmptyException(modTaskRequest).Result;
			if (modResponseTask.StatusCode == "0")
			{
			//请求成功
			modTask.IsSuccess = TaskSuccessEnum.Success;
			_db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
			//下发任务日志
			_taskLogHubContext.Clients.All.PublicTask(modTask.Adapt<WcsTaskOutput>());
			}
			else
			{
			//请求失败
			modTask.IsSuccess = TaskSuccessEnum.Fail;
			modTask.Information = modResponseTask.Message;
			_db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
			}
			//todo:LED屏
			}
			break;
			case "101":
			{
			//满放货异常
			var modPosPlcTask = modDevice.listStation.FirstOrDefault(s => s.Text == "PlcTaskNo");
			var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
			var modPosPalletNo = modDevice.listStation.FirstOrDefault(s => s.Text == "PalletNo");
			var (result, TaskNo) = plcConn.GetPlcDBValue(modPosPlcTask.PosType, modDevice.DbNumber, modPosPlcTask.PlcPos);
			if (!result.IsSucceed)
			break;
			string taskNo = Convert.ToString(TaskNo);
			var modTask = _db.Queryable<WcsTask>().First(s => s.TaskNo == taskNo && s.Status == TaskStatusEnum.Doing);
			if (modTask == null)
			{
			Log.Error($"【跺机】当前任务号不存在对应的任务，任务号：{modTask.TaskNo}");
			break;
			}
			modTask.Status = TaskStatusEnum.Exception;
			_db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
			Log.Information($"【跺机】wcs任务变更满取异常，任务号：{modTask.TaskNo}");
			var modTaskRequest = modTask.Adapt<TaskRequest>();
			HttpService httpService = new HttpService();
			var modResponseTask = httpService.RequestEmptyException(modTaskRequest).Result;
			if (modResponseTask.StatusCode == "0")
			{
			//请求成功
			modTask.IsSuccess = TaskSuccessEnum.Success;
			_db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
			var modInsertTask = modResponseTask.TaskList;
			modInsertTask.TaskType = TaskTypeEnum.In;
			modInsertTask.Origin = "WMS";
			modInsertTask.StartLocate = modTask.StartLocate;
			modInsertTask.Levels = 1;
			_db.Insertable(modInsertTask);

			//下发任务日志
			_taskLogHubContext.Clients.All.PublicTask(modInsertTask.Adapt<WcsTaskOutput>());
			}
			else
			{
			//请求失败
			modTask.IsSuccess = TaskSuccessEnum.Fail;
			modTask.Information = modResponseTask.Message;
			_db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
			}
			//todo:LED屏

			}
			break;
			default:
			break;
			}