HuaYiZhongHeng/BaiBuLiKu.git

			@@ -29,10 +29,12 @@
			using System.Threading.Tasks;
			using WIDESEAWCS_BasicInfoRepository;
			using WIDESEAWCS_BasicInfoService;
			using WIDESEAWCS_Common;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Core;
			using WIDESEAWCS_Core.Helper;
			using WIDESEAWCS_DTO.TaskInfo;
			using WIDESEAWCS_ISystemServices;
			using WIDESEAWCS_ITaskInfoRepository;
			using WIDESEAWCS_ITaskInfoService;
			using WIDESEAWCS_Model.Models;
			@@ -53,8 +55,9 @@
			private readonly IRouterService _routerService;
			private readonly IMapper _mapper;
			private readonly IDt_StationManagerService _stationManagerService;
			private readonly ISys_ConfigService _sys_ConfigService;

			public CommonConveyorLine_AfterJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IDt_StationManagerService stationManagerService)
			public CommonConveyorLine_AfterJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IDt_StationManagerService stationManagerService, ISys_ConfigService sys_ConfigService)
			{
			_taskService = taskService;
			_taskExecuteDetailService = taskExecuteDetailService;
			@@ -62,9 +65,10 @@
			_mapper = mapper;
			_taskRepository = taskRepository;
			_stationManagerService = stationManagerService;
			_sys_ConfigService = sys_ConfigService;
			}

			public Task Execute(IJobExecutionContext context)
			public async Task Execute(IJobExecutionContext context)
			{
			try
			{
			@@ -85,6 +89,10 @@
			method.Invoke(this, new object[] { conveyorLine, command, station });
			}
			}
			//if (station.stationType == 6 && station.stationArea == "3")
			//{
			// await GetEmptyTrayAsync(station);
			//}
			}

			#region 路由方式
			@@ -117,7 +125,7 @@
			//WriteDebug("CommonConveyorLineJob", "test");
			//Console.Out.WriteLine(DateTime.Now);
			}
			return Task.CompletedTask;
			return;
			}

			/// <summary>
			@@ -128,6 +136,7 @@
			/// <param name="childDeviceCode">子设备编号</param>
			public void RequestInbound(CommonConveyorLine_After conveyorLine, ConveyorLineTaskCommand_After command, Dt_StationManager stationInfo)
			{
			ConsoleHelper.WriteSuccessLine($"【{conveyorLine.DeviceName}】,托盘号：【{command.ConveyorLineBarcode}】,站台：【{stationInfo.remark}】请求任务");
			var taskNew = _taskService.QueryTaskByPalletCode(command.ConveyorLineBarcode, stationInfo.Roadway);
			if (taskNew == null)
			{
			@@ -142,6 +151,37 @@
			//taskCommand.ConveyorLineTaskNum = task.TaskNum;
			//taskCommand.ConveyorLineTargetAddress = Convert.ToInt16(task.NextAddress);
			conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 1, stationInfo.stationChildCode);
			//conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, 1, task.NextAddress);
			//ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			}
			}
			}
			}

			/// <summary>
			/// 输送线请求空框
			/// </summary>
			/// <param name="conveyorLine"></param>
			/// <param name="command"></param>
			/// <param name="stationInfo"></param>
			public void RequestEmptyOutbound(CommonConveyorLine_After conveyorLine, ConveyorLineTaskCommand_After command, Dt_StationManager stationInfo)
			{
			if (stationInfo.stationType != 7) return;
			var taskNew = _taskRepository.QueryFirst(x => x.Roadway == stationInfo.Roadway && x.TaskType == (int)TaskOutboundTypeEnum.OutTray);
			if (taskNew == null) //不存在空框出库任务则请求WMS出空库
			{
			ConsoleHelper.WriteWarningLine("请求空托盘");
			if (_taskService.RequestTask(command.ConveyorLineBarcode, stationInfo).Result.Status)
			{
			Dt_Task task = _taskService.QueryTaskByPalletCode(command.ConveyorLineBarcode, stationInfo.Roadway);
			if (task != null)
			{
			//ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(task);
			//taskCommand.InteractiveSignal = command.InteractiveSignal;
			//taskCommand.ResponState = 1;
			//taskCommand.ConveyorLineTaskNum = task.TaskNum;
			//taskCommand.ConveyorLineTargetAddress = Convert.ToInt16(task.NextAddress);
			//conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 1, stationInfo.stationChildCode);
			//conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, 1, task.NextAddress);
			//ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			}
			@@ -186,6 +226,30 @@
			// }
			//}

			private async Task GetEmptyTrayAsync(Dt_StationManager stationManager)
			{
			var config = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
			var wmsBase = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.WMSIP_BASE)?.ConfigValue;
			var requestTask = config.FirstOrDefault(x => x.ConfigKey == SysConfigKeyConst.GetFROutTrayToCW)?.ConfigValue;
			if (wmsBase == null \|\| requestTask == null)
			{
			throw new InvalidOperationException("WMS IP 未配置");
			}
			var wmsIpAddrss = wmsBase + requestTask;

			var result = await HttpHelper.PostAsync(wmsIpAddrss, new { palletCode = "", EquiCodeMOM = stationManager.stationEquipMOM, Roadways = stationManager.Roadway, area = stationManager.stationArea, Position = stationManager.stationChildCode }.ToJsonString());
			WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);
			if(!content.Status)
			{
			//ConsoleHelper.WriteErrorLine($"分容呼叫空托盘失败{content.Message}");
			return;
			}
			WMSTaskDTO wMSTaskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());

			ConsoleHelper.WriteSuccessLine(content.Data.ToString());
			List<WMSTaskDTO> wMSTaskDTOs = new List<WMSTaskDTO>() { wMSTaskDTO };
			_taskService.ReceiveWMSTask(wMSTaskDTOs);
			}
			}
			}
			#endregion