将微信配置信息存到数据库并进行调用

1. package com.dataxai.web.core.config;
3. import com.alibaba.fastjson2.JSON;
4. import com.dataxai.web.domain.Wxpay;
5. import com.dataxai.web.mapper.WxpayMapper;
6. import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder;
7. import com.wechat.pay.contrib.apache.httpclient.auth.*;
8. import com.wechat.pay.contrib.apache.httpclient.util.PemUtil;
9. import lombok.Data;
10. import lombok.extern.slf4j.Slf4j;
11. import org.apache.http.impl.client.CloseableHttpClient;
12. import org.springframework.beans.factory.annotation.Autowired;
13. import org.springframework.boot.context.properties.ConfigurationProperties;
14. import org.springframework.context.annotation.Bean;
15. import org.springframework.context.annotation.Configuration;
16. import org.springframework.context.annotation.PropertySource;
17. import org.springframework.core.io.ClassPathResource;
18. import javax.annotation.PostConstruct;
19. import java.io.*;
20. import java.nio.charset.StandardCharsets;
21. import java.security.PrivateKey;
24. @Configuration
25. @Data //使用set方法将wxpay节点中的值填充到当前类的属性中
26. @Slf4j
27. public class WxPayConfig {
29.     // 商户号
30.     private String mchId;
32.     // 商户API证书序列号
33.     private String mchSerialNo;
35.     // 商户私钥文件
36.     private String privateKeyPath;
38.     // APIv3密钥
39.     private String apiV3Key;
41.     // APPID
42.     private String appid;
44.     // 微信服务器地址
45.     private String domain;
47.     // 接收结果通知地址
48.     private String notifyDomain;
50.     // 接收结果通知地址
51.     private String notifyDomainProd;
53.     // APIv2密钥
54.     private String partnerKey;
56.     @Autowired
57.     private WxpayMapper configMapper;
59.     @PostConstruct
60.     public void init() {
61.         log.info("初始化微信支付配置...");
62.         //从数据库获得配置信息
63.         Wxpay dbConfig = configMapper.getOne(1l);
64.         if (dbConfig != null) {
65.             this.mchId = dbConfig.getMchId();
66.             this.mchSerialNo = dbConfig.getMchSerialNo();
67.             this.privateKeyPath = dbConfig.getPrivateKeyPath(); // 设置私钥路径
68.             this.apiV3Key = dbConfig.getApiV3Key();
69.             this.appid = dbConfig.getAppId();
70.             this.domain = dbConfig.getDomain();
71.             this.notifyDomain = dbConfig.getNotifyDomain();
72.             this.notifyDomainProd = dbConfig.getNotifyDomainProd();
73.             this.partnerKey = dbConfig.getPartnerKey();
75.             log.info("微信支付配置已成功初始化: {}", JSON.toJSONString(dbConfig));
76.         } else {
77.             throw new IllegalStateException("未找到微信支付配置");
78.         }
79.     }
82.     /**
83.      * 获取商户的私钥文件
84.      * @param filename
85.      * @return
86.      */
87.     private PrivateKey getPrivateKey(String filename) {
89.         System.out.println("filename = "+filename);
90.         filename = "/config/"+filename;
91.         ClassPathResource resource = new ClassPathResource(filename);
92.         InputStream inputStream = null;
93.         try {
94.             inputStream = resource.getInputStream();
95.             return PemUtil.loadPrivateKey(inputStream);
96.         } catch (IOException e) {
97.             throw new RuntimeException("私钥文件不存在",e);
98.         }
100.     }
102.     /**
103.      * 获取签名验证器
104.      * @return
105.      */
106.     @Bean
107.     public ScheduledUpdateCertificatesVerifier getVerifier(){
109.         log.info("获取签名验证器");
111.         //获取商户私钥
112.         PrivateKey privateKey = getPrivateKey(privateKeyPath);
114.         //私钥签名对象
115.         PrivateKeySigner privateKeySigner = new PrivateKeySigner(mchSerialNo, privateKey);
117.         //身份认证对象
118.         WechatPay2Credentials wechatPay2Credentials = new WechatPay2Credentials(mchId, privateKeySigner);
120.         // 使用定时更新的签名验证器，不需要传入证书
121.         ScheduledUpdateCertificatesVerifier verifier = new ScheduledUpdateCertificatesVerifier(
122.                 wechatPay2Credentials,
123.                 apiV3Key.getBytes(StandardCharsets.UTF_8));
125.         return verifier;
126.     }
129.     /**
130.      * 获取http请求对象
131.      * @param verifier
132.      * @return
133.      */
134.     @Bean(name = "wxPayClient")
135.     public CloseableHttpClient getWxPayClient(ScheduledUpdateCertificatesVerifier verifier){
137.         log.info("获取httpClient");
139.         //获取商户私钥
140.         PrivateKey privateKey = getPrivateKey(privateKeyPath);
142.         WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create()
143.                 .withMerchant(mchId, mchSerialNo, privateKey)
144.                 .withValidator(new WechatPay2Validator(verifier));
145.         // ... 接下来，你仍然可以通过builder设置各种参数，来配置你的HttpClient
147.         // 通过WechatPayHttpClientBuilder构造的HttpClient，会自动的处理签名和验签，并进行证书自动更新
148.         CloseableHttpClient httpClient = builder.build();
150.         return httpClient;
151.     }
153.     /**
154.      * 获取HttpClient，无需进行应答签名验证，跳过验签的流程
155.      */
156.     @Bean(name = "wxPayNoSignClient")
157.     public CloseableHttpClient getWxPayNoSignClient(){
159.         //获取商户私钥
160.         PrivateKey privateKey = getPrivateKey(privateKeyPath);
162.         //用于构造HttpClient
163.         WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create()
164.                 //设置商户信息
165.                 .withMerchant(mchId, mchSerialNo, privateKey)
166.                 //无需进行签名验证、通过withValidator((response) -> true)实现
167.                 .withValidator((response) -> true);
169.         // 通过WechatPayHttpClientBuilder构造的HttpClient，会自动的处理签名和验签，并进行证书自动更新
170.         CloseableHttpClient httpClient = builder.build();
172.         log.info("== getWxPayNoSignClient END ==");
174.         return httpClient;
175.     }
177. }

复制代码

mapper层和controller层省略

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。