WCSNet6.git - Gitblit

			@@ -16,6 +16,7 @@
			using System.Data;
			using System.Reflection.Emit;
			using WCS.Application.Entity;
			using WCS.Application.Service.WcsDevice.Dto;
			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;
			@@ -26,6 +27,8 @@
			private static readonly object OLock = new object();

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

			private static int fendao = 1;

			public static void OnChangeEvent(object sender, EventArgs e)
			{
			@@ -996,10 +999,11 @@
			string groupMsg = "";
			if (modDevice.StationNum == "27")
			{
			var Qty = plcConn.GetPlcDBValue(PLCDataTypeEnum.Int,"DB135.0").ToString();//获取叠托机叠托数量
			groupMsg = http.BindPlnInHouseWcs(Qty, palletVal);
			var (res2,Qty) = plcConn.GetPlcDBValue(PLCDataTypeEnum.Short,"DB135","0");//获取叠托机叠托数量

			groupMsg = http.BindPlnInHouseWcs(Qty.ToString(), palletVal);

			if (!groupMsg.Contains("-1"))
			if (groupMsg.Contains("-1"))
			{
			var (res350, palletVal350) = plcConn.GetPlcDBValue(PLCDataTypeEnum.String, modDevice.DbNumber, modPosPallet.PlcPos);
			if (res350.IsSucceed && palletVal350 != "350")
			@@ -1016,8 +1020,8 @@
			{
			plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "350");
			}
			break;
			}
			break;
			}
			string IsBale = "0";
			strMsg = http.RequestRoadWay(palletVal, modDevice.StationNum, taskModel, louCeng, ref EndLocate, ref TaskNo);
			@@ -1426,6 +1430,9 @@
			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();
			////string b = taskVal.GetValue();
			//string a = palletVal.ToString();
			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			@@ -1435,10 +1442,10 @@
			InteractiveMsg = $"写入指令430：托盘到达{modDevice.StationNum}工位",
			PalletNo = palletVal,
			Status = TaskStatusEnum.Complete,
			StartLocat = starVal,
			StartLocat = starVal.ToString(),
			EndLocat = modDevice.StationNum,
			};


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

			@@ -1482,7 +1489,7 @@
			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)
			@@ -1748,8 +1755,53 @@


			#endregion

			}
			break;
			#region 小车可放信号
			case "150":
			{ // 获取工位任务号信息
			var strMsg = "";
			var http = new HttpService();
			// 获取托盘任务号
			var modPosTask = modDevice.listStation.FirstOrDefault(m => m.Text == "任务号");
			var (res1, val) = plcConn.GetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos);
			if (res1.IsSucceed)
			{
			string tasknoVal = val.ToString();
			var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.IsDelete == false);
			if (modTask == null)
			{
			//读取成功后写入151
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "151");//收到可放信号后写入151
			if (ret.IsSucceed)
			{
			//回传WMS可放信号
			strMsg = http.RequesContinueAgv(val.ToString(), modDevice.StationNum);
			if (!strMsg.Contains("-1"))
			{
			// 插入任务明细
			var modInsertTaskMonitor = new WcsTaskMonitor()
			{
			TaskNo = tasknoVal,
			PlcId = modDevice.Id,
			PlcName = modDevice.Text,
			InteractiveMsg = $"写入指令151：{modDevice.StationNum}工位可接受AGV放货入库",
			Status = TaskStatusEnum.Complete,
			StartLocat = modDevice.StationNum
			};
			// 插入交互日志
			_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
			}
			}
			break;
			}
			}
			//

			}
			break;
			#endregion

			default: break;
			}
			@@ -1800,7 +1852,7 @@
			private static async void BoxConveyorLine(WcsDeviceDto modDevice)
			{
			var plcConn = modDevice.PLCUtil;

			//二楼主扫分道
			if (modDevice.DbNumber == "DB101")//&& modDevice.DbNumber == "DB102"&& (modDevice.DbNumber == "DB102"\|\|modDevice.PlcIdIP == "10.18.51.110")
			{
			// 主扫交互流程
			@@ -1810,15 +1862,26 @@
			// 主扫申请分道 wcs写入2
			{
			// 判断是否演示模式 true：演示模式 false:生产模式
			if (PLCTaskAction.boDemo)
			if (PLCTaskAction.boDemo)
			{
			// 通道号
			var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "通道号");

			// 演示模式直接写入1分道
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "1");
			// 演示模式直接写入分道号
			//Random random = new Random();
			//int ranNumber = random.Next(2) == 0 ? 1 : 5;
			if (fendao == 1)
			{
			fendao = 5;
			}
			else
			{
			fendao = 1;
			}
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, fendao.ToString()); //
			if (ret.IsSucceed)
			{
			Log.Information(string.Format("分道成功，道号是：" + fendao));
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (!retVal.IsSucceed)
			@@ -1871,11 +1934,12 @@
			}
			}
			}
			// 根据箱内品种号获取码躲绑定工位及对应的分道号
			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)


			// 验证是否零箱
			if (boxInfo.BitBoxMark == "1")
			{
			// 绑定信息为null写入剔除通道号
			// 是零箱直接剔除，进行人工组托
			var ret = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, "0");
			if (ret.IsSucceed)
			{
			@@ -1883,8 +1947,225 @@
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			Log.Error("箱码未绑定分拣任务，进行剔除。");
			Log.Error("零箱，进行剔除。");
			break;
			}
			}
			break;
			}


			// 根据箱内品种号获取码躲绑定工位及对应的分道号
			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)
			{
			// 判断是否关联单据 wcsordertask
			var orderModel = _db.Queryable<WcsOderTask>()
			.First(m => m.SkuNo == boxInfo.SkuNo && m.Status == TaskStatusEnum.Wait && m.LotNo == boxInfo.LotNo && m.IsDelete == false);
			if (orderModel != null)
			{
			// 根据boxinfo表产线字段自动绑定分道(1线产品只能绑定到8道)
			if (boxInfo.LineNo != "1")
			{// 绑定到除8道外其他道

			// 获取未绑定道
			var lineNoModels = _db.Queryable<WcsCheckTask>()
			.Where(m => m.Status == "0" && m.LineNo != "8" && m.RoboatType == PLCTypeEnum.RobotPalletizer).ToList();
			if (lineNoModels.Count > 0)
			{
			// 获取当前物料品种号
			var skuInfo = await _db.Queryable<WcsMateialPzInfo>().Where(w => w.SkuNo == boxInfo.SkuNo).FirstAsync();
			if (skuInfo == 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;
			}
			}
			break;
			}

			foreach (var lineNoModel in lineNoModels)
			{
			// 读取设备验证是否绑定分道
			var (respg, pzNo) = plcConn.GetPlcDBValue(lineNoModel.PosType, lineNoModel.DbNumber, lineNoModel.PlcPos);
			if (respg.IsSucceed)
			{
			if (pzNo != 0)
			{
			// plc此分道未解绑
			break;
			}
			else
			{
			// 自动绑定分道
			lineNoModel.OrderNo = orderModel.OrderNo;
			lineNoModel.LotNo = boxInfo.LotNo;
			lineNoModel.SkuNo = boxInfo.SkuNo;
			lineNoModel.SkuName = boxInfo.SkuName;
			lineNoModel.Qty = orderModel.Qty;
			lineNoModel.Status = "1";//已绑定
			lineNoModel.PZNo = skuInfo.PZNo;

			// 给PLC写入品规
			var ret = plcConn.SetPlcDBValue(lineNoModel.PosType, lineNoModel.DbNumber, lineNoModel.PlcPos, skuInfo.PZNo);
			if (ret.IsSucceed)
			{
			//写入流程字成功后更新分拣任务
			_db.Updateable(lineNoModel).ExecuteCommand();
			//更新WcsOderTask表
			orderModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(orderModel).ExecuteCommand();
			// Liudl 通知前端更新分拣任务
			//下发分拣任务
			HubUtil.PublicCheckTask(lineNoModel.Adapt<WcsDeviceTaskOrderDto>());
			break;
			}
			else
			{
			throw Oops.Bah("与PCL交互失败，绑定失败！");
			}
			}
			}
			else
			{
			// 读取plc失败
			break;
			}
			}

			}
			else
			{
			// 若没有空闲道，进行剔除处理。防止堵塞件箱线
			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;
			}
			}
			break;
			}
			}
			else
			{// 绑定到8道
			// 获取未绑定道
			var lineNo8Model = _db.Queryable<WcsCheckTask>()
			.First(m => m.Status == "0" && m.LineNo == "8" && m.RoboatType == PLCTypeEnum.RobotPalletizer);
			if (lineNo8Model != null)
			{
			// 获取当前物料品种号
			var skuInfo = await _db.Queryable<WcsMateialPzInfo>().Where(w => w.SkuNo == boxInfo.SkuNo).FirstAsync();
			if (skuInfo == 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;
			}
			}
			break;
			}


			// 读取设备验证是否绑定分道
			var (respg, pzNo) = plcConn.GetPlcDBValue(lineNo8Model.PosType, lineNo8Model.DbNumber, lineNo8Model.PlcPos);
			if (respg.IsSucceed)
			{
			if (pzNo != 0)
			{
			// plc此分道未解绑
			break;
			}
			else
			{
			// 自动绑定分道
			lineNo8Model.OrderNo = orderModel.OrderNo;
			lineNo8Model.LotNo = boxInfo.LotNo;
			lineNo8Model.SkuNo = boxInfo.SkuNo;
			lineNo8Model.SkuName = boxInfo.SkuName;
			lineNo8Model.Qty = orderModel.Qty;
			lineNo8Model.Status = "1";//已绑定
			lineNo8Model.PZNo = skuInfo.PZNo;

			// 给PLC写入品规
			var ret = plcConn.SetPlcDBValue(lineNo8Model.PosType, lineNo8Model.DbNumber, lineNo8Model.PlcPos, skuInfo.PZNo);
			if (ret.IsSucceed)
			{
			//写入流程字成功后更新分拣任务
			_db.Updateable(lineNo8Model).ExecuteCommand();
			//更新WcsOderTask表
			orderModel.Status = TaskStatusEnum.Doing;
			_db.Updateable(orderModel).ExecuteCommand();

			// Liudl 通知前端更新分拣任务
			//下发分拣任务
			HubUtil.PublicCheckTask(lineNo8Model.Adapt<WcsDeviceTaskOrderDto>());
			break;
			}
			else
			{
			throw Oops.Bah("与PCL交互失败，绑定失败！");
			}
			}
			}
			else
			{
			// 读取plc失败
			break;
			}


			}
			else
			{
			// 没有空闲道，进行剔除处理。防止堵塞件箱线
			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;
			}
			}
			break;
			}
			}
			}
			else
			{
			// 不关联单据直接进行剔除处理
			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;
			}
			}
			}
			}
			@@ -1898,14 +2179,16 @@
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			if (modDevice.DbNumber == "DB102")//1L拆跺分拣后需要回传箱码
			{
			var http = new HttpService();
			IsBaleModel2 ret1 = http.RequestBoxno(boxNoVal);
			if (ret1.Success == -1)
			{ // liudl 此段程序不会执行确认后直接删除
			if (modDevice.DbNumber == "DB102")//1L拆跺分拣后需要回传箱码
			{
			Log.Error("箱码分拣回传失败，需要手动拣货。失败箱码："+boxNoVal);
			break;
			var http = new HttpService();
			IsBaleModel2 ret1 = http.RequestBoxno(boxNoVal);
			if (ret1.Success == -1)
			{
			Log.Error("箱码分拣回传失败，需要手动拣货。失败箱码：" + boxNoVal);
			break;
			}
			}
			}
			break;
			@@ -1919,10 +2202,88 @@
			default: break;
			}
			}
			else
			//一楼主扫分道
			else if (modDevice.DbNumber == "DB102")
			{
			switch (modDevice.Value.ToString())
			{
			case "1":
			// 1楼件箱PLC请求WCS读码
			{
			// 读取plc箱码
			var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "主扫条码");
			var (res, boxNo) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos);
			if (string.IsNullOrWhiteSpace(boxNo.ToString()))
			{

			// 箱信息为null写入剔除通道号:0
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "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 modLineNo = modDevice.listStation.FirstOrDefault(m => m.Text == "通道号");

			// 调用wms接口验证箱码是否可拣货并返回装车口
			var http = new HttpService();
			RequestloadingAddre requesModel = http.ResultBoxInfoExportWcs(boxNoVal);
			if (requesModel.Success != "1")
			{
			// 箱信息为null写入剔除通道号:0
			var ret = plcConn.SetPlcDBValue(modLineNo.PosType, modDevice.DbNumber, modLineNo.PlcPos, "0");
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			Log.Error("出库分拣根据箱码获取装车口失败，进行剔除。" + requesModel.Message);
			break;
			}
			}
			}
			else
			{
			// 写入出库分道号
			// var ret = plcConn.SetPlcDBValue(modLineNo.PosType, modDevice.DbNumber, modLineNo.PlcPos, requesModel.loadingAddre);
			var ret = plcConn.SetPlcDBValue(modLineNo.PosType, modDevice.DbNumber, modLineNo.PlcPos, requesModel.loadingAddre);
			if (ret.IsSucceed)
			{
			// 写入流程控制字 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			{
			break;
			}
			}
			}
			}
			}; break;
			case "10":
			// 1楼件箱PLC读码失败，WCS不做处理直接剔除手持拣货。
			{

			}; break;
			default:
			break;
			}
			}
			else
			{
			// 插码交互
			switch (modDevice.Value.ToString())
			switch (modDevice.Value.ToString())
			{
			case "1":
			// 托盘条码可读
			@@ -1932,7 +2293,7 @@
			// 读取PLC托盘条码号
			var (res, palletVal) = plcConn.GetPlcDBValue(modPalletNo.PosType, modDevice.DbNumber, modPalletNo.PlcPos);
			string palletNo = palletVal.ToString();
			if (string.IsNullOrEmpty(palletNo))
			if (string.IsNullOrEmpty(palletNo))
			{
			Log.Error(string.Format("{0}，读取的托盘号为null", modDevice.Text));
			break;
			@@ -1940,18 +2301,18 @@

			// 根据工位号将托盘号保存在分道表
			var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
			if (checkTaskMedel == null)
			if (checkTaskMedel == null)
			{
			Log.Error(string.Format("根据码垛工位{0}，获取分道失败!", modDevice.StationNum));
			break;
			}
			checkTaskMedel.PalletNo = palletNo;
			var rowCount = _db.Updateable(checkTaskMedel).ExecuteCommand();
			if (rowCount > 0 )
			if (rowCount > 0)
			{
			// plc写入读取成功表示 2
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "2");
			if (retVal.IsSucceed)
			if (retVal.IsSucceed)
			{
			// liudl 此处需添加
			// 通知分拣码垛页更新
			@@ -1971,24 +2332,24 @@
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1");
			break;
			}
			else
			else
			{
			// 获取箱条码
			// 获取箱条码配置
			var modBoxNo = modDevice.listStation.FirstOrDefault(m => m.Text == "箱条码");
			var (res, boxVal) = plcConn.GetPlcDBValue(modBoxNo.PosType, modDevice.DbNumber, modBoxNo.PlcPos);
			string boxNo = boxVal.ToString();
			if (string.IsNullOrEmpty(boxNo))
			if (string.IsNullOrEmpty(boxNo))
			{
			Log.Error($"码垛工位{modDevice.StationNum}，箱码为null插码失败!请人工强制结批。" );
			Log.Error($"码垛工位{modDevice.StationNum}，箱码为null插码失败!请人工强制结批。");
			// 写入插入结果 2：插码失败
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");


			break;
			}
			// 验证箱码表是否存在此箱码
			var boxInfo = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.BoxNo == boxNo).ToList();
			if (boxInfo.Count == 0)
			if (boxInfo.Count == 0)
			{
			Log.Error($"码垛工位{modDevice.StationNum}，箱码{boxNo}不存在!请人工强制结批。");
			// 写入插入结果 2：插码失败
			@@ -2003,37 +2364,46 @@
			break;
			}
			string palletNo = checkTaskMedel.PalletNo;
			if (string.IsNullOrEmpty(palletNo))
			if (string.IsNullOrEmpty(palletNo))
			{
			Log.Error(string.Format("获取码垛工位{0}上的托盘号失败！",modDevice.StationNum));
			Log.Error(string.Format("获取码垛工位{0}上的托盘号失败！", modDevice.StationNum));
			break;
			}
			// 修改插码表
			foreach (WcsBoxInfo item in boxInfo)
			foreach (WcsBoxInfo item in boxInfo)
			{
			item.PalletNo = palletNo;
			item.UpdateTime = DateTime.Now;
			item.OrderCode = checkTaskMedel.OrderNo;
			}

			var rowCount = _db.Updateable(boxInfo).ExecuteCommand();
			Log.Information(string.Format("插码成功，箱码是：" + boxNo, modDevice.StationNum));
			if (rowCount > 0)
			{
			// 插码成功
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "1");


			//是否结批箱
			if (boxInfo[0].EndLotFlag == "1" && retVal.IsSucceed)
			if (boxInfo[0].EndLotFlag == "1" && retVal.IsSucceed)
			{
			// 触发结批分道变为结批中
			AutoEndLot(boxInfo[0].LotNo, plcConn, "2");
			}

			//检查已码垛箱数，码垛数量与完工数量相等后自动结批
			//var finishiqty = _db.Queryable<WcsBoxInfoLog>().Count(m => m.SkuNo = )
			//if (true)
			//{

			//}
			}
			else
			else
			{
			// 插码失败
			Log.Error($"箱码{boxNo};码垛工位{modDevice.StationNum}，插码失败，请强制结批");
			var retVal = plcConn.SetPlcDBValue(modAddCode.PosType, modDevice.DbNumber, modAddCode.PlcPos, "2");
			if (retVal.IsSucceed)
			if (retVal.IsSucceed)
			{
			// 触发结批不解绑分道
			AutoEndLot(boxInfo[0].LotNo, plcConn, "1");
			@@ -2044,8 +2414,8 @@
			break;
			case "40":
			// 请求组托，申请入库
			{
			lock (OLock)
			{
			lock (OLock)
			{
			// 根据工位号，获取托盘号
			var checkTaskMedel = _db.Queryable<WcsCheckTask>().First(m => m.Port == modDevice.StationNum && m.IsDelete == false);
			@@ -2058,7 +2428,7 @@

			// 写入交互工位目标地址
			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");
			@@ -2081,11 +2451,11 @@
			Log.Error(string.Format("申请巷道失败，码垛工位{0};原因{1}", modDevice.StationNum, strMsg));
			break;
			}
			else
			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)
			if (taskModel != null)
			{
			// 获取入库取货工位
			string endLocatVlue = PLCCommon.RoadwayToStationNum(taskModel.EndRoadway, "2");
			@@ -2140,10 +2510,10 @@
			// taskModel.Status = TaskStatusEnum.Doing;
			// _db.Updateable(taskModel).ExecuteCommand();
			//}
			}
			}
			}
			}
			else
			else
			{
			// 根据托盘号，将组托信息插入boxinfolog表并删除boxinfo表数据
			var boxInfoList = _db.Queryable<WcsBoxInfo>().Where(w => w.IsDelete == false && w.PalletNo == palletNo).ToList();
			@@ -2160,19 +2530,37 @@
			}
			break;
			}
			//判断托盘上的箱码是否已组盘
			foreach (var item in boxInfoList)
			{
			var groupBoxno = _db.Queryable<WcsBoxInfoLog>().Where(w => w.BoxNo == item.BoxNo).ToList();
			if (groupBoxno.Count>0)
			{
			Log.Error(string.Format("申请巷道失败，码垛工位{0}，箱码信息不存在", modDevice.StationNum));
			// 写入交互工位目标地址
			var retVal = plcConn.SetPlcDBValue(posModel.PosType, numModel.DbNumber, posModel.PlcPos, "234");
			if (retVal.IsSucceed)
			{
			// 写入组托回复流程字
			retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			}
			break;
			}
			}

			// 组托成功后将信息存到log表
			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}'";
			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,
			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"))
			{
			@@ -2224,7 +2612,7 @@
			{
			// 写入组托回复流程字
			var retVal = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "50");
			if (retVal.IsSucceed)
			if (retVal.IsSucceed)
			{
			// 将入库任务由正在执行改为正在执行
			taskModel.Status = TaskStatusEnum.Doing;
			@@ -2254,24 +2642,25 @@
			}
			}
			break;
			default:break;
			}
			default: break;
			}
			}
			}

			/// <summary>
			/// 拆垛机器人业务处理
			/// 出库件箱输送和拆垛机器人业务处理
			/// </summary>
			/// <param name="modDevice"></param>
			private static void StackingRobot(WcsDeviceDto modDevice)
			{
			var plcConn = modDevice.PLCUtil;
			if (modDevice.DbNumber == "DB131" && modDevice.DbNumber == "DB132" && modDevice.DbNumber == "DB133" && modDevice.DbNumber == "DB134")
			if (modDevice.DbNumber == "DB131" \|\| modDevice.DbNumber == "DB132" \|\| modDevice.DbNumber == "DB133" \|\| modDevice.DbNumber == "DB134")
			{
			switch (modDevice.Value.ToString())
			{
			case "10"://10 plc请求wcs读托盘码 20 wcs读取ok wcs 写入数量及规格 30
			var strMsg = "";

			//wcs读取ok20
			var ret = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "20");
			if (ret.IsSucceed)
			{
			@@ -2286,7 +2675,7 @@
			// 根据任务号获取任务信息
			if (res1.IsSucceed)
			{
			var modTask = _db.Queryable<WcsTask>().First(m => m.Status == TaskStatusEnum.Doing && m.TaskNo == tasknoVal && m.EndLocate == "009" && m.IsDelete == false);
			var modTask = _db.Queryable<WcsTask>().First(m => m.TaskNo == tasknoVal && m.EndLocate == "009" && m.IsDelete == false);
			if (modTask == null)
			{
			Log.Error(string.Format($"出库任务未下发，请人工处理，无法拆垛！"));
			@@ -2296,45 +2685,42 @@
			//通过任务号和托盘号向WMS申请此托盘的拆垛信息
			var http = new HttpService();
			RequestBoxInfoCheckAll tasklist = http.RequestBoxCheckinfo(palletVal, tasknoVal);
			if (!tasklist.Success.Contains("-1"))
			if (tasklist.Success != -1)
			{
			//获取拆垛物料品种(需要增加物料判断，同一个物料号可能会出现不同的码垛规则)
			var pz = _db.Queryable<WcsMateialPzInfo>().First(m => m.SkuNo == tasklist.list[0].SkuNo);
			var pz = _db.Queryable<WcsMateialPzInfo>().First(m => m.SkuNo == tasklist.data.SkuNo);
			//下发拆托规格，拆箱数和托盘上总箱数（不绑定机器人，拆垛任务信息只下发一次）
			// 给PLC写入任务数据
			var listResult = new List<Result>();
			// 获取托盘规则
			var Standard = modDevice.listStation.FirstOrDefault(m => m.Text == "规格");
			listResult.Add(plcConn.SetPlcDBValue(Standard.PosType, modDevice.DbNumber, Standard.PlcPos, tasklist.list[0].Standard));
			listResult.Add(plcConn.SetPlcDBValue(Standard.PosType, modDevice.DbNumber, Standard.PlcPos, pz.PZNo));
			//抓箱数
			var qty = modDevice.listStation.FirstOrDefault(m => m.Text == "拆箱数量");
			listResult.Add(plcConn.SetPlcDBValue(qty.PosType, modDevice.DbNumber, qty.PlcPos, tasklist.list[0].Qty.ToString()));
			listResult.Add(plcConn.SetPlcDBValue(qty.PosType, modDevice.DbNumber, qty.PlcPos, tasklist.data.Qty.ToString()));
			//总箱数
			var qtycount = modDevice.listStation.FirstOrDefault(m => m.Text == "总箱数");
			listResult.Add(plcConn.SetPlcDBValue(qtycount.PosType, modDevice.DbNumber, qtycount.PlcPos, tasklist.list[0].QtyCount.ToString()));
			listResult.Add(plcConn.SetPlcDBValue(qtycount.PosType, modDevice.DbNumber, qtycount.PlcPos, tasklist.data.QtyCount.ToString()));


			// 是否写入成功
			if (listResult.All(s => s.IsSucceed))
			{
			var ret1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "20");
			//wcs 写入数量及规格 30
			var ret1 = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");

			}
			else
			{
			Log.Error(string.Format($"码垛信息未写入！托盘号："+palletVal+"，码垛位："+modDevice.StationNum));
			Log.Error(string.Format($"码垛信息未写入！托盘号：" + palletVal + "，码垛位：" + modDevice.StationNum));
			break;
			}
			}
			}
			}

			break;
			default:
			break;
			break;
			}
			}

			}
			}

			/// <summary>