From 0b4792ff8245f9eac16e6d02452eb9a091f6f72b Mon Sep 17 00:00:00 2001
From: huanghongfeng <huanghongfeng@hnkhzn.com>
Date: 星期二, 28 十月 2025 19:42:04 +0800
Subject: [PATCH] 1
---
代码管理/WCS/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs | 169 +++++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 142 insertions(+), 27 deletions(-)
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs"
index db4b58e..c1a5208 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs"
@@ -6,6 +6,7 @@
using System.Threading.Tasks;
using WIDESEA_Common.Log;
using WIDESEAWCS_Common.TaskEnum;
+using WIDESEAWCS_Core;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_DTO.Enum;
using WIDESEAWCS_ISystemServices;
@@ -29,48 +30,126 @@
private readonly IRouterService _routerService;
private readonly IAgvStationService _agvStationService;
private readonly IMapper _mapper;
+ private readonly IRgvOperationService _gvOperationService;
+ private readonly IEquipmentStatusService _equipmentStatusService;
- public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IAgvStationService agvStation, IMapper mapper)
+ public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IAgvStationService agvStation, IMapper mapper, IRgvOperationService gvOperationService, IEquipmentStatusService equipmentStatusService)
{
_taskService = taskService;
_taskExecuteDetailService = taskExecuteDetailService;
_routerService = routerService;
_agvStationService = agvStation;
_mapper = mapper;
+ _gvOperationService = gvOperationService;
+ _equipmentStatusService=equipmentStatusService;
}
public async Task Execute(IJobExecutionContext context)
{
try
{
-
-
CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
if (conveyorLine != null)
{
- AQMConveyorRgvommand aQMConveyor=AQMCommand(conveyorLine, "AQM001");
- //瀹夊叏闂ㄥ紑闂ㄧ敵璇�+瀹夊叏闂ㄧ姸鎬� 1
- if(aQMConveyor.DoorRequest==1)
+ //鏍规嵁璁惧鏌ユ壘鍑哄搴旂殑绔欏彴淇℃伅
+ List<AGVStation> aGVStations = _agvStationService.GetYljSide(conveyorLine.DeviceCode);
+ foreach (var Stations in aGVStations)
{
- if(aQMConveyor.ResetStatus == 1)
+ /*if (Stations.Station_material == (int)RGVEquipment.AQMexit)
{
- //鍐欏叆杈撻�佺嚎杩涜鍒囨崲淇″彿
- var deviceProDtqh = GetDeviceProDTO(conveyorLine, "AQM001", "IndicatorStatus", "DeviceCommand");
- bool handoffbool = conveyorLine.Communicator.Write(deviceProDtqh.DeviceProDataBlock, (short)3);
- if (handoffbool)
+ //鑾峰彇鍒板畨鍏ㄩ棬淇℃伅
+ AQMReturnnormal aQMConveyor = AQMStoticCommand(conveyorLine, Stations.ChildPosiDeviceCode);
+ if(Stations.Station_tasktype== (int)RGVTasktype.Outbound)
{
- //闇�瑕佸垽鏂璻gv锛屽爢鍨涙満鏄惁鍏佽寮�闂�
+ //璇诲彇鍫嗗灈鏈轰笌RGV鏄惁鍦ㄦ姤璀︼紝濡傛灉鍦ㄦ姤璀︼紝鍒欏啓鍏ュ畨鍏ㄩ棬鎶ヨ
+ if (_gvOperationService.AQMReadAlarminform(2) && _equipmentStatusService.GetSCstatus())
+ {
+ //鍐欏叆鎶ヨ
+ GetDeviceAddress.WriteSecurityDoorpolice(Stations.ChildPosiDeviceCode, "AlarmSummary", 1);
+ }
- //濡傛灉鍏佽寮�闂紝鍒欏啓鍏�4锛岃〃绀哄垏鎹㈡垚鍔燂紝
- bool Maintenancebool = conveyorLine.Communicator.Write(deviceProDtqh.DeviceProDataBlock, (short)4);
+
+ //瀹夊叏闂ㄦ�ュ仠鐘舵��
+ if (aQMConveyor.EmergencyStopStatus == 0)
+ {
+ //绔嬮┈鍋滄鍏ㄩ儴RGV(寰楀垽鏂璕GV鐘舵��,娌″仠姝㈢殑鍒欏仠姝�)
+ _gvOperationService.WriteOutbuttonpause(null);
+
+ }
+
+ //瀹夊叏闂ㄨ繘琛岃姹�
+ if (aQMConveyor.DoorRequest == 1 && aQMConveyor.IndicatorStatus== (int)SafetyDoorStatus.YellowBlink2Hz)
+ {
+ //璇诲彇鍒拌姹傚悗锛屾牴鎹姸鎬佹寚绀虹伅杩涜鎿嶄綔
+ if (aQMConveyor.EmergencyStopStatus == 1 && aQMConveyor.EmergencyStopStatus == 0) //鏈�ュ仠锛岄渶瑕佺敵璇疯繘鍏ヨ澶�
+ {
+ //鐩存帴鍋滄RGV鍔ㄤ綔
+ _gvOperationService.WriteOutbuttonpause(null);
+
+ //璇诲彇瀛愭瘝杞︽槸鍚﹂兘鍦ㄧ┖闂茬姸鎬�
+ if (GetDeviceAddress.OutRGVStatice()) //璇诲彇瀛愭瘝杞︾姸鎬�
+ {
+ //鍐欏叆寮�闂ㄤ俊鍙�
+ GetDeviceAddress.WriteSecurityDoorpolice(Stations.ChildPosiDeviceCode, "OpenDoor", 1);
+ }
+ }
+ }
}
- }
- }
- else
- {
- //璇诲彇DBW8=1,DBW6=1,DBW10=1,DBW4=1,绗﹀悎鍚庯紝杩涜鍐欏叆鍒囨崲鐘舵�丏BW0=3
- AQMReturnnormal aQMReturnnormal=AQMStoticCommand(conveyorLine, "AQM001"); //鍒ゆ柇
+ else
+ {
+ if (_gvOperationService.AQMReadAlarminform(1) && _equipmentStatusService.GetSCstatus())
+ {
+ //鍐欏叆鎶ヨ
+ GetDeviceAddress.WriteSecurityDoorpolice(Stations.ChildPosiDeviceCode, "AlarmSummary", 1);
+ }
+
+ //瀹夊叏闂ㄦ�ュ仠鐘舵��
+ if (aQMConveyor.EmergencyStopStatus == 0)
+ {
+ //绔嬮┈鍋滄鍏ㄩ儴RGV(寰楀垽鏂璕GV鐘舵��,娌″仠姝㈢殑鍒欏仠姝�)
+ _gvOperationService.InWriteOutbuttonpause(null);
+
+ }
+
+ //瀹夊叏闂ㄨ繘琛岃姹�
+ if (aQMConveyor.DoorRequest == 1 && aQMConveyor.IndicatorStatus == (int)SafetyDoorStatus.YellowBlink2Hz)
+ {
+ //璇诲彇鍒拌姹傚悗锛屾牴鎹姸鎬佹寚绀虹伅杩涜鎿嶄綔
+ if (aQMConveyor.EmergencyStopStatus == 1 && aQMConveyor.EmergencyStopStatus == 0) //鏈�ュ仠锛岄渶瑕佺敵璇疯繘鍏ヨ澶�
+ {
+ //鐩存帴鍋滄RGV鍔ㄤ綔
+ _gvOperationService.InWriteOutbuttonpause(null);
+
+ //璇诲彇瀛愭瘝杞︽槸鍚﹂兘鍦ㄧ┖闂茬姸鎬�
+ if (GetDeviceAddress.OutRGVStatice()) //璇诲彇瀛愭瘝杞︾姸鎬�
+ {
+ //鍐欏叆寮�闂ㄤ俊鍙�
+ GetDeviceAddress.WriteSecurityDoorpolice(Stations.ChildPosiDeviceCode, "OpenDoor", 1);
+ }
+ }
+ }
+ }
+ }*/
+ /*else
+ {
+ PlatformStatus aQMConveyor = StoticCommand(conveyorLine, Stations.ChildPosiDeviceCode);
+ if (aQMConveyor.HCJ_GoodsStatus == 0) //鍙繘琛屾斁璐�
+ {
+ WebResponseContent webResponseContent = new WebResponseContent();
+ //鏍规嵁绫诲瀷鏌ユ壘浠诲姟
+ if (Stations.Station_material == (int)RGVEquipment.AbnormalOutbound)
+ {
+ //鏌ユ壘鏄惁鏈夊紓甯告惉杩愪换鍔�
+ webResponseContent = _taskService.UpdateDeliveryAddress(Stations.HCJStorageaddress.ToString(), 1); //杩橀渶瑕佷紶鍏ュ湴鍧�
+ }
+ else
+ {
+ //鍑哄簱绔欏彴鐨勪换鍔�
+ webResponseContent = _taskService.UpdateDeliveryAddress(Stations.HCJStorageaddress.ToString(), 2);
+ }
+ }
+ }*/
}
}
}
@@ -107,18 +186,58 @@
return conveyorRgvCommand;
}
+ /// <summary>
+ /// 瀹夊叏闂ㄤ俊鍙�
+ /// </summary>
public AQMReturnnormal AQMStoticCommand(CommonConveyorLine conveyorLine, string kladder)
{
- AQMReturnnormal conveyorRgvCommand = new AQMReturnnormal();
+ try
+ {
+ AQMReturnnormal conveyorRgvCommand = new AQMReturnnormal();
+ List<DeviceProDTO> deviceProDTO6 = conveyorLine.DeviceProDTOs
+ .Where(x => x.DeviceChildCode == kladder
+ //&& DBLine.ConveyorAQMReturnnormal.Contains(x.DeviceProParamName)
+ && x.DeviceProParamType == "ReadDeviceCommand")
+ .ToList();
+ foreach (var item in deviceProDTO6)
+ {
+ var paramName = item.DeviceProParamName;
+ var propertyInfo = typeof(AQMReturnnormal).GetProperty(paramName);
+
+ if (propertyInfo != null)
+ {
+ if (item.DeviceDataType == "short")
+ {
+ var value = conveyorLine.Communicator.Read<short>(item.DeviceProAddress);
+ propertyInfo.SetValue(conveyorRgvCommand, value);
+ }
+ }
+ }
+ return conveyorRgvCommand;
+ }
+ catch (Exception ex)
+ {
+ return null;
+ throw;
+ }
+ }
+
+ public DeviceProDTO? GetDeviceProDTO(CommonConveyorLine conveyorLine, string PLCmanipula, string DeviceProParamName, string DeviceProParamType)
+ {
+ return conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == PLCmanipula && x.DeviceProParamName == DeviceProParamName && x.DeviceProParamType == DeviceProParamType);
+ }
+
+ public PlatformStatus StoticCommand(CommonConveyorLine conveyorLine, string kladder)
+ {
+ PlatformStatus conveyorRgvCommand = new PlatformStatus();
List<DeviceProDTO> deviceProDTO6 = conveyorLine.DeviceProDTOs
.Where(x => x.DeviceChildCode == kladder
- && DBLine.ConveyorAQMReturnnormal.Contains(x.DeviceProParamName)
&& x.DeviceProParamType == "ReadDeviceCommand")
.ToList();
foreach (var item in deviceProDTO6)
{
var paramName = item.DeviceProParamName;
- var propertyInfo = typeof(AQMReturnnormal).GetProperty(paramName);
+ var propertyInfo = typeof(PlatformStatus).GetProperty(paramName);
if (propertyInfo != null)
{
@@ -132,10 +251,6 @@
return conveyorRgvCommand;
}
- public DeviceProDTO? GetDeviceProDTO(CommonConveyorLine conveyorLine, string PLCmanipula, string DeviceProParamName, string DeviceProParamType)
- {
- return conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == PLCmanipula && x.DeviceProParamName == DeviceProParamName && x.DeviceProParamType == DeviceProParamType);
- }
}
}
--
Gitblit v1.9.3