//package org.ruoyi.system.controller.system;
|
//
|
//import cn.hutool.core.bean.BeanUtil;
|
//import cn.hutool.core.collection.CollectionUtil;
|
//import cn.hutool.extra.qrcode.QrCodeUtil;
|
//import cn.hutool.json.JSONObject;
|
//import cn.hutool.json.JSONUtil;
|
//import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
|
//import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
|
//import com.github.binarywang.wxpay.bean.order.WxPayNativeOrderResult;
|
//import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
|
//import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
|
//import com.github.binarywang.wxpay.exception.WxPayException;
|
//import com.github.binarywang.wxpay.service.WxPayService;
|
//import com.stripe.Stripe;
|
//import com.stripe.exception.StripeException;
|
//import com.stripe.model.Event;
|
//import com.stripe.model.Price;
|
//import com.stripe.model.Product;
|
//import com.stripe.model.checkout.Session;
|
//import com.stripe.net.Webhook;
|
//import com.stripe.param.checkout.SessionCreateParams;
|
//import jakarta.servlet.http.HttpServletRequest;
|
//import lombok.RequiredArgsConstructor;
|
//import lombok.extern.slf4j.Slf4j;
|
//import org.ruoyi.common.config.PayConfig;
|
//import org.ruoyi.common.core.domain.R;
|
//import org.ruoyi.common.core.exception.base.BaseException;
|
//import org.ruoyi.common.core.service.ConfigService;
|
//import org.ruoyi.common.core.utils.StringUtils;
|
//import org.ruoyi.common.oss.core.OssClient;
|
//import org.ruoyi.common.oss.entity.UploadResult;
|
//import org.ruoyi.common.oss.factory.OssFactory;
|
//import org.ruoyi.common.response.PayResponse;
|
//import org.ruoyi.common.service.PayService;
|
//import org.ruoyi.common.utils.MD5Util;
|
//import org.ruoyi.system.domain.bo.PaymentOrdersBo;
|
//import org.ruoyi.system.domain.bo.SysUserBo;
|
//import org.ruoyi.system.domain.request.OrderRequest;
|
//import org.ruoyi.system.domain.vo.PaymentOrdersVo;
|
//import org.ruoyi.system.domain.vo.SysUserVo;
|
//import org.ruoyi.system.service.IPaymentOrdersService;
|
//import org.ruoyi.system.service.ISysUserService;
|
//import org.springframework.web.bind.annotation.*;
|
//
|
//import java.io.ByteArrayOutputStream;
|
//import java.io.InputStream;
|
//import java.math.BigDecimal;
|
//import java.math.RoundingMode;
|
//import java.util.HashMap;
|
//import java.util.List;
|
//import java.util.Map;
|
//
|
//
|
//@RequiredArgsConstructor
|
//@RestController
|
//@RequestMapping("/pay")
|
//@Slf4j
|
//public class PayController {
|
//
|
// private final PayService payService;
|
//
|
// private final ISysUserService userService;
|
//
|
// private final IPaymentOrdersService paymentOrdersService;
|
//
|
// private final PayConfig payConfig;
|
//
|
// private final WxPayService wxService;
|
//
|
// private final ConfigService configService;
|
//
|
// /**
|
// * 获取支付二维码
|
// *
|
// * @Date 2023/7/3
|
// * @return void
|
// **/
|
// @PostMapping("/payUrl")
|
// public R<PaymentOrdersVo> payUrl(@RequestBody OrderRequest orderRequest) {
|
// PaymentOrdersBo payOrder = paymentOrdersService.createPayOrder(orderRequest);
|
// PaymentOrdersVo paymentOrdersVo = new PaymentOrdersVo();
|
// if(!Boolean.parseBoolean(getKey("enabled"))){
|
// String payUrl = payService.getPayUrl(payOrder.getOrderNo(), orderRequest.getName(), Double.parseDouble(orderRequest.getMoney()), "192.168.1.6");
|
// byte[] bytes = QrCodeUtil.generatePng(payUrl, 300, 300);
|
// OssClient storage = OssFactory.instance();
|
// UploadResult upload=storage.upload(bytes, storage.getPath("qrCode",".png"), "image/png");
|
// BeanUtil.copyProperties(payOrder,paymentOrdersVo);
|
// paymentOrdersVo.setUrl(upload.getUrl());
|
// }else {
|
// WxPayUnifiedOrderRequest request = new WxPayUnifiedOrderRequest();
|
// request.setTradeType("NATIVE");
|
// request.setBody(orderRequest.getName());
|
// request.setOutTradeNo(payOrder.getOrderNo());
|
// request.setTotalFee(BaseWxPayRequest.yuanToFen(orderRequest.getMoney()));
|
// request.setSpbillCreateIp("127.0.0.1");
|
// request.setNotifyUrl(getKey("notifyUrl"));
|
// request.setProductId(payOrder.getId().toString());
|
// try {
|
// WxPayNativeOrderResult order = wxService.createOrder(request);
|
// byte[] bytes = QrCodeUtil.generatePng(order.getCodeUrl(), 300, 300);
|
// OssClient storage = OssFactory.instance();
|
// UploadResult upload = storage.upload(bytes, storage.getPath("qrCode",".png"), "image/png");
|
// BeanUtil.copyProperties(payOrder,paymentOrdersVo);
|
// paymentOrdersVo.setUrl(upload.getUrl());
|
// } catch (WxPayException e) {
|
// throw new BaseException("获取微信支付二维码发生错误：{}"+e.getMessage());
|
// }
|
// }
|
// return R.ok(paymentOrdersVo);
|
// }
|
//
|
// /**
|
// * 回调通知地址
|
// *
|
// * @Date 2023/7/3
|
// * @param
|
// * @return void
|
// **/
|
// @GetMapping("/notifyUrl")
|
// public String notifyUrl(PayResponse payResponse) {
|
// // 校验签名
|
// String mdString = "money=" + payResponse.getMoney() + "&name=" + payResponse.getName() +
|
// "&out_trade_no=" + payResponse.getOut_trade_no() + "&pid=" + payConfig.getPid() +
|
// "&trade_no=" + payResponse.getTrade_no() + "&trade_status=" + payResponse.getTrade_status() +
|
// "&type=" + payResponse.getType() + payConfig.getKey();
|
// String sign = MD5Util.GetMD5Code(mdString);
|
// if(!sign.equals(payResponse.getSign())){
|
// throw new BaseException("校验签名失败！");
|
// }
|
// double money = Double.parseDouble(payResponse.getMoney());
|
// log.info("支付订单号{}",payResponse);
|
// PaymentOrdersBo paymentOrdersBo = new PaymentOrdersBo();
|
// paymentOrdersBo.setOrderNo(payResponse.getOut_trade_no());
|
// List<PaymentOrdersVo> paymentOrdersList = paymentOrdersService.queryList(paymentOrdersBo);
|
// if (CollectionUtil.isEmpty(paymentOrdersList)){
|
// throw new BaseException("订单不存在！");
|
// }
|
// // 订单状态修改为已支付
|
// PaymentOrdersVo paymentOrdersVo = paymentOrdersList.get(0);
|
// paymentOrdersVo.setPaymentStatus("2");
|
// paymentOrdersVo.setPaymentMethod(payResponse.getType());
|
// BeanUtil.copyProperties(paymentOrdersVo,paymentOrdersBo);
|
// paymentOrdersService.updateByBo(paymentOrdersBo);
|
//
|
// SysUserVo sysUserVo = userService.selectUserById(paymentOrdersVo.getUserId());
|
// sysUserVo.setUserBalance(sysUserVo.getUserBalance() + money);
|
// SysUserBo sysUserBo = new SysUserBo();
|
// BeanUtil.copyProperties(sysUserVo,sysUserBo);
|
// // 设置为付费用户
|
// sysUserBo.setUserGrade("1");
|
// userService.updateUser(sysUserBo);
|
// return "success";
|
// }
|
//
|
// /**
|
// * 跳转通知地址
|
// *
|
// * @Date 2023/7/3
|
// * @param
|
// * @return void
|
// **/
|
// @GetMapping("/return_url")
|
// public void returnUrl() {
|
// log.info("return_url===========");
|
// }
|
//
|
//
|
// @PostMapping("/notify/wxOrder")
|
// public String parseOrderNotifyResult(@RequestBody String xmlData) throws WxPayException {
|
// WxPayOrderNotifyResult notifyResult = this.wxService.parseOrderNotifyResult(xmlData);
|
// // TODO 根据自己业务场景需要构造返回对象
|
// PaymentOrdersBo paymentOrdersBo = new PaymentOrdersBo();
|
// paymentOrdersBo.setOrderNo(notifyResult.getOutTradeNo());
|
// List<PaymentOrdersVo> paymentOrdersList = paymentOrdersService.queryList(paymentOrdersBo);
|
// PaymentOrdersVo paymentOrdersVo = paymentOrdersList.get(0);
|
// paymentOrdersVo.setPaymentStatus("2");
|
// paymentOrdersVo.setPaymentMethod("wx");
|
// BeanUtil.copyProperties(paymentOrdersVo,paymentOrdersBo);
|
// paymentOrdersService.updateByBo(paymentOrdersBo);
|
// SysUserVo sysUserVo = userService.selectUserById(paymentOrdersVo.getUserId());
|
// sysUserVo.setUserBalance(sysUserVo.getUserBalance() + convertCentsToYuan(notifyResult.getTotalFee()));
|
// SysUserBo sysUserBo = new SysUserBo();
|
// BeanUtil.copyProperties(sysUserVo,sysUserBo);
|
// // 设置为付费用户
|
// sysUserBo.setUserGrade("1");
|
// userService.updateUser(sysUserBo);
|
// return WxPayNotifyResponse.success("success");
|
// }
|
//
|
// /**
|
// * 将分转换为元，并保留精度。
|
// *
|
// * @param cents 分的金额，类型为Integer
|
// * @return 转换后的元金额，类型为double
|
// */
|
// public static double convertCentsToYuan(Integer cents) {
|
// // 处理空输入
|
// if (cents == null) {
|
// throw new IllegalArgumentException("输入的分金额不能为空");
|
// }
|
//
|
// // 100分 = 1元
|
// BigDecimal centsBigDecimal = new BigDecimal(cents);
|
// BigDecimal yuan = centsBigDecimal.divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);
|
// // 转换为double并返回
|
// return yuan.doubleValue();
|
// }
|
//
|
// /**
|
// * 获取订单信息
|
// *
|
// */
|
// @PostMapping("/orderInfo")
|
// public R<PaymentOrdersVo> orderInfo(@RequestBody OrderRequest orderRequest) {
|
// if(StringUtils.isEmpty(orderRequest.getOrderNo())){
|
// throw new BaseException("订单号不能为空！");
|
// }
|
// PaymentOrdersBo paymentOrdersBo = new PaymentOrdersBo();
|
// paymentOrdersBo.setOrderNo(orderRequest.getOrderNo());
|
// List<PaymentOrdersVo> paymentOrdersList = paymentOrdersService.queryList(paymentOrdersBo);
|
// if (CollectionUtil.isEmpty(paymentOrdersList)){
|
// throw new BaseException("订单不存在！");
|
// }
|
// PaymentOrdersVo paymentOrdersVo = paymentOrdersList.get(0);
|
// return R.ok(paymentOrdersVo);
|
// }
|
//
|
// // 获取支付链接
|
//// static {
|
//// Stripe.apiKey = "sk_test_51PMMj2KcfX4oNioqXkoKpScTsgmR55xQki2tg8MEZJYc0gjhYV85t2FzDasE06eqZb0sqyYhOp3UXhcGGQLWI4A9008aq8SOnb";
|
//// }
|
//
|
// /**
|
// * 去支付
|
// * 1、创建产品
|
// * 2、设置价格
|
// * 3、创建支付信息 得到url
|
// * @return
|
// */
|
// @PostMapping("/stripePay")
|
// public String pay(@RequestBody OrderRequest orderRequest) throws StripeException {
|
//
|
// String enabled = configService.getConfigValue("stripe", "enabled");
|
// if(!Boolean.parseBoolean(enabled)){
|
// String prompt = configService.getConfigValue("stripe", "prompt");
|
// throw new BaseException(prompt);
|
// }
|
//
|
// // 获取支付链接
|
// Stripe.apiKey = configService.getConfigValue("stripe", "key");
|
//
|
// // 获取金额字符串并解析为 double
|
// double moneyDouble = Double.parseDouble(orderRequest.getMoney());
|
//
|
// // 将金额转换为以分为单位的整数
|
// int randMoney = (int) (moneyDouble * 100);
|
//
|
// Map<String, Object> params = new HashMap<>();
|
// params.put("name", orderRequest.getName());
|
// Product product = Product.create(params);
|
//
|
// Map<String, Object> recurring = new HashMap<>();
|
// recurring.put("interval", "month");
|
// Map<String, Object> params2 = new HashMap<>();
|
// params2.put("unit_amount", randMoney);
|
// params2.put("currency", "usd");
|
// params2.put("recurring", recurring);
|
// params2.put("product", product.getId());
|
// Price price = Price.create(params2);
|
//
|
// // 创建支付订单
|
// PaymentOrdersBo payOrder = paymentOrdersService.createPayOrder(orderRequest);
|
//
|
// //创建支付信息 得到url
|
// SessionCreateParams params3 = SessionCreateParams.builder()
|
// .setMode(SessionCreateParams.Mode.SUBSCRIPTION)
|
// .setSuccessUrl(configService.getConfigValue("stripe", "success"))
|
// .setCancelUrl(configService.getConfigValue("stripe", "cancel"))
|
// .addLineItem(
|
// SessionCreateParams.LineItem.builder()
|
// .setQuantity(1L)
|
// .setPrice(price.getId())
|
// .build()).putMetadata("orderId", payOrder.getOrderNo())
|
// .build();
|
// Session session = Session.create(params3);
|
// return session.getUrl();
|
// }
|
//
|
// /**
|
// * 支付回调
|
// *
|
// */
|
// @PostMapping("/stripe_events")
|
// public R<String> stripeEvent(HttpServletRequest request) {
|
// try {
|
// String endpointSecret = configService.getConfigValue("stripe", "secret");//webhook秘钥签名
|
// InputStream inputStream = request.getInputStream();
|
// ByteArrayOutputStream output = new ByteArrayOutputStream();
|
// byte[] buffer = new byte[1024*4];
|
// int n = 0;
|
// while (-1 != (n = inputStream.read(buffer))) {
|
// output.write(buffer, 0, n);
|
// }
|
// byte[] bytes = output.toByteArray();
|
// String payload = new String(bytes, "UTF-8");
|
// String sigHeader = request.getHeader("Stripe-Signature");
|
// Event event = Webhook.constructEvent(payload, sigHeader, endpointSecret);//验签，并获取事件
|
// if("checkout.session.completed".equals(event.getType())){
|
// // 解析 JSON 字符串为 JSONObject
|
// JSONObject jsonObject = JSONUtil.parseObj(event);
|
// // 获取 metadata 对象
|
// JSONObject metadata = jsonObject.getJSONObject("data")
|
// .getJSONObject("object")
|
// .getJSONObject("metadata");
|
//
|
// OrderRequest orderRequest = new OrderRequest();
|
// orderRequest.setPayType("stripe");
|
// orderRequest.setOrderNo(metadata.getStr("orderId"));
|
// paymentOrdersService.updatePayOrder(orderRequest);
|
// }
|
// } catch (Exception e) {
|
// System.out.println("stripe异步通知（webhook事件）"+e);
|
// }
|
// return R.ok();
|
// }
|
//
|
// public String getKey(String key) {
|
// return configService.getConfigValue("weixin", key);
|
// }
|
//
|
//}
|
//
|
