不记录系统日志

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/YzgMqProcedure.java

@@ -107,7 +107,7 @@ public class YzgMqProcedure implements InitializingBean {
      * @return
      */
     private TimeUnit getTimeUnit(long waitTime) {
-        TimeUnit prevUnit = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN;
+        TimeUnit prevUnit = null;
         for (TimeUnit timeUnit : YZG_MQ_SYSTEM_QUEUE_PLAN_TIME) {
             // 判断时间
             if (timeUnit.unit < min) {
@@ -115,12 +115,17 @@ public class YzgMqProcedure implements InitializingBean {
             }
             // 在时间范围内，则返回大于等待时间的队列
             if (timeUnit.unit >= waitTime) {
+                if (prevUnit == null) {
+                    prevUnit = timeUnit;
+                }
                 break;
             }
             // 上次单位
             prevUnit = timeUnit;
         }
-        if (prevUnit.unit < min && prevUnit != YZG_MQ_SYSTEM_QUEUE_PLAN_MIN) {
+        if (prevUnit == null) {
+            prevUnit = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN;
+        } else if (prevUnit.unit < min) {
             throw new CodeException("算法错误");
         }
         // 返回最大时间的队列