RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -14,6 +14,7 @@
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEAWCS_Common;
			using WIDESEAWCS_Common.LocationEnum;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Communicator;
			using WIDESEAWCS_Core.Helper;
			@@ -33,10 +34,13 @@
			{
			private readonly ITaskService _taskService;
			private readonly IStationMangerService _stationMangerService;
			public TSJJob(ITaskService taskService, IStationMangerService stationMangerService)
			private readonly IStationInfoService _stationInfoService;

			public TSJJob(ITaskService taskService, IStationMangerService stationMangerService, IStationInfoService stationInfoService)
			{
			_taskService = taskService;//æ³¨å¥
			_stationMangerService = stationMangerService;
			_stationInfoService = stationInfoService;
			}

			public Task Execute(IJobExecutionContext context)
			@@ -69,12 +73,12 @@
			continue;
			//throw new Exception("è®¾å¤æé");
			}
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt()\|\| task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt())
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt() \|\| task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt() \|\| task.TaskType == TaskTypeEnum.F04.ObjToInt())
			{
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt())
			{
			//å¤æ3æ¥¼å¥åºç®±å·ææ
			if (device.GetValue<HoistEnum, short>(HoistEnum.OutboundInplace, task.SourceAddress) != 2)
			if (device.GetValue<HoistEnum, short>(HoistEnum.OutboundInplace, task.TargetAddress) != 2)
			{
			if (task.ExceptionMessage == "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç")
			{
			@@ -87,27 +91,15 @@
			}
			else
			{
			//åç©ºç®±çæ¶åè¦è¯»ä¸ä¸ªå
			if (device.GetValue<HoistEnum, string>(HoistEnum.Emptycontainernumber, task.SourceAddress) == null)
			if (device.GetValue<HoistEnum, short>(HoistEnum.ReturnbinAvailable, task.TargetAddress) != 2)
			{
			if (task.ExceptionMessage != "4æ¥¼ç©ºç®±,è¯»ç å¨æ²¡æè¯»å°å¼")
			if (task.ExceptionMessage != "4Fæåæºå¥å£æè´§")
			{
			task.ExceptionMessage = "4æ¥¼ç©ºç®±,è¯»ç å¨æ²¡æè¯»å°å¼";
			task.ExceptionMessage = "4Fæåæºå¥å£æè´§";
			Uptasks.Add(task);
			}
			continue;
			}
			//å¤æ4æ¥¼ç©ºç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.ReturnbinAvailable, task.SourceAddress) == 2)
			{
			if (task.ExceptionMessage != "TSJ4æ¥¼åæç®±ä¸ºç©º")
			{
			task.ExceptionMessage = "TSJ4æ¥¼åæç®±ä¸ºç©º";
			Uptasks.Add(task);
			}
			continue;
			}

			}


			@@ -115,7 +107,7 @@
			var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
			if (result.Status == false)
			{
			if (task.ExceptionMessage!= result.Message)
			if (task.ExceptionMessage != result.Message)
			{
			task.ExceptionMessage = result.Message;
			Uptasks.Add(task);
			@@ -129,23 +121,49 @@
			//è¿éä»»å¡åæäºCheckPalletCodeing

			}
			else if(task.TaskType == TaskTypeEnum.CK3F.ObjToInt()) //åºåº
			else if (task.TaskType == TaskTypeEnum.CK3F.ObjToInt() \|\| task.TaskType == TaskTypeEnum.Q1TSJ4.ObjToInt() \|\| task.TaskType == TaskTypeEnum.F03.ObjToInt()) //åºåº
			{
			////åºåºæç®±ç¼åæ°é(è¿ä¸ªæ¯åºåºæ¥è¯¢çæ¶åè¦æ¥ä¸ä¸ï¼è¿ç»wms)
			//if (device.GetValue<HoistEnum, short>(HoistEnum.Outboundmaterialbox, "TSJ") == 0) throw new Exception("æ²¡æåºåºæç®±ç¼åæ°éä¸ºç©º");
			//è¯»å3æ¥¼åºåºæç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, task.TargetAddress) != 1)

			if (task.TaskType == TaskTypeEnum.CK3F.ObjToInt())
			{
			if (task.ExceptionMessage != "3æ¥¼åºåºæç®±æ²¡æå°ä½")
			//è¯»å3æ¥¼åºåºæç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, task.SourceAddress) != 1)
			{
			task.ExceptionMessage = "3æ¥¼åºåºæç®±æ²¡æå°ä½";
			Uptasks.Add(task);
			if (task.ExceptionMessage != "3æ¥¼æåæºåºå£åçµåé¦æ è´§")
			{
			task.ExceptionMessage = "3æ¥¼æåæºåºå£åçµåé¦æ è´§";
			Uptasks.Add(task);
			}
			continue;
			}
			continue;
			}
			else
			{
			if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, task.SourceAddress) != 1)
			{
			if (task.ExceptionMessage != "4æ¥¼æåæºåºå£åçµåé¦æ è´§")
			{
			task.ExceptionMessage = "4æ¥¼æåæºåºå£åçµåé¦æ è´§";
			Uptasks.Add(task);
			}
			continue;
			}

			if (device.GetValue<HoistEnum, short>(HoistEnum.ROutScanningCompletionSignal, task.SourceAddress) != 1)
			{
			if (task.ExceptionMessage != "4æ¥¼æåæºåºå£æ«ç å®æä¿¡å·æ²¡æå®æ")
			{
			task.ExceptionMessage = "4æ¥¼æåæºåºå£æ«ç å®æä¿¡å·æ²¡æå®æ";
			Uptasks.Add(task);
			}
			continue;
			}
			}
			//ç¶åè°ç¨è¾éçº¿æ¥å£ï¼éç¥è¾éçº¿ææç®±éè¦å¥åºï¼ä»»å¡ä¸¾è¡æ§è¡
			var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
			if (result.Status == false)
			if (result.Status == false)
			{
			if (task.ExceptionMessage != result.Message)
			{
			@@ -158,72 +176,94 @@
			task.ExceptionMessage = "";
			Uptasks.Add(task);
			}
			else if (task.TaskType == TaskTypeEnum.Q1TSJ4.ObjToInt())//å3æ¥¼åºåºä¸ä¸æ ·ï¼
			{
			#region 4æ¥¼åºåº
			//4æ¥¼åºåºæç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, task.TargetAddress) != 2)
			{
			if (task.ExceptionMessage != "4æ¥¼åºåºæç®±æ²¡æå°ä½")
			{
			task.ExceptionMessage = "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç";
			Uptasks.Add(task);
			}
			continue;
			}

			#endregion
			task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
			task.ExceptionMessage = "";
			Uptasks.Add(task);
			}
			//else if (task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt()) //åæ¥¼åºåå°æåæº
			//{


			//}
			}

			//æ¥æ¾ä¸æ¥¼å¥åºä»»å¡ç¶æä¸ºCheckPalletCodeingçä»»å¡æçå·ç¡®è®¤ä¸
			var RK3FTasks = _taskService.Repository.QueryFirst(x => x.TaskType == TaskTypeEnum.RK3F.ObjToInt() && x.TaskState == (int)TaskStatusEnum.CheckPalletCodeing);
			if (RK3FTasks!=null)
			{
			var Barcode = device.SetValue<HoistEnum, short>(HoistEnum.Codereadingtriggered, 1);
			//æ£æ¥3æ¥¼å¥åºç®±å·æ¯å¤å°ï¼ç¶åä¼ ç»wms
			var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Inboxnumber, "TSJ");
			//æ ¹æ®è¯»å°çç®±å·è¿è¡æç®±æ£éªï¼æ£éªéè¿å°±è§¦åè¯»ç å¨è¯»åï¼å¦æä¸éè¿å°±æåºå¼å¸¸
			//var Verification = _taskService.MaterialBoxInspection(RK3FTasks.WMSTaskNum, BinNumber.ToString());
			//if (!Verification.Status)
			//{
			// if (!(RK3FTasks.ExceptionMessage == Verification.Message))
			// {
			// RK3FTasks.ExceptionMessage = Verification.Message;
			// Uptasks.Add(RK3FTasks);
			// }
			// //æç®±éªè¯åå¥½åï¼éè¦æ´æ¹
			// RK3FTasks.TargetAddress = Verification.Data.ToString();
			//}

			//å¦ææç®±æ£éªæåå°±åå¥è¯»ç å¨çå¼
			var result = _taskService.Hikvisiontaskscontinue(RK3FTasks.WMSTaskNum, RK3FTasks.TargetAddress);
			if (result.Status == false)
			{
			if (RK3FTasks.ExceptionMessage != result.Message)
			{
			RK3FTasks.ExceptionMessage = result.Message;
			Uptasks.Add(RK3FTasks);
			}
			}
			RK3FTasks.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;
			Uptasks.Add(RK3FTasks);
			}
			if (Uptasks.Count > 0)
			{
			_taskService.UpdateData(Uptasks);
			}
			WriteInfo(device.DeviceName, "infoLog");

			WriteDebug(device.DeviceName, "debugLog");
			#region æçå·ç¡®è®¤ä¸
			//æ¥æ¾ä¸æ¥¼å¥åºä»»å¡ç¶æä¸ºCheckPalletCodeingçä»»å¡æçå·ç¡®è®¤ä¸
			var RK3FTask = _taskService.Repository.QueryFirst(x => x.TaskType == TaskTypeEnum.RK3F.ObjToInt() && x.TaskState == (int)TaskStatusEnum.CheckPalletCodeing);
			if (RK3FTask != null)
			{
			if (device.GetValue<HoistEnum, short>(HoistEnum.RInScanningCompletionSignal, RK3FTask.TargetAddress) != 1)
			{
			RK3FTask.ExceptionMessage = "3æ¥¼æ«ç å®æä¿¡å·æ²¡æå®æ";
			_taskService.UpdateData(RK3FTask);
			}
			else //å®æå°±æä»»å¡ç¶ææ¹ææçå·ç¡®è®¤å®æ
			{
			//æ£æ¥3æ¥¼å¥åºç®±å·æ¯å¤å°ï¼ç¶åä¼ ç»wms
			var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Inboxnumber, RK3FTask.TargetAddress);
			if (!string.IsNullOrEmpty(BinNumber))
			{
			BinNumber = BinNumber.TrimEnd('\0').Substring(2);
			//æ ¹æ®è¯»å°çç®±å·è¿è¡æç®±æ£éªï¼æ£éªéè¿å°±è§¦åè¯»ç å¨è¯»åï¼å¦æä¸éè¿å°±æåºå¼å¸¸
			var Verification = _taskService.MaterialBoxInspection(RK3FTask.WMSTaskNum, BinNumber);
			if (!Verification.Status)
			{
			if (RK3FTask.ExceptionMessage != Verification.Message)
			{
			RK3FTask.ExceptionMessage = Verification.Message;
			_taskService.UpdateData(RK3FTask);
			}
			}
			else
			{

			//å¦æè´¨æ£éè¿å°±ä¸æ¹åRK3FTask.TargetAddressçå¼ï¼
			if (!string.IsNullOrEmpty(Verification.Message))
			{
			//å¯»æ¾å¹³åºè´§ä½
			var Location = _stationInfoService.Repository.QueryFirst(x=>x.StationRegion==Verification.Message.ObjToInt()&&x.StationStatus==(int)LocationStatusEnum.Free&&x.FloorNumber=="CC"&&x.IsOccupied==(int)LocationStatusEnum.Free);
			//è¿éè¦å¤æ
			if (Location==null)
			{
			RK3FTask.ExceptionMessage = "$æªæ¾å°{Verification.Message}åºåçè´§ä½{Location}";
			}
			RK3FTask.CurrentAddress = RK3FTask.TargetAddress;
			RK3FTask.NextAddress = Location.StationCode;
			RK3FTask.TargetAddress = Location.StationCode;
			_taskService.UpdateData(RK3FTask);
			}
			//è°ç¨æµ·åº·è¿è¡æ§è¡å®ææ¥å£
			var result = _taskService.Hikvisiontaskscontinue(RK3FTask.WMSTaskNum, RK3FTask.NextAddress);
			if (result.Status)
			{
			RK3FTask.ExceptionMessage = "";
			RK3FTask.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;
			_taskService.UpdateData(RK3FTask);
			}
			else
			{
			if (RK3FTask.ExceptionMessage != result.Message)
			{
			RK3FTask.ExceptionMessage = result.Message;
			_taskService.UpdateData(RK3FTask);
			}
			}
			}
			}
			}
			}
			#endregion

			#region 4Fæåæºåºå£æçå·ä¸æ¥WMS
			var Address = "TSJC4F";
			if (device.GetValue<HoistEnum, short>(HoistEnum.ROutScanningCompletionSignal, Address) == 1)
			{
			var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Emptycontainernumber, Address);
			if (!string.IsNullOrEmpty(BinNumber))
			{
			BinNumber = BinNumber.TrimEnd('\0').Substring(2);
			_taskService.InboundElevatorExit(Address, BinNumber);
			}
			}
			#endregion
			//WriteInfo(device.DeviceName, "infoLog");

			//WriteDebug(device.DeviceName, "debugLog");
			}
			catch (Exception ex)
			{
			@@ -232,7 +272,7 @@
			}
			else
			{
			WriteError(nameof(TestJob), "åæ°éè¯¯,æªä¼ éè®¾å¤åæ°æè®¾å¤ç±»åéè¯¯");
			WriteError(nameof(TSJJob), "åæ°éè¯¯,æªä¼ éè®¾å¤åæ°æè®¾å¤ç±»åéè¯¯");
			}