//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);
//    }
//
//}
//