策略模式实现多种支付方式

使用策略模式优雅的实现多种支付方式（支付宝、微信），或者多种支付场景（订单、维修金）的业务，且方便扩展。

下例是使用注解配合反射方式，扫描到所有的具体的支付策略并放到map集合中，然后根据前端传递来的支付类型参数，选择对应的支付策略，完成支付过程。

如上图：

PayStrategy是支付策略接口；

OrderPay（订单支付），RepairPay（维修金支付）是具体的支付策略（支付场景）；

AbstractPayService是实现PayStrategy接口的抽象类，规定了支付的流程，在其中选择具体的支付策略，为controller提供支付接口；

PayServiceImpl实现AbstractPayService中规定的支付流程的具体步骤，通过PayStrategyFactory获取实际的支付策略class，通过BeansUtil返回spring容器中的策略实现类bean；

PayStrategyFactory通过扫描被Pay注解注释的类，获得所有支付策略的类型和class；

Pay注解表名被注解的类是一个具体的支付策略，可以设置支付类型。

具体代码如下：

PayStrategy

package com.zhya.strategy.service;

/**
 * 支付策略
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
public interface PayStrategy {

    /**
     * 支付前准备支付参数
     *
     * @param payFor
     * @return
     */
    boolean prePay(String payFor);

    /**
     * 支付后处理支付回调结果
     *
     * @param payFor
     * @param isPaySuccess
     */
    void afterPay(String payFor, boolean isPaySuccess);
}

Pay注解

package com.zhya.strategy.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 支付策略
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface Pay {
    /**
     * 支付类型
     *
     * @return
     */
    String value();
}

OrderPay订单支付

package com.zhya.strategy.service.impl;

import com.zhya.strategy.annotation.Pay;
import com.zhya.strategy.service.PayStrategy;
import org.springframework.stereotype.Service;

/**
 * 订单支付
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@Service
@Pay("order")
public class OrderPay implements PayStrategy {
    /**
     * 支付前准备支付参数
     *
     * @param payFor
     */
    @Override
    public boolean prePay(String payFor) {
        System.out.printf("-----------%s-----------
", "订单支付");
        return true;
    }

    /**
     * 支付后处理支付回调结果
     *
     * @param payFor
     * @param isPaySuccess
     */
    @Override
    public void afterPay(String payFor, boolean isPaySuccess) {
        System.out.printf("-----------%s-----------
", "订单支付回调");
    }
}

RepairPay维修金支付

package com.zhya.strategy.service.impl;

import com.zhya.strategy.annotation.Pay;
import com.zhya.strategy.service.PayStrategy;
import org.springframework.stereotype.Service;

/**
 * 维修金支付
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@Service
@Pay("repair")
public class RepairPay implements PayStrategy {
    /**
     * 支付前准备支付参数
     *
     * @param payFor
     */
    @Override
    public boolean prePay(String payFor) {
        System.out.printf("-----------%s-----------
", "维修金支付");
        return true;
    }

    /**
     * 支付后处理支付回调结果
     *
     * @param payFor
     * @param isPaySuccess
     */
    @Override
    public void afterPay(String payFor, boolean isPaySuccess) {
        System.out.printf("-----------%s-----------
", "维修金支付回调");
    }
}

BeansUtil

package com.zhya.strategy.util;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

/**
 * bean工具类
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@Component
public class BeansUtil implements ApplicationContextAware {
    private static ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        BeansUtil.applicationContext = applicationContext;
    }

    /**
     * 获取实例
     *
     * @param clazz
     * @return
     */
    public static Object getBean(Class clazz) {
        return applicationContext.getBean(clazz);
    }
}

PayStrategyFactory策略工厂

package com.zhya.strategy.util;

import com.zhya.strategy.annotation.Pay;
import com.zhya.strategy.service.PayStrategy;
import org.reflections.Reflections;
import org.springframework.util.StringUtils;

import java.util.HashMap;
import java.util.Map;
import java.util.Set;

/**
 * 支付策略工厂
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
public class PayStrategyFactory {
    // 单例开始

    /**
     * 私有化构造函数，单例
     */
    private PayStrategyFactory() {

    }

    private static class Builder {
        private static final PayStrategyFactory payStrategyFactory = new PayStrategyFactory();
    }

    public static PayStrategyFactory getInstance() {
        return Builder.payStrategyFactory;
    }
    // 单例结束

    private static final String PAY_STRATEGY_IMPLEMENTATION_PACKAGE = "com.zhya.strategy.service.impl";
    private static final Map<String, Class> STRATEGY_MAP = new HashMap<>();

    // 获取所有支付策略
    static {
        Reflections reflections = new Reflections(PAY_STRATEGY_IMPLEMENTATION_PACKAGE);
        Set<Class<?>> classSet = reflections.getTypesAnnotatedWith(Pay.class);
        classSet.forEach(aClass -> {
            Pay payAnnotation = aClass.getAnnotation(Pay.class);
            STRATEGY_MAP.put(payAnnotation.value(), aClass);
        });
    }

    /**
     * 根据支付策略类型获取支付策略bean
     *
     * @param type
     * @return
     */
    public static PayStrategy getStrategy(String type) {
        // 反射获取支付策略实现类clazz
        Class clazz = STRATEGY_MAP.get(type);
        if (StringUtils.isEmpty(clazz)) {
            return null;
        }

        // 通过applicationContext获取bean
        return (PayStrategy) BeansUtil.getBean(clazz);
    }
}

AbstractPayService提供支付服务的抽象类

package com.zhya.strategy.service;

/**
 * 支付service
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
public abstract class AbstractPayService implements PayStrategy {
    protected String payType;

    /**
     * 支付
     *
     * @param payType
     * @param payFor
     */
    public void pay(String payType, String payFor) {
        this.payType = payType;
        boolean isPrepared = prePay(payFor);

        if (isPrepared) {
            System.out.println("------------支付请求已提交------------");
        } else {
            System.out.println("------------支付请求提交失败------------");
            return;
        }
        afterPay(payFor, true);
    }
}

　　

PayServiceImpl支付服务实现类

package com.zhya.strategy.service.impl;

import com.zhya.strategy.service.AbstractPayService;
import com.zhya.strategy.service.PayStrategy;
import com.zhya.strategy.util.PayStrategyFactory;
import org.springframework.stereotype.Service;

/**
 * 支付service
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@Service
public class PayServiceImpl extends AbstractPayService {
    /**
     * 支付前准备支付参数
     *
     * @param payFor
     */
    @Override
    public boolean prePay(String payFor) {
        PayStrategy payStrategy = PayStrategyFactory.getStrategy(this.payType);
        if (payStrategy == null) {
            System.out.printf("没有%s类型的支付策略...
", this.payType);
            return false;
        }
        return payStrategy.prePay(payFor);
    }

    /**
     * 支付后处理支付回调结果
     *
     * @param payFor
     * @param isPaySuccess
     */
    @Override
    public void afterPay(String payFor, boolean isPaySuccess) {
        PayStrategy payStrategy = PayStrategyFactory.getStrategy(this.payType);
        payStrategy.afterPay(payFor, true);
    }
}

　　

PayController

package com.zhya.strategy.controller;

import com.zhya.strategy.service.AbstractPayService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * 支付
 *
 * @author zhangyang
 * @date 2018/11/14
 **/
@RestController
@RequestMapping("pay")
public class PayController {
    @Autowired
    private AbstractPayService payService;

    @GetMapping
    public void pay(@RequestParam String payType, @RequestParam String payFor) {
        payService.pay(payType, payFor);
    }
}