微信支付
微信支付的两种模式
1:由微信生成二维码,客户扫描二维码后,确认支付,微信回调给当前系统.
2:由系统调用统一下单API,取得预支付交易信息后,根据信息生成二维码,然后后台循环查询订单API接口查询付款状态(统一下单API,查询订单API)
区别:模式一是跳到微信让微信给我们生成二维码
模式二是可控制高,比较自主.
一:二维码
1.1:二维码优势
♦ 信息量大,可以容纳1850个大写字母或者2710个数字或500多个汉字
♦ 应用范围广,支持文字,声音(存放地址,地址里播放声音其实还是地址),图片,指纹等等
♦ 容错能力强,即是图片出现部分的破损也能使用
♦ 成本低,容易制作
二:微信支付
2.1:一共12个API
实现思路:
微信接口只接收xml字符串需要sas解析或者dom4j解析.将map转成xml通过httpClient远程提交参数接收返回结果
微信接口提供了一些工具类把map转换成xml
统一下单接口最终就是通过它生成一串支付地址,然后把支付地址展示给前端页面,让用户支付.最终订单有没有完成,需要调用查询订单接口,查看完成状态.
微信支付发送的是post请求,请求是xml格式的
代码实现
一:需要创建支付服务模块(pyg_pay_interface和pyg_pay_service)
**A😗*pyg_pay_service
1:pom.xml文件导入坐标
//打包方式为war包为web项目 <packaging>war</packaging> <dependencies> //导入工具类依赖 <dependency> <groupId>com.pinyougou</groupId> <artifactId>pyg_common</artifactId> <version>1.0-SNAPSHOT</version> </dependency> //依赖dao层操作数据库 <dependency> <groupId>com.pinyougou</groupId> <artifactId>pyg_dao</artifactId> <version>1.0-SNAPSHOT</version> </dependency> //依赖于pyg_pay_interface接口 <dependency> <groupId>com.pinyougou</groupId> <artifactId>pyg_pay_interface</artifactId> <version>1.0-SNAPSHOT</version> </dependency> //微信的坐标,可以使用它的工具类生成uuid <dependency> <groupId>com.github.wxpay</groupId> <artifactId>wxpay-sdk</artifactId> <version>0.0.3</version> </dependency> //指定一台服务器 <build> <plugins> <plugin> <groupId>org.apache.tomcat.maven</groupId> <artifactId>tomcat7-maven-plugin</artifactId> <version>2.2</version> <configuration> <!-- 指定端口 --> <port>9000</port> <!-- 请求路径 --> <path>/</path> </configuration> </plugin> </plugins> </build> </dependencies>
2:web.xml文件
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5"> <!-- 加载spring容器 --> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath*:spring/applicationContext*.xml</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> </web-app>
3.1:applicationContext-service.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <!-- 访问dubbo要占用的当前主机端口，默认端口不写是20880 --> <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol> <!-- 配置dubbo服务的名称 --> <dubbo:application name="pinyougou-pay-service"/> <!-- 配置dubbo注册地址--> <dubbo:registry address="zookeeper://192.168.25.134:2181"/> <!--配置dubbo服务注解扫描的包 --> <dubbo:annotation package="com.pinyougou.pay.service.impl" /> </beans>
3.2:applicationContext-tx.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <!-- 事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 开启事务控制的注解支持 --> <tx:annotation-driven transaction-manager="transactionManager"/> </beans>
4.在pyg_common导入配置文件
支付相关的信息
appid=wx8397f8696b538317 //商户ID partner=1473426802 //商户号 partnerkey=T6m9iK73b0kn9g5v426MKfHQH7X8rKwb //商户的key值 notifyurl=http://a31ef7db.ngrok.io/WeChatPay/WeChatPayNotify //回调地址,我们的二维码使我们自己生成的所以不需要回调
导入HttpClientUtils.java工具类
package util; /** * http请求客户端 * * @author Administrator * */ public class HttpClientUtil { public static HttpClientContext context = null; static { System.out.println("====================begin"); context = HttpClientContext.create(); } private String url; private Map<String, String> param; private int statusCode; private String content; private String xmlParam; private boolean isHttps; public boolean isHttps() { return isHttps; } public void setHttps(boolean isHttps) { this.isHttps = isHttps; } public String getXmlParam() { return xmlParam; } public void setXmlParam(String xmlParam) { this.xmlParam = xmlParam; } public HttpClientUtil(String url, Map<String, String> param) { this.url = url; this.param = param; } public HttpClientUtil(String url) { this.url = url; } public void setParameter(Map<String, String> map) { param = map; } public void addParameter(String key, String value) { if (param == null) param = new HashMap<String, String>(); param.put(key, value); } public void post() throws ClientProtocolException, IOException { HttpPost http = new HttpPost(url); setEntity(http); execute(http); } public void put() throws ClientProtocolException, IOException { HttpPut http = new HttpPut(url); setEntity(http); execute(http); } public void get() throws ClientProtocolException, IOException { if (param != null) { StringBuilder url = new StringBuilder(this.url); boolean isFirst = true; for (String key : param.keySet()) { if (isFirst) url.append("?"); else url.append("&"); url.append(key).append("=").append(param.get(key)); } this.url = url.toString(); } HttpGet http = new HttpGet(url); execute(http); } /** * set http post,put param */ private void setEntity(HttpEntityEnclosingRequestBase http) { if (param != null) { List<NameValuePair> nvps = new LinkedList<NameValuePair>(); for (String key : param.keySet()) nvps.add(new BasicNameValuePair(key, param.get(key))); // 参数 http.setEntity(new UrlEncodedFormEntity(nvps, Consts.UTF_8)); // 设置参数 } if (xmlParam != null) { http.setEntity(new StringEntity(xmlParam, Consts.UTF_8)); } } private void execute(HttpUriRequest http) throws ClientProtocolException, IOException { CloseableHttpClient httpClient = null; try { if (isHttps) { SSLContext sslContext = new SSLContextBuilder() .loadTrustMaterial(null, new TrustStrategy() { // 信任所有 public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException { return true; } }).build(); SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory( sslContext); httpClient = HttpClients.custom().setSSLSocketFactory(sslsf) .build(); } else { httpClient = HttpClients.createDefault(); } CloseableHttpResponse response = httpClient.execute(http,context); try { if (response != null) { if (response.getStatusLine() != null) statusCode = response.getStatusLine().getStatusCode(); HttpEntity entity = response.getEntity(); // 响应内容 content = EntityUtils.toString(entity, Consts.UTF_8); } } finally { response.close(); } } catch (Exception e) { e.printStackTrace(); } finally { httpClient.close(); } } public int getStatusCode() { return statusCode; } public String getContent() throws ParseException, IOException { return content; } }
导入生成支付二维码的页面
<!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <meta http-equiv="X-UA-Compatible" content="IE=9; IE=8; IE=7; IE=EDGE"> <meta http-equiv="X-UA-Compatible" content="IE=EmulateIE7" /> <title>微信支付页</title> <link rel="icon" href="/assets/img/favicon.ico"> <script type="text/javascript" src="plugins/angularjs/angular.min.js"> </script> <script type="text/javascript" src="js/base.js"> </script> <script type="text/javascript" src="js/service/payService.js"> </script> <script type="text/javascript" src="js/controller/payController.js"> </script> <script type="text/javascript" src="plugins/qrious.min.js"></script> <link rel="stylesheet" type="text/css" href="css/webbase.css" /> <link rel="stylesheet" type="text/css" href="css/pages-weixinpay.css" /> </head> <body ng-app="pinyougou" ng-controller="payController" ng-init="createNative()"> <!--head--> <div class="top"> <div class="py-container"> <div class="shortcut"> <ul class="fl"> <li class="f-item">品优购欢迎您！</li> <li class="f-item">请登录 <span><a href="#">免费注册</a></span></li> </ul> <ul class="fr"> <li class="f-item">我的订单</li> <li class="f-item space"></li> <li class="f-item">我的品优购</li> <li class="f-item space"></li> <li class="f-item">品优购会员</li> <li class="f-item space"></li> <li class="f-item">企业采购</li> <li class="f-item space"></li> <li class="f-item">关注品优购</li> <li class="f-item space"></li> <li class="f-item">客户服务</li> <li class="f-item space"></li> <li class="f-item">网站导航</li> </ul> </div> </div> </div> <div class="cart py-container"> <!--logoArea--> <div class="logoArea"> <div class="fl logo"><span class="title">收银台</span></div> </div> <!--主内容--> <div class="checkout py-container pay"> <div class="checkout-tit"> <h4 class="fl tit-txt"><span class="success-icon"></span><span class="success-info">订单提交成功，请您及时付款！订单号：{{payNo}}</span></h4> <span class="fr"><em class="sui-lead">应付金额：</em><em class="orange money">￥{{payMoney}}</em>元</span> <div class="clearfix"></div> </div> <div class="checkout-steps"> <div class="fl weixin">微信支付</div> <div class="fl sao"> <p class="red">二维码已过期，刷新页面重新获取二维码。</p> <div class="fl code"> <img id="qrious" alt=""> <div class="saosao"> <p>请使用微信扫一扫</p> <p>扫描二维码支付</p> </div> </div> <div class="fl phone"> </div> </div> <div class="clearfix"></div> <p><a href="pay.html" target="_blank">> 其他支付方式</a></p> </div> </div> </div> <!-- 底部栏位 --> <!--页面底部--> <div class="clearfix footer"> <div class="py-container"> <div class="footlink"> <div class="Mod-service"> <ul class="Mod-Service-list"> <li class="grid-service-item intro intro1"> <i class="serivce-item fl"></i> <div class="service-text"> <h4>正品保障</h4> <p>正品保障，提供发票</p> </div> </li> <li class="grid-service-item intro intro2"> <i class="serivce-item fl"></i> <div class="service-text"> <h4>正品保障</h4> <p>正品保障，提供发票</p> </div> </li> <li class="grid-service-item intro intro3"> <i class="serivce-item fl"></i> <div class="service-text"> <h4>正品保障</h4> <p>正品保障，提供发票</p> </div> </li> <li class="grid-service-item intro intro4"> <i class="serivce-item fl"></i> <div class="service-text"> <h4>正品保障</h4> <p>正品保障，提供发票</p> </div> </li> <li class="grid-service-item intro intro5"> <i class="serivce-item fl"></i> <div class="service-text"> <h4>正品保障</h4> <p>正品保障，提供发票</p> </div> </li> </ul> </div> <div class="clearfix Mod-list"> <div class="yui3-g"> <div class="yui3-u-1-6"> <h4>购物指南</h4> <ul class="unstyled"> <li>购物流程</li> <li>会员介绍</li> <li>生活旅行/团购</li> <li>常见问题</li> <li>购物指南</li> </ul> </div> <div class="yui3-u-1-6"> <h4>配送方式</h4> <ul class="unstyled"> <li>上门自提</li> <li>211限时达</li> <li>配送服务查询</li> <li>配送费收取标准</li> <li>海外配送</li> </ul> </div> <div class="yui3-u-1-6"> <h4>支付方式</h4> <ul class="unstyled"> <li>货到付款</li> <li>在线支付</li> <li>分期付款</li> <li>邮局汇款</li> <li>公司转账</li> </ul> </div> <div class="yui3-u-1-6"> <h4>售后服务</h4> <ul class="unstyled"> <li>售后政策</li> <li>价格保护</li> <li>退款说明</li> <li>返修/退换货</li> <li>取消订单</li> </ul> </div> <div class="yui3-u-1-6"> <h4>特色服务</h4> <ul class="unstyled"> <li>夺宝岛</li> <li>DIY装机</li> <li>延保服务</li> <li>品优购E卡</li> <li>品优购通信</li> </ul> </div> <div class="yui3-u-1-6"> <h4>帮助中心</h4> <img src="img/wx_cz.jpg"> </div> </div> </div> <div class="Mod-copyright"> <ul class="helpLink"> <li>关于我们<span class="space"></span></li> <li>联系我们<span class="space"></span></li> <li>关于我们<span class="space"></span></li> <li>商家入驻<span class="space"></span></li> <li>营销中心<span class="space"></span></li> <li>友情链接<span class="space"></span></li> <li>关于我们<span class="space"></span></li> <li>营销中心<span class="space"></span></li> <li>友情链接<span class="space"></span></li> <li>关于我们</li> </ul> <p>地址：北京市昌平区建材城西路金燕龙办公楼一层 邮编：100096 电话：400-618-4000 传真：010-82935100</p> <p>京ICP备08001421号京公网安备110108007702</p> </div> </div> </div> </div> <!--页面底部END--> <script type="text/javascript" src="js/plugins/jquery/jquery.min.js"></script> <script type="text/javascript" src="js/plugins/jquery.easing/jquery.easing.min.js"></script> <script type="text/javascript" src="js/plugins/sui/sui.min.js"></script> <script type="text/javascript" src="js/widget/nav.js"></script> <script type="text/javascript"> $(function(){ $("ul.payType li").click(function(){ $(this).css("border","2px solid #E4393C").siblings().css("border-color","#ddd"); }) }) </script> </body> </html>
5.根据Dubbo服务扫描的包创建包(com.pinyougou.pay.service.impl)
♦ 5.1:pyg_pay_interface模块下创建PayService.java接口
public interface PayService{ //请求完微信生成支付地址的方法(二维码) //参数1:商户订单号 参数二:总金额 public Map createNative(String out_trade_no,String total_fee); //请求微信查询支付状态 public Map queryPayStatus(String out_trade_no); //根据用户id获取支付单对象 public TbPayLog searchPayLogFromRedis(String userId); //根据支付单号,更新付款信息 public void updateOrderStatus(String out_trade_no,String transaction_id); }
♦ 5.2:pyg_pay_service模块com.pinyougou.pay.service.impl路径下创建PayServiceImpl.java实现类
@Service public class PayServiceImpl implement PayService{ //拿到配置文件的属性 @Value("${appid}") private String appid;//商户ID @Value("${partner}") private String partner;//商家号 @Value("${partnerkey}") private String partnerkey;//秘钥 @Value("${notifyurl}") private String notifyurl;//回调地址(必填,内容随便) @Autowride private RedisTemplate redisTemplate; @Autowride private TbPayLogMapper payLogMapper; @Autowride private TborderMapper orderMapper; @Override public Map createNative(String out_trade_no,String total_fee){ try{//请求微信的生成订单接口地址,获取支付的连接地址 HttpClientUtils util=new HttpClientUtils("https://api.mch.weixin.qq.com/pay/unifiedorder"); //请求内容数据的封装 Map map= new HashMap<>(); map.put("appid",appid); map.put("mch_id",partner); map.put("nonce_str",WXPayUtil.generateUUID());//随机32位字符串 map.put("body","品优购商品"); //描述信息 map.put("out_trade_no",out_trade_no);//商户订单号 double totalMoney=new Double(total_fee)*100; map.put("total_fee",(long)totalMoney+"") //商品总金额单位为分 map.put("spbill_create_ip","127.0.0.1"); //终端地址 map.put("notify_url",notifyurl); //通知地址 map.put("trade_type","NATIVE"); //交易类型 //通过微信的api将map转成xml格式的字符串 //生成带签名的xml String signedXml= WXPayUtil.generateSignedXml(map,partnerkey); Sytem.out.print("发送给微信"+signedXml) //设置请求参数setXmlParam();方法发送的是xml格式 util.setXmlParam(signedXml); //发送post请求,发送的是xml格式的 util.post(); String content=util.getContent(); Sytem.out.print("微信返回的"+content) //通过工具类将返回的String的xml内容转换成map Map responseMap=WXPayUtil.xmlToMap(content); Map resultMap=new HashMap<>(); resultMap.put("out_trade_no",out_trade_no); //支付单号 resultMap.put("total_fee",total_fee); //支付金额 resultMap.put("code_url",responseMap.get("code_url"));//支付地址 return resultMap; }catch(IOException e){ e.printStackTrace(); } return null; } } @Override public Map queryPayStatus(String out_trade_no){ try{ //1.请求微信的订单状态查询接口 HttpClient util new HttpClient("https://api.mch.weixin.qq.com/pay/orderquery"); //2.封装数据 Map requestMap= new HashMap<>(); requestMap.put("appid",appid); requestMap.put("mch_id",mch_id); requestMap.put("out_trade_no",out_trade_no); requestMap.put("nonce_str",WXPayUtil.generateUUID()); //3.转换带签名的数据 String signedXml=WXPayUtil.generateSignedXml(requestMap,partnerkey); //4.设置到xml格式到post请求中 util.setXmlParam(signedXml); //5.发送请求(xml) util.post(); //6.获取返回值 String content= util.getContent(); Map resultMap= WXPayUtil.xmlToMap(content); return resultMap; }catch(Exception e){ e.printStackTrace(); return null; } } @Override public TbPayLog searchPayLogFromRedis(String userId){ TbPayLog payLog=(TbPayLog) redisTemplate.boundHashOps("payLog").get(userId); return payLog; } @Override //根据支付单号,更新付款信息 public void updateOrderStatus(String out_trade_no,String transaction_id){ //获取支付单对象 TbPayLog payLog= payLogMapper.selectByPrimaryKey(out_trade_no); //获取支付状态,微信的业务代码 payLog.setTransactionId(transaction_id); //支付时间 payLog.setPayTime(new Date()); //支付状态 payLog.setTradeState("1");//0未支付 1已支付 //更新数据库中的payLog数据 payLogMapper.updateByPrimaryKey(payLog); //根据支付单的订单列表,更新订单支付的相关信息 String[] orderIds=payLog.getOrdrList().split(","); for(String orderId :orderIds){ TbOrder order= orderMapper.selectByPrimaryKey(Long.parseLong(orderId); //状态:1 未付款 2 已付款 order.setStatus("2"); order.setPaymentTime(new Date()); order.setUpdateTime(new Date()); orderMapper.updateByPrimaryKey(order); } //将redis中的当前用户的付款信息清除 redisTemplate.boundHash("payLog").delete(payLog.getUserId()); }
6.创建PayController.java类
@RestController @RequestMapping("/pay") public class PayController{ @Reference private PayService payService; @RequestMapping("/createNative") public Map createNative(String out_trade_no,String total_fee){ /* String outTradeNo=UUID.randomUUID().toString().replaceAll("_","");*/ //获取用户的支付单 String userId=SecurityContextHolder.getContext().getAuthentication().getName(); //从Redis中获取用户的支付单 TbPayLog payLog= payService.searchPayLogFromRedis(userId); //设置订单号 付款金额 return payService.createNative(payLog.getOutTradeNo(),payLog.getTotalFee()); } @RequestMapping("/queryPayStatus") public Result queryPayStatus(String out_trade_no){ int timeout=1; //无限循环查询订单支付状态 while(true){ Map resultMap=payService.queryPayStatus(out_trade_no); //失败的逻辑 if(resultMap==null){ return new Result(false,"付款失败!!!")； } //支付成功的逻辑 if("SUCCESS".equals(resultMap.get("trade_state"))){ //修改order的状态 修改paylog的状态 payService.updateOrderStatus(out_trade_no,resultMap.get("transaction_id").toString()); return new Result(true,"付款成功!!!")； } //每隔三秒查询订单的支付状态 try{ Thread.sleep(3000); }catch(Exception e){ } timeout++; //退出逻辑 ,超过该时间,停止支付查询 if(timeout>10){ return new Result(false,"timeout"); } } } }
