WCSNet6.git - Gitblit

			@@ -10,6 +10,7 @@
			using System;
			using System.Data;
			using System.Reflection.Emit;
			using WCS.Application.Entity;
			using WCS.Application.Util;

			namespace WCS.Application;
			@@ -26,16 +27,16 @@
			switch (mod.Type)
			{
			case PLCTypeEnum.StackingMachine:
			StackingMachine(mod);
			StackingMachine(mod); // 跺机
			break;
			case PLCTypeEnum.ConveyorLine:
			ConveyorLine(mod);
			ConveyorLine(mod); // 托盘输送线
			break;
			case PLCTypeEnum.AGV:
			AGV(mod);
			AGV(mod); // AGV调度
			break;
			case PLCTypeEnum.PalletMachine:
			PalletMachine(mod);
			case PLCTypeEnum.RobotPalletizer:
			RobotPalletizer(mod); // 码垛机器人
			break;
			case PLCTypeEnum.StackingRobot:
			PalletMachine(mod);
			@@ -223,13 +224,13 @@
			if (startStationRes.IsSucceed)
			{
			// 根据工位号获取对应的输送线IP
			var plcConveyorConn = PLCCommon.GetPlcIp(startStationVal.ToString());
			PLCUtil plcConveyorConn = PLCCommon.GetPlcIp(startStationVal.ToString());
			if (plcConveyorConn.Connected)
			{
			// 向取货工位写入流程字640 取货已完成
			var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == startStationVal.ToString()
			&& m.DeviceType == DeviceTypeEnum.Business && m.IsDelete == false);
			var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640");

			var modcTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = modTask.TaskNo,
			@@ -240,9 +241,21 @@
			StartLocat = startStationVal.ToString(),
			EndLocat = modTask.EndLocate // 目标储位地址
			};

			// 读取wcs控制字
			var (ress, va1s) = plcConveyorConn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos);
			if (va1s.ToString() == "630")
			{
			modcTaskMonitor.InteractiveMsg = string.Format("工位：{0},写入取货完成:640", startStationVal);
			// 插入交互日志
			_db.Insertable(modcTaskMonitor).ExecuteCommand();
			}

			var retc = plcConveyorConn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "640");

			if (!retc.IsSucceed)
			{
			modcTaskMonitor.InteractiveMsg = string.Format("输送线取货工位：{0},写入取货完成640失败等待在次写入", startStationVal);
			modcTaskMonitor.InteractiveMsg = string.Format("工位：{0},写入取货完成640失败", startStationVal);
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			//下发任务日志
			@@ -250,43 +263,56 @@
			break;
			}

			modcTaskMonitor.InteractiveMsg = string.Format("输送线取货工位：{0},写入取货完成640成功", startStationVal);
			// 插入交互日志
			_db.Insertable(modcTaskMonitor).ExecuteCommand();
			//下发任务日志
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}

			// 读取wcs控制字
			var (resss, va1ss) = plcConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos);
			if (va1ss.ToString() == "830")
			{
			modInsertTaskMonitor.InteractiveMsg = string.Format("工位：{0}跺机取货完成写入850", startStationVal);
			modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 目标储位地址
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			}

			// 写入流程控制字
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850");
			if (!ret.IsSucceed)
			{
			modInsertTaskMonitor.InteractiveMsg = string.Format("工位：{0}跺机取货完成写入850失败,等待再次写入。", startStationVal);
			modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 目标储位地址
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			break; // 写入失败跳出等待再次写入
			}

			modInsertTaskMonitor.InteractiveMsg = string.Format("输送线取货工位：{0}跺机取货完成850成功", startStationVal);
			modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 目标储位地址
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			//下发任务日志
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			}
			else if (modTask.TaskType == TaskTypeEnum.Out)
			{
			// 读取wcs控制字
			var (resss, va1ss) = plcConn.GetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos);
			if (va1ss.ToString() == "830")
			{
			// 记录任务明细
			modInsertTaskMonitor.InteractiveMsg = string.Format("储位地址：{0}取货完成写入850", modTask.StartLocate);
			modInsertTaskMonitor.EndLocat = endStation; // 放货工位
			}
			// 写入流程控制字
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "850");
			if (!ret.IsSucceed)
			{
			modInsertTaskMonitor.InteractiveMsg = string.Format("储位地址：{0}取货完成写入850失败,等待再次写入。", modTask.StartLocate);
			modInsertTaskMonitor.EndLocat = modTask.EndLocate; // 目标储位地址
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			break; // 写入失败跳出等待再次写入
			}

			// 记录任务明细
			modInsertTaskMonitor.InteractiveMsg = string.Format("储位地址：{0}取货完成", modTask.StartLocate);
			modInsertTaskMonitor.EndLocat = endStation; // 放货工位

			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			//下发任务日志
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
			}
			@@ -378,8 +404,7 @@
			}
			}
			// 根据任务号获取起始工位地址，根据起始工位地址获取LEDIP 推送到LED屏幕。
			var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == modTask.TaskNo);
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();

			// 插入交互日志
			_db.Insertable(modTaskMonitor).ExecuteCommand();
			@@ -453,6 +478,14 @@
			_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.StartLocate).Select(s => s.LedIP).First();

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

			break;
			}
			}
			@@ -817,7 +850,6 @@
			}
			}
			}


			/// <summary>
			/// 输送线业务处理
			@@ -1221,9 +1253,12 @@
			// 通知任务界面任务已存在更新请更新界面
			HubUtil.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());

			// led更新内容
			//DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and StationNum = '{EndLocat}'")[0];
			//LedDisplay(ConveyorsRow10["LedIP"].ToString(), "工位:" + EndLocat, "出库中 " + $"储位地址：{StartLocat}", "托盘号:" + PalletNo);
			// 根据任务号获取起始工位地址，根据起始工位地址获取LEDIP 推送到LED屏幕。
			var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == modInsertTaskMonitor.TaskNo);
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == taskInfo.StartLocate).Select(s => s.LedIP).First();

			// led显示内容
			LedDisplay(modDevice.LedIP, "到达工位:" + modDevice.StationNum, "出库完成 " + $"储位地址：{modInsertTaskMonitor.StartLocat}", "托盘号:" + palletVal);
			}
			// 反馈WMS出库完成
			//TaskReques taskReques = new TaskReques();
			@@ -1247,27 +1282,61 @@
			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);
			if (modTask == null)
			{
			Log.Error(string.Format("输送线440:未找到对应的任务。"));
			break;
			}
			// 改变任务状态
			modTask.Status = TaskStatusEnum.Complete;
			modTask.FinishDate = DateTime.Now;
			_db.Updateable(modTask).ExecuteCommand();
			HubUtil.PublicTask(modTask.Adapt<WcsTaskOutput>());
			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = taskVal,
			TaskNo = modTask.TaskNo,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令450：{modDevice.StationNum}拣选完成,托盘离开工位",
			PalletNo = palletVal,
			Status = TaskStatusEnum.Complete,
			StartLocat = starVal,
			StartLocat = starVal.ToString(),
			EndLocat = modDevice.StationNum,
			};
			if (modTask.Origin == "WMS")
			{
			// 反馈WMS
			var requestMode = new TaskRequestWMS()
			{
			TaskNo = modTask.TaskNo,
			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更新内容
			//DataRow ConveyorsRow10 = PlcInfoDt.Select($"Level = '2' and StationNum = '{EndLocat}'")[0];
			//LedDisplay(ConveyorsRow10["LedIP"].ToString(), "工位:" + EndLocat, "出库中 " + $"储位地址：{StartLocat}", "托盘号:" + PalletNo);
			// led显示内容
			modDevice.LedIP = _db.Queryable<WcsDevice>().Where(w => w.StationNum == modTask.StartLocate).Select(s => s.LedIP).First();
			LedDisplay(modDevice.LedIP, "工位:" + modTask.StartLocate, $"拣选完成，托盘离开工位", "托盘号:" + modTask.PalletNo);
			}
			#endregion
			}
			@@ -1293,7 +1362,143 @@
			/// <param name="modDevice"></param>
			private static void PalletMachine(WcsDeviceDto modDevice)
			{
			var plcConn = modDevice.PLCUtil;
			switch (modDevice.Value.ToString())
			{
			case "220":
			// 注释1
			{

			}
			break;
			case "230":
			// 注释2
			{

			}
			break;
			case "240":
			{

			}
			break;
			default: break;
			}
			}

			/// <summary>
			/// 码垛机器人业务处理
			/// </summary>
			/// <param name="modDevice"></param>
			private static void RobotPalletizer(WcsDeviceDto modDevice)
			{
			var plcConn = modDevice.PLCUtil;
			switch (modDevice.Value.ToString())
			{
			case "1":
			// 主扫申请分道 wcs写入2
			{

			var taskModel = "";
			// 判断是否演示模式
			if (PLCTaskAction.boDemo)
			{
			// 演示模式
			taskModel = "1";

			// 直接
			}
			else
			{
			// 通道号
			var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "通道号");

			// 读取plc箱码
			var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "箱码");
			var (res, boxNo) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modBoxNo.PlcPos);
			if (string.IsNullOrWhiteSpace(boxNo.ToString()))
			{
			// 箱码为null写入剔除通道号
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			Log.Error("箱码为null进行剔除");
			break;
			}
			}
			}
			else
			{
			// 根据箱码获取箱内信息
			string boxNoVal = boxNo.ToString();
			var boxInfo = _db.Queryable<WcsBoxInfo>().First(w => w.IsDelete == false && w.BoxNo == boxNoVal && string.IsNullOrEmpty(w.PalletNo));
			if (boxInfo == null)
			{
			// 箱信息为null写入剔除通道号
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			Log.Error("箱码为null或已绑定托盘，进行剔除。");
			break;
			}
			}
			}
			// 根据箱内品种号获取码躲绑定工位及对应的分道号
			var checkTaskInfo = _db.Queryable<WcsCheckTask>().First(w => w.SkuNo == boxInfo.SkuNo && w.SkuName == boxInfo.SkuName && w.LotNo == boxInfo.LotNo);
			if (checkTaskInfo == null)
			{
			// 绑定信息为null写入剔除通道号
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			Log.Error("箱码未绑定分拣任务，进行剔除。");
			break;
			}
			}
			}
			else
			{
			// 与plc交互写入分道号和流程控制字
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, checkTaskInfo.RoboatNo);
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			break;
			}
			}
			}
			}
			}
			}
			break;
			case "230":
			// 注释2
			{

			}
			break;
			case "240":
			{

			}
			break;
			default: break;
			}
			}

			/// <summary>