RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -20,13 +20,75 @@
			{
			public partial class TaskJob
			{

			#region ä¸åååè½¦å¥åºä»»å¡
			/// <summary>
			/// ä¸åååè½¦æ°å»ºå¥åºä»»å¡
			/// </summary>
			/// <param name="tasks"></param>
			public void SendRGVInTask(List<Dt_Task> tasks)
			public void SendRGVNewInTask(List<Dt_Task> tasks)
			{
			FOURBOTnewMovePodTask fOURBOTnewMovePodTask = new();
			WebResponseContent content = new WebResponseContent();
			try
			{
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(FOURBOTnewMovePodTask)) ?? throw new Exception("æªæ¾å°ååè½¦ä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			int i = 0;
			foreach (var task in tasks)
			{
			i++;
			fOURBOTnewMovePodTask = new()
			{
			priority = task.Grade,
			podID = task.PalletCode,
			desExt = new
			{
			unload = 0//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			},
			desStationCodes = task.SourceAddress,
			desType = 5
			};
			fOURBOTnewMovePodTask.requestID += i;
			try
			{
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);

			string dataJson = fOURBOTReturn.data.ToString();
			FOURBOTnewMovePodTaskResponseData? fOURBO = JsonConvert.DeserializeObject<FOURBOTnewMovePodTaskResponseData>(dataJson);
			if (fOURBO == null \|\| fOURBO.taskID == 0)
			{
			throw new Exception($"æªè·åå°ååè½¦è¿åçä»»å¡IDï¼è¿åæ°æ®ï¼{response}");
			}
			//FOURBOTnewMovePodTaskResponseData fOURBO = fOURBOTReturn.data as FOURBOTnewMovePodTaskResponseData ?? throw new Exception("æªè·åå°ååè½¦è¿åçä»»å¡ID");
			task.RGVTaskId = fOURBO.taskID;
			task.ExceptionMessage = "";
			task.TaskState = (int)TaskStatusEnum.Execut;
			}
			catch (Exception ex)
			{
			task.ExceptionMessage = ex.Message;
			}
			}
			_taskService.UpdateData(tasks);
			content.OK();
			}
			catch (Exception ex)
			{
			content.Error(ex.Message);
			}
			finally
			{
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åååè½¦æ°å»ºå¥åºä»»å¡", "", "");
			}
			}

			#region
			/// <summary>
			/// ä¸åååè½¦å¤å½¢æ£æµä»»å¡
			/// </summary>
			/// <param name="tasks"></param>
			public void SendRGVCheckShapeTask(List<Dt_Task> tasks)
			{
			FOURBOTnewMovePodTask fOURBOTnewMovePodTask = new();
			WebResponseContent content = new WebResponseContent();
			@@ -62,7 +124,7 @@
			}
			//FOURBOTnewMovePodTaskResponseData fOURBO = fOURBOTReturn.data as FOURBOTnewMovePodTaskResponseData ?? throw new Exception("æªè·åå°ååè½¦è¿åçä»»å¡ID");
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Execut;
			item.TaskState = (int)TaskStatusEnum.TakeFinish;
			}
			}
			_taskService.UpdateData(tasks);
			@@ -91,7 +153,7 @@
			WebResponseContent content = new WebResponseContent();
			try
			{
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(GetBlockPodContentDto)) ?? throw new Exception("æªæ¾å°ååè½¦ä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(GetBlockPodContentDto)) ?? throw new Exception("æªæ¾å°æ¹éè·åé»ç¢æçå³ç³»æ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			List<Dt_Task> dt_Tasks = new List<Dt_Task>();
			var PalletCodes = tasks.Select(x => x.PalletCode).ToList();
			//GetBlockPodContentDto content = new GetBlockPodContentDto();
			@@ -125,7 +187,7 @@
			foreach (var item in Result.outPods)
			{
			var task = tasks.First(x => x.PalletCode == item.outPod);
			if (item.blockPods.Count > 0)
			if (item.blockPods != null && item.blockPods.Count > 0)
			{
			task.TaskState = (int)TaskStatusEnum.RGV_WaitMoveToExecute;
			dt_Tasks.Add(task);
			@@ -169,64 +231,68 @@
			var locationsToUpdate = new List<Dt_RGVLocationInfo>();
			var stationsToUpdate = new List<Dt_StationManger>();
			#region ä»»å¡ä¸å
			foreach (var item in tasks)
			var item = tasks.FirstOrDefault();
			if (item != null)
			{
			try
			{
			#region è·åè´§ä½
			var rGVLocationInfo = _rGVLocationInfoService.GetFreeLocationInfo(item.Roadway);
			var rGVLocationInfo = _rGVLocationInfoService.GetInFreeLocationInfo(item.Roadway);
			if (rGVLocationInfo == null)
			{
			item.ExceptionMessage = $"æªæ¾å°ç»ç¹åºåºã{item.Roadway}ãå¯ç¨ç©ºè´§ä½ï¼";
			continue;
			}
			#endregion
			fOURBOTnewMovePodTask = new FOURBOTnewMovePodTask
			{
			priority = item.Grade,
			podID = item.PalletCode,
			desStorageID = rGVLocationInfo.LocationCode,
			//destination = rGVLocationInfo.LocationCode,
			desExt = new { unload = 1 }, // æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			desType = 2
			};
			fOURBOTnewMovePodTask.taskExt = new
			{
			autoToRest = 1
			};
			item.CurrentAddress = item.NextAddress;
			item.NextAddress = rGVLocationInfo.LocationCode;
			item.TargetAddress = rGVLocationInfo.LocationCode;
			item.Roadway = rGVLocationInfo.RoadwayNo;

			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			var fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			if (fOURBOTReturn.returnCode == 0)
			{
			var data = fOURBOTReturn.data.ToString();
			var fOURBO = data.DeserializeObject<FOURBOTnewMovePodTaskResponseData>();
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Puting;

			rGVLocationInfo.LocationStatus = LocationStatusEnum.InLock.ObjToInt();
			locationsToUpdate.Add(rGVLocationInfo);

			#region éæ¾å¥åºç«å°
			var stationManger = _stationMangerService.GetInStationInfo(item.SourceAddress);
			if (stationManger != null)
			{
			stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
			stationsToUpdate.Add(stationManger);
			}
			content.OK();
			#endregion
			}
			else
			{
			item.ExceptionMessage = $"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}";
			// è®°å½å¤±è´¥çä»»å¡
			content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}");
			fOURBOTnewMovePodTask = new FOURBOTnewMovePodTask
			{
			priority = item.Grade,
			podID = item.PalletCode,
			desStorageID = rGVLocationInfo.LocationCode,
			//destination = rGVLocationInfo.LocationCode,
			desExt = new { unload = 1 }, // æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			desType = 2
			};
			fOURBOTnewMovePodTask.taskExt = new
			{
			autoToRest = 1
			};
			item.CurrentAddress = item.NextAddress;
			item.NextAddress = rGVLocationInfo.LocationCode;
			item.TargetAddress = rGVLocationInfo.LocationCode;
			item.Roadway = rGVLocationInfo.RoadwayNo;

			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			var fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			if (fOURBOTReturn.returnCode == 0)
			{
			var data = fOURBOTReturn.data.ToString();
			var fOURBO = data.DeserializeObject<FOURBOTnewMovePodTaskResponseData>();
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Puting;

			rGVLocationInfo.LocationStatus = LocationStatusEnum.InLock.ObjToInt();
			locationsToUpdate.Add(rGVLocationInfo);

			#region éæ¾å¥åºç«å°
			var stationManger = _stationMangerService.GetInStationInfo(item.SourceAddress);
			if (stationManger != null)
			{
			stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
			stationsToUpdate.Add(stationManger);
			}
			content.OK();
			#endregion
			}
			else
			{
			item.ExceptionMessage = $"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}";
			// è®°å½å¤±è´¥çä»»å¡
			content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}");
			}
			tasksToUpdate.Add(item);
			}
			}
			catch (Exception ex)
			@@ -235,8 +301,77 @@
			//WriteError($"{nameof(TaskJob)}-{item.TaskId}", ex.Message, ex);
			content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{ex.Message}");
			}
			tasksToUpdate.Add(item);
			}
			#region MyRegion
			//foreach (var item in tasks)
			//{
			// try
			// {
			// #region è·åè´§ä½
			// var rGVLocationInfo = _rGVLocationInfoService.GetFreeLocationInfo(item.Roadway);
			// if (rGVLocationInfo == null)
			// {
			// item.ExceptionMessage = $"æªæ¾å°ç»ç¹åºåºã{item.Roadway}ãå¯ç¨ç©ºè´§ä½ï¼";
			// continue;
			// }
			// #endregion
			// fOURBOTnewMovePodTask = new FOURBOTnewMovePodTask
			// {
			// priority = item.Grade,
			// podID = item.PalletCode,
			// desStorageID = rGVLocationInfo.LocationCode,
			// //destination = rGVLocationInfo.LocationCode,
			// desExt = new { unload = 1 }, // æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			// desType = 2
			// };
			// fOURBOTnewMovePodTask.taskExt = new
			// {
			// autoToRest = 1
			// };
			// item.CurrentAddress = item.NextAddress;
			// item.NextAddress = rGVLocationInfo.LocationCode;
			// item.TargetAddress = rGVLocationInfo.LocationCode;
			// item.Roadway = rGVLocationInfo.RoadwayNo;

			// string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			// var fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			// content.Data = fOURBOTReturn;
			// if (fOURBOTReturn.returnCode == 0)
			// {
			// var data = fOURBOTReturn.data.ToString();
			// var fOURBO = data.DeserializeObject<FOURBOTnewMovePodTaskResponseData>();
			// item.RGVTaskId = fOURBO.taskID;
			// item.TaskState = (int)TaskStatusEnum.Puting;

			// rGVLocationInfo.LocationStatus = LocationStatusEnum.InLock.ObjToInt();
			// locationsToUpdate.Add(rGVLocationInfo);

			// #region éæ¾å¥åºç«å°
			// var stationManger = _stationMangerService.GetInStationInfo(item.SourceAddress);
			// if (stationManger != null)
			// {
			// stationManger.IsOccupied = LocationStatusEnum.Free.ObjToInt();
			// stationsToUpdate.Add(stationManger);
			// }
			// content.OK();
			// #endregion
			// }
			// else
			// {
			// item.ExceptionMessage = $"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}";
			// // è®°å½å¤±è´¥çä»»å¡
			// content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{fOURBOTReturn.returnMsg}");
			// }
			// }
			// catch (Exception ex)
			// {
			// item.ExceptionMessage = $"å¤çä»»å¡å¼å¸¸ï¼{ex.Message}";
			// //WriteError($"{nameof(TaskJob)}-{item.TaskId}", ex.Message, ex);
			// content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{ex.Message}");
			// }
			// tasksToUpdate.Add(item);
			//}
			#endregion
			#endregion
			#region æ´æ°æ°æ®
			// å¦ææéè¦æ´æ°çæ°æ®ï¼ææ§è¡äºå¡
			@@ -290,7 +425,8 @@
			item.NextAddress = stationManger.StationCode;
			fOURBOTnewMovePodTask.priority = item.Grade;
			fOURBOTnewMovePodTask.podID = item.PalletCode;
			fOURBOTnewMovePodTask.destination = item.NextAddress;
			//fOURBOTnewMovePodTask.desNodeID = item.NextAddress;
			fOURBOTnewMovePodTask.desStationCodes = item.NextAddress;
			fOURBOTnewMovePodTask.desExt = new
			{
			unload = 1//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			@@ -342,7 +478,7 @@
			if (FreeLocationInfos.Count < 1) throw new Exception($"æååºåå»ºç§»åºä»»å¡æ å¯ç¨ç©ºè´§ä½");
			foreach (var item in rGVLocationInfos)
			{
			Dt_RGVLocationInfo? rGVLocationInfo = FreeLocationInfos.Where(x => x.Layer == item.Layer).OrderBy(n => Math.Abs(n.Row - item.Row)).FirstOrDefault();
			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()
			{
			@@ -382,21 +518,21 @@
			{
			WebResponseContent content = new WebResponseContent();
			List<Dt_Task> dt_Tasks = new List<Dt_Task>();
			List<MoveBlockPodContentDto> moveBlocks = new List<MoveBlockPodContentDto>();
			MoveBlockPodContentDto moveBlock = new MoveBlockPodContentDto();
			try
			{

			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(MoveBlockPodContentDto)) ?? throw new Exception("æªæ¾å°ååè½¦æ¹éæ¬è¿é»ç¢æä»»å¡æ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			foreach (var item in tasks)
			{
			MoveBlockPodContentDto moveBlock = new MoveBlockPodContentDto()
			MoveBlockPodContentDtoInfo moveBlockInfo = new MoveBlockPodContentDtoInfo()
			{
			podID = item.PalletCode,
			des = item.TargetAddress
			};
			moveBlocks.Add(moveBlock);
			moveBlock.content.Add(moveBlockInfo);
			}
			string response = HttpHelper.Post(apiInfo.ApiAddress, moveBlocks.Serialize());
			string response = HttpHelper.Post(apiInfo.ApiAddress, moveBlock.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			if (fOURBOTReturn.returnCode == 0)
			@@ -428,7 +564,7 @@
			}
			finally
			{
			_trackloginfoService.AddTrackLog(moveBlocks, content, "ä¸åååè½¦æ¹éç§»åºä»»å¡", "", "");
			_trackloginfoService.AddTrackLog(moveBlock, content, "ä¸åååè½¦æ¹éç§»åºä»»å¡", "", "");
			}
			}
			#endregion
			@@ -463,24 +599,28 @@
			try
			{
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(FOURBOTnewMovePodTask)) ?? throw new Exception("æªæ¾å°ååè½¦ä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			var i = 0;
			foreach (var item in tasks)
			{
			i++;
			var stationManger = _stationMangerService.GetOutStationInfo(item.TargetAddress);
			item.NextAddress = stationManger.StationCode;
			if (stationManger.IsOccupied != LocationStatusEnum.Free.ObjToInt()) continue;
			#region ä¸ååºåºä»»å¡
			fOURBOTnewMovePodTask.priority = item.Grade;
			fOURBOTnewMovePodTask.podID = item.PalletCode;
			fOURBOTnewMovePodTask.destination = item.NextAddress;
			//fOURBOTnewMovePodTask.desNodeID = item.NextAddress;
			fOURBOTnewMovePodTask.desStationCodes = item.NextAddress;
			fOURBOTnewMovePodTask.desExt = new
			{
			unload = 0//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			unload = 1//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			};
			fOURBOTnewMovePodTask.taskExt = new
			{
			autoToRest = 1
			};
			fOURBOTnewMovePodTask.desType = 5;
			fOURBOTnewMovePodTask.requestID = DateTime.Now.ToString("yyyyMMddHHmmss") + i;
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;