#

Junjie

2025-03-29 5dd930fc0ad19cfc75df3a035336dd003e7c22ef

 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -89,7 +89,7 @@
            while (true) {
                try {
                    read();
                    Thread.sleep(50);
                    Thread.sleep(200);
                } catch (Exception e) {
                    log.error("ShuttleThread Fail", e);
                }
@@ -194,7 +194,7 @@
            }

            JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集
            if (!socketResults.isEmpty() && socketResults.size() >= 5) {
            if (!socketResults.isEmpty() && socketResults.size() >= 100) {
                socketResults.remove(0);//清理头节点
            }
            socketResults.add(result);//添加数据
@@ -402,7 +402,7 @@
                socketResults.remove(removeIdx);
            }
        } catch (Exception e) {
//            e.printStackTrace();
            e.printStackTrace();
        }
    }

@@ -715,6 +715,23 @@
    }

    @Override
    public boolean isFault() {
        if (this.shuttleProtocol.getErrorCode() == null
                || this.shuttleProtocol.getMode() == null
                || this.shuttleProtocol.getExtend() == null
        ) {
            return false;
        }

        InnerSuhttleExtend extend = (InnerSuhttleExtend) this.shuttleProtocol.getExtend();
        boolean res = this.shuttleProtocol.getMode() == 0
                && !this.shuttleProtocol.getErrorCode().equals("0")
                && extend.getSuspendState() == 1
                ;
        return res;
    }

    @Override
    public List<NavigateNode> getMoveAdvancePath() {
        ObjectMapper objectMapper = SpringUtils.getBean(ObjectMapper.class);
        NavigateMapData navigateMapData = SpringUtils.getBean(NavigateMapData.class);