設計模式的應用-策略模式實現支付方式回調策略

時間  2019-11-17
標籤 設計 模式 應用 策略 實現 支付 方式 简体版
原文   原文鏈接

簡單瞭解下支付流程

支付寶支付流程git

支付寶支付liuc

微信掃碼支付流程服務器

微信掃碼支付流程

項目代碼查看：https://git.oschina.net/lkqm/ploy微信

重構前的代碼：

Servlet

如下代碼有點亂，看註釋，瞭解這個步驟便可，執行回調的Servlet:app

支付寶異步

/**
 * 支付結果回調Servlet
 *
 * @author 
 */

@WebServlet("/pay/notify/alipay.do")
public class AlipayNotifyServlet extends HttpServlet {

    private static final long serialVersionUID = 8158440606464368180L;

    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws IOException, ServletException {

        // 1.得到支付寶服務器post過來的參數
        Map<String, String> params = new HashMap<String, String>();
        Map<String, String[]> requestParams = request.getParameterMap();
        for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext(); ) {
            String name = (String) iter.next();
            String[] values = (String[]) requestParams.get(name);
            String valueStr = "";
            for (int i = 0; i < values.length; i++) {
                valueStr = (i == values.length - 1) ? valueStr + values[i]
                        : valueStr + values[i] + ",";
            }
            params.put(name, valueStr);
        }

        // 2.驗證參數的合法性（根據簽名驗證保證數據時，從支付寶平臺的數據）
        boolean verify_result = AlipayNotify.verify(params);
        String trade_status = request.getParameter("trade_status");
        if (verify_result
                && (trade_status.equals("TRADE_FINISHED") || trade_status
                .equals("TRADE_SUCCESS"))) {
            try {
                // 3.支付成功，執行業務邏輯
                String out_trade_no = request.getParameter("out_trade_no");
                String total_fee = request.getParameter("total_fee");
                // 修改訂單狀態
                UserService userService = ServiceFactory.getService(UserService.class);
                userService.paySuccess(out_trade_no,
                        String.valueOf(total_fee),
                        String.valueOf(Order.PAY_WAY_ALIPAY));
                response.reset();
                PrintWriter out = response.getWriter();
                // 4.返回執行成功的標識與支付寶服務器通訊，不然支付寶服務器會屢次再POST數據
                out.print("SUCCESS");
                out.flush();
            } catch (ServiceFailedException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

微信ide

/**
 * 微信支付回調地址
 * 
 * @author 
 * 
 */
public class WechatpayNotifyServlet extends HttpServlet {

    private static final long serialVersionUID = 8158440606464368180L;
    private UserService userService = ServiceFactory.getService(UserService.class);

    public void doPost(HttpServletRequest request,HttpServletResponse response) throws IOException{  
        
        // 1. 得到請求參數（用戶支付成功後，微信服務器post數據過來）
        InputStream inputStream = request.getInputStream();  
        BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));  
        StringBuilder sb = new StringBuilder();  
        String s ;  
        while ((s = in.readLine()) != null){  
            sb.append(s);  
        }  
        in.close();  
        inputStream.close();  
  
        //解析xml成map
        Map<String, String> parameterMap = null;
        try {
            parameterMap = XMLUtil.doXMLParse(sb.toString());
        } catch (JDOMException e1) {
            e1.printStackTrace();
        }  
          
        //過濾空 設置 TreeMap  
        SortedMap<Object,Object> packageParams = new TreeMap<Object,Object>();        
        Iterator<String> it = parameterMap.keySet().iterator();  
        while (it.hasNext()) {  
            String parameter = it.next();  
            String parameterValue = parameterMap.get(parameter);  
              
            String v = "";  
            if(null != parameterValue) {  
                v = parameterValue.trim();  
            }  
            packageParams.put(parameter, v);  
        }
          
        // 帳號信息  
        String key = PayConfigUtil.API_KEY; // key  
  
        //2. 判斷簽名是否正確  
        if(PayCommonUtil.isTenpaySign("UTF-8", packageParams,key)) {  
            //------------------------------  
            //處理業務開始  
            //------------------------------  
            String resXml = "";  
            if("SUCCESS".equals(packageParams.get("result_code"))){  
                // 3.這裏是支付成功  
                //////////執行本身的業務邏輯////////////////  
                String out_trade_no = (String)packageParams.get("out_trade_no");  
                String total_fee = (String)packageParams.get("total_fee"); 
                try{
                    double money = Integer.valueOf(total_fee)/100.0;  // 分轉化爲員
                    userService.paySuccess(out_trade_no, String.valueOf(money), String.valueOf(Order.PAY_WAY_WECHAT));
                } catch(ServiceFailedException e) {
                    e.printStackTrace();
                } catch(Exception e) {
                    e.printStackTrace();
                }
                  
                //////////執行本身的業務邏輯////////////////  
                  
                //4. 通知微信.異步確認成功.必寫.否則會一直通知後臺.八次以後就認爲交易失敗了.  
                resXml = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>"  
                        + "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";  
                  
            } else {  
                System.out.println("支付失敗,錯誤信息：" + packageParams.get("err_code"));  
                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();  
        } else{  
            System.out.println("通知簽名驗證失敗");  
        }
          
    }  

}

開始重構

上面兩個Servlet像極了，獲取請求數據，驗證數據，支付成功判斷，執行成功業務邏輯...，這不是模版模式的應用嗎？對，可是這裏先用策略模式重構下支付回調的問題！！！工具

定義一個支付工具類PayNotifyUtil執行以上步驟，將具體怎麼執行交給策略類來作，AliPayNotifyPloyImpl和WeChatPayNotifyPloyImpl, 這樣在Servlet中就無須關心是什麼支付平臺回調的。post

目錄結構

類結構

Servlet代碼

只須要關注使用的什麼支付策略！！！測試

**
 * 支付寶支付回調通知
 */
@WebServlet("/pay/notify/alipay.do")
public class AlipayNotifyServlet extends HttpServlet {

    @Override
    public void service(HttpServletRequest request, HttpServletResponse response)
            throws IOException, ServletException {
        // 1. 得到支付策略
        PayNotifyPloy payNotifyPloy = new AliPayNotifyPloyImpl();
        PayNotifyUtil payNotifyUtil = new PayNotifyUtil(payNotifyPloy);
        // 2. 得到請求參數
        Map<String, String> payInfo = payNotifyUtil.loadPayData(request);
        // 3. 驗證支付數據
        String result="";
        if( !payNotifyUtil.verifyData(payInfo)) {
            System.out.println("驗證失敗");
        } else if (!payNotifyUtil.isPaySuccess(payInfo) ) {
            // 支付失敗
            result = payNotifyUtil.getFailedResponseData();
        } else {
            //4. 執行業務邏輯
            OrderMode orderMode = payNotifyUtil.getServiceMode(payInfo);
            // 修改訂單狀態
            UserService userService = ServiceFactory.getService(UserService.class);
            try {
                userService.paySuccess(orderMode.getTradeNo(), orderMode.getTotalFee(), PayWayEnum.ALIPAY);
                // 支付成功數據
                result = payNotifyUtil.getSuccessfulResponseData();
            } catch (Exception e) {
                // 邏輯執行失敗，等同於支付失敗，因此返回失敗數據
                result = payNotifyUtil.getFailedResponseData();
            }
        }

        response.reset();
        PrintWriter out = response.getWriter();
        // 返回數據
        out.print(result);
        out.flush();
    }
}

未來的某一天，須要增長微信支付功能，對應微信支付回調，只須要copy上面代碼而後，修改策略的實現類便可。微信支付

這個時候IDEA IDE提示發現---WeChatPayNotifyServlet和AliPayNotifyServlet代碼重複，是時候應用使用模版方法重構了

PayNotifyUtil工具類

/**
 * 支付之付款工具類
 * Created by  on 2017/2/25.
 */
public class PayNotifyUtil {

    // 支付策略
    private PayNotifyPloy payNotifyPloy;

    public PayNotifyUtil(PayNotifyPloy payNotifyPloy) {
        this.payNotifyPloy = payNotifyPloy;
    }

    // 加載支付信息
    public Map<String, String> loadPayData(HttpServletRequest request) throws IOException {
        return payNotifyPloy.loadPayInfo(request);
    }

    // 驗證參數
    public boolean verifyData(Map<String, String> postData) {
        return payNotifyPloy.verifyData(postData);
    }

    // 判斷是否支付成功
    public boolean isPaySuccess(Map<String, String> data) {
        return payNotifyPloy.isPaySuccess(data);
    }

    // 得到支付成功的返回數據
    public String getSuccessfulResponseData() {
        return payNotifyPloy.getSuccessfulResponseData();
    }

    // 得到支付失敗的返回數據
    public String getFailedResponseData() {
        return payNotifyPloy.getFailedResponseData();
    }

    // 得到業務結果須要的數據
    public OrderMode getServiceMode(Map<String, String> params) {
        return payNotifyPloy.getServiceMode(params);
    }
}

策略接口

/**
 * 支付回調策略接口
 * Created by  on 2017/2/25.
 */
public interface PayNotifyPloy {

    // 加載支付回調信息
    Map<String, String> loadPayInfo(HttpServletRequest request) throws IOException;

    // 得到返回給支付平臺表明成功的
    String getSuccessfulResponseData();

    // 得到返回給支付平臺表明失敗
    String getFailedResponseData();

    // 判斷是否支付成功
    boolean isPaySuccess(Map<String, String> data);

    // 驗證數據的合法性
    boolean verifyData(Map<String, String> postData);

    // 得到須要的信息（好比支付的訂單號、支付的金額）
    OrderMode getServiceMode(Map<String, String> params);
}

如今你能夠定義你的具體平臺的實現類了！！！

總結

因爲經驗不足和對支付平臺每種支付方式的接口瞭解不詳細，重構的代碼還有不少細節不足，好比異常的設計，代碼已經傳在git上,供參考，並求指點：https://git.oschina.net/lkqm/ploy

注： 重構後的支付回調代碼未測試

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程