SpringBoot集成支付宝 - 少走弯路就看这篇

<!-- alipay -->  
<dependency>  
   <groupId>com.alipay.sdk</groupId>  
   <artifactId>alipay-sdk-java</artifactId>  
   <version>4.35.132.ALL</version>  
</dependency>

@RestController  
@RequestMapping("/alipay")  
public class AliPayController {
@Autowired  
AliPayService aliPayService;  

@PostMapping("/order")  
public GenericResponse<Object> placeOrderForPCWeb(@RequestBody AliPayRequest aliPayRequest) {  
    try {  
        return aliPayService.placeOrderForPCWeb(aliPayRequest);  
    } catch (IOException e) {  
        throw new RuntimeException(e);  
    }  
}  

@PostMapping("/callback/async")  
public String asyncCallback(HttpServletRequest request) {  
    return aliPayService.orderCallbackInAsync(request);  
}  

@GetMapping("/callback/sync")  
public void syncCallback(HttpServletRequest request, HttpServletResponse response) {  
    aliPayService.orderCallbackInSync(request, response);  
}  

}

public class AliPayService {

@Autowired  
AliPayHelper aliPayHelper;  

@Resource  
AlipayConfig alipayConfig;  

@Transactional(rollbackFor = Exception.class)  
public GenericResponse<Object> placeOrderForPCWeb(AliPayRequest aliPayRequest) throws IOException {  
    log.info("【请求开始-在线购买-交易创建】*********统一下单开始*********");  

    String tradeNo = aliPayHelper.generateTradeNumber();  

    String subject = "购买套餐1";  
    Map<String, Object> map = aliPayHelper.placeOrderAndPayForPCWeb(tradeNo, 100, subject);  

    if (Boolean.parseBoolean(String.valueOf(map.get("isSuccess")))) {  
        log.info("【请求开始-在线购买-交易创建】统一下单成功，开始保存订单数据");  

        //保存订单信息  
        // 添加你自己的业务逻辑，主要是保存订单数据

        log.info("【请求成功-在线购买-交易创建】*********统一下单结束*********");  
        return new GenericResponse<>(ResponseCode.SUCCESS, map.get("body"));  
    }else{  
        log.info("【失败：请求失败-在线购买-交易创建】*********统一下单结束*********");  
        return new GenericResponse<>(ResponseCode.INTERNAL_ERROR, String.valueOf(map.get("subMsg")));  
    }  
}  

// sync return page  
public void orderCallbackInSync(HttpServletRequest request, HttpServletResponse response) {  
    try {  
        OutputStream outputStream = response.getOutputStream();  
        //通过设置响应头控制浏览器以UTF-8的编码显示数据，如果不加这句话，那么浏览器显示的将是乱码  
        response.setHeader("content-type", "text/html;charset=UTF-8");  
        String outputData = "支付成功，请返回网站并刷新页面。";  

        /**  
         * data.getBytes()是一个将字符转换成字节数组的过程，这个过程中一定会去查码表，  
         * 如果是中文的操作系统环境，默认就是查找查GB2312的码表，  
         */  
        byte[] dataByteArr = outputData.getBytes("UTF-8");//将字符转换成字节数组，指定以UTF-8编码进行转换  
        outputStream.write(dataByteArr);//使用OutputStream流向客户端输出字节数组  
    } catch (IOException e) {  
        throw new RuntimeException(e);  
    }  
}  

public String orderCallbackInAsync(HttpServletRequest request) {  
    try {  
        Map<String, String> map = aliPayHelper.paramstoMap(request);  
        String tradeNo = map.get("out_trade_no");  
        String sign = map.get("sign");  
        String content = AlipaySignature.getSignCheckContentV1(map);  
        boolean signVerified = aliPayHelper.CheckSignIn(sign, content);  

        // check order status  
        // 这里在DB中检查order的状态，如果已经支付成功，无需再次验证。
        if(从DB中拿到order，并且判断order是否支付成功过){  
            log.info("订单：" + tradeNo + " 已经支付成功，无需再次验证。");  
            return "success";  
        }  

        //验证业务数据是否一致  
        if(!checkData(map, order)){  
            log.error("返回业务数据验证失败，订单：" + tradeNo );  
            return "返回业务数据验证失败";  
        }  
        //签名验证成功  
        if(signVerified){  
            log.info("支付宝签名验证成功，订单：" + tradeNo);  
            // 验证支付状态  
            String tradeStatus = request.getParameter("trade_status");  
            if(tradeStatus.equals("TRADE_SUCCESS")){  
                log.info("支付成功，订单："+tradeNo);  
		        // 更新订单状态，执行一些业务逻辑

                return "success";  
            }else{  
                System.out.println("支付失败，订单：" + tradeNo );  
                return "支付失败";  
            }  
        }else{  
            log.error("签名验证失败，订单：" + tradeNo );  
            return "签名验证失败.";  
        }  
    } catch (IOException e) {  
        log.error("IO exception happened ", e);  
        throw new RuntimeException(ResponseCode.INTERNAL_ERROR, e.getMessage());  
    }  
}  


public boolean checkData(Map<String, String> map, OrderInfo order) {  
    log.info("【请求开始-交易回调-订单确认】*********校验订单确认开始*********");  

    //验证订单号是否准确，并且订单状态为待支付  
    if(验证订单号是否准确，并且订单状态为待支付){  
        float amount1 = Float.parseFloat(map.get("total_amount"));  
        float amount2 = (float) order.getOrderAmount();  
        //判断金额是否相等  
        if(amount1 == amount2){  
            //验证收款商户id是否一致  
            if(map.get("seller_id").equals(alipayConfig.getPid())){  
                //判断appid是否一致  
                if(map.get("app_id").equals(alipayConfig.getAppid())){  
                    log.info("【成功：请求开始-交易回调-订单确认】*********校验订单确认成功*********");  
                    return true;                    }  
            }  
        }  
    }  
    log.info("【失败：请求开始-交易回调-订单确认】*********校验订单确认失败*********");  
    return false;    }  

}

public class AliPayHelper {

@Resource  
private AlipayConfig alipayConfig;  

//返回数据格式  
private static final String FORMAT = "json";  
//编码类型  
private static final String CHART_TYPE = "utf-8";  
//签名类型  
private static final String SIGN_TYPE = "RSA2";  

/*支付销售产品码,目前支付宝只支持FAST_INSTANT_TRADE_PAY*/  
public static final String PRODUCT_CODE = "FAST_INSTANT_TRADE_PAY";  

private static AlipayClient alipayClient = null;  

private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmssSSS");  
private static final Random random = new Random();  

@PostConstruct  
public void init(){  
    alipayClient = new DefaultAlipayClient(  
            alipayConfig.getGateway(),  
            alipayConfig.getAppid(),  
            alipayConfig.getPrivateKey(),  
            FORMAT,  
            CHART_TYPE,  
            alipayConfig.getPublicKey(),  
            SIGN_TYPE);  
};  

/*================PC网页支付====================*/  
/**  
 * 统一下单并调用支付页面接口  
 * @param outTradeNo  
 * @param totalAmount  
 * @param subject  
 * @return  
 */  
public Map<String, Object> placeOrderAndPayForPCWeb(String outTradeNo, float totalAmount, String subject){  
    AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();  
    request.setNotifyUrl(alipayConfig.getNotifyUrl());  
    request.setReturnUrl(alipayConfig.getReturnUrl());  
    JSONObject bizContent = new JSONObject();  
    bizContent.put("out_trade_no", outTradeNo);  
    bizContent.put("total_amount", totalAmount);  
    bizContent.put("subject", subject);  
    bizContent.put("product_code", PRODUCT_CODE);  

    request.setBizContent(bizContent.toString());  
    AlipayTradePagePayResponse response = null;  
    try {  
        response = alipayClient.pageExecute(request);  
    } catch (AlipayApiException e) {  
        e.printStackTrace();  
    }  
    Map<String, Object> resultMap = new HashMap<>();  
    resultMap.put("isSuccess", response.isSuccess());  
    if(response.isSuccess()){  
        log.info("调用成功");  
        log.info(JSON.toJSONString(response));  
        resultMap.put("body", response.getBody());  
    } else {  
        log.error("调用失败");  
        log.error(response.getSubMsg());  
        resultMap.put("subMsg", response.getSubMsg());  
    }  
    return resultMap;  
}  

/**  
 * 交易订单查询  
 * @param out_trade_no  
 * @return  
 */  
public Map<String, Object> tradeQueryForPCWeb(String out_trade_no){  
    AlipayTradeQueryRequest request = new AlipayTradeQueryRequest();  
    JSONObject bizContent = new JSONObject();  
    bizContent.put("trade_no", out_trade_no);  
    request.setBizContent(bizContent.toString());  
    AlipayTradeQueryResponse response = null;  
    try {  
        response = alipayClient.execute(request);  
    } catch (AlipayApiException e) {  
        e.printStackTrace();  
    }  
    Map<String, Object> resultMap = new HashMap<>();  
    resultMap.put("isSuccess", response.isSuccess());  
    if(response.isSuccess()){  
        System.out.println("调用成功");  
        System.out.println(JSON.toJSONString(response));  
        resultMap.put("status", response.getTradeStatus());  
    } else {  
        System.out.println("调用失败");  
        System.out.println(response.getSubMsg());  
        resultMap.put("subMsg", response.getSubMsg());  
    }  
    return resultMap;  
}  

/**  
 * 验证签名是否正确  
 * @param sign  
 * @param content  
 * @return  
 */  
public boolean CheckSignIn(String sign, String content){  
    try {  
        return AlipaySignature.rsaCheck(content, sign, alipayConfig.getPublicKey(), CHART_TYPE, SIGN_TYPE);  
    } catch (AlipayApiException e) {  
        e.printStackTrace();  
    }  
    return false;  
}  

/**  
 * 将异步通知的参数转化为Map  
 * @return  
 */  
public Map<String, String> paramstoMap(HttpServletRequest request) throws UnsupportedEncodingException {  
    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] + ",";  
        }  
        // 乱码解决，这段代码在出现乱码时使用。  

//            valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");

params.put(name, valueStr);

}

return params;

}
}

@Data

@Component

@ConfigurationProperties(prefix = "alipay")

public class AlipayConfig {

private String gateway;  

private String appid;  

private String pid;  

private String privateKey;  

private String publicKey;  

private String returnUrl;  

private String notifyUrl;  

}

# alipay config

alipay.gateway=https://openapi.alipaydev.com/gateway.do

alipay.appid=your_appid

alipay.pid=your_pid

alipay.privatekey=your_private_key

alipay.publickey=your_public_key

alipay.returnurl=完成支付后的同步跳转地址

alipay.notifyurl=完成支付后，支付宝会异步回调的地址

async function onPositiveClick() {

paymentLoading.value = true

const { data } = await placeAlipayOrder<string>({

//你的一些请求参数，例如金额等等

})
const div = document.createElement('divform')

div.innerHTML = data

document.body.appendChild(div)

document.forms[0].setAttribute('target', '_blank')

document.forms[0].submit()
showModal.value = false

paymentLoading.value = false

}

# alipay config  
alipay.gateway=https://openapi.alipaydev.com/gateway.do  
alipay.appid=your_appid
alipay.pid=your_pid  
alipay.privatekey=your_private_key
alipay.publickey=your_public_key
alipay.returnurl=完成支付后的同步跳转地址 
alipay.notifyurl=完成支付后，支付宝会异步回调的地址