xwgong

/**
 * Alipay.com Inc.
 * Copyright (c) 2005-2008 All Rights Reserved.
 */
package com.alipay.client.trade;

import java.io.IOException;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.security.Security;

import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.bouncycastle.jce.provider.BouncyCastleProvider;

import com.airplane.action.BackStageAction;
import com.alipay.client.base.PartnerConfig;
import com.alipay.client.security.RSASignature;
import com.alipay.client.util.StringUtil;

/**
 * 
 * 安全支付服務(wù)器端處理程序
 * 
 * 1.將業(yè)務(wù)參數(shù)：合作商戶ID、 外部交易號(hào)、商品名稱、商品的具體描述、商品總價(jià)、賣家?guī)簟otify_url這些參數(shù)按照固定順序簽名
 * 2.將簽名結(jié)果返回客戶端
 * @author 3Y
 */
public class RSATrade extends HttpServlet {

    private static final long serialVersionUID = -3035307235076650766L;
    private static Log logger = LogFactory.getLog(RSATrade.class);
    static {
          Security.addProvider(new BouncyCastleProvider());
       }
    String basePath="";
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws IOException {
        System.out.println("request in");
        response.setCharacterEncoding("utf-8");
        PrintWriter out = response.getWriter();
        logger.info("here");
        //得到應(yīng)用服務(wù)器地址
        String path = request.getContextPath();
        basePath = request.getScheme() + "://" + request.getLocalAddr() + ":"
                                   + request.getServerPort() + path + "/";
        logger.info("here1");
        String strReString="";
        //檢查商戶PartnerConfig.java文件的配置參數(shù)
        logger.info(checkInfo());
        if(!checkInfo()){
            strReString="<result><is_success>F</is_success><error>缺少partner或者seller," +
                    "請(qǐng)?jiān)赾om/alipay/client/base/PartnerConfig.java中增加</error></result>";
            out.print(strReString);
            return;
        }
        
        String signData=getSignDate(request);
        String sign = sign(signData,PartnerConfig.RSA_PRIVATE);
        signData = URLEncoder.encode(signData,"utf-8");
         sign = URLEncoder.encode(sign,"utf-8");
        logger.info(signData);
        logger.info(sign);
        //返回待簽名數(shù)據(jù)和簽名數(shù)據(jù)
        strReString="<result><is_success>T</is_success><content>"+signData+"</content><sign>"+sign+"</sign></result>";
        logger.info(strReString);
        //對(duì)返回客戶端的數(shù)據(jù)encode
        out.print(strReString); 
        return;
    }
    
    

    //檢查商戶PartnerConfig.java文件的配置參數(shù)
    private boolean checkInfo() {
        String partner = PartnerConfig.PARTNER;
        String seller = PartnerConfig.SELLER;
        //如果合作商戶ID為空或者賬號(hào)ID為空返回false
        if (StringUtil.isBlank(partner) || StringUtil.isBlank(seller))
            return false;
        
        return true;
    }
    
    
    /**
     * 準(zhǔn)備待簽名的數(shù)據(jù)
     * 
     * @param request
     * @return
     * @throws UnsupportedEncodingException
     */
    private String getSignDate(
            HttpServletRequest request) throws UnsupportedEncodingException {
        request.setCharacterEncoding("utf-8");
        
        //合作商戶ID
        String partner = PartnerConfig.PARTNER;
        //賣家?guī)ぬ?hào)
        String seller = PartnerConfig.SELLER;
     // 外部交易號(hào) 這里取當(dāng)前時(shí)間，商戶可根據(jù)自己的情況修改此參數(shù)，但保證唯一性
        String outTradeNo = System.currentTimeMillis() + "";
        String opt = request.getParameter("opt").trim();
        String user_id = request.getParameter("user_id").trim();
        //opt:0為支付,1為充值
        if("0".equals(opt)){
            outTradeNo = request.getParameter("order_id").trim();
        }else if("1".equals(opt)){
            outTradeNo = System.currentTimeMillis() + "";
        }
        
        // 商品名稱
        String subject = request.getParameter("subject").trim();
        // 商品具體描述
        String body = request.getParameter("body").trim();
        // 商品總價(jià)
        String totalFee = request.getParameter("total_fee").trim();
        // 接收支付寶發(fā)送的通知的url 商戶可根據(jù)自己的情況修改此參數(shù)
        String notify_url = basePath+"servlet/RSANotifyReceiver?opt=" + opt +"&order_id="+outTradeNo+"&user_id="+user_id+"&payMoney="+totalFee;
        
        //組裝待簽名數(shù)據(jù)
        String signData = "partner=" + "\"" + partner + "\"";
        signData += "&";
        signData += "seller=" + "\"" + seller + "\"";
        signData += "&";
        signData += "out_trade_no=" + "\"" + outTradeNo + "\"";
        signData += "&";
        signData += "subject=" + "\"" + subject+ "\"";
        signData += "&";
        signData += "body=" + "\"" + body + "\"";
        signData += "&";
        signData += "total_fee=" + "\""+ totalFee + "\"";
        signData += "&";
        signData += "notify_url=" + "\""+notify_url+ "\"";
        return signData;
    }

    
    
    /**
     * 對(duì)參數(shù)進(jìn)行簽名
     * 
     * @param signData 待簽名數(shù)據(jù)，key rsa商戶私鑰
     * @return
     */
    private String sign(String signData,String key) {
        System.out.println("signData:"+signData);
        String sign = "";
        try {
            sign = RSASignature.sign(signData, key);
        } catch (Exception e1) {
            e1.printStackTrace();
        }
        return sign;
    }

    
}
RSATrade.java為客戶端與服務(wù)器端為商品信息進(jìn)行的簽名操作,簽名完成之后服務(wù)器會(huì)將簽名信息以及回調(diào)地址返給客戶端.客戶端拿到回調(diào)地址交給支付寶進(jìn)行回調(diào).
支付寶流程為:客戶端在支付寶支付之前請(qǐng)求RSATrade.java,此時(shí)服務(wù)器為商品信息注冊(cè)簽名,簽名完成之后服務(wù)器把簽名過(guò)的商品信息和支付寶的回調(diào)地址(RSANotifyReceiver
)和參數(shù)傳給客戶端,客戶端會(huì)把回調(diào)地址和簽過(guò)名的商品信息交給支付寶,支付寶在完成支付之后請(qǐng)求回調(diào)地址,進(jìn)行簽名和公鑰驗(yàn)證,驗(yàn)證成功即可執(zhí)行持久化操作.若操作成功,客戶端會(huì)請(qǐng)求RSACallBack.java類,進(jìn)行客戶端與服務(wù)器端的同步操作.