From f2ac01bac269e245f2af8393005e42cdc1d33b61 Mon Sep 17 00:00:00 2001
From: zhouquan <zhiyong.pei@broconcentric.com>
Date: 星期二, 19 八月 2025 16:55:58 +0800
Subject: [PATCH] 数据汇总添加S4NG排料产品信息
---
src/Bro.M141.Process/MyMQTT.cs | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/Bro.M141.Process/MyMQTT.cs b/src/Bro.M141.Process/MyMQTT.cs
index 209162d..eba6af5 100644
--- a/src/Bro.M141.Process/MyMQTT.cs
+++ b/src/Bro.M141.Process/MyMQTT.cs
@@ -134,7 +134,7 @@
}
}
- public async Task<string> MESForBasketAsync(string ztype, string zlsn, string zlpn, string zstatus, string zversion, int timeoutMs = 30000)
+ public async Task<string> MESForBasketAsync(string ztype, string zlsn, string zlpn, string zstatus, string zversion, int timeoutMes = 30000)
{
var guid = Guid.NewGuid().ToString();
var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
@@ -157,7 +157,7 @@
CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"RabbitMQ 绡叿 鍙戦��1锛歿message}");
_sendChannel.BasicPublish("", "auto_line_mac_queue", null, body);
- var completed = await Task.WhenAny(tcs.Task, Task.Delay(timeoutMs));
+ var completed = await Task.WhenAny(tcs.Task, Task.Delay(timeoutMes));
_pendingTask1.TryRemove(guid, out _);
if (completed == tcs.Task)
return await tcs.Task;
@@ -211,7 +211,7 @@
var DefectCodeMap = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
{
- ["ok"] = "",
+ ["OK"] = "",
["寮傝壊"] = "SZ2001",
["纾ㄥ嵃"] = "SZ2012",
["鍘嬩激"] = "SZ2014",
--
Gitblit v1.8.0