标签:private qrcode res 实现 sortedmap img nsf ade ase
1.封装工具类:
包括的方法实现:
xml转Map,Map转xml,生成微信支付签名sign,签名的校验,把Map转为SortMap(有序)
package net.xdclass.xdvideo.controller; import net.xdclass.xdvideo.config.WeChatConfig; import net.xdclass.xdvideo.domain.JsonData; import net.xdclass.xdvideo.domain.User; import net.xdclass.xdvideo.domain.VideoOrder; import net.xdclass.xdvideo.service.UserService; import net.xdclass.xdvideo.service.VideoOrderService; import net.xdclass.xdvideo.utils.CommonUtils; import net.xdclass.xdvideo.utils.JwtUtils; import net.xdclass.xdvideo.utils.WXPayUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; import javax.xml.transform.OutputKeys; import javax.xml.transform.Transformer; import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import java.io.*; import java.net.URLEncoder; import java.util.*; @Controller @RequestMapping("/api/v1/wechat") public class WechatController { @Autowired private WeChatConfig weChatConfig; @Autowired private UserService userService; @Autowired private VideoOrderService videoOrderService; /** * 拼装微信扫一扫登录url * @return */ @GetMapping("login_url") @ResponseBody public JsonData loginUrl(@RequestParam(value = "access_page",required = true)String accessPage) throws UnsupportedEncodingException { String redirectUrl = weChatConfig.getOpenRedirectUrl(); //获取开放平台重定向地址 String callbackUrl = URLEncoder.encode(redirectUrl,"GBK"); //进行编码 String qrcodeUrl = String.format(weChatConfig.getOpenQrcodeUrl(),weChatConfig.getOpenAppid(),callbackUrl,accessPage); return JsonData.buildSuccess(qrcodeUrl); } /** * 微信扫码登录,回调地址 * @param code * @param state * @param response * @throws IOException */ @GetMapping("/user/callback") public void wechatUserCallback(@RequestParam(value = "code",required = true) String code, String state, HttpServletResponse response) throws IOException { User user = userService.saveWeChatUser(code); if(user != null){ //生成jwt String token = JwtUtils.geneJsonWebToken(user); // state 当前用户的页面地址,需要拼接 http:// 这样才不会站内跳转 response.sendRedirect(state+"?token="+token+"&head_img="+user.getHeadImg()+"&name="+URLEncoder.encode(user.getName(),"UTF-8")); } } package net.xdclass.xdvideo.utils; import org.w3c.dom.Entity; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; import javax.xml.transform.OutputKeys; import javax.xml.transform.Transformer; import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import java.io.ByteArrayInputStream; import java.io.InputStream; import java.io.StringWriter; import java.util.*; /** * 微信支付工具类,xml转map,map转xml,生成签名 */ public class WXPayUtil { /** * XML格式字符串转换为Map * * @param strXML XML字符串 * @return XML数据转换后的Map * @throws Exception */ public static Map<String, String> xmlToMap(String strXML) throws Exception { try { Map<String, String> data = new HashMap<String, String>(); DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance(); DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder(); InputStream stream = new ByteArrayInputStream(strXML.getBytes("UTF-8")); org.w3c.dom.Document doc = documentBuilder.parse(stream); doc.getDocumentElement().normalize(); NodeList nodeList = doc.getDocumentElement().getChildNodes(); for (int idx = 0; idx < nodeList.getLength(); ++idx) { Node node = nodeList.item(idx); if (node.getNodeType() == Node.ELEMENT_NODE) { org.w3c.dom.Element element = (org.w3c.dom.Element) node; data.put(element.getNodeName(), element.getTextContent()); } } try { stream.close(); } catch (Exception ex) { // do nothing } return data; } catch (Exception ex) { throw ex; } } /** * 将Map转换为XML格式的字符串 * * @param data Map类型数据 * @return XML格式的字符串 * @throws Exception */ public static String mapToXml(Map<String, String> data) throws Exception { DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance(); DocumentBuilder documentBuilder= documentBuilderFactory.newDocumentBuilder(); org.w3c.dom.Document document = documentBuilder.newDocument(); org.w3c.dom.Element root = document.createElement("xml"); document.appendChild(root); for (String key: data.keySet()) { String value = data.get(key); if (value == null) { value = ""; } value = value.trim(); org.w3c.dom.Element filed = document.createElement(key); filed.appendChild(document.createTextNode(value)); root.appendChild(filed); } TransformerFactory tf = TransformerFactory.newInstance(); Transformer transformer = tf.newTransformer(); DOMSource source = new DOMSource(document); transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); transformer.setOutputProperty(OutputKeys.INDENT, "yes"); StringWriter writer = new StringWriter(); StreamResult result = new StreamResult(writer); transformer.transform(source, result); String output = writer.getBuffer().toString(); //.replaceAll("\n|\r", ""); try { writer.close(); } catch (Exception ex) { } return output; } /** * 生成微信支付sign * @return */ public static String createSign(SortedMap<String, String> params, String key){ StringBuilder sb = new StringBuilder(); Set<Map.Entry<String, String>> es = params.entrySet(); Iterator<Map.Entry<String,String>> it = es.iterator(); //生成 stringA="appid=wxd930ea5d5a258f4f&body=test&device_info=1000&mch_id=10000100&nonce_str=ibuaiVcKdpRxkhJA"; while (it.hasNext()){ Map.Entry<String,String> entry = (Map.Entry<String,String>)it.next(); String k = (String)entry.getKey(); String v = (String)entry.getValue(); if(null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)){ sb.append(k+"="+v+"&"); } } sb.append("key=").append(key); String sign = CommonUtils.MD5(sb.toString()).toUpperCase(); return sign; } /** * 校验签名 * @param params * @param key * @return */ public static boolean isCorrectSign(SortedMap<String, String> params, String key){ String sign = createSign(params,key); String weixinPaySign = params.get("sign").toUpperCase(); return weixinPaySign.equals(sign); } /** * 获取有序map * @param map * @return */ public static SortedMap<String,String> getSortedMap(Map<String,String> map){ SortedMap<String, String> sortedMap = new TreeMap<>(); Iterator<String> it = map.keySet().iterator(); while (it.hasNext()){ String key = (String)it.next(); String value = map.get(key); String temp = ""; if( null != value){ temp = value.trim(); } sortedMap.put(key,temp); } return sortedMap; } } }
2.根据配置的回调url开发controller:
扫码后返回给回调url的结果是个xml字符串:
package net.xdclass.xdvideo.controller; import net.xdclass.xdvideo.config.WeChatConfig; import net.xdclass.xdvideo.domain.JsonData; import net.xdclass.xdvideo.domain.User; import net.xdclass.xdvideo.domain.VideoOrder; import net.xdclass.xdvideo.service.UserService; import net.xdclass.xdvideo.service.VideoOrderService; import net.xdclass.xdvideo.utils.JwtUtils; import net.xdclass.xdvideo.utils.WXPayUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.URLEncoder; import java.util.Date; import java.util.Map; import java.util.SortedMap; @Controller @RequestMapping("/api/v1/wechat") public class WechatController { @Autowired private WeChatConfig weChatConfig; @Autowired private UserService userService; @Autowired private VideoOrderService videoOrderService; /** * 拼装微信扫一扫登录url * @return */ @GetMapping("login_url") @ResponseBody public JsonData loginUrl(@RequestParam(value = "access_page",required = true)String accessPage) throws UnsupportedEncodingException { String redirectUrl = weChatConfig.getOpenRedirectUrl(); //获取开放平台重定向地址 String callbackUrl = URLEncoder.encode(redirectUrl,"GBK"); //进行编码 String qrcodeUrl = String.format(weChatConfig.getOpenQrcodeUrl(),weChatConfig.getOpenAppid(),callbackUrl,accessPage); return JsonData.buildSuccess(qrcodeUrl); } /** * 微信扫码登录,回调地址 * @param code * @param state * @param response * @throws IOException */ @GetMapping("/user/callback") public void wechatUserCallback(@RequestParam(value = "code",required = true) String code, String state, HttpServletResponse response) throws IOException { User user = userService.saveWeChatUser(code); if(user != null){ //生成jwt String token = JwtUtils.geneJsonWebToken(user); // state 当前用户的页面地址,需要拼接 http:// 这样才不会站内跳转 response.sendRedirect(state+"?token="+token+"&head_img="+user.getHeadImg()+"&name="+URLEncoder.encode(user.getName(),"UTF-8")); } } /** * 微信支付回调 */ @RequestMapping("/order/callback") public void orderCallback(HttpServletRequest request,HttpServletResponse response) throws Exception { InputStream inputStream = request.getInputStream(); //BufferedReader是包装设计模式,性能更搞 BufferedReader in = new BufferedReader(new InputStreamReader(inputStream,"UTF-8")); StringBuffer sb = new StringBuffer(); String line ; while ((line = in.readLine()) != null){ sb.append(line); } in.close(); inputStream.close(); Map<String,String> callbackMap = WXPayUtil.xmlToMap(sb.toString()); System.out.println(callbackMap.toString()); SortedMap<String,String> sortedMap = WXPayUtil.getSortedMap(callbackMap); //判断签名是否正确 if(WXPayUtil.isCorrectSign(sortedMap,weChatConfig.getKey())){ if("SUCCESS".equals(sortedMap.get("result_code"))){ //获取订单流水号 String outTradeNo = sortedMap.get("out_trade_no"); //根据订单流水号获取订单信息 VideoOrder dbVideoOrder = videoOrderService.findByOutTradeNo(outTradeNo); //判断逻辑看业务场景,状态是否为未支付0,是的话更新订单信息 if(dbVideoOrder != null && dbVideoOrder.getState()==0){ VideoOrder videoOrder = new VideoOrder(); videoOrder.setOpenid(sortedMap.get("openid")); videoOrder.setOutTradeNo(outTradeNo); videoOrder.setNotifyTime(new Date()); videoOrder.setState(1); int rows = videoOrderService.updateVideoOderByOutTradeNo(videoOrder); if(rows == 1){ //通知微信订单处理成功 response.setContentType("text/xml"); response.getWriter().println("success"); return; } } } } //都处理失败 response.setContentType("text/xml"); response.getWriter().println("fail"); } }
文档参考:https://pay.weixin.qq.com/wiki/doc/api/app/app.php?chapter=9_7&index=3
标签:private qrcode res 实现 sortedmap img nsf ade ase
原文地址:https://www.cnblogs.com/big-cut-cat/p/9867907.html