From dc23ab59268e6dccd7d50d10cf8cffe1bf67d551 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期二, 13 五月 2025 18:55:34 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/RgvThread.java |   50 ++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 44 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index 38b1d23..8c2ceeb 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -48,11 +48,11 @@
     //    private RgvProtocol rgvProtocol;
     private TaskProtocolCache taskProtocolCache = new TaskProtocolCache();
     // # 杞ㄩ亾鎬婚暱
-    private Long trackEntireLength = 100L;
+    private Long trackEntireLength = 224000L;
     //# 杞ㄩ亾鍩哄噯鐐�
-    private Long trackBenchmark = 100L;
+    private Long trackBenchmark = 1L;
     //  # 閬胯璺濈
-    private Long avoidDistance = 100L;
+    private Long avoidDistance = 5000L;
 
     /**
      * 宸ヤ綅1澶嶄綅淇″彿
@@ -343,6 +343,10 @@
                         log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
                         return false;
                     }
+                    long avoidAbs = Math.abs(avoid - rgvProtocolOther.getRgvPos());
+                    if (avoidAbs<51){
+                        return true;
+                    }
                     rgvTaskProtocolOther.setAvoid(1);
                     rgvTaskProtocolOther.setAvoidingTheDestination(avoid);
                     RgvTaskCache.updateRgvStatus(rgvTaskProtocolOther);
@@ -359,6 +363,10 @@
                         log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
                         return false;
                     }
+                    long avoidAbs = Math.abs(avoid - rgvProtocolOther.getRgvPos());
+                    if (avoidAbs<51){
+                        return true;
+                    }
                     rgvTaskProtocolOther.setAvoid(1);
                     rgvTaskProtocolOther.setAvoidingTheDestination(avoid);
                     RgvTaskCache.updateRgvStatus(rgvTaskProtocolOther);
@@ -370,10 +378,14 @@
                         > avoidDistance) {//鏃犻渶閬胯
                     return true;
                 } else {
-                    if (rgvProtocolOther.getRgvPosDestination() >= rgvProtocolOther.getRgvPos()) {
+                    if (rgvProtocolOther.getRgvPosDestination() >= rgvProtocolOther.getRgvPos()-50) {
                         long avoid = rgvProtocolOther.getRgvPos() - rgvProtocolOther.getCarBodyJiaoMing() - avoidDistance - rgvProtocol.getCarBodyKunPeng();
                         if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                             log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
+                            return false;
+                        }
+                        long avoidAbs = Math.abs(avoid - rgvProtocol.getRgvPos());
+                        if (avoidAbs<51){
                             return false;
                         }
                         rgvTaskProtocol.setAvoid(1);
@@ -382,6 +394,12 @@
                         return false;
                     }
                     return false;
+                }
+            } else {
+                if ((rgvProtocolOther.getRgvPosDestinationOrPos(true) - rgvProtocolOther.getCarBodyJiaoMing())
+                        - (targetPosition + rgvProtocol.getCarBodyKunPeng())
+                        > avoidDistance) {//鏃犻渶閬胯
+                    return true;
                 }
             }
         } else {
@@ -395,6 +413,10 @@
                     if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                         log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
                         return false;
+                    }
+                    long avoidAbs = Math.abs(avoid - rgvProtocolOther.getRgvPos());
+                    if (avoidAbs<51){
+                        return true;
                     }
                     rgvTaskProtocolOther.setAvoid(1);
                     rgvTaskProtocolOther.setAvoidingTheDestination(avoid);
@@ -412,6 +434,10 @@
                         log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
                         return false;
                     }
+                    long avoidAbs = Math.abs(avoid - rgvProtocolOther.getRgvPos());
+                    if (avoidAbs<51){
+                        return true;
+                    }
                     rgvTaskProtocolOther.setAvoid(1);
                     rgvTaskProtocolOther.setAvoidingTheDestination(avoid);
                     RgvTaskCache.updateRgvStatus(rgvTaskProtocolOther);
@@ -424,10 +450,14 @@
                         > avoidDistance) {//鏃犻渶閬胯
                     return true;
                 } else {
-                    if (rgvProtocolOther.getRgvPosDestination() <= rgvProtocolOther.getRgvPos()) {
+                    if (rgvProtocolOther.getRgvPosDestination() <= rgvProtocolOther.getRgvPos() + 50) {
                         long avoid = rgvProtocolOther.getRgvPos() + rgvProtocolOther.getCarBodyKunPeng() + avoidDistance + rgvProtocol.getCarBodyJiaoMing();
                         if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[0])) {
                             log.error("琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛佷换鍔″紓甯�  鑱旂郴绠$悊鍛橈紒锛侊紒");
+                            return false;
+                        }
+                        long avoidAbs = Math.abs(avoid - rgvProtocol.getRgvPos());
+                        if (avoidAbs<51){
                             return false;
                         }
                         rgvTaskProtocol.setAvoid(1);
@@ -436,6 +466,12 @@
                         return false;
                     }
                     return false;
+                }
+            } else {
+                if ((rgvProtocolOther.getRgvPosDestinationOrPos(false) - rgvProtocolOther.getCarBodyJiaoMing())
+                        - (targetPosition + rgvProtocol.getCarBodyKunPeng())
+                        > avoidDistance) {//鏃犻渶閬胯
+                    return true;
                 }
             }
         }
@@ -520,8 +556,10 @@
                 RgvProtocol rgvProtocol = RgvStatusCache.getRgvStatus(slave.getId());
                 if (rgvProtocol == null) {
                     rgvProtocol = new RgvProtocol();
-                    rgvProtocol.setRgvNo(slave.getId());
                 }
+                rgvProtocol.setRgvNo(slave.getId());
+                rgvProtocol.setCarBodyJiaoMing(slave.getCarBodyJiaoMing());
+                rgvProtocol.setCarBodyKunPeng(slave.getCarBodyKunPeng());
 
                 rgvProtocol.setRgvPos((long)siemensNet.getByteTransform().TransInt32(result.Content, 0));
                 rgvProtocol.setRgvPosDestination((long)siemensNet.getByteTransform().TransInt32(result.Content, 4));

--
Gitblit v1.9.1