RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -4,6 +4,7 @@
			using System.Collections;
			using System.Collections.Generic;
			using System.Linq;
			using System.Net.NetworkInformation;
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEAWCS_Common;
			@@ -32,10 +33,8 @@
			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,
			@@ -47,7 +46,7 @@
			desStationCodes = task.SourceAddress,
			desType = 5
			};
			fOURBOTnewMovePodTask.requestID += i;
			fOURBOTnewMovePodTask.requestID += task.TaskId;
			try
			{
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			@@ -65,22 +64,34 @@
			task.RGVTaskId = fOURBO.taskID;
			task.ExceptionMessage = "";
			task.TaskState = (int)TaskStatusEnum.Execut;
			task.Dispatchertime = DateTime.Now;
			}
			catch (Exception ex)
			{
			task.ExceptionMessage = ex.Message;
			content.Error(ex.Message);
			}
			finally
			{
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åååè½¦æ°å»ºå¥åºä»»å¡", "", "");
			}
			}
			_taskService.UpdateData(tasks);
			var uptasks = tasks.Where(task => string.IsNullOrEmpty(task.ExceptionMessage)).ToList();
			if (uptasks.Count() > 0) _taskService.UpdateData(uptasks);
			var errortasks = tasks.Where(task => !string.IsNullOrEmpty(task.ExceptionMessage)).ToList();
			if (errortasks.Count() > 0)
			{
			foreach (var item in errortasks)
			{
			Thread.Sleep(500);
			_taskService.ErrorTaskFeedback(item, true);
			}
			}
			content.OK();
			}
			catch (Exception ex)
			{
			content.Error(ex.Message);
			}
			finally
			{
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åååè½¦æ°å»ºå¥åºä»»å¡", "", "");
			}
			}

			@@ -110,6 +121,7 @@
			keepRobot = 1,
			keepRobotTimeout = 1
			};
			fOURBOTnewMovePodTask.requestID += item.TaskId;
			fOURBOTnewMovePodTask.desType = 1;
			fOURBOTnewMovePodTask.desNodeID = item.NextAddress;
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			@@ -125,6 +137,7 @@
			}
			//FOURBOTnewMovePodTaskResponseData fOURBO = fOURBOTReturn.data as FOURBOTnewMovePodTaskResponseData ?? throw new Exception("æªè·åå°ååè½¦è¿åçä»»å¡ID");
			item.RGVTaskId = fOURBO.taskID;
			item.Dispatchertime = DateTime.Now;
			item.TaskState = (int)TaskStatusEnum.TakeFinish;
			}
			}
			@@ -137,7 +150,7 @@
			}
			finally
			{
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åååè½¦æ°å»ºå¥åºä»»å¡", "", "");
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åååè½¦å¤å½¢æ£æµä»»å¡", "", "");
			}
			}
			#endregion
			@@ -149,15 +162,11 @@
			/// <param name="tasks"></param>
			public void IsMoveTask(List<Dt_Task> tasks)
			{

			object requestData = null; // æ·»å åéè®°å½è¯·æ±æ°æ®
			WebResponseContent content = new WebResponseContent();
			try
			{
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(GetBlockPodContentDto)) ?? throw new Exception("æªæ¾å°æ¹éè·åé»ç¢æçå³ç³»æ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			List<Dt_Task> dt_Tasks = new List<Dt_Task>();
			//List<Dt_Task> dt_Tasks = new List<Dt_Task>();
			var PalletCodes = tasks.Select(x => x.PalletCode).ToList();
			//GetBlockPodContentDto content = new GetBlockPodContentDto();
			var request = new GetBlockPodContentListDto
			{
			content = new List<GetBlockPodContentDto>
			@@ -169,45 +178,113 @@
			}
			}
			};
			requestData = request; // ä¿åè¯·æ±æ°æ®ç¨äºæ¥å¿
			//content.candidatePodIDs = tasks.Select(x => x.PalletCode).ToList();
			string response = HttpHelper.Post(apiInfo.ApiAddress, request.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.OK(data: fOURBOTReturn);
			//string response = HttpHelper.Post("http://127.0.0.1:4523/m2/6165241-5857331-default/440906899?apifoxApiId=440906899", request.Serialize());
			content = _apiInfoService.PostInterfaceRequest(nameof(GetBlockPodContentDto), request.Serialize(), "æ¹éè·åé»ç¢æçå³ç³»");
			if (!content.Status)
			{
			foreach (var item in tasks)
			{
			item.ExceptionMessage = content.Message;
			}
			_taskService.UpdateData(tasks);
			return;
			}
			FOURBOTReturn fOURBOTReturn = content.Data as FOURBOTReturn;
			if (fOURBOTReturn.returnCode == 0)
			{
			//ReturnBlockPodResultDto getBlockPod = fOURBOTReturn.data as ReturnBlockPodResultDto ?? throw new Exception("æªè·åå°é»ç¢æçå³ç³»æ°æ®");
			var dataJson = fOURBOTReturn.data.ToString();
			if (string.IsNullOrEmpty(dataJson))
			{
			foreach (var item in tasks)
			{
			item.ExceptionMessage = "è·åé»ç¢æçå³ç³»å¤±è´¥ï¼";
			}
			_taskService.UpdateData(tasks);
			return;
			}
			ReturnBlockPodResultDto? getBlockPod = JsonConvert.DeserializeObject<ReturnBlockPodResultDto>(dataJson);
			if (getBlockPod == null)
			{
			foreach (var item in tasks)
			{
			item.ExceptionMessage = "é»ç¢æçå³ç³»æ°æ®è½¬æ¢å®ä½å¤±è´¥ï¼";
			}
			_taskService.UpdateData(tasks);
			return;
			}
			if (getBlockPod.Result.Count == 0)
			{
			throw new Exception("æªè·åå°é»ç¢æçå³ç³»æ°æ®");
			}
			foreach (var Result in getBlockPod.Result)
			{
			foreach (var item in Result.outPods)
			foreach (var item in tasks)
			{
			var task = tasks.First(x => x.PalletCode == item.outPod);
			item.ExceptionMessage = "æªè·åå°é»ç¢æçå³ç³»æ°æ®ï¼";
			}
			_taskService.UpdateData(tasks);
			return;
			}
			#region å¤ææ¯å¦éè¦ç§»åº
			foreach (var task in tasks)
			{
			var item = getBlockPod.Result[0].outPods.FirstOrDefault(x => x.outPod == task.PalletCode);
			if (item != null)
			{
			if (item.blockPods != null && item.blockPods.Count > 0)
			item.blockPods = item.blockPods.Except(PalletCodes).ToList();
			if (item.blockPods != null && item.blockPods.Count > 0)
			{
			#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);
			#region ç§»åºç¶æåé¦ç»WMS
			WMSInOutBoundCompleteFeedback boundCompleteFeedback = new WMSInOutBoundCompleteFeedback();
			boundCompleteFeedback.taskCode = task.WMSTaskNum;
			boundCompleteFeedback.containerCode = task.PalletCode;
			boundCompleteFeedback.fromStationCode = task.SourceAddress;
			boundCompleteFeedback.toLocationCode = task.TargetAddress;
			boundCompleteFeedback.status = 5;
			boundCompleteFeedback.custStatus = "";
			_apiInfoService.PostInterfaceRequest(nameof(WMSInOutBoundCompleteFeedback), boundCompleteFeedback.Serialize(), "æååºåºä»»å¡çå¾ç§»åºä¸æ¥WMS");
			#endregion
			}
			else
			{
			task.TaskState = (int)TaskStatusEnum.RGV_WaitSend;
			dt_Tasks.Add(task);
			}
			}
			else task.ExceptionMessage = $"RCSæªåé¦ã{task.PalletCode}ãå¯åºåºæçä¿¡æ¯,è¯¦æè¯·æ¥çæ¹éè·åé»ç¢æçå³ç³»æ¥å£æ¥å¿ï¼";
			}
			_taskService.UpdateData(dt_Tasks);
			_taskService.Repository.UpdateData(tasks);
			#endregion
			#region MyRegion
			//foreach (var Result in getBlockPod.Result)
			//{
			// foreach (var item in Result.outPods)
			// {
			// 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)
			// {
			// #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);
			// }
			// else
			// {
			// task.TaskState = (int)TaskStatusEnum.RGV_WaitSend;
			// dt_Tasks.Add(task);
			// }
			// }
			//}
			//_taskService.UpdateData(dt_Tasks);
			#endregion
			content.OK();
			}
			}
			@@ -217,7 +294,7 @@
			}
			finally
			{
			_trackloginfoService.AddTrackLog(requestData, content, "å¤çåºåºä»»å¡æ¯å¦éè¦ç§»åº", "", "");
			//_trackloginfoService.AddTrackLog(requestData, content, "å¤çåºåºä»»å¡æ¯å¦éè¦ç§»åº", "", "");
			}
			}
			#endregion
			@@ -265,6 +342,7 @@
			{
			autoToRest = 1
			};
			fOURBOTnewMovePodTask.requestID = DateTime.Now.ToString("yyyyMMddHHmmssfff") + item.TaskId;
			item.CurrentAddress = item.NextAddress;
			item.NextAddress = rGVLocationInfo.LocationCode;
			item.TargetAddress = rGVLocationInfo.LocationCode;
			@@ -279,17 +357,17 @@
			var fOURBO = data.DeserializeObject<FOURBOTnewMovePodTaskResponseData>();
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Puting;

			rGVLocationInfo.LocationStatus = LocationStatusEnum.InLock.ObjToInt();
			item.Dispatchertime = DateTime.Now;
			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
			}
			@@ -307,6 +385,10 @@
			item.ExceptionMessage = $"å¤çä»»å¡å¼å¸¸ï¼{ex.Message}";
			//WriteError($"{nameof(TaskJob)}-{item.TaskId}", ex.Message, ex);
			content.Error($"ååè½¦æ¥å£è¿åéè¯¯ï¼{ex.Message}");
			}
			finally
			{

			}
			}
			#region MyRegion
			@@ -392,8 +474,8 @@
			_taskService.UpdateData(tasksToUpdate);
			if (locationsToUpdate.Any())
			_rGVLocationInfoService.UpdateData(locationsToUpdate);
			//if (stationsToUpdate.Any())
			// _stationMangerService.UpdateData(stationsToUpdate);
			if (stationsToUpdate.Any())
			_stationMangerService.UpdateData(stationsToUpdate);

			_unitOfWorkManage.CommitTran();
			}
			@@ -412,7 +494,7 @@
			}
			finally
			{
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åå¤å½¢æ£æµä»»å¡å¤±è´¥", "", "");
			_trackloginfoService.AddTrackLog(fOURBOTnewMovePodTask, content, "ä¸åå¤å½¢æ£æµæåä»»å¡", "", "");
			}
			}
			#endregion
			@@ -458,6 +540,7 @@
			}
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Puting;
			item.Dispatchertime = DateTime.Now;
			}
			}
			_taskService.UpdateData(tasks);
			@@ -481,6 +564,13 @@
			try
			{
			List<Dt_RGVLocationInfo> rGVLocationInfos = _rGVLocationInfoService.Repository.QueryData(x => blockPods.Contains(x.PalletCode));
			var palletCodes = rGVLocationInfos.Select(x => x.PalletCode).ToList();
			// è·å blockPods ä¸åå¨ä½ palletCodes ä¸ä¸åå¨çæçç
			var missingPalletCodes = blockPods.Except(palletCodes).ToList();
			if (missingPalletCodes.Any())
			{
			throw new Exception($"æªæ¾å°ä»¥ä¸é»ç¢æè´§ä½ä¿¡æ¯ï¼{string.Join(",", missingPalletCodes)}");
			}
			var Items = _rGVLocationInfoService.GetMoveFreeLocationInfo(rGVLocationInfos);

			List<Dt_Task> tasks = Items.Item1;
			@@ -490,7 +580,7 @@
			tasks.ForEach(x =>
			{
			x.TaskNum = _taskService.GetTaskNum(nameof(SequenceEnum.SeqTaskNum));
			x.WMSTaskNum = task.WMSTaskNum;
			//x.WMSTaskNum = task.WMSTaskNum;
			});
			rGVLocationInfos.ForEach(x =>
			{
			@@ -562,6 +652,7 @@
			var task = tasks.First(x => x.PalletCode == item.podID);
			task.RGVTaskId = item.taskID;
			task.TaskState = TaskStatusEnum.RGV_MoveTaskSend.ObjToInt();
			task.Dispatchertime = DateTime.Now;
			dt_Tasks.Add(task);
			}
			_taskService.UpdateData(dt_Tasks);
			@@ -586,10 +677,11 @@
			{
			foreach (var item in tasks)
			{
			var takes = _taskService.Repository.QueryFirst(x => x.Roadway == item.Roadway && x.TaskType == (int)TaskTypeEnum.CPMoveInventory);
			var takes = _taskService.Repository.QueryFirst(x => x.Roadway == item.Roadway && x.TaskType == (int)TaskTypeEnum.CPMoveInventory && (x.TaskState == (int)TaskStatusEnum.RGV_NewMoveTask \|\| x.TaskState == (int)TaskStatusEnum.RGV_MoveTaskSend));
			if (takes == null)
			{
			item.TaskState = (int)TaskStatusEnum.RGV_WaitSend;
			item.Dispatchertime = DateTime.Now;
			}
			}
			_taskService.UpdateData(tasks);
			@@ -634,7 +726,7 @@
			autoToRest = 1
			};
			fOURBOTnewMovePodTask.desType = 5;
			fOURBOTnewMovePodTask.requestID = DateTime.Now.ToString("yyyyMMddHHmmss") + i;
			fOURBOTnewMovePodTask.requestID = DateTime.Now.ToString("yyyyMMddHHmmssfff") + item.TaskId;
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.OK(data: fOURBOTReturn);
			@@ -648,6 +740,7 @@
			}
			item.RGVTaskId = fOURBO.taskID;
			item.TaskState = (int)TaskStatusEnum.Execut;
			item.Dispatchertime = DateTime.Now;
			//stationManger.IsOccupied = LocationStatusEnum.Lock.ObjToInt();
			//_stationMangerService.UpdateData(stationManger);
			}