RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -1,6 +1,7 @@
			ï»¿using Newtonsoft.Json;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
			using System;
			using System.Collections;
			using System.Collections.Generic;
			using System.Linq;
			using System.Text;
			@@ -51,7 +52,7 @@
			{
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);

			string dataJson = fOURBOTReturn.data.ToString();
			@@ -113,7 +114,7 @@
			fOURBOTnewMovePodTask.desNodeID = item.NextAddress;
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0)
			{
			string dataJson = fOURBOTReturn.data.ToString();
			@@ -172,7 +173,7 @@
			//content.candidatePodIDs = tasks.Select(x => x.PalletCode).ToList();
			string response = HttpHelper.Post(apiInfo.ApiAddress, request.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0)
			{
			//ReturnBlockPodResultDto getBlockPod = fOURBOTReturn.data as ReturnBlockPodResultDto ?? throw new Exception("æªè·åå°é»ç¢æçå³ç³»æ°æ®");
			@@ -188,10 +189,16 @@
			{
			var task = tasks.First(x => x.PalletCode == item.outPod);
			if (item.blockPods != null && item.blockPods.Count > 0)
			item.blockPods = item.blockPods.Except(PalletCodes).ToList();
			if (item.blockPods != null && item.blockPods.Count > 0)
			{
			task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
			#region å¤æé»ç¢ææ¯å¦ä¸ºåºåºä»»å¡
			//var except = item.blockPods.Except(PalletCodes).ToList();
			#endregion
			var responseContent = AddMoveTask(item.blockPods, task);//æ·»å ç§»åºä»»å¡
			if (!responseContent.Status) task.ExceptionMessage = responseContent.Message;
			else task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
			dt_Tasks.Add(task);
			AddMoveTask(item.blockPods);//æ·»å ç§»åºä»»å¡
			}
			else
			{
			@@ -237,7 +244,7 @@
			try
			{
			#region è·åè´§ä½
			var rGVLocationInfo = _rGVLocationInfoService.GetInFreeLocationInfo(item.Roadway);
			var rGVLocationInfo = _rGVLocationInfoService.GetInFreeLocationInfo(item.Roadway.ObjToInt());
			if (rGVLocationInfo == null)
			{
			item.ExceptionMessage = $"æªæ¾å°ç»ç¹åºåºã{item.Roadway}ãå¯ç¨ç©ºè´§ä½ï¼";
			@@ -265,7 +272,7 @@

			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			var fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0)
			{
			var data = fOURBOTReturn.data.ToString();
			@@ -277,12 +284,12 @@
			locationsToUpdate.Add(rGVLocationInfo);

			#region éæ¾å¥åºç«å°
			var stationManger = _stationMangerService.GetInStationInfo(item.SourceAddress);
			if (stationManger != null)
			{
			stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
			stationsToUpdate.Add(stationManger);
			}
			//var stationManger = _stationMangerService.GetInStationInfo(item.SourceAddress);
			//if (stationManger != null)
			//{
			// stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
			// stationsToUpdate.Add(stationManger);
			//}
			content.OK();
			#endregion
			}
			@@ -385,8 +392,8 @@
			_taskService.UpdateData(tasksToUpdate);
			if (locationsToUpdate.Any())
			_rGVLocationInfoService.UpdateData(locationsToUpdate);
			if (stationsToUpdate.Any())
			_stationMangerService.UpdateData(stationsToUpdate);
			//if (stationsToUpdate.Any())
			// _stationMangerService.UpdateData(stationsToUpdate);

			_unitOfWorkManage.CommitTran();
			}
			@@ -444,6 +451,7 @@
			//FOURBOTnewMovePodTaskResponseData fOURBO = fOURBOTReturn.data as FOURBOTnewMovePodTaskResponseData ?? throw new Exception("æªè·åå°ååè½¦è¿åçä»»å¡ID");
			string dataJson = fOURBOTReturn.data.ToString();
			FOURBOTnewMovePodTaskResponseData? fOURBO = JsonConvert.DeserializeObject<FOURBOTnewMovePodTaskResponseData>(dataJson);
			content.OK(data: fOURBO);
			if (fOURBO == null \|\| fOURBO.taskID == 0)
			{
			throw new Exception($"æªè·åå°ååè½¦è¿åçä»»å¡IDï¼è¿åæ°æ®ï¼{response}");
			@@ -467,49 +475,51 @@
			#endregion

			#region æ·»å ç§»åºä»»å¡
			public void AddMoveTask(List<string> blockPods)
			public WebResponseContent AddMoveTask(List<string> blockPods, Dt_Task task)
			{
			WebResponseContent content = new WebResponseContent();
			try
			{
			List<Dt_Task> tasks = new List<Dt_Task>();
			List<Dt_RGVLocationInfo> _UpRGVLocationInfos = new List<Dt_RGVLocationInfo>();
			List<Dt_RGVLocationInfo> rGVLocationInfos = _rGVLocationInfoService.Repository.QueryData(x => blockPods.Contains(x.PalletCode));
			var FreeLocationInfos = _rGVLocationInfoService.GetFreeLocationInfos();
			if (FreeLocationInfos.Count < 1) throw new Exception($"æååºåå»ºç§»åºä»»å¡æ å¯ç¨ç©ºè´§ä½");
			foreach (var item in rGVLocationInfos)
			var Items = _rGVLocationInfoService.GetMoveFreeLocationInfo(rGVLocationInfos);

			List<Dt_Task> tasks = Items.Item1;
			List<Dt_RGVLocationInfo> _UpRGVLocationInfos = Items.Item2;
			if (tasks.Count < blockPods.Count) throw new Exception("å¯ç§»åºç©ºè´§ä½å°äºéç§»åºæçæ°é");

			tasks.ForEach(x =>
			{
			Dt_RGVLocationInfo? rGVLocationInfo = FreeLocationInfos.Where(x => x.Layer == item.Layer && x.RoadwayNo != item.RoadwayNo).OrderBy(n => Math.Abs(n.Row - item.Row)).FirstOrDefault();
			rGVLocationInfo ??= FreeLocationInfos.First();
			Dt_Task dt_Task = new()
			{
			TaskNum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)),
			//WMSTaskNum = taskDTO.taskCode,
			//WMSId = GetTaskNum(nameof(SequenceEnum.SeqTaskNum)),
			Grade = 1,
			PalletCode = item.PalletCode,
			Roadway = item.RoadwayNo,
			TaskState = TaskStatusEnum.RGV_NewMoveTask.ObjToInt(),
			TaskType = TaskTypeEnum.CPMoveInventory.ObjToInt(),
			SourceAddress = item.LocationCode,
			CurrentAddress = item.LocationCode,
			NextAddress = rGVLocationInfo.LocationCode,
			TargetAddress = rGVLocationInfo.LocationCode,
			Creater = "WCS",
			};
			tasks.Add(dt_Task);
			item.LocationStatus = LocationStatusEnum.MoveLock.ObjToInt();
			rGVLocationInfo.LocationStatus = LocationStatusEnum.MoveLock.ObjToInt();
			_UpRGVLocationInfos.Add(rGVLocationInfo);
			FreeLocationInfos.Remove(rGVLocationInfo);
			x.TaskNum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
			x.WMSTaskNum = task.WMSTaskNum;
			});
			rGVLocationInfos.ForEach(x =>
			{
			x.LocationStatus = LocationStatusEnum.MoveLock.ObjToInt();
			});
			_UpRGVLocationInfos.ForEach(x =>
			{
			x.LocationStatus = LocationStatusEnum.MoveLock.ObjToInt();
			});
			try
			{
			_unitOfWorkManage.BeginTran();
			_rGVLocationInfoService.UpdateData(rGVLocationInfos);
			_rGVLocationInfoService.UpdateData(_UpRGVLocationInfos);
			_taskService.AddData(tasks);
			_unitOfWorkManage.CommitTran();
			content.OK();
			}
			_rGVLocationInfoService.UpdateData(rGVLocationInfos);
			_rGVLocationInfoService.UpdateData(_UpRGVLocationInfos);
			_taskService.AddData(tasks);
			catch (Exception ex)
			{
			_unitOfWorkManage.RollbackTran();
			throw new Exception(ex.Message);
			}
			}
			catch (Exception ex)
			{
			throw new Exception(ex.Message);
			content.Error(ex.Message);
			}
			return content;
			}
			#endregion

			@@ -534,7 +544,7 @@
			}
			string response = HttpHelper.Post(apiInfo.ApiAddress, moveBlock.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0)
			{
			string dataJson = fOURBOTReturn.data.ToString();
			@@ -604,8 +614,12 @@
			{
			i++;
			var stationManger = _stationMangerService.GetOutStationInfo(item.TargetAddress);
			//if (stationManger.IsOccupied != LocationStatusEnum.Free.ObjToInt())
			//{
			// item.ExceptionMessage = $"åºåºç«å°ã{stationManger.StationCode}ãè¢«å ç¨";
			// continue;
			//}
			item.NextAddress = stationManger.StationCode;
			if (stationManger.IsOccupied != LocationStatusEnum.Free.ObjToInt()) continue;
			#region ä¸ååºåºä»»å¡
			fOURBOTnewMovePodTask.priority = item.Grade;
			fOURBOTnewMovePodTask.podID = item.PalletCode;
			@@ -623,7 +637,7 @@
			fOURBOTnewMovePodTask.requestID = DateTime.Now.ToString("yyyyMMddHHmmss") + i;
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0)
			{
			string dataJson = fOURBOTReturn.data.ToString();
			@@ -634,8 +648,8 @@
			}
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Execut;
			stationManger.IsOccupied = LocationStatusEnum.Lock.ObjToInt();
			_stationMangerService.UpdateData(stationManger);
			//stationManger.IsOccupied = LocationStatusEnum.Lock.ObjToInt();
			//_stationMangerService.UpdateData(stationManger);
			}
			#endregion
			}