|
|
@@ -1,6 +1,7 @@
|
|
|
package cn.tr.plugin.numbering.strategy.core;
|
|
|
|
|
|
import cn.tr.plugin.numbering.strategy.core.properties.NumberingStrategyProperties;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.cache.CacheManager;
|
|
|
|
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
@@ -12,6 +13,7 @@ import java.util.concurrent.ConcurrentMap;
|
|
|
* @Author : LF
|
|
|
* @Date: 2023年04月24日
|
|
|
*/
|
|
|
+@Slf4j
|
|
|
public class DefaultNumberingStrategyClientFactory implements NumberingStrategyClientFactory {
|
|
|
private final ConcurrentMap<String, NumberingStrategyClient> clients = new ConcurrentHashMap<>();
|
|
|
private CacheManager cacheManager;
|
|
|
@@ -28,6 +30,7 @@ public class DefaultNumberingStrategyClientFactory implements NumberingStrategyC
|
|
|
@Override
|
|
|
public NumberingStrategyClient createOrUpdateSmsClient(NumberingStrategyProperties config) {
|
|
|
NumberingStrategyClient client = getSerialStrategyClient(config.getClientId());
|
|
|
+ log.info("[Strategy ClientId]:{},[Strategy Type]:{}",config.getClientId(),config.getType());
|
|
|
if(client==null){
|
|
|
client=new DefaultNumberingStrategyClient(config,cacheManager);
|
|
|
clients.put(config.getClientId(),client);
|