From 35c26fb50cc90b85a8cf924f7b47e3ab412cabb5 Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期六, 10 一月 2026 19:41:14 +0800
Subject: [PATCH] 事务粒度调整
---
src/main/java/com/zy/core/thread/SiemensCrnThread.java | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensCrnThread.java b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
index a974565..4cc9ad2 100644
--- a/src/main/java/com/zy/core/thread/SiemensCrnThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
@@ -208,6 +208,9 @@
crnCommand.setAckFinish((short)1);
if (write(crnCommand)) {
resetFlag = false;
+ News.info("{}鍙峰爢鍨涙満锛屼换鍔}瀹屾垚纭淇″彿鍙戦�佹垚鍔�",crnProtocol.getCrnNo(),crnProtocol.getTaskNo());
+ } else {
+ News.error("{}鍙峰爢鍨涙満锛屼换鍔}瀹屾垚纭淇″彿鍙戦�佸け璐�",crnProtocol.getCrnNo(),crnProtocol.getTaskNo());
}
}
}
@@ -262,7 +265,7 @@
command.setCrnNo(slave.getId());
-// short[] array = new short[10];
+
short[] array = new short[10];
array[0] = command.getAckFinish(); // 浠诲姟瀹屾垚纭浣�
array[1] = command.getTaskNo(); // 浠诲姟鍙�
@@ -278,7 +281,6 @@
OperateResult result = siemensNet.Write("DB100.0", array);
-
News.info("鍫嗗灈鏈哄懡浠や笅鍙慬id:{}] >>>>> {}", slave.getId(), array);
//鍫嗗灈鏈轰换鍔″啓鍏ュ悗锛屽洖璇讳竴娆★紝鐪嬫槸鍚︽垚鍔�
@@ -375,7 +377,6 @@
}
}
-
try {
// 鏃ュ織璁板綍
BasCrnOptService bean = SpringUtils.getBean(BasCrnOptService.class);
@@ -402,7 +403,7 @@
if (result != null && result.IsSuccess) {
Thread.sleep(200);
this.readStatus();
-// News.info("鍫嗗灈鏈哄懡浠や笅鍙慬id:{}] >>>>> {}", slave.getId(), JSON.toJSON(command));
+ News.info("鍫嗗灈鏈哄懡浠や笅鍙慬id:{}] >>>>> {}", slave.getId(), JSON.toJSON(command));
OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(command)));
return true;
} else {
--
Gitblit v1.9.1