forked from plusone/plusone-commons
Compare commits
7 Commits
3b441e4575
...
dev
| Author | SHA1 | Date | |
|---|---|---|---|
| 255aaf182a | |||
| 468453781e | |||
| 3b241de08c | |||
| fb46def402 | |||
| 386ede6afd | |||
| 8ec61a84c9 | |||
| 726a94a1a8 |
60
NOTICE
Normal file
60
NOTICE
Normal file
@@ -0,0 +1,60 @@
|
|||||||
|
Plusone Commons
|
||||||
|
Copyright 2022-present ZhouXY108
|
||||||
|
|
||||||
|
This product includes software developed at
|
||||||
|
Plusone Commons (http://gitea.zhouxy.xyz/plusone/plusone-commons).
|
||||||
|
|
||||||
|
===========================================================================
|
||||||
|
Third-party components and their licenses:
|
||||||
|
===========================================================================
|
||||||
|
|
||||||
|
This software contains code from the following third-party projects:
|
||||||
|
|
||||||
|
1. Apache Seata
|
||||||
|
- Component: IdWorker class implementation
|
||||||
|
- Source: org.apache.seata.common.util.IdWorker
|
||||||
|
- Origin: https://github.com/apache/incubator-seata/blob/2.x/common/src/main/java/org/apache/seata/common/util/IdWorker.java
|
||||||
|
- License: Apache License 2.0
|
||||||
|
- License URL: https://www.apache.org/licenses/LICENSE-2.0.txt
|
||||||
|
- Copyright: The Apache Software Foundation
|
||||||
|
|
||||||
|
===========================================================================
|
||||||
|
Dependencies and their licenses:
|
||||||
|
===========================================================================
|
||||||
|
|
||||||
|
The following dependencies are used in this project:
|
||||||
|
|
||||||
|
Required Dependencies:
|
||||||
|
- guava: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
|
||||||
|
Optional Dependencies:
|
||||||
|
- gson: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
- jsr305: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
- joda-time: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
|
||||||
|
Test Dependencies:
|
||||||
|
- commons-lang3: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
- Logback: Eclipse Public License 1.0 (https://www.eclipse.org/org/documents/epl-1.0/EPL-1.0.txt) / LGPL 2.1 (https://www.gnu.org/licenses/old-licenses/lgpl-2.1.html)
|
||||||
|
- Slf4j: MIT License (https://mit-license.org/)
|
||||||
|
- JUnit: Eclipse Public License 2.0 (https://www.eclipse.org/org/documents/epl-2.0/EPL-2.0.txt)
|
||||||
|
- lombok: MIT License (https://mit-license.org/)
|
||||||
|
- hutool: MulanPSL-2.0 (http://license.coscl.org.cn/MulanPSL2)
|
||||||
|
- MyBatis: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
- h2: MPL 2.0 (https://www.mozilla.org/en-US/MPL/2.0/) / EPL 1.0 (https://www.eclipse.org/org/documents/epl-1.0/EPL-1.0.txt)
|
||||||
|
- Jackson: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
|
||||||
|
|
||||||
|
===========================================================================
|
||||||
|
Apache License 2.0 Notice:
|
||||||
|
===========================================================================
|
||||||
|
|
||||||
|
Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
you may not use this file except in compliance with the License.
|
||||||
|
You may obtain a copy of the License at
|
||||||
|
|
||||||
|
http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
|
||||||
|
Unless required by applicable law or agreed to in writing, software
|
||||||
|
distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
See the License for the specific language governing permissions and
|
||||||
|
limitations under the License.
|
||||||
29
README.md
29
README.md
@@ -209,9 +209,34 @@ throw LoginException.Type.TOKEN_TIMEOUT.create();
|
|||||||
分页结果可以存放到 `PageResult` 中,作为出参。
|
分页结果可以存放到 `PageResult` 中,作为出参。
|
||||||
|
|
||||||
#### 2. UnifiedResponse
|
#### 2. UnifiedResponse
|
||||||
UnifiedResponse 对返回给前端的数据进行封装,包含 `code`、`message`、`data。`
|
|
||||||
|
|
||||||
可使用 `UnifiedResponses` 快速构建 `UnifiedResponse` 对象。 `UnifiedResponses` 默认的成功代码为 "2000000", 用户按测试类 `CustomUnifiedResponseFactoryTests` 中所示范的,继承 `UnifiedResponses` 实现自己的工厂类, 自定义 `SUCCESS_CODE` 和 `DEFAULT_SUCCESS_MSG` 和工厂方法。 见 [issue#22 @Gitea](http://gitea.zhouxy.xyz/plusone/plusone-commons/issues/22)。
|
`UnifiedResponse` 对返回给前端的数据进行封装,包含 `code`、`message`、`data。`
|
||||||
|
|
||||||
|
`UnifiedResponses` 是 `UnifiedResponse` 的工厂类。用于快速构建 `UnifiedResponse` 对象,默认的成功代码为 `2000000`。
|
||||||
|
|
||||||
|
用户可以继承 `UnifiedResponses` 实现自己的工厂类,自定义 SUCCESS_CODE 和 DEFAULT_SUCCESS_MSG,以及工厂方法。如下所示:
|
||||||
|
```java
|
||||||
|
// 自定义工厂类
|
||||||
|
public static class CustomUnifiedResponses extends UnifiedResponses {
|
||||||
|
public static final String SUCCESS_CODE = "000";
|
||||||
|
public static final String DEFAULT_SUCCESS_MSG = "成功";
|
||||||
|
public static <T> UnifiedResponse<T> success() {
|
||||||
|
return of(SUCCESS_CODE, DEFAULT_SUCCESS_MSG);
|
||||||
|
}
|
||||||
|
public static <T> UnifiedResponse<T> success(@Nullable String message) {
|
||||||
|
return of(SUCCESS_CODE, message);
|
||||||
|
}
|
||||||
|
public static <T> UnifiedResponse<T> success(@Nullable String message, @Nullable T data) {
|
||||||
|
return of(SUCCESS_CODE, message, data);
|
||||||
|
}
|
||||||
|
private CustomUnifiedResponses() {
|
||||||
|
super();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 使用自定义工厂类
|
||||||
|
CustomUnifiedResponses.success("查询成功", userList); // 状态码为 000
|
||||||
|
```
|
||||||
|
见 [issue#22 @Gitea](http://gitea.zhouxy.xyz/plusone/plusone-commons/issues/22)
|
||||||
|
|
||||||
## 八、time - 时间 API
|
## 八、time - 时间 API
|
||||||
### 1. 季度
|
### 1. 季度
|
||||||
|
|||||||
@@ -0,0 +1,254 @@
|
|||||||
|
/*
|
||||||
|
* Copyright 2025 the original author or authors.
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* https://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package xyz.zhouxy.plusone.commons.collection;
|
||||||
|
|
||||||
|
import static xyz.zhouxy.plusone.commons.util.AssertTools.checkArgumentNotNull;
|
||||||
|
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.function.BiFunction;
|
||||||
|
import java.util.function.Consumer;
|
||||||
|
import java.util.function.Function;
|
||||||
|
import java.util.function.Supplier;
|
||||||
|
|
||||||
|
import javax.annotation.CheckForNull;
|
||||||
|
import javax.annotation.Nonnull;
|
||||||
|
import javax.annotation.Nullable;
|
||||||
|
|
||||||
|
import com.google.common.annotations.Beta;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Map 修改器
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* 封装一系列对 Map 数据的修改操作,修改 Map 的数据。可以用于 Map 的数据初始化等操作。
|
||||||
|
*
|
||||||
|
* <pre>
|
||||||
|
* // MapModifier
|
||||||
|
* MapModifier<String, Object> modifier = new MapModifier<String, Object>()
|
||||||
|
* .putAll(commonProperties)
|
||||||
|
* .put("username", "Ben")
|
||||||
|
* .put("accountStatus", LOCKED);
|
||||||
|
*
|
||||||
|
* // 从 Supplier 中获取 Map,并修改数据
|
||||||
|
* Map<String, Object> map = modifier.getAndModify(HashMap::new);
|
||||||
|
*
|
||||||
|
* // 可以灵活使用不同 Map 类型的不同构造器
|
||||||
|
* Map<String, Object> map = modifier.getAndModify(() -> new HashMap<>(8));
|
||||||
|
* Map<String, Object> map = modifier.getAndModify(() -> new HashMap<>(anotherMap));
|
||||||
|
* Map<String, Object> map = modifier.getAndModify(TreeMap::new);
|
||||||
|
* Map<String, Object> map = modifier.getAndModify(ConcurrentHashMap::new);
|
||||||
|
*
|
||||||
|
* // 修改已有的 Map
|
||||||
|
* modifier.modify(map);
|
||||||
|
*
|
||||||
|
* // 创建一个有初始化数据的不可变的 Map
|
||||||
|
* Map<String, Object> map = modifier.getUnmodifiableMap();
|
||||||
|
*
|
||||||
|
* // 链式调用创建并初始化数据
|
||||||
|
* Map<String, Object> map = new MapModifier<String, Object>()
|
||||||
|
* .putAll(commonProperties)
|
||||||
|
* .put("username", "Ben")
|
||||||
|
* .put("accountStatus", LOCKED)
|
||||||
|
* .getAndModify(HashMap::new);
|
||||||
|
* </pre>
|
||||||
|
*
|
||||||
|
* @author ZhouXY108 <luquanlion@outlook.com>
|
||||||
|
* @since 1.1.0
|
||||||
|
*/
|
||||||
|
@Beta
|
||||||
|
public class MapModifier<K, V> {
|
||||||
|
|
||||||
|
@Nonnull
|
||||||
|
private Consumer<Map<K, V>> operators;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建一个空的 MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier() {
|
||||||
|
this.operators = m -> {
|
||||||
|
// do nothing
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加一个键值对。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param key 要添加的 {@code key}
|
||||||
|
* @param value 要添加的 {@code value}
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> put(@Nullable K key, @Nullable V value) {
|
||||||
|
return addOperationInternal(map -> map.put(key, value));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加一个键值对,如果 key 已经存在,则不添加。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param key 要添加的 {@code key}
|
||||||
|
* @param value 要添加的 {@code value}
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> putIfAbsent(@Nullable K key, @Nullable V value) {
|
||||||
|
return addOperationInternal(map -> map.putIfAbsent(key, value));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加多个键值对。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param otherMap 要添加的键值对集合。
|
||||||
|
* 如果为 {@code null},则什么都不做。
|
||||||
|
*
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> putAll(@Nullable Map<? extends K, ? extends V> otherMap) {
|
||||||
|
if (otherMap == null || otherMap.isEmpty()) {
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
return addOperationInternal(map -> map.putAll(otherMap));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加多个键值对。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param entries 要添加的键值对集合
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
@SafeVarargs
|
||||||
|
public final MapModifier<K, V> putAll(Map.Entry<? extends K, ? extends V>... entries) {
|
||||||
|
if (entries.length == 0) {
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
return addOperationInternal(map -> {
|
||||||
|
for (Map.Entry<? extends K, ? extends V> entry : entries) {
|
||||||
|
map.put(entry.getKey(), entry.getValue());
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 当 {@code key} 不存在时,计算对应的值,并添加到 {@code map} 中。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* 调用 {@link Map#computeIfAbsent(Object, Function)}。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param key 要添加的 {@code key}
|
||||||
|
* @param mappingFunction 计算 {@code key} 对应的值
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> computeIfAbsent(K key,
|
||||||
|
Function<? super K, ? extends V> mappingFunction) {
|
||||||
|
return addOperationInternal(map -> map.computeIfAbsent(key, mappingFunction));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 当 {@code key} 存在时,计算对应的值,并添加到 {@code map} 中。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* 调用 {@link Map#computeIfPresent(Object, BiFunction)}。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:键值对是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param key 要添加的 {@code key}
|
||||||
|
* @param remappingFunction 计算 {@code key} 对应的值
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> computeIfPresent(K key,
|
||||||
|
BiFunction<? super K, ? super V, ? extends V> remappingFunction) {
|
||||||
|
return addOperationInternal(map -> map.computeIfPresent(key, remappingFunction));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 删除 {@code key}。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* <b>注意:key 是否允许为 {@code null},由最终作用的 {@link Map} 类型决定。</b>
|
||||||
|
*
|
||||||
|
* @param key 要删除的 {@code key}
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> remove(K key) {
|
||||||
|
return addOperationInternal(map -> map.remove(key));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 清空 {@code map}
|
||||||
|
*
|
||||||
|
* @return MapModifier
|
||||||
|
*/
|
||||||
|
public MapModifier<K, V> clear() {
|
||||||
|
return addOperationInternal(Map::clear);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 修改 {@code map}
|
||||||
|
*
|
||||||
|
* @param map 要修改的 {@code map}
|
||||||
|
* @return 修改后的 {@code map}。当入参是 {@code null} 时,返回 {@code null}。
|
||||||
|
*/
|
||||||
|
public <T extends Map<K, V>> void modify(@Nullable T map) {
|
||||||
|
if (map != null) {
|
||||||
|
this.operators.accept(map);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 修改 {@code map}
|
||||||
|
*
|
||||||
|
* @param mapSupplier {@code map} 的 {@link Supplier}
|
||||||
|
* @return 修改后的 {@code map}。
|
||||||
|
* 当从 {@code mapSupplier} 获取的 {@code map} 为 {@code null} 时,返回 {@code null}。
|
||||||
|
*/
|
||||||
|
@CheckForNull
|
||||||
|
public <T extends Map<K, V>> T getAndModify(Supplier<T> mapSupplier) {
|
||||||
|
checkArgumentNotNull(mapSupplier, "The map supplier cannot be null.");
|
||||||
|
T map = mapSupplier.get();
|
||||||
|
modify(map);
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建一个有初始化数据的不可变的 {@code Map}
|
||||||
|
*
|
||||||
|
* @return 不可变的 {@code Map}
|
||||||
|
*/
|
||||||
|
public Map<K, V> getUnmodifiableMap() {
|
||||||
|
return Collections.unmodifiableMap(getAndModify(HashMap::new));
|
||||||
|
}
|
||||||
|
|
||||||
|
private MapModifier<K, V> addOperationInternal(Consumer<Map<K, V>> operator) {
|
||||||
|
this.operators = this.operators.andThen(operator);
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -19,7 +19,40 @@ package xyz.zhouxy.plusone.commons.model.dto;
|
|||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* UnifiedResponse 工厂
|
* {@link UnifiedResponse} 工厂类。
|
||||||
|
* 用于快速构建 {@link UnifiedResponse} 对象,默认的成功代码为 {@code 2000000}。
|
||||||
|
*
|
||||||
|
* <p>
|
||||||
|
* 用户可以继承 {@link UnifiedResponses} 实现自己的工厂类,
|
||||||
|
* 自定义 SUCCESS_CODE 和 DEFAULT_SUCCESS_MSG,以及工厂方法。
|
||||||
|
* 如下所示:
|
||||||
|
* <pre>
|
||||||
|
* // 自定义工厂类
|
||||||
|
* public static class CustomUnifiedResponses extends UnifiedResponses {
|
||||||
|
*
|
||||||
|
* public static final String SUCCESS_CODE = "000";
|
||||||
|
* public static final String DEFAULT_SUCCESS_MSG = "成功";
|
||||||
|
*
|
||||||
|
* public static <T> UnifiedResponse<T> success() {
|
||||||
|
* return of(SUCCESS_CODE, DEFAULT_SUCCESS_MSG);
|
||||||
|
* }
|
||||||
|
*
|
||||||
|
* public static <T> UnifiedResponse<T> success(@Nullable String message) {
|
||||||
|
* return of(SUCCESS_CODE, message);
|
||||||
|
* }
|
||||||
|
*
|
||||||
|
* public static <T> UnifiedResponse<T> success(@Nullable String message, @Nullable T data) {
|
||||||
|
* return of(SUCCESS_CODE, message, data);
|
||||||
|
* }
|
||||||
|
*
|
||||||
|
* private CustomUnifiedResponses() {
|
||||||
|
* super();
|
||||||
|
* }
|
||||||
|
* }
|
||||||
|
* // 使用自定义工厂类
|
||||||
|
* CustomUnifiedResponses.success("查询成功", userList); // 状态码为 000
|
||||||
|
* </pre>
|
||||||
|
* 见 <a href="http://zhouxy.xyz:3000/plusone/plusone-commons/issues/22">issue#22</a>。
|
||||||
*
|
*
|
||||||
* @author ZhouXY108 <luquanlion@outlook.com>
|
* @author ZhouXY108 <luquanlion@outlook.com>
|
||||||
* @since 1.0.0
|
* @since 1.0.0
|
||||||
|
|||||||
@@ -52,13 +52,11 @@
|
|||||||
* {@link UnifiedResponse} 对返回给前端的数据进行封装,包含 code、message、data。
|
* {@link UnifiedResponse} 对返回给前端的数据进行封装,包含 code、message、data。
|
||||||
*
|
*
|
||||||
* <p>
|
* <p>
|
||||||
* 可使用 {@link UnifiedResponses} 快速构建 {@link UnifiedResponse} 对象。
|
* {@link UnifiedResponses} 用于快速构建 {@link UnifiedResponse} 对象,默认的成功代码为 {@code 2000000}。
|
||||||
* {@link UnifiedResponses} 默认的成功代码为 "2000000",
|
*
|
||||||
* 用户按测试类
|
* <p>
|
||||||
* <a href="http://zhouxy.xyz:3000/plusone/plusone-commons/src/branch/main/src/test/java/xyz/zhouxy/plusone/commons/model/dto/CustomUnifiedResponseFactoryTests.java">CustomUnifiedResponseFactoryTests</a>
|
* 用户可以继承 {@link UnifiedResponses} 实现自己的工厂类,
|
||||||
* 中所示范的,继承 {@link UnifiedResponses} 实现自己的工厂类,
|
* 自定义 SUCCESS_CODE 和 DEFAULT_SUCCESS_MSG,以及工厂方法。
|
||||||
* 自定义 SUCCESS_CODE 和 DEFAULT_SUCCESS_MSG 和工厂方法。
|
|
||||||
* 见 <a href="http://zhouxy.xyz:3000/plusone/plusone-commons/issues/22">issue#22</a>。
|
|
||||||
*
|
*
|
||||||
* @author ZhouXY108 <luquanlion@outlook.com>
|
* @author ZhouXY108 <luquanlion@outlook.com>
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -0,0 +1,316 @@
|
|||||||
|
/*
|
||||||
|
* Copyright 2025 the original author or authors.
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* https://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package xyz.zhouxy.plusone.commons.collection;
|
||||||
|
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertNull;
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertThrows;
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||||
|
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.TreeMap;
|
||||||
|
import java.util.UUID;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
|
||||||
|
import javax.annotation.Nullable;
|
||||||
|
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
|
||||||
|
import com.google.common.collect.ImmutableMap;
|
||||||
|
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
|
public class MapModifierTests {
|
||||||
|
|
||||||
|
private static final String APP_START_ID = UUID.randomUUID().toString();
|
||||||
|
private static final String LOCKED = "LOCKED";
|
||||||
|
|
||||||
|
private static final Map<String, String> commonProperties = ImmutableMap.<String, String>builder()
|
||||||
|
.put("channel", "MOBILE")
|
||||||
|
.put("appStartId", APP_START_ID)
|
||||||
|
.build();
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void demo() {
|
||||||
|
Map<String, String> expected = new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("channel", "MOBILE");
|
||||||
|
put("appStartId", APP_START_ID);
|
||||||
|
put("username", "Ben");
|
||||||
|
put("accountStatus", LOCKED);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// MapModifier
|
||||||
|
MapModifier<String, String> modifier = new MapModifier<String, String>()
|
||||||
|
.putAll(commonProperties)
|
||||||
|
.put("username", "Ben")
|
||||||
|
.put("accountStatus", LOCKED);
|
||||||
|
|
||||||
|
// 从 Supplier 中获取 Map,并修改数据
|
||||||
|
HashMap<String, String> hashMap1 = modifier.getAndModify(HashMap::new);
|
||||||
|
assertEquals(expected, hashMap1);
|
||||||
|
|
||||||
|
// 可以灵活使用不同 Map 类型的不同构造器
|
||||||
|
HashMap<String, String> hashMap2 = modifier.getAndModify(() -> new HashMap<>(8));
|
||||||
|
assertEquals(expected, hashMap2);
|
||||||
|
|
||||||
|
// HashMap<String, String> hashMap3 = modifier.getAndModify(() -> new HashMap<>(anotherMap));
|
||||||
|
TreeMap<String, String> treeMap = modifier.getAndModify(TreeMap::new);
|
||||||
|
assertEquals(expected, treeMap);
|
||||||
|
ConcurrentHashMap<String, String> concurrentHashMap = modifier.getAndModify(ConcurrentHashMap::new);
|
||||||
|
assertEquals(expected, concurrentHashMap);
|
||||||
|
|
||||||
|
assertNull(modifier.getAndModify(() -> (Map<String, String>) null));
|
||||||
|
|
||||||
|
// 修改已有的 Map
|
||||||
|
Map<String, String> srcMap = new HashMap<>();
|
||||||
|
srcMap.put("srcKey1", "srcValue1");
|
||||||
|
srcMap.put("srcKey2", "srcValue2");
|
||||||
|
modifier.modify(srcMap);
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
putAll(commonProperties);
|
||||||
|
put("username", "Ben");
|
||||||
|
put("accountStatus", LOCKED);
|
||||||
|
put("srcKey1", "srcValue1");
|
||||||
|
put("srcKey2", "srcValue2");
|
||||||
|
}
|
||||||
|
}, srcMap);
|
||||||
|
|
||||||
|
assertDoesNotThrow(() -> modifier.modify((Map<String, String>) null));
|
||||||
|
|
||||||
|
// 创建一个有初始化数据的不可变的 {@code Map}
|
||||||
|
Map<String, String> unmodifiableMap = modifier.getUnmodifiableMap();
|
||||||
|
assertEquals(expected, unmodifiableMap);
|
||||||
|
assertThrows(UnsupportedOperationException.class,
|
||||||
|
() -> unmodifiableMap.put("key", "value"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void createAndInitData() {
|
||||||
|
// 链式调用创建并初始化数据
|
||||||
|
HashMap<String, String> map = new MapModifier<String, String>()
|
||||||
|
.putAll(commonProperties)
|
||||||
|
.put("username", "Ben")
|
||||||
|
.put("accountStatus", LOCKED)
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
|
||||||
|
HashMap<String, String> expected = new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("channel", "MOBILE");
|
||||||
|
put("appStartId", APP_START_ID);
|
||||||
|
put("username", "Ben");
|
||||||
|
put("accountStatus", LOCKED);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
assertEquals(expected, map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void put() {
|
||||||
|
Map<String, String> map = new MapModifier<String, String>()
|
||||||
|
.put("key1", "value0")
|
||||||
|
.put("key1", "value1")
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key1", "value0");
|
||||||
|
put("key1", "value1");
|
||||||
|
}
|
||||||
|
}, map);
|
||||||
|
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.put("key1", "newValue1")
|
||||||
|
.put("key2", null)
|
||||||
|
.modify(map);
|
||||||
|
|
||||||
|
assertEquals("newValue1", map.get("key1"));
|
||||||
|
assertTrue(map.containsKey("key2"));
|
||||||
|
assertNull(map.get("key2"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void putIfAbsent() {
|
||||||
|
Map<String, String> map = new MapModifier<String, String>()
|
||||||
|
.putIfAbsent("key1", null)
|
||||||
|
.putIfAbsent("key1", "value1")
|
||||||
|
.putIfAbsent("key1", "value2")
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
putIfAbsent("key1", null);
|
||||||
|
putIfAbsent("key1", "value1");
|
||||||
|
putIfAbsent("key1", "value2");
|
||||||
|
}
|
||||||
|
}, map);
|
||||||
|
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.putIfAbsent("key1", "newValue1")
|
||||||
|
.modify(map);
|
||||||
|
|
||||||
|
assertTrue(map.containsKey("key1"));
|
||||||
|
assertEquals("value1", map.get("key1"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void putAll_map() {
|
||||||
|
Map<String, String> entries = new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
}
|
||||||
|
};
|
||||||
|
Map<String, String> map = new MapModifier<String, String>()
|
||||||
|
.putAll((Map<String, String>) null)
|
||||||
|
.putAll(Collections.emptyMap())
|
||||||
|
.putAll(entries)
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
assertEquals(entries, map);
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.putAll(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key2", "newValue2");
|
||||||
|
put("key3", "value3");
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.modify(map);
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
put("key2", "newValue2");
|
||||||
|
put("key3", "value3");
|
||||||
|
}
|
||||||
|
}, map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void putAll_entries() {
|
||||||
|
Map<String, String> entries = new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
}
|
||||||
|
};
|
||||||
|
Map<String, String> map = new MapModifier<String, String>()
|
||||||
|
.putAll(new SimpleEntry<>("key1", "value1"),
|
||||||
|
new SimpleEntry<>("key2", "value2"))
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
assertEquals(entries, map);
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.putAll()
|
||||||
|
.putAll(new SimpleEntry<>("key2", "newValue2"),
|
||||||
|
new SimpleEntry<>("key3", "value3"))
|
||||||
|
.modify(map);
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
put("key2", "newValue2");
|
||||||
|
put("key3", "value3");
|
||||||
|
}
|
||||||
|
}, map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void computeIfAbsent_keyAndFunction() {
|
||||||
|
Map<String, String> map = new MapModifier<String, String>()
|
||||||
|
.computeIfAbsent("key1", k -> null)
|
||||||
|
.computeIfAbsent("key1", k -> "value1")
|
||||||
|
.computeIfAbsent("key1", k -> "value2")
|
||||||
|
.getAndModify(HashMap::new);
|
||||||
|
|
||||||
|
assertEquals(new HashMap<String, String>() {
|
||||||
|
{
|
||||||
|
computeIfAbsent("key1", k -> null);
|
||||||
|
computeIfAbsent("key1", k -> "value1");
|
||||||
|
computeIfAbsent("key1", k -> "value2");
|
||||||
|
}
|
||||||
|
}, map);
|
||||||
|
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.computeIfAbsent("key1", k -> "newValue1")
|
||||||
|
.modify(map);
|
||||||
|
|
||||||
|
assertTrue(map.containsKey("key1"));
|
||||||
|
assertEquals("value1", map.get("key1"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void computeIfPresent_keyAndBiFunction() {
|
||||||
|
Map<String, String> map = new HashMap<String, String>() {{
|
||||||
|
put("key1", "value1");
|
||||||
|
}};
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.computeIfPresent("key1", (k, v) -> k + v)
|
||||||
|
.computeIfPresent("key2", (k, v) -> k + v)
|
||||||
|
.modify(map);
|
||||||
|
assertEquals(new HashMap<String, String>() {{
|
||||||
|
put("key1", "key1value1");
|
||||||
|
}}, map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void remove() {
|
||||||
|
Map<String, String> map = new HashMap<String, String>() {{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
}};
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.remove("key2")
|
||||||
|
.modify(map);
|
||||||
|
assertEquals(new HashMap<String, String>() {{
|
||||||
|
put("key1", "value1");
|
||||||
|
}}, map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void clear() {
|
||||||
|
Map<String, String> map = new HashMap<String, String>() {{
|
||||||
|
put("key1", "value1");
|
||||||
|
put("key2", "value2");
|
||||||
|
}};
|
||||||
|
new MapModifier<String, String>()
|
||||||
|
.clear()
|
||||||
|
.modify(map);
|
||||||
|
assertTrue(map.isEmpty());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
static class SimpleEntry<K, V> implements Map.Entry<K, V> {
|
||||||
|
private final K key;
|
||||||
|
private final V value;
|
||||||
|
|
||||||
|
public SimpleEntry(K key, V value) {
|
||||||
|
this.key = key;
|
||||||
|
this.value = value;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public V setValue(@Nullable V value) {
|
||||||
|
throw new UnsupportedOperationException("Unimplemented method 'setValue'");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,3 +1,19 @@
|
|||||||
|
/*
|
||||||
|
* Copyright 2025 the original author or authors.
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* https://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
package xyz.zhouxy.plusone.commons.util;
|
package xyz.zhouxy.plusone.commons.util;
|
||||||
|
|
||||||
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
|
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
|
||||||
|
|||||||
@@ -52,6 +52,8 @@
|
|||||||
<jasypt.version>1.9.3</jasypt.version>
|
<jasypt.version>1.9.3</jasypt.version>
|
||||||
<jbcrypt.version>0.4</jbcrypt.version>
|
<jbcrypt.version>0.4</jbcrypt.version>
|
||||||
|
|
||||||
|
<minio.version>8.6.0</minio.version>
|
||||||
|
|
||||||
<lombok.version>1.18.36</lombok.version>
|
<lombok.version>1.18.36</lombok.version>
|
||||||
<hutool.version>5.8.37</hutool.version>
|
<hutool.version>5.8.37</hutool.version>
|
||||||
|
|
||||||
@@ -146,22 +148,27 @@
|
|||||||
<version>${gson.version}</version>
|
<version>${gson.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- MapStruct -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.mapstruct</groupId>
|
<groupId>org.mapstruct</groupId>
|
||||||
<artifactId>mapstruct</artifactId>
|
<artifactId>mapstruct</artifactId>
|
||||||
<version>${mapstruct.version}</version>
|
<version>${mapstruct.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- H2 测试数据库 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.h2database</groupId>
|
<groupId>com.h2database</groupId>
|
||||||
<artifactId>h2</artifactId>
|
<artifactId>h2</artifactId>
|
||||||
<version>${h2.version}</version>
|
<version>${h2.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- MyBatis -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.mybatis</groupId>
|
<groupId>org.mybatis</groupId>
|
||||||
<artifactId>mybatis</artifactId>
|
<artifactId>mybatis</artifactId>
|
||||||
<version>${mybatis.version}</version>
|
<version>${mybatis.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- Query DSL -->
|
<!-- Query DSL -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.querydsl</groupId>
|
<groupId>com.querydsl</groupId>
|
||||||
@@ -169,6 +176,7 @@
|
|||||||
<version>${querydsl.version}</version>
|
<version>${querydsl.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- Byte Buddy 字节码工具 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>net.bytebuddy</groupId>
|
<groupId>net.bytebuddy</groupId>
|
||||||
<artifactId>byte-buddy</artifactId>
|
<artifactId>byte-buddy</artifactId>
|
||||||
@@ -188,22 +196,34 @@
|
|||||||
<version>${poi.version}</version>
|
<version>${poi.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- JWT -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.auth0</groupId>
|
<groupId>com.auth0</groupId>
|
||||||
<artifactId>java-jwt</artifactId>
|
<artifactId>java-jwt</artifactId>
|
||||||
<version>${java-jwt.version}</version>
|
<version>${java-jwt.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- jasypt 加密解密 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.jasypt</groupId>
|
<groupId>org.jasypt</groupId>
|
||||||
<artifactId>jasypt</artifactId>
|
<artifactId>jasypt</artifactId>
|
||||||
<version>${jasypt.version}</version>
|
<version>${jasypt.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- Bcrypt是一种用于密码哈希的加密算法,基于Blowfish算法 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.mindrot</groupId>
|
<groupId>org.mindrot</groupId>
|
||||||
<artifactId>jbcrypt</artifactId>
|
<artifactId>jbcrypt</artifactId>
|
||||||
<version>${jbcrypt.version}</version>
|
<version>${jbcrypt.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- MinIO -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.minio</groupId>
|
||||||
|
<artifactId>minio</artifactId>
|
||||||
|
<version>${minio.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.projectlombok</groupId>
|
<groupId>org.projectlombok</groupId>
|
||||||
<artifactId>lombok</artifactId>
|
<artifactId>lombok</artifactId>
|
||||||
|
|||||||
Reference in New Issue
Block a user