WCSNet6.git - Gitblit

			@@ -20,6 +20,7 @@
			namespace WCS.Application;
			public static class PLCService
			{
			private static readonly object OLock = new object();

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

			@@ -1705,7 +1706,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写入剔除通道号
			@@ -1868,181 +1869,184 @@
			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)
			{
			// 组托成功后将信息存到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)
			// 直接箱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>());
			}
			}
			}
			}
			@@ -2114,11 +2118,11 @@
			}

			/// <summary>
			/// 自动结批
			/// 自动结批并解绑分道
			/// </summary>
			/// <param name="lotNo">批次号</param>
			/// <param name="plcConn">Plc连接</param>
			/// <param name="status">是否解绑分道 0：解绑 1：绑定</param>
			/// <param name="status">是否解绑分道 0：解绑 1：绑定</param>
			private static void AutoEndLot(string lotNo,PLCUtil plcConn,string status)
			{
			try
			@@ -2135,7 +2139,10 @@
			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 最后一托盘申请完入库才可清空
			@@ -2146,7 +2153,7 @@
			//item.SkuName = "";
			//item.BoxType = "";
			//item.Qty = 0;
			//item.PZNo = "";
			item.PZNo = "";
			item.Status = status; // 绑定分道 0：解绑 1：绑定

			//更新分拣任务