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;
			@@ -29,14 +30,17 @@
			namespace WIDESEAWCS_Tasks
			{
			[DisallowConcurrentExecution]
			public class TSJJob : JobBase, IJob
			public partial class TSJJob : JobBase, IJob
			{
			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)
			@@ -45,211 +49,11 @@
			if (flag && value != null)
			{
			OtherDevice device = (OtherDevice)value;
			//Example
			//device.GetValue è¯»å
			//device.SetValue åå¥
			// _taskService.Repository ä»å¨å±ï¼è¿è¡æ°æ®åºè®¿é®
			try
			{
			List<Dt_Task> Uptasks = new List<Dt_Task>();
			//æ¥è¯¢ææä»»å¡ç±»åä¸º3,4æ¥¼çå¥åºä»»å¡ç±»åä¸ä»»å¡ç¶æä¸ºAGV_WaitToExecuteçä»»å¡
			var taskList = _taskService.Repository.QueryData(x => x.TaskState == TaskStatusEnum.AGV_WaitToExecute.ObjToInt());
			//ä»»å¡çç®æ å°åå¯¹äºç«å°å·ï¼
			foreach (var task in taskList)
			{
			//åæ£æ¥è®¾å¤ç¶æ
			if (device.GetValue<HoistEnum, short>(HoistEnum.EquipmentStatus, "TSJ") == 2)
			{
			if (task.ExceptionMessage == "æåæºè®¾å¤æé")
			{
			continue;
			}
			task.ExceptionMessage = "æåæºè®¾å¤æé";
			Uptasks.Add(task);
			continue;
			//throw new Exception("è®¾å¤æé");
			}
			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.TargetAddress) != 2)
			{
			if (task.ExceptionMessage == "3æ¥¼å¥åºç®±å·æè´§ï¼è¯·åå¤ç")
			{
			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;
			}
			}
			HKConexecutTask(device);

			PalletNumConfirmation(device);

			//ç¶åè°ç¨è¾éçº¿æ¥å£ï¼éç¥è¾éçº¿ææç®±éè¦å¥åºï¼ä»»å¡ä¸¾è¡æ§è¡
			var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
			if (result.Status == false)
			{
			if (task.ExceptionMessage != result.Message)
			{
			task.ExceptionMessage = result.Message;
			Uptasks.Add(task);
			}
			continue;
			}
			task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
			task.ExceptionMessage = "";
			Uptasks.Add(task);

			//è¿éä»»å¡åæäºCheckPalletCodeing

			}
			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("æ²¡æåºåºæç®±ç¼åæ°éä¸ºç©º");

			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;
			}
			}
			//ç¶åè°ç¨è¾éçº¿æ¥å£ï¼éç¥è¾éçº¿ææç®±éè¦å¥åºï¼ä»»å¡ä¸¾è¡æ§è¡
			var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
			if (result.Status == false)
			{
			if (task.ExceptionMessage != result.Message)
			{
			task.ExceptionMessage = result.Message;
			Uptasks.Add(task);
			}
			continue;
			}
			task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
			task.ExceptionMessage = "";
			Uptasks.Add(task);
			}
			}
			if (Uptasks.Count > 0)
			{
			_taskService.UpdateData(Uptasks);
			}

			#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)
			{
			WriteError(device.DeviceName, "éè¯¯", ex);
			}
			PalletReportingToWMS(device);
			}
			else
			{