对接支付宝和微信

rentaiming

2024-05-22 72f43644f615875fe2de6d98712661c19d7421df

 ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java

@@ -8,6 +8,7 @@
import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.Paylog;
import com.ruoyi.order.service.IPaylogService;
import com.ruoyi.order.service.impl.PaylogServiceImpl;
import com.ruoyi.order.util.DateUtil;
import com.ruoyi.order.util.SinataUtil;
import com.ruoyi.order.util.alipay.config.AlipayConfig;
@@ -67,99 +68,23 @@
    @Resource
    private IPaylogService iPaylogService;


    @Resource
     private PaylogServiceImpl   paylogServiceImpl;

    Logger log = LoggerFactory.getLogger(getClass());
    @ResponseBody
    @RequestMapping("getPayInfo")
    @RequestMapping("/getPayInfo")
    public R<Map<String, Object>> getPayInfo(Integer uid, Integer type, String subject, String body, String orderID,
                                          HttpServletRequest request) {
        Double price = 0.0;

        try {
            if(judgeContainsStr(orderID)){
                price=  Double.valueOf(1);
                body = "商品支付";
                subject = "商品支付";
                Map<String, Object> map = new HashMap<String, Object>();
                if (type == 1) {
                    // 支付宝预下单
                    return alipay("1", subject, body, price, request);
                } else {
                    // 微信预下单
                    return wxpay(1, "1", body, price, request);
                }
            }
            return paylogServiceImpl.getPayInfo(uid, type, subject, body, orderID,request);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return R.fail("获取异常");
    }

    /**
     * 支付宝订单退款
     *
     * @author tzj
     * @param out_trade_no
     *            商品订单号
     * @param trade_no
     *            支付宝交易号
     * @param refund_amount
     *            退款金额
     * @return
     */
    public boolean refundForAlipay(String out_trade_no, String trade_no, Double refund_amount) {
        try {
            // 实例化客户端
            AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do",
                    AlipayConfig.app_id, AlipayConfig.private_key, "json", AlipayConfig.input_charset,
                    AlipayConfig.ali_public_key,"RSA2");
            // 实例化具体API对应的request类,类名称和接口名称对应
            AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
            // SDK已经封装掉了公共参数，这里只需要传入业务参数
            // 此次只是参数展示，未进行字符串转义，实际情况下请转义
            request.setBizContent("{" + "\"out_trade_no\":\"" + out_trade_no + "\", " + "\"trade_no\":\"" + trade_no
                    + "\", " + "\"refund_amount\":" + refund_amount + ", " + "\"refund_reason\":\"正常退款\","
                    + "\"out_request_no\":\"HZ01RF001\"" + "}");
            AlipayTradeRefundResponse response = alipayClient.execute(request);
            // 调用成功，则处理业务逻辑
            if (response.isSuccess()) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return false;
    }

    /**
     * 获取支付信息支付(签约app支付2.0)
     *
     * @param subject
     * @param body
     * @param price
     * @param request
     * @return
     */
    public  R<Map<String, Object>> alipay(String orderNo, String subject, String body, Double price,
                                             HttpServletRequest request) {
        try {
            // 接口封装支付宝请求参数
            // Map<String, Object> mData = new HashMap<String, Object>();

            // 构建请求支付签名参数
            Map<String, Object> pay = PayDemoActivity.appPay(subject, body, price, orderNo);
            /*
             * Set<Entry<String, String>> entrySet = pay.entrySet();
             * Iterator<Entry<String, String>> iterator = entrySet.iterator();
             * while (iterator.hasNext()) { Entry<String, String> next =
             * iterator.next(); mData.put(next.getKey(), next.getValue()); }
             */
            return R.ok(pay);
        } catch (Exception e) {
            e.printStackTrace();
            return R.fail("支付异常!");
        }
    }

    /**
     * 服务器异步通知处理支付宝
@@ -168,116 +93,15 @@
     * @param res
     */
    @RequestMapping("/alipay/notify")
    public void notifyUrl(HttpServletRequest request, HttpServletResponse res) {
        HttpServletResponse response = (HttpServletResponse) res;
        response.setContentType("text/html;charset=UTF-8");
        PrintWriter out;
    public void notifyUrl(HttpServletRequest request, HttpServletResponse response) {
        try {
            out = response.getWriter();
            // 获取支付宝POST过来反馈信息
            Map<String, String> params = new HashMap<String, String>();
            Map requestParams = request.getParameterMap();
            log.debug("AlipayController.notifyUrl__requestParams：\n" + requestParams);
            for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext();) {
                String name = (String) iter.next();
                String[] values = (String[]) requestParams.get(name);
                String valueStr = "";
                for (int i = 0; i < values.length; i++) {
                    valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";
                }
                // 乱码解决，这段代码在出现乱码时使用。如果mysign和sign不相等也可以使用这段代码转化
                valueStr = new String(valueStr.getBytes("ISO-8859-1"), "gbk");
                params.put(name, valueStr);
            }

            Paylog paylog = getPayLog_alipay(request);

            // 验证成功
            if ("TRADE_FINISHED".equals(paylog.getTradeStatus())) {
                System.out.println("AlipayController.notifyUrl__验证成功：success");
                // 支付失败
            } else if ("TRADE_SUCCESS".equals(paylog.getTradeStatus())) {
                // 支付成功
                try {
                    if(judgeContainsStr(paylog.getOutTradeNo())){


                    }
                    // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
                    log.debug("AlipayController.notifyUrl__回调处理：success");
                    out.println("success"); // 请不要修改或删除
                // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
                log.debug("AlipayController.notifyUrl__回调处理：success");
                out.println("success"); // 请不要修改或删除
            paylogServiceImpl.notifyUrl(request,response);
            } catch (Exception e) {
                log.debug("AlipayController.notifyUrl__回调逻辑代码处理异常！fail");
                // 返回失败
                out.println("fail");
                e.printStackTrace();
            }
            // ////////////////////////////////////////////////////////////////////////////////////////
        } else {// 验证失败
            log.debug("AlipayController.notifyUrl__回调处理失败！fail");
            out.println("fail");
        }
    } catch (
    IOException e) {
        log.debug("AlipayController.notifyUrl__支付宝服务器异步通知数据处理失败！");
        e.printStackTrace();

    }
}

///////////////////////////////////////////////////////////////////////////////////////////////////
/**
 * 统一下单
 *
 * @param apptype
 * @param outTradeNo
 * @param body
 * @param price
 * @param request
 * @return
 */
public static R<Map<String, Object>> wxpay(Integer apptype, String outTradeNo, String body, Double price,
                                        HttpServletRequest request) {
    // 获取预支付接口返回参数
    Map<String, Object> map = new HashMap<String, Object>();
    Map<String, Object> appPayMap = new HashMap<String, Object>();
    try {
        // 构建接口请求参数
        UnifiedorderReqData unifiedorderReqData = new UnifiedorderReqData(apptype, outTradeNo, body, price,
                Configure.wx_notify_url);
        // 请求接口获取返回接口
        String result = requestUnifiedorderService(apptype, unifiedorderReqData);
        System.out.println(result);
        System.out.println("WxpayController.createOrder__result：\n" + result);
        // 获取预支付接口返回参数
        map = XMLParser.getMapFromXML(result);
        System.out.println("WxpayController.createOrder__result：\n" + result);
        // 捕获预支付接口错误提示
        if ("FAIL".equals(map.get("result_code")) || "FAIL".equals(map.get("return_code"))) {
            return R.fail(String.valueOf(map.get("return_msg")));
        }

        // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
        AppPayReqData appPay = new AppPayReqData(apptype, (String) map.get("appid"), (String) map.get("mch_id"),
                (String) map.get("prepay_id"), unifiedorderReqData.getNonce_str());

        // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
        appPayMap.put("appid", appPay.getAppid());// 公众账号ID
        appPayMap.put("nonceStr", appPay.getNoncestr());// 随机字符串(32位)
        appPayMap.put("package", appPay.get_package());// 扩展字段(暂填写固定值Sign=WXPay)
        appPayMap.put("partnerId", appPay.getPartnerid());// 商户号
        appPayMap.put("prepayId", appPay.getPrepayid());// 预支付编号（微信返回的支付交易会话ID）
        appPayMap.put("timeStamp", appPay.getTimestamp());// 时间戳
        appPayMap.put("sign", appPay.getSign());// 根据API给的签名规则进行签名
        return R.ok(appPayMap);
    } catch (Exception e) {
        System.out.println("统一下单_API_处理异常！");
        e.printStackTrace();
    }
    return R.fail("统一下单失败");
}

/**
 * 微信支付回调（参考财付通回调接口）
@@ -288,159 +112,13 @@
@RequestMapping("/wxpay/notify")
public void wxnotify(HttpServletRequest request, HttpServletResponse response) {
    try {
        System.out.println("微信支付回调！！！！！！！！！！！！！！！！！！！！！！！！！");
        // 异步通知返回报文
        StringBuffer notityXml = new StringBuffer();
        String inputLine;
        while ((inputLine = request.getReader().readLine()) != null) {
            notityXml.append(inputLine);
        }
        request.getReader().close();
        // log.debug("WxpayController.notify__notityXml：\n" + notityXml);
        System.out.println("WxpayController.notify__notityXml：\n" + notityXml);

        // 验证签名
        if (Signature.checkIsSignValidFromResponseString(1, notityXml.toString())
                || Signature.checkIsSignValidFromResponseString(2, notityXml.toString())) {
            Map<String, Object> map = XMLParser.getMapFromXML(notityXml.toString());
            // log.debug("WxpayController.notify__map：\n" + map);
            // 接口返回状态
            String result_code = (String) map.get("result_code");
            if ("SUCCESS".equals(result_code)) {
                // // 商户订单号
                String out_trade_no = (String) map.get("out_trade_no");
                // // 微信支付交易号
                String trade_no = (String) map.get("transaction_id");
                // // 金额,以分为单位
                String total_fee = (String) map.get("total_fee");
                // // 优惠金额
                // String discount = (String) map.get("discount");
                // // 支付完成时间
                String time_end = (String) map.get("time_end");
                // // 支付者唯一Id（对应买家账号的一个加密串 ）
                String buyer_id = (String) map.get("buyer_id");

                ///////////////////////////// 这里程序处理支付回调逻辑
                ///////////////////////////// ////////////////////
                Paylog paylog = new Paylog();
                paylog.setOutTradeNo(out_trade_no);
                paylog.setPayType(2);
                paylog.setBuyerId(buyer_id);
                paylog.setTradeNo(trade_no);
                paylog.setPayMoney(Double.parseDouble(total_fee) / 100);
                paylog.setState(1);
                System.out.println("支付完成时间"+time_end);
                paylog.setAddTime(LocalDateTime.now());
                iPaylogService.save(paylog);
                if(judgeContainsStr(paylog.getOutTradeNo())){



                    log.debug("WxpayController.notify__回调处理成功：SUCCESS");
                    response.getOutputStream().print("success");
                }
                log.debug("WxpayController.notify__回调处理成功：SUCCESS");
                response.getOutputStream().print("success");
            } else {
                log.debug("WxpayController.notify__回调处理：验证状态错误！" + result_code);
                System.out.println("验证状态错误！" + result_code);
            }
        } else {
            log.debug("WxpayController.notify__回调处理：通知签名验证失败！");
            System.out.println("通知签名验证失败！");
        }
        paylogServiceImpl.notifyUrl(request,response);
    } catch (Exception e) {
        e.printStackTrace();

    }
}

/**
 * 微信退款
 *
 * @param transactionID
 *            【支付交易号】是微信系统为每一笔支付交易分配的订单号，通过这个订单号可以标识这笔交易，
 *            它由支付订单API支付成功时返回的数据里面获取到。建议优先使用
 * @param outTradeNo
 *            【商品订单编号】商户系统内部的订单号,transaction_id
 *            、out_trade_no二选一，如果同时存在优先级：transaction_id>out_trade_no
 * @param outRefundNo
 *            【退款编号】商户系统内部的退款单号，商户系统内部唯一，同一退款单号多次请求只退一笔
 *            订单总金额，单位为分
 * @param refundFee
 *            退款总金额，单位为分,可以做部分退款
 * @return
 */
public static boolean refundForWxpay(Integer apptype, String transactionID, String outTradeNo, String outRefundNo,
                                     Integer totalFee, Integer refundFee, String pay_type) {
    Map<String, Object> map = new HashMap<String, Object>();
    try {
        // 构建接口请求参数
        com.tencent.protocol.RefundReqData refundReqData = new com.tencent.protocol.RefundReqData(transactionID, outTradeNo, outRefundNo, totalFee, refundFee,
                pay_type);

        // 请求接口返回结果
        String result = requestRefundService(apptype, refundReqData);
        System.out.println("微信退款返回内容：" + result);
        // 获取预支付接口返回参数
        map = XMLParser.getMapFromXML(result);
        System.out.println("微信退款返回参数：" + map);
        // 退款成功处理
        if ("SUCCESS".equals(map.get("result_code"))) {
            return true;
        }
    } catch (Exception e) {
        e.printStackTrace();
        return false;
    }
    return false;
}

/**
 * 获取支付宝
 *
 * @param request
 * @return
 * @throws Exception
 */
private Paylog getPayLog_alipay(HttpServletRequest request) throws IOException {
    //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
    // 商户订单号
    String out_trade_no = new String(request.getParameter("out_trade_no").getBytes("ISO-8859-1"), "UTF-8");
    // 支付宝交易号
    String trade_no = new String(request.getParameter("trade_no").getBytes("ISO-8859-1"), "UTF-8");
    // 交易状态
    String trade_status = new String(request.getParameter("trade_status").getBytes("ISO-8859-1"), "UTF-8");
    // 支付者唯一Id
    String buyer_id = new String(request.getParameter("buyer_id").getBytes("ISO-8859-1"), "UTF-8");
    // 支付帐号
    String buyer_email = "";
    if (SinataUtil.isNotEmpty(request.getParameter("buyer_logon_id"))) {
        buyer_email = new String(request.getParameter("buyer_logon_id").getBytes("ISO-8859-1"), "UTF-8");
    }
    // 支付金额
    String total_fee = new String(request.getParameter("total_amount").getBytes("ISO-8859-1"), "UTF-8");
    // 支付时间
    String notify_time = new String(request.getParameter("notify_time").getBytes("ISO-8859-1"), "UTF-8");

    //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
    Paylog paylog = new Paylog();
    paylog.setOutTradeNo(out_trade_no);
    paylog.setPayType(1);
    paylog.setBuyerId(buyer_id);
    paylog.setTradeNo(trade_no);
    paylog.setPayMoney(Double.parseDouble(total_fee));
    paylog.setState(1);
    paylog.setAddTime(LocalDateTime.now());
    paylog.setTradeStatus(trade_status.toString());
    iPaylogService.save(paylog);
    return paylog;
}

public boolean judgeContainsStr(String cardNum) {
    String regex=".*[a-zA-Z]+.*";
    Matcher m= Pattern.compile(regex).matcher(cardNum);
    return m.matches();
}


}