RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -20,6 +20,7 @@
			using SqlSugar;
			using System.Collections.Generic;
			using System.Diagnostics.CodeAnalysis;
			using System.Threading.Tasks;
			using WIDESEAWCS_BasicInfoService;
			using WIDESEAWCS_Common;
			using WIDESEAWCS_Common.LocationEnum;
			@@ -37,6 +38,7 @@
			using WIDESEAWCS_IBasicInfoService;
			using WIDESEAWCS_ITaskInfoService;
			using WIDESEAWCS_Model.Models;
			using WIDESEAWCS_QuartzJob;
			using WIDESEAWCS_QuartzJob.Models;
			using WIDESEAWCS_QuartzJob.Service;

			@@ -96,8 +98,8 @@
			foreach (var task in item.tasks)
			{
			#region å¤æ
			content = TaskHelpMethods.isOkTaskInfo(task, true, true);
			if (!content.Status)
			var contentStatus = TaskHelpMethods.isOkTaskInfo(task, true, true);
			if (!contentStatus.Status)
			{
			objects.Add(new
			{
			@@ -105,7 +107,6 @@
			Message = $"ä»»å¡å·ã{task.taskCode}ã{content.Message}"
			});
			continue;
			//throw new Exception(content.Message);
			}
			if (BaseDal.QueryFirst(x => x.WMSTaskNum == task.taskCode && x.TaskType == item.taskType) != null)
			{
			@@ -132,7 +133,7 @@
			objects.Add(new
			{
			taskCode = task.taskCode,
			Message = $"èµ·ç¹ä½ç½®ã{task.containerCode}ãå·²åå¨ä»»å¡"
			Message = $"èµ·ç¹ä½ç½®ã{task.fromLocationCode}ãå·²åå¨ä»»å¡"
			});
			continue;
			//throw new Exception($"èµ·ç¹ä½ç½®ã{task.containerCode}ãå·²åå¨ä»»å¡");
			@@ -140,6 +141,7 @@
			#endregion
			switch (item.taskType)
			{
			#region å¯ä¹å£«AGVé¢æåº
			case (int)TaskTypeEnum.MLInbound:
			content = CreateKLSNewInTask(task, item.taskType);
			objects.Add(content.Data);
			@@ -148,6 +150,8 @@
			content = CreateKLSNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			#endregion
			#region æ·è§ååè½¦æååº
			case (int)TaskTypeEnum.CPInbound:
			content = CreateRGVNewInTask(task, item.taskType);
			objects.Add(content.Data);
			@@ -156,22 +160,30 @@
			content = CreateRGVNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJInbound:
			#endregion
			#region æµ·åº·AGV
			case (int)TaskTypeEnum.Q1TSJ4:
			content = CreateHKNewInTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJOutbound:
			case (int)TaskTypeEnum.STU0003:
			case (int)TaskTypeEnum.CHUKU1:
			content = CreateHKNewOutTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.Carry:
			case (int)TaskTypeEnum.F01:
			case (int)TaskTypeEnum.Q3RK:
			case (int)TaskTypeEnum.Q3CK:
			content = CarryTask(task, item.taskType);
			objects.Add(content.Data);
			break;
			case (int)TaskTypeEnum.CJCarry:
			case (int)TaskTypeEnum.F02:
			case (int)TaskTypeEnum.RK3F:
			case (int)TaskTypeEnum.CK3F:
			content = CJCarryTaske(task, item.taskType);
			objects.Add(content.Data);
			break;
			#endregion
			default:
			objects.Add(new
			{
			@@ -207,9 +219,10 @@
			var KLS = new CancelGALAXISTask();
			CancelHIKROBOTTask cancelHIKROBOTTask = new CancelHIKROBOTTask();
			CancelSXCTake cancelSXCTake = new CancelSXCTake();
			var deviceName = "";
			try
			{
			Dt_Task dt_Task = BaseDal.QueryFirst(x => x.WMSTaskNum == wMSCancelTask.TaskCode);
			Dt_Task dt_Task = BaseDal.QueryFirst(x => x.WMSTaskNum == wMSCancelTask.TaskCode && x.TaskType != TaskTypeEnum.CPMoveInventory.ObjToInt());
			if (dt_Task == null) throw new Exception("æªæ¥è¯¢å°ä»»å¡å·ç¸å³ä»»å¡");

			// å¤æå½åä»»å¡æ¯å¦ä¸ºå¯ä¹å£«ä»»å¡
			@@ -218,12 +231,13 @@
			//ååè½¦
			bool isAGV = dt_Task.TaskType == (int)TaskTypeEnum.CPInbound \|\| dt_Task.TaskType == (int)TaskTypeEnum.CPOutbound;
			//æµ·åº·
			bool isHK = dt_Task.TaskType == (int)TaskTypeEnum.Carry \|\| dt_Task.TaskType == (int)TaskTypeEnum.CJInbound \|\| dt_Task.TaskType == (int)TaskTypeEnum.CJInbound \|\| dt_Task.TaskType == (int)TaskTypeEnum.CJOutbound;
			bool isHK = dt_Task.TaskType == (int)TaskTypeEnum.Carry \|\| dt_Task.TaskType == (int)TaskTypeEnum.RK3F \|\| dt_Task.TaskType == (int)TaskTypeEnum.CK3F \|\| dt_Task.TaskType == (int)TaskTypeEnum.Q1TSJ4 \|\| dt_Task.TaskType == (int)TaskTypeEnum.STU0003 \|\| dt_Task.TaskType == (int)TaskTypeEnum.F02 \|\| dt_Task.TaskType == (int)TaskTypeEnum.CHUKU1 \|\| dt_Task.TaskType == (int)TaskTypeEnum.Q3RK \|\| dt_Task.TaskType == (int)TaskTypeEnum.Q3CK;
			//è¿éå°ç¶ææ¹åäº198åæ¶ä»»å¡
			dt_Task.TaskType = TaskStatusEnum.WMSCancel.ObjToInt();
			#region å¯ä¹å£«
			if (isGALAXISTask)
			{
			deviceName = "å¯ä¹å£«AGV";
			KLS = new CancelGALAXISTask
			{
			taskId = dt_Task.WMSTaskNum,
			@@ -251,25 +265,34 @@
			#region ååè½¦
			if (isAGV)
			{
			cancelSXCTake = new CancelSXCTake
			deviceName = "ååè½¦";
			if (dt_Task.RGVTaskId == 0)
			{
			taskID = dt_Task.RGVTaskId,
			withoutRunning = 1
			};
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(CancelSXCTake));
			if (apiInfo == null) throw new Exception("æªæ¾å°ååè½¦AGVä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			string response = HttpHelper.Post(apiInfo.ApiAddress, cancelSXCTake.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0 && fOURBOTReturn.returnUserMsg == "æå")
			{
			//ç´æ¥ç§»å¥åå²
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å®æ);
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å é¤);
			content.OK($"åæ¶{dt_Task.WMSTaskNum}ä»»å¡æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥{fOURBOTReturn.data}");
			cancelSXCTake = new CancelSXCTake
			{
			taskID = dt_Task.RGVTaskId,
			withoutRunning = 1
			};
			Dt_ApiInfo? apiInfo = _apiInfoService.Repository.QueryFirst(x => x.ApiCode == nameof(CancelSXCTake));
			if (apiInfo == null) throw new Exception("æªæ¾å°ååè½¦AGVä»»å¡ä¸åæ¥å£éç½®ä¿¡æ¯ï¼è¯·æ£æ¥æ¥å£éç½®");
			string response = HttpHelper.Post(apiInfo.ApiAddress, cancelSXCTake.Serialize());
			FOURBOTReturn fOURBOTReturn = response.DeserializeObject<FOURBOTReturn>();
			content.OK(data: fOURBOTReturn);
			if (fOURBOTReturn.returnCode == 0 && fOURBOTReturn.returnUserMsg == "æå")
			{
			//ç´æ¥ç§»å¥åå²
			BaseDal.DeleteAndMoveIntoHty(dt_Task, OperateTypeEnum.èªå¨å®æ);
			content.OK($"åæ¶{dt_Task.WMSTaskNum}ä»»å¡æå", dt_Task);
			}
			else
			{
			content.Error($"ä»»å¡{dt_Task.WMSTaskNum}å¤±è´¥{fOURBOTReturn.data}");
			}
			}
			}
			#endregion
			@@ -277,6 +300,7 @@
			#region æµ·åº·
			if (isHK)
			{
			deviceName = "æµ·åº·æºå¨äºº";
			cancelHIKROBOTTask = new CancelHIKROBOTTask
			{
			robotTaskCode = dt_Task.WMSTaskNum,
			@@ -308,30 +332,7 @@
			}
			finally
			{
			// å¨ finally ä¸å¤æåªä¸ªå¯¹è±¡è¢«èµå¼äº
			object logObject = null;
			string deviceName = "";

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

			if (logObject != null)
			{
			_trackloginfoService.AddTrackLog(logObject, content, $"åæ¶{deviceName}ä»»å¡,", "", "");
			}
			_trackloginfoService.AddTrackLog(wMSCancelTask, content, $"åæ¶{deviceName}ä»»å¡,", "", "");
			}
			return content;
			}
			@@ -1134,7 +1135,22 @@
			}
			else if (getLocationInfo.WarehouseId == 5)
			{

			//è¯»ååçµä¿¡å·
			var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "F1") as OtherDevice;
			if (device == null) throw new Exception("æªæ¾å°1æ¥¼è´¨æ£é¨è®¾å¤ä¿¡æ¯");
			if (!device.IsConnected) throw new Exception("PLC1æ¥¼è´¨æ£é¨è®¾å¤è¿æ¥å¤±è´¥");
			var sta = _stationMangerService.Repository.QueryData(x => x.Remark == "æååº");
			foreach (var item in sta)
			{
			bool value = device.GetValue<QualityInspectionCommandEnum, bool>(QualityInspectionCommandEnum.R_StockAvailableSymbol, item.StationCode);
			list.Add(new
			{
			LoctionCode = item.StationCode,
			LocationStatus = value ? 100 : 0,
			EnableStatus = 0,
			});
			}
			content.OK(data: list);
			}
			}
			catch (Exception ex)
			@@ -1298,5 +1314,34 @@
			return WebResponseContent.Instance.Error(ex.Message);
			}
			}


			public override WebResponseContent DeleteData(object[] keys)
			{
			try
			{
			// æ¥æ¾ææä»»å¡ä¸åå«è¿ä¸ªidç
			var take = BaseDal.QueryData(x => keys.Contains(x.TaskId));

			// æ§è¡ç§»å¥åå²æä½ï¼å¹¶æ£æ¥ç»æ
			bool moveResult = BaseDal.DeleteAndMoveIntoHty(take, OperateTypeEnum.äººå·¥å é¤);

			if (!moveResult)
			{
			// ç§»å¥åå²å¤±è´¥ï¼è¿åéè¯¯ä¿¡æ¯
			return WebResponseContent.Instance.Error("ç§»å¥åå²è®°å½å¤±è´¥");
			}
			return WebResponseContent.Instance.OK("å é¤æåï¼æ°æ®å·²ç§»å¥åå²");
			}
			catch (Exception ex)
			{
			// è®°å½å¼å¸¸æ¥å¿
			// Logger.Error(ex.Message);
			return WebResponseContent.Instance.Error("å é¤å¤±è´¥ï¼" + ex.Message);
			}
			}



			}
			}