springboot整合pi支付开发

pi支付流程图：

  1. 使用Pi SDK功能发起支付
  2. 由 Pi SDK 自动调用的回调函数（让您的应用服务器知道它需要发出批准 API 请求）
  3. 从您的应用程序服务器到 Pi 服务器的 API 请求以批准付款（让 Pi 服务器知道您知道此付款）
  4. Pi浏览器向用户显示付款详细信息页面，我们正在等待用户签署交易
  5. 由 Pi SDK 自动调用的回调函数（让您的应用服务器知道它需要发出完整的 API 请求）
  6. 从您的应用服务器到 Pi 服务器的 API 请求以完成付款（让 Pi 服务器知道您已完成此付款）

支付流程

 引入依赖

  <dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId><version>4.10.0-RC1</version></dependency><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>5.8.0.M4</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.13</version></dependency><dependency><groupId>commons-lang</groupId><artifactId>commons-lang</artifactId><version>2.6</version></dependency>

配置api密钥

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;/*** 服务器端key* @author ThinkPad*/
@Configuration
@Data
public class CommonConfig {@Value("${sdk.serverAccessKey}")private String serverAccessKey;
}

 接收和返回数据对象

loginVO接收pi中心来的用户信息

import lombok.Data;/*** @author wzx* 登录数据封装类*/
@Data
public class LoginVO {private String userId;private String userName;private String accessToken;
}

paymentVO接收支付授权的信息

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.math.BigDecimal;/*** @author ThinkPad*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PaymentVO {private String paymentId;// 交易金额private BigDecimal amount;// 名片对应的用户数据private String shopUserId;// 商品idprivate String shopId;// 当前账号用户的idprivate String userId;}

completeVO接收支付完成的信息

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** @author ThinkPad*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class CompleteVO {// PI支付IDprivate String paymentId;// txIdprivate String txId;// 订单ID【余额支付参数】private String orderId;// 支付方式：0：PI钱包 1：余额支付private String payType;
}

incompleteVO接收未完成订单的信息

/*** @author ThinkPad*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class IncompleteVO {private String identifier;private TransactionVO transaction;
}
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** @author ThinkPad*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class TransactionVO {private String txid;private String _link;
}

工具类

发起http请求工具类

import org.apache.commons.lang.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.ParseException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;/*** @author Ashy.Cheung* @http 请求工具类* @date 2017.11.10*/
public class HttpClientUtil {public static String sendGet(String url) {CloseableHttpClient httpclient = HttpClients.createDefault();HttpGet httpget = new HttpGet(url);CloseableHttpResponse response = null;try {response = httpclient.execute(httpget);} catch (IOException e1) {e1.printStackTrace();}String result = null;try {HttpEntity entity = response.getEntity();if (entity != null) {result = EntityUtils.toString(entity);}} catch (ParseException | IOException e) {e.printStackTrace();} finally {try {response.close();} catch (IOException e) {e.printStackTrace();}}return result;}/**** @param url* @param charsetName 返回字符集* @return*/public static String sendGet(String url, String charsetName) {InputStream inputStream = null;HttpURLConnection urlConnection = null;try {URL url1 = new URL(url);urlConnection = (HttpURLConnection) url1.openConnection();// 将返回的输入流转换成字符串inputStream = urlConnection.getInputStream();// 指定编码格式if (StringUtils.isBlank(charsetName)) {charsetName = "UTF-8";}InputStreamReader inputStreamReader = new InputStreamReader(inputStream, charsetName);BufferedReader in = new BufferedReader(inputStreamReader);String jsonUserStr = in.readLine();return jsonUserStr;} catch (Exception e) {throw new RuntimeException(e);} finally {try {if (null != inputStream) {inputStream.close();}urlConnection.disconnect();} catch (Exception e) {}try {if (null != urlConnection) {urlConnection.disconnect();}} catch (Exception e) {}}}/*** 发送HttpPost请求，参数为String* 接收端以流形式接收*/public static String sendPost(String url, String param) {CloseableHttpClient httpclient = HttpClients.createDefault();StringEntity strEntity = null;try {strEntity = new StringEntity(param, "UTF-8");strEntity.setContentType("application/json");} catch (Exception e1) {e1.printStackTrace();}HttpPost httppost = new HttpPost(url);httppost.setEntity(strEntity);CloseableHttpResponse response = null;String result = null;try {response = httpclient.execute(httppost);HttpEntity entity1 = response.getEntity();result = EntityUtils.toString(entity1);} catch (IOException e) {//  e.printStackTrace();} finally {try {response.close();} catch (Exception e) {}}return result;}/*** 发送不带参数的HttpPost请求*/public static String sendPost(String url) {CloseableHttpClient httpclient = HttpClients.createDefault();HttpPost httppost = new HttpPost(url);CloseableHttpResponse response = null;try {response = httpclient.execute(httppost);} catch (IOException e) {e.printStackTrace();}HttpEntity entity = response.getEntity();String result = null;try {result = EntityUtils.toString(entity);} catch (ParseException | IOException e) {e.printStackTrace();} finally {try {response.close();} catch (Exception e) {}}return result;}}

 分布式锁工具类

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.connection.RedisStringCommands;
import org.springframework.data.redis.connection.ReturnType;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.types.Expiration;
import org.springframework.stereotype.Component;import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;
@Component
public class RedisLockUtil {private static final Logger log = LoggerFactory.getLogger(RedisLockUtil.class);@ResourceRedisTemplate<String, Object> redisTemplate;/*** 释放锁脚本，原子操作，lua脚本*/private static final String UNLOCK_LUA;static {StringBuilder sb = new StringBuilder();sb.append("if redis.call(\"get\",KEYS[1]) == ARGV[1] ");sb.append("then ");sb.append("    return redis.call(\"del\",KEYS[1]) ");sb.append("else ");sb.append("    return 0 ");sb.append("end ");UNLOCK_LUA = sb.toString();}/*** 获取分布式锁，原子操作** @param lockKey   锁* @param lockValue 唯一ID* @param leaseTime 过期时间 秒* @return 是否枷锁成功*/public  boolean tryLock(String lockKey, String lockValue, long leaseTime) {try {RedisCallback<Boolean> callback = (connection) -> connection.set(lockKey.getBytes(StandardCharsets.UTF_8),lockValue.getBytes(StandardCharsets.UTF_8), Expiration.seconds(leaseTime),RedisStringCommands.SetOption.SET_IF_ABSENT);return redisTemplate.execute(callback);} catch (Exception e) {log.error("redis lock error ,lock key: {}, value : {}, error info : {}", lockKey, lockValue, e);}return false;}/*** 释放锁** @param lockKey   锁* @param lockValue 唯一ID* @return 执行结果*/public  boolean unlock(String lockKey, String lockValue) {RedisCallback<Boolean> callback = (connection) -> connection.eval(UNLOCK_LUA.getBytes(), ReturnType.BOOLEAN, 1, lockKey.getBytes(StandardCharsets.UTF_8), lockValue.getBytes(StandardCharsets.UTF_8));return redisTemplate.execute(callback);}/*** 获取分布式锁，该方法不再使用** @param lockKey   锁* @param lockValue 唯一ID* @param waitTime  等待时间 秒* @param leaseTime 过期时间 秒* @return 是否枷锁成功*/@Deprecatedpublic   boolean tryLock(String lockKey, String lockValue, long waitTime, long leaseTime) {try {RedisCallback<Boolean> callback = (connection) -> connection.set(lockKey.getBytes(StandardCharsets.UTF_8),lockValue.getBytes(StandardCharsets.UTF_8), Expiration.seconds(leaseTime),RedisStringCommands.SetOption.SET_IF_ABSENT);return redisTemplate.execute(callback);} catch (Exception e) {log.error("redis lock error ,lock key: {}, value : {}, error info : {}", lockKey, lockValue, e);}return false;}
}

生成uuid工具类

import java.text.SimpleDateFormat;
import java.util.Date;public class UUID {public static String randomUUID() {SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd'T'HH'H'mm'M'ss'S'SSS");String id = sdf.format(new Date()) + (int) ((Math.random() * 9 + 1) * 100000000) + (int) ((Math.random() * 9 + 1) * 10);return id;}public static String randomQr() {String id = (int) ((Math.random() * 9 + 1) * 1000) + "-" + (int) ((Math.random() * 9 + 1) * 1000) + "-" + (int) ((Math.random() * 9 + 1) * 1000);return id;}}

信息返回的枚举

import lombok.AllArgsConstructor;import lombok.Getter;/*** @author ThinkPad*/@Getter
@AllArgsConstructor
public enum PaymentEnum {PAYMENT_ENUM_1(1, "订单不存在","失败"),PAYMENT_ENUM_2(2,"订单不是待支付状态","失败"),PAYMENT_ENUM_3(3,"支付金额少于订单金额","失败"),PAYMENT_ENUM_4(4,"调用太快","失败"),PAYMENT_ENUM_5(5,"余额不足,请前往充值","失败"),PAYMENT_ENUM_6(6,"支付成功","成功"),PAYMENT_ENUM_7(7,"处理成功","失败"),PAYMENT_ENUM_8(8,"处理失败","失败");private final Integer code;private final String msg;private final String status;public static String getMsgByCode(Integer code) {for (PaymentEnum value : PaymentEnum.values()) {if (value.getCode().equals(code)) {return value.getMsg();}}return null;}public static String getStatusByCode(Integer code) {for (PaymentEnum value : PaymentEnum.values()) {if (value.getCode().equals(code)) {return value.getStatus() ;}}return null;}}

支付的controller层

 /*** 处理未完成的订单 （这部十分重要，会影响到后面的操作）*/@PostMapping("payOrder/incomplete")@ApiOperation("处理未完成的订单")@ApiImplicitParam(name = "Authorization", value = "传入你的令牌",required = true, dataType = "String",paramType="header")public ResponseVO incomplete(@RequestBody IncompleteVO incompleteVO) {try {return orderInfoService.incomplete(incompleteVO);} catch (Exception e) {log.error("报错如下：{}", e.getMessage());throw new BusinessException("支付失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}}/*** 前端请求支付授权,在本地订单创建后调*/@PostMapping("payOrder/approve")@ApiOperation("前端请求支付授权,在本地订单创建后调")@ApiImplicitParam(name = "Authorization", value = "传入你的令牌",required = true, dataType = "String",paramType="header")public ResponseVO<String> approve(@RequestBody PaymentVO paymentVO) {try {String orderId = orderInfoService.approve(paymentVO);return ResponseVO.getSuccessResponseVo(orderId);} catch (Exception e) {log.error("报错如下：{}", e.getMessage());throw new BusinessException("支付失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}}/*** 前端支付完成,余额支付直接调用此方法*/@PostMapping("payOrder/complete")@ApiOperation("前端支付完成,余额支付直接调用此方法")@ApiImplicitParam(name = "Authorization", value = "传入你的令牌",required = true, dataType = "String",paramType="header")public ResponseVO complete(@RequestBody CompleteVO completeVO) {try {return orderInfoService.complete(completeVO);} catch (Exception e) {log.error("报错如下：{}", e.getMessage());throw new BusinessException("支付失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}}/*** 取消支付,订单关闭*/@PostMapping("payOrder/cancelled")@ApiOperation("取消支付,订单关闭")@ApiImplicitParam(name = "Authorization", value = "传入你的令牌",required = true, dataType = "String",paramType="header")public ResponseVO<String> cancelled(@RequestBody String orderId) {try {Boolean order = orderInfoService.cancelled(orderId);
//            if (!order){throw  new BusinessException("取消订单失败");}return ResponseVO.getSuccessResponseVo("取消订单成功");} catch (Exception e) {log.error("报错如下：{}", e.getMessage());throw new BusinessException("取消失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}}

支付的service层

    /*** 请求支付授权，创建order。返回orderId* @param paymentVO* @return*/@Override@Transactional(rollbackFor = Exception.class)public String approve(PaymentVO paymentVO) {log.error("approve-------------------------------------------------------------");OrderInfo orderInfo;log.error("paymentVO----------------------------------"+paymentVO);//获取付款信息OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url("https://api.minepi.com/v2/payments/" + paymentVO.getPaymentId()).addHeader("Authorization", "Key " + commonConfig.getServerAccessKey()).build();try (Response response = client.newCall(request).execute()) {if (!response.isSuccessful()) {String string = response.body().string();JSONObject jsonObject1 = JSON.parseObject(string);log.error("!response-------------------------------------------------------------"+commonConfig.getServerAccessKey());throw new RuntimeException("payments error " + jsonObject1.getString("error_message"));}String string = response.body().string();log.error("response-------------------------------------------------------------"+string);JSONObject jsonObject1 = JSON.parseObject(string);//校验实际支付金额BigDecimal userFinalPrice = paymentVO.getAmount();if (userFinalPrice.compareTo(jsonObject1.getBigDecimal("amount")) < 0) {log.error(userFinalPrice+"response-------------------------------------------------------------"+jsonObject1.getBigDecimal("amount"));throw new RuntimeException("支付金额少于订单金额");}} catch (Exception e) {throw  new BusinessException("支付失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}OkHttpClient client1 = new OkHttpClient();//信息真实，通知PI我准备好了，可以付款了Request request1 = new Request.Builder().url("https://api.minepi.com/v2/payments/" + paymentVO.getPaymentId() + "/approve").addHeader("Content-Type", "application/json").addHeader("Access-Control-Allow-Origin", "*").addHeader("Authorization", "Key " + commonConfig.getServerAccessKey()).post(RequestBody.create("", MediaType.parse("application/json"))).build();try (Response response1 = client1.newCall(request1).execute()) {if (!response1.isSuccessful()) {throw new RuntimeException("approve error: ");}log.error("response1-------------------------------------------------------------");//更新支付报文
//                    tMerStoreGoodsOrderEntity.setPayOrderId(paymentDto.getPaymentId());
//                    tMerStoreGoodsOrderEntity.setPayStatusType("10007002");//支付中
//                    itMerStoreGoodsOrderService.updateById(tMerStoreGoodsOrderEntity);log.error("return-------------------------------------------------------------");} catch (RuntimeException | IOException e) {log.error("error-------------------------------------------------------------");e.printStackTrace();}// 生成订单orderInfo = new OrderInfo();orderInfo.setOrderId(StringUtil.generateShortId());orderInfo.setShopId(paymentVO.getShopId());orderInfo.setUserId(paymentVO.getUserId());orderInfo.setShopUserId(paymentVO.getShopUserId());orderInfo.setAmount(paymentVO.getAmount());orderInfoMapper.insert(orderInfo);log.error("生成订单-------------------------------------------------------------");return orderInfo.getOrderId();}/*** 前端支付完成,余额支付直接调用此方法*/@Override@Transactional(rollbackFor = Exception.class)public ResponseVO complete(CompleteVO completeVO) {String payType = completeVO.getPayType();log.error("complete------------------------------------------------------------"+completeVO);if ("1".equals(payType)) {//余额支付String orderId = completeVO.getOrderId();String lockName = "access:lock:complete:" + orderId;String lockId = UUID.randomUUID();if (!redisLockUtil.tryLock(lockName, lockId, 20L)) {// 调用太快return new ResponseVO(PaymentEnum.getStatusByCode(4),4,PaymentEnum.getMsgByCode(4));}// 获取订单信息OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", orderId));if ((orderInfo.getOrderStatus() != 0)) {// 订单不是待支付状态return new ResponseVO(PaymentEnum.getStatusByCode(2),2,PaymentEnum.getMsgByCode(2));}String userId = orderInfo.getUserId();AccountInfo accountInfo = accountInfoMapper.selectOne(new QueryWrapper<AccountInfo>().eq("user_id", userId));BigDecimal balance = accountInfo.getPiBalance();if (balance.compareTo(orderInfo.getAmount()) < 0) {// 余额不足，请前往充值return new ResponseVO(PaymentEnum.getStatusByCode(5),5,PaymentEnum.getMsgByCode(5));}int update = orderInfoMapper.update(null,new UpdateWrapper<OrderInfo>().eq("order_id",orderId).set("order_status",1));balance=balance.subtract(orderInfo.getAmount());int update1 = accountInfoMapper.update(null, new UpdateWrapper<AccountInfo>().eq("user_id", userId).set("pi_balance", balance));// 支付成功return new ResponseVO(PaymentEnum.getStatusByCode(6),6,PaymentEnum.getMsgByCode(6));}//PI钱包支付String paymentId = completeVO.getPaymentId();//PI订单号String lockName = "access:lock:complete:" + paymentId;String lockId = UUID.randomUUID();log.error(paymentId+"-----------------"+lockName+"---------------------"+lockId);if (!redisLockUtil.tryLock(lockName, lockId, 20L)) {// 调用太快log.error("!RedisLockUtil---------------------------------------------------------调用太快");return new ResponseVO(PaymentEnum.getStatusByCode(4),4,PaymentEnum.getMsgByCode(4));}OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", completeVO.getOrderId()));log.error("orderId--------------------------------------------------------------"+orderInfo);if (null == orderInfo) {// 订单不存在log.error("!orderinfo--------------------------------------------------------不存在");return new ResponseVO(PaymentEnum.getStatusByCode(1),1,PaymentEnum.getMsgByCode(1));}log.error("orderinfo------------------------------------------------------------------"+orderInfo);if (orderInfo.getOrderStatus() != 0) {// 订单不是待支付状态log.error("!order---------------------------------------------------------pay");return  new ResponseVO(PaymentEnum.getStatusByCode(2),2,PaymentEnum.getMsgByCode(2));}//通知PI完成交易JSONObject jsonObject = new JSONObject();jsonObject.put("txid", completeVO.getTxId());Map<String, String> heads = new HashMap<>();heads.put("Content-Type", "application/json;charset=UTF-8");heads.put("Authorization", "Key " + commonConfig.getServerAccessKey());log.error("pi-----------------------------------------"+jsonObject);try {HttpResponse response = HttpRequest.post("https://api.minepi.com/v2/payments/" + paymentId + "/complete").headerMap(heads, false).body(String.valueOf(jsonObject)).timeout(5 * 60 * 1000).execute();String body = response.body();JSONObject jsonObject1 = JSON.parseObject(body);String error = jsonObject1.getString("error");if (!StringUtils.isEmpty(error)) {log.error("!strinutils-----------------------------"+body);throw new RuntimeException("订单完成异常!");}orderInfo.setOrderStatus(1);// 更新订单orderInfoMapper.updateById(orderInfo);log.error("支付成功------------------------------------------------------");// 支付成功return  new ResponseVO(PaymentEnum.getStatusByCode(6),6,PaymentEnum.getMsgByCode(6));} catch (Exception e) {throw e;}}@Override@Transactional(rollbackFor = Exception.class)public Boolean cancelled(String orderId) {int update = orderInfoMapper.update(null, new UpdateWrapper<OrderInfo>().eq("order_id", orderId).set("order_status", 3));return update > 0;}@Overridepublic ResponseVO incomplete(IncompleteVO incompleteVO) {log.error("incomplete--------------------------------");try {//先处理未完成的订单String oldpaymentId = incompleteVO.getIdentifier();TransactionVO transaction = incompleteVO.getTransaction();log.error("?transation--------------------"+transaction);log.error("?oldpaymentId------------------"+oldpaymentId);if (null != transaction) {log.error("transation--------------------"+transaction);log.error("oldpaymentId------------------"+oldpaymentId);String txid = transaction.getTxid();String txURL = transaction.get_link();//                OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", oldpaymentId));
//                if (null == orderInfo) {
//                    log.error("order-----------------null");
//                    throw new RuntimeException("旧订单不存在");
//                }
//
//                if (orderInfo.getOrderStatus()==1) {
//                    log.error("orderStatus---------------------"+orderInfo.getOrderStatus());
//                    throw new RuntimeException("订单是已支付状态");
//                }String get = HttpClientUtil.sendGet(txURL);JSONObject jsonObject1 = JSON.parseObject(get);String piOrderId = jsonObject1.getString("memo");//我方订单IDlog.error("memo---------------------"+piOrderId);JSONObject jsonObject = new JSONObject();jsonObject.put("txid", txid);Map<String, String> heads = new HashMap<>();heads.put("Content-Type", "application/json;charset=UTF-8");heads.put("Authorization", "Key " + commonConfig.getServerAccessKey());try {HttpResponse response = HttpRequest.post("https://api.minepi.com/v2/payments/" + piOrderId + "/complete").headerMap(heads, false).body(String.valueOf(jsonObject)).timeout(5 * 60 * 1000).execute();String body = response.body();JSONObject jsonObject2 = JSON.parseObject(body);String error = jsonObject2.getString("error");if (!StringUtils.isEmpty(error)) {log.error("!response------------------"+error);throw new RuntimeException("订单完成异常!");}return new ResponseVO(PaymentEnum.getStatusByCode(7),7,PaymentEnum.getMsgByCode(7));} catch (Exception e) {throw e;}}} catch (Exception e) {return new ResponseVO(PaymentEnum.getStatusByCode(8),8,PaymentEnum.getMsgByCode(8));}return new ResponseVO(PaymentEnum.getStatusByCode(8),8,PaymentEnum.getMsgByCode(8));}

 前端代码

前端路由 

API
// 授权
import request from "@/api/http";
import axios from "axios";// 支付授权
export function payAuth(data){return request({url: "/api/order/payOrder/approve",method: "post",data,});
}//未完成订单
export function payIncomplete(data){return request({url: "/api/order/payOrder/incomplete",method: "post",data,});
}//支付成功
export function payDone(data){return request({url: "/api/order/payOrder/complete",method: "post",data,});
}
//支付取消
export function payCancel(data){return request({url: "/api/order/payOrder/cancelled",method: "post",data,})
}

支付前端代码

 test(){const pay_message = this.pay_messagelet orderid = ''console.log({amount: pay_message.amount,shopUserId: pay_message.shopUserId,shopId: pay_message.shopId,userId: pay_message.userId})Pi.createPayment({// Amount of π to be paid:amount: 3.14,// An explanation of the payment - will be shown to the user:memo: "购买特殊数据", // e.g: "Digital kitten #1234",// An arbitrary developer-provided metadata object - for your own usage:metadata: { productID : 'apple_pie_1'  }, // e.g: { kittenId: 1234 }}, {// Callbacks you need to implement - read more about those in the detailed docs linked below:// 授权async onReadyForServerApproval(paymentId) {console.log('paymentId',paymentId)payAuth({paymentId: paymentId,amount: pay_message.amount,shopUserId: pay_message.shopUserId,shopId: pay_message.shopId,userId: pay_message.userId}).then((data) => {orderid = data.dataconsole.log('orderId',orderid)}).catch(error => {console.log(error)})},//支付成功onReadyForServerCompletion: function(paymentId, txid) {alert(1111)console.log(paymentId, 'paymentId', 'txid', txid,'orderid',orderid )payDone({paymentId: paymentId, txId: txid, orderId: orderid,payType:'0'}).then(res => {console.log(res)// if (res && res.code === 0) {//   this.payDoneJump();// }})},//支付取消onCancel: function(orderid) {console.log('onCancel' + orderid)payCancel(orderid).then((data) => {console.log(data)})},//支付失败onError: function(error, payment) {console.log('error:',error);console.log('payment:',payment)}});},

登录自动调用未支付订单，这个十分重要因为会影响支付授权。 

const loginFun = () => {Pi.init({ version: "2.0", sandbox: true });const scopes = ["payments", "username", "wallet_address"];function onIncompletePaymentFound(payment) {alert(1111111)console.log("payment", payment);return payIncomplete({identifier:payment.identifier,transaction:{_link:payment.transaction._link,txid:res.transaction.txid}})}Pi.authenticate(scopes, onIncompletePaymentFound).then(function (auth) {console.log("auth", auth);let userInfo = {accessToken: auth.accessToken,userId: auth.user.uid,userName: auth.user.username,};// userGetPush().then((data) => {//   console.log(data);//   userStore().userGetPush = data.data;// });Login(userInfo).then((data) => {console.log(data);if (data.status == "success") {// 将用户信息存入piniauserStore().userInfoChange(data.data);// 发布消息到socket Login() 存入userId// this.$socket.emit("login", data.data.userInfo.userId);router.push("/home");}});}).catch(function (error) {console.error(error);});
};

详细流程

使用Pi-SDK功能发起支付

 由Pi SDK自动调用的回调函数，发出支付批准请求

 

 路由到后端的支付授权接口

 后端服务器向Pi服务器发起支付授权

 @Override@Transactional(rollbackFor = Exception.class)public String approve(PaymentVO paymentVO) {log.error("approve-------------------------------------------------------------");OrderInfo orderInfo;log.error("paymentVO----------------------------------"+paymentVO);//获取付款信息OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url("https://api.minepi.com/v2/payments/" + paymentVO.getPaymentId()).addHeader("Authorization", "Key " + commonConfig.getServerAccessKey()).build();try (Response response = client.newCall(request).execute()) {if (!response.isSuccessful()) {String string = response.body().string();JSONObject jsonObject1 = JSON.parseObject(string);log.error("!response-------------------------------------------------------------"+commonConfig.getServerAccessKey());throw new RuntimeException("payments error " + jsonObject1.getString("error_message"));}String string = response.body().string();log.error("response-------------------------------------------------------------"+string);JSONObject jsonObject1 = JSON.parseObject(string);//校验实际支付金额BigDecimal userFinalPrice = paymentVO.getAmount();if (userFinalPrice.compareTo(jsonObject1.getBigDecimal("amount")) < 0) {log.error(userFinalPrice+"response-------------------------------------------------------------"+jsonObject1.getBigDecimal("amount"));throw new RuntimeException("支付金额少于订单金额");}} catch (Exception e) {throw  new BusinessException("支付失败，请联系后台人员"+e.getLocalizedMessage()+e.toString()+e.getCause().toString());}OkHttpClient client1 = new OkHttpClient();//信息真实，通知PI我准备好了，可以付款了Request request1 = new Request.Builder().url("https://api.minepi.com/v2/payments/" + paymentVO.getPaymentId() + "/approve").addHeader("Content-Type", "application/json").addHeader("Access-Control-Allow-Origin", "*").addHeader("Authorization", "Key " + commonConfig.getServerAccessKey()).post(RequestBody.create("", MediaType.parse("application/json"))).build();try (Response response1 = client1.newCall(request1).execute()) {if (!response1.isSuccessful()) {throw new RuntimeException("approve error: ");}log.error("response1-------------------------------------------------------------");//更新支付报文
//                    tMerStoreGoodsOrderEntity.setPayOrderId(paymentDto.getPaymentId());
//                    tMerStoreGoodsOrderEntity.setPayStatusType("10007002");//支付中
//                    itMerStoreGoodsOrderService.updateById(tMerStoreGoodsOrderEntity);log.error("return-------------------------------------------------------------");} catch (RuntimeException | IOException e) {log.error("error-------------------------------------------------------------");e.printStackTrace();}// 生成订单orderInfo = new OrderInfo();orderInfo.setOrderId(StringUtil.generateShortId());orderInfo.setShopId(paymentVO.getShopId());orderInfo.setUserId(paymentVO.getUserId());orderInfo.setShopUserId(paymentVO.getShopUserId());orderInfo.setAmount(paymentVO.getAmount());orderInfoMapper.insert(orderInfo);log.error("生成订单-------------------------------------------------------------");return orderInfo.getOrderId();}

PI游览器向用户显示付款详细信息页面，我们等待用户签署交易

 由Pi SDK自动调用完成的回调函数

 从你的后端服务器到Pi服务器的API请求以完成付款（让pi服务器知道你完成此付款）

 /*** 前端支付完成,余额支付直接调用此方法*/@Override@Transactional(rollbackFor = Exception.class)public ResponseVO complete(CompleteVO completeVO) {String payType = completeVO.getPayType();log.error("complete------------------------------------------------------------"+completeVO);if ("1".equals(payType)) {//余额支付String orderId = completeVO.getOrderId();String lockName = "access:lock:complete:" + orderId;String lockId = UUID.randomUUID();if (!redisLockUtil.tryLock(lockName, lockId, 20L)) {// 调用太快return new ResponseVO(PaymentEnum.getStatusByCode(4),4,PaymentEnum.getMsgByCode(4));}// 获取订单信息OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", orderId));if ((orderInfo.getOrderStatus() != 0)) {// 订单不是待支付状态return new ResponseVO(PaymentEnum.getStatusByCode(2),2,PaymentEnum.getMsgByCode(2));}String userId = orderInfo.getUserId();AccountInfo accountInfo = accountInfoMapper.selectOne(new QueryWrapper<AccountInfo>().eq("user_id", userId));BigDecimal balance = accountInfo.getPiBalance();if (balance.compareTo(orderInfo.getAmount()) < 0) {// 余额不足，请前往充值return new ResponseVO(PaymentEnum.getStatusByCode(5),5,PaymentEnum.getMsgByCode(5));}int update = orderInfoMapper.update(null,new UpdateWrapper<OrderInfo>().eq("order_id",orderId).set("order_status",1));balance=balance.subtract(orderInfo.getAmount());int update1 = accountInfoMapper.update(null, new UpdateWrapper<AccountInfo>().eq("user_id", userId).set("pi_balance", balance));// 支付成功return new ResponseVO(PaymentEnum.getStatusByCode(6),6,PaymentEnum.getMsgByCode(6));}//PI钱包支付String paymentId = completeVO.getPaymentId();//PI订单号String lockName = "access:lock:complete:" + paymentId;String lockId = UUID.randomUUID();log.error(paymentId+"-----------------"+lockName+"---------------------"+lockId);if (!redisLockUtil.tryLock(lockName, lockId, 20L)) {// 调用太快log.error("!RedisLockUtil---------------------------------------------------------调用太快");return new ResponseVO(PaymentEnum.getStatusByCode(4),4,PaymentEnum.getMsgByCode(4));}OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", completeVO.getOrderId()));log.error("orderId--------------------------------------------------------------"+orderInfo);if (null == orderInfo) {// 订单不存在log.error("!orderinfo--------------------------------------------------------不存在");return new ResponseVO(PaymentEnum.getStatusByCode(1),1,PaymentEnum.getMsgByCode(1));}log.error("orderinfo------------------------------------------------------------------"+orderInfo);if (orderInfo.getOrderStatus() != 0) {// 订单不是待支付状态log.error("!order---------------------------------------------------------pay");return  new ResponseVO(PaymentEnum.getStatusByCode(2),2,PaymentEnum.getMsgByCode(2));}//通知PI完成交易JSONObject jsonObject = new JSONObject();jsonObject.put("txid", completeVO.getTxId());Map<String, String> heads = new HashMap<>();heads.put("Content-Type", "application/json;charset=UTF-8");heads.put("Authorization", "Key " + commonConfig.getServerAccessKey());log.error("pi-----------------------------------------"+jsonObject);try {HttpResponse response = HttpRequest.post("https://api.minepi.com/v2/payments/" + paymentId + "/complete").headerMap(heads, false).body(String.valueOf(jsonObject)).timeout(5 * 60 * 1000).execute();String body = response.body();JSONObject jsonObject1 = JSON.parseObject(body);String error = jsonObject1.getString("error");if (!StringUtils.isEmpty(error)) {log.error("!strinutils-----------------------------"+body);throw new RuntimeException("订单完成异常!");}orderInfo.setOrderStatus(1);// 更新订单orderInfoMapper.updateById(orderInfo);log.error("支付成功------------------------------------------------------");// 支付成功return  new ResponseVO(PaymentEnum.getStatusByCode(6),6,PaymentEnum.getMsgByCode(6));} catch (Exception e) {throw e;}}

注意，如果用户有未处理的订单，会导致用户重新创建支付失败，需要有个接口去处理未完成的订单

前端一初始化就去执行处理未完成的订单

路由到后端的接口 

 

 后端接口代码

@Overridepublic ResponseVO incomplete(IncompleteVO incompleteVO) {log.error("incomplete--------------------------------");try {//先处理未完成的订单String oldpaymentId = incompleteVO.getIdentifier();TransactionVO transaction = incompleteVO.getTransaction();log.error("?transation--------------------"+transaction);log.error("?oldpaymentId------------------"+oldpaymentId);if (null != transaction) {log.error("transation--------------------"+transaction);log.error("oldpaymentId------------------"+oldpaymentId);String txid = transaction.getTxid();String txURL = transaction.get_link();//                OrderInfo orderInfo = orderInfoMapper.selectOne(new QueryWrapper<OrderInfo>().eq("order_id", oldpaymentId));
//                if (null == orderInfo) {
//                    log.error("order-----------------null");
//                    throw new RuntimeException("旧订单不存在");
//                }
//
//                if (orderInfo.getOrderStatus()==1) {
//                    log.error("orderStatus---------------------"+orderInfo.getOrderStatus());
//                    throw new RuntimeException("订单是已支付状态");
//                }String get = HttpClientUtil.sendGet(txURL);JSONObject jsonObject1 = JSON.parseObject(get);String piOrderId = jsonObject1.getString("memo");//我方订单IDlog.error("memo---------------------"+piOrderId);JSONObject jsonObject = new JSONObject();jsonObject.put("txid", txid);Map<String, String> heads = new HashMap<>();heads.put("Content-Type", "application/json;charset=UTF-8");heads.put("Authorization", "Key " + commonConfig.getServerAccessKey());try {HttpResponse response = HttpRequest.post("https://api.minepi.com/v2/payments/" + piOrderId + "/complete").headerMap(heads, false).body(String.valueOf(jsonObject)).timeout(5 * 60 * 1000).execute();String body = response.body();JSONObject jsonObject2 = JSON.parseObject(body);String error = jsonObject2.getString("error");if (!StringUtils.isEmpty(error)) {log.error("!response------------------"+error);throw new RuntimeException("订单完成异常!");}return new ResponseVO(PaymentEnum.getStatusByCode(7),7,PaymentEnum.getMsgByCode(7));} catch (Exception e) {throw e;}}} catch (Exception e) {return new ResponseVO(PaymentEnum.getStatusByCode(8),8,PaymentEnum.getMsgByCode(8));}return new ResponseVO(PaymentEnum.getStatusByCode(8),8,PaymentEnum.getMsgByCode(8));}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/129848.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

16.（开发工具篇mysql）mysql不同库同步数据的异常记录

16.（开发工具篇mysql）mysql不同库同步数据的异常记录

1：mysql导入时出现“ERROR at line : Unknown command ‘\‘‘.“的解决办法 default-character-set=utf82：ERROR 2006 (HY000) at line 71: MySQL server has gone away （1） 连接超时 查看各项连接时间： show global variables like %timeout;这些值是相对是MySQL的默认…
阅读更多...
2023 IDC中国数字金融论坛丨中电金信向行业分享“源启+应用重构”新范式

2023 IDC中国数字金融论坛丨中电金信向行业分享“源启+应用重构”新范式

9月8日&#xff0c;IDC主办的“2023 IDC中国数字金融论坛”在北京召开。中电金信受邀参会&#xff0c;并带来了深度数字化转型趋势之下关于应用重构的分享与洞见。 论坛重点关注金融科技创新发展趋势与数字化转型之路&#xff0c;中电金信副总经理、研究院院长况文川带来了“创…
阅读更多...
自然语言处理（NLP）的开发框架

自然语言处理（NLP）的开发框架

自然语言处理&#xff08;NLP&#xff09;领域有许多开源的框架和库&#xff0c;用于处理文本数据和构建NLP应用程序。以下是一些常见的NLP开源框架及其特点&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合…
阅读更多...
基于Java的个性化旅游攻略系统设计与实现(源码+lw+ppt+部署文档+视频讲解等)

基于Java的个性化旅游攻略系统设计与实现(源码+lw+ppt+部署文档+视频讲解等)

文章目录 前言具体实现截图论文参考详细视频演示代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作者&#xff0c;博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java、小程序技…
阅读更多...
12. Java异常及异常处理处理

12. Java异常及异常处理处理

Java —— 异常及处理 1. 异常2. 异常体系3. 常见Exception4. 异常处理4.1 try finally catch关键字4.2 throws和throw 自定义异常4.3 finally&#xff0c;final&#xff0c;finalize三者的区别 1. 异常 异常&#xff1a;在程序执行过程中发生的意外状况&#xff0c;可能导致程…
阅读更多...
NLP - 数据预处理 - 文本按句子进行切分

NLP - 数据预处理 - 文本按句子进行切分

NLP - 数据预处理 - 文本按句子进行切分 文章目录 NLP - 数据预处理 - 文本按句子进行切分一、前言二、环境配置1、安装nltk库2、下载punkt分句器 三、运行程序四、额外补充 一、前言 在学习对数据训练的预处理的时候遇到了一个问题&#xff0c;就是如何将文本按句子切分&#…
阅读更多...
Spring Boot中实现发送文本、带附件和HTML邮件

Spring Boot中实现发送文本、带附件和HTML邮件

SpringBoot实现发送邮箱 引言 在现代应用程序中&#xff0c;电子邮件通常是不可或缺的一部分。在Spring Boot中&#xff0c;你可以轻松地实现发送不同类型的邮件&#xff0c;包括文本、带附件和HTML邮件。本博客将向你展示如何使用Spring Boot发送这些不同类型的电子邮件。 步…
阅读更多...
Idea JavaWeb项目，继承自HttpFilter的过滤器，启动Tomcat时部署工件出错

Idea JavaWeb项目，继承自HttpFilter的过滤器，启动Tomcat时部署工件出错

JDK版本&#xff1a;1.8 Tomcat版本&#xff1a;8.5 10-Oct-2023 13:55:17.586 严重 [RMI TCP Connection(3)-127.0.0.1] org.apache.catalina.core.StandardContext.startInternal One or more Filters failed to start. Full details will be found in the appropriate conta…
阅读更多...
双机备份？

双机备份？

1.双机热备&#xff08;概念&#xff09; 从广义上讲&#xff0c;就是对于重要的服务&#xff0c;使用两台服务器&#xff0c;互相备份&#xff0c;共同执行同一服务。当一台服务器出现故障时&#xff0c;可以由另一台服务器承担服务任务&#xff0c;从而在不需要人工干预的情…
阅读更多...
第二证券：5.5G时代将至 算力基建迎政策助力

第二证券：5.5G时代将至 算力基建迎政策助力

昨日&#xff0c;A股全线低开&#xff0c;三大股指盘中均跌超1%&#xff0c;盘中冲高回落&#xff0c;午后逐渐止跌。到收盘&#xff0c;沪指跌0.44%报3096.92点&#xff0c;深成指微跌0.03%报10106.96点&#xff0c;创业板指跌0.26%报1998.61点&#xff0c;两市算计成交7700元…
阅读更多...
PyCharm搭建Scrapy环境

PyCharm搭建Scrapy环境

Scrapy入门 1、Scrapy概述2、PyCharm搭建Scrapy环境3、Scrapy使用四部曲4、Scrapy入门案例4.1、明确目标4.2、制作爬虫4.3、存储数据4.4、运行爬虫 1、Scrapy概述 Scrapy是一个由Python语言开发的适用爬取网站数据、提取结构性数据的Web应用程序框架。主要用于数据挖掘、信息处…
阅读更多...
安全与隐私：直播购物App开发中的重要考虑因素

安全与隐私：直播购物App开发中的重要考虑因素

随着直播购物App的崭露头角&#xff0c;开发者需要特别关注安全性和隐私问题。本文将介绍在直播购物App开发中的一些重要安全和隐私考虑因素&#xff0c;并提供相关的代码示例。 1. 数据加密 在直播购物App中&#xff0c;用户的个人信息和支付信息是极为敏感的数据。为了保护…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023