RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -89,47 +89,99 @@
			WebResponseContent content = new WebResponseContent();
			try
			{
			List<object> objects = new List<object>();
			foreach (var item in taskDTOs)
			{
			foreach (var task in item.tasks)
			{
			#region å¤æ
			content = TaskHelpMethods.isOkTaskInfo(task, true, true);
			if (!content.Status) throw new Exception(content.Message);
			if (BaseDal.QueryFirst(x => x.WMSTaskNum == task.taskCode \|\| x.PalletCode == task.containerCode) != null)
			if (!content.Status)
			{
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"ä»»å¡å·ã{task.taskCode}ã{content.Message}"
			});
			continue;
			//throw new Exception(content.Message);
			}
			if (BaseDal.QueryFirst(x => x.WMSTaskNum == task.taskCode) != null)
			{
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"ä»»å¡å·ã{task.taskCode}ãå·²åå¨ä»»å¡"
			});
			continue;
			//throw new Exception($"ä»»å¡å·ã{task.taskCode}ãå·²åå¨ä»»å¡");
			}
			if (BaseDal.QueryFirst(x => x.PalletCode == task.containerCode) != null)
			{
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"æçå·ã{task.containerCode}ãå·²åå¨ä»»å¡"
			});
			continue;
			//throw new Exception($"æçå·ã{task.containerCode}ãå·²åå¨ä»»å¡");
			}
			if (BaseDal.QueryFirst(x => x.SourceAddress == task.fromLocationCode) != null)
			{
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"èµ·ç¹ä½ç½®ã{task.containerCode}ãå·²åå¨ä»»å¡"
			});
			continue;
			//throw new Exception($"èµ·ç¹ä½ç½®ã{task.containerCode}ãå·²åå¨ä»»å¡");
			}
			#endregion
			switch (item.taskType)
			{
			case (int)TaskTypeEnum.MLInbound:
			CreateKLSNewInTask(task, item.taskType);
			content = CreateKLSNewInTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.MLOutbound:
			CreateKLSNewOutTask(task, item.taskType);
			content = CreateKLSNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CPInbound:
			CreateRGVNewInTask(task, item.taskType);
			content = CreateRGVNewInTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CPOutbound:
			CreateRGVNewOutTask(task, item.taskType);
			content = CreateRGVNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJInbound:
			CreateHKNewInTask(task, item.taskType);
			content = CreateHKNewInTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJOutbound:
			CreateHKNewOutTask(task, item.taskType);
			content = CreateHKNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.Carry:
			CarryTask(task, item.taskType);
			content = CarryTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJCarry:
			CJCarryTaske(task, item.taskType);
			content = CJCarryTaske(task, item.taskType);
			objects.Add(content.Data);
			break;
			default:
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"æªå®ä¹çä»»å¡ç±»å"
			});
			break;
			}
			}
			}
			content.Data = objects;
			}
			catch (Exception ex)
			{
			@@ -167,7 +219,7 @@
			#region å¯ä¹å£«
			if (isGALAXISTask)
			{
			KLS = new CancelGALAXISTask
			KLS = new CancelGALAXISTask
			{
			taskId = dt_Task.WMSTaskNum,
			reportTime = DateTime.Now.ToString()
			@@ -180,11 +232,11 @@
			{
			//ç´æ¥ç§»å¥åå²
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å®æ);
			content.OK("åæ¶ä»»å¡æå", dt_Task);
			content.OK($"åæ¶{dt_Task.WMSTaskNum}ä»»å¡æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{agvContent.data.returnInfo}");
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥{agvContent.data.returnInfo}");

			}
			}
			@@ -193,9 +245,10 @@
			#region ååè½¦
			if (isAGV)
			{
			cancelSXCTake = new CancelSXCTake
			cancelSXCTake = new CancelSXCTake
			{
			taskID = dt_Task.RGVTaskId
			taskID = dt_Task.RGVTaskId,
			withoutRunning = 1
			};
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(CancelSXCTake));
			if (apiInfo == null) throw new Exception("æªæ¾å°ååè½¦AGVä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			@@ -205,18 +258,18 @@
			{
			//ç´æ¥ç§»å¥åå²
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å®æ);
			content.OK("åæ¶ä»»å¡æå", dt_Task);
			content.OK($"åæ¶{dt_Task.WMSTaskNum}ä»»å¡æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{fOURBOTReturn.data}");
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥{fOURBOTReturn.data}");
			}
			}
			#endregion
			#region æµ·åº·
			if (isHK)
			{
			cancelHIKROBOTTask = new CancelHIKROBOTTask
			cancelHIKROBOTTask = new CancelHIKROBOTTask
			{
			robotTaskCode = dt_Task.WMSTaskNum,
			cancelType = "CANCEL"//åè½¯åæ¶ï¼DROPäººå·¥ä»å¥ï¼åç¡¬åæ¶ï¼
			@@ -229,11 +282,11 @@
			{
			//ç´æ¥ç§»å¥åå²
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å®æ);
			content.OK("åæ¶ä»»å¡æå", dt_Task);
			content.OK("åæ¶{dt_Task.WMSTaskNum}ä»»å¡æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{hIKROBOTReturn.data}");
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥ï¼éè¯¯ä¿¡æ¯ï¼{hIKROBOTReturn.data}");
			}

			}
			@@ -250,17 +303,17 @@
			object logObject = null;
			string deviceName = "";

			if (KLS != null )
			if (KLS != null)
			{
			logObject = KLS;
			deviceName = "å¯ä¹å£«AGV";
			}
			else if (cancelHIKROBOTTask != null )
			else if (cancelHIKROBOTTask != null)
			{
			logObject = cancelHIKROBOTTask;
			deviceName = "æµ·åº·æºå¨äºº";
			}
			else if (cancelSXCTake != null )
			else if (cancelSXCTake != null)
			{
			logObject = cancelSXCTake;
			deviceName = "ååè½¦";
			@@ -268,7 +321,7 @@

			if (logObject != null)
			{
			_trackloginfoService.AddTrackLog(logObject, content, $"åæ¶{deviceName}ä»»å¡", "", "");
			_trackloginfoService.AddTrackLog(logObject, content, $"åæ¶{deviceName}ä»»å¡,", "", "");
			}
			}
			return content;
			@@ -309,7 +362,6 @@
			{
			taskId = dt_Task.WMSTaskNum,
			reportTime = DateTime.Now.ToString(),
			district = dt_Task.Roadway,//ä»»å¡åºåº
			priorityCode = updateTaskPriority.taskPriority,
			};
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(UpdateGALAXISTaskGrade));
			@@ -320,11 +372,11 @@
			{

			BaseDal.UpdateData(dt_Task);
			content.OK("ä¿®æ¹ä»»å¡ä¼åçº§æå", dt_Task);
			content.OK($"ä¿®æ¹{dt_Task.WMSTaskNum}ä»»å¡ä¼åçº§æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{agvContent.data.returnInfo}");
			content.Error($"{dt_Task.WMSTaskNum}ä»»å¡å¤±è´¥,éè¯¯ä¿¡æ¯ï¼{agvContent.data.returnInfo}");
			}
			}
			#endregion
			@@ -332,23 +384,23 @@
			#region ååè½¦
			if (isAGV)
			{
			request = new UpdateAgvSXCTake
			request = new UpdateAgvSXCTake
			{
			taskID = dt_Task.RGVTaskId,
			priority = updateTaskPriority.taskPriority
			};
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(UpdateAgvSXCTake));
			if (apiInfo == null) throw new Exception("æªæ¾å°ååè½¦AGVä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			if (apiInfo == null) throw new Exception("æªæ¾å°æ´æ°ååè½¦ä»»å¡ä¼åçº§æ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			string response = HttpHelper.Post(apiInfo.ApiAddress, request.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			if (fOURBOTReturn.returnCode == 0 && fOURBOTReturn.returnUserMsg == "æå")
			{
			BaseDal.UpdateData(dt_Task);
			content.OK("ä¿®æ¹ä»»å¡ä¼åçº§æå", dt_Task);
			content.OK("ä¿®æ¹{dt_Task.WMSTaskNum}ä»»å¡ä¼åçº§æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{fOURBOTReturn.data}");
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥ï¼éè¯¯ä¿¡æ¯ï¼{fOURBOTReturn.data}");
			}
			}

			@@ -356,7 +408,7 @@
			#region æµ·åº·
			if (isHK)
			{
			Hkrequest = new HIKROBOTTaskGrade
			Hkrequest = new HIKROBOTTaskGrade
			{
			robotTaskCode = dt_Task.WMSTaskNum,//ä»»å¡å·
			initPriority = updateTaskPriority.taskPriority//ä¼åçº§
			@@ -368,11 +420,11 @@
			if (hIKROBOTReturn.code == "SUCCESS0" && hIKROBOTReturn.message == "æå")
			{
			BaseDal.UpdateData(dt_Task);
			content.OK("ä¿®æ¹ä»»å¡ä¼åçº§æå", dt_Task);
			content.OK("ä¿®æ¹{dt_Task.WMSTaskNum}ä»»å¡ä¼åçº§æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡å¤±è´¥{hIKROBOTReturn.data}");
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥ï¼éè¯¯ä¿¡æ¯{hIKROBOTReturn.data}");
			}
			}
			#endregion
			@@ -387,7 +439,7 @@
			object logObject = null;
			string deviceName = "";

			if (updateGALAXISTaskGrade != null )
			if (updateGALAXISTaskGrade != null)
			{
			logObject = updateGALAXISTaskGrade;
			deviceName = "å¯ä¹å£«AGV";
			@@ -397,7 +449,7 @@
			logObject = Hkrequest;
			deviceName = "æµ·åº·æºå¨äºº";
			}
			else if (request != null )
			else if (request != null)
			{
			logObject = request;
			deviceName = "ååè½¦";
			@@ -1015,14 +1067,51 @@
			/// <param name="AreaCode"></param>
			/// <returns></returns>
			/// <exception cref="NotImplementedException">åºåå·</exception>
			public WebResponseContent LocationInquiry(string AreaCode)
			public WebResponseContent LocationInquiry(WMSGetLocationInfo getLocationInfo)
			{
			if (AreaCode == null)
			WebResponseContent content = new WebResponseContent();
			List<object> list = new List<object>();
			try
			{
			//æ¥è¯¢è¾éçº¿ç©ºæç¼åä¿¡æ¯æ¶è¿åç©ºä½æ°é
			}
			return WebResponseContent.Instance.OK();
			if (getLocationInfo == null) throw new Exception("è¯·æ±åæ°ä¸è½ä¸ºç©ºï¼");
			if (getLocationInfo.AreaCode == null) throw new Exception("åºåºç¼å·ä¸è½ä¸ºç©ºï¼");
			if (getLocationInfo.WarehouseId == 0) throw new Exception("ä»åºIDä¸è½ä¸ºç©ºï¼");
			if (getLocationInfo.WarehouseId == 1)
			{
			List<Dt_RGVLocationInfo> rGVLocationInfos = _rGVLocationInfoService.Repository.QueryData(x => x.WarehouseId == getLocationInfo.AreaCode.ObjToInt());
			foreach (var item in rGVLocationInfos)
			{
			list.Add(new
			{
			LoctionCode = item.LocationCode,
			LocationStatus = item.LocationStatus,
			EnableStatus = item.EnableStatus
			});
			}
			content.Data = list;
			}
			else if (getLocationInfo.WarehouseId == 2)
			{

			}
			else if (getLocationInfo.WarehouseId == 3)
			{

			}
			else if (getLocationInfo.WarehouseId == 4)
			{

			}
			else if (getLocationInfo.WarehouseId == 5)
			{

			}
			}
			catch (Exception ex)
			{
			content.Error(ex.Message);
			}
			return content;
			}


			@@ -1118,32 +1207,33 @@
			};
			string response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOToccupyStation.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);
			if (fOURBOTReturn.returnCode != 0 /&& fOURBOTReturn.returnUserMsg != $"ç«ç¹å·²è¢«å ç¨,(podID={iQC.ContainerCode})"/)
			throw new Exception(fOURBOTReturn.returnUserMsg);
			#endregion

			#region åå»ºååè½¦ä»»å¡
			var task = BaseDal.QueryFirst(x => x.PalletCode == iQC.ContainerCode && x.SourceAddress == iQC.StationCode && x.TaskState == (int)TaskStatusEnum.New);
			//var task = BaseDal.QueryFirst(x => x.PalletCode == iQC.ContainerCode && x.SourceAddress == iQC.StationCode && x.TaskState == (int)TaskStatusEnum.New);
			#endregion
			#region å¼å«ååè½¦
			apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(FOURBOTnewMovePodTask)) ?? throw new Exception("æªæ¾å°ååè½¦ä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			FOURBOTnewMovePodTask fOURBOTnewMovePodTask = new()
			{
			priority = task.Grade,
			podID = task.PalletCode,
			//desNodeID = task.SourceAddress,
			desExt = new
			{
			unload = 0//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			},
			desStationCodes = task.SourceAddress,
			desType = 5
			};
			response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.Data = fOURBOTReturn;
			if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);
			task.TaskState = (int)TaskStatusEnum.Execut;
			BaseDal.UpdateData(task);
			//apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(FOURBOTnewMovePodTask)) ?? throw new Exception("æªæ¾å°ååè½¦ä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			//FOURBOTnewMovePodTask fOURBOTnewMovePodTask = new()
			//{
			// priority = task.Grade,
			// podID = task.PalletCode,
			// //desNodeID = task.SourceAddress,
			// desExt = new
			// {
			// unload = 0//æ¯å¦æ¾ä¸å®¹å¨,0å¦1æ¯
			// },
			// desStationCodes = task.SourceAddress,
			// desType = 5
			//};
			//response = HttpHelper.Post(apiInfo.ApiAddress, fOURBOTnewMovePodTask.Serialize());
			//fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			//content.Data = fOURBOTReturn;
			//if (fOURBOTReturn.returnCode != 0) throw new Exception(fOURBOTReturn.returnUserMsg);
			//task.TaskState = (int)TaskStatusEnum.Execut;
			//BaseDal.UpdateData(task);
			#endregion
			return WebResponseContent.Instance.OK();
			}
			@@ -1166,7 +1256,7 @@
			var Agvlocation = _rGVLocationInfoService.Repository.QueryData(x => fOURBOTStorageStatusNotify.storageCode.Contains(x.LocationCode));
			foreach (var item in Agvlocation)
			{
			item.LocationStatus = (int)(fOURBOTStorageStatusNotify.disable == 0 ? EnableStatusEnum.Normal : EnableStatusEnum.Disable);
			item.EnableStatus = (int)(fOURBOTStorageStatusNotify.disable == 0 ? EnableStatusEnum.Normal : EnableStatusEnum.Disable);
			}
			_rGVLocationInfoService.UpdateData(Agvlocation);
			return WebResponseContent.Instance.OK();