天天看点

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

一、简介

电脑支付常用于电商和后台管理系统的账户充值等场景。

电脑网站支付 文档

电脑网站支付流程图

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

项目源代码(含数据库):码云Gitee

二、集成步骤

0、创建应用、配置密钥

集成前需要先创建应用、配置密钥、回调地址等以及

alipay-sdk-java.jar

alipay-trade-sdk.jar

请查看

SpringBoot(一)集成支付宝 - 准备工作 | 官网案例

1、pom 坐标

<parent>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-parent</artifactId>
	<version>2.0.3.RELEASE</version>
	<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<fastjson.version>1.2.41</fastjson.version>
</properties>

<dependencies>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter</artifactId>
	</dependency>

	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-test</artifactId>
		<scope>test</scope>
	</dependency>

	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>

	<!-- mariadb依赖  start-->
	<dependency>
		<groupId>org.mariadb.jdbc</groupId>
		<artifactId>mariadb-java-client</artifactId>
	</dependency>
	<!-- mariadb依赖  end-->

	<!--sprignboot mybatis支持-->
	<dependency>
		<groupId>org.mybatis.spring.boot</groupId>
		<artifactId>mybatis-spring-boot-starter</artifactId>
		<version>1.3.0</version>
	</dependency>

	<!-- jsp相关 -->
	<dependency>
		<groupId>jstl</groupId>
		<artifactId>jstl</artifactId>
		<version>1.2</version>
	</dependency>

	<!-- 用于解析jsp页面-->
	<dependency>
		<groupId>org.apache.tomcat.embed</groupId>
		<artifactId>tomcat-embed-jasper</artifactId>
	</dependency>
	<!-- 热部署 -->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-devtools</artifactId>
		<optional>true</optional>
	</dependency>

	<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>fastjson</artifactId>
		<version>${fastjson.version}</version>
	</dependency>

	<!-- apache的工具包 MapUtils start -->
	<dependency>
		<groupId>commons-collections</groupId>
		<artifactId>commons-collections</artifactId>
		<version>3.2.2</version>
	</dependency>
	<dependency>
		<groupId>org.apache.commons</groupId>
		<artifactId>commons-lang3</artifactId>
		<version>3.7</version>
	</dependency>
	<!-- apache的工具包 end -->

	<!--redis-->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-data-redis</artifactId>
	</dependency>


	<!-- 支付宝 alipay sdk -->
	<!-- https://mvnrepository.com/artifact/com.alipay.sdk/alipay-sdk-java -->
	<dependency>
		<groupId>com.alipay.sdk</groupId>
		<artifactId>alipay-sdk-java</artifactId>
		<version>3.1.0</version>
	</dependency>

	<!-- wx xml相关 -->
	<!-- https://mvnrepository.com/artifact/com.thoughtworks.xstream/xstream -->
	<dependency>
		<groupId>com.thoughtworks.xstream</groupId>
		<artifactId>xstream</artifactId>
		<version>1.4.9</version>
	</dependency>

</dependencies>
           

2、application.properties

spring:
  datasource:
    driver-class-name: org.mariadb.jdbc.Driver
    url: jdbc:mariadb://localhost:3306/alipay?allowMultiQueries=true&useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
    username: root
    password: 123456
  mvc:
    view:
      prefix: /WEB-INF/jsp/
      suffix: .jsp
    static-path-pattern: /**
  redis:
    host: 127.0.0.1
    port: 6379
    timeout: 10000
    password: 123456
mybatis:
  mapper-locations: classpath:/mybatis-mapper/*
  type-aliases-package: com.example.demo.pojo
logging:
  level:
      org:
        springframework: WARN
      #打印dao上的sql语句
      com:
        example:
          demo :
            dao : DEBUG
#  config: classpath:logback-admin.xml  #这个注释掉就不会在服务器产生日志
server:
  port: 8080

devtools:
  livereload:
    enabled: true #是否支持livereload
    port: 35729
  restart:
    enabled: true #是否支持热部署
           

3、支付宝配置类

public class AlipayConfig {
    //这里用natapp内外网穿透
//    public static final String natUrl = "http://gca8w8.natappfree.cc";
    public static final String natUrl = "http://localhost:8080";

    // 应用ID,您的APPID,收款账号既是您的APPID对应支付宝账号
    public static String app_id = "";//在后台获取(必须配置)

    // 商户私钥,您的PKCS8格式RSA2私钥
    public static String merchant_private_key = "";

    // 支付宝公钥,查看地址:https://openhome.alipay.com/platform/keyManage.html 对应APPID下的支付宝公钥。
    public static String alipay_public_key = "";

    // 服务器异步通知页面路径  需http://格式的完整路径,不能加?id=123这类自定义参数,必须外网可以正常访问
    public static String notify_url = natUrl + "/alipay/alipayNotifyNotice";

    // 页面跳转同步通知页面路径 需http://格式的完整路径,不能加?id=123这类自定义参数,必须外网可以正常访问
    public static String return_url = natUrl + "/alipay/alipayReturnNotice";
//    public static String return_url = "http://login.calidray.com/?#/sign";
    // 签名方式
    public static String sign_type = "RSA2";

    // 字符编码格式
    public static String charset = "utf-8";

    // 支付宝网关
    public static String gatewayUrl = "https://openapi.alipaydev.com/gateway.do";//注意:沙箱测试环境,正式环境为:https://openapi.alipay.com/gateway.do
}
           

4、支付宝Controller

@Controller
@RequestMapping("/alipay")
public class AlipayController {

    private static final Logger LOGGER = LoggerFactory.getLogger(AlipayController.class);

    @Autowired
    private ProductService productService;

    @Autowired
    private OrdersService ordersService;

    /**
     * 对应官方例子   alipay.trade.page.pay.jsp
     * @Description: 前往支付宝第三方网关进行支付
     * @Description notify_url 和 return_url 需要外网可以访问,建议natapp 内网穿透
     * @Date 2020-10-29 15:02
     * @Author: StarSea99
     */
    @PostMapping("goAlipay")
    @ResponseBody
    public String goAlipay(String orderId, HttpServletRequest request, HttpServletRequest response) throws Exception {

        Orders order = ordersService.getOrderById(orderId);

        Product product = productService.getProductById(order.getProductId());

        //获得初始化的AlipayClient
        AlipayClient alipayClient = new DefaultAlipayClient(AlipayConfig.gatewayUrl, AlipayConfig.app_id, AlipayConfig.merchant_private_key, "json", AlipayConfig.charset, AlipayConfig.alipay_public_key, AlipayConfig.sign_type);

        //设置请求参数
        AlipayTradePagePayRequest alipayRequest = new AlipayTradePagePayRequest();
        alipayRequest.setReturnUrl(AlipayConfig.return_url);
        alipayRequest.setNotifyUrl(AlipayConfig.notify_url);

        //商户订单号,商户网站订单系统中唯一订单号,必填
        String out_trade_no = orderId;
        //付款金额,必填
        String total_amount = order.getOrderAmount();
        //订单名称,必填
        String subject = product.getName();
        //商品描述,可空
        String body = "用户订购商品个数:" + order.getBuyCounts();

        // 该笔订单允许的最晚付款时间,逾期将关闭交易。取值范围:1m~15d。m-分钟,h-小时,d-天,1c-当天(1c-当天的情况下,无论交易何时创建,都在0点关闭)。 该参数数值不接受小数点, 如 1.5h,可转换为 90m。
        String timeout_express = "10m";

        //例子去官方api找
        alipayRequest.setBizContent("{\"out_trade_no\":\"" + out_trade_no + "\","
                + "\"total_amount\":\"" + total_amount + "\","
                + "\"subject\":\"" + subject + "\","
                + "\"body\":\"" + body + "\","
                + "\"timeout_express\":\"" + timeout_express + "\","
                + "\"product_code\":\"FAST_INSTANT_TRADE_PAY\"}");

        //请求
        String result = alipayClient.pageExecute(alipayRequest).getBody();
        System.out.println("==="+result);
        return result;
    }

    /**
     * @Title: 对应官方例子return_url.jsp    return_url必须放在公网上  回跳页面
     * @Description: 支付宝同步通知页面
     * @Description TODO
     * @Date 2020-10-29 15:02
     * @Author: StarSea99
     */
    @RequestMapping("alipayReturnNotice")
    public String alipayReturnNotice(HttpServletRequest request, HttpServletRequest response, Map map) throws Exception {

        LOGGER.info("支付成功, 进入同步通知接口...");

        //获取支付宝GET过来反馈信息
        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);
        }

        boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key, AlipayConfig.charset, AlipayConfig.sign_type); //调用SDK验证签名

        //——请在这里编写您的程序(以下代码仅作参考)——
        if (signVerified) {
            //商户订单号
            String out_trade_no = new String(request.getParameter("out_trade_no").getBytes("ISO-8859-1"), "UTF-8");

            //支付宝交易号
            String trade_no = new String(request.getParameter("trade_no").getBytes("ISO-8859-1"), "UTF-8");

            //付款金额
            String total_amount = new String(request.getParameter("total_amount").getBytes("ISO-8859-1"), "UTF-8");

            // 修改叮当状态,改为 支付成功,已付款; 同时新增支付流水  这里放在 异步 业务 处理
//            ordersService.updateOrderStatus(out_trade_no, trade_no, total_amount);

            //页面  展示
            Orders order = ordersService.getOrderById(out_trade_no);
            Product product = productService.getProductById(order.getProductId());

            LOGGER.info("********************** 支付成功(支付宝同步通知) **********************");
            LOGGER.info("* 订单号: {}", out_trade_no);
            LOGGER.info("* 支付宝交易号: {}", trade_no);
            LOGGER.info("* 实付金额: {}", total_amount);
            LOGGER.info("* 购买产品: {}", product.getName());
            LOGGER.info("***************************************************************");

            map.put("out_trade_no", out_trade_no);
            map.put("trade_no", trade_no);
            map.put("total_amount", total_amount);
            map.put("productName", product.getName());

        } else {
            LOGGER.info("支付, 验签失败...");
        }

        //前后分离形式  直接返回页面 记得加上注解@Response  http://login.calidray.com你要返回的网址,再页面初始化时候让前端调用你其他接口,返回信息
//        String result = "<form action=\"http://login.calidray.com/?#/index/depreciation-scrap/depreciation\"  method=\"get\" name=\"form1\">\n" +
//                "</form>\n" +
//                "<script>document.forms[0].submit();</script>";
//
//        return result;
        //前后不分离的形式,直接返回jsp页面
        return "alipaySuccess";
    }


/* *
 * 功能:支付宝服务器异步通知页面   对应官方例子 notify_url.jsp     notify_url必须放入公网
 * 日期:2017-03-30
 * 说明:
 * 以下代码只是为了方便商户测试而提供的样例代码,商户可以根据自己网站的需要,按照技术文档编写,并非一定要使用该代码。
 * 该代码仅供学习和研究支付宝接口使用,只是提供一个参考。
 *************************页面功能说明*************************  制作业务处理
 * 创建该页面文件时,请留心该页面文件中无任何HTML代码及空格。
 * 该页面不能在本机电脑测试,请到服务器上做测试。请确保外部可以访问该页面。
 * 如果没有收到该页面返回的 success
 * 建议该页面只做支付成功的业务逻辑处理,退款的处理请以调用退款查询接口的结果为准。
 */
    /**
     * @Description: 支付宝异步 通知  制作业务处理
     * @Description TODO
     * @Date 2020-10-29 15:02
     * @Author: StarSea99
     */
    @RequestMapping(value = "/alipayNotifyNotice")
    @ResponseBody
    public String alipayNotifyNotice(HttpServletRequest request, HttpServletRequest response) throws Exception {

        LOGGER.info("支付成功, 进入异步通知接口...");

        //获取支付宝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] + ",";
            }
            //乱码解决,这段代码在出现乱码时使用
//			valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");
            params.put(name, valueStr);
        }

        boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key, AlipayConfig.charset, AlipayConfig.sign_type); //调用SDK验证签名

        //——请在这里编写您的程序(以下代码仅作参考)——

		/* 实际验证过程建议商户务必添加以下校验:
        1、需要验证该通知数据中的out_trade_no是否为商户系统中创建的订单号,
		2、判断total_amount是否确实为该订单的实际金额(即商户订单创建时的金额),
		3、校验通知中的seller_id(或者seller_email) 是否为out_trade_no这笔单据的对应的操作方(有的时候,一个商户可能有多个seller_id/seller_email)
		4、验证app_id是否为该商户本身。
		*/
        if (signVerified) {//验证成功
            //商户订单号
            String out_trade_no = new String(request.getParameter("out_trade_no").getBytes("ISO-8859-1"), "UTF-8");

            //支付宝交易号
            String trade_no = new String(request.getParameter("trade_no").getBytes("ISO-8859-1"), "UTF-8");

            //交易状态
            String trade_status = new String(request.getParameter("trade_status").getBytes("ISO-8859-1"), "UTF-8");

            //付款金额
            String total_amount = new String(request.getParameter("total_amount").getBytes("ISO-8859-1"), "UTF-8");

            if (trade_status.equals("TRADE_FINISHED")) {
                //判断该笔订单是否在商户网站中已经做过处理
                //如果没有做过处理,根据订单号(out_trade_no)在商户网站的订单系统中查到该笔订单的详细,并执行商户的业务程序
                //如果有做过处理,不执行商户的业务程序

                //注意: 尚自习的订单没有退款功能, 这个条件判断是进不来的, 所以此处不必写代码
                //退款日期超过可退款期限后(如三个月可退款),支付宝系统发送该交易状态通知
            } else if (trade_status.equals("TRADE_SUCCESS")) {
                //判断该笔订单是否在商户网站中已经做过处理
                //如果没有做过处理,根据订单号(out_trade_no)在商户网站的订单系统中查到该笔订单的详细,并执行商户的业务程序
                //如果有做过处理,不执行商户的业务程序

                //注意:
                //付款完成后,支付宝系统发送该交易状态通知

                // 修改叮当状态,改为 支付成功,已付款; 同时新增支付流水
                ordersService.updateOrderStatus(out_trade_no, trade_no, total_amount);

                //这里不用 查  只是为了 看日志 查的方法应该卸载 同步回调 页面 中
                Orders order = ordersService.getOrderById(out_trade_no);
                Product product = productService.getProductById(order.getProductId());

                LOGGER.info("********************** 支付成功(支付宝异步通知)查询 只是为了 看日志  **********************");
                LOGGER.info("* 订单号: {}", out_trade_no);
                LOGGER.info("* 支付宝交易号: {}", trade_no);
                LOGGER.info("* 实付金额: {}", total_amount);
                LOGGER.info("* 购买产品: {}", product.getName());
                LOGGER.info("***************************************************************");
            }
            LOGGER.info("支付成功...");
        } else {//验证失败
            LOGGER.info("支付, 验签失败...");
        }
        return "success";
    }
}
           

5、ProductController 类

@Controller
@RequestMapping
public class ProductController {

    @Autowired
    private ProductService productService;

    @Autowired
    private OrdersService ordersService;

    //获取产品列表
    @RequestMapping
    public String products(Map map) {
        List<Product> pList = productService.getProducts();
        map.put("pList", pList);
        return "index";
    }

    //首页显示,查询全部产品
    @RequestMapping("index")
    public String index(Map map) {
        List<Product> pList = productService.getProducts();
        map.put("pList", pList);
        return "index";
    }

    //进入购物车页面
    @RequestMapping(value = "/goConfirm")
    public String goConfirm(String productId, Map map) {
        Product p = productService.getProductById(productId);
        map.put("p", p);
        return "goConfirm";
    }

    //分段提交,保存订单
    @RequestMapping(value = "/createOrder")
    @ResponseBody
    public LeeJSONResult createOrder(Orders order) throws Exception {

        Product p = productService.getProductById(order.getProductId());

        Sid sid = new Sid();
        String orderId = sid.nextShort();//生成16位随机字符串

        order.setId(orderId);//设置id
        order.setOrderNum(orderId);//设置订单号
        order.setCreateTime(new Date());//设置创建时间
        order.setOrderAmount(String.valueOf(Float.valueOf(p.getPrice()) * order.getBuyCounts()));//实际支付金额
        order.setOrderStatus(OrderStatusEnum.WAIT_PAY.key);//订单状态

        ordersService.saveOrder(order);
        return LeeJSONResult.ok(orderId);
    }

    //分段提交,第二段
    @RequestMapping(value = "/goPay")
    public String goPay(String orderId, Map map) {
        //根据订单号查询订单
        Orders order = ordersService.getOrderById(orderId);
        //根据订单号查询产品
        Product p = productService.getProductById(order.getProductId());

        map.put("order", order);
        map.put("p", p);

        return "goPay";
    }

}
           

6、想看完成的代码可以查看 Gitee

数据库,页面展示以及业务层调用 这里略过

项目源代码(含数据库):码云Gitee

7、项目效果图展示

说明:此项目只是为了跑通流程,页面不够好可以自行寻找整合。

首页

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

购物车

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

确认订单

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

支付宝支付(使用沙箱)

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

支付成功回调信息页

SpringBoot(二)集成支付宝 - 电脑网站支付和查询账单案例

如果有收获!!! 希望老铁们来个三连,点赞、收藏、转发。

创作不易,别忘点个赞,可以让更多的人看到这篇文章,顺便鼓励我写出更好的博客