删除paypal支付
This commit is contained in:
wuchunlei
@@ -1,216 +0,0 @@
|
||||
package com.peanut.modules.pay.paypal.config;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.peanut.modules.common.entity.BuyOrder;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
import java.io.*;
|
||||
import java.net.HttpURLConnection;
|
||||
import java.net.URL;
|
||||
import java.util.*;
|
||||
|
||||
@Component
|
||||
@Slf4j
|
||||
public class PaypalConfig {
|
||||
|
||||
//沙盒
|
||||
public static final String modeUrl = "https://api-m.sandbox.paypal.com";
|
||||
public static final String CLIENID ="Ab8SeEuhkLGp6Fts9V3Cti0UcXQhITRWZkiHDM3U1fDY9YrrRc5IOcYHPfV6qROhmh0hvgysqrfOCSUr";
|
||||
public static final String SECRET ="EF63FGWI9fd4q07Ndvc_h8P7jxiZcGOWn8Ul_y1_EKpluKJNFHOW8BP62Kf1wBDQ3XYIeqF8_kVrDF7C";
|
||||
public static final String WEBSCR ="https://www.sandbox.paypal.com/cgi-bin/webscr";//回调验证地址
|
||||
//sb-in47yk34022562@personal.example.com
|
||||
//p#54df;P
|
||||
|
||||
//sb-n2lz015338486@business.example.com
|
||||
//4lnAJn.G
|
||||
|
||||
//正式
|
||||
// public static final String modeUrl = "https://api-m.paypal.com";
|
||||
// public static final String CLIENID ="";
|
||||
// public static final String SECRET ="";
|
||||
// public static final String WEBSCR ="https://www.paypal.com/cgi-bin/webscr";
|
||||
|
||||
|
||||
public static final String accessTokenURL = "/v1/oauth2/token";
|
||||
public static final String createOrderURL = "/v2/checkout/orders";
|
||||
public static final String captureURL = "/v2/checkout/orders/%1s/capture";
|
||||
public static final String orderInfoURL = "/v2/checkout/orders/";
|
||||
public static final String refundURL = "/v2/payments/captures/%1s/refund";
|
||||
public static final String refundInfoURL = "/v2/payments/refunds/";
|
||||
|
||||
|
||||
|
||||
//回调验证
|
||||
public String receiveVerify(String verifyData) throws Exception{
|
||||
URL url = new URL(WEBSCR);
|
||||
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
||||
connection.setRequestMethod("POST");
|
||||
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
||||
connection.setDoOutput(true);
|
||||
OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream());
|
||||
writer.write(verifyData);
|
||||
writer.flush();
|
||||
writer.close();
|
||||
connection.getOutputStream().close();
|
||||
InputStream responseStream = connection.getResponseCode() / 100 == 2
|
||||
? connection.getInputStream()
|
||||
: connection.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal回调验证返回的信息是 result = {}", response);
|
||||
return response;
|
||||
}
|
||||
|
||||
//退款查询
|
||||
public JSONObject refundInfo(String refundId) throws Exception{
|
||||
URL url = new URL(modeUrl+refundInfoURL+refundId);
|
||||
HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
|
||||
httpConn.setRequestMethod("GET");
|
||||
httpConn.setRequestProperty("Content-Type", "application/json");
|
||||
httpConn.setRequestProperty("Authorization", "Bearer " + getAccessToken().get("access_token"));
|
||||
|
||||
InputStream responseStream = httpConn.getResponseCode() / 100 == 2
|
||||
? httpConn.getInputStream()
|
||||
: httpConn.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal退款查询返回的信息是 result = {}", response);
|
||||
return JSONObject.parseObject(response);
|
||||
}
|
||||
|
||||
//退款
|
||||
public JSONObject refund(String captureId) throws Exception{
|
||||
URL url = new URL(String.format(modeUrl+refundURL,captureId));
|
||||
HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
|
||||
httpConn.setRequestMethod("POST");
|
||||
httpConn.setRequestProperty("Content-Type", "application/json");
|
||||
httpConn.setRequestProperty("Authorization", "Bearer " + getAccessToken().get("access_token"));
|
||||
httpConn.setRequestProperty("Prefer", "return=representation");
|
||||
httpConn.setDoOutput(true);
|
||||
|
||||
InputStream responseStream = httpConn.getResponseCode() / 100 == 2
|
||||
? httpConn.getInputStream()
|
||||
: httpConn.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal退款返回的信息是 result = {}", response);
|
||||
return JSONObject.parseObject(response);
|
||||
}
|
||||
|
||||
//订单查询
|
||||
public JSONObject orderInfo(String paypalOrderId) throws Exception{
|
||||
URL url = new URL(modeUrl+orderInfoURL+paypalOrderId);
|
||||
HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
|
||||
httpConn.setRequestMethod("GET");
|
||||
httpConn.setRequestProperty("Authorization", "Bearer " + getAccessToken().get("access_token"));
|
||||
|
||||
InputStream responseStream = httpConn.getResponseCode() / 100 == 2
|
||||
? httpConn.getInputStream()
|
||||
: httpConn.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal订单查询返回的信息是 result = {}", response);
|
||||
return JSONObject.parseObject(response);
|
||||
}
|
||||
|
||||
//用户授权支付成功，进行扣款操作
|
||||
public JSONObject capture(String paypalOrderId){
|
||||
try {
|
||||
URL url = new URL(String.format(modeUrl+captureURL,paypalOrderId));
|
||||
HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
|
||||
httpConn.setRequestMethod("POST");
|
||||
httpConn.setRequestProperty("Content-Type", "application/json");
|
||||
httpConn.setRequestProperty("Authorization", "Bearer " + getAccessToken().get("access_token"));
|
||||
|
||||
InputStream responseStream = httpConn.getResponseCode() / 100 == 2
|
||||
? httpConn.getInputStream()
|
||||
: httpConn.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal扣款返回的信息是 result = {}", response);
|
||||
return JSONObject.parseObject(response);
|
||||
}catch (Exception e) {
|
||||
log.error(">>>>>>>>>>:PayPal扣款失败 reason = {}", e.getMessage());
|
||||
e.printStackTrace();
|
||||
return JSONObject.parseObject("{'error':'PayPal扣款失败，请联系管理员'}");
|
||||
}
|
||||
}
|
||||
|
||||
//下单
|
||||
public JSONObject createOrder(BuyOrder buyOrder,String returnUrl,String cancelUrl){
|
||||
try{
|
||||
URL u = new URL(modeUrl+createOrderURL);
|
||||
HttpURLConnection connection = (HttpURLConnection) u.openConnection();
|
||||
connection.setRequestMethod("POST");
|
||||
connection.setRequestProperty("Content-Type", "application/json");
|
||||
connection.setRequestProperty("Authorization", "Bearer " + getAccessToken().get("access_token"));
|
||||
connection.setDoOutput(true);
|
||||
OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream());
|
||||
|
||||
JSONArray purchase_units = new JSONArray();
|
||||
JSONObject purchaseUnit = new JSONObject();
|
||||
JSONObject amount = new JSONObject();
|
||||
amount.put("currency_code", "USD");//美元
|
||||
amount.put("value", buyOrder.getOrderMoney().toString());// 金额
|
||||
purchaseUnit.put("custom_id",buyOrder.getOrderSn());
|
||||
purchaseUnit.put("invoice_id",buyOrder.getOrderSn());
|
||||
purchaseUnit.put("amount",amount);
|
||||
purchaseUnit.put("description", buyOrder.getRemark());
|
||||
purchase_units.add(purchaseUnit);
|
||||
JSONObject applicationContext = new JSONObject();
|
||||
applicationContext.put("user_action", "PAY_NOW");//付款按钮显示立即付款
|
||||
applicationContext.put("shipping_preference", "NO_SHIPPING");//从 PayPal 网站编辑送货地址。推荐用于数字商品。
|
||||
applicationContext.put("return_url", returnUrl);//客户批准付款后重定向到客户的 URL
|
||||
applicationContext.put("cancel_url", cancelUrl);//客户取消付款后，客户被重定向的 URL
|
||||
JSONObject jsonObject = new JSONObject();
|
||||
jsonObject.put("intent","CAPTURE");// 用户付款了，商户立即收款
|
||||
jsonObject.put("purchase_units",purchase_units);
|
||||
jsonObject.put("application_context", applicationContext);
|
||||
writer.write(jsonObject.toString());
|
||||
writer.flush();
|
||||
writer.close();
|
||||
connection.getOutputStream().close();
|
||||
InputStream responseStream = connection.getResponseCode() / 100 == 2
|
||||
? connection.getInputStream()
|
||||
: connection.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
log.info(">>>>>>>>>>>palypal下单返回的信息是 result = {}", response);
|
||||
return JSONObject.parseObject(response);
|
||||
}catch (Exception e) {
|
||||
log.error(">>>>>>>>>>:PayPal创建订单网络连接失败 reason = {}", e.getMessage());
|
||||
e.printStackTrace();
|
||||
return JSONObject.parseObject("{'error':'PayPal创建订单网络连接失败，请联系管理员'}");
|
||||
}
|
||||
}
|
||||
|
||||
public JSONObject getAccessToken(){
|
||||
try {
|
||||
String credentials = CLIENID + ":" + SECRET;
|
||||
String encodedCredentials = Base64.getEncoder().encodeToString(credentials.getBytes());
|
||||
URL url = new URL(modeUrl+accessTokenURL);
|
||||
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
||||
connection.setRequestMethod("POST");
|
||||
connection.setRequestProperty("Authorization", "Basic " + encodedCredentials);
|
||||
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
||||
connection.setDoOutput(true);
|
||||
String postParameters = "grant_type=client_credentials";
|
||||
try (OutputStream os = connection.getOutputStream()) {
|
||||
byte[] postParametersBytes = postParameters.getBytes();
|
||||
os.write(postParametersBytes);
|
||||
os.flush();
|
||||
}
|
||||
InputStream responseStream = connection.getResponseCode() / 100 == 2
|
||||
? connection.getInputStream()
|
||||
: connection.getErrorStream();
|
||||
Scanner s = new Scanner(responseStream).useDelimiter("\\A");
|
||||
String response = s.hasNext() ? s.next() : "";
|
||||
return JSONObject.parseObject(response);
|
||||
}catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,174 +0,0 @@
|
||||
package com.peanut.modules.pay.paypal.controller;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.peanut.common.utils.R;
|
||||
import com.peanut.modules.book.service.*;
|
||||
import com.peanut.modules.common.entity.*;
|
||||
import com.peanut.modules.pay.paypal.config.PaypalConfig;
|
||||
import com.peanut.modules.pay.paypal.service.PayPaypalOrderService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import java.util.*;
|
||||
|
||||
/**
|
||||
* paypal支付
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/pay/paypal")
|
||||
@Slf4j
|
||||
public class PaypalController {
|
||||
|
||||
@Autowired
|
||||
private PaypalConfig paypalConfig;
|
||||
@Autowired
|
||||
private BuyOrderService buyOrderService;
|
||||
@Autowired
|
||||
private PayPaypalOrderService payPaypalOrderService;
|
||||
@Autowired
|
||||
private UserEbookBuyService userEbookBuyService;
|
||||
@Autowired
|
||||
private BookBuyConfigService bookBuyConfigService;
|
||||
@Autowired
|
||||
private MyUserService userService;
|
||||
@Autowired
|
||||
private TransactionDetailsService transactionDetailsService;
|
||||
@Autowired
|
||||
private PayPaymentOrderService payPaymentOrderService;
|
||||
|
||||
@RequestMapping("/createOrder")
|
||||
public R createOrder(@RequestBody Map<String,Object> params){
|
||||
BuyOrder buyOrder = buyOrderService.getOne(new LambdaQueryWrapper<BuyOrder>()
|
||||
.eq(BuyOrder::getOrderSn,params.get("orderSn")));
|
||||
if ("3".equals(buyOrder.getOrderStatus())){
|
||||
return R.error("订单已完成");
|
||||
}
|
||||
if ("point".equals(buyOrder.getOrderType())){
|
||||
buyOrder.setRemark("Recharge Virtual Coin");
|
||||
}
|
||||
JSONObject res = paypalConfig.createOrder(buyOrder,params.get("returnUrl").toString(),params.get("cancelUrl").toString());
|
||||
if (res.containsKey("links")&&res.containsKey("status")){
|
||||
if ("CREATED".equals(res.get("status").toString())){
|
||||
PayPaypalOrder payPaypalOrder = new PayPaypalOrder();
|
||||
payPaypalOrder.setOrderId(buyOrder.getOrderId());
|
||||
payPaypalOrder.setOrderSn(buyOrder.getOrderSn());
|
||||
payPaypalOrder.setUserId(buyOrder.getUserId());
|
||||
payPaypalOrder.setPaypalOrderId(res.get("id").toString());
|
||||
payPaypalOrder.setDescription(buyOrder.getRemark());
|
||||
payPaypalOrderService.save(payPaypalOrder);
|
||||
JSONArray array = (JSONArray)res.get("links");
|
||||
String url = "";
|
||||
for (int i = 0; i < array.size(); i++) {
|
||||
JSONObject o = (JSONObject)array.get(i);
|
||||
if ("approve".equals(o.get("rel"))){
|
||||
url = o.get("href").toString();
|
||||
}
|
||||
}
|
||||
|
||||
return R.ok().put("id",res.get("id").toString()).put("url",url);
|
||||
}
|
||||
}
|
||||
return R.error(res.get("error").toString());
|
||||
}
|
||||
|
||||
@RequestMapping("/orderInfo")
|
||||
public R orderInfo(@RequestBody Map<String,Object> params) throws Exception{
|
||||
JSONObject res = paypalConfig.orderInfo(params.get("paypalId").toString());
|
||||
return R.ok().put("res",res);
|
||||
}
|
||||
|
||||
@RequestMapping("/capture")
|
||||
@Transactional
|
||||
public R capture(@RequestBody Map<String,Object> params){
|
||||
JSONObject res = paypalConfig.capture(params.get("paypalId").toString());
|
||||
if (res.containsKey("status")&&"COMPLETED".equals(res.get("status").toString())){
|
||||
PayPaypalOrder payPaypalOrder = payPaypalOrderService.getOne(new LambdaQueryWrapper<PayPaypalOrder>()
|
||||
.eq(PayPaypalOrder::getPaypalOrderId,params.get("paypalId").toString()));
|
||||
JSONArray purchaseUnits = JSONArray.parseArray(res.get("purchase_units").toString());
|
||||
JSONObject purchaseUnit = (JSONObject)purchaseUnits.get(0);
|
||||
JSONObject payments = JSONObject.parseObject(purchaseUnit.get("payments").toString());
|
||||
JSONArray captures = JSONArray.parseArray(payments.get("captures").toString());
|
||||
JSONObject capture = (JSONObject)captures.get(0);
|
||||
if ("COMPLETED".equals(capture.get("status").toString())){
|
||||
//更新PayPal订单
|
||||
payPaypalOrder.setCaptureId(capture.get("id").toString());
|
||||
payPaypalOrder.setCaptureTime(new Date());
|
||||
payPaypalOrderService.updateById(payPaypalOrder);
|
||||
BuyOrder buyOrder = buyOrderService.getById(payPaypalOrder.getOrderId());
|
||||
if ("abroadBook".equals(buyOrder.getOrderType())){
|
||||
userEbookBuyService.addBookForUser(buyOrder.getUserId(),Arrays.asList(buyOrder.getAbroadBookId()));
|
||||
}
|
||||
if ("point".equals(buyOrder.getOrderType())){
|
||||
BookBuyConfigEntity bookBuyConfigEntity = bookBuyConfigService.getById(buyOrder.getProductId());
|
||||
MyUserEntity userEntity = userService.getById(buyOrder.getUserId());
|
||||
String realMoney = bookBuyConfigEntity.getRealMoney();
|
||||
//更新账户余额
|
||||
userService.rechargeHSPoint(userEntity,Integer.valueOf(realMoney));
|
||||
//插入虚拟币消费记录
|
||||
transactionDetailsService.rechargeRecord(userEntity,realMoney,payPaypalOrder.getId(),"PayPal",buyOrder.getOrderSn());
|
||||
//插入花生币充值记录
|
||||
payPaymentOrderService.insertDetail(userEntity,bookBuyConfigEntity,payPaypalOrder.getId().toString());
|
||||
}
|
||||
return R.ok();
|
||||
}
|
||||
}
|
||||
return R.error("执行扣款失败");
|
||||
}
|
||||
|
||||
@RequestMapping("/refund")
|
||||
public R refund(@RequestBody Map<String,Object> params) throws Exception{
|
||||
JSONObject res = paypalConfig.refund(params.get("captureId").toString());
|
||||
return R.ok().put("res",res);
|
||||
}
|
||||
|
||||
@RequestMapping("/refundInfo")
|
||||
public R refundInfo(@RequestBody Map<String,Object> params) throws Exception{
|
||||
JSONObject res = paypalConfig.refundInfo(params.get("refundId").toString());
|
||||
return R.ok().put("res",res);
|
||||
}
|
||||
|
||||
@RequestMapping("/receivePaypalStatus")
|
||||
public void receivePaypalStatus(HttpServletRequest request, HttpServletResponse response) throws Exception{
|
||||
//获取paypal请求参数,并拼接验证参数
|
||||
Enumeration<String> en = request.getParameterNames();
|
||||
String str = "cmd=_notify-validate";
|
||||
while (en.hasMoreElements()) {
|
||||
String paramName = en.nextElement();
|
||||
String paramValue = request.getParameter(paramName);
|
||||
str = str + "&" + paramName + "=" + paramValue;
|
||||
}
|
||||
//发送给papal,确认回调信息的安全性
|
||||
String res = paypalConfig.receiveVerify(str);
|
||||
if ("VERIFIED".equals(res)){
|
||||
log.info(">>>>>>>>>>>palypal回调校验通过，返回的信息是 result = {}", str);
|
||||
String paymentStatus = request.getParameter("payment_status");
|
||||
//扣款id
|
||||
String txnId = request.getParameter("txn_id");
|
||||
PayPaypalOrder payPaypalOrder = payPaypalOrderService.getOne(new LambdaQueryWrapper<PayPaypalOrder>()
|
||||
.eq(PayPaypalOrder::getCaptureId,txnId));
|
||||
payPaypalOrder.setPaymentStatus(request.getParameter("payment_status"));// 交易状态 Completed 代表交易成功
|
||||
payPaypalOrder.setPaymentDate(request.getParameter("payment_date"));// 交易时间
|
||||
payPaypalOrder.setPayerEmail(request.getParameter("payer_email"));// 付款人email
|
||||
payPaypalOrder.setPayerId(request.getParameter("payer_id")); // 付款人id
|
||||
payPaypalOrder.setMcGross(request.getParameter("mc_gross")); // 交易金额
|
||||
payPaypalOrder.setCallbackData(str);
|
||||
payPaypalOrderService.updateById(payPaypalOrder);
|
||||
BuyOrder buyOrder = buyOrderService.getById(payPaypalOrder.getOrderId());
|
||||
if (paymentStatus.equalsIgnoreCase("Completed")) {// 订单交易成功
|
||||
buyOrder.setOrderStatus("3");
|
||||
} else {
|
||||
buyOrder.setOrderStatus("2");
|
||||
}
|
||||
buyOrderService.updateById(buyOrder);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -1,7 +0,0 @@
|
||||
package com.peanut.modules.pay.paypal.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.peanut.modules.common.entity.PayPaypalOrder;
|
||||
|
||||
public interface PayPaypalOrderService extends IService<PayPaypalOrder> {
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package com.peanut.modules.pay.paypal.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.peanut.modules.common.dao.PayPaypalOrderDao;
|
||||
import com.peanut.modules.common.entity.PayPaypalOrder;
|
||||
import com.peanut.modules.pay.paypal.service.PayPaypalOrderService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Slf4j
|
||||
@Service("payPaypalOrderService")
|
||||
public class PayPaypalOrderServiceImpl extends ServiceImpl<PayPaypalOrderDao, PayPaypalOrder> implements PayPaypalOrderService {
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user