package cn.iocoder.yudao.module.system.framework.weixin.config;
|
|
import cn.binarywang.wx.miniapp.config.WxMaConfig;
|
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
|
import cn.binarywang.wx.miniapp.config.impl.WxMaRedisBetterConfigImpl;
|
import com.binarywang.spring.starter.wxjava.miniapp.properties.WxMaProperties;
|
import com.binarywang.spring.starter.wxjava.mp.properties.WxMpProperties;
|
import lombok.extern.slf4j.Slf4j;
|
import me.chanjar.weixin.common.redis.RedisTemplateWxRedisOps;
|
import me.chanjar.weixin.common.redis.WxRedisOps;
|
import me.chanjar.weixin.mp.config.WxMpConfigStorage;
|
import me.chanjar.weixin.mp.config.WxMpHostConfig;
|
import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
|
import me.chanjar.weixin.mp.config.impl.WxMpRedisConfigImpl;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
|
/**
|
* 微信公众号、小程序（weixin-java）的配置类
|
*
|
* weixin-java 4.8.x 的 {@code AbstractWxMpConfigStorageConfiguration} / {@code AbstractWxMaConfigStorageConfiguration}
|
* 在初始化 config storage 时，会无条件调用 {@code DefaultApacheHttpClientBuilder.get()}，后者在类加载时引用
|
* Apache HttpClient 4.x 的 {@code org.apache.http.ssl.TrustStrategy} 等类，导致启动报
|
* {@code NoClassDefFoundError}（Spring Boot 4.x / 新版 Spring Cloud Alibaba 不再传递 HttpClient 4.x）。
|
*
|
* 本配置类自行创建 {@link WxMpConfigStorage} / {@link WxMaConfig} bean，绕过官方的初始化逻辑，
|
* 配合 {@code http-client-type: HttpComponents} 配置，只依赖 Apache HttpClient 5.x。
|
*
|
* @author 芋道源码
|
*/
|
@Configuration(proxyBeanMethods = false)
|
@Slf4j
|
public class YudaoWxClientConfiguration {
|
|
@Bean
|
@ConditionalOnProperty(prefix = WxMpProperties.PREFIX + ".config-storage", name = "type", havingValue = "redistemplate")
|
@ConditionalOnClass(StringRedisTemplate.class)
|
@ConditionalOnMissingBean(WxMpConfigStorage.class)
|
public WxMpConfigStorage wxMpConfigStorage(WxMpProperties properties, ApplicationContext applicationContext) {
|
StringRedisTemplate redisTemplate = applicationContext.getBean(StringRedisTemplate.class);
|
WxRedisOps redisOps = new RedisTemplateWxRedisOps(redisTemplate);
|
WxMpRedisConfigImpl config = new WxMpRedisConfigImpl(redisOps, properties.getConfigStorage().getKeyPrefix());
|
applyWxMpConfig(config, properties);
|
return config;
|
}
|
|
@Bean
|
@ConditionalOnProperty(prefix = WxMaProperties.PREFIX + ".config-storage", name = "type", havingValue = "redistemplate")
|
@ConditionalOnClass(StringRedisTemplate.class)
|
@ConditionalOnMissingBean(WxMaConfig.class)
|
public WxMaConfig wxMaConfig(WxMaProperties properties, ApplicationContext applicationContext) {
|
StringRedisTemplate redisTemplate = applicationContext.getBean(StringRedisTemplate.class);
|
WxRedisOps redisOps = new RedisTemplateWxRedisOps(redisTemplate);
|
WxMaRedisBetterConfigImpl config = new WxMaRedisBetterConfigImpl(redisOps, properties.getConfigStorage().getKeyPrefix());
|
applyWxMaConfig(config, properties);
|
return config;
|
}
|
|
private void applyWxMpConfig(WxMpDefaultConfigImpl config, WxMpProperties properties) {
|
config.setAppId(properties.getAppId());
|
config.setSecret(properties.getSecret());
|
config.setToken(properties.getToken());
|
config.setAesKey(properties.getAesKey());
|
config.setUseStableAccessToken(properties.isUseStableAccessToken());
|
|
WxMpProperties.ConfigStorage storage = properties.getConfigStorage();
|
config.setHttpProxyHost(storage.getHttpProxyHost());
|
config.setHttpProxyUsername(storage.getHttpProxyUsername());
|
config.setHttpProxyPassword(storage.getHttpProxyPassword());
|
if (storage.getHttpProxyPort() != null) {
|
config.setHttpProxyPort(storage.getHttpProxyPort());
|
}
|
|
if (properties.getHosts() != null && StringUtils.isNotEmpty(properties.getHosts().getApiHost())) {
|
WxMpHostConfig hostConfig = new WxMpHostConfig();
|
hostConfig.setApiHost(properties.getHosts().getApiHost());
|
hostConfig.setOpenHost(properties.getHosts().getOpenHost());
|
hostConfig.setMpHost(properties.getHosts().getMpHost());
|
config.setHostConfig(hostConfig);
|
}
|
}
|
|
private void applyWxMaConfig(WxMaDefaultConfigImpl config, WxMaProperties properties) {
|
WxMaProperties.ConfigStorage storage = properties.getConfigStorage();
|
config.setAppid(StringUtils.trimToNull(properties.getAppid()));
|
config.setSecret(StringUtils.trimToNull(properties.getSecret()));
|
config.setToken(StringUtils.trimToNull(properties.getToken()));
|
config.setAesKey(StringUtils.trimToNull(properties.getAesKey()));
|
config.setMsgDataFormat(StringUtils.trimToNull(properties.getMsgDataFormat()));
|
config.useStableAccessToken(properties.isUseStableAccessToken());
|
config.setApiHostUrl(StringUtils.trimToNull(properties.getApiHostUrl()));
|
config.setAccessTokenUrl(StringUtils.trimToNull(properties.getAccessTokenUrl()));
|
|
config.setHttpProxyHost(storage.getHttpProxyHost());
|
config.setHttpProxyUsername(storage.getHttpProxyUsername());
|
config.setHttpProxyPassword(storage.getHttpProxyPassword());
|
if (storage.getHttpProxyPort() != null) {
|
config.setHttpProxyPort(storage.getHttpProxyPort());
|
}
|
|
config.setRetrySleepMillis(Math.max(storage.getRetrySleepMillis(), 1000));
|
config.setMaxRetryTimes(Math.max(storage.getMaxRetryTimes(), 0));
|
}
|
|
}
|
