HuaYiZhongHeng/BaiBuLiKu.git

			@@ -20,11 +20,9 @@
			using AutoMapper;
			using HslCommunication;
			using Newtonsoft.Json;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
			using Quartz;
			using SqlSugar;
			using System.Reflection;
			using System.Threading.Tasks;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Core;
			using WIDESEAWCS_Core.Helper;
			@@ -121,7 +119,7 @@
			{
			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 });
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			}
			}
			else
			@@ -140,7 +138,7 @@
			{
			command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
			int count = strings.Count - index;
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count });
			method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
			}
			}
			}
			@@ -177,140 +175,28 @@
			/// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param>
			public void RequestInbound(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int ProtocalDetailValue)
			{
			// 获取下一个任务
			var task = _taskService.QueryBarCodeConveyorLineTask(command.Barcode, childDeviceCode);
			//var taskOut = _taskService.QueryNextConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			//return;
			// 处理出库任务
			HandleTaskOut(conveyorLine, command, childDeviceCode, ProtocalDetailValue, task);

			// 如果没有出库任务，处理新任务
			if (task == null)
			try
			{
			HandleNewTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
			// 获取下一个任务
			var task = _taskService.QueryBarCodeConveyorLineTask(command.Barcode, childDeviceCode);
			//var taskOut = _taskService.QueryNextConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			//return;
			// 处理出库任务
			HandleTaskOut(conveyorLine, command, childDeviceCode, ProtocalDetailValue, task);

			// 如果没有出库任务，处理新任务
			if (task == null && command.Barcode != "NoRead")
			{
			HandleNewTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
			}
			}

			#region 老版本

			//var taskNew = _taskService.QueryCraneConveyorLineTask(command.Barcode.ObjToInt(), childDeviceCode);
			//var Taskout = _taskService.QueryNextConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			//if (Taskout != null)
			//{
			// // 空托盘任务
			// if (Taskout.TaskType == (int)TaskOutboundTypeEnum.OutTray)
			// {
			// ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(Taskout);
			// taskCommand.InteractiveSignal = command.InteractiveSignal;
			// if (command.Barcode == "")
			// {
			// var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == Taskout.TargetAddress).Capacity;
			// taskCommand.TargetAddress = NGAddress;
			// }
			// conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);

			// _taskService.UpdateTaskStatusToNext(Taskout);
			// }
			// else if (Taskout.TaskType == (int)TaskOutboundTypeEnum.Outbound)
			// {
			// ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(Taskout);
			// taskCommand.InteractiveSignal = command.InteractiveSignal;
			// if (Taskout.TaskState == (int)TaskOutStatusEnum.SC_OutFinish)
			// {
			// if (command.Barcode == "")
			// {
			// var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == Taskout.TargetAddress).Capacity;
			// taskCommand.TargetAddress = NGAddress;
			// }
			// conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);

			// _taskService.UpdateTaskStatusToNext(Taskout);
			// }
			// else if (Taskout.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting)
			// {
			// if (command.Barcode == "")
			// {
			// var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == Taskout.TargetAddress).Capacity;
			// taskCommand.TargetAddress = NGAddress;

			// conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			// _taskService.UpdateTaskStatusToNext(Taskout);
			// }
			// else
			// {
			// // todo 调用WMS任务完成接口
			// var x = new { taskNum = Taskout.TaskNum };
			// var result = HttpHelper.GetAsync("http:127.0.0.1:8098/api/Task/CompleteTaskAsync", x.ToJsonString()).Result;
			// WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);
			// if (content.Status)
			// {
			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			// _taskService.UpdateTaskStatusToNext(Taskout);
			// }
			// }
			// }
			// }
			//}
			//if (taskNew == null)
			//{
			// // 化成->陈化空托盘回流
			// if (conveyorLine.DeviceCode == "1003" && childDeviceCode == "1016")
			// {
			// //TODO 调用WMS创建化成->陈化空托盘回流
			// WMSTaskDTO taskDTO = new WMSTaskDTO()
			// {
			// TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
			// Grade = 1,
			// PalletCode = command.Barcode,
			// RoadWay = "CHSC01",
			// SourceAddress = childDeviceCode,
			// TargetAddress = "CHSC01",
			// TaskState = (int)TaskInStatusEnum.InNew,
			// Id = 0,
			// TaskType = (int)TaskInboundTypeEnum.InTray,
			// };
			// WebResponseContent content = CreateAndSendTask(taskDTO);
			// if (content.Status)
			// {
			// Dt_Task task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			// if (task != null)
			// {
			// ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			// taskCommand.InteractiveSignal = command.InteractiveSignal;
			// conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);

			// _taskService.UpdateTaskStatusToNext(task);
			// }
			// }
			// }
			// else
			// {
			// if (_taskService.RequestWMSTask(command.Barcode, childDeviceCode).Status)
			// {
			// Dt_Task task = _taskService.QueryConveyorLineTask(conveyorLine.DeviceCode, childDeviceCode);
			// if (task != null)
			// {
			// ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			// taskCommand.InteractiveSignal = command.InteractiveSignal;
			// conveyorLine.SendCommand(taskCommand, childDeviceCode);

			// ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);

			// _taskService.UpdateTaskStatusToNext(task);
			// }
			// }
			// }
			//}

			#endregion
			catch (Exception ex)
			{
			return;
			}
			}

			#region 输送线请求入库下一地址

			/// <summary>
			/// 输送线请求入库下一地址
			@@ -318,20 +204,22 @@
			/// <param name="conveyorLine">输送线实例对象</param>
			/// <param name="command">读取的请求信息</param>
			/// <param name="childDeviceCode">子设备编号</param>
			public void RequestInNextAddress(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode)
			{
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress);
			if (newTask != null)
			{
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(newTask);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			conveyorLine.SendCommand(taskCommand, childDeviceCode);
			}
			}
			}
			//public void RequestInNextAddress(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode)
			//{
			// Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			// if (task != null)
			// {
			// Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress);
			// if (newTask != null)
			// {
			// ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(newTask);
			// taskCommand.InteractiveSignal = command.InteractiveSignal;
			// conveyorLine.SendCommand(taskCommand, childDeviceCode);
			// }
			// }
			//}

			#endregion

			/// <summary>
			/// 输送线入库完成
			@@ -350,7 +238,7 @@
			//conveyorLine.SetValue(ConveyorLineDBName.WriteInteractiveSignal, 0, childDeviceCode);
			WebResponseContent content = _taskService.UpdateTaskStatusToNext(task);

			Console.Out.WriteLine(content.Serialize());
			//Console.Out.WriteLine(content.Serialize());
			}
			}

			@@ -407,28 +295,86 @@
			Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
			if (task != null)
			{
			WebResponseContent content = new WebResponseContent();
			ConveyorLineTaskCommand taskCommand = _mapper.Map<ConveyorLineTaskCommand>(task);
			taskCommand.InteractiveSignal = command.InteractiveSignal;
			if (task.PalletCode != command.Barcode)
			{
			var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == task.TargetAddress).Capacity;
			taskCommand.TargetAddress = NGAddress;
			conveyorLine.SendCommand(taskCommand, childDeviceCode);
			}
			else
			{
			taskCommand.TargetAddress = 0;
			}
			// TODO调用任务完成执行任务完成

			conveyorLine.SendCommand(taskCommand, childDeviceCode);
			ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
			WebResponseContent content = _taskService.UpdateTaskStatusToNext(task);
			content = _taskService.UpdateTaskStatusToNext(task);
			}
			}

			/// <summary>
			/// 创建任务并发送请求
			/// 监测空托盘实盘出库
			/// </summary>
			private WebResponseContent CreateAndSendTask(WMSTaskDTO taskDTO)
			/// <param name="conveyorLine">输送线实例对象</param>
			/// <param name="command">读取的请求信息</param>
			/// <param name="childDeviceCode">子设备编号</param>
			/// <param name="index">线体当前bool读取偏移地址</param>
			public async void EmptyTrayReturn(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int index, Platform platform)
			{
			try
			{
			TaskOutboundTypeEnum taskOutboundTypeEnum;
			if (platform.PlatformType.Contains("OutTray"))
			taskOutboundTypeEnum = TaskOutboundTypeEnum.OutTray;
			else
			taskOutboundTypeEnum = TaskOutboundTypeEnum.Outbound;
			await CheckAndCreateTask(taskOutboundTypeEnum, childDeviceCode, index, platform.Stacker.Split(',')[0], platform.Stacker.Split(',').ToList());
			}
			catch (Exception)
			{
			}
			}

			/// <summary>
			/// 检查任务并创建新任务
			/// </summary>
			private async Task CheckAndCreateTask(TaskOutboundTypeEnum taskType, string childDeviceCode, int index, string roadWay, List<string> roadways = null)
			{
			var tasks = _taskRepository.QueryData(x => x.TaskType == (int)taskType && x.TargetAddress == childDeviceCode);
			if (tasks.Count < index)
			{
			#region 调用WMS获取出库任务

			WMSTaskDTO taskDTO = new WMSTaskDTO();
			object dynamic = new
			{
			position = childDeviceCode,
			tag = (int)taskType,
			areaCdoe = roadWay,
			roadways = roadways
			};
			var result = await HttpHelper.PostAsync("http://localhost:5000/api/Task/RequestTrayOutTaskAsync", dynamic.ToJsonString());

			WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);

			// 检查状态并返回
			if (!content.Status)
			return;

			taskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());

			#endregion

			CreateAndSendTask(taskDTO);
			}
			}

			/// <summary>
			/// 创建任务
			/// </summary>
			public WebResponseContent CreateAndSendTask(WMSTaskDTO taskDTO)
			{
			var content = _taskService.ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO });
			if (content.Status)
			@@ -436,66 +382,6 @@
			Console.WriteLine($"{taskDTO.TaskType}呼叫成功");
			}
			return content;
			}

			/// <summary>
			/// 陈化空托盘出库
			/// </summary>
			/// <param name="conveyorLine">输送线实例对象</param>
			/// <param name="command">读取的请求信息</param>
			/// <param name="childDeviceCode">子设备编号</param>
			/// <param name="index">线体当前bool读取偏移地址</param>
			public void EmptyTrayReturn(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int index)
			{
			CheckAndCreateTask((int)TaskOutboundTypeEnum.OutTray, childDeviceCode, index, "CHSC01", "001-001-001");
			}

			/// 静置空托盘出库
			/// </summary>
			/// <param name="conveyorLine">输送线实例对象</param>
			/// <param name="command">读取的请求信息</param>
			/// <param name="childDeviceCode">子设备编号</param>
			/// <param name="index">线体当前bool读取偏移地址</param>
			public void EmptyTrayOutbound(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int index)
			{
			CheckAndCreateTask((int)TaskOutboundTypeEnum.OutTray, childDeviceCode, index, "JZSC01", "002-020-001");
			}

			/// <summary>
			/// 陈化出库(实盘)
			/// </summary>
			/// <param name="conveyorLine">输送线实例对象</param>
			/// <param name="command">读取的请求信息</param>
			/// <param name="childDeviceCode">子设备编号</param>
			/// <param name="index">线体当前bool读取偏移地址</param>
			public void ChuanhuaOutbound(CommonConveyorLine conveyorLine, ConveyorLineTaskCommand command, string childDeviceCode, int index)
			{
			CheckAndCreateTask((int)TaskOutboundTypeEnum.Outbound, childDeviceCode, index, "CHSC01", "001-001-001");
			}

			/// <summary>
			/// 检查任务并创建新任务
			/// </summary>
			private void CheckAndCreateTask(int taskType, string childDeviceCode, int index, string roadWay, string sourceAddress)
			{
			var tasks = _taskRepository.QueryData(x => x.TaskType == taskType && x.TargetAddress == childDeviceCode);
			if (tasks.Count < index)
			{
			var taskDTO = new WMSTaskDTO()
			{
			TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
			Grade = 1,
			PalletCode = DateTime.Now.ToString("yyyyMMddHHmmss"),
			RoadWay = roadWay,
			SourceAddress = sourceAddress,
			TargetAddress = childDeviceCode,
			TaskState = (int)TaskOutStatusEnum.OutNew,
			Id = 0,
			TaskType = taskType
			};

			CreateAndSendTask(taskDTO);
			}
			}

			/// <summary>