|
|
@@ -1,25 +1,22 @@
|
|
|
package com.cyksj.service.paypal;
|
|
|
|
|
|
-import cn.hutool.json.JSONObject;
|
|
|
import com.cyksj.common.exception.BusinessRuntimeException;
|
|
|
import com.cyksj.common.task.GlobalThreadPoolTaskExecutor;
|
|
|
import com.cyksj.common.util.Jsons;
|
|
|
import com.cyksj.enums.GatewayApiCode;
|
|
|
-import com.cyksj.enums.GatewayResponse;
|
|
|
import com.cyksj.mapper.GoodsDonSkuMapper;
|
|
|
import com.cyksj.model.entity.GoodsDonSku;
|
|
|
import com.cyksj.model.entity.OrderDon;
|
|
|
import com.cyksj.model.entity.PaypalPayConfig;
|
|
|
+import com.cyksj.model.entity.VipOrderDon;
|
|
|
import com.cyksj.redis.RedisService;
|
|
|
import com.cyksj.service.order.OrderDonService;
|
|
|
-import com.paypal.api.payments.Amount;
|
|
|
-import com.paypal.api.payments.Sale;
|
|
|
+import com.cyksj.service.order.VipOrderDonService;
|
|
|
import com.paypal.base.rest.APIContext;
|
|
|
import com.paypal.base.rest.OAuthTokenCredential;
|
|
|
import com.paypal.base.rest.PayPalRESTException;
|
|
|
import com.paypal.core.PayPalHttpClient;
|
|
|
import com.paypal.http.HttpResponse;
|
|
|
-import com.paypal.http.serializer.Json;
|
|
|
import com.paypal.orders.*;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -52,6 +49,9 @@ public class PaypalV2Service {
|
|
|
private final RedisService redisService;
|
|
|
|
|
|
private final GoodsDonSkuMapper skuMapper;
|
|
|
+
|
|
|
+ private final VipOrderDonService vipOrderDonService;
|
|
|
+
|
|
|
private static final String SANDBOX_URL = "https://api-m.sandbox.paypal.com";
|
|
|
|
|
|
private static final String LIVE_URL = "https://api-m.paypal.com";
|
|
|
@@ -269,4 +269,130 @@ public class PaypalV2Service {
|
|
|
apiContext.setConfigurationMap(sdkConfig);
|
|
|
return apiContext;
|
|
|
}
|
|
|
+
|
|
|
+ public String createVipPayment(Long orderId, String successUrl) {
|
|
|
+ VipOrderDon orderDon = vipOrderDonService.getById(orderId);
|
|
|
+ redisService.set(RedisService.key.ABROAD_SUCCESS_URL.getName() + orderId,successUrl,RedisService.key.ABROAD_SUCCESS_URL.getTimeout());
|
|
|
+ BigDecimal money = orderDon.getMoney().divide(new BigDecimal(7),2,RoundingMode.HALF_DOWN);
|
|
|
+ orderDon.setAbroadMoney(money);
|
|
|
+ orderDon.setType(VipOrderDon.Type.PAYPAL);
|
|
|
+ vipOrderDonService.updateById(orderDon);
|
|
|
+ if (VipOrderDon.Status.hasPayment.equals(orderDon.getStatus())) {
|
|
|
+ throw new BusinessRuntimeException(GatewayApiCode.METADATA_SYSTEM_ERROR.getCode(),"该订单已支付");
|
|
|
+ }
|
|
|
+ PaypalPayConfig paypalPayConfig = paypalPayConfigService.getById(1);
|
|
|
+ PayPalClient payPalClient = new PayPalClient();
|
|
|
+ // 设置环境沙盒或生产
|
|
|
+ PayPalHttpClient client = payPalClient.client(paypalPayConfig.getMode(), paypalPayConfig.getClientId(), paypalPayConfig.getClientSecret());
|
|
|
+
|
|
|
+ //回调参数（支付成功success路径所携带的参数）
|
|
|
+ Map<String, String> sParaTemp = new HashMap<String, String>();
|
|
|
+
|
|
|
+ sParaTemp.put("orderId", orderId.toString());
|
|
|
+
|
|
|
+ String returnUrl = "https://" + paypalPayConfig.getHost() + "/8081/api/applet/vip/orders/paypalV2/notify";
|
|
|
+
|
|
|
+ // 配置请求参数
|
|
|
+ OrderRequest orderRequest = new OrderRequest();
|
|
|
+ orderRequest.checkoutPaymentIntent("CAPTURE");
|
|
|
+ List<PurchaseUnitRequest> purchaseUnits = new ArrayList<>();
|
|
|
+ BigDecimal totalMoney = money.divide(new BigDecimal(100), 2, RoundingMode.HALF_DOWN);
|
|
|
+ purchaseUnits.add(new PurchaseUnitRequest().referenceId(orderId.toString()).amountWithBreakdown(new AmountWithBreakdown().currencyCode("USD").value(totalMoney.toString())));
|
|
|
+ orderRequest.purchaseUnits(purchaseUnits);
|
|
|
+ orderRequest.applicationContext(new ApplicationContext()
|
|
|
+ .landingPage(LANDINGPAGE)
|
|
|
+ .userAction(USERACTION)
|
|
|
+ .returnUrl(returnUrl)
|
|
|
+ .cancelUrl(paypalPayConfig.getCancelUrl()));
|
|
|
+ OrdersCreateRequest request = new OrdersCreateRequest().requestBody(orderRequest);
|
|
|
+
|
|
|
+ HttpResponse<Order> response;
|
|
|
+ try {
|
|
|
+ response = client.execute(request);
|
|
|
+ Order order = response.result();
|
|
|
+ String payHref = null;
|
|
|
+ String status = order.status();
|
|
|
+ if (status.equals("CREATED")) {
|
|
|
+ List<LinkDescription> links = order.links();
|
|
|
+ for (LinkDescription linkDescription : links) {
|
|
|
+ if (linkDescription.rel().equals("approve")) {
|
|
|
+ payHref = linkDescription.href();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return payHref;
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ public String successVipPayment(String token, String payerId, PaypalPayConfig paypalPayConfig) throws Exception {
|
|
|
+ log.info("paypalV2回调 token:{},payerId:{}", token, payerId);
|
|
|
+ //捕获订单 进行支付
|
|
|
+ HttpResponse<Order> response = null;
|
|
|
+ OrdersCaptureRequest ordersCaptureRequest = new OrdersCaptureRequest(token);
|
|
|
+ ordersCaptureRequest.requestBody(new OrderRequest());
|
|
|
+
|
|
|
+ PayPalClient payPalClient = new PayPalClient();
|
|
|
+ try {
|
|
|
+ response = payPalClient.client(paypalPayConfig.getMode(), paypalPayConfig.getClientId(), paypalPayConfig.getClientSecret()).execute(ordersCaptureRequest);
|
|
|
+ Order result = response.result();
|
|
|
+ log.info("captureOrder response: {}", result);
|
|
|
+ for (PurchaseUnit purchaseUnit : result.purchaseUnits()) {
|
|
|
+ for (Capture capture : purchaseUnit.payments().captures()) {
|
|
|
+ if ("COMPLETED".equals(capture.status())) {
|
|
|
+ //支付成功
|
|
|
+ // 订单号
|
|
|
+ String saleId = capture.id();
|
|
|
+ String fee = capture.sellerReceivableBreakdown().paypalFee().value();
|
|
|
+ String orderId = purchaseUnit.referenceId();
|
|
|
+ String json = Jsons.toJson(result);
|
|
|
+ log.info("captureOrder response body: {}", json);
|
|
|
+ //更新订单支付状态
|
|
|
+ VipOrderDon orderDon = vipOrderDonService.getById(orderId);
|
|
|
+ orderDon.setTransactionId(saleId);
|
|
|
+ orderDon.setPayTime(new Date());
|
|
|
+ orderDon.setAbroadTransactionFee(new BigDecimal(fee).multiply(BigDecimal.valueOf(100)));
|
|
|
+ vipOrderDonService.orderNotify(orderDon);
|
|
|
+ log.info("支付成功订单："+orderId+",支付交易号："+saleId);
|
|
|
+
|
|
|
+ THREAD_POOL.execute(()->{
|
|
|
+ try {
|
|
|
+ APIContext apiContext = this.getAPIContext(paypalPayConfig.getClientId(), paypalPayConfig.getClientSecret(), paypalPayConfig.getMode());
|
|
|
+ String baseUrl = "live".equals(paypalPayConfig.getMode()) ? LIVE_URL : SANDBOX_URL;
|
|
|
+ URL url = new URL(baseUrl + "/v1/shipping/trackers-batch");
|
|
|
+ HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
|
|
|
+ httpConn.setRequestMethod("POST");
|
|
|
+ httpConn.setRequestProperty("Content-Type", "application/json");
|
|
|
+ httpConn.setRequestProperty("Authorization", apiContext.getAccessToken());
|
|
|
+ httpConn.setDoOutput(true);
|
|
|
+ OutputStreamWriter writer = new OutputStreamWriter(httpConn.getOutputStream());
|
|
|
+ writer.write("{\"trackers\": [{ \"transaction_id\": \"" + saleId + "\", \"status\": \"SHIPPED\"}]}");
|
|
|
+ writer.flush();
|
|
|
+ writer.close();
|
|
|
+ httpConn.getOutputStream().close();
|
|
|
+
|
|
|
+ InputStream responseStream = httpConn.getResponseCode() / 100 == 2 ? httpConn.getInputStream() : httpConn.getErrorStream();
|
|
|
+ Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
|
|
+ String res = s.hasNext() ? s.next() : "";
|
|
|
+ log.info("添加物流信息 response:{}",res);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+
|
|
|
+ return redisService.getStr(RedisService.key.ABROAD_SUCCESS_URL.getName() + orderId);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (IOException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (Exception e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ log.info("支付失败返回参数："+ Jsons.toJson(response.result()));
|
|
|
+ return paypalPayConfig.getCancelUrl();
|
|
|
+ }
|
|
|
}
|
zoujiajian