处理货单延迟挂单到挂单中状态处理BUG

performance-web/src/main/java/com/clx/performance/strategy/impl/OneGoodsOrderStrategy.java

@@ -30,6 +30,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.LinkedList;
@@ -180,8 +181,7 @@ public class OneGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
             Message message = MessageBuilder.withBody(entry.getKey().getBytes()).build();
             long epochMilli = 0L;
             if (entry.getValue().isAfter(now)) {
-                epochMilli = entry.getValue().minusMinutes(now.getMinute()).getMinute() * 60 * 1000;
-
+                epochMilli = Duration.between(now,entry.getValue()).toMillis();
                 log.info("货单更改挂单中,选择时间在当前时间之后，则设置延迟队列时间,时间为：{}", epochMilli);
 
             }
@@ -202,4 +202,17 @@ public class OneGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
             }
         }
     }
+
+    public static void main(String[] args) {
+        // "2023-10-31 00:00:00"   2023-10-14 11:33:05
+        LocalDateTime now = DateUtils.parseDateTime("2023-10-14 11:33:05").get();
+        LocalDateTime end = DateUtils.parseDateTime("2023-10-31 00:00:00").get();
+        System.out.println();
+        Duration duration = Duration.between(now,end);
+        long millis = duration.toMillis();
+
+
+        System.out.println(millis);
+
+    }
 }

performance-web/src/main/java/com/clx/performance/strategy/impl/ThreeGoodsOrderStrategy.java

@@ -34,6 +34,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.LinkedList;
@@ -194,7 +195,7 @@ public class ThreeGoodsOrderStrategy extends GoodsOrderStrategy implements Initi
             Message message = MessageBuilder.withBody(entry.getKey().getBytes()).build();
             long epochMilli = 0L;
             if (entry.getValue().isAfter(now)) {
-                epochMilli = entry.getValue().minusMinutes(now.getMinute()).getMinute() * 60 * 1000;
+                epochMilli = Duration.between(now,entry.getValue()).toMillis();
 
                 log.info("货单更改挂单中,选择时间在当前时间之后，则设置延迟队列时间,时间为：{}", epochMilli);
 

performance-web/src/main/java/com/clx/performance/strategy/impl/TwoGoodsOrderStrategy.java

@@ -30,6 +30,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.LinkedList;
@@ -214,7 +215,7 @@ public class TwoGoodsOrderStrategy extends GoodsOrderStrategy implements Initial
             Message message = MessageBuilder.withBody(entry.getKey().getBytes()).build();
             long epochMilli = 0L;
             if (entry.getValue().isAfter(now)) {
-                epochMilli = entry.getValue().minusMinutes(now.getMinute()).getMinute() * 60 * 1000;
+                epochMilli = Duration.between(now,entry.getValue()).toMillis();
                 log.info("货单更改挂单中,选择时间在当前时间之后，则设置延迟队列时间,时间为：{}", epochMilli);
             }
             if (epochMilli == 0L) {