• springboot集成 生成二维码微信支付

    目录

    1、添加依赖

     2、封装工具类

    2.1 HttpUtil

    2.2 WebServletUtil

    2.3 Swagger2Conf

    2.4 向微信发送请求并获取code_url

    3、控制层

    4、配置文件

    payconfig.properties

    5、测试

    5.1、访问doc.html

    5.2、获取二维码

    1、添加依赖

            
            org.springframework.boot
            spring-boot-starter-web
        
        
            com.fasterxml.jackson.core
            jackson-databind
            2.11.0
        
          
        
          com.fasterxml.jackson.datatype
          jackson-datatype-jsr310
          2.9.3
        
        
        
            org.projectlombok
            lombok
            true
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        
        
            org.springframework.boot
            spring-boot-configuration-processor
            true
        
        
        
        
             com.google.zxing
             core
             3.2.1
         
         
             com.google.zxing
             javase
             3.2.0
         
         
         
            com.github.wxpay
            wxpay-sdk
            0.0.3
        

         
        
            org.apache.httpcomponents
            httpclient
        

         
        
            com.github.xiaoymin
            swagger-bootstrap-ui
            1.9.6
        
        
            com.spring4all
            swagger-spring-boot-starter
            1.9.1.RELEASE

     2、封装工具类

    2.1 HttpUtil

    1. public class HttpUtil {
    2. 	 private String url;
    3.     private Map param;
    4.     private int statusCode;//状态码
    5.     private String content;//主体部分
    6.     private String xmlParam;//生成的xml
    7.     private boolean isHttps;
    8.  
    9.     public boolean isHttps() {
    10.         return isHttps;
    11.     }
    12.  
    13.     public void setHttps(boolean isHttps) {
    14.         this.isHttps = isHttps;
    15.     }
    16.  
    17.     public String getXmlParam() {
    18.         return xmlParam;
    19.     }
    20.  
    21.     public void setXmlParam(String xmlParam) {
    22.         this.xmlParam = xmlParam;
    23.     }
    24.  
    25.     public HttpUtil(String url, Map param) {
    26.         this.url = url;
    27.         this.param = param;
    28.     }
    29.  
    30.     public HttpUtil(String url) {
    31.         this.url = url;
    32.     }
    33.  
    34.     public void setParameter(Map map) {
    35.         param = map;
    36.     }
    37.  
    38.     public void addParameter(String key, String value) {
    39.         if (param == null)
    40.             param = new HashMap();
    41.         param.put(key, value);
    42.     }
    43.  
    44.     public void post() throws ClientProtocolException, IOException {
    45.         HttpPost http = new HttpPost(url);
    46.         setEntity(http);
    47.         execute(http);
    48.     }
    49.  
    50.     public void put() throws ClientProtocolException, IOException {
    51.         HttpPut http = new HttpPut(url);
    52.         setEntity(http);
    53.         execute(http);
    54.     }
    55.  
    56.     public void get() throws ClientProtocolException, IOException {
    57.         if (param != null) {
    58.             StringBuilder url = new StringBuilder(this.url);
    59.             boolean isFirst = true;
    60.             for (String key : param.keySet()) {
    61.                 if (isFirst)
    62.                     url.append("?");
    63.                 else
    64.                     url.append("&");
    65.                 url.append(key).append("=").append(param.get(key));
    66.             }
    67.             this.url = url.toString();
    68.         }
    69.         HttpGet http = new HttpGet(url);
    70.         execute(http);
    71.     }
    72.  
    73.     /**
    74.      * set http post,put param
    75.      */
    76.     private void setEntity(HttpEntityEnclosingRequestBase http) {
    77.         if (param != null) {
    78.             List nvps = new LinkedList();
    79.             for (String key : param.keySet())
    80.                 nvps.add(new BasicNameValuePair(key, param.get(key))); // 参数
    81.             http.setEntity(new UrlEncodedFormEntity(nvps, Consts.UTF_8)); // 设置参数
    82.         }
    83.         if (xmlParam != null) {
    84.             http.setEntity(new StringEntity(xmlParam, Consts.UTF_8));
    85.         }
    86.     }
    87.  
    88.     private void execute(HttpUriRequest http) throws ClientProtocolException,
    89.             IOException {
    90.         CloseableHttpClient httpClient = null;
    91.         try {
    92.             if (isHttps) {
    93.                 SSLContext sslContext = new SSLContextBuilder()
    94.                         .loadTrustMaterial(null, new TrustStrategy() {
    95.                             // 信任所有
    96.                             public boolean isTrusted(X509Certificate[] chain,
    97.                                                      String authType)
    98.                                     throws CertificateException {
    99.                                 return true;
    100.                             }
    101.                         }).build();
    102.                 SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
    103.                         sslContext);
    104.                 httpClient = HttpClients.custom().setSSLSocketFactory(sslsf)
    105.                         .build();
    106.             } else {
    107.                 httpClient = HttpClients.createDefault();
    108.             }
    109.             CloseableHttpResponse response = httpClient.execute(http);
    110.             try {
    111.                 if (response != null) {
    112.                     if (response.getStatusLine() != null)
    113.                         statusCode = response.getStatusLine().getStatusCode();
    114.                     HttpEntity entity = response.getEntity();
    115.                     // 响应内容
    116.                     content = EntityUtils.toString(entity, Consts.UTF_8);
    117.                 }
    118.             } finally {
    119.                 response.close();
    120.             }
    121.         } catch (Exception e) {
    122.             e.printStackTrace();
    123.         } finally {
    124.             httpClient.close();
    125.         }
    126.     }
    127.  
    128.     public int getStatusCode() {
    129.         return statusCode;
    130.     }
    131.  
    132.     public String getContent() throws ParseException, IOException {
    133.         return content;
    134.     }
    135. }

    2.2 WebServletUtil

    可以根据上下文获取Reques和Response对象

    1. public class WebServletUtil {
    2. 	private static ServletRequestAttributes servletRequestAttributes;
    3.  
    4. 	static {
    5. 		servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    6. 	}
    7.  
    8. 	public static HttpServletRequest getRequest(){
    9. 		return servletRequestAttributes.getRequest();
    10. 	}
    11.  
    12. 	public static HttpServletResponse getResponse(){
    13. 		return servletRequestAttributes.getResponse();
    14. 	}
    15. }

    2.3 Swagger2Conf

    为了更方便测试接口集成了swagger文档

    1. @Configuration
    2. @EnableSwagger2//开启swagger
    3. public class Swagger2Conf {
    4.  
    5.     @Bean
    6.     public Docket webApiConfig(){
    7.  
    8.         return new Docket(DocumentationType.SWAGGER_2)
    9.                 .groupName("webApi")
    10.                 .apiInfo(webApiInfo())
    11.                 .select()
    12.                 .apis(RequestHandlerSelectors.basePackage("com.gzh.weixinpay.controller"))
    13.                 //过滤掉所有error或error.*页面
    14.                 .paths(Predicates.not(PathSelectors.regex("/error.*")))
    15.                 .build();
    16.     }
    17.     private ApiInfo webApiInfo(){
    18.  
    19.         return new ApiInfoBuilder()
    20.                 .title("权限管理API文档")
    21.                 .description("本文档描述了权限管理接口定义")
    22.                 .version("1.0")
    23.                 .contact(new Contact("gzh", "http://taobao.com", "1984274233@qq.com"))
    24.                 .build();
    25.     }
    26. }

    2.4 向微信发送请求并获取code_url

    1. package com.gzh.weixinpay.conf;
    2.  
    3. import com.fasterxml.jackson.core.JsonProcessingException;
    4. import com.fasterxml.jackson.databind.ObjectMapper;
    5. import com.github.wxpay.sdk.WXPayUtil;
    6. import com.google.zxing.BarcodeFormat;
    7. import com.google.zxing.EncodeHintType;
    8. import com.google.zxing.MultiFormatWriter;
    9. import com.google.zxing.client.j2se.MatrixToImageWriter;
    10. import com.google.zxing.common.BitMatrix;
    11. import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
    12. import com.gzh.weixinpay.util.HttpUtil;
    13. import com.gzh.weixinpay.util.WebServletUtil;
    14. import lombok.Data;
    15. import org.springframework.beans.factory.annotation.Value;
    16. import org.springframework.boot.context.properties.ConfigurationProperties;
    17. import org.springframework.context.annotation.PropertySource;
    18. import org.springframework.stereotype.Component;
    19.  
    20. import java.io.OutputStream;
    21. import java.io.Serializable;
    22. import java.text.SimpleDateFormat;
    23. import java.util.Date;
    24. import java.util.HashMap;
    25. import java.util.Map;
    26.  
    27. /**
    28.  * TODO
    29.  *
    30.  * @author DELL
    31.  * @version 1.0
    32.  * @since 2022-08-12  21:00:56
    33.  */
    34. @Data
    35. @Component("config")
    36. @ConfigurationProperties(prefix = "weixin")//让配置参数能分离出来
    37. @PropertySource("classpath:payconfig.properties")
    38. public class WxConfig implements Serializable {
    39.  
    40. 	@Value("${APPID}")
    41. 	private String APPID;
    42.  
    43. 	@Value("${MCH_ID}")
    44. 	private String MCH_ID;
    45.  
    46. 	@Value("${KEY}")
    47. 	private String KEY;
    48.  
    49. 	@Value("${SPBILL_CREATE_IP}")
    50. 	private String SPBILL_CREATE_IP;
    51.  
    52. 	@Value("${NOTIFY_URL}")
    53. 	private String NOTIFY_URL;
    54.  
    55. 	@Value("${TRADE_TYPE}")
    56. 	private String TRADE_TYPE;
    57.  
    58. 	@Value("${PLACEANORDER_URL}")
    59. 	private String PAY_URL;
    60.  
    61. 	@Value("${QUERY_URL}")
    62. 	private String QRY_URL;
    63.  
    64.     /**
    65.      *
    66.      * @param out_trade_no 订单编号
    67.      * @param total_fee   总金额
    68.      * @param expireTimeMin  失效时间
    69.      * @return
    70.      */
    71.     public Map createNative(String out_trade_no, int total_fee , Integer expireTimeMin) throws JsonProcessingException {
    72.         Map param = new HashMap();
    73.         param.put("appid", APPID);
    74.         param.put("mch_id", MCH_ID);
    75.         param.put("nonce_str", WXPayUtil.generateNonceStr());
    76.         param.put("body", "测试支付功能"); //定义订单内容
    77.         param.put("out_trade_no", out_trade_no);  //商户订单编号
    78.         param.put("fee_type", "CNY");
    79.         param.put("total_fee", new ObjectMapper().writeValueAsString(total_fee));  //总金额
    80.         param.put("spbill_create_ip", SPBILL_CREATE_IP);
    81.         param.put("notify_url", NOTIFY_URL); //回调地址
    82.         param.put("trade_type", "NATIVE");
    83.         Date date = new Date();
    84.         long time = date.getTime();
    85.         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
    86.         String timeStart = simpleDateFormat.format(time);
    87.         String timeEnd = simpleDateFormat.format(time + expireTimeMin * 60000);
    88.         param.put("time_start", timeStart); //订单创建时间
    89.         param.put("time_expire", timeEnd); //定义失效时间
    90.         try {
    91.  
    92.  
    93.             String xmlParam = WXPayUtil.generateSignedXml(param, KEY); //参数转换
    94.             HttpUtil client = new HttpUtil(PAY_URL);
    95.             client.setHttps(true);
    96.             client.setXmlParam(xmlParam);
    97.             client.post();
    98.             String result = client.getContent();
    99.             Map resultMap = WXPayUtil.xmlToMap(result);
    100.  
    101.             if (resultMap.get("err_code") != null && resultMap.get("err_code").equals("ORDERPAID")) {
    102.                 System.out.println("<--"+out_trade_no+"--> :订单已经支付!");
    103.  
    104.             }
    105.  
    106.             Map map = new HashMap<>();
    107.             String code_url = resultMap.get("code_url");
    108.  
    109.             map.put("code_url", code_url);
    110.             map.put("total_fee", String.valueOf(total_fee));
    111.             map.put("out_trade_no", out_trade_no);
    112.  
    113.             return map;
    114.         } catch (Exception e) {
    115.             e.printStackTrace();
    116.             return null;
    117.         }
    118.     }
    119.  
    120.     /**
    121.      * @param out_trade_no  订单id
    122.      * @return
    123.      */
    124.     public Map queryPayStatus(String out_trade_no) {
    125.  
    126.         Map param = new HashMap();
    127.         param.put("appid", APPID);
    128.         param.put("mch_id", MCH_ID);
    129.         param.put("out_trade_no", out_trade_no);
    130.         param.put("nonce_str", WXPayUtil.generateNonceStr());
    131.         try {
    132.             String xmlParam = WXPayUtil.generateSignedXml(param, KEY);
    133.             HttpUtil client = new HttpUtil(QRY_URL);
    134.             client.setHttps(true);
    135.             client.setXmlParam(xmlParam);
    136.             client.post();
    137.             String result = client.getContent();
    138.             Map map = WXPayUtil.xmlToMap(result);
    139.  
    140.             if (map.get("err_code") != null && map.get("err_code").equals("ORDERNOTEXIST")) {
    141.                 System.out.println("订单不存在!");
    142.             }
    143.             if (map.get("trade_state").equals("SUCCESS")) {
    144.                 //支付成功，未支付为：NOTPAY
    145.             }
    146.  
    147.             return map;
    148.         } catch (Exception e) {
    149.             e.printStackTrace();
    150.             return null;
    151.         }
    152.     }
    153. }

    3、控制层

    1. @RestController
    2. @CrossOrigin
    3. @RequestMapping("/order")
    4. public class PayController {
    5.  
    6. 	@Resource
    7. 	WxConfig config;
    8.  
    9. 	@PostMapping("/createPay")
    10.     public BusiResult createPayOrder(@RequestBody PayVo payVo) throws JsonProcessingException {
    11.         //向微信发起调用生成预付链接
    12.         Map res = config.createNative(payVo.getOrderId(),
    13.                                             payVo.getFee(),
    14.                                             payVo.getExpirTime());
    15.         System.out.println(res);
    16.         return BusiResult.success(res);
    17.     }
    18.     //生成二维码图片
    19.     @GetMapping("getImg")
    20. 	public void getImg(String code_url){
    21. 		if(code_url == null) throw new NullPointerException();
    22.  
    23. 		 try {
    24.                 //生成二维码配置
    25.                 Map hints = new HashMap<>();
    26.                 // 设置纠错等级
    27.                 hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.L);
    28.                 // 编码类型
    29.                 hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
    30.  
    31.                 BitMatrix bitMatrix = new MultiFormatWriter().encode(code_url, BarcodeFormat.QR_CODE, 400, 400, hints);
    32.                 OutputStream outputStream =  WebServletUtil.getResponse().getOutputStream();
    33.  
    34.                 MatrixToImageWriter.writeToStream(bitMatrix, "png", outputStream);
    35.  
    36.             } catch (Exception e){
    37.                 e.printStackTrace();
    38.             }
    39. 	}
    40.  
    41.     @PostMapping("/queryPayStatus")
    42.     public BusiResult queryPayStatus(@RequestBody PayVo payVo){
    43.         //向微信发起调用生成预付链接
    44.         Map res = config.queryPayStatus(payVo.getOrderId());
    45.         System.out.println(res);
    46.         return BusiResult.success(res);
    47.     }
    48. }

    4、配置文件

    payconfig.properties

    #公众号appleId
APPID=?
#商户号
MCH_ID=?
#商户密钥
KEY=?
#APP和网页支付提交用户端ip, Native支付填调用微信支付API的机器IP, 即：服务器ip地址
SPBILL_CREATE_IP=127.0.0.1
#接收微信支付异步通知回调地址，通知url必须为直接可访问的url，不能携带参数。（需要配置）
NOTIFY_URL=http://225m5x.natappfree.cc/page/notify
#支付方式，取值如下：JSAPI，NATIVE，APP
TRADE_TYPE=NATIVE
# 微信支付 - 统一下单地址
PLACEANORDER_URL=https://api.mch.weixin.qq.com/pay/unifiedorder

QUERY_URL=https://api.mch.weixin.qq.com/pay/orderquery

    5、测试

    5.1、访问doc.html

    5.2、获取二维码

     

  • 相关阅读:
    小程序环境切换自定义组件
    mogodb简单整理
    win11该文件没有与之关联的应用怎么办
    JAXB实现xml到bean录入数据库
    Python潮流周刊#10：Twitter 的强敌 Threads 是用 Python 开发的
    知识直播：时代乐见搜狐的长期主义选择
    49. 字母异位词分组
    C++ STL标准模板库(一)
    即时通讯开发Netty实现心跳机制、断线重连机制
    根据您的数据量定制的ChatGPT，改变客户服务的方式
  • 原文地址：https://blog.csdn.net/qq_41720578/article/details/126319804