SuZhouGuanHong/ShanMeiXinNengYuan.git

			@@ -1,4 +1,5 @@
			#region << 版本注释 >>

			/*----------------------------------------------------------------
			* 命名空间：WIDESEAWCS_TaskInfoService
			* 创建者：胡童庆
			@@ -11,17 +12,21 @@
			* 修改时间：
			* 版本：V1.0.1
			* 修改说明：
			*
			*
			----------------------------------------------------------------/

			#endregion << 版本注释 >>

			using AutoMapper;
			using SqlSugar;
			using System.Diagnostics.CodeAnalysis;
			using System.Text.Json;
			using WIDESEAWCS_Common.HttpEnum;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Core;
			using WIDESEAWCS_Core.BaseServices;
			using WIDESEAWCS_Core.Enums;
			using WIDESEAWCS_Core.Http;
			using WIDESEAWCS_DTO.TaskInfo;
			using WIDESEAWCS_ITaskInfoRepository;
			using WIDESEAWCS_ITaskInfoService;
			@@ -44,11 +49,14 @@
			{nameof(Dt_Task.CreateDate),OrderByType.Asc},
			};

			public Dictionary<string, OrderByType> TaskOrderBy { get { return _taskOrderBy; } set { _taskOrderBy = value; } }
			public Dictionary<string, OrderByType> TaskOrderBy
			{ get { return _taskOrderBy; } set { _taskOrderBy = value; } }

			public List<int> TaskInboundTypes => typeof(TaskInboundTypeEnum).GetEnumIndexList();

			public List<int> TaskOutboundTypes => typeof(TaskOutboundTypeEnum).GetEnumIndexList();

			public List<int> TaskRobotTypes => typeof(TaskOtherTypeEnum).GetEnumIndexList();

			public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, IMapper mapper) : base(BaseDal)
			{
			@@ -353,11 +361,43 @@

			if (task.TaskState == (int)TaskInStatusEnum.Line_InFinish)
			{
			Random random = new Random();
			// 调用WMS系统接口，获取最终目标地址
			CreateTaskDto taskDto = new CreateTaskDto()
			{
			Roadway = task.TargetAddress,
			PalletCode = task.PalletCode,
			SourceAddress = task.SourceAddress,
			// 目标地址待定
			TargetAddress = "CLOutAreaA",
			TaskType = task.TaskType,
			};
			content = HttpRequestHelper.HTTPPostAsync(nameof(Category.WMS), taskDto.ToString(), nameof(ConfigKey.GetTasksLocation)).Result;
			if (!content.Status)
			{
			return WebResponseContent.Instance.Error($"调用WMS接口获取任务目标地址失败,任务号:【{task.TaskNum}】,错误信息:【{content.Message}】");
			}

			string wmsTargetAddress = content.Data?.ToString() ?? string.Empty;
			if (string.IsNullOrEmpty(wmsTargetAddress))
			{
			return WebResponseContent.Instance.Error($"调用WMS接口获取任务目标地址失败,任务号:【{task.TaskNum}】,错误信息:【未获取到有效的目标地址】");
			}

			task.NextAddress = wmsTargetAddress;
			task.TargetAddress = wmsTargetAddress;
			task.CurrentAddress = task.NextAddress;
			task.NextAddress = $"{random.Next(1, 100).ToString().PadLeft(3, '0')}-{random.Next(1, 100).ToString().PadLeft(3, '0')}-{random.Next(1, 100).ToString().PadLeft(3, '0')}";
			task.TargetAddress = task.NextAddress;
			}
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup)
			{
			if (task.TaskState >= (int)TaskRobotStatusEnum.RobotNew)
			{
			return content = WebResponseContent.Instance.Error($"该任务状态不可跳转到下一步,任务号:【{task.TaskNum}】,任务状态:【{task.TaskState}】");
			}

			int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskRobotStatusEnum>();

			task.TaskState = nextStatus;
			}
			else
			{
			@@ -400,11 +440,11 @@
			string oldCurrentPos = task.CurrentAddress;
			string oldNextPos = task.NextAddress;

			List<Dt_Router> routers = _routerService.QueryNextRoutes(task.NextAddress, task.TargetAddress);
			if (!routers.Any()) throw new Exception($"未找到设备路由信息");
			Dt_Router routers = _routerService.QueryNextRoute(task.CurrentAddress);
			if (routers == null) throw new Exception($"未找到设备路由信息");

			task.CurrentAddress = task.NextAddress;
			task.NextAddress = routers.FirstOrDefault().ChildPosi;
			task.NextAddress = routers.ChildPosi;

			task.ModifyDate = DateTime.Now;
			task.Modifier = "System";
			@@ -452,7 +492,7 @@
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup && task.TaskState == (int)TaskInStatusEnum.SC_InExecuting)
			{
			//todo
			//todo
			int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskInStatusEnum>();
			task.TaskState = nextStatus;
			task.ModifyDate = DateTime.Now;
			@@ -481,7 +521,6 @@
			}
			else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup)
			{

			}
			else
			{
			@@ -598,5 +637,29 @@
			BaseDal.DeleteAndMoveIntoHty(tasks, OperateTypeEnum.人工删除);
			return WebResponseContent.Instance.OK($"成功删除{tasks.Count}条数据");
			}

			/// <summary>
			/// 根据设备编号、当前地址按照优先级以及创建时间排序查询任务池新增的任务
			/// </summary>
			/// <param name="deviceNo">设备编号</param>
			/// <param name="currentAddress">当前地址</param>
			/// <returns>返回任务实体对象，可能为null</returns>
			public Dt_Task QueryRobotCraneTask(string deviceNo, string currentAddress = "")
			{
			if (string.IsNullOrEmpty(currentAddress))
			return BaseDal.QueryFirst(x => x.Roadway == deviceNo && (TaskRobotTypes.Contains(x.TaskType) && x.TaskState <= (int)TaskRobotStatusEnum.RobotExecuting), TaskOrderBy);
			else
			return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskRobotTypes.Contains(x.TaskType) && x.CurrentAddress == currentAddress && x.TaskState <= (int)TaskRobotStatusEnum.RobotExecuting, TaskOrderBy);
			}

			/// <summary>
			/// 获取与指定任务编号关联的任务。
			/// </summary>
			/// <param name="taskNum">要获取的任务的唯一标识符。</param>
			/// <returns>表示指定编号任务的<see cref="Dt_Task"/>对象，如果不存在该任务则返回<c>null</c>。</returns>
			public Dt_Task QueryByTaskNum(int taskNum)
			{
			return BaseDal.QueryFirst(x => x.TaskNum == taskNum);
			}
			}
			}
			}