• Springboot+mybatis-plus微信支付

    一、根据订单生成付款二维码

    1.导入依赖和配置文件的配置

    1.  
    2.         <dependency>
    3.             <groupId>com.github.wxpaygroupId>
    4.             <artifactId>wxpay-sdkartifactId>
    5.             <version>0.0.3version>
    6.         dependency>
    7.         
    8.         <dependency>
    9.             <groupId>org.apache.httpcomponentsgroupId>
    10.             <artifactId>httpclientartifactId>
    11.             <version>4.5.3version>
    12.         dependency>
    13.   
    14.         <dependency>
    15.             <groupId>com.baomidougroupId>
    16.             <artifactId>mybatis-plus-boot-starterartifactId>
    17.             <version>3.5.2version>
    18.         dependency>
    19.         <dependency>
    20.             <groupId>com.baomidougroupId>
    21.             <artifactId>mybatis-plus-generatorartifactId>
    22.             <version>3.5.2version>
    23.         dependency>

     配置文件:

    1. server.port=9000
    2. #数据库连接的信息
    3. spring.datasource.password=
    4. spring.datasource.username=
    5. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    6. spring.datasource.url=jdbc:mysql://localhost:3306/weixin?serverTimezone=Asia/Shanghai
    7.  
    8. # 微信的appid 商家id 密钥---申请你无法申请因为需要营业执照--
    9. weixin.appid=
    10. weixin.mch_id=
    11. weixin.api_key=

     2.导入发送网络请求配置类

    1. package com.gsh.system.utils;
    2.  
    3. import org.apache.http.Consts;
    4. import org.apache.http.HttpEntity;
    5. import org.apache.http.NameValuePair;
    6. import org.apache.http.client.ClientProtocolException;
    7. import org.apache.http.client.entity.UrlEncodedFormEntity;
    8. import org.apache.http.client.methods.*;
    9. import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
    10. import org.apache.http.conn.ssl.SSLContextBuilder;
    11. import org.apache.http.conn.ssl.TrustStrategy;
    12. import org.apache.http.entity.StringEntity;
    13. import org.apache.http.impl.client.CloseableHttpClient;
    14. import org.apache.http.impl.client.HttpClients;
    15. import org.apache.http.message.BasicNameValuePair;
    16. import org.apache.http.util.EntityUtils;
    17.  
    18. import javax.net.ssl.SSLContext;
    19. import java.io.IOException;
    20. import java.security.cert.CertificateException;
    21. import java.security.cert.X509Certificate;
    22. import java.text.ParseException;
    23. import java.util.HashMap;
    24. import java.util.LinkedList;
    25. import java.util.List;
    26. import java.util.Map;
    27.  
    28. /**
    29.  * http请求客户端
    30.  * 
    31.  * @author 必须引入httpclient的依赖：在java端模拟浏览器的效果。
    32.  * 
    33.  */
    34. public class HttpClient {
    35.    private String url;
    36.    private Map param;
    37.    private int statusCode;
    38.    private String content;
    39.    private String xmlParam;
    40.    private boolean isHttps;
    41.    public boolean isHttps() {
    42.       return isHttps;
    43.    }
    44.    public void setHttps(boolean isHttps) {
    45.       this.isHttps = isHttps;
    46.    }
    47.    public String getXmlParam() {
    48.       return xmlParam;
    49.    }
    50.    public void setXmlParam(String xmlParam) {
    51.       this.xmlParam = xmlParam;
    52.    }
    53.    public HttpClient(String url, Map param) {
    54.       this.url = url;
    55.       this.param = param;
    56.    }
    57.    public HttpClient(String url) {
    58.       this.url = url;
    59.    }
    60.    public void setParameter(Map map) {
    61.       param = map;
    62.    }
    63.    public void addParameter(String key, String value) {
    64.       if (param == null)
    65.          param = new HashMap();
    66.       param.put(key, value);
    67.    }
    68.    public void post() throws ClientProtocolException, IOException {
    69.       HttpPost http = new HttpPost(url);
    70.       setEntity(http);
    71.       execute(http);
    72.    }
    73.    public void put() throws ClientProtocolException, IOException {
    74.       HttpPut http = new HttpPut(url);
    75.       setEntity(http);
    76.       execute(http);
    77.    }
    78.    public void get() throws ClientProtocolException, IOException {
    79.       if (param != null) {
    80.          StringBuilder url = new StringBuilder(this.url);
    81.          boolean isFirst = true;
    82.          for (String key : param.keySet()) {
    83.             if (isFirst)
    84.                url.append("?");
    85.             else
    86.                url.append("&");
    87.             url.append(key).append("=").append(param.get(key));
    88.          }
    89.          this.url = url.toString();
    90.       }
    91.       HttpGet http = new HttpGet(url);
    92.       execute(http);
    93.    }
    94.    /**
    95.     * set http post,put param
    96.     */
    97.    private void setEntity(HttpEntityEnclosingRequestBase http) {
    98.       if (param != null) {
    99.          List nvps = new LinkedList();
    100.          for (String key : param.keySet())
    101.             nvps.add(new BasicNameValuePair(key, param.get(key))); // 参数
    102.          http.setEntity(new UrlEncodedFormEntity(nvps, Consts.UTF_8)); // 设置参数
    103.       }
    104.       if (xmlParam != null) {
    105.          http.setEntity(new StringEntity(xmlParam, Consts.UTF_8));
    106.       }
    107.    }
    108.    private void execute(HttpUriRequest http) throws ClientProtocolException,
    109.          IOException {
    110.       CloseableHttpClient httpClient = null;
    111.       try {
    112.          if (isHttps) {
    113.             SSLContext sslContext = new SSLContextBuilder()
    114.                   .loadTrustMaterial(null, new TrustStrategy() {
    115.                      // 信任所有
    116.                      public boolean isTrusted(X509Certificate[] chain,
    117.                            String authType)
    118.                            throws CertificateException {
    119.                         return true;
    120.                      }
    121.                   }).build();
    122.             SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
    123.                   sslContext);
    124.             httpClient = HttpClients.custom().setSSLSocketFactory(sslsf)
    125.                   .build();
    126.          } else {
    127.             httpClient = HttpClients.createDefault();
    128.          }
    129.          CloseableHttpResponse response = httpClient.execute(http);
    130.          try {
    131.             if (response != null) {
    132.                if (response.getStatusLine() != null)
    133.                   statusCode = response.getStatusLine().getStatusCode();
    134.                HttpEntity entity = response.getEntity();
    135.                // 响应内容
    136.                content = EntityUtils.toString(entity, Consts.UTF_8);
    137.             }
    138.          } finally {
    139.             response.close();
    140.          }
    141.       } catch (Exception e) {
    142.          e.printStackTrace();
    143.       } finally {
    144.          httpClient.close();
    145.       }
    146.    }
    147.    public int getStatusCode() {
    148.       return statusCode;
    149.    }
    150.    public String getContent() throws ParseException, IOException {
    151.       return content;
    152.    }
    153. }

    3.controller 层

    1.  @PostMapping("/createNative/{orderNo}")
    2.     public CommonResult createNative(@PathVariable String orderNo){
    3.         return  orderService.createNative(orderNo);
    4.     }

    4.Service层业务代码

    获取配置文件的信息

    1. //获取配置文件里的appid
    2.     @Value("${weixin.appid}")
    3.     private String appId;
    4.     //获取配置文件里的mch_id
    5.     @Value("${weixin.mch_id}")
    6.     private String mchId;
    7.     //获取配置文件里的apiKey
    8.     @Value("${weixin.api_key}")
    9.     private String apiKey;

     

    1.  
    2. public CommonResult createNative(String orderNo) {
    3.         QueryWrapperwrapper=new QueryWrapper<>();
    4.         wrapper.eq("order_no",orderNo);
    5.         wrapper.eq("status",0);
    6.         Order order = orderMapper.selectOne(wrapper);
    7.         System.out.println(order);
    8.         if(order!=null){
    9.             try{
    10.                 //设置请求参数----需要的格式为.xml格式
    11.                 //我们使用map存放再转为xml
    12.                 Map params=new HashMap<>();//请求参数
    13.                 params.put("appid",appId);
    14.                 params.put("mch_id",mchId);
    15.                 params.put("nonce_str", WXPayUtil.generateNonceStr());
    16.                 params.put("body",order.getCourseTitle());
    17.                 params.put("out_trade_no",orderNo);
    18.                 BigDecimal totalFee = order.getTotalFee();
    19.                 //double会丢失精度所以我们选择BigDecimal
    20.                 //params.put("total_fee",totalFee.multiply(new BigDecimal(100)).longValue()+"");
    21.                 //0.01将来要缓存真实的金额
    22.                 params.put("total_fee",new BigDecimal(0.01).multiply(new BigDecimal(100)).longValue()+"");
    23.                 params.put("spbill_create_ip","127.0.0.1");//未来写成项目部署的ip
    24.                 params.put("notify_url","http://localhost:9000/pay/back");
    25.                 params.put("trade_type","NATIVE");
    26.                 //创建HttpClient对象   远程调用
    27.                 HttpClient client=new HttpClient("https://api.mch.weixin.qq.com/pay/unifiedorder");
    28.                 //支持https协议
    29.                 client.setHttps(true);
    30.                 client.setXmlParam(WXPayUtil.generateSignedXml(params,apiKey));
    31.                 //设置请求方式
    32.                 client.post();
    33.                 String content = client.getContent();
    34.                 System.out.println(content);
    35.                //将返回结果的xml转换为Map
    36.                 Map map = WXPayUtil.xmlToMap(content);
    37.                 if(map.get("result_code").equals("SUCCESS")){
    38.                     Map result=new HashMap<>();
    39.                     result.put("codeUrl",map.get("code_url"));//获取生成二维码地址
    40.                     result.put("price",totalFee);//获取商品价格
    41.                     result.put("orderNo",orderNo);//获取订单编号
    42.                     return new CommonResult(2000,"生成二维码",result);
    43.                 }
    44.             }catch (Exception e){
    45.                 e.printStackTrace();
    46.             }
    47.  
    48.         }
    49.         return new CommonResult(5000,"订单失效",null);
    50.     }

    5.前端二维码的展示

    1.  <el-button type="primary" @click="pay">支付el-button>
    2.     <el-dialog
    3.             title="收银台"
    4.             :visible.sync="dialogVisible"
    5.             width="30%">
    6.       <div style="text-align: center">
    7.         <p>微信支付{{payResult.price}}元p>
    8.         <div style="border: 1px solid #f3f3f3;width: 220px;padding: 10px;margin: 0px auto">
    9.           <vue-qr
    10.                   :text="payResult.codeUrl"
    11.                   :margin="0"
    12.                   colorDark="green"
    13.                   :logoSrc="require('@/assets/logo.png')"
    14.                   colorLight="#fff"
    15.                   :size="200">
    16.  
    17.           vue-qr>
    18.         div>
    19.       div>
    20.       <el-divider>el-divider>
    21.       <div style="font-size: 13px">
    22.         提示:<br>
    23.         支付成功前请勿手动关闭页面<br>
    24.         二维码两小时有效，请及时扫码支付<br>
    25.       div>
    26.     el-dialog>

    6.data数据的存放

    1. data(){
    2.       return{
    3.             orderNo:"e334ce2a6b1d4bc6949",
    4.             dialogVisible:false,
    5.             payResult:{
    6.               price:0,
    7.               codeUrl:"",
    8.               orderNo:"",
    9.             },
    10.         timer1:""
    11.       }
    12.     },

    7.前端发送的请求方法

    1. pay(){
    2.         this.dialogVisible=true;
    3.         this.$http.post("/order/createNative/"+this.orderNo).then(result=>{
    4.           if (result.data.code===2000) {
    5.             this.payResult = result.data.data
    6.             //设置一个定时任务，每隔3秒调用一次
    7.             this.timer1=setInterval(()=>{
    8.               this.queryPayStatus(this.payResult.orderNo)
    9.             },3000)
    10.           }
    11.         })
    12.  
    13.       },

    二、前端调用订单状态查询的方法

    1. //根据订单号查询支付状态
    2.       queryPayStatus(orderNo){
    3.         this.$http.post("/order/queryPayStatus/"+this.orderNo).then(result=>{
    4.           console.log(result.data.code)
    5.           if(result.data.code===2000){
    6.             console.log("****************************")
    7.             //消除定时器
    8.             clearInterval(this.timer1)
    9.             this.timer1=null;
    10.             this.$message.success("支付成功!")
    11.             this.dialogVisible=false;
    12.           }
    13.         })
    14.       },

    三、后台查询订单状态

    1.controller层

    1. @PostMapping("/queryPayStatus/{orderNo}")
    2.     public CommonResult queryPayStatus(@PathVariable String orderNo){
    3.         return  orderService.queryPayStatus(orderNo);
    4.     }

    2.Service业务层

    1.     public CommonResult queryPayStatus(String orderNo) {
    2.  
    3.         try {
    4.             HttpClient client = new HttpClient("https://api.mch.weixin.qq.com/pay/orderquery");
    5.             Map params=new HashMap<>();
    6.             params.put("appid",appId);
    7.             params.put("mch_id",mchId);
    8.             params.put("out_trade_no",orderNo);
    9.             params.put("nonce_str",WXPayUtil.generateNonceStr());
    10.  
    11.             client.setHttps(true);
    12.  
    13.             //根据订单状态查询微信的支付情况
    14.             client.setXmlParam(WXPayUtil.generateSignedXml(params,apiKey));
    15.             client.post();
    16.             String content = client.getContent();
    17.             System.out.println(content);
    18.             //将返回的xml内容转为map内容
    19.             Map map = WXPayUtil.xmlToMap(content);
    20.             //修改订单状态
    21.             if(map.get("trade_state").equals("SUCCESS")) {
    22.                 Order order = new Order();
    23.                 order.setStatus(1);
    24.                 order.setGmtModified(LocalDateTime.now());
    25.                 QueryWrapper wrapper=new QueryWrapper<>();
    26.                 wrapper.eq("order_no",orderNo);
    27.                 wrapper.eq("status",0);
    28.                 orderMapper.update(order,wrapper);
    29.                 return new CommonResult(2000,"支付成功!",null);
    30.             }
    31.         } catch (Exception e) {
    32.  
    33.         }
    34.         return new CommonResult(5000,"支付失败！",null);
    35.     }

  • 相关阅读:
    HTTP超时时间设置
    【SLAM】 前端-视觉里程计之相对位姿估计
    网络I/O_04 IO模型
    【报错解决】java:错误：无效的源发行版：15
    第十三天到达终点数字
    “蔚来杯“2022牛客暑期多校训练营6 ABM题解
    多目标进化算法详细讲解及代码实现（样例：MOEA/D、NSGA-Ⅱ求解多目标（柔性）作业车间调度问题）
    电影大师杂记
    《神经网络与深度学习》算法伪代码汇总
    VBA根据Excel内容快速创建PPT
  • 原文地址：https://blog.csdn.net/Have_MonkeyG/article/details/126372648