HuaYiZhongHeng/BaiBuLiKu.git

			@@ -60,146 +60,205 @@

			public async Task Execute(IJobExecutionContext context)
			{
			try
			string jobName = context.JobDetail.Key.Name;
			if (MemoryLockManager.TryAcquireLock(jobName))
			{
			CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
			if (conveyorLine != null)
			try
			{
			List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);
			foreach (string childDeviceCode in childDeviceCodes)
			CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
			if (conveyorLine != null)
			{
			await ProcessDeviceAsync(conveyorLine, childDeviceCode);
			}
			List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);
			var tasks = childDeviceCodes.Select(childDeviceCode => ProcessDeviceAsync(conveyorLine, childDeviceCode)).ToList();
			await Task.WhenAll(tasks);

			List<Dt_StationManager> stationManagers = _stationManagerService.GetAllStationByDeviceCode(conveyorLine.DeviceCode);
			foreach (var station in stationManagers)
			{
			if (station.stationType == 11)
			List<Dt_StationManager> stationManagers = _stationManagerService.GetAllStationByDeviceCode(conveyorLine.DeviceCode);
			foreach (var station in stationManagers)
			{
			ConveyorLineTaskCommand command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(station.stationChildCode);
			ConveyorLineTaskCommandWrite commandWrite = conveyorLine.ReadCustomer<ConveyorLineTaskCommandWrite>(station.stationChildCode, "DeviceCommand");
			if (command != null && commandWrite != null)
			if (station.stationType == 11)
			{
			var structs = BitConverter.GetBytes(commandWrite.WriteInteractiveSignal).Reverse().ToArray().ToBoolArray();
			if (structs[0] == true)
			ConveyorLineTaskCommand command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(station.stationChildCode);
			ConveyorLineTaskCommandWrite commandWrite = conveyorLine.ReadCustomer<ConveyorLineTaskCommandWrite>(station.stationChildCode, "DeviceCommand");
			if (command != null && commandWrite != null)
			{
			ConsoleHelper.WriteWarningLine($"【{conveyorLine.DeviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{station.stationChildCode}】空托盘请求扫码入库");
			NGRequestTaskInbound(conveyorLine, command, station.stationChildCode, 0, station.stationLocation);
			}
			else
			{
			ConveyorLineSendFinish(conveyorLine, station.stationChildCode, 0, false);
			}
			}
			}
			}
			}
			}
			catch (Exception ex)
			{
			Console.Out.WriteLine(nameof(CommonConveyorLineJob) + ":" + ex.ToString());
			}
			}

			private async Task ProcessDeviceAsync(CommonConveyorLine conveyorLine, string childDeviceCode)
			{
			ConveyorLineTaskCommand command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(childDeviceCode);
			ConveyorLineTaskCommandWrite commandWrite = conveyorLine.ReadCustomer<ConveyorLineTaskCommandWrite>(childDeviceCode, "DeviceCommand");
			if (command != null && commandWrite != null)
			{
			var structs = BitConverter.GetBytes(commandWrite.WriteInteractiveSignal).Reverse().ToArray().ToBoolArray();

			List<DeviceProtocolDetailDTO>? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.Where(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand.InteractiveSignal)).ToList();

			if (deviceProtocolDetails != null)
			{
			foreach (var item in deviceProtocolDetails)
			{
			var outDeviceCodes = _routerService.QueryOutDeviceCodes(conveyorLine.DeviceCode);
			if (structs[item.ProtocalDetailValue.ObjToInt()] == true)
			{
			MethodInfo? method = GetType().GetMethod(item.ProtocolDetailType);
			if (method != null)
			{
			command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, item.ProtocalDetailValue.ObjToInt() });
			}
			}
			else
			{
			DeviceProDTO? devicePro = conveyorLine.DeviceProDTOs.Where(x => x.DeviceProParamType == nameof(DeviceCommand) && x.DeviceChildCode == childDeviceCode).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
			string[] x = devicePro.DeviceProAddress.Split('.');
			x[x.Length - 1] = (item.ProtocalDetailValue.ObjToInt() + 1).ToString();
			string DeviceProAddress = string.Join(".", x);
			var writeRead = conveyorLine.Communicator.Read<bool>(DeviceProAddress);
			if (writeRead)
			{
			conveyorLine.Communicator.Write(DeviceProAddress, false);
			//ConveyorLineSendFinish(conveyorLine, childDeviceCode, item.ProtocalDetailValue.ObjToInt(), false);
			}
			}
			}
			}

			Platform platform = _platFormRepository.QueryFirst(x => x.PLCCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
			if (platform != null)
			{
			if (command.InteractiveSignal != 2)
			{
			MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
			if (method != null)
			{
			command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			int count = string.IsNullOrEmpty(platform.Location) ? 0 + 1 : platform.Location.Split(',').Count() + 1;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			}
			}
			else
			{
			if (platform.Location != null && platform.Location != "")
			{
			var strings = platform.Location.Split(',').ToList();
			foreach (var ite in strings)
			{
			//int index = strings.FindIndex(p => p == ite);
			ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
			if (command1.InteractiveSignal != 2)
			{
			MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
			if (method != null)
			var structs = BitConverter.GetBytes(commandWrite.WriteInteractiveSignal).Reverse().ToArray().ToBoolArray();
			if (structs[0] == true)
			{
			command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			//int count = strings.Count - index;
			int count = strings.Count;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			ConsoleHelper.WriteWarningLine($"【{conveyorLine.DeviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{station.stationChildCode}】空托盘请求扫码入库");
			NGRequestTaskInbound(conveyorLine, command, station.stationChildCode, 0, station.stationLocation);
			}
			else
			{
			ConveyorLineSendFinish(conveyorLine, station.stationChildCode, 0, false);
			}
			}
			}
			}
			}
			}
			catch (Exception ex)
			{
			Console.Out.WriteLine(nameof(CommonConveyorLineJob) + ":" + ex.ToString());
			}
			finally
			{
			MemoryLockManager.ReleaseLock(jobName);
			}
			}
			else
			{
			ConsoleHelper.WriteErrorLine($"[CommonConveyorLineJob]【{jobName}】任务已被锁定，无法处理");
			}
			return;
			}

			private Task ProcessDeviceAsync(CommonConveyorLine conveyorLine, string childDeviceCode)
			{
			ConveyorLineTaskCommand command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(childDeviceCode);
			ConveyorLineTaskCommandWrite commandWrite = conveyorLine.ReadCustomer<ConveyorLineTaskCommandWrite>(childDeviceCode, "DeviceCommand");
			if (command != null && commandWrite != null)
			{
			#region 调用事件总线通知前端

			var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken");
			if (tokenInfos == null \|\| !tokenInfos.Any())
			if (tokenInfos != null && tokenInfos.Any())
			{
			//throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存");
			return;
			}
			var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();
			var userIds = tokenInfos?.Select(x => x.UserId).ToList();
			var userTokenIds = tokenInfos.Select(x => x.Token_ID).ToList();
			var userIds = tokenInfos.Select(x => x.UserId).ToList();

			object obj = new
			{
			childDeviceCode,
			command,
			commandWrite
			};
			_noticeService.LineData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });
			object obj = new
			{
			command,
			commandWrite
			};
			_noticeService.LineData(userIds.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, childDeviceCode, data = obj });
			}

			#endregion 调用事件总线通知前端

			var writeInteractiveSignal = commandWrite.WriteInteractiveSignal;
			var structs = BitConverter.GetBytes(writeInteractiveSignal).Reverse().ToArray().ToBoolArray();
			List<DeviceProtocolDetailDTO>? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.Where(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand.InteractiveSignal)).ToList();

			if (deviceProtocolDetails != null)
			{
			foreach (var item in deviceProtocolDetails)
			{
			int itemValue = item.ProtocalDetailValue.ObjToInt();
			if (structs[itemValue] == true)
			{
			var numRead = itemValue;
			var numWrite = itemValue + 1;
			ConsoleHelper.WriteWarningLine($"【{conveyorLine.DeviceName}】【{childDeviceCode}】【{numRead.ToString()}】位输送线读取信号：【{structs[itemValue]}】【{numWrite}】位WCS写入信号：【{structs[itemValue + 1]}】");
			if (structs[itemValue + 1] != structs[itemValue])
			{
			MethodInfo? method = GetType().GetMethod(item.ProtocolDetailType);
			if (method != null)
			{
			command.InteractiveSignal = writeInteractiveSignal;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, itemValue });
			}
			}
			}
			else
			{
			ConveyorLineSendFinish(conveyorLine, childDeviceCode, itemValue, false);
			}
			}
			}

			Platform platform = _platFormRepository.QueryFirst(x => x.PLCCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
			if (platform != null && !string.IsNullOrEmpty(platform.Location))
			{
			var strings = platform.Location.Split(',').ToList();
			foreach (var ite in strings)
			{
			ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
			if (command1.InteractiveSignal != 2)
			{
			command.InteractiveSignal = writeInteractiveSignal;
			int count = strings.Count;
			MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
			if (method != null)
			{
			command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			};
			}
			}
			}

			#region
			//var structs = BitConverter.GetBytes(commandWrite.WriteInteractiveSignal).Reverse().ToArray().ToBoolArray();

			//List<DeviceProtocolDetailDTO>? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.Where(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand.InteractiveSignal)).ToList();

			//if (deviceProtocolDetails != null)
			//{
			// foreach (var item in deviceProtocolDetails)
			// {
			// if (structs[item.ProtocalDetailValue.ObjToInt()] == true)
			// {
			// MethodInfo? method = GetType().GetMethod(item.ProtocolDetailType);
			// if (method != null)
			// {
			// var numRead = item.ProtocalDetailValue.ObjToInt();
			// var numWrite = item.ProtocalDetailValue.ObjToInt() + 1;
			// ConsoleHelper.WriteWarningLine($"【{conveyorLine.DeviceName}】【{childDeviceCode}】【{numRead.ToString()}】位输送线读取信号：【{structs[item.ProtocalDetailValue.ObjToInt()]}】【{numWrite}】位WCS写入信号：【{structs[item.ProtocalDetailValue.ObjToInt() + 1]}】");
			// if (structs[item.ProtocalDetailValue.ObjToInt() + 1] != structs[item.ProtocalDetailValue.ObjToInt()])
			// {
			// command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			// method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, item.ProtocalDetailValue.ObjToInt() });
			// }
			// }
			// }
			// else
			// {
			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, item.ProtocalDetailValue.ObjToInt(), false);
			// }
			// }
			//}

			//Platform platform = _platFormRepository.QueryFirst(x => x.PLCCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
			//if (platform != null)
			//{
			// if (command.InteractiveSignal != 2)
			// {
			// MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
			// if (method != null)
			// {
			// command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			// int count = string.IsNullOrEmpty(platform.Location) ? 0 + 1 : platform.Location.Split(',').Count() + 1;
			// method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			// }
			// }
			// else
			// {
			// if (platform.Location != null && platform.Location != "")
			// {
			// var strings = platform.Location.Split(',').ToList();
			// foreach (var ite in strings)
			// {
			// //int index = strings.FindIndex(p => p == ite);
			// ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
			// if (command1.InteractiveSignal != 2)
			// {
			// MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
			// if (method != null)
			// {
			// command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			// //int count = strings.Count - index;
			// int count = strings.Count;
			// method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			// }
			// }
			// }
			// }
			// }
			//}
			#endregion
			}
			return Task.CompletedTask;
			}

			#region 入库
			@@ -218,11 +277,33 @@
			ConsoleHelper.WriteWarningLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】请求扫码入库");

			var task = _taskService.QueryBarCodeConveyorLineTask(command.Barcode, childDeviceCode);
			HandleTaskOut(conveyorLine, command, childDeviceCode, ProtocalDetailValue, task);

			if (task == null && command.Barcode != "NoRead" && command.Barcode.IsNotEmptyOrNull())
			if (task != null)
			{
			HandleNewTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
			if (task.TaskType == (int)TaskOutboundTypeEnum.OutTray \|\| task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
			{
			HandleTaskOut(conveyorLine, command, childDeviceCode, ProtocalDetailValue, task);
			}
			else
			{
			var next = task.NextAddress;
			var taskCommand = MapTaskCommand(task, command);
			task.NextAddress = next;
			conveyorLine.SendCommand(taskCommand, childDeviceCode);

			ConsoleHelper.WriteWarningLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】请求扫码入库,下一目标地址【{taskCommand.TargetAddress}】");

			ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			_taskService.UpdateTaskStatusToNext(task);
			}
			}
			else
			{
			if (task == null && command.Barcode != "NoRead" && command.Barcode.IsNotEmptyOrNull())
			{
			task = _taskService.QueryBarcodeTask(command.Barcode, childDeviceCode);
			if (task == null)
			HandleNewTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
			}
			}
			}
			catch (Exception ex)
			@@ -274,10 +355,11 @@
			/// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param>
			public void ConveyorLineInFinish(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
			{
			ConsoleHelper.WriteWarningLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】输送线入库完成");
			var task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null && task.TaskState != (int)TaskInStatusEnum.Line_InFinish)
			{
			if (command.Barcode == task.PalletCode)
			if (command.Barcode == task.PalletCode && childDeviceCode == task.NextAddress)
			{
			ConsoleHelper.WriteWarningLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】输送线入库完成,下一目标地址【等待分配货位】");
			ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			@@ -318,9 +400,10 @@
			public void RequestOutbound(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
			{
			var task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			ConsoleHelper.WriteSuccessLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】输送线请求出库,task{task.ToJsonString()}");
			if (task != null)
			{
			if (command.Barcode == task.PalletCode)
			//if (command.Barcode == task.PalletCode)
			{
			//task.NextAddress = task.NextAddress.Replace("-1", "");
			//ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			@@ -470,7 +553,7 @@
			var tasks = _taskRepository.QueryData(x => x.TaskType == (int)taskType && x.TargetAddress == childDeviceCode);
			if (tasks.Count < index)
			{
			ConsoleHelper.WriteErrorLine($"【{childDeviceCode}】请求【{taskType.ToString()}】任务,已有【{taskType.ToString()}】任务【{tasks.Count}】,最多拥有【{index - 1}】");
			//ConsoleHelper.WriteErrorLine($"【{childDeviceCode}】请求【{taskType.ToString()}】任务,已有【{taskType.ToString()}】任务【{tasks.Count}】,最多拥有【{index - 1}】");

			#region 调用WMS获取出库任务