package org.yeshi.utils.alipay;
|
|
import com.alipay.api.AlipayApiException;
|
import com.alipay.api.AlipayClient;
|
import com.alipay.api.DefaultAlipayClient;
|
import com.alipay.api.request.AlipayFundAccountQueryRequest;
|
import com.alipay.api.request.AlipayFundTransCommonQueryRequest;
|
import com.alipay.api.request.AlipayFundTransUniTransferRequest;
|
import com.alipay.api.response.AlipayFundAccountQueryResponse;
|
import com.alipay.api.response.AlipayFundTransCommonQueryResponse;
|
import com.alipay.api.response.AlipayFundTransUniTransferResponse;
|
import net.sf.json.JSONObject;
|
import org.apache.commons.beanutils.BeanUtils;
|
import org.apache.commons.io.IOUtils;
|
import org.yeshi.utils.StringUtil;
|
import org.yeshi.utils.entity.alipay.AlipayAppInfo;
|
import org.yeshi.utils.entity.alipay.AlipayTransferInfo;
|
import org.yeshi.utils.exception.AlipayCommonException;
|
import org.yeshi.utils.exception.AlipayTransferException;
|
|
import java.lang.reflect.InvocationTargetException;
|
import java.math.BigDecimal;
|
|
public class AlipayUtil {
|
|
public static AlipayClient getAlipayClient(AlipayAppInfo app) throws AlipayApiException {
|
if (app.getCertInfo() == null) {
|
AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", app.getAppId(), app.getPrivateKey(), "json", "GBK", app.getAlipayPublicKey(), "RSA2");
|
return alipayClient;
|
} else {
|
String privateKey = app.getPrivateKey();
|
MyCertAlipayRequest certAlipayRequest = new MyCertAlipayRequest();
|
certAlipayRequest.setServerUrl("https://openapi.alipay.com/gateway.do");
|
certAlipayRequest.setAppId(app.getAppId());
|
certAlipayRequest.setPrivateKey(privateKey);
|
certAlipayRequest.setFormat("json");
|
certAlipayRequest.setCharset("GBK");
|
certAlipayRequest.setSignType("RSA2");
|
certAlipayRequest.setCertStream(
|
app.getCertInfo().getAppCertPublicKeyStream());
|
certAlipayRequest.setAlipayPublicCertStream(
|
app.getCertInfo().getAlipayPublicCertStream());
|
certAlipayRequest.setRootCertStream(
|
app.getCertInfo().getAlipayRootCertStream());
|
return new CertAlipayClient(certAlipayRequest);
|
}
|
}
|
|
/**
|
* 统一转账（包含红包与转账） https://opendocs.alipay.com/apis/api_28/alipay.fund.trans.uni.transfer
|
*
|
* @param app
|
* @param info
|
* @return
|
* @throws AlipayApiException
|
* @throws NumberFormatException
|
* @throws AlipayTransferException
|
*/
|
public static AlipayFundTransUniTransferResponse alipayFundTransUniTransfer(AlipayAppInfo app, AlipayTransferInfo info)
|
throws AlipayApiException, NumberFormatException, AlipayTransferException {
|
AlipayFundTransUniTransferRequest request = new AlipayFundTransUniTransferRequest();
|
com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
|
json.put("out_biz_no", info.getOutBizNo());
|
json.put("trans_amount", info.getMoney().toString());
|
json.put("product_code", info.getProductCode().name());
|
json.put("order_title", info.getOrderTitle());
|
JSONObject payee_info = new JSONObject();
|
|
if (!StringUtil.isNullOrEmpty(info.getAccount().getUserId())) {
|
payee_info.put("identity_type", "ALIPAY_USER_ID");
|
payee_info.put("identity", info.getAccount().getUserId());
|
} else {
|
payee_info.put("identity", info.getAccount().getAccount());
|
payee_info.put("identity_type", "ALIPAY_LOGON_ID");
|
payee_info.put("name", info.getAccount().getName());
|
}
|
|
|
json.put("payee_info", payee_info);
|
json.put("remark", info.getMark());
|
json.put("biz_scene", info.getBizScene().name());
|
|
com.alibaba.fastjson.JSONObject params = new com.alibaba.fastjson.JSONObject();
|
if (AlipayTransferInfo.AlipayProductCodeEnum.STD_RED_PACKET == info.getProductCode()) {
|
params.put("sub_biz_scene", "REDPACKET");
|
}
|
|
if (!StringUtil.isNullOrEmpty(info.getPayerName())) {
|
params.put("payer_show_name", info.getPayerName());
|
}
|
|
|
json.put("business_params", params.toJSONString());
|
|
request.setBizContent(json.toString());
|
AlipayFundTransUniTransferResponse response = null;
|
response = getAlipayClient(app).certificateExecute(request);
|
// 成功转账
|
if (response != null && response.isSuccess() && "10000".equals(response.getCode())) {
|
return response;
|
} else// 转账失败
|
{
|
throw new AlipayTransferException(Integer.parseInt(response.getCode()), response.getSubCode(),
|
response.getBody());
|
}
|
}
|
|
|
/**
|
* 获取订单详情
|
* API接口地址为:https://opendocs.alipay.com/apis/api_28/alipay.fund.trans.common.query/
|
*
|
* @param app
|
* @param productCode
|
* @param bizScene
|
* @param outBizNo
|
* @return
|
* @throws AlipayApiException
|
*/
|
public static AlipayFundTransCommonQueryResponse getOrderDetail(AlipayAppInfo app, AlipayTransferInfo.AlipayProductCodeEnum productCode, AlipayTransferInfo.AlipayBizSceneEnum bizScene, String outBizNo) throws AlipayApiException, AlipayCommonException {
|
AlipayClient alipayClient = getAlipayClient(app);
|
AlipayFundTransCommonQueryRequest request = new AlipayFundTransCommonQueryRequest();
|
com.alibaba.fastjson.JSONObject content = new com.alibaba.fastjson.JSONObject();
|
if (productCode != null)
|
content.put("product_code", productCode.name());
|
if (bizScene != null)
|
content.put("biz_scene", bizScene.name());
|
content.put("out_biz_no", outBizNo);
|
request.setBizContent(content.toString());
|
AlipayFundTransCommonQueryResponse response = alipayClient.certificateExecute(request);
|
if (response.isSuccess())
|
return response;
|
else
|
throw new AlipayCommonException(response.getCode(), response.getSubMsg(), response.getBody());
|
}
|
|
/**
|
* 获取账户余额
|
* API接口地址:https://opendocs.alipay.com/apis/api_28/alipay.fund.account.query
|
*
|
* @param app
|
* @param userId
|
* @return
|
* @throws AlipayApiException
|
* @throws AlipayCommonException
|
*/
|
public static BigDecimal getAccountBalance(AlipayAppInfo app, String userId) throws AlipayApiException, AlipayCommonException {
|
AlipayClient alipayClient = getAlipayClient(app);
|
AlipayFundAccountQueryRequest request = new AlipayFundAccountQueryRequest();
|
com.alibaba.fastjson.JSONObject content = new com.alibaba.fastjson.JSONObject();
|
content.put("alipay_user_id", userId);
|
content.put("account_type", "ACCTRANS_ACCOUNT");
|
request.setBizContent(content.toString());
|
|
AlipayFundAccountQueryResponse response = alipayClient.certificateExecute(request);
|
if (response.isSuccess()) {
|
return new BigDecimal(response.getAvailableAmount());
|
} else {
|
throw new AlipayCommonException(response.getCode(), response.getSubMsg(), response.getBody());
|
}
|
}
|
|
|
}
|
