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表單渲染到h5頁面上,使用如:$('#view).html(alipayForm)’) * (支付寶app支付--返回一個參數包，如sdk-version=**&service=**&&service=**&&body=**&&out_trade_no=**&,前端使用支付寶sdk調用app支付’) * { * wxNativeUrl:微信掃碼地址 * wxAppPackage:app支付sdk參數包 * wxJsapiPackage:公眾號支付包 * wxH5Url:h5支付url * wxScanUrl:wxScanUrl * alipayScanUrl:支付寶掃碼支付url * alipayH5Form:支付寶h5支付表單 * 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;@Servicepublic 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;/** * 支付寶相關業務實現類 */@Servicepublic 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和h5支付需要用戶的真實請求地址 * @param tradeType * @param outTradeNo * @return */public interface WxPayService { /** * * @param config {appId:應用ID,mchId:商務號ID,mchKey:商務號密鑰,notifyUrl:異步通知地址,signType:簽名類型} * @param request {body:訂單描述,totalFee:金額, * spbillCreateIp:app和h5支付需要用戶的真實請求地址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@Slf4jpublic 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和h5支付需要用戶的真實請求地址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 實現微信和支付寶支付功能的文章就介紹到這了,更多相關Java 微信和支付寶支付內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！