ZhiHuiQiCe/LongDeLiLiKu.git

			@@ -42,7 +42,6 @@
			private readonly IRouterExtension _routerExtension;
			private readonly List<Dt_WarehouseDevice> warehouseDevices;
			private static object lockObj = 0;//
			private static List<string> strings = new List<string>();

			public ConveyorLineJob_CPH(ICacheService cacheService, ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IRouterService routerService, IRouterExtension routerExtension)
			{
			@@ -54,14 +53,6 @@
			_routerRepository = routerRepository;
			_routerService = routerService;
			_routerExtension = routerExtension;
			//string boxCodes = AppSettings.Get("BoxCodes");
			//if (!string.IsNullOrEmpty(boxCodes) && strings.Count<=0)
			//{
			// foreach (string s in boxCodes.Split(","))
			// {
			// strings.Add(s);
			// }
			//}
			string? warehouseDevicesStr = _cacheService.Get<string>(nameof(Dt_WarehouseDevice));
			if (!string.IsNullOrEmpty(warehouseDevicesStr))
			{
			@@ -80,11 +71,9 @@
			if (lockObj.ToString()=="0")
			{
			lockObj = 1;
			Task task = Task.Run(() =>
			Task task = Task.Run(async () =>
			{
			try
			{
			while (true)
			{
			bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
			if (flag && value != null)
			@@ -93,6 +82,8 @@
			OtherDevice device = (OtherDevice)value;
			List<Dt_StationManger> stationMangers = _stationMangerRepository.QueryData(x => x.StationDeviceCode == device.DeviceCode);
			Dt_StationManger? RequestIn = stationMangers.FirstOrDefault(x => x.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt());
			while (true)
			{
			if (RequestIn != null)
			{
			DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == RequestIn.StationCode && x.DeviceProParamType == nameof(R_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
			@@ -103,47 +94,26 @@
			//鐮佸灈鐜嚎璇锋眰浠诲姟
			if (conveyorLineInfoRead != null && (conveyorLineInfoRead.R_State == 2 \|\| conveyorLineInfoRead.R_State == 3) && conveyorLineInfoRead.R_TaskNo <= 0 && !string.IsNullOrEmpty(conveyorLineInfoRead.R_BoxCode) && conveyorLineInfoRead.R_Request == 1)
			{
			//WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode);
			////鍚慦MS璇锋眰浠诲姟
			//if (true)
			//{

			//}
			//string[] strings = conveyorLineInfoRead.R_BoxCode.Split("-");
			//if (strings.Length==2)
			//{
			#region todo:涓存椂閫昏緫
			////鍐欏叆鎵ц鏁版嵁
			//if (strings.FirstOrDefault(x=>x == conveyorLineInfoRead.R_BoxCode)!=null)
			//{
			//鍐欏叆鎵ц鏁版嵁
			device.SetValue(W_CLineCPHDB.W_TaskNo, 100 + 5, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Channel, 14, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Long, 465, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Wide, 375, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_High, 690, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Long, 485, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Wide, 460, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_High, 420, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_TMID, conveyorLineInfoRead.R_BoxCode, RequestIn.StationCode);
			device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
			// WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode);
			// if (content.Message.Contains("true"))
			// {
			// strings.Remove(conveyorLineInfoRead.R_BoxCode);
			// WriteInfo(RequestIn.StationName, content.Message);
			// }
			// else
			// {
			// WriteError(RequestIn.StationName, content.Message);
			// }
			//}
			//else
			//{
			// WriteError(RequestIn.StationName, $"鏈壘鍒版潯鐮亄conveyorLineInfoRead.R_BoxCode}鏁版嵁");
			//}
			WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode);
			if (content.Status)
			{
			WriteInfo(RequestIn.StationName, content.Message);
			}
			else
			{
			WriteError(RequestIn.StationName, content.Message);
			}
			#endregion
			//}
			//else
			//{
			// WriteError(RequestIn.StationName, $"鏁版嵁鎴彇閿欒锛歿strings}");
			//}
			}
			}
			else
			@@ -171,13 +141,11 @@
			}
			}
			}
			Thread.Sleep(100);
			}
			}
			}
			catch (Exception ex)
			{

			lockObj = 0;
			WriteError(nameof(ConveyorLineJob_CPH), $"閿欒淇℃伅锛歿ex.Message}");
			}
			@@ -186,6 +154,7 @@
			}

			}

			return Task.CompletedTask;
			}
			}