财付通支付demo完整代码

package com.demodashi.pay.web; import java.io.BufferedOutputStream; import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.util.HashMap; import java.util.Hashtable; import java.util.Iterator; import java.util.Map; import java.util.SortedMap; import java.util.TreeMap; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.view.RedirectView; import com.demodashi.pay.client.ClientResponseHandler; import com.demodashi.pay.client.TenpayHttpClient; import com.demodashi.pay.entity.UserVO; import com.demodashi.pay.util.PayConfigUtil; import com.demodashi.pay.util.RequestHandler; import com.demodashi.pay.util.ResponseHandler; import com.demodashi.pay.util.TenpayUtil; import com.demodashi.pay.util.XMLUtil; import com.google.zxing.BarcodeFormat; import com.google.zxing.EncodeHintType; import com.google.zxing.MultiFormatWriter; import com.google.zxing.WriterException; import com.google.zxing.common.BitMatrix; /** * 财付通支付测试 * * @author Javid */ @Controller public class PayController extends BaseController { /** * * @date 2017年6月30日 上午11:35:05 * @author javid * @Description: 财付通支付测试 * @param request * @param response * @return * @throws UnsupportedEncodingException * */ @RequestMapping("/pay.do") @ResponseBody public ModelAndView pay(HttpServletRequest request, HttpServletResponse response) throws UnsupportedEncodingException { // 创建支付请求对象 RequestHandler reqHandler = new RequestHandler(request, response); // 设置密钥 reqHandler.setKey(PayConfigUtil.KEY); // 设置支付网关 reqHandler.setGateUrl(PayConfigUtil.GateUrl); // 请求URL // 设置支付参数 reqHandler.setParameter("partner", PayConfigUtil.PARTNER); // 商户号 reqHandler.setParameter("body", "测试"); // 商品描述 reqHandler.setParameter("out_trade_no", PayConfigUtil.OUT_TRADE_NO); // 订单编号 reqHandler.setParameter("total_fee", PayConfigUtil.TOTAL_FEE); // 价格的单位为分 reqHandler.setParameter("spbill_create_ip", PayConfigUtil.SPBILL_CREATE_IP); // 终端IP reqHandler.setParameter("input_charsetParameter", "UTF-8"); // 字符编码 reqHandler.setParameter("sign_key_index", "1"); // 密钥序号 reqHandler.setParameter("bank_type", "DEFAULT"); // 银行类型(中介担保时此参数无效) reqHandler.setParameter("fee_type", "1"); // 币种，1人民币 reqHandler.setParameter("return_url", PayConfigUtil.RETURN_URL); // 支付成功跳转URL reqHandler.setParameter("notify_url", PayConfigUtil.NOTIFY_URL); // 回调URL // 系统可选参数 reqHandler.setParameter("sign_type", "MD5"); // 签名类型,默认：MD5 reqHandler.setParameter("service_version", "1.0"); // 版本号，默认为1.0 reqHandler.setParameter("input_charset", "UTF-8"); // 字符编码 reqHandler.setParameter("sign_key_index", "1"); // 密钥序号 // 业务可选参数 reqHandler.setParameter("attach", ""); // 附加数据，原样返回 reqHandler.setParameter("product_fee", ""); // 商品费用，必须保证transport_fee + // product_fee=total_fee reqHandler.setParameter("transport_fee", "0"); // 物流费用，必须保证transport_fee // + // product_fee=total_fee reqHandler.setParameter("time_start", TenpayUtil.getCurrTime()); // 订单生成时间，格式为yyyymmddhhmmss reqHandler.setParameter("time_expire", ""); // 订单失效时间，格式为yyyymmddhhmmss reqHandler.setParameter("buyer_id", ""); // 买方财付通账号 reqHandler.setParameter("goods_tag", ""); // 商品标记 reqHandler.setParameter("trade_mode", "1"); // 交易模式，1即时到账(默认)，2中介担保，3后台选择（买家进支付中心列表选择） reqHandler.setParameter("transport_desc", ""); // 物流说明 reqHandler.setParameter("trans_type", "1"); // 交易类型，1实物交易，2虚拟交易 reqHandler.setParameter("agentid", ""); // 平台ID reqHandler.setParameter("agent_type", ""); // 代理模式，0无代理(默认)，1表示卡易售模式，2表示网店模式 reqHandler.setParameter("seller_id", ""); // 卖家商户号，为空则等同于partner // 请求的url String requestUrl = reqHandler.getRequestURL(); // 获取debug信息,建议把请求和debug信息写入日志，方便定位问题 String debuginfo = reqHandler.getDebugInfo(); return new ModelAndView(new RedirectView(requestUrl)); } /** * * @date 2017年6月30日 上午11:53:13 * @author javid * @Description: 财付通后台通知回调 * @param request * @param response * @throws Exception * */ @RequestMapping("/payNotify") public void payNotify(HttpServletRequest request, HttpServletResponse response) throws Exception { // 创建支付应答对象 ResponseHandler resHandler = new ResponseHandler(request, response); resHandler.setKey(PayConfigUtil.KEY); System.out.println("后台回调返回参数:" + resHandler.getAllParameters()); // 判断签名 if (resHandler.isTenpaySign()) { // 通知id String notify_id = resHandler.getParameter("notify_id"); // 创建请求对象 RequestHandler queryReq = new RequestHandler(null, null); // 通信对象 TenpayHttpClient httpClient = new TenpayHttpClient(); // 应答对象 ClientResponseHandler queryRes = new ClientResponseHandler(); // 通过通知ID查询，确保通知来至财付通 queryReq.init(); queryReq.setKey(PayConfigUtil.KEY); queryReq.setGateUrl("https://gw.tenpay.com/gateway/simpleverifynotifyid.xml"); queryReq.setParameter("partner", PayConfigUtil.PARTNER); queryReq.setParameter("notify_id", notify_id); // 通信对象 httpClient.setTimeOut(5); // 设置请求内容 httpClient.setReqContent(queryReq.getRequestURL()); System.out.println("验证ID请求字符串:" + queryReq.getRequestURL()); // 后台调用 if (httpClient.call()) { // 设置结果参数 queryRes.setContent(httpClient.getResContent()); System.out.println("验证ID返回字符串:" + httpClient.getResContent()); queryRes.setKey(PayConfigUtil.KEY); // 获取id验证返回状态码，0表示此通知id是财付通发起 String retcode = queryRes.getParameter("retcode"); // 商户订单号 String out_trade_no = resHandler.getParameter("out_trade_no"); // 财付通订单号 String transaction_id = resHandler.getParameter("transaction_id"); // 金额,以分为单位 String total_fee = resHandler.getParameter("total_fee"); // 如果有使用折扣券，discount有值，total_fee+discount=原请求的total_fee String discount = resHandler.getParameter("discount"); // 支付结果 String trade_state = resHandler.getParameter("trade_state"); // 交易模式，1即时到账，2中介担保 String trade_mode = resHandler.getParameter("trade_mode"); // 判断签名及结果 if (queryRes.isTenpaySign() && "0".equals(retcode)) { System.out.println("id验证成功"); if ("1".equals(trade_mode)) { // 即时到账 if ("0".equals(trade_state)) { // ------------------------------ // 即时到账处理业务开始 // ------------------------------ // 处理数据库逻辑 // 注意交易单不要重复处理 // �