package com.walker.pay.payunk.generator;
|
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
import com.walker.infrastructure.ApplicationRuntimeException;
|
import com.walker.infrastructure.arguments.Variable;
|
import com.walker.infrastructure.utils.JsonUtils;
|
import com.walker.infrastructure.utils.MoneyUtils;
|
import com.walker.pay.Order;
|
import com.walker.pay.PayContext;
|
import com.walker.pay.ResponsePay;
|
import com.walker.pay.payunk.BaseOrderGenerator;
|
import com.walker.pay.payunk.Constants;
|
import com.walker.pay.payunk.DefaultPayContext;
|
import com.walker.pay.payunk.Trans2AlipayResponsePay;
|
import com.walker.pay.payunk.util.AlipayUtils;
|
import com.walker.pay.payunk.util.SignUtils;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 转账到支付宝个人账户，生成器实现。
|
* @author 时克英
|
* @date 2023-10-25
|
*/
|
public class Trans2AlipayOneGenerator extends BaseOrderGenerator {
|
|
public Trans2AlipayOneGenerator(RestTemplate restTemplate){
|
this.setRestTemplate(restTemplate);
|
}
|
|
@Override
|
protected ResponsePay invoke(PayContext payContext, Order platformOrder) {
|
try {
|
DefaultPayContext context = (DefaultPayContext) payContext;
|
// 请求封装参数
|
Map<String, Object> payMap = new HashMap<>(10);
|
// 您的商户唯一标识
|
payMap.put("appid", context.getAppIdConfig().getStringValue());
|
// 支付通道
|
payMap.put("pay_type", Constants.PAY_TYPE_TRANS_ALIPAY_ONE);
|
// 畅联后台 账户管理 账户编号
|
payMap.put("user_account_id", context.getUserAccountId().getStringValue());
|
// 交易金额 单位：元 精确小数点后2位10.00
|
payMap.put("amount", MoneyUtils.scaleYuan2Accuracy(platformOrder.getTotalMoney()));
|
// 回调地址
|
payMap.put("callback_url", platformOrder.getNotifyUrl());
|
// 商户订单号 C20142222231234
|
payMap.put("out_trade_no", String.valueOf(platformOrder.getId()));
|
|
payMap.put("pay", JsonUtils.objectToJsonString(AlipayUtils.acquireAlipayReplace(context)));
|
|
payMap.put("extend", AlipayUtils.getAlipayInfo(platformOrder));
|
|
// sign 签名
|
String signStr = SignUtils.signature(payMap);
|
payMap.put("sign", signStr);
|
|
//
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_JSON);
|
HttpEntity<Map<String, Object>> request = new HttpEntity<>(payMap, headers);
|
ResponseEntity<String> entity = this.getRestTemplate().postForEntity(PAY_RETURN_JSON_URL, request, String.class);
|
|
Trans2AlipayResponsePay responsePay = new Trans2AlipayResponsePay();
|
|
/**
|
* 返回示例
|
* {
|
* "code": 200,
|
* "msg": "获取成功",
|
* "url": "支付连接",
|
* }
|
*/
|
String result = entity.getBody();
|
ObjectNode objectNode = JsonUtils.jsonStringToObjectNode(result);
|
if(objectNode.get("code").intValue() != 200){
|
String error = objectNode.get("msg").toString();
|
logger.error("支付宝个人提现接口错误：{}", error);
|
responsePay.setStatus(false);
|
responsePay.setMessage(error);
|
} else {
|
responsePay.setStatus(true);
|
responsePay.setMessage("success");
|
responsePay.setUrl(objectNode.get("url").toString());
|
logger.error("支付宝个人提现接口成功：{}", responsePay.getUrl());
|
}
|
return responsePay;
|
|
} catch (Exception ex){
|
logger.error("调用支付接口异常，Trans2AlipayOneGenerator：" + ex.getMessage(), ex);
|
throw new ApplicationRuntimeException("Trans2AlipayOneGenerator", ex);
|
}
|
}
|
|
@Deprecated
|
@Override
|
protected ResponsePay invoke(String providerPayType, Order platformOrder, Map<String, Variable> configuration) {
|
throw new UnsupportedOperationException("方法废弃，请勿调用");
|
}
|
}
|
