ZhiHuiQiCe/LongDeLiLiKu.git

			@@ -97,7 +97,7 @@
			{
			shouldRestart = false;
			Dt_StationManger? RequestIn = stationMangers.FirstOrDefault(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt());
			WriteError($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}","å¼å§æ§è¡");
			WriteInfo($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}ååå£","å¼å§æ§è¡");
			while (true)
			{
			if (RequestIn != null)
			@@ -107,11 +107,11 @@
			if (deviceProRead != null && deviceProWrite != null)
			{
			R_CLineCPHInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_CLineCPHInfo>(deviceProRead.DeviceProAddress);
			//ç åç¯çº¿è¯·æ±ä»»å¡
			//ç åç¯çº¿è¯·æ±ä»»å¡
			if (conveyorLineInfoRead != null && (conveyorLineInfoRead.R_State == 2 \|\| conveyorLineInfoRead.R_State == 3) && conveyorLineInfoRead.R_TaskNo <= 0 && !string.IsNullOrEmpty(conveyorLineInfoRead.R_BoxCode) && conveyorLineInfoRead.R_Request == 1)
			{
			//å¤ææ¯å¦ä»»å¡å·²ç»åå¨
			Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.QueryFirst(x => x.BarCode == conveyorLineInfoRead.R_BoxCode.Trim() && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt());
			Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.Db.Queryable<Dt_PackaxisTask>().Where(x => x.BarCode == conveyorLineInfoRead.R_BoxCode.Trim() && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt()).First();
			if (packaxisTask != null)
			{
			//åå¥æ§è¡æ°æ®
			@@ -120,7 +120,7 @@
			device.SetValue(W_CLineCPHDB.W_Long, packaxisTask.PackLength, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Wide, packaxisTask.PackWidth, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_High, packaxisTask.PackHeight, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_TMID, packaxisTask.BarCode, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_TMID, conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
			}
			else
			@@ -136,7 +136,7 @@
			device.SetValue(W_CLineCPHDB.W_Long, _PackaxisTask.PackLength, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Wide, _PackaxisTask.PackWidth, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_High, _PackaxisTask.PackHeight, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_TMID, _PackaxisTask.BarCode, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_TMID, conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
			WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode.Trim());
			if (content.Status)
			@@ -154,6 +154,7 @@
			}
			#endregion
			}
			Thread.Sleep(200);
			}
			}
			else
			@@ -165,8 +166,8 @@
			}
			catch (Exception ex)
			{
			WriteError($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}", $"å¼å¸¸:{ex.Message}");
			Thread.Sleep(1500);
			WriteInfo($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}ååå£", $"å¼å¸¸:{ex.Message}");
			Thread.Sleep(3000);
			shouldRestart = true;
			}
			}
			@@ -182,7 +183,7 @@
			shouldRestart = false;
			//è·åææç åå£
			List<Dt_StationManger> stationMangersMD = stationMangers.Where(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyOutbound.ObjToInt()).ToList();
			WriteError($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}", "å¼å§æ§è¡");
			WriteInfo($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}ç åå£", "å¼å§æ§è¡");
			while (true)
			{
			if (stationMangersMD.Count > 0)
			@@ -211,6 +212,7 @@
			packaxisTask.DeviceCode = item.StackerCraneCode;
			packaxisTask.TaskState = TaskStatusEnum.MD_Executing.ObjToInt();
			_packaxisTaskRepository.UpdateData(packaxisTask);
			device.SetValue(W_CLineCPHDB.W_Request, 1, item.StationCode);
			}
			}
			else
			@@ -230,8 +232,8 @@
			}
			catch (Exception ex)
			{
			WriteError($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}", $"å¼å¸¸:{ex.Message}");
			Thread.Sleep(1500);
			WriteInfo($"çº¿ç¨ {Thread.CurrentThread.ManagedThreadId}ç åå£", $"å¼å¸¸:{ex.Message}");
			Thread.Sleep(3000);
			shouldRestart = true;
			}
			}