package com.wqy; 
 
import java.io.IOException; 
import java.io.OutputStream; 
import java.util.HashMap; 
import java.util.Iterator; 
import java.util.Map; 
import java.util.Set; 
import java.util.SortedMap; 
import java.util.TreeMap; 
 
import javax.servlet.ServletException; 
import javax.servlet.annotation.WebServlet; 
import javax.servlet.http.HttpServlet; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 
 
import org.apache.log4j.Logger; 
 
import com.google.zxing.BarcodeFormat; 
import com.google.zxing.EncodeHintType; 
import com.google.zxing.MultiFormatWriter; 
import com.google.zxing.WriterException; 
import com.google.zxing.client.j2se.MatrixToImageWriter; 
import com.google.zxing.common.BitMatrix; 
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel; 
import com.wqy.util.PayCommonUtil; 
import com.wqy.util.PayConfigUtil; 
 
/** 
 * Servlet implementation class Pay1 
 */ 
@WebServlet("/Pay1") 
public class Pay1 extends HttpServlet { 
  private static final long serialVersionUID = 1L; 
  private static Logger logger = Logger.getLogger(Pay1.class); 
   
  public static int defaultWidthAndHeight=200; 
   
  /** 
   * @see HttpServlet#HttpServlet() 
   */ 
  public Pay1() { 
    super(); 
    // TODO Auto-generated constructor stub 
  } 
 
  /** 
   * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doGet(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
     
    // TODO Auto-generated method stub 
    String nonce_str = PayCommonUtil.getNonce_str(); 
    long time_stamp = System.currentTimeMillis() / 1000; 
    String product_id = "hd_goodsssss_10"; 
    String key = PayConfigUtil.API_KEY; // key 
     
    SortedMap<Object, Object> packageParams = new TreeMap<Object, Object>(); 
    packageParams.put("appid", PayConfigUtil.APP_ID); 
    packageParams.put("mch_id", PayConfigUtil.MCH_ID); 
    packageParams.put("time_stamp", String.valueOf(time_stamp)); 
    packageParams.put("nonce_str", nonce_str); 
    packageParams.put("product_id", product_id); 
    String sign = PayCommonUtil.createSign("UTF-8", packageParams,key);//MD5哈希 
    packageParams.put("sign", sign);  
     
    //生成参数 
    String str = ToUrlParams(packageParams); 
    String payurl = "weixin://wxpay/bizpayurl?" + str; 
    logger.info("payurl:"+payurl); 
     
     
    //生成二维码 
    Map<EncodeHintType, Object> hints=new HashMap<EncodeHintType, Object>(); 
    // 指定纠错等级  
    hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.L);  
    // 指定编码格式  
    hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");  
    hints.put(EncodeHintType.MARGIN, 1); 
    try { 
      BitMatrix bitMatrix = new MultiFormatWriter().encode(payurl,BarcodeFormat.QR_CODE, defaultWidthAndHeight, defaultWidthAndHeight, hints); 
      OutputStream out = response.getOutputStream(); 
      MatrixToImageWriter.writeToStream(bitMatrix, "png", out);//输出二维码 
      out.flush(); 
      out.close(); 
       
    } catch (WriterException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    } 
  } 
   
  public String ToUrlParams(SortedMap<Object, Object> packageParams){ 
    //实际可以不排序 
    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 (null != v && !"".equals(v)) {  
        sb.append(k + "=" + v + "&");  
      }  
    } 
     
    sb.deleteCharAt(sb.length()-1);//删掉最后一个& 
    return sb.toString(); 
  } 
 
  /** 
   * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doPost(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
    // TODO Auto-generated method stub 
    doGet(request, response); 
  } 
 
} 

package com.wqy; 
 
import java.io.BufferedOutputStream; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.util.SortedMap; 
import java.util.TreeMap; 
 
import javax.servlet.ServletException; 
import javax.servlet.annotation.WebServlet; 
import javax.servlet.http.HttpServlet; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 
 
import org.apache.log4j.Logger; 
 
import com.wqy.util.HttpUtil; 
import com.wqy.util.PayCommonUtil; 
import com.wqy.util.PayConfigUtil; 
 
/** 
 * Servlet implementation class Notify1 
 */ 
@WebServlet("/Notify1") 
public class Notify1 extends HttpServlet { 
  private static final long serialVersionUID = 1L; 
  private static Logger logger = Logger.getLogger(Notify1.class); 
 
  /** 
   * @see HttpServlet#HttpServlet() 
   */ 
  public Notify1() { 
    super(); 
    // TODO Auto-generated constructor stub 
  } 
 
  /** 
   * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doGet(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
    // TODO Auto-generated method stub 
 
    // 读取xml 
    InputStream inputStream; 
    StringBuffer sb = new StringBuffer(); 
    inputStream = request.getInputStream(); 
    String s; 
    BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8")); 
    while ((s = in.readLine()) != null) { 
      sb.append(s); 
    } 
    in.close(); 
    inputStream.close(); 
     
    SortedMap<Object, Object> packageParams = PayCommonUtil.xmlConvertToMap(sb.toString()); 
    logger.info(packageParams);  
     
    // 账号信息 
    String key = PayConfigUtil.API_KEY; // key 
     
    String resXml="";//反馈给微信服务器 
    // 验签 
    if (PayCommonUtil.isTenpaySign("UTF-8", packageParams, key)) { 
      //appid openid mch_id is_subscribe nonce_str product_id sign 
       
      //统一下单 
      String openid = (String)packageParams.get("openid"); 
      String product_id = (String)packageParams.get("product_id"); 
      //解析product_id，计算价格等 
       
      String out_trade_no = String.valueOf(System.currentTimeMillis()); // 订单号  
      String order_price = "1"; // 价格  注意：价格的单位是分  
      String body = product_id;  // 商品名称 这里设置为product_id 
      String attach = "XXX店"; //附加数据 
       
      String nonce_str0 = PayCommonUtil.getNonce_str(); 
       
      // 获取发起电脑 ip  
      String spbill_create_ip = PayConfigUtil.CREATE_IP;   
      String trade_type = "NATIVE";  
       
       
      SortedMap<Object,Object> unifiedParams = new TreeMap<Object,Object>();  
      unifiedParams.put("appid", PayConfigUtil.APP_ID); // 必须 
      unifiedParams.put("mch_id", PayConfigUtil.MCH_ID); // 必须 
      unifiedParams.put("out_trade_no", out_trade_no); // 必须 
      unifiedParams.put("product_id", product_id); 
      unifiedParams.put("body", body); // 必须 
      unifiedParams.put("attach", attach); 
      unifiedParams.put("total_fee", order_price); // 必须  
      unifiedParams.put("nonce_str", nonce_str0); // 必须 
      unifiedParams.put("spbill_create_ip", spbill_create_ip); // 必须  
      unifiedParams.put("trade_type", trade_type); // 必须  
      unifiedParams.put("openid", openid);  
      unifiedParams.put("notify_url", PayConfigUtil.NOTIFY_URL);//异步通知url 
       
      String sign0 = PayCommonUtil.createSign("UTF-8", unifiedParams,key);  
      unifiedParams.put("sign", sign0); //签名 
       
      String requestXML = PayCommonUtil.getRequestXml(unifiedParams);  
      logger.info(requestXML); 
      //统一下单接口 
      String rXml = HttpUtil.postData(PayConfigUtil.UFDODER_URL, requestXML);  
       
      //统一下单响应 
      SortedMap<Object, Object> reParams = PayCommonUtil.xmlConvertToMap(rXml); 
      logger.info(reParams);  
       
      //验签 
      if (PayCommonUtil.isTenpaySign("UTF-8", reParams, key)) { 
        // 统一下单返回的参数 
        String prepay_id = (String)reParams.get("prepay_id");//交易会话标识 2小时内有效 
         
        String nonce_str1 = PayCommonUtil.getNonce_str(); 
         
        SortedMap<Object,Object> resParams = new TreeMap<Object,Object>();  
        resParams.put("return_code", "SUCCESS"); // 必须 
        resParams.put("return_msg", "OK"); 
        resParams.put("appid", PayConfigUtil.APP_ID); // 必须 
        resParams.put("mch_id", PayConfigUtil.MCH_ID); 
        resParams.put("nonce_str", nonce_str1); // 必须 
        resParams.put("prepay_id", prepay_id); // 必须 
        resParams.put("result_code", "SUCCESS"); // 必须 
        resParams.put("err_code_des", "OK"); 
         
        String sign1 = PayCommonUtil.createSign("UTF-8", resParams,key);  
        resParams.put("sign", sign1); //签名 
         
        resXml = PayCommonUtil.getRequestXml(resParams); 
        logger.info(resXml); 
         
      }else{ 
        logger.info("签名验证错误"); 
        resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"  
            + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";  
      } 
       
    }else{ 
      logger.info("签名验证错误"); 
      resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"  
          + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";  
    } 
 
    //------------------------------  
    //处理业务完毕  
    //------------------------------  
    BufferedOutputStream out = new BufferedOutputStream(  
        response.getOutputStream());  
    out.write(resXml.getBytes());  
    out.flush();  
    out.close();  
     
  } 
 
  /** 
   * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doPost(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
    // TODO Auto-generated method stub 
    doGet(request, response); 
  } 
 
} 

package com.wqy; 
 
import java.io.BufferedOutputStream; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.util.SortedMap; 
 
import javax.servlet.ServletException; 
import javax.servlet.annotation.WebServlet; 
import javax.servlet.http.HttpServlet; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 
 
import org.apache.log4j.Logger; 
 
import com.wqy.util.PayCommonUtil; 
import com.wqy.util.PayConfigUtil; 
 
/** 
 * Servlet implementation class Re_notify 
 */ 
@WebServlet("/Re_notify") 
public class Re_notify extends HttpServlet { 
  private static final long serialVersionUID = 1L; 
  private static Logger logger = Logger.getLogger(Re_notify.class); 
 
  /** 
   * @see HttpServlet#HttpServlet() 
   */ 
  public Re_notify() { 
    super(); 
    // TODO Auto-generated constructor stub 
  } 
 
  /** 
   * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doGet(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
    // TODO Auto-generated method stub 
    // 读取参数 
    InputStream inputStream; 
    StringBuffer sb = new StringBuffer(); 
    inputStream = request.getInputStream(); 
    String s; 
    BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8")); 
    while ((s = in.readLine()) != null) { 
      sb.append(s); 
    } 
    in.close(); 
    inputStream.close(); 
 
    SortedMap<Object, Object> packageParams = PayCommonUtil.xmlConvertToMap(sb.toString()); 
    logger.info(packageParams); 
 
    // 账号信息 
    String key = PayConfigUtil.API_KEY; // key 
 
    String resXml = ""; // 反馈给微信服务器 
    // 判断签名是否正确 
    if (PayCommonUtil.isTenpaySign("UTF-8", packageParams, key)) { 
      // ------------------------------ 
      // 处理业务开始 
      // ------------------------------ 
      if ("SUCCESS".equals((String) packageParams.get("result_code"))) { 
        // 这里是支付成功 
        ////////// 执行自己的业务逻辑//////////////// 
        String mch_id = (String) packageParams.get("mch_id"); 
        String openid = (String) packageParams.get("openid"); 
        String is_subscribe = (String) packageParams.get("is_subscribe"); 
        String out_trade_no = (String) packageParams.get("out_trade_no"); 
 
        String total_fee = (String) packageParams.get("total_fee"); 
 
        logger.info("mch_id:" + mch_id); 
        logger.info("openid:" + openid); 
        logger.info("is_subscribe:" + is_subscribe); 
        logger.info("out_trade_no:" + out_trade_no); 
        logger.info("total_fee:" + total_fee); 
 
        ////////// 执行自己的业务逻辑//////////////// 
 
        logger.info("支付成功"); 
        // 通知微信.异步确认成功.必写.不然会一直通知后台.八次之后就认为交易失败了. 
        resXml = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>" 
            + "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> "; 
 
      } else { 
        logger.info("支付失败,错误信息：" + packageParams.get("err_code")); 
        resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>" 
            + "<return_msg><![CDATA[报文为空]]></return_msg>" + "</xml> "; 
      } 
 
    } else { 
      logger.info("签名验证错误"); 
      resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"  
          + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";  
    } 
 
    // ------------------------------ 
    // 处理业务完毕 
    // ------------------------------ 
    BufferedOutputStream out = new BufferedOutputStream(response.getOutputStream()); 
    out.write(resXml.getBytes()); 
    out.flush(); 
    out.close(); 
  } 
 
  /** 
   * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse 
   *   response) 
   */ 
  protected void doPost(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
    // TODO Auto-generated method stub 
    doGet(request, response); 
  } 
 
}