RuiShengZhiNeng/GaoPuLiTiKu.git

			@@ -41,7 +41,6 @@

			public Task Execute(IJobExecutionContext context)
			{

			bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
			if (flag && value != null)
			{
			@@ -49,7 +48,7 @@
			//Example
			//device.GetValue è¯»å
			//device.SetValue åå¥
			// _taskService.Repository ä»å¨å±ï¼è¿è¡æ°æ®åºè®¿é®-
			// _taskService.Repository ä»å¨å±ï¼è¿è¡æ°æ®åºè®¿é®
			try
			{
			List<Dt_Task> Uptasks = new List<Dt_Task>();
			@@ -70,25 +69,41 @@
			continue;
			//throw new Exception("è®¾å¤æé");
			}
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt())
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt() \|\| task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt() \|\| task.TaskType == TaskTypeEnum.F04.ObjToInt())
			{
			//å¤æ3æ¥¼å¥åºç®±å·ææ
			if (device.GetValue<HoistEnum, string>(HoistEnum.OutboundInplace, "TSJ") == "1")
			if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt())
			{
			if (task.ExceptionMessage == "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç")
			//å¤æ3æ¥¼å¥åºç®±å·ææ
			if (device.GetValue<HoistEnum, short>(HoistEnum.OutboundInplace, task.TargetAddress) != 2)
			{
			if (task.ExceptionMessage == "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç")
			{
			continue;
			}
			task.ExceptionMessage = "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç";
			Uptasks.Add(task);
			continue;
			}
			task.ExceptionMessage = "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç";
			Uptasks.Add(task);
			continue;
			}

			else
			{
			if (device.GetValue<HoistEnum, short>(HoistEnum.ReturnbinAvailable, task.TargetAddress) != 2)
			{
			if (task.ExceptionMessage != "4Fæåæºå¥å£æè´§")
			{
			task.ExceptionMessage = "4Fæåæºå¥å£æè´§";
			Uptasks.Add(task);
			}
			continue;
			}
			}


			//ç¶åè°ç¨è¾éçº¿æ¥å£ï¼éç¥è¾éçº¿ææç®±éè¦å¥åºï¼ä»»å¡ä¸¾è¡æ§è¡
			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);
			@@ -98,89 +113,138 @@
			task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
			task.ExceptionMessage = "";
			Uptasks.Add(task);

			//è¿éä»»å¡åæäº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, "TSJ") != 1) throw new Exception("3æ¥¼åºåºæç®±æ²¡æå°ä½");

			if (task.TaskType == TaskTypeEnum.CK3F.ObjToInt())
			{
			//è¯»å3æ¥¼åºåºæç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, task.SourceAddress) != 1)
			{
			if (task.ExceptionMessage != "3æ¥¼æåæºåºå£åçµåé¦æ è´§")
			{
			task.ExceptionMessage = "3æ¥¼æåæºåºå£åçµåé¦æ è´§";
			Uptasks.Add(task);
			}
			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;
			}
			}
			//ç¶åè°ç¨è¾éçº¿æ¥å£ï¼éç¥è¾éçº¿ææç®±éè¦å¥åºï¼ä»»å¡ä¸¾è¡æ§è¡
			if (_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Status == false) throw new Exception($"3æ¥¼åºåºä»»å¡ä¸¾è¡æ§è¡å¤±è´¥ï¼éè¯¯ä¿¡æ¯{_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Message}");//ç»ä»»å¡å·

			//å»æ´æ°ä»»å¡éåå¼
			//å3æ¥¼åºåºç®±åè´§å®æ
			device.SetValue<HoistEnum, short>(HoistEnum.Outboundboxon, 1);
			}
			else if (task.TaskType == TaskTypeEnum.Q1TSJ4.ObjToInt())//4æ¥¼å¥åº
			{
			//åç©ºç®±çæ¶åè¦è¯»ä¸ä¸ªå
			if (device.GetValue<HoistEnum, short>(HoistEnum.Emptycontainernumber, "TSJ") == null) throw new Exception($"4æ¥¼ç©ºç®±,è¯»ç å¨æ²¡æè¯»å°å¼");

			//å¤æ4æ¥¼ç©ºç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.ReturnbinAvailable, "TSJ") == 2) throw new Exception("4æ¥¼åæç®±ä¸ºç©º");
			if (_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Status == false) throw new Exception($"3æ¥¼åºåºä»»å¡ä¸¾è¡æ§è¡å¤±è´¥ï¼éè¯¯ä¿¡æ¯{_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Message}");//ç»ä»»å¡å·
			//åå¥ç©ºç®±æ¾å°ä½ä¿¡å·
			device.SetValue(HoistEnum.Emptyboxplacedinposition, "TSJ", "1");
			}
			else if (task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt()) //åæ¥¼åºåå°æåæº
			{

			//4æ¥¼åºåºæç®±å°ä½
			if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJ") == 2) throw new Exception("4æ¥¼åºåºæç®±æ²¡æå°ä½");
			//åä»¥ä¸ä¸ªåºåºå®æä¿¡å·
			device.SetValue(HoistEnum.Outboundboxretrievalcompleted, "TSJ", "1");
			}


			}


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

			//å¦ææç®±æ£éªæåå°±åå¥è¯»ç å¨çå¼
			var result = _taskService.Hikvisiontaskscontinue(item.WMSTaskNum, item.TargetAddress);
			if (result.Status == false)
			{
			if (item.ExceptionMessage != result.Message)
			{
			item.ExceptionMessage = result.Message;
			Uptasks.Add(item);
			}
			continue;
			task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
			task.ExceptionMessage = "";
			Uptasks.Add(task);
			}
			item.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;


			Uptasks.Add(item);
			}
			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
			{
			if (!string.IsNullOrEmpty(Verification.Message)) RK3FTask.TargetAddress = Verification.Message;
			//å¦ææç®±æ£éªæåå°±åå¥è¯»ç å¨çå¼
			var result = _taskService.Hikvisiontaskscontinue(RK3FTask.WMSTaskNum, RK3FTask.TargetAddress);
			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)
			{
			@@ -189,7 +253,7 @@
			}
			else
			{
			WriteError(nameof(TestJob), "åæ°éè¯¯,æªä¼ éè®¾å¤åæ°æè®¾å¤ç±»åéè¯¯");
			WriteError(nameof(TSJJob), "åæ°éè¯¯,æªä¼ éè®¾å¤åæ°æè®¾å¤ç±»åéè¯¯");
			}