From 24de88ebbbb3597bb2043840bc685e3d59363967 Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期一, 07 七月 2025 16:48:39 +0800
Subject: [PATCH] 优化轮询ERP信息流程、添加AGV接口报文打印、执行中任务强制取消的功能
---
core/Monitor.cs | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/core/Monitor.cs b/core/Monitor.cs
index 35739ea..3f81d23 100644
--- a/core/Monitor.cs
+++ b/core/Monitor.cs
@@ -20,7 +20,11 @@
var db = new SqlHelper<object>().GetInstance();
try {
var inboundDataList = db.Queryable<TN_Inbound_DataRecord>().ToList();
- LogHelper.Info($"杞锛氬叆搴撲俊鎭悓姝ワ細褰撳墠娌℃湁寰呭悓姝ョ殑ERP鐗╂枡淇℃伅");
+
+ if (inboundDataList.Count == 0 ) {
+ LogHelper.Info($"杞锛氬叆搴撲俊鎭悓姝ワ細褰撳墠娌℃湁寰呭悓姝ョ殑ERP鐗╂枡淇℃伅");
+ return;
+ }
var needDeleteDataList = new List<TN_Inbound_DataRecord>();
var needUpdateLocCntrRelList = new List<TN_Loc_Container>();
@@ -42,6 +46,10 @@
needUpdateCgDetailList.Add(cgDetail);
needDeleteDataList.Add(inboundData);
}
+ }
+
+ if (needDeleteDataList.Count == 0) {
+ LogHelper.Info($"杞锛氬叆搴撲俊鎭悓姝ワ細寰呮洿鏂扮殑ERP鐗╂枡淇℃伅锛屾殏鏃犵墿鏂欏彲浠ヨ鐩栵紝鐩墠寰呮洿鏂版暟閲忥細{inboundDataList.Count}");
}
using (var tran = db.Ado.UseTran()) {
@@ -81,6 +89,7 @@
if (outboundDataList.Count== 0 ) {
LogHelper.Info($"杞锛氬嚭搴撲俊鎭悓姝ワ細褰撳墠娌℃湁寰呭悓姝ョ殑ERP鐗╂枡淇℃伅");
+ return;
}
var needDeleteDataList = new List<TN_Outbound_DataRecord>();
@@ -103,6 +112,10 @@
needUpdateCgDetailList.Add(cgDetail);
needDeleteDataList.Add(outboundData);
}
+ }
+
+ if (needDeleteDataList.Count == 0) {
+ LogHelper.Info($"杞锛氬嚭搴撲俊鎭悓姝ワ細寰呮洿鏂扮殑ERP鐗╂枡淇℃伅锛屾殏鏃犵墿鏂欏彲浠ヨ鐩栵紝鐩墠寰呮洿鏂版暟閲忥細{outboundDataList.Count}");
}
using (var tran = db.Ado.UseTran()) {
@@ -130,7 +143,6 @@
}
catch (Exception ex) {
-
LogHelper.Info($"鍙戠敓浜嗗紓甯革細{ex.Message}");
}
}
--
Gitblit v1.9.1