admin/sms4j
1
0
Fork 0
mirror of https://gitee.com/dromara/sms4j.git synced 2025-12-06 17:08:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

新增 鼎众短信 渠道接入以及配置对象方式启动执行器相关设计的加载

Browse Source
This commit is contained in:
15946460103 2023-12-27 14:26:15 +08:00
parent 56565d5871
commit d92ff2bf46
8 changed files with 307 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sms4j-comm/src/main/java/org/dromara/sms4j/comm/constant/SupplierConstant.java
View File

@ -55,4 +55,9 @@ public abstract class SupplierConstant {
*/
public static final String LIANLU = "lianlu";
/**
* 鼎众
*/
public static final String DINGZHONG = "dingzhong";
}

35
sms4j-javase-plugin/src/main/java/org/dromara/sms4j/javase/config/SEInitializer.java
View File

@ -24,6 +24,7 @@ import org.dromara.sms4j.core.factory.SmsFactory;
import org.dromara.sms4j.core.proxy.processor.*;
import org.dromara.sms4j.core.proxy.SmsProxyFactory;
import org.dromara.sms4j.ctyun.config.CtyunFactory;
import org.dromara.sms4j.dingzhong.config.DingZhongFactory;
import org.dromara.sms4j.emay.config.EmayFactory;
import org.dromara.sms4j.huawei.config.HuaweiFactory;
import org.dromara.sms4j.javase.util.YamlUtils;
@ -39,6 +40,12 @@ import org.dromara.sms4j.unisms.config.UniFactory;
import org.dromara.sms4j.yunpian.config.YunPianFactory;
import org.dromara.sms4j.zhutong.config.ZhutongFactory;
import java.beans.BeanInfo;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@ -99,6 +106,33 @@ public class SEInitializer {
if (CollUtil.isEmpty(configList)) {
return;
}
try{
Map<String, Map<String, Object>> blends = new HashMap<>();
for (SupplierConfig supplierConfig : configList) {
Map<String, Object> param = new HashMap<>();
String channel = supplierConfig.getSupplier();
Class<? extends SupplierConfig> clazz = supplierConfig.getClass();
BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
for (PropertyDescriptor propertyDescriptor : propertyDescriptors) {
Method readMethod = propertyDescriptor.getReadMethod();
Object item = readMethod.invoke(supplierConfig);
param.put(propertyDescriptor.getName(),item);
}
blends.put(channel,param);
}
//持有初始化配置信息
EnvirmentHolder.frozenEnvirmet(smsConfig, blends);
//注册执行器实现
SmsProxyFactory.addProcessor(new RestrictedProcessor());
SmsProxyFactory.addProcessor(new BlackListProcessor());
SmsProxyFactory.addProcessor(new BlackListRecordingProcessor());
SmsProxyFactory.addProcessor(new SingleBlendRestrictedProcessor());
SmsProxyFactory.addProcessor(new CoreMethodParamValidateProcessor());
}catch (Exception e){
log.error("配置对象转换配置信息失败，但不影响基础功能的使用。【注意】：未加载SMS4J扩展功能模块，拦截器，参数校验可能失效！");
}
for (SupplierConfig supplierConfig : configList) {
SmsFactory.createSmsBlend(supplierConfig);
}
@ -194,6 +228,7 @@ public class SEInitializer {
ProviderFactoryHolder.registerFactory(YunPianFactory.instance());
ProviderFactoryHolder.registerFactory(ZhutongFactory.instance());
ProviderFactoryHolder.registerFactory(LianLuFactory.instance());
ProviderFactoryHolder.registerFactory(DingZhongFactory.instance());
if (SmsUtils.isClassExists("com.jdcloud.sdk.auth.CredentialsProvider")) {
ProviderFactoryHolder.registerFactory(JdCloudFactory.instance());
}

45
sms4j-provider/src/main/java/org/dromara/sms4j/dingzhong/config/DingZhongConfig.java Normal file
View File

@ -0,0 +1,45 @@
package org.dromara.sms4j.dingzhong.config;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.dromara.sms4j.comm.constant.SupplierConstant;
import org.dromara.sms4j.provider.config.BaseConfig;
/**
* @author Wind
*/
@EqualsAndHashCode(callSuper = true)
@Data
public class DingZhongConfig extends BaseConfig {
/**
* 模板变量名称
*/
private String templateName;
/**
* 请求地址
*/
private String requestUrl = "http://demoapi.321sms.com:8201";
/**
* 基础接口名称
*/
private String baseAction = "Sms/SendSms";
/**
* 模板接口名称
*/
private String templateAction = "Sms/SendTemplateSms";
/**
* 获取供应商
*
* @since 3.0.0
*/
@Override
public String getSupplier() {
return SupplierConstant.DINGZHONG;
}
}

48
sms4j-provider/src/main/java/org/dromara/sms4j/dingzhong/config/DingZhongFactory.java Normal file
View File

@ -0,0 +1,48 @@
package org.dromara.sms4j.dingzhong.config;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.dromara.sms4j.comm.constant.SupplierConstant;
import org.dromara.sms4j.dingzhong.service.DingZhongSmsImpl;
import org.dromara.sms4j.provider.factory.AbstractProviderFactory;
/**
* DingZhongFactory
* <p> 鼎众对象建造者
*
* @author :Sh1yu
* 2023/12/26 14:54
**/
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class DingZhongFactory extends AbstractProviderFactory<DingZhongSmsImpl, DingZhongConfig> {
private static final DingZhongFactory INSTANCE = new DingZhongFactory();
/**
* 获取建造者实例
* @return 建造者实例
*/
public static DingZhongFactory instance() {
return INSTANCE;
}
/**
* 创建短信实现对象
* @param dingZhongConfig 短信配置对象
* @return 短信实现对象
*/
@Override
public DingZhongSmsImpl createSms(DingZhongConfig dingZhongConfig) {
return new DingZhongSmsImpl(dingZhongConfig);
}
/**
* 获取供应商
* @return 供应商
*/
@Override
public String getSupplier() {
return SupplierConstant.DINGZHONG;
}
}

101
sms4j-provider/src/main/java/org/dromara/sms4j/dingzhong/service/DingZhongSmsImpl.java Normal file
View File

@ -0,0 +1,101 @@
package org.dromara.sms4j.dingzhong.service;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.dromara.sms4j.api.entity.SmsResponse;
import org.dromara.sms4j.comm.constant.SupplierConstant;
import org.dromara.sms4j.comm.delayedTime.DelayedTime;
import org.dromara.sms4j.comm.utils.SmsUtils;
import org.dromara.sms4j.dingzhong.config.DingZhongConfig;
import org.dromara.sms4j.dingzhong.util.DingZhongHelper;
import org.dromara.sms4j.provider.service.AbstractSmsBlend;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executor;
/**
* <p>类名: DingZhongSmsImpl
* <p>说明： 鼎众短信实现
*
* @author :Sh1yu
* 2023/12/26 17:16
**/
@Slf4j
public class DingZhongSmsImpl extends AbstractSmsBlend<DingZhongConfig> {
/**
* DingZhongSmsImpl
* <p>构造器，用于构造短信实现模块
*
* @author :Sh1yu
*/
public DingZhongSmsImpl(DingZhongConfig config, Executor pool, DelayedTime delayedTime) {
super(config, pool, delayedTime);
}
/**
* DingZhongSmsImpl
* <p>构造器，用于构造短信实现模块
*/
public DingZhongSmsImpl(DingZhongConfig config) {
super(config);
}
@Override
public String getSupplier() {
return SupplierConstant.DINGZHONG;
}
public SmsResponse temp(){
DingZhongHelper helper = new DingZhongHelper(getConfig(), http);
Map<String, Object> paramMap = new LinkedHashMap<>(3);
paramMap.put("cdkey", getConfig().getAccessKeyId());
paramMap.put("password", getConfig().getAccessKeySecret());
paramMap.put("content", "你正在申请手机注册，验证码为：<%code%>，5分钟内有效！");
return helper.smsResponse(paramMap);
}
@Override
public SmsResponse sendMessage(String phone, String message) {
DingZhongHelper helper = new DingZhongHelper(getConfig(), http);
Map<String, Object> paramMap = new LinkedHashMap<>(4);
paramMap.put("cdkey", getConfig().getAccessKeyId());
paramMap.put("password", getConfig().getAccessKeySecret());
paramMap.put("mobile", phone);
paramMap.put("msg", message);
return helper.smsResponse(paramMap);
//return temp();
}
@Override
public SmsResponse sendMessage(String phone, LinkedHashMap<String, String> messages) {
return sendMessage(phone,getConfig().getTemplateId(),messages);
}
@Override
public SmsResponse sendMessage(String phone, String templateId, LinkedHashMap<String, String> messages) {
DingZhongHelper helper = new DingZhongHelper(getConfig(), http);
Map<String, Object> paramMap = new LinkedHashMap<>(5);
paramMap.put("cdkey", getConfig().getAccessKeyId());
paramMap.put("password", getConfig().getAccessKeySecret());
paramMap.put("mobile", phone);
paramMap.put("templateId", templateId);
JSONObject params = new JSONObject();
params.putAll(messages);
paramMap.put("msgParam", params.toString());
return helper.smsResponse(paramMap);
}
@Override
public SmsResponse massTexting(List<String> phones, String message) {
return sendMessage(SmsUtils.arrayToString(phones),message);
}
@Override
public SmsResponse massTexting(List<String> phones, String templateId, LinkedHashMap<String, String> messages) {
return sendMessage(SmsUtils.arrayToString(phones),templateId,messages);
}
}

69
sms4j-provider/src/main/java/org/dromara/sms4j/dingzhong/util/DingZhongHelper.java Normal file
View File

@ -0,0 +1,69 @@
package org.dromara.sms4j.dingzhong.util;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.dromara.sms4j.api.entity.SmsResponse;
import org.dromara.sms4j.comm.constant.Constant;
import org.dromara.sms4j.comm.exception.SmsBlendException;
import org.dromara.sms4j.comm.utils.SmsHttpUtils;
import org.dromara.sms4j.comm.utils.SmsUtils;
import org.dromara.sms4j.dingzhong.config.DingZhongConfig;
import java.util.LinkedHashMap;
import java.util.Map;
/**
* 鼎众 Helper
*
* @author sh1yu
* @since 2023/12/26 20:57
*/
@Slf4j
public class DingZhongHelper {
private final DingZhongConfig config;
private final SmsHttpUtils http;
private int retry = 0;
public DingZhongHelper(DingZhongConfig config, SmsHttpUtils http) {
this.config = config;
this.http = http;
}
public SmsResponse smsResponse(Map<String, Object> paramMap) {
String url = String.format("%s/%s", config.getRequestUrl(), SmsUtils.isEmpty(paramMap.get("templateId"))?config.getBaseAction():config.getTemplateAction());
//String url = String.format("%s/%s", config.getRequestUrl(), "SmsTemplate/CreateSmsTemplate");
Map<String, String> headers = new LinkedHashMap<>(2);
headers.put("Accept", Constant.ACCEPT);
headers.put("Content-Type", Constant.FROM_URLENCODED);
SmsResponse smsResponse = null;
try {
smsResponse = getResponse(http.postFrom(url, headers, paramMap));
} catch (SmsBlendException e) {
smsResponse = new SmsResponse();
smsResponse.setSuccess(false);
smsResponse.setData(e.getMessage());
}
if (smsResponse.isSuccess() || retry == config.getMaxRetries()) {
retry = 0;
return smsResponse;
}
return requestRetry(paramMap);
}
private SmsResponse requestRetry(Map<String, Object> paramMap) {
http.safeSleep(config.getRetryInterval());
retry++;
log.warn("短信第 {" + retry + "} 次重新发送");
return smsResponse(paramMap);
}
private SmsResponse getResponse(JSONObject resJson) {
SmsResponse smsResponse = new SmsResponse();
smsResponse.setSuccess("0".equals(resJson.getStr("resCode")));
smsResponse.setData(resJson);
smsResponse.setConfigId(this.config.getConfigId());
return smsResponse;
}
}

2
sms4j-solon-plugin/src/main/java/org/dromara/sms4j/solon/config/SmsBlendsInitializer.java
View File

@ -15,6 +15,7 @@ import org.dromara.sms4j.core.factory.SmsFactory;
import org.dromara.sms4j.core.proxy.processor.*;
import org.dromara.sms4j.core.proxy.SmsProxyFactory;
import org.dromara.sms4j.ctyun.config.CtyunFactory;
import org.dromara.sms4j.dingzhong.config.DingZhongFactory;
import org.dromara.sms4j.emay.config.EmayFactory;
import org.dromara.sms4j.huawei.config.HuaweiFactory;
import org.dromara.sms4j.jdcloud.config.JdCloudFactory;
@ -103,6 +104,7 @@ public class SmsBlendsInitializer {
ProviderFactoryHolder.registerFactory(YunPianFactory.instance());
ProviderFactoryHolder.registerFactory(ZhutongFactory.instance());
ProviderFactoryHolder.registerFactory(LianLuFactory.instance());
ProviderFactoryHolder.registerFactory(DingZhongFactory.instance());
if(SmsUtils.isClassExists("com.jdcloud.sdk.auth.CredentialsProvider")) {
ProviderFactoryHolder.registerFactory(JdCloudFactory.instance());
}

2
sms4j-spring-boot-starter/src/main/java/org/dromara/sms4j/starter/config/SmsBlendsInitializer.java
View File

@ -16,6 +16,7 @@ import org.dromara.sms4j.core.factory.SmsFactory;
import org.dromara.sms4j.core.proxy.processor.*;
import org.dromara.sms4j.core.proxy.SmsProxyFactory;
import org.dromara.sms4j.ctyun.config.CtyunFactory;
import org.dromara.sms4j.dingzhong.config.DingZhongFactory;
import org.dromara.sms4j.emay.config.EmayFactory;
import org.dromara.sms4j.huawei.config.HuaweiFactory;
import org.dromara.sms4j.jdcloud.config.JdCloudFactory;
@ -101,6 +102,7 @@ public class SmsBlendsInitializer {
ProviderFactoryHolder.registerFactory(YunPianFactory.instance());
ProviderFactoryHolder.registerFactory(ZhutongFactory.instance());
ProviderFactoryHolder.registerFactory(LianLuFactory.instance());
ProviderFactoryHolder.registerFactory(DingZhongFactory.instance());
if(SmsUtils.isClassExists("com.jdcloud.sdk.auth.CredentialsProvider")) {
ProviderFactoryHolder.registerFactory(JdCloudFactory.instance());
}