package com.smartor.message;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.ruoyi.common.enums.WxGZHEnum;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.message.wechat.WechatMpConfig;
|
import com.ruoyi.message.wechat.WechatMpConfigProvider;
|
import com.ruoyi.system.service.ISysConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Map;
|
|
/**
|
* 微信公众号机构级配置实现：收口原先散落在三个类里的 {@code WxGZHEnum.getDescByCode(orgid)}
|
* 调用（{@code RyTask} / {@code RedisMqReceiver} / {@code ServiceSubtaskServiceImpl}）。
|
* <p>
|
* 配置源优先级：
|
* <ol>
|
* <li>{@code sys_config} 表 key = {@code wx.mp.config.<orgid>}，值形如
|
* {@code {"appid":"xx","appSecret":"yy","address":"zz"}} —— 便于新机构不改代码接入；</li>
|
* <li>代码内 {@link WxGZHEnum} 枚举（保持原有配置源不变，行为与线上一致）。</li>
|
* </ol>
|
* 同时把「按 List 下标取 appid/appSecret/address」这种脆弱写法改成了显式字段取值。
|
*/
|
@Slf4j
|
@Component
|
public class WechatMpConfigProviderImpl implements WechatMpConfigProvider {
|
|
/**
|
* 机构级公众号配置的配置项 key 前缀
|
*/
|
private static final String CONFIG_KEY_PREFIX = "wx.mp.config.";
|
|
private final ISysConfigService configService;
|
|
public WechatMpConfigProviderImpl(ISysConfigService configService) {
|
this.configService = configService;
|
}
|
|
@Override
|
public WechatMpConfig getConfig(String orgid) {
|
if (StringUtils.isEmpty(orgid)) {
|
return null;
|
}
|
|
//优先取数据库配置（支持新机构）
|
WechatMpConfig fromDb = readFromDb(orgid);
|
if (fromDb != null && fromDb.isComplete()) {
|
return fromDb;
|
}
|
|
WechatMpConfig config = new WechatMpConfig();
|
config.setOrgid(orgid);
|
for (WxGZHEnum item : WxGZHEnum.values()) {
|
if (orgid.equals(item.getOrgid())) {
|
config.setAppid(item.getAppid());
|
config.setAppSecret(item.getAppSecret());
|
config.setAddress(item.getAddress());
|
break;
|
}
|
}
|
|
if (!config.isComplete()) {
|
log.warn("【WechatMpConfigProviderImpl】机构 {} 的公众号配置不完整：{}", orgid, config);
|
}
|
return config;
|
}
|
|
private WechatMpConfig readFromDb(String orgid) {
|
try {
|
String value = configService.selectConfigByKey(CONFIG_KEY_PREFIX + orgid, orgid);
|
if (StringUtils.isEmpty(value)) {
|
return null;
|
}
|
Map<String, String> map = new ObjectMapper().readValue(value, Map.class);
|
WechatMpConfig config = new WechatMpConfig();
|
config.setOrgid(orgid);
|
config.setAppid(map.get("appid"));
|
config.setAppSecret(map.get("appSecret"));
|
config.setAddress(map.get("address"));
|
return config;
|
} catch (Exception e) {
|
log.warn("【WechatMpConfigProviderImpl】读取 {} 配置失败，orgid：{}，err：{}",
|
CONFIG_KEY_PREFIX + orgid, orgid, e.getMessage());
|
return null;
|
}
|
}
|
}
|
