Merge branch 'dev' into test

2a4036a8 · 吕明尚 · a7f87f32 · 647eb012 · 2a4036a8
Commit 2a4036a8 authored Oct 31, 2024 by 吕明尚
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 0 deletions

RedisTask.java share-quartz/src/main/java/share/quartz/task/RedisTask.java +5 -0

No files found.
--- a/share-quartz/src/main/java/share/quartz/task/RedisTask.java
+++ b/share-quartz/src/main/java/share/quartz/task/RedisTask.java
@@ -650,6 +650,11 @@ public class RedisTask {
                            consumerMember.setMembershipProgress(subtract);
                            updateList.add(consumerMember);
                            return;
+                        } else if (subtract.compareTo(BigDecimal.valueOf(configMap.get(Collections.max(configMap.keySet())).getLimitRequirements())) >= 0) {
+                            consumerMember.setMembershipLevel(Collections.max(configMap.keySet()));
+                            consumerMember.setMembershipProgress(subtract);
+                            updateList.add(consumerMember);
+                            return;
                        }
                    }
                }