微信小程序支付之V2支付

一、引入maven

<dependency><groupId>com.github.binarywang</groupId><artifactId>weixin-java-pay</artifactId><version>3.3.4.B</version><exclusions><exclusion><artifactId>qrcode-utils</artifactId><groupId>com.github.binarywang</groupId></exclusion></exclusions>
</dependency><!--微信支付依赖-->
<dependency><groupId>org.jdom</groupId><artifactId>jdom</artifactId><version>1.1</version><scope>compile</scope>
</dependency>

二、调用

package com.dcqq.wechat;import com.dcqq.common.core.controller.BaseController;
import com.dcqq.common.core.domain.R;
import com.dcqq.common.core.domain.entity.SysUser;
import com.dcqq.common.utils.ip.IpUtils;
import com.dcqq.common.utils.wx.HttpUtil;
import com.dcqq.common.utils.wx.PayCommonUtil;
import com.dcqq.common.utils.wx.WxPayConfig;
import com.dcqq.common.utils.wx.XMLUtil;
import com.dcqq.system.domain.TShopOrder;
import com.dcqq.system.domain.vo.PayVo;
import com.dcqq.system.service.ISysUserService;
import com.dcqq.system.service.ITShopOrderService;
import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.util.*;/*** 微信支付管理Controller** @author dcqq* @date 2024-01-04*/
@RestController
@Api(tags = "微信支付管理")
@RequestMapping("/wechat/pay")
public class ApiPayController extends BaseController {@Autowiredprivate ITShopOrderService shopOrderService;@Autowiredprivate ISysUserService userService;/*** 调用统一下单接口,并组装生成支付所需参数对象.*/@PostMapping("/tradeOrder")@ApiOperation("支付接口")public R tradeOrder(@RequestBody PayVo payVo,HttpServletRequest request) {TShopOrder order = shopOrderService.getByOrderNo(payVo.getOrderNo());if (payVo.getPayWay()==2) {//小程序支付Map<String, Object> map = wxPay(order, request);return R.ok(map);}return null;}/*** @Description: 小程序支付* @param request*/private Map<String, Object> wxPay(TShopOrder order, HttpServletRequest request){SysUser user = userService.selectUserById(order.getSysUserId());String openid=user.getOpenId();Integer total=order.getOrderPrice().multiply(new BigDecimal("100")).intValue();try {request.setCharacterEncoding("UTF-8");//订单标题String title = "小程序微信支付";//时间戳String times = System.currentTimeMillis() + "";SortedMap<String, Object> packageParams = new TreeMap<String, Object>();packageParams.put("appid", WxPayConfig.appid);packageParams.put("mch_id", WxPayConfig.mch_id);packageParams.put("nonce_str", times);//时间戳packageParams.put("body", title);//支付主体packageParams.put("out_trade_no", order.getOrderNo());//订单编号packageParams.put("total_fee", total);//元转成分packageParams.put("attach","");packageParams.put("spbill_create_ip", IpUtils.getIpAddr(request));//这里之前加了ip,但是总是获取sign失败,原因不明,之后就注释掉了packageParams.put("notify_url", WxPayConfig.notify_url);//支付回调接口,用于支付成功后处理业务逻辑,小程序端支付success不能保证100%回调成功,建议采用后端异步回调处理方式,回调方法在最后packageParams.put("trade_type", WxPayConfig.tradeType);//这个api有,固定的packageParams.put("openid", openid);//openid//获取signString sign = PayCommonUtil.createSign("UTF-8", packageParams, WxPayConfig.apiKey);//最后这个是自己设置的32位密钥packageParams.put("sign", sign);//转成XMLString requestXML = PayCommonUtil.getRequestXml(packageParams);System.out.println(requestXML);//得到含有prepay_id的XMLString resXml = HttpUtil.postData(WxPayConfig.pay_url, requestXML);System.out.println(resXml);//解析XML存入MapMap map = XMLUtil.doXMLParse(resXml);System.out.println(map);// String return_code = (String) map.get("return_code");//得到prepay_idString prepay_id = (String) map.get("prepay_id");SortedMap<String, Object> packageP = new TreeMap<String, Object>();//以下map的key必须和微信参数一致,请勿修改packageP.put("appId", WxPayConfig.appid);//!!!注意,这里是appId,上面是appid,真怀疑写这个东西的人。。。packageP.put("nonceStr", times);//时间戳packageP.put("package", "prepay_id=" + prepay_id);//必须把package写成 "prepay_id="+prepay_id这种形式packageP.put("signType", WxPayConfig.signType);//paySign加密packageP.put("timeStamp", (System.currentTimeMillis() / 1000) + "");//得到paySignString paySign = PayCommonUtil.createSign("UTF-8", packageP, WxPayConfig.apiKey);packageP.put("paySign", paySign);return packageP;}catch(Exception e){e.printStackTrace();}return null;}/*** @Description:微信支付回调* @return* @throws Exception*/@RequestMapping(value="/wxNotify")public String wxNotify(HttpServletRequest request) {String result = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";try {DataInputStream in = new DataInputStream(request.getInputStream());byte[] bytes = new byte[request.getContentLength()];in.readFully(bytes);in.close();String xml = new String(bytes);Map<String, String> map = XMLUtil.doXMLParse(xml);if (map != null && !map.isEmpty()) {System.out.println(map);System.out.println(map.get("attach"));if (map.get("return_code").equals("SUCCESS")) {//String[] resultBody = map.get("attach").split(",");String orderSn=map.get("out_trade_no");/**更新订单信息*/shopOrderService.payCallback(orderSn);return WxPayNotifyResponse.success("处理成功!");}}return result.replace("SUCCESS", "FAIL").replace("OK", "返回数据错误");} catch (Exception e) {e.printStackTrace();return result.replace("SUCCESS", "FAIL").replace("OK", "本地服务器内部错误");}}
}

三、引入工具类,在公共文件下创建wx文件夹,把下面的代码全部放里面

package com.dcqq.common.utils.wx;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;
import java.net.URLConnection;public class HttpUtil {//private static final Log logger = Logs.get();private final static int CONNECT_TIMEOUT = 5000; // in millisecondsprivate final static String DEFAULT_ENCODING = "UTF-8";public static String postData(String urlStr, String data){return postData(urlStr, data, null);}public static String postData(String urlStr, String data, String contentType){BufferedReader reader = null;try {URL url = new URL(urlStr);URLConnection conn = url.openConnection();conn.setDoOutput(true);conn.setConnectTimeout(CONNECT_TIMEOUT);conn.setReadTimeout(CONNECT_TIMEOUT);if(contentType != null)conn.setRequestProperty("content-type", contentType);OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream(), DEFAULT_ENCODING);if(data == null)data = "";writer.write(data);writer.flush();writer.close();reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), DEFAULT_ENCODING));StringBuilder sb = new StringBuilder();String line = null;while ((line = reader.readLine()) != null) {sb.append(line);sb.append("\r\n");}return sb.toString();} catch (IOException e) {//logger.error("Error connecting to " + urlStr + ": " + e.getMessage());} finally {try {if (reader != null)reader.close();} catch (IOException e) {}}return null;}
}
package com.dcqq.common.utils.wx;
import org.apache.commons.lang3.StringUtils;import javax.servlet.http.HttpServletRequest;/*** @Description:* @Date: 2018/7/17* @Author: wcf*/
public class IpUtils {/*** IpUtils工具类方法* 获取真实的ip地址* @param request* @return*/public static String getIpAddr(HttpServletRequest request) {String ip = request.getHeader("X-Forwarded-For");if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){//多次反向代理后会有多个ip值,第一个ip才是真实ipint index = ip.indexOf(",");if(index != -1){return ip.substring(0,index);}else{return ip;}}ip = request.getHeader("X-Real-IP");if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){return ip;}return request.getRemoteAddr();}
}
package com.dcqq.common.utils.wx;import java.security.MessageDigest;public class MD5 {private static String byteArrayToHexString(byte b[]) {StringBuffer resultSb = new StringBuffer();for (int i = 0; i < b.length; i++)resultSb.append(byteToHexString(b[i]));return resultSb.toString();}private static String byteToHexString(byte b) {int n = b;if (n < 0)n += 256;int d1 = n / 16;int d2 = n % 16;return hexDigits[d1] + hexDigits[d2];}public static String MD5Encode(String origin, String charsetname) {String resultString = null;try {resultString = new String(origin);MessageDigest md = MessageDigest.getInstance("MD5");if (charsetname == null || "".equals(charsetname))resultString = byteArrayToHexString(md.digest(resultString.getBytes()));elseresultString = byteArrayToHexString(md.digest(resultString.getBytes(charsetname)));} catch (Exception exception) {}return resultString;}private static final String hexDigits[] = { "0", "1", "2", "3", "4", "5","6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };}
package com.dcqq.common.utils.wx;import java.text.SimpleDateFormat;
import java.util.*;public class PayCommonUtil {/*** 是否签名正确,规则是:按参数名称a-z排序,遇到空值的参数不参加签名。* @return boolean*/public static boolean isTenpaySign(String characterEncoding, SortedMap<Object, Object> packageParams, String API_KEY) {StringBuffer sb = new StringBuffer();Set es = packageParams.entrySet();Iterator it = es.iterator();while(it.hasNext()) {Map.Entry entry = (Map.Entry)it.next();String k = (String)entry.getKey();String v = (String)entry.getValue();if(!"sign".equals(k) && null != v && !"".equals(v)) {sb.append(k + "=" + v + "&");}}sb.append("key=" + API_KEY);//算出摘要String mysign = MD5.MD5Encode(sb.toString(), characterEncoding).toLowerCase();String tenpaySign = ((String)packageParams.get("sign")).toLowerCase();//System.out.println(tenpaySign + "    " + mysign);return tenpaySign.equals(mysign);}/*** @author* @Description:sign签名  https://pay.weixin.qq.com/wiki/doc/api/wxa/wxa_api.php?chapter=7_7&index=3* @param characterEncoding*            编码格式* @param parameters*            请求参数* @return*/public static String createSign(String characterEncoding, SortedMap<String, Object> packageParams, String API_KEY) {StringBuffer sb = new StringBuffer();Set es = packageParams.entrySet();Iterator it = es.iterator();while (it.hasNext()) {Map.Entry entry = (Map.Entry) it.next();String k = entry.getKey().toString();String v = entry.getValue().toString();if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {sb.append(k + "=" + v + "&");}}sb.append("key=" + API_KEY);System.out.println(sb.toString());String sign = MD5.MD5Encode(sb.toString(), characterEncoding).toUpperCase();return sign;}/*** @author* @Description:将请求参数转换为xml格式的string* @param parameters*            请求参数* @return*/public static String getRequestXml(SortedMap<String, Object> parameters) {StringBuffer sb = new StringBuffer();sb.append("<xml>");Set es = parameters.entrySet();Iterator it = es.iterator();while (it.hasNext()) {Map.Entry entry = (Map.Entry) it.next();String k = entry.getKey().toString();String v = entry.getValue().toString();if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k) || "sign".equalsIgnoreCase(k)) {sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");} else {sb.append("<" + k + ">" + v + "</" + k + ">");}}sb.append("</xml>");return sb.toString();}/*** 取出一个指定长度大小的随机正整数.** @param length*            int 设定所取出随机数的长度。length小于11* @return int 返回生成的随机数。*/public static int buildRandom(int length) {int num = 1;double random = Math.random();if (random < 0.1) {random = random + 0.1;}for (int i = 0; i < length; i++) {num = num * 10;}return (int) ((random * num));}/*** 获取当前时间 yyyyMMddHHmmss** @return String*/public static String getCurrTime() {Date now = new Date();SimpleDateFormat outFormat = new SimpleDateFormat("yyyyMMddHHmmss");String s = outFormat.format(now);return s;}
}
package com.dcqq.common.utils.wx;/*** @Description:* @Date: 2018/7/17* @Author: wcf*/
public class WxPayConfig {//小程序appidpublic static final String appid = "wxaf1111111111111111111";//微信支付的商户idpublic static final String mch_id = "55555555";//微信支付的商户密钥public static final String key = "A5223241994ASDr222222222";//支付成功后的服务器回调urlpublic static final String notify_url = "http://com.ss/wechat/pay/wxNotify";//签名方式public static final String signType = "MD5";//交易类型public static final String tradeType = "JSAPI";//api-keypublic static final String apiKey = "A5223241994ASDr222222222";//微信统一下单接口地址 https://api.mch.weixin.qq.com/pay/unifiedorderpublic static final String pay_url = "https://api.mch.weixin.qq.com/pay/unifiedorder";
}
package com.dcqq.common.utils.wx;import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;public class XMLUtil {public static Map doXMLParse(String strxml) throws JDOMException, IOException {strxml = strxml.replaceFirst("encoding=\".*\"", "encoding=\"UTF-8\"");if(null == strxml || "".equals(strxml)) {return null;}Map m = new HashMap();InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));SAXBuilder builder = new SAXBuilder();Document doc = builder.build(in);Element root = doc.getRootElement();List list = root.getChildren();Iterator it = list.iterator();while(it.hasNext()) {Element e = (Element) it.next();String k = e.getName();String v = "";List children = e.getChildren();if(children.isEmpty()) {v = e.getTextNormalize();} else {v = XMLUtil.getChildrenText(children);}m.put(k, v);}//关闭流in.close();return m;}/*** 获取子结点的xml* @param children* @return String*/public static String getChildrenText(List children) {StringBuffer sb = new StringBuffer();if(!children.isEmpty()) {Iterator it = children.iterator();while(it.hasNext()) {Element e = (Element) it.next();String name = e.getName();String value = e.getTextNormalize();List list = e.getChildren();sb.append("<" + name + ">");if(!list.isEmpty()) {sb.append(XMLUtil.getChildrenText(list));}sb.append(value);sb.append("</" + name + ">");}}return sb.toString();}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/620740.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

生成视频 图像拖拽生成视频

目录 motionctrl DragNUWA 预训练模型&#xff1a; motionctrl 该工具的多功能性使其成为视频制作领域的一项重要创新。它不仅能与现有的视频生成工具如LVDM和VideoCrafter1无缝集成&#xff0c;还能与SVD等其他视频生成方法兼容&#xff0c;为视频创造提供更多可能性。此外…

带F/V变换的反馈型相位控制电路D211,内置过载限制功能、电压监测功能

D211是一块相位控制集成电路&#xff0c;该电路内部具有F-V转换接口、控制放大器、过载限制、软启动、自动重触发、电压监视、电压电流同步等功能。主要应用于电动工具中马达转速的控制。 主要特点&#xff1a; 内置F-V转换接口 外控制集成放大器 内置过载限制功能 …

【数据结构】八大排序之计数排序算法

&#x1f984;个人主页:修修修也 &#x1f38f;所属专栏:数据结构 ⚙️操作环境:Visual Studio 2022 目录 一.计数排序简介及思想 二.计数排序代码实现 三.计数排序复杂度分析 &#x1f4cc;时间复杂度 &#x1f4cc;空间复杂度 结语 一.计数排序简介及思想 计数排序(Cou…

Gitlab集成openLDAP统一认证登录

vim /etc/gitlab/gitlab.rb&#xff0c; 可以配置很多个server&#xff0c;因此与sssd服务一样可以配置多个ldap作为高可用 gitlab-ctl reconfiguregitlab-rake gitlab:ldap:checkgitlab-ctl restart gitlab-rake gitlab:ldap:check Checking LDAP ...LDAP: ... Server: ldapm…

Leetcode刷题(二十四)

括号生成&#xff08;Medium&#xff09; 数字 n 代表生成括号的对数&#xff0c;请你设计一个函数&#xff0c;用于能够生成所有可能的并且 有效的 括号组合。示例 1&#xff1a;输入&#xff1a;n 3 输出&#xff1a;["((()))","(()())","(())()&…

发起人自选-钉钉审批

场景描述 配置一个审批流程&#xff0c;在某些审批节点&#xff0c;不能确定谁具体来审批&#xff0c;所以需要手工选择一个人或者多个人保证流程能得以顺利通过。有些审批流程的做法是&#xff0c;上一个节点来选择指定的人&#xff0c;而钉钉的做法是发起人来指定。 钉钉设…

【Maven】007-Maven 工程的继承和聚合关系

【Maven】007-Maven 工程的继承和聚合关系 文章目录 【Maven】007-Maven 工程的继承和聚合关系一、Maven 工程的继承关系1、继承的概念2、继承的作用3、继承的语法4、父工程统一管理依赖版本父工程声明依赖版本子工程继承以来版本 二、Maven 工程的聚合关系1、聚合的概念2、聚合…

linux文本三剑客(grep,sed,awk)使用

目录 一、grepgrep概念grep使用 二、sedsed概念sed使用 三、awkawk概念awk使用 一、grep grep概念 Linux系统中grep命令是一种强大的文本搜索工具&#xff0c;它能使用正则表达式搜索文本&#xff0c;并把匹配的行打印出来(匹配到的标红)。grep全称是Global Regular Expressi…

【信号与系统】【北京航空航天大学】实验一、信号的MATLAB表示及信号运算

一、实验目的 1、初步掌握 MATLAB 仿真软件的使用&#xff1b; 2、学习使用 MATLAB 产生基本时域信号&#xff0c;并绘制信号波形&#xff1b; 3、学习利用 MATLAB 实现信号的基本运算&#xff1b; 4、利用 MATLAB 分析常用的连续时域信号。 二、实验内容 1、 生成连续信号 …

Redis 常见的性能问题有哪些?该如何解决?

Redis 常见的性能问题有哪些&#xff1f;该如何解决&#xff1f; Redis 常见的性能问题包括内存使用过高、网络延迟、阻塞操作、持久化操作引起的性能问题等。以下是一些常见性能问题及解决方法&#xff1a; 内存使用过高&#xff1a; 问题&#xff1a; 当 Redis 使用的内存超…

jQuery圆形轮播自动切换图文

jQuery圆形轮播自动切换图文 注意这里用到了swiper插件&#xff0c;记得引入swiper.js和swiper.css swiper官网 这里面用到的swiper版本是Swiper 4.4.2 不同版本有些写法会不同&#xff0c;可对照官方文档进行调整 效果展示 jquery圆形轮播自动切换文字 html代码片段 <li…

【LangChain学习之旅】—(6) 提示工程(下):用思维链和思维树提升模型思考质量

【LangChain学习之旅】—&#xff08;6&#xff09; 提示工程&#xff08;下&#xff09;&#xff1a;用思维链和思维树提升模型思考质量 什么是 Chain of ThoughtFew-Shot CoTZero-Shot CoTChain of Thought 实战CoT 的模板设计程序的完整框架Tree of Thought总结 Reference&a…

优雅草蜻蜓API大数据服务中心v1.0.4更新-加入蓝奏云直链解析·每日Bing·字数统计·今日油价·历史上的今天等接口

2024年1月13日优雅草蜻蜓API大数据服务中心v1.0.4更新-加入蓝奏云直链解析每日Bing字数统计今日油价历史上的今天等接口 优雅草api服务-大数据中心自12月29日推出以来截止2024年1月13日累计被调用次数为413次&#xff0c;共收录23个接口&#xff0c;截止前一日2024年1月12日当…

OpenCV-Python(36):ORB算法

ORB&#xff08;Oriented FAST and Rotated BRIEF&#xff09;是一种用于图像特征提取和描述的算法。它是FAST角点检测器和BRIEF特征描述符的结合体&#xff0c;通过在FAST角点周围计算BRIEF描述符来提取关键点的特征。 ORB算法具有以下特点&#xff1a; 1.速度快&#xff1a…

《向量数据库指南》让「引用」为 RAG 机器人回答增加可信度

在之前的文章中&#xff0c;我们已经介绍了如何用 Milvus 向量数据库以及 LlamaIndex 搭建基础的聊天机器人《Chat Towards Data Science &#xff5c;如何用个人数据知识库构建 RAG 聊天机器人&#xff1f;》《书接上回&#xff0c;如何用 LlamaIndex 搭建聊天机器人&#xff…

pyqt5 pyinstaller 打包 QThread QLable QscrollArea 滑动 红果短剧

废话 不多说&#xff0c;直接上代码&#xff01;&#xff01;&#xff01; UI.py self.scrollArea QtWidgets.QScrollArea(self.centralwidget)self.scrollArea.setGeometry(QtCore.QRect(20, 130, 541, 511))self.scrollArea.setWidgetResizable(True)self.scrollArea.setOb…

vue2、vue3里面去掉访问地址中路由‘#‘号--nginx配置

需求 我们这里分享一下关于Vue2和Vue3里面如何去掉浏览器路由里面#号的问题&#xff0c;以及nginx的配置。 去掉#号问题之前我们先讨论一下html中的hash模式和history模式。 html中的hash模式 HTML的hash模式指的是URL中的锚点部分&#xff08;#后面的内容&#xff09;被用…

通信入门系列——微积分中极限、连续、导数、微分、积分

本节目录 一、极限 1、数列极限 2、函数极限 二、连续 三、导数 四、微分 五、积分本节内容 一、极限 1、数列极限 数列极限&#xff1a;设{xn}为一个实数列&#xff0c;A为一个定数。若对任意给定的ε>0&#xff0c;总存在正整数N,使得当n>N时&#xff0c;有|xn-A|<…

linux搭建SRS服务器

linux搭建SRS服务器 文章目录 linux搭建SRS服务器SRS说明实验说明搭建步骤推流步骤查看web端服务器拉流步骤final SRS说明 SRS&#xff08;simple Rtmp Server&#xff09;,是一个简单高效的实时视频服务器&#xff0c;支持RTMP/WebRTC/HLS/HTTP-FLV/SRT, 是国人自己开发的一款…

常见面试题之HTML

行内元素有哪些&#xff1f;块级元素有哪些&#xff1f; 空(void)元素有那些&#xff1f; HTML 中的行内元素&#xff08;inline elements&#xff09;通常用于在一行内显示&#xff0c;不会独占一行的空间。常见的行内元素有&#xff1a; <span>&#xff1a;用于对文本…