zoukankan      html  css  js  c++  java

  • 微信支付异步回调，带你解决微信支付的深坑

    1.首先我们先下载微信支付的服务器端demo





    2.个文件作用介绍

    index.jsp  下单  payRequest.jsp  获取微信支付prepay_id等。

    重点我说说这个payNotifyUrl.jsp

    1. <%@ page language="java" contentType="text/html; charset=GBK" pageEncoding="GBK"%>
    2. <%@ page import="com.tenpay.RequestHandler" %>
    3. <%@ page import="com.tenpay.ResponseHandler" %>   
    4. <%@ page import="com.tenpay.client.ClientResponseHandler" %>    
    5. <%@ page import="com.tenpay.client.TenpayHttpClient" %>
    6. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    7. <%
    8. //---------------------------------------------------------
    9. //财付通支付通知（后台通知）示例，商户按照此文档进行开发即可
    10. //---------------------------------------------------------
    11. //商户号  
    12. String partner = "1900000109";
    13.  
    14. //密钥
    15. String key = "8934e7d15453e97507ef794cf7b0519d";
    16.  
    17. //创建支付应答对象
    18. ResponseHandler resHandler = new ResponseHandler(request, response);
    19. resHandler.setKey(key);
    20.  
    21. //判断签名
    22. if(resHandler.isTenpaySign()) {
    23. 	
    24. 	//通知id
    25. 	String notify_id = resHandler.getParameter("notify_id");
    26. 	
    27. 	//创建请求对象
    28. 	RequestHandler queryReq = new RequestHandler(null, null);
    29. 	//通信对象
    30. 	TenpayHttpClient httpClient = new TenpayHttpClient();
    31. 	//应答对象
    32. 	ClientResponseHandler queryRes = new ClientResponseHandler();
    33. 	
    34. 	//通过通知ID查询，确保通知来至财付通
    35. 	queryReq.init();
    36. 	queryReq.setKey(key);
    37. 	queryReq.setGateUrl("https://gw.tenpay.com/gateway/verifynotifyid.xml");
    38. 	queryReq.setParameter("partner", partner);
    39. 	queryReq.setParameter("notify_id", notify_id);
    40. 	
    41. 	//通信对象
    42. 	httpClient.setTimeOut(5);
    43. 	//设置请求内容
    44. 	httpClient.setReqContent(queryReq.getRequestURL());
    45. 	System.out.println("queryReq:" + queryReq.getRequestURL());
    46. 	//后台调用
    47. 	if(httpClient.call()) {
    48. 		//设置结果参数
    49. 		queryRes.setContent(httpClient.getResContent());
    50. 		System.out.println("queryRes:" + httpClient.getResContent());
    51. 		queryRes.setKey(key);
    52. 			
    53. 			
    54. 		//获取返回参数
    55. 		String retcode = queryRes.getParameter("retcode");
    56. 		String trade_state = queryRes.getParameter("trade_state");
    57. 	
    58. 		String trade_mode = queryRes.getParameter("trade_mode");
    59. 			
    60. 		//判断签名及结果
    61. 		if(queryRes.isTenpaySign()&& "0".equals(retcode) && "0".equals(trade_state) && "1".equals(trade_mode)) {
    62. 			System.out.println("订单查询成功");
    63. 			//取结果参数做业务处理				
    64. 			System.out.println("out_trade_no:" + queryRes.getParameter("out_trade_no")+
    65. 					" transaction_id:" + queryRes.getParameter("transaction_id"));
    66. 			System.out.println("trade_state:" + queryRes.getParameter("trade_state")+
    67. 					" total_fee:" + queryRes.getParameter("total_fee"));
    68. 		        //如果有使用折扣券，discount有值，total_fee+discount=原请求的total_fee
    69. 			System.out.println("discount:" + queryRes.getParameter("discount")+
    70. 					" time_end:" + queryRes.getParameter("time_end"));
    71. 			//------------------------------
    72. 			//处理业务开始
    73. 			//------------------------------
    74. 			
    75. 			//处理数据库逻辑
    76. 			//注意交易单不要重复处理
    77. 			//注意判断返回金额
    78. 			
    79. 			//------------------------------
    80. 			//处理业务完毕
    81. 			//------------------------------
    82. 			resHandler.sendToCFT("Success");
    83. 		}
    84. 		else{
    85. 				//错误时，返回结果未签名，记录retcode、retmsg看失败详情。
    86. 				System.out.println("查询验证签名失败或业务错误");
    87. 				System.out.println("retcode:" + queryRes.getParameter("retcode")+
    88. 						" retmsg:" + queryRes.getParameter("retmsg"));
    89. 		}
    90. 	
    91. 	} else {
    92.  
    93. 		System.out.println("后台调用通信失败");
    94. 			
    95. 		System.out.println(httpClient.getResponseCode());
    96. 		System.out.println(httpClient.getErrInfo());
    97. 		//有可能因为网络原因，请求已经处理，但未收到应答。
    98. 	}
    99. }
    100. else{
    101. 	System.out.println("通知签名验证失败");
    102. }
    103.  
    104. %>
    105.
    就是上面的这代码。完全没有用。查看sdk源码才知道 这个异步回调是接收微信发送的所有参数，然后排序  加密 验签。  最坑的是  微信 的参数根本不是通过的参数返回的。而是通过的流。所以这个太坑了。下面我把我修改过的源码发出来 帮助大家解决回调问题。

    首先是控制器

    1. /**
    2. 	 * 异步回调接口
    3. 	 * @param request
    4. 	 * @param response
    5. 	 * @throws Exception
    6. 	 */
    7. 	@RequestMapping(value="/weixin_parent_notify.do",produces="text/html;charset=utf-8")
    8. 	@ResponseBody
    9. 	public String WeixinParentNotifyPage(HttpServletRequest request,HttpServletResponse response) throws Exception{
    10. 		
    11. 		ServletInputStream instream = request.getInputStream();
    12. 		StringBuffer sb = new StringBuffer();
    13. 		int len = -1;
    14. 		byte[] buffer = new byte[1024];
    15. 		
    16. 		while((len = instream.read(buffer)) != -1){
    17. 			sb.append(new String(buffer,0,len));
    18. 		}
    19. 		instream.close();
    20. 		
    21. 		SortedMap<String,String> map = WXRequestUtil.doXMLParseWithSorted(sb.toString());//接受微信的通知参数
    22. 		Map<String,String> return_data = new HashMap<String,String>();
    23. 	
    24. 		//创建支付应答对象
    25. 		ResponseHandler resHandler = new ResponseHandler(request, response);
    26. 		
    27. 		resHandler.setAllparamenters(map);
    28. 		resHandler.setKey(ConstantUtil.PARTNER_KEY[0]);
    29. 		
    30. 		//判断签名
    31. 		if(resHandler.isTenpaySign()){
    32. 			if(!map.get("return_code").toString().equals("SUCCESS")){
    33. 				return_data.put("return_code", "FAIL");
    34. 				return_data.put("return_msg", "return_code不正确");
    35. 			}else{
    36. 				if(!map.get("result_code").toString().equals("SUCCESS")){
    37. 					return_data.put("return_code", "FAIL");
    38. 					return_data.put("return_msg", "result_code不正确");
    39. 				}
    40. 				
    41. 				
    42. 				
    43. 				String out_trade_no = map.get("out_trade_no").toString();
    44. 				String time_end = map.get("time_end").toString();
    45. 				BigDecimal total_fee = new BigDecimal(map.get("total_fee").toString());
    46. 				//付款完成后，支付宝系统发送该交易状态通知
    47. 				System.out.println("交易成功");
    48. 				Map order = orderdao.PaymentEndGetOrderInfo(out_trade_no);
    49. 				
    50. 				if(order == null){
    51. 					System.out.println("订单不存在");
    52. 					return_data.put("return_code", "FAIL");
    53. 					return_data.put("return_msg", "订单不存在");
    54. 					return WXRequestUtil.GetMapToXML(return_data);
    55. 				}
    56. 				
    57. 				int order_type = (int) order.get("order_type");
    58. 				boolean payment_status = (boolean) order.get("payment_status");
    59. 				int supplier_id = (int) order.get("supplier_id");
    60. 				
    61. 				BigDecimal p = new BigDecimal("100");  
    62. 				BigDecimal amount = (BigDecimal) order.get("amount");
    63. 				
    64. 				amount  = amount.multiply(p);
    65. 				
    66. 				//如果订单已经支付返回错误
    67. 				if(payment_status){
    68. 					System.out.println("订单已经支付");
    69. 					return_data.put("return_code", "SUCCESS");
    70. 					return_data.put("return_msg", "OK");
    71. 					return WXRequestUtil.GetMapToXML(return_data);
    72. 				}
    73. 				
    74. 				
    75. 				//如果支付金额不等于订单金额返回错误
    76. 				if(amount.compareTo(total_fee)!=0){
    77. 					System.out.println("资金异常");
    78. 					return_data.put("return_code", "FAIL");
    79. 					return_data.put("return_msg", "金额异常");
    80. 					return WXRequestUtil.GetMapToXML(return_data);
    81. 				}
    82. 				
    83. 				//更新订单信息
    84. 				if(orderdao.PaymentEndUpdateOrder(out_trade_no, time_end)){
    85. 					System.out.println("更新订单成功");
    86. 					//如果该订单是幼儿产品  并且 存在代理
    87. 					if(order_type == 2){
    88. 						if(supplier_id != 0){
    89. 							Map su = userdao.getSupplierInfo(supplier_id);
    90. 							String phone = (String) su.get("phone_number");
    91. 							String nickname = (String) su.get("nickname");
    92. 							String app_token = (String) su.get("app_token");
    93. 							
    94. 							String content = "【三盛科创】尊敬的"+ nickname +"您好。您在我们平台出售的商品有新用户下单。请您点击该链接查看发货信息。"+Config.WEB_SERVER+"/order/SupplierOrderInfo.do?order_number="+out_trade_no+"&sid="+app_token+".请您务必妥善包管。";
    95. 							MessageUtil.SendMessage(phone,content);
    96. 						}
    97. 					}else{
    98. 						orderdao.UpdateOrderStatus(out_trade_no, 3);//更新订单为已完成
    99. 					}
    100. 					
    101. 					return_data.put("return_code", "SUCCESS");
    102. 					return_data.put("return_msg", "OK");
    103. 					return WXRequestUtil.GetMapToXML(return_data);
    104. 				}else{
    105. 					return_data.put("return_code", "FAIL");
    106. 					return_data.put("return_msg", "更新订单失败");
    107. 					return WXRequestUtil.GetMapToXML(return_data);
    108. 				}
    109. 			}
    110. 		}else{
    111. 			return_data.put("return_code", "FAIL");
    112. 			return_data.put("return_msg", "签名错误");
    113. 		}
    114. 		
    115. 		String xml = WXRequestUtil.GetMapToXML(return_data);
    116. 		return xml;
    117. 	}

    微信工具类WXRequestUtil.java 

    1. package com.tenpay.util;
    2.  
    3. import java.io.BufferedReader;
    4. import java.io.ByteArrayInputStream;
    5. import java.io.File;
    6. import java.io.FileInputStream;
    7. import java.io.InputStream;
    8. import java.io.InputStreamReader;
    9. import java.io.OutputStream;
    10. import java.net.ConnectException;
    11. import java.net.HttpURLConnection;
    12. import java.net.InetAddress;
    13. import java.net.URL;
    14. import java.security.KeyStore;
    15. import java.util.Date;
    16. import java.util.HashMap;
    17. import java.util.Iterator;
    18. import java.util.List;
    19. import java.util.Map;
    20. import java.util.SortedMap;
    21. import java.util.TreeMap;
    22.  
    23. import javax.net.ssl.SSLContext;
    24.  
    25. import org.apache.http.Consts;
    26. import org.apache.http.HttpEntity;
    27. import org.apache.http.client.methods.CloseableHttpResponse;
    28. import org.apache.http.client.methods.HttpPost;
    29. import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
    30. import org.apache.http.conn.ssl.SSLContexts;
    31. import org.apache.http.entity.StringEntity;
    32. import org.apache.http.impl.client.CloseableHttpClient;
    33. import org.apache.http.impl.client.HttpClients;
    34. import org.apache.http.util.EntityUtils;
    35. import org.glassfish.jersey.internal.util.Base64;
    36. import org.jdom.Document;
    37. import org.jdom.Element;
    38. import org.jdom.input.SAXBuilder;
    39.  
    40. import com.zhiweism.util.MD5;
    41. import com.zhiweism.util.Util;
    42.  
    43. /*
    44.  * 用户发起统一下单请求
    45.  * 作者：董志平
    46.  * 用于发起微信扫码支付接口
    47.  */
    48. public class WXRequestUtil {
    49. 	private static String WXSign = null;
    50. //	//测试
    51. 	public static void main(String[] args) {
    52. 		//Map<String,String> res = SendPayment("苹果","20170106113325",1,0);
    53. 	}
    54. 	
    55. 	/*
    56. 	 * 发起支付请求
    57. 	 * body	商品描述
    58. 	 * out_trade_no	订单号
    59. 	 * total_fee	订单金额		单位  元
    60. 	 * product_id	商品ID
    61. 	 */
    62. 	public static Map<String,String> SendPayment(String body,String out_trade_no,double total_fee,int app_type){
    63. 		String url = "https://api.mch.weixin.qq.com/pay/unifiedorder";
    64. 		String xml = WXParamGenerate(body,out_trade_no,total_fee,app_type);
    65. 		String res = httpsRequest(url,"POST",xml);
    66. 		Map<String,String> data = null;
    67. 		try {
    68. 			data = doXMLParse(res);
    69. 		} catch (Exception e) {
    70. 			data = null;
    71. 		}
    72. 		return data;
    73. 	}
    74.  
    75. 	
    76. 	/**
    77. 	 * 获取签名
    78. 	 * @return
    79. 	 */
    80. 	public static String getWXSign() {
    81. 		return WXSign;
    82. 	}
    83.  
    84. 	/**
    85. 	 * 	获得随机字符串
    86. 	 * 
    87. 	 */
    88. 	public static String NonceStr(){
    89. 		String res = Base64.encodeAsString(Math.random()+"::"+new Date().toString()).substring(0, 30);
    90. 		return res;
    91. 	}
    92. 	
    93. 	/**
    94. 	 * 获取时间戳
    95. 	 */
    96. 	public static String GetTimeStamp(){
    97. 		int t = (int)(System.currentTimeMillis()/1000);
    98. 		return t+"";
    99. 	}
    100. 	
    101. 	
    102. 	/**
    103. 	 * 	获取用户的ip
    104. 	 * 
    105. 	 */
    106. 	 public static String GetIp() {
    107.         InetAddress ia=null;
    108.         try {
    109.             ia=InetAddress.getLocalHost();
    110.             String localip=ia.getHostAddress();
    111.             return localip;
    112.         } catch (Exception e) {
    113.             return null;
    114.         }
    115.     }
    116. 	 
    117. 	 /**
    118. 	  * 获取签名
    119. 	  * 
    120. 	  */
    121. 	 public static String GetSign(Map<String,String> param,int app_type){
    122. 		String StringA =  Util.formatUrlMap(param, false, false);
    123. 		String stringSignTemp = MD5.md5(StringA+"&key="+ConstantUtil.PARTNER_KEY[app_type]).toUpperCase();
    124. 		return stringSignTemp;
    125. 	 }
    126. 	 
    127. 	 /**
    128. 	  * 
    129. 	  * Map转xml数据
    130. 	  */
    131. 	 public static String GetMapToXML(Map<String,String> param){
    132. 		 StringBuffer sb = new StringBuffer();
    133. 		 sb.append("<xml>");
    134. 		 for (Map.Entry<String,String> entry : param.entrySet()) { 
    135. 			    sb.append("<"+ entry.getKey() +">");
    136. 			    sb.append(entry.getValue());
    137. 			    sb.append("</"+ entry.getKey() +">");
    138. 		}  
    139. 		 sb.append("</xml>");
    140. 		 return sb.toString();
    141. 	 }
    142. 	
    143. 	
    144. 	//微信统一下单参数设置
    145. 	public static String WXParamGenerate(String description,String out_trade_no,double total_fee,int app_type){
    146. 		int fee = (int)(total_fee * 100.00);
    147. 		Map<String,String> param = new HashMap<String,String>();
    148. 		param.put("appid", ConstantUtil.APP_ID[app_type]);
    149. 		param.put("mch_id", ConstantUtil.PARTNER[app_type]);
    150. 		param.put("nonce_str",NonceStr());
    151. 		param.put("body",description);
    152. 		param.put("out_trade_no",out_trade_no);
    153. 		param.put("total_fee", fee+"");
    154. 		param.put("spbill_create_ip", GetIp());
    155. 		param.put("notify_url", ConstantUtil.WEIXIN_NOTIFY[app_type]);
    156. 		param.put("trade_type", "APP");
    157. 		
    158. 		WXSign = GetSign(param,app_type);
    159. 		
    160. 		param.put("sign", WXSign);
    161. 		return GetMapToXML(param);
    162. 	}
    163. 	
    164. 	//发起微信支付请求
    165.     public static String httpsRequest(String requestUrl, String requestMethod, String outputStr) {  
    166.       try {  
    167.           URL url = new URL(requestUrl);  
    168.           HttpURLConnection conn = (HttpURLConnection) url.openConnection();  
    169.           
    170.           conn.setDoOutput(true);  
    171.           conn.setDoInput(true);  
    172.           conn.setUseCaches(false);  
    173.           // 设置请求方式（GET/POST）  
    174.           conn.setRequestMethod(requestMethod);  
    175.           conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");  
    176.           // 当outputStr不为null时向输出流写数据  
    177.           if (null != outputStr) {  
    178.               OutputStream outputStream = conn.getOutputStream();  
    179.               // 注意编码格式  
    180.               outputStream.write(outputStr.getBytes("UTF-8"));  
    181.               outputStream.close();  
    182.           }  
    183.           // 从输入流读取返回内容  
    184.           InputStream inputStream = conn.getInputStream();  
    185.           InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");  
    186.           BufferedReader bufferedReader = new BufferedReader(inputStreamReader);  
    187.           String str = null;
    188.           StringBuffer buffer = new StringBuffer();  
    189.           while ((str = bufferedReader.readLine()) != null) {  
    190.               buffer.append(str);  
    191.           }  
    192.           // 释放资源  
    193.           bufferedReader.close();  
    194.           inputStreamReader.close();  
    195.           inputStream.close();  
    196.           inputStream = null;  
    197.           conn.disconnect();  
    198.           return buffer.toString();  
    199.       } catch (ConnectException ce) {  
    200.           System.out.println("连接超时：{}"+ ce);  
    201.       } catch (Exception e) {  
    202.           System.out.println("https请求异常：{}"+ e);  
    203.       }  
    204.       return null;  
    205.     }  
    206.       
    207.     //退款的请求方法  
    208.     public static String httpsRequest2(String requestMethod, String outputStr) throws Exception {  
    209.           KeyStore keyStore  = KeyStore.getInstance("PKCS12");  
    210.           StringBuilder res = new StringBuilder("");  
    211.           FileInputStream instream = new FileInputStream(new File("/home/apiclient_cert.p12"));  
    212.           try {  
    213.               keyStore.load(instream, "".toCharArray());  
    214.           } finally {  
    215.               instream.close();  
    216.           }  
    217.  
    218.           // Trust own CA and all self-signed certs  
    219.           SSLContext sslcontext = SSLContexts.custom()  
    220.                   .loadKeyMaterial(keyStore, "1313329201".toCharArray())  
    221.                   .build();   
    222.           SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(  
    223.                   sslcontext,  
    224.                   new String[] { "TLSv1" },  
    225.                   null,  
    226.                   SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);  
    227.           CloseableHttpClient httpclient = HttpClients.custom()  
    228.                   .setSSLSocketFactory(sslsf)  
    229.                   .build();  
    230.           try {  
    231.  
    232.               HttpPost httpost = new HttpPost("https://api.mch.weixin.qq.com/secapi/pay/refund");  
    233.               httpost.addHeader("Connection", "keep-alive");  
    234.               httpost.addHeader("Accept", "*/*");  
    235.               httpost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");  
    236.               httpost.addHeader("Host", "api.mch.weixin.qq.com");  
    237.               httpost.addHeader("X-Requested-With", "XMLHttpRequest");  
    238.               httpost.addHeader("Cache-Control", "max-age=0");  
    239.               httpost.addHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0) ");  
    240.                StringEntity entity2 = new StringEntity(outputStr ,Consts.UTF_8);  
    241.                httpost.setEntity(entity2);  
    242.               System.out.println("executing request" + httpost.getRequestLine());  
    243.  
    244.               CloseableHttpResponse response = httpclient.execute(httpost);  
    245.                
    246.               try {  
    247.                   HttpEntity entity = response.getEntity();  
    248.                     
    249.                   System.out.println("----------------------------------------");  
    250.                   System.out.println(response.getStatusLine());  
    251.                   if (entity != null) {  
    252.                       System.out.println("Response content length: " + entity.getContentLength());  
    253.                       BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(entity.getContent()));  
    254.                       String text = "";
    255.                       res.append(text);  
    256.                       while ((text = bufferedReader.readLine()) != null) {  
    257.                           res.append(text);  
    258.                           System.out.println(text);  
    259.                       }  
    260.                        
    261.                   }  
    262.                   EntityUtils.consume(entity);  
    263.               } finally {  
    264.                   response.close();  
    265.               }  
    266.           } finally {  
    267.               httpclient.close();  
    268.           }  
    269.           return  res.toString();  
    270.             
    271.     }
    272.       
    273.     //xml解析  
    274.     public static Map<String, String> doXMLParse(String strxml) throws Exception {  
    275.           strxml = strxml.replaceFirst("encoding=".*"", "encoding="UTF-8"");  
    276.           if(null == strxml || "".equals(strxml)) {  
    277.               return null;  
    278.           }  
    279.             
    280.           Map<String,String> m = new HashMap<String,String>();   
    281.           InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));  
    282.           SAXBuilder builder = new SAXBuilder();  
    283.           Document doc = builder.build(in);  
    284.           Element root = doc.getRootElement();  
    285.           List list = root.getChildren();  
    286.           Iterator it = list.iterator();  
    287.           while(it.hasNext()) {  
    288.               Element e = (Element) it.next();  
    289.               String k = e.getName();  
    290.               String v = "";  
    291.               List children = e.getChildren();  
    292.               if(children.isEmpty()) {  
    293.                   v = e.getTextNormalize();  
    294.               } else {  
    295.                   v = getChildrenText(children);  
    296.               }  
    297.                 
    298.               m.put(k, v);  
    299.           }  
    300.             
    301.           //关闭流  
    302.           in.close();   
    303.           return m;  
    304.     }  
    305.     
    306.     //xml解析  
    307.     public static SortedMap<String, String> doXMLParseWithSorted(String strxml) throws Exception {  
    308.           strxml = strxml.replaceFirst("encoding=".*"", "encoding="UTF-8"");  
    309.           if(null == strxml || "".equals(strxml)) {  
    310.               return null;  
    311.           }  
    312.             
    313.           SortedMap<String,String> m = new TreeMap<String,String>();   
    314.           InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));  
    315.           SAXBuilder builder = new SAXBuilder();  
    316.           Document doc = builder.build(in);  
    317.           Element root = doc.getRootElement();  
    318.           List list = root.getChildren();  
    319.           Iterator it = list.iterator();  
    320.           while(it.hasNext()) {  
    321.               Element e = (Element) it.next();  
    322.               String k = e.getName();  
    323.               String v = "";  
    324.               List children = e.getChildren();  
    325.               if(children.isEmpty()) {  
    326.                   v = e.getTextNormalize();  
    327.               } else {  
    328.                   v = getChildrenText(children);  
    329.               }  
    330.                 
    331.               m.put(k, v);  
    332.           }  
    333.             
    334.           //关闭流  
    335.           in.close();   
    336.           return m;  
    337.     }  
    338.       
    339.     public static String getChildrenText(List children) {  
    340.           StringBuffer sb = new StringBuffer();  
    341.           if(!children.isEmpty()) {  
    342.               Iterator it = children.iterator();  
    343.               while(it.hasNext()) {  
    344.                   Element e = (Element) it.next();  
    345.                   String name = e.getName();  
    346.                   String value = e.getTextNormalize();  
    347.                   List list = e.getChildren();  
    348.                   sb.append("<" + name + ">");  
    349.                   if(!list.isEmpty()) {  
    350.                       sb.append(getChildrenText(list));  
    351.                   }  
    352.                   sb.append(value);  
    353.                   sb.append("</" + name + ">");  
    354.               }  
    355.           }   
    356.           return sb.toString();  
    357.     }
    358. }
    修改微信ResponseHandler.java 

    1. package com.tenpay;
    2.  
    3.  
    4. import java.io.IOException;
    5. import java.io.PrintWriter;
    6. import java.io.UnsupportedEncodingException;
    7. import java.util.Iterator;
    8. import java.util.Map;
    9. import java.util.Set;
    10. import java.util.SortedMap;
    11. import java.util.TreeMap;
    12.  
    13. import javax.servlet.http.HttpServletRequest;
    14. import javax.servlet.http.HttpServletResponse;
    15.  
    16. import com.tenpay.util.MD5Util;
    17. import com.tenpay.util.TenpayUtil;
    18.  
    19. /**
    20.  * 
    21.  * @author miklchen
    22.  *
    23.  */
    24. public class ResponseHandler { 
    25.  
    26. 	private String key;
    27. 	
    28.  
    29. 	private SortedMap parameters; 
    30. 	
    31. 	
    32. 	private String debugInfo;
    33. 	
    34. 	private HttpServletRequest request;
    35. 	
    36. 	private HttpServletResponse response;
    37. 	
    38. 	private String uriEncoding;
    39. 	
    40. 	/**
    41. 	 * 
    42. 	 * @param request
    43. 	 * @param response
    44. 	 */
    45. 	public ResponseHandler(HttpServletRequest request,
    46. 			HttpServletResponse response)  {
    47. 		this.request = request;
    48. 		this.response = response;
    49.  
    50. 		this.key = "";
    51. 		this.parameters = new TreeMap();
    52. 		this.debugInfo = "";
    53. 		
    54. 		this.uriEncoding = "";
    55. 	}
    56. 	
    57. 	/**
    59. 	*/
    60. 	public String getKey() {
    61. 		return key;
    62. 	}
    63.  
    64. 	/**
    65. 	*
    66. 	*/
    67. 	public void setKey(String key) {
    68. 		this.key = key;
    69. 	}
    70.  
    71. 	/**
    72. 	 *ֵ
    73. 	 * @param parameter 
    74. 	 * @return String 
    75. 	 */
    76. 	public String getParameter(String parameter) {
    77. 		String s = (String)this.parameters.get(parameter); 
    78. 		return (null == s) ? "" : s;
    79. 	}
    80. 	
    81. 	/**
    82. 	 * @param parameter
    83. 	 * @param parameterValueֵ
    84. 	 */
    85. 	public void setParameter(String parameter, String parameterValue) {
    86. 		String v = "";
    87. 		if(null != parameterValue) {
    88. 			v = parameterValue.trim();
    89. 		}
    90. 		
    91. 		this.parameters.put(parameter, v);
    92. 	}
    93. 	
    94. 	/**
    95. 	 * 
    96. 	 * @return SortedMap
    97. 	 */
    98. 	public SortedMap getAllParameters() {
    99. 		return this.parameters;
    100. 	}
    101. 	
    102. 	public void setAllparamenters(SortedMap map){
    103. 		this.parameters = map;
    104. 	}
    105. 	
    106. 	/**
    107. 	 * 微信异步回调签名
    108. 	 * @return boolean
    109. 	 */
    110. 	public boolean isTenpaySign() {
    111. 		StringBuffer sb = new StringBuffer();
    112. 		Set es = this.parameters.entrySet();
    113. 		Iterator it = es.iterator();
    114. 		while(it.hasNext()) {
    115. 			Map.Entry entry = (Map.Entry)it.next();
    116. 			String k = (String)entry.getKey();
    117. 			String v = (String)entry.getValue();
    118. 			if(!"sign".equals(k) && null != v && !"".equals(v)) {
    119. 				sb.append(k + "=" + v + "&");
    120. 			}
    121. 		}
    122. 		
    123. 		sb.append("key="+this.getKey());
    124. 		String enc = TenpayUtil.getCharacterEncoding(this.request, this.response);
    125. 		String sign = MD5Util.MD5Encode(sb.toString(), enc).toLowerCase();
    126. 		
    127. 		String tenpaySign = this.getParameter("sign").toLowerCase();
    128. 		
    129. 		System.out.println("sign:"+sign+"      tenpaysign:"+tenpaySign);
    130. 		
    131. 		return tenpaySign.equals(sign);
    132. 	}
    133. 	
    134. 	/**
    135. 	 * 
    136. 	 * @throws IOException 
    137. 	 */
    138. 	public void sendToCFT(String msg) throws IOException {
    139. 		String strHtml = msg;
    140. 		PrintWriter out = this.getHttpServletResponse().getWriter();
    141. 		out.println(strHtml);
    142. 		out.flush();
    143. 		out.close();
    144.  
    145. 	}
    146. 	
    147. 	/**
    148. 	 *
    149. 	 * @return String
    150. 	 */
    151. 	public String getUriEncoding() {
    152. 		return uriEncoding;
    153. 	}
    154.  
    155. 	/**
    156. 	 * @param uriEncoding
    157. 	 * @throws UnsupportedEncodingException
    158. 	 */
    159. 	public void setUriEncoding(String uriEncoding)
    160. 			throws UnsupportedEncodingException {
    161. 		if (!"".equals(uriEncoding.trim())) {
    162. 			this.uriEncoding = uriEncoding;
    163.  
    164. 			
    165. 			String enc = TenpayUtil.getCharacterEncoding(request, response);
    166. 			Iterator it = this.parameters.keySet().iterator();
    167. 			while (it.hasNext()) {
    168. 				String k = (String) it.next();
    169. 				String v = this.getParameter(k);
    170. 				v = new String(v.getBytes(uriEncoding.trim()), enc);
    171. 				this.setParameter(k, v);
    172. 			}
    173. 		}
    174. 	}
    175.  
    176. 	/**
    177. 	
    178. 	*/
    179. 	public String getDebugInfo() {
    180. 		return debugInfo;
    181. 	}
    182. 	
    183. 	/**
    184. 	*
    185. 	*/
    186. 	protected void setDebugInfo(String debugInfo) {
    187. 		this.debugInfo = debugInfo;
    188. 	}
    189. 	
    190. 	protected HttpServletRequest getHttpServletRequest() {
    191. 		return this.request;
    192. 	}
    193. 	
    194. 	protected HttpServletResponse getHttpServletResponse() {
    195. 		return this.response;
    196. 	}
    197. 	
    198. }

    试试是不是已经可以发起异步回调了。记得key  在  微信支付 -》API安全  下面设置。





  • 相关阅读:
    java 线程 Lock 锁使用Condition实现线程的等待（await）与通知(signal)
    A计划(三维dfs)
    最少拦截系统(线性dp)
    疯狂的采药（完全背包）
    Modular Inverse （拓展欧几里得求逆元）
    斐波那契数列的3种求法及几种素数筛法
    Magic Odd Square （思维+构造）
    Marlin (思维)
    qdu_组队训练（ABCFIJK）
    2018蓝桥编程题6-9+ 50%的10
  • 原文地址：https://www.cnblogs.com/jpfss/p/9942630.html
Copyright © 2011-2022 走看看