From ac2920c6c36227646c03a38c76a335120b449817 Mon Sep 17 00:00:00 2001
From: Zhang-Hong-Lin <a3219986988@163.com>
Date: 星期日, 06 七月 2025 18:29:13 +0800
Subject: [PATCH] 优先级
---
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs | 213 ++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 179 insertions(+), 34 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
index 64f7259..14c5a3b 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
@@ -1,10 +1,12 @@
锘縰sing Autofac.Core;
using HslCommunication;
using HslCommunication.Core;
+using HslCommunication.Enthernet;
using HslCommunication.WebSocket;
using Microsoft.Extensions.Hosting;
using Microsoft.VisualBasic.FileIO;
using Newtonsoft.Json;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using Quartz;
using SixLabors.ImageSharp.PixelFormats;
using System;
@@ -18,6 +20,7 @@
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Communicator;
using WIDESEAWCS_Core;
+using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_ISystemServices;
using WIDESEAWCS_ITaskInfoService;
@@ -25,6 +28,7 @@
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.DeviceBase;
using WIDESEAWCS_QuartzJob.StackerCrane.Enum;
+using WIDESEAWCS_TaskInfoService;
using WIDESEAWCS_Tasks.OHT;
namespace WIDESEAWCS_Tasks
@@ -36,21 +40,31 @@
public static OHTReadData oHTReadData = new OHTReadData();
private readonly ITaskService _taskService;
private readonly Idt_ErrormsginfoService _ErrormsginfoService;
+ private readonly IRepository<Dt_Task_hty> _taskhtyRepository;
WebSocketServer _webSocketServer;
- public OHTJob(ITaskService taskService, WebSocketServer webSocketServer,Idt_ErrormsginfoService errormsginfoService)
+ OtherDevice devicese;
+ OtherDevice deviceses;
+ public OHTJob(ITaskService taskService, WebSocketServer webSocketServer, Idt_ErrormsginfoService errormsginfoService, IRepository<Dt_Task_hty> taskhtyRepository)
{
_taskService = taskService;//娉ㄥ叆
_webSocketServer = webSocketServer;
_ErrormsginfoService = errormsginfoService;
+ _taskhtyRepository = taskhtyRepository;
}
public Task Execute(IJobExecutionContext context)
{
-
+ //return Task.CompletedTask;
bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
if (flag && value != null)
{
//澶╄溅PLC瀵硅薄
OtherDevice device = (OtherDevice)value;
+ OtherDevice zxj = (OtherDevice)Storage.Devices.Find(v => v.DeviceName == "闃虫瀬鏁村舰鏈�");
+ OtherDevice gzj = (OtherDevice)Storage.Devices.Find(v => v.DeviceName == "闃虫瀬瑙勬暣鏈�");
+ devicese = zxj;
+ deviceses = gzj;
+
+
//鏁村舰鏈篜LC瀵硅薄
var ZXJdevice = Storage.Devices.Find(v => v.DeviceName == "闃虫瀬鏁村舰鏈�");
//瑙勬暣鏈篜LC瀵硅薄
@@ -72,11 +86,13 @@
{
throw new Exception(string.Format("澶╄溅鍙栬揣瀹屾垚浠诲姟鏈煡璇㈠埌浠诲姟鍙穥0}", oHTReadData.R_TaskNumber));
}
+ //鍏ュ簱
if (nawtask.TaskType == (int)TaskInboundTypeEnum.Inbound)
{
- //濡傛灉浠诲姟鐨勭姸鎬佹槸澶╄溅鍏ュ簱鍙栬揣鎵ц涓�
+ //濡傛灉浠诲姟鐨勭姸鎬佹槸鍚︽槸澶╄溅鍏ュ簱鍙栬揣鎵ц涓�
if (nawtask.TaskState == (int)TaskInStatusEnum.Line_InGrabExecuting)
{
+ //淇敼鐘舵��
WebResponseContent result = _taskService.UpdateTaskStatusToLine_Ingrab(nawtask);
if (result.Status)
{
@@ -84,16 +100,60 @@
}
}
}
+ //鍑哄簱
else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.Outbound)
{
- //濡傛灉浠诲姟鐘舵�佹槸澶╄溅鍑哄簱鍙栬揣鎵ц涓�
+ //濡傛灉浠诲姟鐘舵�佹槸鍚︽槸澶╄溅鍑哄簱鍙栬揣鎵ц涓�
if (nawtask.TaskState == (int)TaskOutStatusEnum.Line_OutGrabExecuting)
{
+ //淇敼鐘舵��
WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
if (result.Status)
{
device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
}
+ }
+ }
+ //鐩存帴鍑哄簱
+ else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.OutInventory)
+ {
+ //淇敼鐘舵��
+ WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
+ if (result.Status)
+ {
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
+ }
+ }
+ //鍓旈櫎鍑哄簱
+ else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu)
+ {
+ //淇敼鐘舵��
+ WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
+ if (result.Status)
+ {
+ //gzj.SetValue(DeviceDBName.W_GZJ_LockGZJ, true);
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
+ }
+ }
+ //鍓旈櫎鍏ュ簱
+ else if (nawtask.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu)
+ {
+ //淇敼鐘舵��
+ WebResponseContent result = _taskService.UpdateTaskStatusToLine_Ingrab(nawtask);
+ if (result.Status)
+ {
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
+ }
+ }
+ //鍓旈櫎鐩存帴鍑哄簱
+ else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
+ {
+ //淇敼鐘舵��
+ WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
+ if (result.Status)
+ {
+ //gzj.SetValue(DeviceDBName.W_GZJ_LockGZJ, true);
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
}
}
return Task.CompletedTask;
@@ -106,44 +166,79 @@
{
device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
}
+
+ var nawtask = _taskService.QueryTakNnmTask(oHTReadData.R_TaskNumber);
+ if (nawtask == null)
+ {
+ throw new Exception(string.Format("澶╄溅鍙栬揣瀹屾垚浠诲姟鏈煡璇㈠埌浠诲姟鍙穥0}", oHTReadData.R_TaskNumber));
+ }
+ //鍓旈櫎鍑哄簱涓庡墧闄ょ洿鎺ュ嚭搴�
+ //if (nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu || nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
+ //{
+ // gzj.SetValue(DeviceDBName.W_GZJ_LockGZJ, false);
+ //}
+ return Task.CompletedTask;
+ }
+ else if (oHTReadData.R_RunState == (int)RunStateEnum.MoveCompleted && oHTReadData.R_TaskState == (int)TaskStateEnum.TaskComplete)
+ {
+ //澶╄溅绉诲姩瀹屾垚
+ WebResponseContent result = _taskService.StackCraneTaskCompleted(oHTReadData.R_TaskNumber, oHTReadData.weight);
+ if (result.Status)
+ {
+ //鍓旈櫎鍑哄簱銆佺洿鎺ュ嚭搴撶粰瀹屾垚淇″彿
+ //List<Dt_Task_hty> Task_hty = _taskhtyRepository.QueryData();
+ //int shu = Task_hty.Count - 1;
+ //int zhi = Task_hty[shu].TaskId;
+ //Dt_Task_hty lishi = _taskhtyRepository.QueryFirst(x => x.TaskId == zhi);
+ //if (lishi.TargetAddress == "40-2-1")
+ //{
+ // gzj.SetValue(DeviceDBName.W_GZJ_LockGZJ, false);
+ //}
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
+ }
return Task.CompletedTask;
}
#endregion
#region 澶╄溅鍙戦�佷换鍔￠�昏緫
- if (oHTReadData.R_RunMode == (int)RunModeEnum.Automatic )
+ if (oHTReadData.R_RunMode == (int)RunModeEnum.Automatic)
{
if (oHTReadData.R_RunState == (int)RunStateEnum.Standby)
{
- Dt_Task? task = GetTask(InorOut);
- if (task != null)
+ //鏌ョ湅浠诲姟姹犱腑鏄惁瀛樺湪鎵ц涓殑浠诲姟
+ var tasking = _taskService.QueryTasking();
+ if (tasking==null)
{
- OHTTaskCommand? oHTTaskCommand = ConvertToOHTTaskCommand(task);
- if (oHTTaskCommand != null)
+ Dt_Task? task = GetTask(InorOut);
+ if (task != null)
{
- //缁欏ぉ杞︿笅鍙戜换鍔′箣鍓嶅皢姝ゅ�煎啓0
- device.SetValue(DeviceDBName.W_ConfirmSignal, 0);
- //todo锛氬啓鍏ヤ换鍔″懡浠�
- device.SetValue(DeviceDBName.W_Task_Type, oHTTaskCommand.W_Task_Type);
- device.SetValue(DeviceDBName.W_Pick_Line, oHTTaskCommand.W_Pick_Line);
- device.SetValue(DeviceDBName.W_Pick_Column, oHTTaskCommand.W_Pick_Column);
- device.SetValue(DeviceDBName.W_Put_Line, oHTTaskCommand.W_Put_Line);
- device.SetValue(DeviceDBName.W_Put_Column, oHTTaskCommand.W_Put_Column);
- device.SetValue(DeviceDBName.W_Catch_1, oHTTaskCommand.W_Catch_1);
- device.SetValue(DeviceDBName.W_Catch_2, oHTTaskCommand.W_Catch_2);
- device.SetValue(DeviceDBName.W_TaskNumber, oHTTaskCommand.W_TaskNumber);
- device.SetValue(DeviceDBName.W_CheckValue, oHTTaskCommand.W_CheckValue);
- //纭淇″彿鍐欏叆1锛屼换鍔′笅杈惧畬鎴�
- device.SetValue(DeviceDBName.W_ConfirmSignal, 1);
- Thread.Sleep(500);
- //WCS妫�娴嬪埌澶╄溅鐨凴_TaskState=1锛岄�氳繃W_ConfirmSignal缃�2琛ㄧず璁╁ぉ杞﹀紑濮嬫墽琛屼换鍔�
- int R_TaskState = device.GetValue<DeviceDBName, short>(DeviceDBName.R_TaskState);
- if (R_TaskState == 1)
+ OHTTaskCommand? oHTTaskCommand = ConvertToOHTTaskCommand(task);
+ if (oHTTaskCommand != null)
{
- device.SetValue(DeviceDBName.W_ConfirmSignal, 2);
+ //缁欏ぉ杞︿笅鍙戜换鍔′箣鍓嶅皢姝ゅ�煎啓0
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 0);
+ //todo锛氬啓鍏ヤ换鍔″懡浠�
+ device.SetValue(DeviceDBName.W_Task_Type, oHTTaskCommand.W_Task_Type);
+ device.SetValue(DeviceDBName.W_Pick_Line, oHTTaskCommand.W_Pick_Line);
+ device.SetValue(DeviceDBName.W_Pick_Column, oHTTaskCommand.W_Pick_Column);
+ device.SetValue(DeviceDBName.W_Put_Line, oHTTaskCommand.W_Put_Line);
+ device.SetValue(DeviceDBName.W_Put_Column, oHTTaskCommand.W_Put_Column);
+ device.SetValue(DeviceDBName.W_Catch_1, oHTTaskCommand.W_Catch_1);
+ device.SetValue(DeviceDBName.W_Catch_2, oHTTaskCommand.W_Catch_2);
+ device.SetValue(DeviceDBName.W_TaskNumber, oHTTaskCommand.W_TaskNumber);
+ device.SetValue(DeviceDBName.W_CheckValue, oHTTaskCommand.W_CheckValue);
+ //纭淇″彿鍐欏叆1锛屼换鍔′笅杈惧畬鎴�
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 1);
+ Thread.Sleep(500);
+ //WCS妫�娴嬪埌澶╄溅鐨凴_TaskState=1锛岄�氳繃W_ConfirmSignal缃�2琛ㄧず璁╁ぉ杞﹀紑濮嬫墽琛屼换鍔�
+ int R_TaskState = device.GetValue<DeviceDBName, short>(DeviceDBName.R_TaskState);
+ if (R_TaskState == 1)
+ {
+ device.SetValue(DeviceDBName.W_ConfirmSignal, 2);
+ }
+ //涓嬪彂鎴愬姛锛屼慨鏀逛换鍔＄姸鎬�
+ _taskService.UpdateTaskStatus(task.TaskId, oHTTaskCommand.W_Task_Type);
}
- //涓嬪彂鎴愬姛锛屼慨鏀逛换鍔＄姸鎬�
- _taskService.UpdateTaskStatus(task.TaskNum, oHTTaskCommand.W_Task_Type);
}
}
}
@@ -151,8 +246,8 @@
#endregion
}
catch (Exception ex)
- {
- _ErrormsginfoService.UpdateErrorMsg(ex.Message,1);
+ {
+ _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);
}
}
return Task.CompletedTask;
@@ -168,8 +263,8 @@
public OHTTaskCommand? ConvertToOHTTaskCommand([NotNull] Dt_Task task)
{
OHTTaskCommand oHtTaskCommand = new OHTTaskCommand();
-
- if (task.TaskState==(int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
+
+ if (task.TaskState == (int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
{
oHtTaskCommand.W_Task_Type = 2;
string[] SourceCodes = task.SourceAddress.Split("-");
@@ -179,6 +274,18 @@
oHtTaskCommand.W_Pick_Column = Convert.ToInt16(SourceCodes[1]);
oHtTaskCommand.W_Put_Line = 0;
oHtTaskCommand.W_Put_Column = 0;
+
+ //鍓旈櫎鍑哄簱(涓嶉渶瑕佸彂閫佷俊鍙�)
+ //鍓旈櫎鍏ュ簱
+ if (task.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu)
+ {
+ devicese.SetValue(DeviceDBName.W_ZXJ_LockLocation, true);
+ }
+ //鍓旈櫎鐩存帴鍑哄簱
+ else if (task.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
+ {
+ devicese.SetValue(DeviceDBName.W_ZXJ_LockLocation, true);
+ }
}
else
{
@@ -198,6 +305,25 @@
oHtTaskCommand.W_Pick_Column =0;
oHtTaskCommand.W_Put_Line = Convert.ToInt16(SourceCodes[0]);
oHtTaskCommand.W_Put_Column = Convert.ToInt16(SourceCodes[1]);
+
+ //鍓旈櫎鍑哄簱
+ //if (task.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu)
+ //{
+ // deviceses.SetValue(DeviceDBName.W_GZJ_LockGZJ, true);
+ //}
+ //鍓旈櫎鍏ュ簱
+ if (task.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu)
+ {
+
+ devicese.SetValue(DeviceDBName.W_ZXJ_LockLocation, false);
+ }
+ //鍓旈櫎鐩存帴鍑哄簱
+ else if (task.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
+ {
+
+ //deviceses.SetValue(DeviceDBName.W_GZJ_LockGZJ, true);
+ devicese.SetValue(DeviceDBName.W_ZXJ_LockLocation, false);
+ }
}
else
{
@@ -207,6 +333,25 @@
}
oHtTaskCommand.W_CheckValue = 3 + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
}
+ else if(task.TaskState == (int)TaskMoveStatusEnum.OutNewMove )
+ {
+ oHtTaskCommand.W_Task_Type = 4;
+ string[] SourceCodes = task.TargetAddress.Split("-");
+ if (SourceCodes.Length == 3)
+ {
+ oHtTaskCommand.W_Pick_Line = 0;
+ oHtTaskCommand.W_Pick_Column = 0;
+ oHtTaskCommand.W_Put_Line = Convert.ToInt16(SourceCodes[0]);
+ oHtTaskCommand.W_Put_Column = Convert.ToInt16(SourceCodes[1]);
+ }
+ else
+ {
+ //鏁版嵁閰嶇疆閿欒
+ _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"浠诲姟婧愬湴鍧�閰嶇疆閿欒锛�");
+ return null;
+ }
+ oHtTaskCommand.W_CheckValue = 4 + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
+ }
if (task.WMSId==1)
{
--
Gitblit v1.9.3