无关风月
2025-04-08 cc2dbab7c527dd323a8bf713cb254b8d2bc40717
提现
3个文件已修改
1个文件已添加
240 ■■■■ 已修改文件
ruoyi-common/ruoyi-common-core/src/main/java/com/ruoyi/common/core/constant/WechatConstants.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-service/ruoyi-order/pom.xml 5 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/WithdrawServiceImpl.java 146 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/vx/TestWxPay.java 83 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-common/ruoyi-common-core/src/main/java/com/ruoyi/common/core/constant/WechatConstants.java
@@ -57,9 +57,13 @@
    public static final String TRANSFER_DETAIL_LIST = "transfer_detail_list";
    /**
     * 微信商家转账到用户零钱接口地址(前缀)
     * 微信商家转账到用户零钱接口地址(前缀)弃用
     */
    public static final String WE_CHAT_URL_PRE = "https://api.mch.weixin.qq.com/v3/transfer/batches";
    /**
     * 微信发起转账(前缀)
     */
    public static final String WE_CHAT_PAY_URL_PRE = "https://api.mch.weixin.qq.com/v3/fund-app/mch-transfer/transfer-bills";
    /**
     * 微信商家转账到用户零钱接口地址(后缀)
ruoyi-service/ruoyi-order/pom.xml
@@ -19,7 +19,10 @@
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.github.wechatpay-apiv3</groupId>
            <artifactId>wechatpay-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/WithdrawServiceImpl.java
@@ -138,7 +138,7 @@
            throw new GlobalException("当前订单提现申请已通过!");
        }
        return weChatPay(order.getOrderMoney(), openId,list.get(0).getId());
        return weChatPay(order.getOrderMoney(), openId,list.get(0).getId(),order.getServeName());
    }
    @Override
@@ -252,7 +252,7 @@
            // 已通过
            withdraw.setState(Constants.ONE);
            // 商家微信打款至微信零钱
            boolean update = weChatPay(order.getOrderMoney(), openId,withdraw.getId());
            boolean update = weChatPay(order.getOrderMoney(), openId,withdraw.getId(),order.getServerName());
//            if (!update) {
//                throw new GlobalException("交易提现失败,请检查是否绑定微信!");
//            }
@@ -272,15 +272,94 @@
    @Resource
    private WithdrawDetailService withdrawDetailService;
    private boolean weChatPay(BigDecimal orderMoney, String openId,String withdrawId) {
//    private boolean weChatPay(BigDecimal orderMoney, String openId,String withdrawId) {
//        if (StringUtils.isBlank(openId)) {
//            return false;
//        }
//
//        BigDecimal maxTransferAmount = new BigDecimal("20000"); // 单次转账限额,单位为分
//        int totalTransfers = orderMoney.multiply(new BigDecimal("100")).divide(maxTransferAmount, 0, RoundingMode.UP).intValue();
//        boolean allTransfersSuccessful = true;
//
//        for (int i = 0; i < totalTransfers; i++) {
//            BigDecimal transferAmount;
//            if (i < totalTransfers - 1) {
//                transferAmount = maxTransferAmount;
//            } else {
//                // 最后一笔转账,金额为剩余金额
//                transferAmount = orderMoney.multiply(new BigDecimal("100")).subtract(maxTransferAmount.multiply(new BigDecimal(i))).setScale(0, RoundingMode.DOWN);
//            }
//
//            Map<String, Object> postMap = new HashMap<>(8);
//            postMap.put(WechatConstants.APP_ID, "wx98563d0ec9cf21c8");
//            postMap.put(WechatConstants.OUT_BATCH_NO, String.valueOf(UUID.randomUUID()).replaceAll("-", ""));
//            System.err.println("====="+postMap.get(WechatConstants.OUT_BATCH_NO));
//            postMap.put(WechatConstants.BATCH_NAME, "二手回收提现");
//            postMap.put(WechatConstants.BATCH_REMARK, "二手回收提现");
//            postMap.put(WechatConstants.TOTAL_AMOUNT, transferAmount);
//            postMap.put(WechatConstants.TOTAL_NUM, Constants.ONE);
//
//            List<Map<String, Object>> list = new ArrayList<>();
//            Map<String, Object> subMap = new HashMap<>(4);
//            subMap.put(WechatConstants.OUT_DETAIL_NO, String.valueOf(SNOW_FLAKE_ID_WORKER.nextId()));
//            subMap.put(WechatConstants.TRANSFER_AMOUNT, transferAmount);
//            subMap.put(WechatConstants.TRANSFER_REMARK, "二手回收提现到账");
//            subMap.put(WechatConstants.OPEN_ID, openId);
//            list.add(subMap);
//            postMap.put(WechatConstants.TRANSFER_DETAIL_LIST, list);
//
//            // 使用类加载器获取资源 URL
////            String path = ClassLoader.getSystemResource("/usr/local/vx/apiclient_key.pem").getPath();
//
////            String result = HttpUtil.postTransBatRequest(
////                    WechatConstants.WE_CHAT_URL_PRE,
////                    JSONObject.toJSONString(postMap),
////                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",
////                    "1665330417",
////                    "/usr/local/vx/apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);
//            String result = HttpUtil.postTransBatRequest(
//                    WechatConstants.WE_CHAT_URL_PRE,
//                    JSONObject.toJSONString(postMap),
//                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",
//                    "1665330417",
//                    "D:\\study\\JiaDianHuiShou\\ruoyi-service\\ruoyi-order\\src\\main\\java\\com\\ruoyi\\order\\vx\\apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);
//
//            JSONObject jsonObject = JSONObject.parseObject(result);
//
//            WithdrawDetail withdrawDetail = new WithdrawDetail();
//            withdrawDetail.setWithdrawId(withdrawId);
//            withdrawDetail.setMoney(transferAmount);
//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
//            withdrawDetailService.save(withdrawDetail);
//
//            if (jsonObject.containsKey(WechatConstants.CREATE_TIME)) {
//                // 转账成功
//                //保存转账明细
////                WithdrawDetail withdrawDetail = new WithdrawDetail();
////                withdrawDetail.setWithdrawId(withdrawId);
////                withdrawDetail.setMoney(transferAmount);
////                withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
////                withdrawDetailService.save(withdrawDetail);
//
//
//            } else {
//                allTransfersSuccessful = false;
//                break;
//            }
//
//        }
//
//        return allTransfersSuccessful;
//    }
    // 上架打款到用户零钱接口已弃用 用新版商家转账接口
    private boolean weChatPay(BigDecimal orderMoney, String openId,String withdrawId,String serverName) {
        if (StringUtils.isBlank(openId)) {
            return false;
        }
        BigDecimal maxTransferAmount = new BigDecimal("20000"); // 单次转账限额,单位为分
        BigDecimal maxTransferAmount = new BigDecimal("200000"); // 单次转账限额,单位为分
        int totalTransfers = orderMoney.multiply(new BigDecimal("100")).divide(maxTransferAmount, 0, RoundingMode.UP).intValue();
        boolean allTransfersSuccessful = true;
        for (int i = 0; i < totalTransfers; i++) {
            BigDecimal transferAmount;
            if (i < totalTransfers - 1) {
@@ -292,46 +371,33 @@
            Map<String, Object> postMap = new HashMap<>(8);
            postMap.put(WechatConstants.APP_ID, "wx98563d0ec9cf21c8");
            postMap.put(WechatConstants.OUT_BATCH_NO, String.valueOf(UUID.randomUUID()).replaceAll("-", ""));
            // 订单号
            postMap.put("out_bill_no", String.valueOf(UUID.randomUUID()).replaceAll("-", ""));
            System.err.println("====="+postMap.get(WechatConstants.OUT_BATCH_NO));
            postMap.put(WechatConstants.BATCH_NAME, "二手回收提现");
            postMap.put(WechatConstants.BATCH_REMARK, "二手回收提现");
            postMap.put(WechatConstants.TOTAL_AMOUNT, transferAmount);
            postMap.put(WechatConstants.TOTAL_NUM, Constants.ONE);
            List<Map<String, Object>> list = new ArrayList<>();
            Map<String, Object> subMap = new HashMap<>(4);
            subMap.put(WechatConstants.OUT_DETAIL_NO, String.valueOf(SNOW_FLAKE_ID_WORKER.nextId()));
            subMap.put(WechatConstants.TRANSFER_AMOUNT, transferAmount);
            subMap.put(WechatConstants.TRANSFER_REMARK, "二手回收提现到账");
            subMap.put(WechatConstants.OPEN_ID, openId);
            list.add(subMap);
            postMap.put(WechatConstants.TRANSFER_DETAIL_LIST, list);
            // 使用类加载器获取资源 URL
//            String path = ClassLoader.getSystemResource("/usr/local/vx/apiclient_key.pem").getPath();
//            String result = HttpUtil.postTransBatRequest(
//                    WechatConstants.WE_CHAT_URL_PRE,
//                    JSONObject.toJSONString(postMap),
//                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",
//                    "1665330417",
//                    "/usr/local/vx/apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);
            postMap.put(WechatConstants.OPEN_ID, openId);
            // 转账金额
            postMap.put("transfer_amount", transferAmount);
            // 转账备注
            postMap.put("transfer_remark", transferAmount);
            // 回调地址
            postMap.put("notify_url", transferAmount);
            // 转账场景报备信息
            Map<String, Object> info = new HashMap<>();
            info.put("info_type","回收商品名称");
            info.put("info_content",serverName);
            postMap.put("transfer_scene_report_infos", JSONObject.toJSONString(info));
            String result = HttpUtil.postTransBatRequest(
                    WechatConstants.WE_CHAT_URL_PRE,
                    WechatConstants.WE_CHAT_PAY_URL_PRE,
                    JSONObject.toJSONString(postMap),
                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",
                    "1665330417",
                    "D:\\study\\JiaDianHuiShou\\ruoyi-service\\ruoyi-order\\src\\main\\java\\com\\ruoyi\\order\\vx\\apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);
                    "E:\\ershoucert\\apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);
            JSONObject jsonObject = JSONObject.parseObject(result);
            WithdrawDetail withdrawDetail = new WithdrawDetail();
            withdrawDetail.setWithdrawId(withdrawId);
            withdrawDetail.setMoney(transferAmount);
            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
            withdrawDetailService.save(withdrawDetail);
//            WithdrawDetail withdrawDetail = new WithdrawDetail();
//            withdrawDetail.setWithdrawId(withdrawId);
//            withdrawDetail.setMoney(transferAmount);
//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
//            withdrawDetailService.save(withdrawDetail);
            if (jsonObject.containsKey(WechatConstants.CREATE_TIME)) {
                // 转账成功
                //保存转账明细
ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/vx/TestWxPay.java
New file
@@ -0,0 +1,83 @@
package com.ruoyi.order.vx;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.common.core.constant.WechatConstants;
import com.ruoyi.common.core.utils.StringUtils;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
public class TestWxPay {
    public static void main(String[] args) {
        weChatPay(BigDecimal.valueOf(0.1), "ouqOk6xtWA3JDmpd9HpZf9ijESIs", "1", "空调挂机");
    }
    private static boolean weChatPay(BigDecimal orderMoney, String openId, String withdrawId, String serverName) {
        if (StringUtils.isBlank(openId)) {
            return false;
        }
        BigDecimal maxTransferAmount = new BigDecimal("200000"); // 单次转账限额,单位为分
        int totalTransfers = orderMoney.multiply(new BigDecimal("100")).divide(maxTransferAmount, 0, RoundingMode.UP).intValue();
        boolean allTransfersSuccessful = true;
        for (int i = 0; i < totalTransfers; i++) {
            BigDecimal transferAmount;
            if (i < totalTransfers - 1) {
                transferAmount = maxTransferAmount;
            } else {
                // 最后一笔转账,金额为剩余金额
                transferAmount = orderMoney.multiply(new BigDecimal("100")).subtract(maxTransferAmount.multiply(new BigDecimal(i))).setScale(0, RoundingMode.DOWN);
            }
            Map<String, Object> postMap = new HashMap<>(8);
            postMap.put(WechatConstants.APP_ID, "wx98563d0ec9cf21c8");
            // 订单号
            postMap.put("out_bill_no", String.valueOf(UUID.randomUUID()).replaceAll("-", ""));
            System.err.println("====="+postMap.get("out_bill_no"));
            postMap.put(WechatConstants.OPEN_ID, openId);
            // 转账金额
            postMap.put("transfer_amount", transferAmount);
            postMap.put("transfer_scene_id", "1010");
            // 转账备注
            postMap.put("transfer_remark", "二手回收提现确认收款");
            // 回调地址
//            postMap.put("notify_url", transferAmount);
            // 转账场景报备信息
            List<Map<String, Object>> list = new ArrayList<>();
            Map<String, Object> info = new HashMap<>();
            info.put("info_type","回收商品名称");
            info.put("info_content",serverName);
            list.add(info);
            postMap.put("transfer_scene_report_infos", list);
            String result = HttpUtil.postTransBatRequest(
                    WechatConstants.WE_CHAT_PAY_URL_PRE,
                    JSONObject.toJSONString(postMap),
                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",
                    "1665330417",
                    "E:\\ershoucert\\apiclient_key.pem", "/v3/fund-app/mch-transfer/transfer-bills");
            JSONObject jsonObject = JSONObject.parseObject(result);
//            WithdrawDetail withdrawDetail = new WithdrawDetail();
//            withdrawDetail.setWithdrawId(withdrawId);
//            withdrawDetail.setMoney(transferAmount);
//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
//            withdrawDetailService.save(withdrawDetail);
            System.err.println(jsonObject);
            if (jsonObject.containsKey(WechatConstants.CREATE_TIME)) {
                // 转账成功
                //保存转账明细
//                WithdrawDetail withdrawDetail = new WithdrawDetail();
//                withdrawDetail.setWithdrawId(withdrawId);
//                withdrawDetail.setMoney(transferAmount);
//                withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));
//                withdrawDetailService.save(withdrawDetail);
            } else {
                allTransfersSuccessful = false;
                break;
            }
        }
        return allTransfersSuccessful;
    }
}