ZhiHuiQiCe/LongDeLiLiKu.git

			@@ -22,6 +22,7 @@
			using WIDESEAWCS_Core;
			using SqlSugar.Extensions;
			using WIDESEAWCS_Tasks.ConveyorLineJob;
			using WIDESEAWCS_QuartzJob.Repository;

			namespace WIDESEAWCS_Tasks
			{
			@@ -32,15 +33,17 @@
			private readonly ITaskExecuteDetailService _taskExecuteDetailService;
			private readonly ITaskRepository _taskRepository;
			private readonly IRouterService _routerService;
			private readonly IRouterRepository _routerRepository;
			private readonly IStationMangerRepository _stationMangerRepository;

			public StackerCraneJob_CP(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository)
			public StackerCraneJob_CP(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository,IRouterRepository routerRepository)
			{
			_taskService = taskService;
			_taskExecuteDetailService = taskExecuteDetailService;
			_taskRepository = taskRepository;
			_routerService = routerService;
			_stationMangerRepository = stationMangerRepository;
			_routerRepository = routerRepository;
			}

			public Task Execute(IJobExecutionContext context)
			@@ -57,22 +60,26 @@
			commonStackerCrane.CheckStackerCraneTaskCompleted();//é²æ¢ä»»å¡å®æäºä»¶çæµè¶æ¶ï¼åæå¨è§¦åä¸æ¬¡
			if (commonStackerCrane.StackerCraneAutoStatusValue == StackerCraneAutoStatus.Automatic && commonStackerCrane.StackerCraneStatusValue == StackerCraneStatus.Normal && commonStackerCrane.StackerCraneWorkStatusValue == StackerCraneWorkStatus.Standby)
			{
			Dt_Task? task = GetTask(commonStackerCrane);
			if (task != null)
			short stackerError = commonStackerCrane.Communicator.Read<short>("DB1000.54.0");
			if (stackerError == 0)
			{
			StackerCraneTaskCommand? stackerCraneTaskCommand = ConvertToStackerCraneTaskCommand(task);
			if (stackerCraneTaskCommand != null)
			Dt_Task? task = GetTask(commonStackerCrane);
			if (task != null)
			{
			bool sendFlag = commonStackerCrane.SendCommand(stackerCraneTaskCommand);
			if (sendFlag)
			StackerCraneTaskCommand? stackerCraneTaskCommand = ConvertToStackerCraneTaskCommand(task);
			if (stackerCraneTaskCommand != null)
			{
			commonStackerCrane.LastTaskType = task.TaskType;
			task.Dispatchertime = DateTime.Now;
			task.ExceptionMessage = "";
			_taskService.UpdateTask(task, TaskStatusEnum.SC_Executing);
			commonStackerCrane.Communicator.Write("DB1000.20.0", true);
			//å»¶æ¶1s
			Thread.Sleep(1000);
			bool sendFlag = commonStackerCrane.SendCommand(stackerCraneTaskCommand);
			if (sendFlag)
			{
			commonStackerCrane.LastTaskType = task.TaskType;
			task.Dispatchertime = DateTime.Now;
			task.ExceptionMessage = "";
			_taskService.UpdateTask(task, TaskStatusEnum.SC_Executing);
			commonStackerCrane.Communicator.Write("DB1000.20.0", true);
			//å»¶æ¶1s
			Thread.Sleep(1000);
			}
			}
			}
			}
			@@ -109,26 +116,36 @@
			{
			try
			{
			Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
			Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == taskNum && x.TaskState==TaskStatusEnum.SC_Executing.ObjToInt());
			if (task != null)
			{
			if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
			{
			Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.StackerCraneStationCode == task.NextAddress);
			Dt_StationManger stationManger = _stationMangerRepository.QueryFirst(x => x.StackerCraneStationCode == task.NextAddress && x.StackerCraneCode==deviceCode);
			if (stationManger == null)
			{
			_taskExecuteDetailService.AddTaskExecuteDetail(taskNum, $"è¾éçº¿åºåºç«ç¹æªéç½®,{task.NextAddress}");
			_taskService.UpdateTaskExceptionMessage(taskNum, $"è¾éçº¿åºåºç«ç¹æªéç½®,{task.NextAddress}");
			return WebResponseContent.Instance.Error($"è¾éçº¿åºåºç«ç¹æªéç½®,{task.NextAddress}");
			}

			Dt_Router router = _routerRepository.QueryFirst(x => x.InOutType == task.TaskType && x.StartPosi == stationManger.StationCode && x.ChildPosi == stationManger.StationDeviceCode);
			if (router == null)
			{
			_taskService.UpdateTaskExceptionMessage(taskNum, $"æªæ¾å°è·¯ç±ä¿¡æ¯,{task.NextAddress}");
			WriteError(deviceCode, $"æªæ¾å°è·¯ç±ä¿¡æ¯,{task.NextAddress}");
			return WebResponseContent.Instance.Error($"æªæ¾å°è·¯ç±ä¿¡æ¯,{task.NextAddress}");
			}
			//å åæºå®æå®æ
			int oldStatus = task.TaskState;
			task.DeviceCode = stationManger.StationDeviceCode;
			task.TaskState = TaskStatusEnum.Line_Execute.ObjToInt();
			task.CurrentAddress = stationManger.StationCode;
			_taskRepository.UpdateData(task);
			task.NextAddress = router.NextPosi;
			_taskService.UpdateTask(task, TaskStatusEnum.Line_Execute);

			//_taskService.UpdateTask(task, TaskStatusEnum.Line_Execute, deviceCode: stationManger.StationDeviceCode, currentAddress: stationManger.StationCode, nextAddress: router.NextPosi, targetAddress: router.NextPosi);
			_taskExecuteDetailService.AddTaskExecuteDetail(taskNum, $"ç³»ç»èªå¨æµç¨,ä»»å¡ç¶æä»ã{oldStatus}ãè½¬å°ã{task.TaskState}ã");
			//todo å®æ
			WriteInfo(deviceCode, $"å åæºä»»å¡å®æ,ä»»å¡å·:{taskNum}");
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup \|\| task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
			{
			@@ -174,6 +191,7 @@
			{
			if (commonStackerCrane.LastTaskType.GetValueOrDefault().GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
			{
			//ä¸ä¸ä¸ªä¸ºåºåºåæ¥æ¯å¦åå¨å¥åºä»»å¡ äº¤æ¿æ§è¡
			task = _taskService.QueryStackerCraneInTask(commonStackerCrane.DeviceCode);
			if (task == null)
			{
			@@ -182,6 +200,7 @@
			}
			else
			{
			//ä¸ä¸ä¸ªä¸ºå¥åºåæ¥æ¯å¦åå¨åºåºä»»å¡ äº¤æ¿æ§è¡
			task = _taskService.QueryStackerCraneOutTask(commonStackerCrane.DeviceCode);
			if (task == null)
			{
			@@ -192,22 +211,24 @@

			if (task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
			{
			if (OutTaskStationIsOccupied(task) != null \|\| true)
			//å¤æåºåºç«å°å ç¨
			if (OutTaskStationIsOccupied(task) == null)
			{
			return task;
			}
			else
			{
			List<string> otherOutStaionCodes = _routerService.QueryNextRoutes(commonStackerCrane.DeviceCode, task.NextAddress).Select(x => x.ChildPosi).ToList();
			bool flag = false;
			List<string> otherOutStaionCodes = _routerService.QueryNextRoutes(commonStackerCrane.DeviceCode, task.NextAddress, task.TaskType).Select(x => x.ChildPosi).ToList();
			List<Dt_Task> tasks = _taskService.QueryStackerCraneOutTasks(commonStackerCrane.DeviceCode, otherOutStaionCodes);
			foreach (var item in tasks)
			{
			if (OutTaskStationIsOccupied(task) != null)
			{
			return task;
			flag = true;
			break;
			}
			}
			task = _taskService.QueryStackerCraneInTask(commonStackerCrane.DeviceCode);
			if (!flag)
			{
			task = _taskService.QueryStackerCraneInTask(commonStackerCrane.DeviceCode);
			}
			}
			}

			@@ -221,18 +242,24 @@
			/// <returns>å¦ææªè¢«å ç¨ï¼è¿åä¼ å¥çä»»å¡ä¿¡æ¯ï¼å¦åï¼è¿ånull</returns>
			private Dt_Task? OutTaskStationIsOccupied([NotNull] Dt_Task task)
			{
			Dt_StationManger? stationManger = _stationMangerRepository.QueryFirst(x => x.StationCode == task.TargetAddress && x.StackerCraneCode == task.DeviceCode);
			Dt_StationManger? stationManger = _stationMangerRepository.QueryFirst(x => (x.StationCode == task.NextAddress) && x.StackerCraneCode == task.DeviceCode);
			if (stationManger != null)
			{
			IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == stationManger.StationDeviceCode);
			if (device != null)
			{
			OtherDevice client = (OtherDevice)device;
			if (client.GetValue<R_ConveyorLineCPDB, short>(R_ConveyorLineCPDB.Command, stationManger.StationCode)==3)//åºåºç«å°æªè¢«å ç¨
			short command = client.GetValue<R_ConveyorLineCPDB, short>(R_ConveyorLineCPDB.Command, stationManger.StationCode);
			if (command==3)//åºåºç«å°æªè¢«å ç¨
			{
			task.NextAddress = stationManger.StackerCraneStationCode;
			_taskRepository.UpdateData(task);
			return task;
			}
			else
			{
			task.ExceptionMessage = "åºåºç«å°æ æ³ä¸å";
			_taskRepository.UpdateData(task);
			}
			}
			else
			@@ -290,7 +317,7 @@
			return null;
			}
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)//å¤ææ¯å¦æ¯åºåºä»»å¡
			{
			string[] targetCodes = task.NextAddress.Split("-");
			if (targetCodes.Length == 3)
			@@ -319,7 +346,7 @@
			return null;
			}
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)//å¤ææ¯å¦æ¯ç§»åºä»»å¡
			{
			string[] targetCodes = task.NextAddress.Split("-");
			if (targetCodes.Length == 5)