Skip to content

Commit 583e1a0

Browse files
lixizelixize
authored
🆕 #2991【视频号】增加视频号模块，实现视频号大部分相关接口
1 parent 899ea65 commit 583e1a0

File tree

420 files changed

+20931
-1
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

420 files changed

+20931
-1
lines changed

‎pom.xml

+1
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@
119119
<module>weixin-java-miniapp</module>
120120
<module>weixin-java-open</module>
121121
<module>weixin-java-qidian</module>
122+
<module>weixin-java-channel</module>
122123
<module>spring-boot-starters</module>
123124
<!--module>weixin-java-osgi</module-->
124125
</modules>

‎spring-boot-starters/pom.xml

+1
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
<module>wx-java-open-spring-boot-starter</module>
2323
<module>wx-java-qidian-spring-boot-starter</module>
2424
<module>wx-java-cp-spring-boot-starter</module>
25+
<module>wx-java-channel-spring-boot-starter</module>
2526
</modules>
2627

2728
<dependencies>

‎spring-boot-starters/wx-java-channel-spring-boot-starter/pom.xml

+60
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
2+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3+
<parent>
4+
<artifactId>wx-java-spring-boot-starters</artifactId>
5+
<groupId>com.github.binarywang</groupId>
6+
<version>4.4.9.B</version>
7+
</parent>
8+
<modelVersion>4.0.0</modelVersion>
9+
10+
<artifactId>wx-java-channel-spring-boot-starter</artifactId>
11+
<name>WxJava - Spring Boot Starter for Channel</name>
12+
<description>微信视频号开发的 Spring Boot Starter</description>
13+
14+
<dependencies>
15+
<dependency>
16+
<groupId>com.github.binarywang</groupId>
17+
<artifactId>weixin-java-channel</artifactId>
18+
<version>${project.version}</version>
19+
</dependency>
20+
<dependency>
21+
<groupId>redis.clients</groupId>
22+
<artifactId>jedis</artifactId>
23+
<scope>provided</scope>
24+
</dependency>
25+
<dependency>
26+
<groupId>org.redisson</groupId>
27+
<artifactId>redisson</artifactId>
28+
<scope>provided</scope>
29+
</dependency>
30+
<dependency>
31+
<groupId>org.springframework.data</groupId>
32+
<artifactId>spring-data-redis</artifactId>
33+
<version>${spring.boot.version}</version>
34+
<scope>provided</scope>
35+
</dependency>
36+
</dependencies>
37+
38+
<build>
39+
<plugins>
40+
<plugin>
41+
<groupId>org.springframework.boot</groupId>
42+
<artifactId>spring-boot-maven-plugin</artifactId>
43+
<version>${spring.boot.version}</version>
44+
</plugin>
45+
<plugin>
46+
<groupId>org.apache.maven.plugins</groupId>
47+
<artifactId>maven-source-plugin</artifactId>
48+
<version>2.2.1</version>
49+
<executions>
50+
<execution>
51+
<id>attach-sources</id>
52+
<goals>
53+
<goal>jar-no-fork</goal>
54+
</goals>
55+
</execution>
56+
</executions>
57+
</plugin>
58+
</plugins>
59+
</build>
60+
</project>

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/WxChannelAutoConfiguration.java

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config;
2+
3+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
4+
import org.springframework.boot.context.properties.EnableConfigurationProperties;
5+
import org.springframework.context.annotation.Configuration;
6+
import org.springframework.context.annotation.Import;
7+
8+
/**
9+
* 自动配置
10+
*
11+
* @author <a href="https://github.com/lixize">Zeyes</a>
12+
*/
13+
@Configuration
14+
@EnableConfigurationProperties(WxChannelProperties.class)
15+
@Import({
16+
WxChannelStorageAutoConfiguration.class,
17+
WxChannelServiceAutoConfiguration.class
18+
})
19+
public class WxChannelAutoConfiguration {
20+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/WxChannelServiceAutoConfiguration.java

+37
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config;
2+
3+
4+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
5+
import lombok.AllArgsConstructor;
6+
import me.chanjar.weixin.channel.api.WxChannelService;
7+
import me.chanjar.weixin.channel.api.impl.WxChannelServiceImpl;
8+
import me.chanjar.weixin.channel.config.WxChannelConfig;
9+
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
10+
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
11+
import org.springframework.context.annotation.Bean;
12+
import org.springframework.context.annotation.Configuration;
13+
14+
/**
15+
* 微信小程序平台相关服务自动注册
16+
*
17+
* @author <a href="https://github.com/lixize">Zeyes</a>
18+
*/
19+
@Configuration
20+
@AllArgsConstructor
21+
public class WxChannelServiceAutoConfiguration {
22+
private final WxChannelProperties properties;
23+
24+
/**
25+
* Channel Service
26+
*
27+
* @return Channel Service
28+
*/
29+
@Bean
30+
@ConditionalOnMissingBean(WxChannelService.class)
31+
@ConditionalOnBean(WxChannelConfig.class)
32+
public WxChannelService wxChannelService(WxChannelConfig wxChannelConfig) {
33+
WxChannelService wxChannelService = new WxChannelServiceImpl();
34+
wxChannelService.setConfig(wxChannelConfig);
35+
return wxChannelService;
36+
}
37+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/WxChannelStorageAutoConfiguration.java

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config;
2+
3+
import com.binarywang.spring.starter.wxjava.channel.config.storage.WxChannelInJedisConfigStorageConfiguration;
4+
import com.binarywang.spring.starter.wxjava.channel.config.storage.WxChannelInMemoryConfigStorageConfiguration;
5+
import com.binarywang.spring.starter.wxjava.channel.config.storage.WxChannelInRedisTemplateConfigStorageConfiguration;
6+
import com.binarywang.spring.starter.wxjava.channel.config.storage.WxChannelInRedissonConfigStorageConfiguration;
7+
import org.springframework.context.annotation.Configuration;
8+
import org.springframework.context.annotation.Import;
9+
10+
/**
11+
* 微信小程序存储策略自动配置
12+
*
13+
* @author <a href="https://github.com/lixize">Zeyes</a>
14+
*/
15+
@Configuration
16+
@Import({
17+
WxChannelInMemoryConfigStorageConfiguration.class,
18+
WxChannelInJedisConfigStorageConfiguration.class,
19+
WxChannelInRedisTemplateConfigStorageConfiguration.class,
20+
WxChannelInRedissonConfigStorageConfiguration.class
21+
})
22+
public class WxChannelStorageAutoConfiguration {
23+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/storage/AbstractWxChannelConfigStorageConfiguration.java

+39
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config.storage;
2+
3+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
4+
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
5+
import org.apache.commons.lang3.StringUtils;
6+
7+
/**
8+
* @author <a href="https://github.com/lixize">Zeyes</a>
9+
*/
10+
public abstract class AbstractWxChannelConfigStorageConfiguration {
11+
12+
protected WxChannelDefaultConfigImpl config(WxChannelDefaultConfigImpl config, WxChannelProperties properties) {
13+
config.setAppid(StringUtils.trimToNull(properties.getAppid()));
14+
config.setSecret(StringUtils.trimToNull(properties.getSecret()));
15+
config.setToken(StringUtils.trimToNull(properties.getToken()));
16+
config.setAesKey(StringUtils.trimToNull(properties.getAesKey()));
17+
config.setMsgDataFormat(StringUtils.trimToNull(properties.getMsgDataFormat()));
18+
19+
WxChannelProperties.ConfigStorage configStorageProperties = properties.getConfigStorage();
20+
config.setHttpProxyHost(configStorageProperties.getHttpProxyHost());
21+
config.setHttpProxyUsername(configStorageProperties.getHttpProxyUsername());
22+
config.setHttpProxyPassword(configStorageProperties.getHttpProxyPassword());
23+
if (configStorageProperties.getHttpProxyPort() != null) {
24+
config.setHttpProxyPort(configStorageProperties.getHttpProxyPort());
25+
}
26+
27+
int maxRetryTimes = configStorageProperties.getMaxRetryTimes();
28+
if (configStorageProperties.getMaxRetryTimes() < 0) {
29+
maxRetryTimes = 0;
30+
}
31+
int retrySleepMillis = configStorageProperties.getRetrySleepMillis();
32+
if (retrySleepMillis < 0) {
33+
retrySleepMillis = 1000;
34+
}
35+
config.setRetrySleepMillis(retrySleepMillis);
36+
config.setMaxRetryTimes(maxRetryTimes);
37+
return config;
38+
}
39+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/storage/WxChannelInJedisConfigStorageConfiguration.java

+73
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,73 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config.storage;
2+
3+
4+
import com.binarywang.spring.starter.wxjava.channel.properties.RedisProperties;
5+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
6+
import lombok.RequiredArgsConstructor;
7+
import me.chanjar.weixin.channel.config.WxChannelConfig;
8+
import me.chanjar.weixin.channel.config.impl.WxChannelRedisConfigImpl;
9+
import me.chanjar.weixin.common.redis.JedisWxRedisOps;
10+
import me.chanjar.weixin.common.redis.WxRedisOps;
11+
import org.apache.commons.lang3.StringUtils;
12+
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
13+
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
14+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
15+
import org.springframework.context.ApplicationContext;
16+
import org.springframework.context.annotation.Bean;
17+
import org.springframework.context.annotation.Configuration;
18+
import redis.clients.jedis.JedisPool;
19+
import redis.clients.jedis.JedisPoolConfig;
20+
21+
/**
22+
* @author <a href="https://github.com/lixize">Zeyes</a>
23+
*/
24+
@Configuration
25+
@ConditionalOnProperty(prefix = WxChannelProperties.PREFIX + ".config-storage", name = "type", havingValue = "jedis")
26+
@ConditionalOnClass({JedisPool.class, JedisPoolConfig.class})
27+
@RequiredArgsConstructor
28+
public class WxChannelInJedisConfigStorageConfiguration extends AbstractWxChannelConfigStorageConfiguration {
29+
private final WxChannelProperties properties;
30+
private final ApplicationContext applicationContext;
31+
32+
@Bean
33+
@ConditionalOnMissingBean(WxChannelConfig.class)
34+
public WxChannelConfig wxChannelConfig() {
35+
WxChannelRedisConfigImpl config = getWxChannelRedisConfig();
36+
return this.config(config, properties);
37+
}
38+
39+
private WxChannelRedisConfigImpl getWxChannelRedisConfig() {
40+
RedisProperties redisProperties = properties.getConfigStorage().getRedis();
41+
JedisPool jedisPool;
42+
if (redisProperties != null && StringUtils.isNotEmpty(redisProperties.getHost())) {
43+
jedisPool = getJedisPool();
44+
} else {
45+
jedisPool = applicationContext.getBean(JedisPool.class);
46+
}
47+
WxRedisOps redisOps = new JedisWxRedisOps(jedisPool);
48+
return new WxChannelRedisConfigImpl(redisOps, properties.getConfigStorage().getKeyPrefix());
49+
}
50+
51+
private JedisPool getJedisPool() {
52+
WxChannelProperties.ConfigStorage storage = properties.getConfigStorage();
53+
RedisProperties redis = storage.getRedis();
54+
55+
JedisPoolConfig config = new JedisPoolConfig();
56+
if (redis.getMaxActive() != null) {
57+
config.setMaxTotal(redis.getMaxActive());
58+
}
59+
if (redis.getMaxIdle() != null) {
60+
config.setMaxIdle(redis.getMaxIdle());
61+
}
62+
if (redis.getMaxWaitMillis() != null) {
63+
config.setMaxWaitMillis(redis.getMaxWaitMillis());
64+
}
65+
if (redis.getMinIdle() != null) {
66+
config.setMinIdle(redis.getMinIdle());
67+
}
68+
config.setTestOnBorrow(true);
69+
config.setTestWhileIdle(true);
70+
71+
return new JedisPool(config, redis.getHost(), redis.getPort(), redis.getTimeout(), redis.getPassword(), redis.getDatabase());
72+
}
73+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/storage/WxChannelInMemoryConfigStorageConfiguration.java

+29
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config.storage;
2+
3+
4+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
5+
import lombok.RequiredArgsConstructor;
6+
import me.chanjar.weixin.channel.config.WxChannelConfig;
7+
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
8+
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
9+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
10+
import org.springframework.context.annotation.Bean;
11+
import org.springframework.context.annotation.Configuration;
12+
13+
/**
14+
* @author <a href="https://github.com/lixize">Zeyes</a>
15+
*/
16+
@Configuration
17+
@ConditionalOnProperty(prefix = WxChannelProperties.PREFIX + ".config-storage", name = "type",
18+
matchIfMissing = true, havingValue = "memory")
19+
@RequiredArgsConstructor
20+
public class WxChannelInMemoryConfigStorageConfiguration extends AbstractWxChannelConfigStorageConfiguration {
21+
private final WxChannelProperties properties;
22+
23+
@Bean
24+
@ConditionalOnMissingBean(WxChannelProperties.class)
25+
public WxChannelConfig wxChannelConfig() {
26+
WxChannelDefaultConfigImpl config = new WxChannelDefaultConfigImpl();
27+
return this.config(config, properties);
28+
}
29+
}

‎spring-boot-starters/wx-java-channel-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/channel/config/storage/WxChannelInRedisTemplateConfigStorageConfiguration.java

+40
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
package com.binarywang.spring.starter.wxjava.channel.config.storage;
2+
3+
import com.binarywang.spring.starter.wxjava.channel.properties.WxChannelProperties;
4+
import lombok.RequiredArgsConstructor;
5+
import me.chanjar.weixin.channel.config.WxChannelConfig;
6+
import me.chanjar.weixin.channel.config.impl.WxChannelRedisConfigImpl;
7+
import me.chanjar.weixin.common.redis.RedisTemplateWxRedisOps;
8+
import me.chanjar.weixin.common.redis.WxRedisOps;
9+
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
10+
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
11+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
12+
import org.springframework.context.ApplicationContext;
13+
import org.springframework.context.annotation.Bean;
14+
import org.springframework.context.annotation.Configuration;
15+
import org.springframework.data.redis.core.StringRedisTemplate;
16+
17+
/**
18+
* @author <a href="https://github.com/lixize">Zeyes</a>
19+
*/
20+
@Configuration
21+
@ConditionalOnProperty(prefix = WxChannelProperties.PREFIX + ".config-storage", name = "type", havingValue = "redistemplate")
22+
@ConditionalOnClass(StringRedisTemplate.class)
23+
@RequiredArgsConstructor
24+
public class WxChannelInRedisTemplateConfigStorageConfiguration extends AbstractWxChannelConfigStorageConfiguration {
25+
private final WxChannelProperties properties;
26+
private final ApplicationContext applicationContext;
27+
28+
@Bean
29+
@ConditionalOnMissingBean(WxChannelConfig.class)
30+
public WxChannelConfig wxChannelConfig() {
31+
WxChannelRedisConfigImpl config = getWxChannelInRedisTemplateConfig();
32+
return this.config(config, properties);
33+
}
34+
35+
private WxChannelRedisConfigImpl getWxChannelInRedisTemplateConfig() {
36+
StringRedisTemplate redisTemplate = applicationContext.getBean(StringRedisTemplate.class);
37+
WxRedisOps redisOps = new RedisTemplateWxRedisOps(redisTemplate);
38+
return new WxChannelRedisConfigImpl(redisOps, properties.getConfigStorage().getKeyPrefix());
39+
}
40+
}

0 commit comments

Comments
 (0)