From d074cb16f7b3ba11363766dd78802da60f4ec07d Mon Sep 17 00:00:00 2001
From: L <L@132>
Date: 星期四, 23 四月 2026 09:39:47 +0800
Subject: [PATCH] *
---
src/main/java/com/zy/core/thread/SteThread.java | 23 ++++++++++++++++++++---
1 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SteThread.java b/src/main/java/com/zy/core/thread/SteThread.java
index cc049cb..6204a40 100644
--- a/src/main/java/com/zy/core/thread/SteThread.java
+++ b/src/main/java/com/zy/core/thread/SteThread.java
@@ -78,6 +78,14 @@
private void taskIssued() {
while (true) {
try {
+ if(!connectSte){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ continue;
+ }
int step = 1;
Task task = MessageQueue.poll(SlaveType.Ste, slave.getId());
if (task != null) {
@@ -130,6 +138,15 @@
private void readStatusSte() {
while (true) {
try {
+ if(!connectSte){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ initSte();
+ continue;
+ }
Thread.sleep(50);
// System.out.println("璇荤嚎绋�"+ slave.getId());
@@ -242,7 +259,7 @@
BasSteService service = SpringUtils.getBean(BasSteService.class);
if (null != service) {
// 鍚屾pakMk
- BasSte one = service.selectById(slave.getId());
+ BasSte one = service.getById(slave.getId());
if (one != null) {
steProtocol.setPakMk(one.getPakMk());
}
@@ -351,7 +368,7 @@
null, // 淇敼浜哄憳
null // 澶囨敞
);
- bean.insert(basSteOpt);
+ bean.save(basSteOpt);
}
}
@@ -370,7 +387,7 @@
public boolean confirmPos() {
BasSteService service = SpringUtils.getBean(BasSteService.class);
- BasSte basSte = service.selectById(slave.getId());
+ BasSte basSte = service.getById(slave.getId());
if (basSte != null) {
// 鏇存柊plc鏁版嵁鍧�
short[] arr = new short[] {basSte.getRow().shortValue(), basSte.getBay().shortValue(), basSte.getLev().shortValue()};
--
Gitblit v1.9.1