MingHeZhiNeng/JiaXingRGV.git

			@@ -20,6 +20,7 @@
			using WIDESEA_Common.Log;
			using WIDESEAWCS_Common.TaskEnum;
			using WIDESEAWCS_Core;
			using WIDESEAWCS_Core.BaseRepository;
			using WIDESEAWCS_Core.Enums;
			using WIDESEAWCS_DTO.Enum;
			using WIDESEAWCS_ISystemServices;
			@@ -48,15 +49,19 @@
			private readonly ITaskRepository _taskRepository;
			private readonly IRouterService _routerService;
			private readonly IAgvStationService _agvStationService;
			IRepository<AbnormalTask> _abnormalTask;
			IRgvoperainformService _rgvoperainformService;


			public SpeStackerCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IAgvStationService agvStationService)
			public SpeStackerCraneJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IAgvStationService agvStationService, IRepository<AbnormalTask> abnormalTask, IRgvoperainformService rgvoperainformService)
			{
			_taskService = taskService;
			_taskExecuteDetailService = taskExecuteDetailService;
			_taskRepository = taskRepository;
			_routerService = routerService;
			_agvStationService = agvStationService;
			_abnormalTask = abnormalTask;
			_rgvoperainformService = rgvoperainformService;
			}


			@@ -64,10 +69,15 @@
			{
			try
			{
			//WriteLog.Write_Log("23");

			SpeStackerCrane speStackerCrane = (SpeStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
			if (speStackerCrane != null)
			{
			GetStackerObject getStackerObject = new GetStackerObject(speStackerCrane);

			_rgvoperainformService.LogAlarmToDatabase(speStackerCrane.DeviceCode);


			if (getStackerObject.RGVInitializationValue == RGVInitialize.Initialized)
			{
			@@ -78,7 +88,7 @@
			}

			//å¤æå½åè®¾å¤æ¯å¥åºè¿æ¯åºåº
			/*if (GetDeviceAddress.OutbounMotherChildCartbool(speStackerCrane.DeviceCode))
			if (GetDeviceAddress.OutbounMotherChildCartbool(speStackerCrane.DeviceCode))
			{
			//å¤æå½åå®å¨é¨æ¯å¦ä¸ºç»¿è²ç¯
			if (GetDeviceAddress.ReadAqmDecicStice(1))
			@@ -92,11 +102,8 @@
			if (GetDeviceAddress.ReadAqmDecicStice(2))
			{
			return null;
			}
			}*/



			}
			}


			if (getStackerObject.RgvCraneAutoStatusValue == RgvCraneAutoStatus.Automatic &&
			@@ -161,12 +168,25 @@
			}
			else if (getStackerObject.StaclerkJobJobStatusValue == RGV_Rgvtaskstutas.AbnormalCompletion && getStackerObject.CurrentRgvtaskid != 0 && getStackerObject.CurrentRgvtaskid != 30001)
			{

			string ErrorContent = RgvOperationService.AQMReadAlarminform();
			if (ErrorContent != null && ErrorContent != "")
			{
			_abnormalTask.AddData(new AbnormalTask
			{
			TaskNum = getStackerObject.CurrentRgvtaskid,
			ErrorContent = ErrorContent,
			CreateDate = DateTime.Now,
			Creater = "system",
			});
			}
			//ä¿®æ¹ä»»å¡ç¶æä¸ºå¼å¸¸å®æ
			_taskService.HandleInAbnormal(getStackerObject.CurrentRgvtaskid);

			//åå¥å¼å¸¸å®ææ¥è¦ä¿¡æ¯
			speStackerCrane.Communicator.Write<short>("DB101.36", 1); //åå¥æ¥è¦
			//speStackerCrane.Communicator.Write<short>("DB101.36", 1); //åå¥æ¥è¦

			speStackerCrane.SetValue(RGV_taskcoDBName.RGV_taskcomplete, 1);
			speStackerCrane.SetValue(RGV_taskcoDBName.RGV_taskcomplete, 0);
			}
			}
			#endregion
			@@ -216,23 +236,32 @@
			public Dt_Task? ForkliftUnloading(AGVStation RGVTaskdevice)
			{
			Dt_Task dt_Task = _taskService.GetInkouFinhuoTask(RGVTaskdevice.ChildPosiDeviceCode);

			if (dt_Task == null) return null;
			//å¤æHCJæ¯å¦æè´§
			if (GetDeviceAddress.HCJIsstock(dt_Task.NextAddress))
			{
			//å¤æåè½¦æ¯å¦å¨æ¥é©³å°ä¸
			var zichestation = _agvStationService.OutGetZicheDeepHCJ(1061);
			int ziche = GetDeviceAddress.GetEquipmentlocation(zichestation.ChildPosiDeviceCode);
			if ((ziche == zichestation.WaitmomentOne \|\| ziche == zichestation.WaitmomentTwo \|\| ziche == zichestation.MotherCarDeviceCode \|\| ziche == zichestation.MotherCardeputy \|\| ziche == zichestation.HCJStorageaddress) && ziche != 1021)
			if ((ziche == zichestation.WaitmomentOne \|\| ziche == zichestation.WaitmomentTwo \|\| ziche == zichestation.MotherCarDeviceCode \|\| ziche == zichestation.MotherCardeputy \|\| ziche == zichestation.HCJStorageaddress) && ziche != 1021 && ziche !=0)
			{
			//è·åè¿ä¸ªæ¥é©³å°æ¯å¦æåè´§ä»»å¡
			Dt_Task zitask = _taskService.ViceChariotPickupTask2(RGVTaskdevice.ChildPosiDeviceCode);
			if (zitask == null)
			{

			return dt_Task;
			}
			}
			else
			{
			//å¦ææ²¡è´§ï¼åä¸åç§»å¨ä»»å¡
			RGVMovetask(RGVTaskdevice.HCJStorageaddress, RGVTaskdevice.ChildPosiDeviceCode);
			}
			}
			else
			{
			//å¦ææ²¡è´§ï¼åä¸åç§»å¨ä»»å¡
			RGVMovetask(RGVTaskdevice.HCJStorageaddress, RGVTaskdevice.ChildPosiDeviceCode);
			}
			return null;
			}
			@@ -244,6 +273,10 @@
			//è·ååè½¦åè´§ä»»å¡
			Dt_Task dt_Task = _taskService.ViceChariotPickupTask(RGVTaskdevice.ChildPosiDeviceCode);
			if (dt_Task == null) return null;

			//å¤æHCJç«å°æ¯å¦æè´§
			if (GetDeviceAddress.HCJIsstock(dt_Task.CurrentAddress)) return null;

			if (RGVTaskdevice.Station_Area == 6) //å¤ä¾§è¿åè´§ï¼åéè¦å¤æåè½¦å½åä½ç½®
			{
			if (getStackerObject.RGVCurrentlocation == RGVTaskdevice.WaitmomentOne)
			@@ -270,27 +303,24 @@
			}
			else if (mu2 == InMotherVehicle.Motherinlaw)
			{
			RGVMovetask(InMotherVehicle.ZicheMotherinlaw, InMotherVehicle.ChildPosiDeviceCode);

			//å¤ææ¯è½¦æ¯å¦æä»»å¡
			Dt_Task muche1task = _taskService.MothermachinemovementTask2(InMotherVehicle.ChildPosiDeviceCode);
			if (muche1task == null)
			{
			RGVMovetask(InMotherVehicle.ZicheMotherinlaw, InMotherVehicle.ChildPosiDeviceCode);
			}
			}
			}
			}
			//=============================æ°å¢å½å»åè´§æ¶è¿è¡å¤æå··éï¼çè½ä¸è½æåæåºæ¯è½¦
			return dt_Task;
			}
			//å»æåå ï¼å¨è¯¥åºåè½¦å»åè´§ï¼å¯ç´æ¥ç©¿è¿æ è´§æ¯è½¦ï¼æè½¦
			/*else
			{
			Dt_Task task = _taskService.MothermachinemovementTask2(RGVTaskdevice.ChildPosiDeviceCode);
			if (task == null)
			{
			RGVMovetask(mu1rgv.Motherinlaw, mu1rgv.ChildPosiDeviceCode);
			}
			}*/

			}
			else if (getStackerObject.RGVCurrentlocation == RGVTaskdevice.WaitmomentTwo) //åéè¦å¤æä¸¤ä¸ªæ¯è½¦çä½å
			{
			//å¤æä¸¤ä¸ªåè½¦æ¯å¦å¨å åæºåè´§å£
			//å¤æä¸¤ä¸ªæ¯è½¦æ¯å¦å¨å åæºåè´§å£

			//æ¯è½¦1
			var mu1rgv = _agvStationService.GetMothervehicle(RGVTaskdevice.MotherCarDeviceCode);
			@@ -350,6 +380,29 @@
			{
			return dt_Task;
			}

			//å¤æåä¾§æ¯å¦æè´§ï¼æ¯å¦æä»»å¡

			if (int.Parse(dt_Task.TargetAddress) == (int)StorageAisleEnum.LaneThree \|\| int.Parse(dt_Task.TargetAddress) == (int)StorageAisleEnum.LaneFour)
			{
			int taraddress = int.Parse(dt_Task.TargetAddress);
			var InMotherVehicle = _agvStationService.ObtainCcordingTunnel(taraddress); //è·åå°éè¦å¥åºçæ¯è½¦(2å··é)
			int mu2 = GetDeviceAddress.GetEquipmentlocation(InMotherVehicle.ChildPosiDeviceCode); //æ¤æ¶çRGVåºè¯¥æ è´§
			if (GetDeviceAddress.Mucheywhaddres(InMotherVehicle.ChildPosiDeviceCode)) //å¤ææ è´§
			{
			if (mu2 == InMotherVehicle.Motherinlaw)
			{
			//å¤ææ¯è½¦æ¯å¦æä»»å¡
			Dt_Task muche1task = _taskService.MothermachinemovementTask2(InMotherVehicle.ChildPosiDeviceCode);
			if (muche1task == null)
			{
			RGVMovetask(InMotherVehicle.ZicheMotherinlaw, InMotherVehicle.ChildPosiDeviceCode);
			}
			}

			}
			}


			}
			else if (getStackerObject.RGVCurrentlocation == RGVTaskdevice.WaitmomentTwo) //éè¦å¤æ3å··éæ¯è½¦æ¯å¦å¨åè´§ç«å°
			@@ -462,7 +515,7 @@
			{
			//å¤ææ¯è½¦æ¯å¦æä»»å¡
			Dt_Task _Task1 = _taskService.MothermacTask(Muche.ChildPosiDeviceCode);
			if (task == null)
			if (_Task1 == null)
			{
			RGVMovetask(Muche.ZicheMotherinlaw, Muche.ChildPosiDeviceCode); //å¦ææ²¡æä»»å¡ï¼åå¯ä»¥è¿è¡ç§»å¨åºæ¥
			}
			@@ -512,8 +565,8 @@
			Dt_Task task = _taskService.MothermachinemovementTask2(Muche2.ChildPosiDeviceCode); //è·åå°æ¯è½¦ç§»å¨ä»»å¡
			if (task == null)
			{
			Dt_Task _Task1 = _taskService.MothermacTask(Muche.ChildPosiDeviceCode);
			if (task == null)
			Dt_Task _Task1 = _taskService.MothermacTask(Muche2.ChildPosiDeviceCode);
			if (_Task1 == null)
			{
			RGVMovetask(Muche2.ZicheMotherinlaw, Muche2.ChildPosiDeviceCode); //å¦ææ²¡æä»»å¡ï¼åå¯ä»¥è¿è¡ç§»å¨åºæ¥
			}
			@@ -607,7 +660,7 @@
			=> Findshippingtask(RGVTaskdevice, getStackerObject.RGVCurrentlocation), //åè½¦åè´§åï¼è¿è¡æ¾è´§ï¼å·²å®æï¼

			((int)RGVEquipment.OutRGVForklift, RgvEquipmentStatus.NoCargo)
			=> OutboundGateVehicle(RGVTaskdevice), //åºåºå£RGVåè´§ï¼å·²å®æï¼
			=> OutboundGateVehicle(RGVTaskdevice), //åºåºå£RGVåè´§ï¼å·²å®æï¼

			((int)RGVEquipment.OutRGVForklift, RgvEquipmentStatus.HasCargo)
			=> _taskService.GetOutkouFinhuoTask(RGVTaskdevice.ChildPosiDeviceCode,
			@@ -731,6 +784,16 @@
			{
			return dtTasks;
			}
			else
			{
			//å¦ææ¯è½¦æ è´§ï¼åä¸å°éé¢å»
			bool NoCargobool = GetDeviceAddress.Mucheywhaddres(muchestation.ChildPosiDeviceCode);
			if (NoCargobool)
			{
			//ä¸åæ¯è½¦ç§»å¨ä»»å¡
			RGVMovetask(muchestation.Motherinlaw, muchestation.ChildPosiDeviceCode);
			}
			}
			}
			}
			}
			@@ -767,6 +830,16 @@
			{
			return dtTasks;
			}
			else
			{
			//å¦ææ¯è½¦æ è´§ï¼åä¸å°éé¢å»
			bool NoCargobool = GetDeviceAddress.Mucheywhaddres(muchestation.ChildPosiDeviceCode);
			if (NoCargobool)
			{
			//ä¸åæ¯è½¦ç§»å¨ä»»å¡
			RGVMovetask(muchestation.Motherinlaw, muchestation.ChildPosiDeviceCode);
			}
			}
			}

			}
			@@ -784,6 +857,25 @@

			var mu2rgv = _agvStationService.GetMothervehicle(GdZiche.MotherCardeputy);
			int mu2 = GetDeviceAddress.GetEquipmentlocation(mu2rgv.ChildPosiDeviceCode);

			//éè¦å¤ææ¯è½¦æ¯å¦æè´§ï¼æ è´§åä¸æ¹è³ç§»å¨ä»»å¡
			bool NoCargobool = GetDeviceAddress.Mucheywhaddres(mu1rgv.ChildPosiDeviceCode);
			if (NoCargobool)
			{
			//ä¸åæ¯è½¦ç§»å¨ä»»å¡
			RGVMovetask(mu1rgv.Motherinlaw, mu1rgv.ChildPosiDeviceCode);
			}


			bool NoCargobool2 = GetDeviceAddress.Mucheywhaddres(mu2rgv.ChildPosiDeviceCode);
			if (NoCargobool2)
			{
			//ä¸åæ¯è½¦ç§»å¨ä»»å¡
			RGVMovetask(mu2rgv.Motherinlaw, mu2rgv.ChildPosiDeviceCode);
			}




			if (mu1 == mu1rgv.Motherinlaw && mu2 == mu2rgv.Motherinlaw)
			{
			@@ -849,7 +941,12 @@
			int mucboject4 = GetDeviceAddress.GetEquipmentlocation(muchestation2.ChildPosiDeviceCode);
			if (mucboject4 == muchestation2.Motherinlaw)
			{
			return task;
			//å¤æåè½¦æ¯å¦æåè´§ä»»å¡
			Dt_Task chachetask = _taskService.ChacheGetFinhuoTask("RGV118");
			if(chachetask == null)
			{
			return task;
			}
			}

			}
			@@ -987,6 +1084,13 @@
			}

			}
			}else if(task != null && RgvCraneStatusValue == (int)RgvEquipmentStatus.NoCargo)
			{
			if (GdZiche.HCJStorageaddress == RGVCurrentlocation)
			{
			//å¦æå¨2å··éçæ¯è½¦ï¼åå¯ä»¥æ¾åè½¦æ¥1å·çå¾ç¹ï¼å¦æå¨HCJåå¯ä»¥è®©åè½¦å»2å·
			RGVMovetask(GdZiche.WaitmomentTwo, GdZiche.ChildPosiDeviceCode);
			}
			}
			}
			}