package com.ruoyi.message.config;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.ApplicationArguments;
|
import org.springframework.boot.ApplicationRunner;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 消息发送配置自检。
|
* <p>
|
* 存在的意义：这些 key 过去是散落在各处的 {@code @Value}，改成 {@code @ConfigurationProperties}
|
* 之后如果前缀/层级写错，**编译期完全发现不了**，直到线上发短信时才发现参数是 null。
|
* 因此启动时把当前 profile 真正用到的配置项打印出来（密钥脱敏），并对空值告警。
|
*/
|
@Slf4j
|
@Component
|
public class MessageConfigValidator implements ApplicationRunner {
|
|
private final MessageProperties properties;
|
|
@Value("${spring.profiles.active:}")
|
private String active;
|
|
public MessageConfigValidator(MessageProperties properties) {
|
this.properties = properties;
|
}
|
|
@Override
|
public void run(ApplicationArguments args) {
|
MessageProperties.Sms sms = properties.getSms();
|
XhsmsConfig xhsms = sms.getXhsms();
|
MtSmsConfig mt = sms.getMt();
|
AliyunSmsConfig aliyun = sms.getAliyun();
|
|
log.info("【消息配置自检】active={}，xhsms: path={}, account={}, pwd={}, extno={}",
|
active, mask(xhsms.getPath()), mask(xhsms.getAccount()), maskSecret(xhsms.getPwd()),
|
mask(xhsms.getExtno()));
|
log.info("【消息配置自检】mt(nhfy): url={}, accountName={}, password={}, sourceAddr={}, serviceCode={}, appkey={}, flag={}",
|
mask(mt.getUrl()), mask(mt.getAccountName()), maskSecret(mt.getPassword()),
|
mask(mt.getSourceAddr()), mask(mt.getServiceCode()), mask(mt.getAppkey()), mask(mt.getFlag()));
|
log.info("【消息配置自检】aliyun: accessKeyId={}, accessKeySecret={}, signName={}",
|
mask(aliyun.getAccessKeyId()), maskSecret(aliyun.getAccessKeySecret()), mask(aliyun.getSignName()));
|
log.info("【消息配置自检】wechat: shiyi.url={}, shiyi.key={}, xinhua.service={}",
|
mask(properties.getWechat().getShiyi().getUrl()),
|
maskSecret(properties.getWechat().getShiyi().getKey()),
|
mask(properties.getWechat().getXinhua().getService()));
|
|
check("active", active);
|
if ("xh".equals(active) || "hzszlyy".equals(active)) {
|
check("xhsmsPath", xhsms.getPath());
|
check("xhsmsAccount", xhsms.getAccount());
|
check("xhsmsPwd", xhsms.getPwd());
|
} else if ("nhfy".equals(active)) {
|
check("sms_url", mt.getUrl());
|
check("sms_accountName", mt.getAccountName());
|
check("sms_password", mt.getPassword());
|
check("sms_sourceAddr", mt.getSourceAddr());
|
check("sms_serviceCode", mt.getServiceCode());
|
check("sms_flag", mt.getFlag());
|
}
|
}
|
|
private void check(String key, String value) {
|
if (value == null || value.trim().isEmpty()) {
|
log.warn("【消息配置自检】⚠️ 当前 profile（{}）需要 {}，但该配置为空/未绑定！"
|
+ "请检查 application-{}.yml 与 MessageProperties/RootMessageProperties 的绑定层级。",
|
active, key, active);
|
}
|
}
|
|
private String mask(String value) {
|
if (value == null) {
|
return "<null>";
|
}
|
if (value.isEmpty()) {
|
return "<空>";
|
}
|
return value;
|
}
|
|
private String maskSecret(String value) {
|
if (value == null) {
|
return "<null>";
|
}
|
if (value.isEmpty()) {
|
return "<空>";
|
}
|
if (value.length() <= 2) {
|
return "**";
|
}
|
return value.substring(0, 1) + "***" + value.substring(value.length() - 1);
|
}
|
}
|
