怎么用Java也實現微信和支付寶支付功能

這篇文章主要介紹“怎么用Java也實現微信和支付寶支付功能”，在日常操作中，相信很多人在怎么用Java也實現微信和支付寶支付功能問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”怎么用Java也實現微信和支付寶支付功能”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

一、前期準備

1、申請好微信商戶號appid，拿到商戶id和商戶秘鑰，退款的話需要商戶證書

2、申請好支付寶商戶號appid，商戶公鑰和秘鑰(需要用支付寶工具自己生成)，支付寶退款不需要證書

二、數據庫表設計

1、微信支付配置表

CREATE TABLE `py_wx_config` (  `wx_config_id` varchar(18) NOT NULL COMMENT '微信支付配置ID',  `appid` varchar(128) DEFAULT NULL COMMENT '微信公眾號ID',  `mch_id` varchar(128) DEFAULT NULL COMMENT '商戶號ID',  `mch_key_secret` varchar(2200) DEFAULT NULL COMMENT '商戶安全密鑰',  `crt_path` varchar(200) DEFAULT NULL COMMENT '商戶證書存放路徑',  `app_secret` varchar(2200) DEFAULT NULL COMMENT '公眾號安全密鑰',  `create_id` varchar(18) DEFAULT NULL COMMENT '創建人',  `create_time` datetime DEFAULT NULL COMMENT '創建時間',  `upd_id` varchar(18) DEFAULT NULL COMMENT '修改人',  `upd_time` datetime DEFAULT NULL COMMENT '修改時間',  `delete_flag` tinyint(1) NOT NULL DEFAULT '0' COMMENT '刪除標志',  `app_code` varchar(18) NOT NULL COMMENT '商家編碼',  `bm_code` varchar(20) DEFAULT NULL COMMENT '部門編碼',  PRIMARY KEY (`wx_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='微信支付配置';

2、微信小程序支付配置表

CREATE TABLE `py_wx_min_config` (  `wx_min_config_id` varchar(18) NOT NULL COMMENT '微信支付配置ID',  `appid` varchar(128) DEFAULT NULL COMMENT '微信公眾號ID',  `mch_id` varchar(128) DEFAULT NULL COMMENT '商戶號ID',  `mch_key_secret` varchar(2200) DEFAULT NULL COMMENT '商戶安全密鑰',  `crt_path` varchar(200) DEFAULT NULL COMMENT '商戶證書存放路徑',  `app_secret` varchar(2200) DEFAULT NULL COMMENT '公眾號安全密鑰',  `create_id` varchar(18) DEFAULT NULL COMMENT '創建人',  `create_time` datetime DEFAULT NULL COMMENT '創建時間',  `upd_id` varchar(18) DEFAULT NULL COMMENT '修改人',  `upd_time` datetime DEFAULT NULL COMMENT '修改時間',  `delete_flag` tinyint(1) NOT NULL DEFAULT '0' COMMENT '刪除標志',  `app_code` varchar(18) NOT NULL COMMENT '商家編碼',  `sys_software_code` varchar(18) DEFAULT NULL COMMENT '系統編碼',  PRIMARY KEY (`wx_min_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='微信支付配置';

3、支付寶支付配置表

CREATE TABLE `py_alipay_config` (  `alipay_config_id` varchar(18) NOT NULL COMMENT '支付寶支付配置ID',  `ali_private_key` varchar(2200) DEFAULT NULL COMMENT '支付寶密鑰',  `ali_public_key` varchar(2200) DEFAULT NULL COMMENT '支付寶公鑰',  `ali_appid` varchar(128) DEFAULT NULL COMMENT '支付寶appid',  `create_id` varchar(18) DEFAULT NULL COMMENT '創建人',  `create_time` datetime DEFAULT NULL COMMENT '創建時間',  `upd_id` varchar(18) DEFAULT NULL COMMENT '修改人',  `upd_time` datetime DEFAULT NULL COMMENT '修改時間',  `delete_flag` tinyint(1) NOT NULL DEFAULT '0' COMMENT '刪除標志',  `app_code` varchar(18) NOT NULL COMMENT '商家編碼',  PRIMARY KEY (`alipay_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='支付寶支付配置';

4、支付流水記錄表

CREATE TABLE `py_pay_log` (  `pay_log_id` varchar(18) NOT NULL COMMENT '支付流水ID',  `pay_no` varchar(20) DEFAULT NULL COMMENT '支付訂單號',  `third_id` varchar(64) DEFAULT NULL COMMENT '微信支付寶訂單ID',  `money_type` varchar(20) DEFAULT NULL COMMENT '支付類型 0-微信 1-支付寶 2-會員卡 3-銀聯',  `mq_topic` varchar(100) DEFAULT NULL COMMENT 'MQ主題',  `mq_status` tinyint(3) DEFAULT NULL COMMENT 'MQ發送狀態 0-待發送 1-已發送 2-發送失敗',  `mq_remark` varchar(100) DEFAULT NULL COMMENT 'MQ發送備注',  `request` text COMMENT '發送數據',  `response` text COMMENT '返回數據',  `fee` decimal(14,2) DEFAULT NULL COMMENT '訂單金額',  `create_id` varchar(18) DEFAULT NULL COMMENT '創建人',  `create_time` datetime DEFAULT NULL COMMENT '創建時間',  `upd_id` varchar(18) DEFAULT NULL COMMENT '修改人',  `upd_time` datetime DEFAULT NULL COMMENT '修改時間',  `delete_flag` tinyint(1) NOT NULL DEFAULT '0' COMMENT '刪除標志',  `app_code` varchar(18) NOT NULL COMMENT '商家編碼',  `pay_config_json_str` longtext COMMENT '支付配置',  PRIMARY KEY (`pay_log_id`) USING BTREE ) ENGINE=MyISAM DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC COMMENT='支付流水';

5、支付失敗記錄表

CREATE TABLE `pay_fail_log` (  `pay_id` varchar(18) NOT NULL,  `json_date` varchar(500) DEFAULT NULL,  `create_id` varchar(18) DEFAULT NULL,  `create_time` datetime DEFAULT NULL,  `update_id` varchar(18) DEFAULT NULL,  `update_time` datetime DEFAULT NULL,  `app_code` varchar(18) NOT NULL,  `delete_flag` tinyint(1) DEFAULT '0' COMMENT '是否刪除:0-否；1-是',  PRIMARY KEY (`pay_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT;

三、依賴引入

<?xml version="1.0" encoding="UTF-8"?>  <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">   <parent>   <groupId>org.springframework.boot</groupId>   <artifactId>spring-boot-starter-parent</artifactId>   <version>2.1.3.RELEASE</version>   <relativePath/> <!-- lookup parent from repository -->  </parent>   <modelVersion>4.0.0</modelVersion>  <groupId>com.pay</groupId>  <artifactId>qc-payment</artifactId>  <version>2.3</version>  <name>qc-payment</name>  <!-- FIXME change it to the project's website -->  <url>http://www.example.com</url>   <properties>   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>   <maven.compiler.source>1.7</maven.compiler.source>   <maven.compiler.target>1.7</maven.compiler.target>   <spring-cloud.version>Greenwich.SR1</spring-cloud.version>  </properties>   <dependencies>   <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-data-redis</artifactId>   </dependency>   <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId>   </dependency>   <dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>   </dependency>   <dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-zuul</artifactId>   </dependency>     <!--z支付寶-->   <dependency>    <groupId>com.alipay.sdk</groupId>    <artifactId>alipay-sdk-java</artifactId>    <version>3.3.4.ALL</version>   </dependency>     <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-test</artifactId>    <scope>test</scope>   </dependency>    <!--導入重試機制的坐標-->   <dependency>    <groupId>org.springframework.retry</groupId>    <artifactId>spring-retry</artifactId>   </dependency>    <!--引入Hystrix依賴-->   <dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>   </dependency>    <!--導入jwt相關依賴-->   <dependency>    <groupId>com.auth0</groupId>    <artifactId>java-jwt</artifactId>    <version>3.4.1</version>   </dependency>    <!-- StringUtil 類-->   <dependency>    <groupId>org.apache.commons</groupId>    <artifactId>commons-lang3</artifactId>    <version>3.3.2</version>   </dependency>    <!-- ali 連接池 -->   <dependency>    <groupId>com.alibaba</groupId>    <artifactId>druid</artifactId>    <version>1.1.12</version>   </dependency>    <!-- mybatis -->   <dependency>    <groupId>org.mybatis.spring.boot</groupId>    <artifactId>mybatis-spring-boot-starter</artifactId>    <version>2.0.0</version>   </dependency>    <!-- mysql -->   <dependency>    <groupId>mysql</groupId>    <artifactId>mysql-connector-java</artifactId>   </dependency>   <dependency>    <groupId>javax.persistence</groupId>    <artifactId>persistence-api</artifactId>    <version>1.0.2</version>   </dependency>   <!-- https://mvnrepository.com/artifact/tk.mybatis/mapper -->   <dependency>    <groupId>tk.mybatis</groupId>    <artifactId>mapper</artifactId>    <version>4.0.3</version>   </dependency>    <!-- import lombok 可以省去getter setter toString等方法 -->   <dependency>    <groupId>org.projectlombok</groupId>    <artifactId>lombok</artifactId>    <scope>provided</scope>   </dependency>    <!-- commons-io -->   <dependency>    <groupId>commons-io</groupId>    <artifactId>commons-io</artifactId>    <version>2.4</version>   </dependency>    <!-- 引入easyqinyu-tools項目 -->   <dependency>    <groupId>com.pay</groupId>    <artifactId>easyqinyu-tools</artifactId>    <version>0.0.1-SNAPSHOT</version>   </dependency>    <!-- pagehelper分頁插件 -->   <dependency>    <groupId>com.github.pagehelper</groupId>    <artifactId>pagehelper</artifactId>    <version>5.1.2</version>   </dependency>    <dependency>    <groupId>com.github.pagehelper</groupId>    <artifactId>pagehelper-spring-boot-autoconfigure</artifactId>    <version>1.2.3</version>   </dependency>   <dependency>    <groupId>com.github.pagehelper</groupId>    <artifactId>pagehelper-spring-boot-starter</artifactId>    <version>1.2.3</version>   </dependency>   <dependency>    <groupId>com.qcsoft</groupId>    <artifactId>qc-swagger-ui</artifactId>    <version>0.0.1-SNAPSHOT</version>    <scope>compile</scope>   </dependency>   <dependency>    <groupId>com.google.zxing</groupId>    <artifactId>core</artifactId>    <version>3.3.0</version>   </dependency>    <dependency>    <groupId>com.alibaba</groupId>    <artifactId>fastjson</artifactId>    <version>RELEASE</version>    <scope>compile</scope>   </dependency>    <dependency>    <groupId>org.apache.httpcomponents</groupId>    <artifactId>httpclient</artifactId>    <version>${httpclient.version}</version>   </dependency>     <dependency>    <groupId>com.google.code.gson</groupId>    <artifactId>gson</artifactId>    <version>2.8.2</version>   </dependency>     <!--阿里云信息發送-->   <dependency>    <groupId>com.aliyun</groupId>    <artifactId>aliyun-java-sdk-core</artifactId>    <version>3.3.1</version>   </dependency>   <dependency>    <groupId>com.github.1991wangliang</groupId>    <artifactId>aliyun-java-sdk-dysmsapi</artifactId>    <version>1.0.0</version>   </dependency>    <dependency>    <groupId>org.springframework.kafka</groupId>    <artifactId>spring-kafka</artifactId>   </dependency>    <!-- xml解析-->   <dependency>    <groupId>com.thoughtworks.xstream</groupId>    <artifactId>xstream</artifactId>    <version>1.4.10</version>   </dependency>    <!-- dom4j -->   <dependency>    <groupId>org.dom4j</groupId>    <artifactId>dom4j</artifactId>    <version>2.1.1</version>   </dependency>     <dependency>    <groupId>com.github.binarywang</groupId>    <artifactId>weixin-java-common</artifactId>    <version>3.3.4.B</version>   </dependency>     <dependency>    <groupId>org.jodd</groupId>    <artifactId>jodd-http</artifactId>    <scope>compile</scope>   </dependency>    <dependency>    <groupId>org.apache.commons</groupId>    <artifactId>commons-lang3</artifactId>   </dependency>     <!-- xml解析-->   <dependency>    <groupId>commons-beanutils</groupId>    <artifactId>commons-beanutils</artifactId>    <version>1.9.3</version>   </dependency>    <dependency>    <groupId>jdom</groupId>    <artifactId>jdom</artifactId>    <version>1.0</version>   </dependency>     <dependency>    <groupId>org.bouncycastle</groupId>    <artifactId>bcpkix-jdk15on</artifactId>    <version>1.59</version>   </dependency>   <dependency>    <groupId>org.jodd</groupId>    <artifactId>jodd-http</artifactId>    <version>3.7.1</version>   </dependency>   <!--二維碼工具-->   <dependency>    <groupId>com.google.zxing</groupId>    <artifactId>core</artifactId>    <version>3.2.1</version>   </dependency>    <dependency>    <groupId>com.qcsoft</groupId>    <artifactId>qc-commonbean</artifactId>    <version>0.0.1-SNAPSHOT</version>   </dependency>    <dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-openfeign</artifactId>   </dependency>   <!-- xxl-job-core -->   <dependency>    <groupId>com.xuxueli</groupId>    <artifactId>xxl-job-core</artifactId>    <version>2.0.1</version>   </dependency>   <!--線路跟蹤-->   <dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>   </dependency>    <dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-actuator</artifactId>   </dependency>  </dependencies>    <dependencyManagement>   <dependencies>    <dependency>     <groupId>org.springframework.cloud</groupId>     <artifactId>spring-cloud-dependencies</artifactId>     <version>${spring-cloud.version}</version>     <type>pom</type>     <scope>import</scope>    </dependency>   </dependencies>  </dependencyManagement>  <build>   <finalName>qc-payment</finalName>   <plugins>    <plugin>     <groupId>org.springframework.boot</groupId>     <artifactId>spring-boot-maven-plugin</artifactId>    </plugin>    <plugin>     <groupId>org.apache.maven.plugins</groupId>     <artifactId>maven-compiler-plugin</artifactId>     <configuration>      <source>8</source>      <target>8</target>     </configuration>    </plugin>   </plugins>  </build> </project>

四、程序實現

1、Controller

package com.qcsoft.payment.controller;  import com.alibaba.fastjson.JSON; import com.qcsoft.commonbean.bean.common.SwaggerConstant; import com.qcsoft.commonbean.bean.payment.common.PrePayResult; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.commonbean.bean.payment.wx.exception.WxPayException; import com.qcsoft.commonbean.bean.payment.wx.util.QrcodeUtils; import com.qcsoft.easyqinyutools.message.ReturnMsg; import com.qcsoft.payment.controller.commom.BaseController; import com.qcsoft.payment.service.PayService; import com.qcsoft.swaggerui.anno.ApiTag; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*;  import javax.imageio.ImageIO; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.awt.image.BufferedImage; import java.io.IOException;   /**  * @Description: 支付控制中心  * @Author:   * @Date:   */ @RestController @RequestMapping("/v2") public class PayController extends BaseController {  private static final Logger logger = LoggerFactory.getLogger(PayController.class);   @Autowired  private PayService payService;   //private final AtomicInteger tick = new AtomicInteger();   /**   * 統一預支付接口(統一下單)   *   * @param orderParam {dh:訂單號,payType:支付方式(WXPAY、ALIPAY、MEMBER_CARD、ACCOUNT)，appCode:商家編碼,   *     tradeType:支付方式類型(NATIVE、JSAPI、APP、MWEB)，openId:支付方式為JSAPI必傳，reqId:請求的真實IP地址   *     ,redirectUrl:支付成功返回地址，appCode:商家編碼,outTradeNo:商務訂單號，timeExpire，訂單到期時間   *     ,totalAmount:訂單金額,body:商品簡單描述，subject:訂單標題,quitUrl:中途退出}   * @param token  token   * @return (微信公眾號 / 小程序返回一串json字符串 : { appId :, timeStamp :, nonceStr : ， info_package :, paySign :, signType : }, 前端使用微信sdk調用微信支付)   * (微信掃碼支付返回一個連接，前端需要把連接生成一個二維碼使用,連接如:weixin://123.123.com/***)   * (微信H5--返回一個連接，前端需要把連接生成一個連接前端直接跳轉該連接使用,使用如:location.href='weixin://123.123.com/***')   * (支付寶掃碼支付--返回一個連接，前端直接跳轉到該連接使用,使用如:location.href='weixin://123.123.com/***')   * (支付寶掃碼H5--返回一個頁面form表單，前端需要把這個form表單渲染到h6頁面上,使用如:$("#view).html(alipayForm)')   * (支付寶app支付--返回一個參數包，如sdk-version=**&service=**&&service=**&&body=**&&out_trade_no=**&,前端使用支付寶sdk調用app支付')   * {   * wxNativeUrl:微信掃碼地址   * wxAppPackage:app支付sdk參數包   * wxJsapiPackage:公眾號支付包   * wxH5Url:h6支付url   * wxScanUrl:wxScanUrl   * alipayScanUrl:支付寶掃碼支付url   * alipayH5Form:支付寶h6支付表單   * alipayAppParamStr:支付寶app支付參數支付串   * }   * @throws WxPayException   */  @RequestMapping(value = "/prePayOrder")  @ApiTag(SwaggerConstant.PAYMENT_001)  public ReturnMsg prePayOrder(@RequestBody PreOrderParam orderParam) {   String metadata = JSON.toJSONString(orderParam);   logger.info("PayController.prePayOrder----\n正在請求支付....，參數為>>>>{}", metadata);   ReturnMsg ret = new ReturnMsg();   //預下單   PrePayResult prePayResult = this.payService.payPreOrder(orderParam);   ret.setData(prePayResult);   return ret.success("下單成功，訂單有效期為" + orderParam.getTimeExpire());  }   /**   * 生成支付二維碼   *   * @param url 二維碼地址   * @throws IOException   */  @RequestMapping(value = "/createQrCode/url")  @ApiTag(SwaggerConstant.PAYMENT_001)  public void createQrCode(@PathVariable String url, HttpServletRequest request, HttpServletResponse response) throws IOException {   String queryString = request.getQueryString();   BufferedImage bufferedImage = QrcodeUtils.encode(url+queryString, 500, 500, null, null);   BufferedImage grayImage = QrcodeUtils.grayImage(bufferedImage);   ImageIO.write(grayImage, "png", response.getOutputStream());  }   }

2、PayService

package com.qcsoft.payment.service.impl;  import com.alibaba.fastjson.JSON; import com.alipay.api.AlipayClient; import com.qcsoft.commonbean.bean.common.KafkaConstant; import com.qcsoft.commonbean.bean.payment.ChinaumsConfig; import com.qcsoft.commonbean.bean.payment.PayLog; import com.qcsoft.commonbean.bean.payment.common.PayConstant; import com.qcsoft.commonbean.bean.payment.common.PrePayResult; import com.qcsoft.commonbean.bean.payment.common.WxPrePayResultPackage; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.commonbean.bean.payment.wx.bean.request.WxPayUnifiedOrderRequest; import com.qcsoft.commonbean.bean.payment.wx.bean.result.WxPayUnifiedOrderResult; import com.qcsoft.commonbean.bean.payment.wx.config.WxPayConfig; import com.qcsoft.easyqinyutools.utils.JsonUtil; import com.qcsoft.payment.commns.exception.BaseException; import com.qcsoft.payment.commns.exception.QYError; import com.qcsoft.payment.commns.utils.UserUtil; import com.qcsoft.payment.commns.utils.weixin.PackageUtil; import com.qcsoft.payment.service.*; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;  import java.util.SortedMap; import java.util.TreeMap;  @Service public class PayServiceImpl implements PayService {  public Logger logger = LoggerFactory.getLogger(getClass());  @Autowired  private AliPayService aliPayService;  @Autowired  private WxPayService wxPayService;  @Autowired  private ChinaumsPayService chinaumsPayService;   @Autowired  private UserUtil userUtil;  @Autowired  private PayLogService payLogService;    @Override  public PrePayResult payPreOrder(PreOrderParam orderParam) throws BaseException {   logger.info("PayServiceImpl.payPreOrder---->>>>\n準備下單.....，當前用戶訂單號[{}]", orderParam.getDh());   String temp = "";   PrePayResult payResult = new PrePayResult();   //校驗支付方式   String payType = orderParam.getPayType();   if (!StringUtils.isNotBlank(payType))    throw new BaseException(QYError.msg("請選擇支付方式!"));   if (PayConstant.WXPAY.toString().equals(payType)) {    //查詢商家配置信息    WxPayConfig config;    if (orderParam.getTradeType().equals(PayConstant.WECHATAPP.toString())) {     config = wxPayService.getWxMinPayConfigByAppCode(orderParam.getAppCode(), orderParam.getSysSoftwareCode());    } else {     config = wxPayService.getWxPayConfigByAppCode(orderParam.getAppCode(), orderParam.getBmCode());    }    //設置預支付請求參數    if (orderParam.getTradeType().equals(PayConstant.WECHATAPP.toString())) {     orderParam.setTradeType(PayConstant.JSAPI.toString());    }    WxPayUnifiedOrderRequest requestParam = wxPayService.packRequestParam(orderParam);    //開始請求預支付接口    WxPayUnifiedOrderResult result = wxPayService.wxPrePay(config, requestParam);    //根據支付類型設置值    WxPrePayResultPackage resultPackage = null;    if (orderParam.getTradeType().equals(PayConstant.APP.toString()) || orderParam.getTradeType().equals(PayConstant.JSAPI.toString()) || orderParam.getTradeType().equals(PayConstant.WECHATAPP.toString())) {     resultPackage = new WxPrePayResultPackage();     String timeMillis = PackageUtil.getTimeStamp();     String nonceString = PackageUtil.getNonceStr();     resultPackage.setAppId(result.getAppid());     resultPackage.setNonceStr(nonceString);     resultPackage.setTimeStamp(timeMillis);     resultPackage.setPrePayId(result.getPrepayId());     resultPackage.setInfoPackage("prepay_id=" + result.getPrepayId());     resultPackage.setSignType(requestParam.getSignType());     if (orderParam.getTradeType().equals(PayConstant.APP.toString())) {      SortedMap<String, String> returnData = PackageUtil.getReturnData(resultPackage, config.getMchId());      String paysign = PackageUtil.createSign(returnData, config.getMchKey());      resultPackage.setPaySign(paysign);      resultPackage.setInfoPackage(returnData.get("package"));      payResult.setWxAppPackage(resultPackage);     } else {      SortedMap<String, String> paypackageParams = new TreeMap<String, String>();      paypackageParams.put("appId", result.getAppid()); // appid      paypackageParams.put("timeStamp", timeMillis); //      paypackageParams.put("nonceStr", nonceString); //      paypackageParams.put("package", resultPackage.getInfoPackage()); //      paypackageParams.put("signType", resultPackage.getSignType());      String paysign = PackageUtil.createSign(paypackageParams, config.getMchKey());      resultPackage.setPaySign(paysign);      payResult.setWxJsapiPackage(resultPackage);     }    } else if (orderParam.getTradeType().equals(PayConstant.MWEB.toString())) {     payResult.setWxH5Url(result.getMwebUrl() + " &redirect_url=" + orderParam.getRedirectUrl());    } else if (orderParam.getTradeType().equals(PayConstant.NATIVE.toString())) {     payResult.setWxNativeUrl(result.getCodeURL());    }    //添加支付日志    insertPayLog(orderParam, KafkaConstant.PAYMENT_NOTIFY_001.getTopic(), "0", resultPackage, JSON.toJSONString(config));    return payResult;   } else if (PayConstant.ALIPAY.toString().equals(payType)) {    AlipayClient client = aliPayService.getAlipayClientByAppCode(orderParam.getAppCode());    if (orderParam.getTradeType().equals(PayConstant.APP.toString())) {     temp = aliPayService.aliAppPay(client, orderParam);     payResult.setAlipayAppParamStr(temp);    } else if (orderParam.getTradeType().equals(PayConstant.MWEB.toString())) {     temp = aliPayService.aliH5Pay(client, orderParam);     payResult.setAlipayH5Form(temp);    } else if (orderParam.getTradeType().equals(PayConstant.NATIVE.toString())) {     temp = aliPayService.aliScanPay(client, orderParam);     payResult.setAlipayScanUrl(temp);    }    //添加支付日志    insertPayLog(orderParam, KafkaConstant.PAYMENT_NOTIFY_001.getTopic(), "1", orderParam, JSON.toJSONString(aliPayService.getConfigByAppCode(orderParam.getAppCode())));    return payResult;   } else if (PayConstant.WECHATAPP.toString().equals(payType)) {    } else if (PayConstant.CHINAUMS.toString().equals(payType)) { //銀聯pos支付    //查詢商家配置信息    ChinaumsConfig config;    config = chinaumsPayService.getPayConfigByAppCode(orderParam.getAppCode(), orderParam.getBmCode());    if (orderParam.getTradeType().equals(PayConstant.CODE_SCAN.toString())) {     chinaumsPayService.codeScanPay(config, orderParam);    }    //添加支付日志    insertPayLog(orderParam, KafkaConstant.PAYMENT_NOTIFY_001.getTopic(), "3", orderParam, JSON.toJSONString(config));    return payResult;   }   logger.warn("用戶未選擇正確的支付方式");   throw new BaseException(QYError.msg("請選擇正確的支付方式!"));   }   public void insertPayLog(PreOrderParam orderParam, String topic, String moneyType, Object obj, String payConfigJsonStr) {   PayLog payLog = new PayLog();   payLog.setAppCode(orderParam.getAppCode());   payLog.setPayLogId(orderParam.getDh());   payLog.setMoneyType(moneyType);   payLog.setMqTopic(topic);   payLog.setMqStatus(0);   payLog.setPayNo(orderParam.getDh());   payLog.setRequest(JsonUtil.toJSon(obj));   payLog.setFee(orderParam.getTotalAmount());   payLog.setPayConfigJsonStr(payConfigJsonStr);   payLogService.saveOrUpdate(payLog);  } }

3、AliPayService

package com.qcsoft.payment.service;  import com.alipay.api.AlipayClient; import com.alipay.api.request.AlipayTradeRefundRequest; import com.alipay.api.response.AlipayTradeQueryResponse; import com.alipay.api.response.AlipayTradeRefundResponse; import com.qcsoft.commonbean.bean.payment.AlipayConfig; import com.qcsoft.commonbean.bean.payment.alipay.AliPayRefundParam; import com.qcsoft.commonbean.bean.payment.common.PayNotify; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.easyqinyutools.message.ReturnMsg;  import javax.servlet.http.HttpServletRequest; import java.util.Map;  public interface AliPayService {  /**   *   * @param alipayClient   * @param orderParam   * @param   * @return   */  String aliAppPay(AlipayClient alipayClient,PreOrderParam orderParam);    String aliScanPay(AlipayClient alipayClient, PreOrderParam orderParam);   String aliH5Pay(AlipayClient alipayClient, PreOrderParam orderParam);   void aliPayNotify(PayNotify params);   boolean rsaCheckV1(HttpServletRequest request,String appCode);   AlipayTradeQueryResponse aliPayOrderQuery(AlipayClient alipayClient, String out_trade_no);   AlipayClient getAlipayClientByAppCode(String appCode);   AlipayConfig getConfigByAppCode(String appCode);   /**   * 支付寶退款接口   * @param aliPayRefundParam   * @return   */  ReturnMsg aliPayRefund(AliPayRefundParam aliPayRefundParam);  }

AliPayServiceImpl

package com.qcsoft.payment.service.impl;  import com.alibaba.fastjson.JSON; import com.alipay.api.AlipayApiException; import com.alipay.api.AlipayClient; import com.alipay.api.DefaultAlipayClient; import com.alipay.api.domain.AlipayTradeAppPayModel; import com.alipay.api.domain.AlipayTradePrecreateModel; import com.alipay.api.domain.AlipayTradeRefundModel; import com.alipay.api.domain.AlipayTradeWapPayModel; import com.alipay.api.internal.util.AlipaySignature; import com.alipay.api.request.*; import com.alipay.api.response.*; import com.qcsoft.commonbean.bean.payment.AlipayConfig; import com.qcsoft.commonbean.bean.payment.alipay.AliPayRefundParam; import com.qcsoft.commonbean.bean.payment.common.PayConstant; import com.qcsoft.commonbean.bean.payment.common.PayNotify; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.easyqinyutools.message.ReturnMsg; import com.qcsoft.payment.commns.exception.BaseException; import com.qcsoft.payment.commns.exception.QYError; import com.qcsoft.payment.commns.utils.DateUtils; import com.qcsoft.payment.commns.utils.RedisUtil; import com.qcsoft.payment.service.AliPayService; import com.qcsoft.payment.service.AlipayConfigService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service;  import javax.servlet.http.HttpServletRequest; import java.net.URLEncoder; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.Map;  /**  * 支付寶相關業務實現類  */ @Service public class AliPayServiceImpl implements AliPayService {  private static final Logger logger = LoggerFactory.getLogger(AliPayServiceImpl.class);  @Autowired  private AlipayConfigService alipayConfigService;  @Autowired  private RedisUtil redisUtil;  @Value("${payNotifyUrl}")  private String notifyUrl;   /**   * APP支付   * 參數加簽   */  @Override  public String aliAppPay(AlipayClient alipayClient, PreOrderParam orderParam) {   logger.info("AliPayServiceImpl.aliAppPay--->>>\n支付寶預支付開始，\n支付類型為:APP支付,\n訂單號為:{}", orderParam.getDh());   Date date = new Date();   AlipayTradeAppPayResponse response = null;   // 發起App支付請求   AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();   // 訂單描述   model.setBody(orderParam.getBody());   // 訂單標題   model.setSubject(orderParam.getSubject());   // 商戶訂單號 就是商戶后臺生成的訂單號   model.setOutTradeNo(orderParam.getOutTradeNo());   // 該筆訂單允許的最晚付款時間，逾期將關閉交易。取值范圍：1m～15d。m-分鐘，h-小時，d-天，1c-當天 (屁股后面的字母一定要帶，不然報錯)   model.setTimeoutExpress(DateUtils.toString(date, orderParam.getTimeExpire()));   // 訂單總金額 ，默認單位為元，精確到小數點后兩位，取值范圍[0.01,100000000]   model.setTotalAmount(orderParam.getTotalAmount().toString());   // 銷售產品碼   model.setProductCode(PayConstant.ALIPAY_QUICK_WAP_WAY.getKey());   AlipayTradeAppPayRequest request = new AlipayTradeAppPayRequest();   request.setBizModel(model);   // request.setNotifyUrl("商戶外網可以訪問的異步地址，不寫就是不回調");   request.setNotifyUrl(notifyUrl + PayConstant.ALIPAY_05.getKey() + "/" + orderParam.getAppCode() + "/" + orderParam.getDh());   //支付成功返回地址   request.setReturnUrl(orderParam.getRedirectUrl());   // 通過api的方法請求阿里接口獲得反饋   logger.info("AliPayServiceImpl.aliAppPay----->\n支付寶預支付接口請求信息:{}", JSON.toJSONString(request));   try {    response = alipayClient.sdkExecute(request);   } catch (AlipayApiException e) {    logger.info("AliPayServiceImpl.aliAppPay----->\n支付寶預下單失敗,\n本次下單的訂單號為:{},\n相關報錯信息為:{}", orderParam.getDh(), response, e);    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + e.getMessage() + "]"));   }    logger.info("AliPayServiceImpl.aliAppPay----->\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));   if (response.isSuccess()) {    logger.info("AliPayServiceImpl.aliAppPay----->\n支付寶預下單成功,\n本次下單的訂單號為:{},商戶訂單號為:{}", orderParam.getDh(), orderParam.getOutTradeNo());   } else {    logger.error("AliPayServiceImpl.aliAppPay----->\n調用支付寶預下單接口失敗!\n具體信息為:\n{}", response.getBody());    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + response.getMsg() + "]"));   }   return response.getBody();  }    /**   * 掃碼支付   * 參數加簽   */  @Override  public String aliScanPay(AlipayClient alipayClient, PreOrderParam orderParam) {   logger.info("AliPayServiceImpl.aliScanPay--->>>\n支付寶預支付開始，\n支付類型為:掃碼支付,\n訂單號:{}", orderParam.getDh());   /* AlipayTradePagePayResponse response = null;*/   AlipayTradePrecreateResponse response = null;   Date date = new Date();   /**    * 設置請求model參數(body、subject、outTradeNo、totalAmount、timeoutExpress；必傳)    */   AlipayTradePrecreateModel model = new AlipayTradePrecreateModel();   // 訂單描述   model.setBody(orderParam.getBody());   // 訂單標題   model.setSubject(orderParam.getBody());   // 商戶訂單號 就是商戶后臺生成的訂單號   model.setOutTradeNo(orderParam.getOutTradeNo());   // 該筆訂單允許的最晚付款時間，逾期將關閉交易。取值范圍：1m～15d。m-分鐘，h-小時，d-天，1c-當天 (屁股后面的字母一定要帶，不然報錯)   model.setTimeoutExpress(orderParam.getTimeExpire());   //model.setSellerId(DateUtils.toString(date, "yyyyMMddHHmmssSSS"));   // 訂單總金額 ，默認單位為元，精確到小數點后兩位，取值范圍[0.01,100000000]   model.setTotalAmount(orderParam.getTotalAmount().toString());   //model.setProductCode(PayConstant.ALIPAY_FAST_INSTANT_TRADE_PAY.getKey());   // 選填   /**    * 創建支付寶掃碼支付請求接口類，設置相關請求處理信息，準備請求下單    */   AlipayTradePrecreateRequest request = new AlipayTradePrecreateRequest();   request.setBizModel(model);   // request.setNotifyUrl("商戶外網可以訪問的異步地址，不寫就是不回調");   request.setNotifyUrl(notifyUrl + PayConstant.ALIPAY_05.getKey() + "/" + orderParam.getAppCode() + "/" + orderParam.getDh());    //支付成功返回地址   request.setReturnUrl(orderParam.getRedirectUrl());   // 通過api的方法請求阿里接口獲得反饋 alipayClient.pageExecute(request)   try {    logger.info("支付寶掃碼付請求報文：{}",JSON.toJSONString(request));    response = alipayClient.execute(request)/**/;   } catch (AlipayApiException e) {    logger.info("AliPayServiceImpl.aliScanPay----->\n支付寶預下單失敗,\n本次下單的訂單號:{},\n相關報錯信息為:{}", orderParam.getDh(), response, e);    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + e.getMessage() + "]"));   }catch (Exception e){    e.printStackTrace();    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + e.getMessage() + "]"));   }    //打印返回信息   logger.info("AliPayServiceImpl.aliScanPay----->\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));   //判斷預下單返回狀態   if (response.isSuccess()) {    logger.info("AliPayServiceImpl.aliScanPay----->\n支付寶預下單成功,\n本次下單的訂單號:{},商務訂單號為", orderParam.getDh(), orderParam.getOutTradeNo());   } else {    logger.error("AliPayServiceImpl.aliScanPay----->\n調用支付寶預下單接口失敗!\n具體信息:\n{}", response.getBody());    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + response.getMsg() + "]"));   }    return response.getQrCode();  }    /**   * H5支付   * 參數加簽   */  @Override  public String aliH5Pay(AlipayClient alipayClient, PreOrderParam orderParam) {   logger.info("AliPayServiceImpl.aliH5Pay--->>>\n支付寶預支付開始，\n支付類型為:H5支付,\n訂單號:{}", orderParam.getDh());   String form = "";   AlipayTradeWapPayResponse response = null;   /**    * 封裝請求支付信息    */   AlipayTradeWapPayModel payModel = new AlipayTradeWapPayModel();   payModel.setOutTradeNo(orderParam.getOutTradeNo());   payModel.setSubject(orderParam.getBody());   payModel.setTotalAmount(orderParam.getTotalAmount().toString());   payModel.setBody(orderParam.getBody());   payModel.setTimeoutExpress(orderParam.getTimeExpire());   payModel.setProductCode(PayConstant.ALIPAY_QUICK_WAP_WAY.getKey());   payModel.setQuitUrl(URLEncoder.encode(orderParam.getQuitUrl()));   /**    * 創建支付寶H5支付請求接口類，設置相關請求處理信息，準備請求下單    */   AlipayTradeWapPayRequest alipay_request = new AlipayTradeWapPayRequest();   alipay_request.setBizModel(payModel);   // 設置異步通知地址   logger.info("通知地址{}", notifyUrl + PayConstant.ALIPAY_05.getKey() + "/" + orderParam.getAppCode() + "/" + orderParam.getDh());   alipay_request.setNotifyUrl(notifyUrl + PayConstant.ALIPAY_05.getKey() + "/" + orderParam.getAppCode() + "/" + orderParam.getDh());   // 設置同步地址   alipay_request.setReturnUrl(URLEncoder.encode(orderParam.getRedirectUrl()));   // 調用SDK生成表單   try {    response = alipayClient.pageExecute(alipay_request);    if (response.isSuccess()) {     form = response.getBody();     logger.info("AliPayServiceImpl.aliH5Pay----->>>>\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));    } else {     logger.info("AliPayServiceImpl.aliH5Pay----->>>>\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));     throw new BaseException(QYError.msg("支付寶"));    }    } catch (AlipayApiException e) {    logger.info("AliPayServiceImpl.aliH5Pay----->>>>\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));    throw new BaseException(QYError.msg("調用支付寶預下單接口失敗![" + e.getMessage() + "]"));   }   logger.info("AliPayServiceImpl.aliH5Pay----->>>>\n支付寶預支付接口返回信息:{}", JSON.toJSONString(response));   /**    * 打印日志，并返回鏈接    */   return form;  }   /**   * 支付寶通知   *   * @param params   */  @Override  public void aliPayNotify(PayNotify params) {   logger.info("AliPayServiceImpl.appAliPayNotify-\n阿里服務器消費手機回調參數獲取和參數判斷-------》》》");   /**    * 打印信息    */   //校驗支付金額   /*ReturnMsg returnMsg = restTemplate.postForEntity(params.getNoOrderAmountUrl(), params, ReturnMsg.class).getBody();   if (!returnMsg.isSuccess()) {    logger.info("WxPayController.wxPayNotify-->\n校驗訂單金額失敗，請核實商務訂單號:{}", params);    throw new BaseException(QYError.msg("校驗訂單金額失敗!商務訂單號[" + params.getOutTradeNo() + "]"));   }*/   /**    * 判斷支付狀態    */   if (params.getTradeStatus().equals("TRADE_SUCCESS")) {    logger.info("AliPayServiceImpl.appAliPayNotify----\n支付寶支付成功!商務訂單號[{}]----->>", params.getOutTradeNo(), JSON.toJSONString(params));   } else {    logger.error("AliPayServiceImpl.appAliPayNotify---\n支付寶支付失敗!商務訂單號[{}]---->>", params.getOutTradeNo());    throw new BaseException(QYError.msg("支付寶支付失敗!商務訂單號[" + params.getOutTradeNo() + "]"));   }  }   @Override  public boolean rsaCheckV1(HttpServletRequest request, String appCode) {   //獲取支付寶GET過來反饋信息   Map<String, String> params = new HashMap<String, String>();   // 簽名驗證(對支付寶返回的數據驗證，確定是支付寶返回的)   boolean result = false;   try {    // 從支付寶回調的request域中取值    Map<String, String[]> requestParams = request.getParameterMap();    for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext(); ) {     String name = 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);    }    logger.info("AliPayServiceImpl.appAliPayNotify--\n支付寶通知數據包----->>>>>>>>>>>>>>>{}", JSON.toJSONString(params));    // 商家編碼     AlipayConfig alipayConfig = getConfigByAppCode(appCode);    result = AlipaySignature.rsaCheckV1(params, alipayConfig.getAliPublicKey(),      PayConstant.ALIPAY_CHARSET.getKey(), PayConstant.ALIPAY_SIGN_TYPE_RSA2.getKey());   } catch (Exception e) {    logger.error("AliPayServiceImpl.appAliPayNotify---\n校驗簽名失敗!商務訂單號[{}]---->>", JSON.toJSONString(request), e);    throw new BaseException(QYError.msg("支付寶支付校驗簽名失敗!"));   }   return result;  }   /**   * 根據商務訂單號查詢查詢支付信息   *   * @param alipayClient   * @param out_trade_no   * @return   */  @Override  public AlipayTradeQueryResponse aliPayOrderQuery(AlipayClient alipayClient, String out_trade_no) {   logger.info("AliPayServiceImpl.aliPayOrderQuery----\n根據商務訂單號查詢支付寶訂單信息,\n商務訂單號:[{}]----》》》", out_trade_no);   AlipayTradeQueryResponse response = null;   AlipayTradeQueryRequest request = new AlipayTradeQueryRequest();   //設置查詢參數   Map<String, String> bizModel = new HashMap<>();   bizModel.put("out_trade_no", out_trade_no);   request.setBizContent(JSON.toJSONString(bizModel));   //開始查詢   try {    response = alipayClient.execute(request);   } catch (AlipayApiException e) {    logger.error("AliPayServiceImpl.aliPayOrderQuery--->>\n支付寶訂單查詢失敗,\n商務訂單號:[{}]", out_trade_no);    throw new BaseException(QYError.msg("訂單號[" + out_trade_no + "],訂單支付失敗,狀態碼為[" + response.getTradeStatus() + "]"));   }    logger.info("AliPayServiceImpl.aliPayOrderQuery---->>\n查詢支付寶訂單信息,\n商務訂單號:[{}],\n返回信息:{}", out_trade_no, JSON.toJSONString(response));   //查詢狀態處理   if (response.isSuccess()) {    logger.info("AliPayServiceImpl.aliPayOrderQuery--->>\n支付寶訂單查詢成功,\n商務訂單號:[{}]", out_trade_no);   } else {    logger.error("AliPayServiceImpl.aliPayOrderQuery--->>\n支付寶訂單查詢失敗,\n商務訂單號:[{}]", out_trade_no);    throw new BaseException(QYError.msg("訂單號[" + out_trade_no + "],訂單支付失敗,狀態碼為[" + response.getTradeStatus() + "]"));   }    return response;  }    /**   * 根據商家編碼設置alipay配置信息   *   * @param appCode 商家編碼   * @return   */  @Override  public AlipayClient getAlipayClientByAppCode(String appCode) {   logger.info("AliPayServiceImpl.getAlipayClientByAppCode--->>\n獲取支付寶配置信息:[{}]", appCode);   AlipayConfig alipayConfig = null;   /**    * 獲取商家支付寶配置信息(優先級:1-redis,2-mysql，3-用戶系統)    */   try {    alipayConfig = getConfigByAppCode(appCode);    if (alipayConfig == null) {     logger.info("AliPayServiceImpl.getAlipayClientByAppCode--->>\n獲取支付寶支付配置信息失敗:[{}]", appCode);     logger.info("AliPayServiceImpl.getAlipayClientByAppCode--->>\n獲取支付寶支付配置信息失敗:[{}{}]", appCode,alipayConfig);     throw new BaseException(QYError.msg("獲取支付寶支付配置信息失敗!"));    }   } catch (Exception e) {    logger.error("AliPayServiceImpl.getAlipayClientByAppCode--->>\n獲取支付寶配置信息失敗:[{}]", e);    throw new BaseException(QYError.msg("獲取支付寶配置信息失敗!"));   }   AlipayClient alipayClient = new DefaultAlipayClient(     PayConstant.ALIPAY_01.getKey(),     alipayConfig.getAliAppid(),     alipayConfig.getAliPrivateKey(),     PayConstant.ALIPAY_FORMAT.getKey(),     PayConstant.ALIPAY_CHARSET.getKey(),     alipayConfig.getAliPublicKey(),     PayConstant.ALIPAY_SIGN_TYPE_RSA2.getKey());   return alipayClient;  }   //獲取商家支付寶的配置信息  public AlipayConfig getConfigByAppCode(String appCode) {   AlipayConfig alipayConfig = alipayConfigService.selectByAppCode(appCode);   return alipayConfig;  }    /**   * 支付寶退款接口   * @param aliPayRefundParam   * @return   */  public ReturnMsg aliPayRefund(AliPayRefundParam aliPayRefundParam){   ReturnMsg returnMsg=new ReturnMsg();    String appCode=aliPayRefundParam.getAppCode();   AlipayClient alipayClient = getAlipayClientByAppCode(appCode);    AlipayTradeRefundResponse response = null;   AlipayTradeRefundModel model = new AlipayTradeRefundModel();   //訂單支付時傳入的商戶訂單號,不能和 trade_no同時為空。   model.setOutTradeNo(aliPayRefundParam.getOutTradeNo());   //支付寶交易號，和商戶訂單號不能同時為空   //model.setTradeNo(aliPayRefundParam.getTradeNo());   //標識一次退款請求，同一筆交易多次退款需要保證唯一，如需部分退款，則此參數必傳。   model.setOutRequestNo(aliPayRefundParam.getOutRequestNo());   //    需要退款的金額，該金額不能大于訂單金額,單位為元，支持兩位小數   model.setRefundAmount(aliPayRefundParam.getRefundAmount());   //退款的原因說明   model.setRefundReason(aliPayRefundParam.getRefundReason());    /**    * 創建支付寶掃碼支付請求接口類，設置相關請求處理信息，準備請求下單    */   AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();   request.setBizModel(model);   //商戶外網可以訪問的異步地址，不寫就是不回調   request.setNotifyUrl(notifyUrl + PayConstant.ALIPAY_05.getKey() + "/" + aliPayRefundParam.getAppCode() + "/" + aliPayRefundParam.getDh());   //支付成功返回地址   request.setReturnUrl(aliPayRefundParam.getRedirectUrl());    // 通過api的方法請求阿里接口獲得反饋 alipayClient.pageExecute(request)   try {    logger.info("支付寶退款請求完整報文：{}",JSON.toJSONString(request));    response = alipayClient.execute(request)/**/;   } catch (AlipayApiException e) {    logger.info("支付寶退款失敗,\n本次下單的訂單號:{},\n相關報錯信息為:{}", aliPayRefundParam.getDh(), response, e);    throw new BaseException(QYError.msg("調用支付寶預退款失敗![" + e.getMessage() + "]"));   }catch (Exception e){    e.printStackTrace();    throw new BaseException(QYError.msg("支付寶預退款失敗![" + e.getMessage() + "]"));   }    //打印返回信息   logger.info("支付寶退款失敗:{}", JSON.toJSONString(response));   //判斷預下單返回狀態   if (response.isSuccess()&&"Y".equals(response.getFundChange())) {    logger.info("AliPayServiceImpl.aliScanPay----->\n支付寶退款成功,\n本次下單的訂單號:{},商務訂單號為，{}", aliPayRefundParam.getDh(), aliPayRefundParam.getOutTradeNo());    return returnMsg.setData("退款成功");    } else {    logger.error("AliPayServiceImpl.aliScanPay----->\n調用支付寶退款接口失敗!\n具體信息:\n{}", response.getBody());    throw new BaseException(QYError.msg("調用支付寶退款接口失敗![" + response.getBody() + "]"));   }  }  }

4、WxPayService

package com.qcsoft.payment.service;  import com.qcsoft.commonbean.bean.payment.WxMinConfig; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.commonbean.bean.payment.wx.bean.WxRefund; import com.qcsoft.commonbean.bean.payment.wx.bean.entpay.EntPayParam; import com.qcsoft.commonbean.bean.payment.wx.bean.entpay.EntPayResult; import com.qcsoft.commonbean.bean.payment.wx.bean.request.WxPayUnifiedOrderRequest; import com.qcsoft.commonbean.bean.payment.wx.bean.result.BaseWxPayResult; import com.qcsoft.commonbean.bean.payment.wx.bean.result.WxPayOrderQueryResult; import com.qcsoft.commonbean.bean.payment.wx.bean.result.WxPayUnifiedOrderResult; import com.qcsoft.commonbean.bean.payment.wx.config.WxPayConfig; import com.qcsoft.commonbean.bean.payment.wx.exception.WxPayException;   /**  * 微信預支付  * @param appId 應用ID(微信公眾號)  * @param mchId 商務號ID  * @param mchKey 商務號密鑰  * @param notifyUrl 異步通知地址  * @param signType 簽名類型  * @param body 描述  * @param totalFee 金額  * @param spbillCreateIp app和h6支付需要用戶的真實請求地址  * @param tradeType  * @param outTradeNo  * @return  */ public interface WxPayService {  /**   *   * @param config {appId:應用ID,mchId:商務號ID,mchKey:商務號密鑰,notifyUrl:異步通知地址,signType:簽名類型}   * @param request {body:訂單描述,totalFee:金額,   *    spbillCreateIp:app和h6支付需要用戶的真實請求地址Native支付填調用微信支付API的機器IP,   *    tradeType:SAPI--公眾號支付、NATIVE--原生掃碼支付、APP--app支付，統一下單接口trade_type的傳參可參考這里,   *    outTradeNo:商戶訂單號，productId：商品Id(掃碼支付必傳，其他選填),openid:公眾號openId}   * @return   */  WxPayUnifiedOrderResult wxPrePay(WxPayConfig config, WxPayUnifiedOrderRequest request);   /**   * 根據appCode獲取商家微信支付配置   * @param appCode   * @return   */  WxPayConfig getWxPayConfigByAppCode(String appCode,String bmCode);   WxPayConfig getWxMinPayConfigByAppCode(String appCode,String sysSoftwareCode);   /**   * 封裝預下單參數實體   * @param orderParam 預支付接口參數實體   * @param order 點單   * @return   */  WxPayUnifiedOrderRequest packRequestParam(PreOrderParam orderParam);    /**   * 查詢訂單   * @param appCode 商家編碼   * @param dh 訂單號   * @param sysSoftwareCode   */  WxPayOrderQueryResult wxPayOrderQuery(String appCode, String bmCode, String dh, Integer type, String sysSoftwareCode);    /**   * 企業支付   * @param params   * @return:   * @Author:    * @date:    */  BaseWxPayResult entPay(EntPayParam params) throws WxPayException; }

WxPayServiceImpl

package com.qcsoft.payment.service.impl;  import com.alibaba.fastjson.JSON; import com.qcsoft.commonbean.bean.payment.PayLog; import com.qcsoft.commonbean.bean.payment.WxConfig; import com.qcsoft.commonbean.bean.payment.WxMinConfig; import com.qcsoft.commonbean.bean.payment.common.PayConstant; import com.qcsoft.commonbean.bean.payment.common.PayNotify; import com.qcsoft.commonbean.bean.payment.wx.bean.PreOrderParam; import com.qcsoft.commonbean.bean.payment.wx.bean.entpay.*; import com.qcsoft.commonbean.bean.payment.wx.bean.request.WxPayOrderQueryRequest; import com.qcsoft.commonbean.bean.payment.wx.bean.request.WxPayUnifiedOrderRequest; import com.qcsoft.commonbean.bean.payment.wx.bean.result.BaseWxPayResult; import com.qcsoft.commonbean.bean.payment.wx.bean.result.WxPayOrderQueryResult; import com.qcsoft.commonbean.bean.payment.wx.bean.result.WxPayUnifiedOrderResult; import com.qcsoft.commonbean.bean.payment.wx.config.WxPayConfig; import com.qcsoft.commonbean.bean.payment.wx.exception.WxPayException; import com.qcsoft.commonbean.bean.payment.wx.handler.EntPayHandler; import com.qcsoft.commonbean.bean.payment.wx.handler.WxPayHandler; import com.qcsoft.commonbean.bean.payment.wx.handler.impl.EntPayHandlerImpl; import com.qcsoft.commonbean.bean.payment.wx.handler.impl.WxPayHandlerApacheHttpImpl; import com.qcsoft.payment.commns.exception.BaseException; import com.qcsoft.payment.commns.exception.QYError; import com.qcsoft.payment.commns.utils.DateUtils; import com.qcsoft.payment.commns.utils.RedisUtil; import com.qcsoft.payment.service.PayLogService; import com.qcsoft.payment.service.WxConfigService; import com.qcsoft.payment.service.WxMinConfigService; import com.qcsoft.payment.service.WxPayService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service;  import java.math.BigDecimal; import java.util.Date;  @Service @Slf4j public class WxPayServiceImpl implements WxPayService {  private static final Logger logger = LoggerFactory.getLogger(WxPayServiceImpl.class);   @Value("${payNotifyUrl}")  private String notifyUrl;  @Autowired  private RedisUtil redisUtil;  @Autowired  private WxConfigService wxConfigService;  @Autowired  private WxMinConfigService wxMinConfigService;  @Autowired  private PayLogService payLogService;   /**   * @param config {appId:應用ID,mchId:商務號ID,mchKey:商務號密鑰,notifyUrl:異步通知地址,signType:簽名類型}   * @param request {body:訂單描述,totalFee:金額,   *    spbillCreateIp:app和h6支付需要用戶的真實請求地址Native支付填調用微信支付API的機器IP,   *    tradeType:SAPI--公眾號支付、NATIVE--原生掃碼支付、APP--app支付，統一下單接口trade_type的傳參可參考這里,   *    outTradeNo:商戶訂單號，productId：商品Id(掃碼支付必傳，其他選填),openid:公眾號openId} 還有很多參數選填   * @return   * @throws WxPayException   */  @Override  public WxPayUnifiedOrderResult wxPrePay(WxPayConfig config, WxPayUnifiedOrderRequest request) {   logger.info("WxPayServiceImpl.wxPrePay--->>\n微信預支付,\n商務訂單號:[{}]", request.getOutTradeNo());   WxPayHandler wx = new WxPayHandlerApacheHttpImpl();   WxPayUnifiedOrderResult orderResult = null;   wx.setConfig(config);   log.info("WxPayUnifiedOrderResult ={}", config.getNotifyUrl());   try {    orderResult = wx.unifiedOrder(request);   } catch (WxPayException e) {    logger.error("WxPayServiceImpl.wxPrePay--->>\n微信預支付失敗,\n商務訂單號:[{}]", request.getOutTradeNo(), orderResult);    logger.error("異常信息{}", e.getMessage());    throw new BaseException(QYError.msg("訂單號[" + request.getOutTradeNo() + "]預支付失敗!"));   }   return orderResult;  }    /**   * 根據商家編碼獲取微信商戶配置信息   *   * @param appCode   * @return   */  @Override  public WxPayConfig getWxPayConfigByAppCode(String appCode, String bmCode) {   logger.info("WxPayServiceImpl.getWxPayConfigByAppCode--->>\n獲取微信支付配置信息:appCode[{}],bmCode[{}]", appCode, bmCode);   WxConfig config = null;   WxPayConfig wxPayConfig = new WxPayConfig();   /**    * 獲取商家支付寶配置信息(優先級:1-redis,2-mysql，3-用戶系統)    */   try {    //2、mysql    if (config == null) {     if (StringUtils.isNotBlank(bmCode)) {      config = wxConfigService.selectByBmCode(bmCode, appCode);      //如果部門取不到，則去商家的配置      if (config == null)       config = wxConfigService.selectByAppCode(appCode);     } else {      config = wxConfigService.selectByAppCode(appCode);     }    }    if (config == null) {     logger.warn("WxPayServiceImpl.getWxPayConfigByAppCode--->>\n獲取微信支付配置信息失敗:[{}]", appCode);     throw new BaseException(QYError.msg("獲取微信支付配置信息失敗!"));    }   } catch (Exception e) {    logger.error("WxPayServiceImpl.getWxPayConfigByAppCode--->>\n獲取微信支付配置信息失敗:[{}]", e);    throw new BaseException(QYError.msg("獲取微信支付配置信息失敗!"));   }   //根據appCode查詢商家微信配置信息   wxPayConfig.setAppId(config.getAppid());   wxPayConfig.setMchId(config.getMchId());   wxPayConfig.setMchKey(config.getMchKeySecret());   wxPayConfig.setSignType(PayConstant.WXPAY_SIGNTYPE_MD5.getKey());   wxPayConfig.setKeyUrl(config.getCrtPath());   wxPayConfig.setKeyPath(config.getCrtPath());   log.info("獲取微信公眾號配置為 [{}],轉為微信支付實體為 [{}]",config,wxPayConfig);   return wxPayConfig;  }    @Override  public WxPayConfig getWxMinPayConfigByAppCode(String appCode, String sysSoftwareCode) {   logger.error("WxPayServiceImpl.getWxMinPayConfigByAppCode--->>\n獲取微信小程序支付配置信息:[{}]", appCode);   if (StringUtils.isBlank(sysSoftwareCode)) {    sysSoftwareCode = "store-service";   }   WxMinConfig config = null;   WxPayConfig wxPayConfig = new WxPayConfig();   /**    * 獲取商家支付寶配置信息(優先級:1-redis,2-mysql，3-用戶系統)    */   try {    if (config == null) {     //config = wxMinConfigService.selectByAppCode(appCode);     config = wxMinConfigService.selectBySysSoftwareCode(appCode,sysSoftwareCode);    }    if (config == null) {     logger.warn("WxPayServiceImpl.getWxMinPayConfigByAppCode--->>\n獲取微信小程序支付配置信息失敗:[{}]", appCode);     throw new BaseException(QYError.msg("獲取微信支付配置信息失敗!"));    }   } catch (Exception e) {    logger.error("WxPayServiceImpl.getWxMinPayConfigByAppCode--->>\n獲取微信小程序支付配置信息失敗:[{}]", e);    throw new BaseException(QYError.msg("獲取微信小程序支付配置信息失敗!"));   }   //根據appCode查詢商家微信配置信息   wxPayConfig.setAppId(config.getAppid());   wxPayConfig.setMchId(config.getMchId());   wxPayConfig.setMchKey(config.getMchKeySecret());   wxPayConfig.setSignType(PayConstant.WXPAY_SIGNTYPE_MD5.getKey());   wxPayConfig.setKeyUrl(config.getCrtPath());   wxPayConfig.setKeyPath(config.getCrtPath());   log.info("獲取微信小程序退款配置為 [{}],轉為微信支付實體為 [{}]",config,wxPayConfig);   return wxPayConfig;  }   /**   * 封裝預下單參數實體   *   * @param orderParam 預支付接口參數實體   * @param order  點單   * @return   */  @Override  public WxPayUnifiedOrderRequest packRequestParam(PreOrderParam orderParam) {   Date date = new Date();   BigDecimal paramAmount = new BigDecimal(orderParam.getTotalAmount().toString());   BigDecimal multiplyNum = new BigDecimal("100");   WxPayUnifiedOrderRequest request = WxPayUnifiedOrderRequest.newBuilder()     .body(orderParam.getBody())     .totalFee(paramAmount.multiply(multiplyNum).intValue())     .spbillCreateIp(orderParam.getReqId())     .notifyUrl(notifyUrl + PayConstant.WXPAY_09.getKey())     .tradeType(orderParam.getTradeType())     .outTradeNo(orderParam.getOutTradeNo())     .build();   log.info("WxPayUnifiedOrderRequest = {}", PayConstant.WXPAY_09.getKey());    request.setProductId(orderParam.getDh());   request.setDetail(orderParam.getSubject());   PayNotify payNotify = new PayNotify();   payNotify.setAppCode(orderParam.getAppCode());   payNotify.setCode(orderParam.getBmCode());   payNotify.setDh(orderParam.getDh());   request.setAttach(JSON.toJSONString(payNotify));   if (orderParam.getTradeType().equals(PayConstant.JSAPI.toString())) {    request.setOpenid(orderParam.getOpenId());   }   //開始時間   request.setTimeStart(DateUtils.getLastMinute(date, 0));   //有效期   request.setTimeExpire(orderParam.getTimeExpire());   return request;  }   /**   * 訂單查詢   *   * @param appCode 商家編碼   * @param dh  訂單號   * @param sysSoftwareCode   * @return   */  @Override  public WxPayOrderQueryResult wxPayOrderQuery(String appCode, String bmCode, String dh, Integer type, String sysSoftwareCode) {   logger.info("WxPayServiceImpl.wxPayOrderQuery--->>\n微信訂單查詢,\n本次查詢的商家編碼為:[{}],商務訂單號:[{}]", appCode, dh);   WxPayHandler handler = new WxPayHandlerApacheHttpImpl();   WxPayOrderQueryRequest request = new WxPayOrderQueryRequest();   WxPayOrderQueryResult queryResult = null;   WxPayConfig config = null;     try {    PayLog payLog = payLogService.selectByDh(dh);    if (payLog==null) {     //商家的微信支付     if (type == null || type == 1) {      bmCode = null;      config = this.getWxPayConfigByAppCode(appCode, bmCode);      //部門的微信支付支付     } else if (type == 2) {      config = this.getWxPayConfigByAppCode(appCode, bmCode);      //商家小程序支付     } else if (type == 3) {      config = this.getWxMinPayConfigByAppCode(appCode,sysSoftwareCode);     }    }else{     config = JSON.parseObject(payLog.getPayConfigJsonStr(), WxPayConfig.class);    }    request.setOutTradeNo(dh);    handler.setConfig(config);    queryResult = handler.queryOrder(request);    logger.info("WxPayServiceImpl.wxPayOrderQuery--->>\n微信訂單查詢成功,\n返回包信息:[{}]", JSON.toJSONString(queryResult));   } catch (WxPayException e) {    logger.error("WxPayServiceImpl.wxPayOrderQuery--->>\n微信訂單查詢失敗,\n商務訂單號:[{}]", dh);    throw new BaseException(QYError.msg("微信訂單查詢失敗,商務訂單號:[{}]" + dh + ""));   }   return queryResult;  }  /**   * 企業支付   * @param params   * @return: com.qcsoft.commonbean.bean.payment.wx.bean.result.BaseWxPayResult   * @Author:    * @date:   */  @Override  public BaseWxPayResult entPay(EntPayParam params) throws WxPayException {   WxPayHandler wxPayHandler = new WxPayHandlerApacheHttpImpl();   WxPayConfig config = null;   EntPayResult result = null;   EntPayBankResult bankResult = null;   if (params.getTradeType() != null && params.getTradeType() == 3) {    config = this.getWxMinPayConfigByAppCode(params.getAppCode(),params.getSysSoftwareCode());   } else {    config = this.getWxPayConfigByAppCode(params.getAppCode(), params.getBmCode());   }   config.setUseKey(true);   wxPayHandler.setConfig(config);   if (params.getTradeType()==1) {    EntPayRequest request = packEntPayRequest(params,config);    EntPayHandler entPayHandler = new EntPayHandlerImpl(wxPayHandler);     result = entPayHandler.entPay(request);    return result;   }else{    EntPayBankRequest request = packEntPayBankRequest(params);    EntPayHandler entPayHandler = new EntPayHandlerImpl(wxPayHandler);    bankResult = entPayHandler.payBank(request);    return bankResult;   }  }  /**   * 封裝微信企業支付請求參數   * @param params   * @return: com.qcsoft.commonbean.bean.payment.wx.bean.entpay.EntPayRequest   * @Author:    * @date:    */  public EntPayRequest packEntPayRequest(EntPayParam params,WxPayConfig config) {   EntPayRequest request = new EntPayRequest();   request.setAmount(params.getAmount().multiply(new BigDecimal("10")).intValue());   request.setCheckName("NO_CHECK");   request.setOpenid(params.getOpenid());   request.setSpbillCreateIp(params.getSpbillCreateIp());   request.setPartnerTradeNo(params.getPartnerTradeNo());   request.setMchAppid(config.getAppId());   request.setMchId(config.getMchId());   request.setDescription(params.getDesc());   return request;  }    /**   * 封裝銀行卡企業支付參數   * @param params   * @return: com.qcsoft.commonbean.bean.payment.wx.bean.entpay.EntPayBankRequest   * @Author:    * @date:    */  public EntPayBankRequest packEntPayBankRequest(EntPayParam params) {   EntPayBankRequest request = new EntPayBankRequest();   request.setAmount(params.getAmount().multiply(new BigDecimal("10")).intValue());   request.setBankCode(params.getBankCode());   request.setEncTrueName(params.getEncTrueName());   request.setPartnerTradeNo(params.getPartnerTradeNo());   request.setDescription(params.getDesc());   return request;  } }

5、這些類是和數據庫交互的增刪查該類

@Autowired private WxConfigService wxConfigService; @Autowired private WxMinConfigService wxMinConfigService; @Autowired private PayLogService payLogService; @Autowired private AlipayConfigService alipayConfigService;

到此，關于“怎么用Java也實現微信和支付寶支付功能”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！