From ec899ee7e9ead5152bd9b4c2dedd75c79cab6fb0 Mon Sep 17 00:00:00 2001
From: wxw <Administrator@DESKTOP-5BIMHQ3>
Date: 星期三, 28 八月 2024 17:03:44 +0800
Subject: [PATCH] Merge branch 'master' into wxw
---
Admin.NET/WCS.Application/PLC/PLCJob.cs | 1
Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs | 58 ++++
Admin.NET/WCS.Application/Util/HttpService.cs | 28 ++
.gitignore | 1
Web/src/api/wcs/wcsTask.ts | 8
Admin.NET/WCS.Application/Configuration/Logging.json | 2
Admin.NET/WCS.Application/Hub/TaskLogHub.cs | 56 ++++
Web/src/api/log/wcsAlarmLog.ts | 50 +++
Admin.NET/WCS.Application/Hub/ITaskLogHub.cs | 25 +
Admin.NET/Admin.NET.Core/Logging/LoggingSetup.cs | 5
Web/src/views/wcs/wcsDevice/component/editDialog.vue | 4
Admin.NET/WCS.Application/PLC/PLCService.cs | 327 +++++++++++++++++-------
Web/src/views/wcs/wcsTask/signalR.ts | 37 ++
Admin.NET/WCS.Application/PLC/PLCTaskAction.cs | 4
Admin.NET/WCS.Application/Service/WcsDevice/Dto/WcsDeviceDto.cs | 10
Web/src/views/wcs/wcsTask/index.vue | 120 ++++++---
16 files changed, 583 insertions(+), 153 deletions(-)
diff --git a/.gitignore b/.gitignore
index 10d1295..b1a5d68 100644
--- a/.gitignore
+++ b/.gitignore
@@ -200,6 +200,7 @@
# except build/, which is used as an MSBuild target.
!**/[Pp]ackages/build/
!**/system/log/
+!**/api/log/
# Uncomment if necessary however generally it will be regenerated when needed
#!**/[Pp]ackages/repositories.config
# NuGet v3's project.json files produces more ignorable files
diff --git a/Admin.NET/Admin.NET.Core/Logging/LoggingSetup.cs b/Admin.NET/Admin.NET.Core/Logging/LoggingSetup.cs
index 99e372f..33e1dd2 100644
--- a/Admin.NET/Admin.NET.Core/Logging/LoggingSetup.cs
+++ b/Admin.NET/Admin.NET.Core/Logging/LoggingSetup.cs
@@ -45,7 +45,10 @@
options.WithTraceId = true; // 鏄剧ず绾跨▼Id
options.WithStackFrame = true; // 鏄剧ず绋嬪簭闆�
options.FileNameRule = fileName => string.Format(fileName, DateTime.Now, logLevel.ToString()); // 姣忓ぉ鍒涘缓涓�涓枃浠�
- options.WriteFilter = logMsg => logMsg.LogLevel >= logLevel; // 鏃ュ織绾у埆
+ options.WriteFilter = (logMsg) =>
+ {
+ return logMsg.LogLevel >= logLevel && logMsg.LogName != CommonConst.SysLogCategoryName; // 鍙啓LoggingMonitor鏃ュ織
+ }; // 鏃ュ織绾у埆
options.HandleWriteError = (writeError) => // 鍐欏叆澶辫触鏃跺惎鐢ㄥ鐢ㄦ枃浠�
{
writeError.UseRollbackFileName(Path.GetFileNameWithoutExtension(writeError.CurrentFileName) + "-oops" + Path.GetExtension(writeError.CurrentFileName));
diff --git a/Admin.NET/WCS.Application/Configuration/Logging.json b/Admin.NET/WCS.Application/Configuration/Logging.json
index f1e9833..8e8520c 100644
--- a/Admin.NET/WCS.Application/Configuration/Logging.json
+++ b/Admin.NET/WCS.Application/Configuration/Logging.json
@@ -6,7 +6,7 @@
"Microsoft.EntityFrameworkCore": "Information"
},
"File": {
- "Enabled": false, // 鍚敤鏂囦欢鏃ュ織
+ "Enabled": true, // 鍚敤鏂囦欢鏃ュ織
"FileName": "logs/{0:yyyyMMdd}_{1}.log", // 鏃ュ織鏂囦欢
"Append": true, // 杩藉姞瑕嗙洊
// "MinimumLevel": "Information", // 鏃ュ織绾у埆
diff --git a/Admin.NET/WCS.Application/Hub/ITaskLogHub.cs b/Admin.NET/WCS.Application/Hub/ITaskLogHub.cs
new file mode 100644
index 0000000..0b0dd6b
--- /dev/null
+++ b/Admin.NET/WCS.Application/Hub/ITaskLogHub.cs
@@ -0,0 +1,25 @@
+锘�
+namespace WCS.Application;
+public interface ITaskLogHub
+{
+ /// <summary>
+ /// 涓嬪彂浠诲姟
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ Task PublicTask(WcsTaskOutput context);
+
+ /// <summary>
+ /// 涓嬪彂浠诲姟鏄庣粏
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ Task PublicTaskMonitor(WcsTaskMonitorOutput context);
+
+ /// <summary>
+ /// 鎺ユ敹娑堟伅
+ /// </summary>
+ /// <param name="context"></param>
+ /// <returns></returns>
+ Task ReceiveMessage(object context);
+}
diff --git a/Admin.NET/WCS.Application/Hub/TaskLogHub.cs b/Admin.NET/WCS.Application/Hub/TaskLogHub.cs
new file mode 100644
index 0000000..b4d018c
--- /dev/null
+++ b/Admin.NET/WCS.Application/Hub/TaskLogHub.cs
@@ -0,0 +1,56 @@
+锘縰sing Furion.InstantMessaging;
+using Microsoft.AspNetCore.SignalR;
+
+namespace WCS.Application;
+
+/// <summary>
+/// 浠诲姟鏃ュ織闆嗙嚎鍣�
+/// </summary>
+[MapHub("/hubs/TaskLog")]
+public class TaskLogHub : Hub<ITaskLogHub>
+{
+ private readonly IHubContext<TaskLogHub, ITaskLogHub> _taskLogHubContext;
+
+ public TaskLogHub(IHubContext<TaskLogHub, ITaskLogHub> taskLogHubContext)
+ {
+ _taskLogHubContext = taskLogHubContext;
+ }
+
+ /// <summary>
+ /// 杩炴帴
+ /// </summary>
+ /// <returns></returns>
+ public override async Task OnConnectedAsync()
+ {
+ await base.OnConnectedAsync();
+ }
+
+ /// <summary>
+ /// 鏂紑
+ /// </summary>
+ /// <param name="exception"></param>
+ /// <returns></returns>
+ public override async Task OnDisconnectedAsync(Exception exception)
+ {
+ await base.OnDisconnectedAsync(exception);
+ }
+
+ /// <summary>
+ /// 涓嬪彂浠诲姟
+ /// </summary>
+ /// <returns></returns>
+ public async Task PublicTask(WcsTaskOutput context)
+ {
+ await _taskLogHubContext.Clients.All.PublicTask(context);
+ }
+
+ /// <summary>
+ /// 涓嬪彂浠诲姟鏄庣粏
+ /// </summary>
+ /// <returns></returns>
+ public async Task PublicTaskMonitor(WcsTaskMonitorOutput context)
+ {
+ await _taskLogHubContext.Clients.All.PublicTaskMonitor(context);
+ }
+
+}
diff --git a/Admin.NET/WCS.Application/PLC/PLCJob.cs b/Admin.NET/WCS.Application/PLC/PLCJob.cs
index 3927eca..eb66aae 100644
--- a/Admin.NET/WCS.Application/PLC/PLCJob.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCJob.cs
@@ -1,4 +1,5 @@
锘縰sing Furion.Schedule;
+using Microsoft.AspNetCore.SignalR;
using Microsoft.Extensions.Logging;
namespace WCS.Application;
diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index cf5a94c..7f56930 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -1,12 +1,19 @@
锘�
using Furion.Logging;
using IoTClient;
+using Microsoft.AspNetCore.SignalR;
using System.Data;
namespace WCS.Application;
public static class PLCService
{
private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
+ private static readonly IHubContext<TaskLogHub, ITaskLogHub> _taskLogHubContext;
+
+ static PLCService()
+ {
+ _taskLogHubContext = App.GetService<IHubContext<TaskLogHub, ITaskLogHub>>();
+ }
public static void OnChangeEvent(object sender, EventArgs e)
{
@@ -107,12 +114,8 @@
modTaskMonitor.InteractiveMsg = "璧峰鍌ㄤ綅涓虹┖!";
_db.Insertable(modTaskMonitor).ExecuteCommand();
-
- // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
break;
}
//缁橮LC鍐欏叆浠诲姟鏁版嵁
@@ -144,7 +147,7 @@
if (listResult.All(s => s.IsSucceed))
{
// 鍐欏叆璺烘満浠诲姟涓嬪彂瀹屾垚
- plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "10");
+ plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "10");
// 灏嗗嚭搴撲换鍔″緟鎵ц鏀逛负姝ｅ湪鎵ц
_db.Updateable<WcsTask>()
@@ -165,11 +168,8 @@
EndLocat = outStationNum,
};
_db.Insertable(modInsertTaskMonitor).ExecuteCommand();
- // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modInsertTaskMonitor.Adapt<WcsTaskMonitorOutput>());
//淇敼led灞忎俊鎭�
//LedDisplay(modDevice.LedIP, "宸ヤ綅:" + modTask.EndLocate, "鍑哄簱涓� " + $"鍌ㄤ綅鍦板潃锛歿modTask.StartLocate}", "鎵樼洏鍙�:" + modTask.PalletNo);
}
@@ -236,11 +236,8 @@
Status = TaskStatusEnum.Complete
};
_db.Insertable(modTaskMonitor).ExecuteCommand();
- //閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
}
else if (modTask.TaskType.Value == TaskTypeEnum.Out)
@@ -249,7 +246,7 @@
var res = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, taskNo);
if (!res.IsSucceed)
break;
- res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "20");
+ res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "20");
if (!res.IsSucceed)
break;
// 鏍规嵁璺烘満鍙风‘璁ゅ彇璐у伐浣�
@@ -277,11 +274,8 @@
Status = TaskStatusEnum.Complete
};
_db.Insertable(modTaskMonitor).ExecuteCommand();
- //閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
}
}
break;
@@ -310,7 +304,7 @@
var res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, taskNo);
if (!res.IsSucceed)
break;
- res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "30");
+ res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
if (!res.IsSucceed)
break;
//淇敼浠诲姟鐘舵��
@@ -344,11 +338,8 @@
Status = TaskStatusEnum.Complete
};
_db.Insertable(modTaskMonitor).ExecuteCommand();
- // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
}
else
{
@@ -363,80 +354,129 @@
}
break;
case TaskTypeEnum.Out://鍑哄簱
- // 浠庡嚭搴撲换鍔¤幏鍙栧贩閬撳彿
- string num = ""; // 鏀捐揣宸ヤ綅鍙�
- if (modTask.StartRoadway == "R01")
{
- num = "11"; //浜や簰宸ヤ綅
- }
- else if (modTask.StartRoadway == "R02")
- {
- num = "7"; //浜や簰宸ヤ綅
- }
- var modDevice2 = modDevice.listDevice.FirstOrDefault(s => s.StationNum == num);
- if (modDevice2 == null)
- {
- Log.Error($"銆愯泛鏈恒�戞壘涓嶅埌宸ヤ綅{num}璁惧淇℃伅");
- break;
- }
- // 鏍规嵁鐩爣鍙ｈ幏鍙栫洰鏍囧伐浣�
- string outCode = modTask.EndLocate.IsNullOrEmpty() ? "-1" : modTask.EndLocate;
-
- var listStation = _db.Queryable<WcsPosition>().Where(s => s.DeviceId == modDevice2.Id).ToList();
- //缁橮LC鍐欏叆浠诲姟鏁版嵁
- var listResult = new List<Result>();
- //浠诲姟鍙�
- var modPosTask = listStation.FirstOrDefault(s => s.Text == "TaskNo");
- listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
- //鎵樼洏鍙�
- var modPosPalletNo = listStation.FirstOrDefault(s => s.Text == "PalletNo");
- listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
- //璧峰宸ヤ綅
- var modPosLocatNo = listStation.FirstOrDefault(s => s.Text == "StartLocatNo");
- listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, num));
- // 鐩爣宸ヤ綅
- var modPosEndLocatNo = listStation.FirstOrDefault(s => s.Text == "EndLocatNo");
- listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
- //鍏ㄩ儴鍐欏叆鎴愬姛
- if (listResult.All(s => s.IsSucceed))
- {
- // 鍐欏叆宸ヤ綅wcs鎺у埗瀛�
- var res = plcConn.SetPlcDBValue(modDevice2.PosType, modDevice2.DbNumber, modDevice2.WcsPos, "120");
- if (!res.IsSucceed)
- break;
- //鍐欏叆plc浠诲姟鍙�
- var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
- res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, modTask.TaskNo);
- if (!res.IsSucceed)
- break;
- //鍐欏叆璺烘満wcs鎺у埗瀛楁祦绋�30 杩斿洖鍨涙満鎵ц瀹屾垚
- res = plcConn.SetPlcDBValue(modDevice.PosType.Value, modDevice.DbNumber, modDevice.WcsPos, "30");
- if (!res.IsSucceed)
- break;
- //璁板綍浠诲姟鏄庣粏
- var modTaskMonitor = new WcsTaskMonitor()
+ // 浠庡嚭搴撲换鍔¤幏鍙栧贩閬撳彿
+ string num = ""; // 鏀捐揣宸ヤ綅鍙�
+ if (modTask.StartRoadway == "R01")
{
- TaskNo = modTask.TaskNo,
- PlcId = modDevice2.PlcId,
- PlcName = modDevice2.Text,
- InteractiveMsg = $"鍐欏叆鎸囦护锛氭敹鍒拌泛鏈烘斁璐у畬鎴愶紱鏀捐揣{num}宸ヤ綅===銆媨outCode}鍑哄簱鍙�",
- PalletNo = modTask.PalletNo,
- Status = TaskStatusEnum.Complete,
- StartLocat = num, //璧峰浣嶇疆
- EndLocat = outCode, //鐩爣宸ヤ綅
- };
- _db.Insertable(modTaskMonitor).ExecuteCommand();
+ num = "11"; //浜や簰宸ヤ綅
+ }
+ else if (modTask.StartRoadway == "R02")
+ {
+ num = "7"; //浜や簰宸ヤ綅
+ }
+ var modDevice2 = modDevice.listDevice.FirstOrDefault(s => s.StationNum == num);
+ if (modDevice2 == null)
+ {
+ Log.Error($"銆愯泛鏈恒�戞壘涓嶅埌宸ヤ綅{num}璁惧淇℃伅");
+ break;
+ }
+ // 鏍规嵁鐩爣鍙ｈ幏鍙栫洰鏍囧伐浣�
+ string outCode = modTask.EndLocate.IsNullOrEmpty() ? "-1" : modTask.EndLocate;
- // 閫氱煡浠诲姟鐣岄潰浠诲姟宸插瓨鍦ㄦ洿鏂� 璇锋洿鏂扮晫闈�
- //if (TaskAction.refresh)
- //{
- // wSChat.AlarmInformation("1");
- //}
- //todo:鍨涙満鍑哄簱涓嶇┖璺�
+ var listStation = _db.Queryable<WcsPosition>().Where(s => s.DeviceId == modDevice2.Id).ToList();
+ //缁橮LC鍐欏叆浠诲姟鏁版嵁
+ var listResult = new List<Result>();
+ //浠诲姟鍙�
+ var modPosTask = listStation.FirstOrDefault(s => s.Text == "TaskNo");
+ listResult.Add(plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, modTask.TaskNo));
+ //鎵樼洏鍙�
+ var modPosPalletNo = listStation.FirstOrDefault(s => s.Text == "PalletNo");
+ listResult.Add(plcConn.SetPlcDBValue(modPosPalletNo.PosType, modDevice.DbNumber, modPosPalletNo.PlcPos, modTask.PalletNo));
+ //璧峰宸ヤ綅
+ var modPosLocatNo = listStation.FirstOrDefault(s => s.Text == "StartLocatNo");
+ listResult.Add(plcConn.SetPlcDBValue(modPosLocatNo.PosType, modDevice.DbNumber, modPosLocatNo.PlcPos, num));
+ // 鐩爣宸ヤ綅
+ var modPosEndLocatNo = listStation.FirstOrDefault(s => s.Text == "EndLocatNo");
+ listResult.Add(plcConn.SetPlcDBValue(modPosEndLocatNo.PosType, modDevice.DbNumber, modPosEndLocatNo.PlcPos, outCode));
+ //鍏ㄩ儴鍐欏叆鎴愬姛
+ if (listResult.All(s => s.IsSucceed))
+ {
+ // 鍐欏叆宸ヤ綅wcs鎺у埗瀛�
+ var res = plcConn.SetPlcDBValue(modDevice2.PosType, modDevice2.DbNumber, modDevice2.WcsPos, "120");
+ if (!res.IsSucceed)
+ break;
+ //鍐欏叆plc浠诲姟鍙�
+ var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
+ res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, modTask.TaskNo);
+ if (!res.IsSucceed)
+ break;
+ //鍐欏叆璺烘満wcs鎺у埗瀛楁祦绋�30 杩斿洖鍨涙満鎵ц瀹屾垚
+ res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
+ if (!res.IsSucceed)
+ break;
+ //璁板綍浠诲姟鏄庣粏
+ var modTaskMonitor = new WcsTaskMonitor()
+ {
+ TaskNo = modTask.TaskNo,
+ PlcId = modDevice2.PlcId,
+ PlcName = modDevice2.Text,
+ InteractiveMsg = $"鍐欏叆鎸囦护锛氭敹鍒拌泛鏈烘斁璐у畬鎴愶紱鏀捐揣{num}宸ヤ綅===銆媨outCode}鍑哄簱鍙�",
+ PalletNo = modTask.PalletNo,
+ Status = TaskStatusEnum.Complete,
+ StartLocat = num, //璧峰浣嶇疆
+ EndLocat = outCode, //鐩爣宸ヤ綅
+ };
+ _db.Insertable(modTaskMonitor).ExecuteCommand();
+
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+ //todo:鍨涙満鍑哄簱涓嶇┖璺�
+ }
}
-
break;
case TaskTypeEnum.Move:
+ {
+ //绉诲簱浠诲姟
+ var modStation = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
+ // 鍐欏叆plc浠诲姟鍙�
+ var res = plcConn.SetPlcDBValue(modStation.PosType, modDevice.DbNumber, modStation.PlcPos, taskNo);
+ if (!res.IsSucceed)
+ break;
+ //鍐欏叆plc鎺у埗瀛�
+ res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "30");
+ if (!res.IsSucceed)
+ break;
+ modTask.Status = TaskStatusEnum.Complete;
+ _db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
+ var modTaskRequest = modTask.Adapt<TaskRequest>();
+ HttpService httpService = new HttpService();
+ var modResponseTask = httpService.RequestTask(modTaskRequest).Result;
+ if (modResponseTask.StatusCode == "0")
+ {
+ //璇锋眰鎴愬姛
+ modTask.IsSuccess = TaskSuccessEnum.Success;
+ _db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
+ //todo:淇敼鍌ㄤ綅淇℃伅 浠诲姟绫诲瀷 鎵ц鐘舵�� 璧峰浣嶇疆 鐩爣浣嶇疆
+ //
+
+ //璁板綍浠诲姟鏄庣粏
+ var modTaskMonitor = new WcsTaskMonitor()
+ {
+ TaskNo = modTask.TaskNo,
+ PlcId = modDevice.PlcId,
+ PlcName = modDevice.Text,
+ InteractiveMsg = "浠诲姟瀹屾垚锛岃繑鍥炵粰WMS浠诲姟瀹屾垚",
+ StartLocat = modTask.StartLocate,
+ EndLocat = modTask.EndLocate,
+ PalletNo = modTask.PalletNo,
+ Status = TaskStatusEnum.Complete
+ };
+ _db.Insertable(modTaskMonitor).ExecuteCommand();
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+ }
+ else
+ {
+ //璇锋眰澶辫触
+ modTask.IsSuccess = TaskSuccessEnum.Fail;
+ modTask.Information = modResponseTask.Message;
+ _db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
+ }
+
+ //todo:LED灞�
+
+ }
break;
default:
@@ -444,6 +484,99 @@
}
}
break;
+ case "100":
+ {
+ //绌哄彇璐у紓甯�
+ var modPosPlcTask = modDevice.listStation.FirstOrDefault(s => s.Text == "PlcTaskNo");
+ var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
+ var (result, TaskNo) = plcConn.GetPlcDBValue(modPosPlcTask.PosType, modDevice.DbNumber, modPosPlcTask.PlcPos);
+ if (!result.IsSucceed)
+ break;
+ string taskNo = Convert.ToString(TaskNo);
+ var modTask = _db.Queryable<WcsTask>().First(s => s.TaskNo == taskNo && s.Status == TaskStatusEnum.Doing);
+ if (modTask == null)
+ {
+ Log.Error($"銆愯泛鏈恒�戝綋鍓嶄换鍔″彿涓嶅瓨鍦ㄥ搴旂殑浠诲姟锛屼换鍔″彿锛歿modTask.TaskNo}");
+ break;
+ }
+ var res = plcConn.SetPlcDBValue(modPosTask.PosType, modDevice.DbNumber, modPosTask.PlcPos, taskNo);
+ if (!res.IsSucceed)
+ break;
+ res = plcConn.SetPlcDBValue(modDevice.PosType, modDevice.DbNumber, modDevice.WcsPos, "100");
+ if (!res.IsSucceed)
+ break;
+ modTask.Status = TaskStatusEnum.Exception;
+ _db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
+ Log.Information($"銆愯泛鏈恒�憌cs浠诲姟鍙樻洿绌哄彇寮傚父锛屼换鍔″彿锛歿modTask.TaskNo}");
+ var modTaskRequest = modTask.Adapt<TaskRequest>();
+ HttpService httpService = new HttpService();
+ var modResponseTask = httpService.RequestEmptyException(modTaskRequest).Result;
+ if (modResponseTask.StatusCode == "0")
+ {
+ //璇锋眰鎴愬姛
+ modTask.IsSuccess = TaskSuccessEnum.Success;
+ _db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTask(modTask.Adapt<WcsTaskOutput>());
+ }
+ else
+ {
+ //璇锋眰澶辫触
+ modTask.IsSuccess = TaskSuccessEnum.Fail;
+ modTask.Information = modResponseTask.Message;
+ _db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
+ }
+ //todo:LED灞�
+ }
+ break;
+ case "101":
+ {
+ //婊℃斁璐у紓甯�
+ var modPosPlcTask = modDevice.listStation.FirstOrDefault(s => s.Text == "PlcTaskNo");
+ var modPosTask = modDevice.listStation.FirstOrDefault(s => s.Text == "TaskNo");
+ var modPosPalletNo = modDevice.listStation.FirstOrDefault(s => s.Text == "PalletNo");
+ var (result, TaskNo) = plcConn.GetPlcDBValue(modPosPlcTask.PosType, modDevice.DbNumber, modPosPlcTask.PlcPos);
+ if (!result.IsSucceed)
+ break;
+ string taskNo = Convert.ToString(TaskNo);
+ var modTask = _db.Queryable<WcsTask>().First(s => s.TaskNo == taskNo && s.Status == TaskStatusEnum.Doing);
+ if (modTask == null)
+ {
+ Log.Error($"銆愯泛鏈恒�戝綋鍓嶄换鍔″彿涓嶅瓨鍦ㄥ搴旂殑浠诲姟锛屼换鍔″彿锛歿modTask.TaskNo}");
+ break;
+ }
+ modTask.Status = TaskStatusEnum.Exception;
+ _db.Updateable(modTask).UpdateColumns(s => s.Status).ExecuteCommand();
+ Log.Information($"銆愯泛鏈恒�憌cs浠诲姟鍙樻洿婊″彇寮傚父锛屼换鍔″彿锛歿modTask.TaskNo}");
+ var modTaskRequest = modTask.Adapt<TaskRequest>();
+ HttpService httpService = new HttpService();
+ var modResponseTask = httpService.RequestEmptyException(modTaskRequest).Result;
+ if (modResponseTask.StatusCode == "0")
+ {
+ //璇锋眰鎴愬姛
+ modTask.IsSuccess = TaskSuccessEnum.Success;
+ _db.Updateable(modTask).UpdateColumns(s => s.IsSuccess).ExecuteCommand();
+ var modInsertTask = modResponseTask.TaskList;
+ modInsertTask.TaskType = TaskTypeEnum.In;
+ modInsertTask.Origin = "WMS";
+ modInsertTask.StartLocate = modTask.StartLocate;
+ modInsertTask.Levels = 1;
+ _db.Insertable(modInsertTask);
+
+ //涓嬪彂浠诲姟鏃ュ織
+ _taskLogHubContext.Clients.All.PublicTask(modInsertTask.Adapt<WcsTaskOutput>());
+ }
+ else
+ {
+ //璇锋眰澶辫触
+ modTask.IsSuccess = TaskSuccessEnum.Fail;
+ modTask.Information = modResponseTask.Message;
+ _db.Updateable(modTask).UpdateColumns(s => new { s.IsSuccess, s.Information }).ExecuteCommand();
+ }
+ //todo:LED灞�
+
+ }
+ break;
default:
break;
}
diff --git a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
index 0eaf3a5..63086d6 100644
--- a/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCTaskAction.cs
@@ -1,5 +1,5 @@
-锘縰sing Admin.NET.Core.Service;
-using Furion.Logging;
+锘縰sing Furion.Logging;
+using Microsoft.AspNetCore.SignalR;
namespace WCS.Application;
public static class PLCTaskAction
diff --git a/Admin.NET/WCS.Application/Service/WcsDevice/Dto/WcsDeviceDto.cs b/Admin.NET/WCS.Application/Service/WcsDevice/Dto/WcsDeviceDto.cs
index 96cd826..9a3c42d 100644
--- a/Admin.NET/WCS.Application/Service/WcsDevice/Dto/WcsDeviceDto.cs
+++ b/Admin.NET/WCS.Application/Service/WcsDevice/Dto/WcsDeviceDto.cs
@@ -34,27 +34,27 @@
/// <summary>
/// DB鍖哄煙
/// </summary>
- public string? DbNumber { get; set; }
+ public string DbNumber { get; set; }
/// <summary>
/// 宸ヤ綅鍙�
/// </summary>
- public string? StationNum { get; set; }
+ public string StationNum { get; set; }
/// <summary>
/// PLC鍋忕Щ閲�
/// </summary>
- public string? PlcPos { get; set; }
+ public string PlcPos { get; set; }
/// <summary>
/// WCS鍋忕Щ閲�
/// </summary>
- public string? WcsPos { get; set; }
+ public string WcsPos { get; set; }
/// <summary>
/// 娴佺▼瀛楃被鍨�
/// </summary>
- public PLCDataTypeEnum? PosType { get; set; }
+ public PLCDataTypeEnum PosType { get; set; }
/// <summary>
/// 鏄剧ず灞廼p鍦板潃
diff --git a/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs b/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
index 18318cc..6bd9227 100644
--- a/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
+++ b/Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs
@@ -1,4 +1,8 @@
锘�
+using AngleSharp.Dom;
+using Furion.DatabaseAccessor;
+using Microsoft.AspNetCore.SignalR;
+
namespace WCS.Application;
/// <summary>
@@ -8,9 +12,12 @@
public class WcsTaskService : IDynamicApiController, ITransient
{
private readonly SqlSugarRepository<WcsTask> _wcsTaskRep;
- public WcsTaskService(SqlSugarRepository<WcsTask> wcsTaskRep)
+ private readonly IHubContext<TaskLogHub, ITaskLogHub> _taskLogHubContext;
+
+ public WcsTaskService(SqlSugarRepository<WcsTask> wcsTaskRep, IHubContext<TaskLogHub, ITaskLogHub> taskLogHubContext)
{
_wcsTaskRep = wcsTaskRep;
+ _taskLogHubContext = taskLogHubContext;
}
/// <summary>
@@ -23,7 +30,7 @@
[DisplayName("鍒嗛〉鏌ヨ浠诲姟琛�")]
public async Task<SqlSugarPagedList<WcsTaskOutput>> Page(PageWcsTaskInput input)
{
- input.SearchKey = input.SearchKey?.Trim();
+ input.SearchKey = input.SearchKey?.Trim();
var query = _wcsTaskRep.AsQueryable()
.WhereIF(!string.IsNullOrEmpty(input.SearchKey), u =>
u.TaskNo.Contains(input.SearchKey)
@@ -32,7 +39,7 @@
.WhereIF(input.TaskType.HasValue, u => u.TaskType == input.TaskType)
.WhereIF(input.Status.HasValue, u => u.Status == input.Status)
.Select<WcsTaskOutput>();
- return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
+ return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
}
/// <summary>
@@ -105,7 +112,50 @@
return await _wcsTaskRep.AsQueryable().Select<WcsTaskOutput>().ToListAsync();
}
-
+ /// <summary>
+ /// 瀹屾垚/鍙栨秷浠诲姟琛�
+ /// </summary>
+ /// <param name="input"></param>
+ /// <returns></returns>
+ [HttpPost]
+ [ApiDescriptionSettings(Name = "Finsh")]
+ [DisplayName("瀹屾垚/鍙栨秷浠诲姟琛�")]
+ [UnitOfWork]
+ public async Task Finsh(UpdateWcsTaskInput input)
+ {
+ if (input.Status == TaskStatusEnum.Complete || input.Status == TaskStatusEnum.Cancell)
+ {
+ var modTask = await _wcsTaskRep.GetByIdAsync(input.Id);
+ if (modTask.Status > TaskStatusEnum.Doing)
+ throw Oops.Oh("浠诲姟鐘舵�佸紓甯�");
+ if (input.Status == TaskStatusEnum.Complete)
+ modTask.IsSuccess = TaskSuccessEnum.Success;
+ else
+ modTask.IsSuccess = TaskSuccessEnum.Fail;
+ modTask.FinishDate = DateTime.Now;
+ modTask.Status = input.Status;
+ await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Status, s.IsSuccess, s.FinishDate, s.UpdateTime,s.UpdateUserId,s.UpdateUserName }).ExecuteCommandAsync();
+ //鍐欏叆浠诲姟鏄庣粏琛�
+ WcsTaskMonitor modTaskMonitor = new WcsTaskMonitor()
+ {
+ TaskNo = modTask.TaskNo,
+ PlcId = 0,
+ PlcName = "",
+ Status = TaskStatusEnum.Complete,
+ StartLocat = modTask.StartLocate,
+ EndLocat = modTask.EndLocate,
+ InteractiveMsg = input.Status == TaskStatusEnum.Complete ? "浠诲姟宸叉墜鍔ㄥ畬鎴�" : "浠诲姟宸叉墜鍔ㄥ彇娑�",
+ PalletNo = modTask.PalletNo
+ };
+ await _wcsTaskRep.Context.Insertable(modTaskMonitor).ExecuteCommandAsync();
+ //await _taskLogHubContext.Clients.All.PublicTask(modTask.Adapt<WcsTaskOutput>());
+ //await _taskLogHubContext.Clients.All.PublicTaskMonitor(modTaskMonitor.Adapt<WcsTaskMonitorOutput>());
+ }
+ else
+ {
+ throw Oops.Oh("浠诲姟鐘舵�佸紓甯�");
+ }
+ }
diff --git a/Admin.NET/WCS.Application/Util/HttpService.cs b/Admin.NET/WCS.Application/Util/HttpService.cs
index cbb5172..cb84eb5 100644
--- a/Admin.NET/WCS.Application/Util/HttpService.cs
+++ b/Admin.NET/WCS.Application/Util/HttpService.cs
@@ -20,7 +20,33 @@
{
string url = Urls.WMSAddress + ":" + Urls.WMSPort;
var result = await (url + "/api/DownAPi/ReceiveWcsSignal").SetBody(model, "application/json", Encoding.UTF8).PostAsAsync<ResponseTasks>();
- Log.Debug("璋冪敤WMS鎺ュ彛鍙嶉浠诲姟鎺ュ彛" + result.ToJson());
+ Log.Information("璋冪敤WMS鎺ュ彛鍙嶉浠诲姟鎺ュ彛" + result.ToJson());
+ return result;
+ }
+
+ /// <summary>
+ /// 璋冪敤WMS鎺ュ彛鍙嶉绌哄彇寮傚父鎺ュ彛
+ /// </summary>
+ /// <param name="model">浠诲姟淇℃伅</param>
+ /// <returns></returns>
+ public async Task<ResponseTasks> RequestEmptyException(TaskRequest model)
+ {
+ string url = Urls.WMSAddress + ":" + Urls.WMSPort;
+ var result = await (url + "/api/DownAPi/EmptyException").SetBody(model, "application/json", Encoding.UTF8).PostAsAsync<ResponseTasks>();
+ Log.Information("璋冪敤WMS鎺ュ彛鍙嶉绌哄彇寮傚父鎺ュ彛" + result.ToJson());
+ return result;
+ }
+
+ /// <summary>
+ /// 璋冪敤WMS鎺ュ彛鍙嶉婊″彇寮傚父鎺ュ彛
+ /// </summary>
+ /// <param name="model">浠诲姟淇℃伅</param>
+ /// <returns></returns>
+ public async Task<ResponseTasks> RequestFullException(TaskRequest model)
+ {
+ string url = Urls.WMSAddress + ":" + Urls.WMSPort;
+ var result = await (url + "/api/DownAPi/FullException").SetBody(model, "application/json", Encoding.UTF8).PostAsAsync<ResponseTasks>();
+ Log.Information("璋冪敤WMS鎺ュ彛鍙嶉婊″彇寮傚父鎺ュ彛" + result.ToJson());
return result;
}
}
diff --git a/Web/src/api/log/wcsAlarmLog.ts b/Web/src/api/log/wcsAlarmLog.ts
new file mode 100644
index 0000000..b8621a9
--- /dev/null
+++ b/Web/src/api/log/wcsAlarmLog.ts
@@ -0,0 +1,50 @@
+锘縤mport request from '/@/utils/request';
+enum Api {
+ AddWcsAlarmLog = '/api/wcsAlarmLog/add',
+ DeleteWcsAlarmLog = '/api/wcsAlarmLog/delete',
+ UpdateWcsAlarmLog = '/api/wcsAlarmLog/update',
+ PageWcsAlarmLog = '/api/wcsAlarmLog/page',
+ DetailWcsAlarmLog = '/api/wcsAlarmLog/detail',
+}
+
+// 澧炲姞鎶ヨ鏃ュ織
+export const addWcsAlarmLog = (params?: any) =>
+ request({
+ url: Api.AddWcsAlarmLog,
+ method: 'post',
+ data: params,
+ });
+
+// 鍒犻櫎鎶ヨ鏃ュ織
+export const deleteWcsAlarmLog = (params?: any) =>
+ request({
+ url: Api.DeleteWcsAlarmLog,
+ method: 'post',
+ data: params,
+ });
+
+// 缂栬緫鎶ヨ鏃ュ織
+export const updateWcsAlarmLog = (params?: any) =>
+ request({
+ url: Api.UpdateWcsAlarmLog,
+ method: 'post',
+ data: params,
+ });
+
+// 鍒嗛〉鏌ヨ鎶ヨ鏃ュ織
+export const pageWcsAlarmLog = (params?: any) =>
+ request({
+ url: Api.PageWcsAlarmLog,
+ method: 'post',
+ data: params,
+ });
+
+// 璇︽儏鎶ヨ鏃ュ織
+export const detailWcsAlarmLog = (id: any) =>
+ request({
+ url: Api.DetailWcsAlarmLog,
+ method: 'get',
+ data: { id },
+ });
+
+
diff --git a/Web/src/api/wcs/wcsTask.ts b/Web/src/api/wcs/wcsTask.ts
index 54669c5..c98786f 100644
--- a/Web/src/api/wcs/wcsTask.ts
+++ b/Web/src/api/wcs/wcsTask.ts
@@ -5,6 +5,7 @@
UpdateWcsTask = '/api/wcsTask/update',
PageWcsTask = '/api/wcsTask/page',
DetailWcsTask = '/api/wcsTask/detail',
+ FinshWcsTask = '/api/wcsTask/Finsh',
}
// 澧炲姞浠诲姟琛�
@@ -48,3 +49,10 @@
});
+// 瀹屾垚/鍙栨秷浠诲姟
+export const finshWcsTask = (params?: any) =>
+ request({
+ url: Api.FinshWcsTask,
+ method: 'post',
+ data: params,
+ });
\ No newline at end of file
diff --git a/Web/src/views/wcs/wcsDevice/component/editDialog.vue b/Web/src/views/wcs/wcsDevice/component/editDialog.vue
index fc839f3..0eed749 100644
--- a/Web/src/views/wcs/wcsDevice/component/editDialog.vue
+++ b/Web/src/views/wcs/wcsDevice/component/editDialog.vue
@@ -138,6 +138,10 @@
const ruleForm = ref<any>({});
//鑷娣诲姞鍏朵粬瑙勫垯
const rules = ref<FormRules>({
+ dbNumber: [{ required: true, message: '璇疯緭鍏B鍖哄煙锛�', trigger: 'blur', },],
+ stationNum: [{ required: true, message: '璇疯緭鍏ュ伐浣嶅彿锛�', trigger: 'blur', },],
+ plcPos: [{ required: true, message: '璇疯緭鍏LC鍋忕Щ閲忥紒', trigger: 'blur', },],
+ wcsPos: [{ required: true, message: '璇疯緭鍏CS鍋忕Щ閲忥紒', trigger: 'blur', },],
});
// 椤甸潰鍔犺浇鏃�
diff --git a/Web/src/views/wcs/wcsTask/index.vue b/Web/src/views/wcs/wcsTask/index.vue
index eac32a8..b68e9e8 100644
--- a/Web/src/views/wcs/wcsTask/index.vue
+++ b/Web/src/views/wcs/wcsTask/index.vue
@@ -4,8 +4,9 @@
<el-col :span="12" :xs="24" style="display: flex; height: 100%; flex: 1">
<el-card class="full-table" shadow="hover" ::body-style="{ height: 'calc(100% - 51px)' }">
<template #header>
- <el-icon size="16" style="margin-right: 3px; display: inline; vertical-align: middle"><ele-Collection /></el-icon>浠诲姟鏃ュ織
- </template>
+ <el-icon size="16"
+ style="margin-right: 3px; display: inline; vertical-align: middle"><ele-Collection /></el-icon>浠诲姟鏃ュ織
+ </template>
<el-form :model="queryParams" ref="queryForm" labelWidth="90">
<el-row>
<el-col :xs="24" :sm="12" :md="12" :lg="8" :xl="4" class="mb10">
@@ -53,8 +54,8 @@
</el-col>
</el-row>
</el-form>
- <el-table :data="tableData" style="width: 100%" v-loading="loading" tooltip-effect="light" row-key="id" @row-click="handleClick"
- @sort-change="sortChange" border="">
+ <el-table :data="tableData" style="width: 100%" v-loading="loading" tooltip-effect="light" row-key="id"
+ @cell-click="handleClick" @sort-change="sortChange" border="">
<el-table-column type="index" label="搴忓彿" width="55" align="center" />
<el-table-column prop="taskNo" label="浠诲姟鍙�" show-overflow-tooltip="" />
<el-table-column prop="taskType" width="85" label="浠诲姟绫诲瀷" show-overflow-tooltip="">
@@ -79,17 +80,15 @@
<ModifyRecord :data="scope.row" />
</template>
</el-table-column>
- <el-table-column label="鎿嶄綔" width="130" align="center" fixed="right" show-overflow-tooltip=""
+ <el-table-column prop="鎿嶄綔" label="鎿嶄綔" width="130" align="center" fixed="right" show-overflow-tooltip=""
v-if="auth('wcsTask:complete') || auth('wcsTask:cancell')">
<template #default="scope">
- <!-- <el-button icon="ele-Edit" size="small" text="" type="primary" @click="openEditWcsTask(scope.row)"
- v-auth="'wcsTask:update'"> 缂栬緫 </el-button>
- <el-button icon="ele-Delete" size="small" text="" type="primary" @click="delWcsTask(scope.row)"
- v-auth="'wcsTask:delete'"> 鍒犻櫎 </el-button> -->
- <el-button icon="ele-Check" size="small" text="" type="primary" @click="completeTask(scope.row)"
- v-auth="'wcsTask:complete'"> 瀹屾垚 </el-button>
- <el-button icon="ele-Close" size="small" text="" type="primary" @click="cancellTask(scope.row)"
- v-auth="'wcsTask:cancell'"> 鍙栨秷 </el-button>
+ <template v-if="scope.row.status <= 1">
+ <el-button icon="ele-Check" size="small" text="" type="primary" @click="completeTask(scope.row)"
+ v-auth="'wcsTask:complete'"> 瀹屾垚 </el-button>
+ <el-button icon="ele-Close" size="small" text="" type="primary" @click="cancellTask(scope.row)"
+ v-auth="'wcsTask:cancell'"> 鍙栨秷 </el-button>
+ </template>
</template>
</el-table-column>
</el-table>
@@ -104,8 +103,9 @@
<el-col :span="12" :xs="24" style="display: flex; height: 100%; flex: 1">
<el-card class="full-table" shadow="hover" :body-style="{ height: 'calc(100% - 51px)' }">
<template #header>
- <el-icon size="16" style="margin-right: 3px; display: inline; vertical-align: middle"><ele-Collection /></el-icon>浠诲姟璇︽儏
- </template>
+ <el-icon size="16"
+ style="margin-right: 3px; display: inline; vertical-align: middle"><ele-Collection /></el-icon>浠诲姟璇︽儏
+ </template>
<el-form :model="queryParams2" ref="queryForm2" labelWidth="90">
<el-row>
<el-col :xs="24" :sm="12" :md="12" :lg="8" :xl="4" class="mb10">
@@ -122,7 +122,8 @@
</el-col>
</el-row>
</el-form>
- <el-table :data="tableData2" style="width: 100%" v-loading="loading" tooltip-effect="light" row-key="id" border="">
+ <el-table :data="tableData2" style="width: 100%" v-loading="loading" tooltip-effect="light" row-key="id"
+ border="">
<el-table-column type="index" label="搴忓彿" width="55" align="center" />
<el-table-column prop="taskNo" label="浠诲姟鍙�" show-overflow-tooltip="" />
<el-table-column prop="plcId" label="浜や簰宸ヤ綅鍙�" show-overflow-tooltip="" />
@@ -146,22 +147,18 @@
<script lang="ts" setup="" name="wcsTask">
import ModifyRecord from '/@/components/table/modifyRecord.vue';
-import { ref } from "vue";
+import { onMounted, reactive, ref } from 'vue';
import { ElMessageBox, ElMessage } from "element-plus";
import { auth } from '/@/utils/authFunction';
import { getDictDataItem as di, getDictDataList as dl } from '/@/utils/dict-utils';
import { getDictLabelByVal as dv } from '/@/utils/dict-utils';
-import { formatDate } from '/@/utils/formatTime';
-
import printDialog from '/@/views/system/print/component/hiprint/preview.vue'
import editDialog from '/@/views/wcs/wcsTask/component/editDialog.vue'
-import { pageWcsTask, deleteWcsTask } from '/@/api/wcs/wcsTask';
+import { pageWcsTask, finshWcsTask } from '/@/api/wcs/wcsTask';
import { pageWcsMonitorTask } from '/@/api/wcs/wcsTaskMonitor';
-import { getAPI } from '/@/utils/axios-utils';
-import { SysEnumApi } from '/@/api-services/api';
-import commonFunction from '/@/utils/commonFunction';
+import { signalR } from './signalR';
const showAdvanceQueryUI = ref(false);
const printDialogRef = ref();
@@ -183,7 +180,31 @@
});
const printWcsTaskTitle = ref("");
const editWcsTaskTitle = ref("");
-
+//杩炴帴signalR 鐩戝惉鍚庡彴浠诲姟鏃ュ織鍙樻洿
+onMounted(async () => {
+ signalR.off('PublicTask');
+ signalR.on('PublicTask', (data: any) => {
+ console.log(data)
+ var listTask = tableData.value.filter(t => t.id == data.id);
+ if (listTask.length == 0) {
+ tableData.value.unshift(data)
+ }
+ else {
+ //濡傛灉宸茬粡瀛樺湪灏辨洿鏂版暟鎹�
+ const index = tableData.value.findIndex(t => t.id == data.id);
+ tableData.value.splice(index, 1, data);
+ }
+ });
+ signalR.off('PublicTaskMonitor');
+ signalR.on('PublicTaskMonitor', async (data: any) => {
+ console.log(data);
+ if (queryParams2.value.taskNo == undefined || queryParams2.value.taskNo == data.taskNo) {
+ if (tableData2.value.filter(t => t.id == data.id).length == 0) {
+ tableData2.value.unshift(data)
+ }
+ }
+ });
+});
// 鏀瑰彉楂樼骇鏌ヨ鐨勬帶浠舵樉绀虹姸鎬�
const changeAdvanceQueryUI = () => {
showAdvanceQueryUI.value = !showAdvanceQueryUI.value;
@@ -230,33 +251,48 @@
editDialogRef.value.openDialog(row);
};
//瀹屾垚浠诲姟
-const completeTask = (row: any) => {
-
-}
-//鍙栨秷浠诲姟
-const cancellTask = (row: any) => {
-
-}
-// 鐐瑰嚮琛ㄦ牸
-const handleClick = (row: any, event: any, column: any) => {
- queryParams2.value.taskNo = row.taskNo;
- handleQuery2();
-};
-// 鍒犻櫎
-const delWcsTask = (row: any) => {
- ElMessageBox.confirm(`纭畾瑕佸垹闄ゅ悧?`, "鎻愮ず", {
+const completeTask = async (row: any) => {
+ ElMessageBox.confirm(`纭畾瑕佸畬鎴愪换鍔″悧?`, "鎻愮ず", {
confirmButtonText: "纭畾",
cancelButtonText: "鍙栨秷",
type: "warning",
})
.then(async () => {
- await deleteWcsTask(row);
+ var param = Object.assign(row);
+ param.status = 2;
+ await finshWcsTask(param);
handleQuery();
- ElMessage.success("鍒犻櫎鎴愬姛");
+ handleQuery2();
+ ElMessage.success("瀹屾垚浠诲姟鎴愬姛");
})
.catch(() => { });
-};
+}
+//鍙栨秷浠诲姟
+const cancellTask = async (row: any) => {
+ ElMessageBox.confirm(`纭畾瑕佸彇娑堜换鍔″悧?`, "鎻愮ず", {
+ confirmButtonText: "纭畾",
+ cancelButtonText: "鍙栨秷",
+ type: "warning",
+ })
+ .then(async () => {
+ var param = Object.assign(row);
+ param.status = 4;
+ await finshWcsTask(param);
+ handleQuery();
+ handleQuery2();
+ ElMessage.success("鍙栨秷浠诲姟鎴愬姛");
+ })
+ .catch(() => { });
+}
+// 鐐瑰嚮琛ㄦ牸
+const handleClick = (row, column, cell, event) => {
+ if (column.property === '鎿嶄綔') {
+ return;
+ }
+ queryParams2.value.taskNo = row.taskNo;
+ handleQuery2();
+};
// 鏀瑰彉椤甸潰瀹归噺
const handleSizeChange = (val: number) => {
tableParams.value.pageSize = val;
diff --git a/Web/src/views/wcs/wcsTask/signalR.ts b/Web/src/views/wcs/wcsTask/signalR.ts
new file mode 100644
index 0000000..42c93f8
--- /dev/null
+++ b/Web/src/views/wcs/wcsTask/signalR.ts
@@ -0,0 +1,37 @@
+import * as SignalR from '@microsoft/signalr';
+import { getToken } from '/@/utils/axios-utils';
+
+// 鍒濆鍖朣ignalR瀵硅薄
+const connection = new SignalR.HubConnectionBuilder()
+ .configureLogging(SignalR.LogLevel.Information)
+ .withUrl(`${window.__env__.VITE_API_URL}/hubs/TaskLog?token=${getToken()}`, { transport: SignalR.HttpTransportType.WebSockets, skipNegotiation: true })
+ .withAutomaticReconnect({
+ nextRetryDelayInMilliseconds: () => {
+ return 5000; // 姣�5绉掗噸杩炰竴娆�
+ },
+ })
+ .build();
+
+connection.keepAliveIntervalInMilliseconds = 15 * 1000; // 蹇冭烦妫�娴�15s
+connection.serverTimeoutInMilliseconds = 30 * 60 * 1000; // 瓒呮椂鏃堕棿30m
+
+// 鍚姩杩炴帴
+connection.start().then(() => {
+ console.log('鍚姩杩炴帴task');
+});
+// 鏂紑杩炴帴
+connection.onclose(async () => {
+ console.log('鏂紑杩炴帴task');
+});
+// 閲嶈繛涓�
+connection.onreconnecting(() => {
+ console.log('鏈嶅姟鍣ㄥ凡鏂嚎task');
+});
+// 閲嶈繛鎴愬姛
+connection.onreconnected(() => {
+ console.log('閲嶈繛鎴愬姛task');
+});
+
+connection.on('PublicTask', () => {});
+
+export { connection as signalR };
--
Gitblit v1.8.0