mirror of
https://gitee.com/dromara/sms4j.git
synced 2025-12-07 01:18:33 +08:00
优化部分日志使用
This commit is contained in:
parent
6ef9c692b8
commit
aa51489624
@ -104,7 +104,7 @@ public abstract class SmsProxyFactory {
|
|||||||
log.info("{}:加载SmsDao成功,使用{}", frameworkName,smsDao.getClass().getName());
|
log.info("{}:加载SmsDao成功,使用{}", frameworkName,smsDao.getClass().getName());
|
||||||
return smsDao;
|
return smsDao;
|
||||||
} catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
|
} catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
|
||||||
log.info("{}:加载SmsDao失败,尝试其他框架加载......", frameworkName);
|
log.debug("{}:加载SmsDao失败,尝试其他框架加载......", frameworkName);
|
||||||
}
|
}
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -72,8 +72,8 @@ public class RestrictedProcessor implements CoreMethodProcessor, SmsDaoAware {
|
|||||||
if (SmsUtils.isEmpty(i)) {
|
if (SmsUtils.isEmpty(i)) {
|
||||||
smsDao.set(REDIS_KEY + phone + "max", 1, accTimer / 1000);
|
smsDao.set(REDIS_KEY + phone + "max", 1, accTimer / 1000);
|
||||||
} else if (i >= accountMax) {
|
} else if (i >= accountMax) {
|
||||||
log.info("The phone:" + phone + ",number of short messages reached the maximum today");
|
log.info("The phone: {},number of short messages reached the maximum today", phone);
|
||||||
throw new SmsBlendException("The phone:" + phone + ",number of short messages reached the maximum today");
|
throw new SmsBlendException("The phone: {},number of short messages reached the maximum today", phone);
|
||||||
} else {
|
} else {
|
||||||
smsDao.set(REDIS_KEY + phone + "max", i + 1, accTimer / 1000);
|
smsDao.set(REDIS_KEY + phone + "max", i + 1, accTimer / 1000);
|
||||||
}
|
}
|
||||||
@ -84,8 +84,8 @@ public class RestrictedProcessor implements CoreMethodProcessor, SmsDaoAware {
|
|||||||
if (o < minuteMax) {
|
if (o < minuteMax) {
|
||||||
smsDao.set(REDIS_KEY + phone, o + 1, minTimer / 1000);
|
smsDao.set(REDIS_KEY + phone, o + 1, minTimer / 1000);
|
||||||
} else {
|
} else {
|
||||||
log.info("The phone:" + phone + ",number of short messages reached the maximum today");
|
log.info("The phone: {},number of short messages reached the maximum today", phone);
|
||||||
throw new SmsBlendException("The phone:", phone + " Text messages are sent too often!");
|
throw new SmsBlendException("The phone: {} Text messages are sent too often!", phone);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
smsDao.set(REDIS_KEY + phone, 1, minTimer / 1000);
|
smsDao.set(REDIS_KEY + phone, 1, minTimer / 1000);
|
||||||
|
|||||||
@ -66,8 +66,8 @@ public class SingleBlendRestrictedProcessor implements SmsProcessor, SmsDaoAware
|
|||||||
if (SmsUtils.isEmpty(i)) {
|
if (SmsUtils.isEmpty(i)) {
|
||||||
smsDao.set(REDIS_KEY + configId + "maximum", 1);
|
smsDao.set(REDIS_KEY + configId + "maximum", 1);
|
||||||
} else if (i >= maximum) {
|
} else if (i >= maximum) {
|
||||||
log.info("The channel:" + configId + ",messages reached the maximum");
|
log.info("The channel: {},messages reached the maximum", configId);
|
||||||
throw new SmsBlendException("The channel:" + configId + ",messages reached the maximum");
|
throw new SmsBlendException("The channel: {},messages reached the maximum", configId);
|
||||||
} else {
|
} else {
|
||||||
smsDao.set(REDIS_KEY + configId + "maximum", i + 1);
|
smsDao.set(REDIS_KEY + configId + "maximum", i + 1);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -121,7 +121,7 @@ public class AlibabaSmsImpl extends AbstractSmsBlend<AlibabaConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(phone, message, templateId);
|
return getSmsResponse(phone, message, templateId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -65,7 +65,7 @@ public class CloopenHelper {
|
|||||||
private SmsResponse requestRetry(Map<String, Object> paramMap) {
|
private SmsResponse requestRetry(Map<String, Object> paramMap) {
|
||||||
http.safeSleep(config.getRetryInterval());
|
http.safeSleep(config.getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return smsResponse(paramMap);
|
return smsResponse(paramMap);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -107,7 +107,7 @@ public class CtyunSmsImpl extends AbstractSmsBlend<CtyunConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry ++;
|
retry ++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(phone, message, templateId);
|
return getSmsResponse(phone, message, templateId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -54,7 +54,7 @@ public class DingZhongHelper {
|
|||||||
private SmsResponse requestRetry(Map<String, Object> paramMap) {
|
private SmsResponse requestRetry(Map<String, Object> paramMap) {
|
||||||
http.safeSleep(config.getRetryInterval());
|
http.safeSleep(config.getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return smsResponse(paramMap);
|
return smsResponse(paramMap);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -75,7 +75,7 @@ public class EmaySmsImpl extends AbstractSmsBlend<EmayConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String message) {
|
private SmsResponse requestRetry(String phone, String message) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return sendMessage(phone, message);
|
return sendMessage(phone, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -88,7 +88,7 @@ public class HuaweiSmsImpl extends AbstractSmsBlend<HuaweiConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String templateId, LinkedHashMap<String, String> messages) {
|
private SmsResponse requestRetry(String phone, String templateId, LinkedHashMap<String, String> messages) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return sendMessage(phone, templateId, messages);
|
return sendMessage(phone, templateId, messages);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -107,7 +107,7 @@ public class JdCloudSmsImpl extends AbstractSmsBlend<JdCloudConfig> {
|
|||||||
private SmsResponse requestRetry(List<String> phones, String templateId, LinkedHashMap<String, String> messages) {
|
private SmsResponse requestRetry(List<String> phones, String templateId, LinkedHashMap<String, String> messages) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return massTexting(phones, templateId, messages);
|
return massTexting(phones, templateId, messages);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -142,7 +142,7 @@ public class NeteaseSmsImpl extends AbstractSmsBlend<NeteaseConfig> {
|
|||||||
private SmsResponse requestRetry(String requestUrl, List<String> phones, String message, String templateId) {
|
private SmsResponse requestRetry(String requestUrl, List<String> phones, String message, String templateId) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(requestUrl, phones, message, templateId);
|
return getSmsResponse(requestUrl, phones, message, templateId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -92,7 +92,7 @@ public class QiNiuSmsImpl extends AbstractSmsBlend<QiNiuConfig> {
|
|||||||
}
|
}
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return handleRes(url, params);
|
return handleRes(url, params);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -123,7 +123,7 @@ public class TencentSmsImpl extends AbstractSmsBlend<TencentConfig> {
|
|||||||
private SmsResponse requestRetry(String[] phones, String[] messages, String templateId) {
|
private SmsResponse requestRetry(String[] phones, String[] messages, String templateId) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(phones, messages, templateId);
|
return getSmsResponse(phones, messages, templateId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -113,7 +113,7 @@ public class UniClient {
|
|||||||
private UniResponse requestRetry(String action, Map<String, Object> data) {
|
private UniResponse requestRetry(String action, Map<String, Object> data) {
|
||||||
http.safeSleep(retryInterval);
|
http.safeSleep(retryInterval);
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return request(action, data);
|
return request(action, data);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -82,7 +82,7 @@ public class YunPianSmsImpl extends AbstractSmsBlend<YunpianConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String message) {
|
private SmsResponse requestRetry(String phone, String message) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return sendMessage(phone, message);
|
return sendMessage(phone, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -107,7 +107,7 @@ public class YunPianSmsImpl extends AbstractSmsBlend<YunpianConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String templateId, LinkedHashMap<String, String> messages) {
|
private SmsResponse requestRetry(String phone, String templateId, LinkedHashMap<String, String> messages) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return sendMessage(phone, templateId, messages);
|
return sendMessage(phone, templateId, messages);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -160,7 +160,7 @@ public class ZhutongSmsImpl extends AbstractSmsBlend<ZhutongConfig> {
|
|||||||
private SmsResponse requestRetry(List<String> phones, String content) {
|
private SmsResponse requestRetry(List<String> phones, String content) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(phones, content);
|
return getSmsResponse(phones, content);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -248,7 +248,7 @@ public class ZhutongSmsImpl extends AbstractSmsBlend<ZhutongConfig> {
|
|||||||
private SmsResponse requestRetry(String templateId, List<String> phones, LinkedHashMap<String, String> messages) {
|
private SmsResponse requestRetry(String templateId, List<String> phones, LinkedHashMap<String, String> messages) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponseTemplate(templateId, phones, messages);
|
return getSmsResponseTemplate(templateId, phones, messages);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -104,7 +104,7 @@ public class ZhangJunSmsImpl extends AbstractSmsBlend<ZhangJunConfig> {
|
|||||||
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
private SmsResponse requestRetry(String phone, String message, String templateId) {
|
||||||
http.safeSleep(getConfig().getRetryInterval());
|
http.safeSleep(getConfig().getRetryInterval());
|
||||||
retry++;
|
retry++;
|
||||||
log.warn("短信第 {" + retry + "} 次重新发送");
|
log.warn("短信第 {} 次重新发送", retry);
|
||||||
return getSmsResponse(phone, message, templateId);
|
return getSmsResponse(phone, message, templateId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user