From 7e186ce8acbdb0690de064758563d0e58d797d5f Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期一, 28 七月 2025 08:07:35 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/JarThread.java | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/JarThread.java b/src/main/java/com/zy/core/thread/JarThread.java
index 3f3fdc2..0a57129 100644
--- a/src/main/java/com/zy/core/thread/JarThread.java
+++ b/src/main/java/com/zy/core/thread/JarThread.java
@@ -159,6 +159,19 @@
jarProtocol.setMode( 0);
jarProtocol.setStatus(JarStatusType.OFF_LINE);
jarProtocol.setJarErr(0);
+
+
+ // 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
+ BasJarService service = SpringUtils.getBean(BasJarService.class);
+ if (null != service) {
+ // 鍚屾pakMk
+ BasJar basJar = service.selectById(slave.getId());
+ basJar.setJarNo(slave.getId());
+ if (!service.updateById(jarProtocol.toSqlModel(basJar))){
+ News.error("纭寲缃恜lc鏁版嵁搴撴洿鏂板け璐� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+ }
+
+ }
} catch (Exception e){
log.error("JAR鍒濆鍖栧紓甯革紒锛侊紒 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
}
@@ -334,6 +347,7 @@
}
} else {
OutputQueue.STE.offer(MessageFormat.format("銆恵0}銆憑1}纭寲缃恜lc鐘舵�佷俊鎭け璐�", DateUtils.convert(new Date()), slave.getId()));
+ initSte();
throw new CoolException(MessageFormat.format( "纭寲缃恜lc鐘舵�佷俊鎭け璐� ===>> [id:{0}] [ip:{1}] [port:{2}]", slave.getId(), slave.getIp(), slave.getPort()));
}
} catch (Exception e) {
--
Gitblit v1.9.1