klzhangweiya пре 2 година
родитељ
комит
9b4d8bddbd

+ 2 - 2
vber-framework/src/main/java/com/vber/framework/sharding/LongDateShardingAlgorithm.java

@@ -52,8 +52,8 @@ public class LongDateShardingAlgorithm implements StandardShardingAlgorithm<Long
     public Collection<String> doSharding(Collection<String> availableTargetNames, RangeShardingValue<Long> shardingValue) {
         Collection<String> result = new LinkedHashSet<>(availableTargetNames.size());
         Range<Long> range = shardingValue.getValueRange();
-        Integer lowerEndPoint = Integer.parseInt(String.valueOf(range.lowerEndpoint()).substring(4, 6));
-        Integer upperEndpoint = Integer.parseInt(String.valueOf(range.upperEndpoint()).substring(4, 6));
+        Integer lowerEndPoint = Integer.parseInt(String.valueOf(range.lowerEndpoint()).substring(firstIndex, secondIndex));
+        Integer upperEndpoint = Integer.parseInt(String.valueOf(range.upperEndpoint()).substring(firstIndex, secondIndex));
         for (Integer value = lowerEndPoint; value <= upperEndpoint; value++) {
             String database_index = String.valueOf(value);
             for (String each : availableTargetNames) {