//package com.dsh.activity.util.wx;
|
//
|
//import com.dsh.activity.util.wx.WXPayConstants;
|
//import com.dsh.activity.util.wx.WXPaySignatureCertificateUtil;
|
//import com.dsh.activity.util.wx.WxV3PayConfig;
|
//import com.fasterxml.jackson.databind.JsonNode; // 引入Jackson库处理JSON
|
//import com.fasterxml.jackson.databind.ObjectMapper;
|
//import com.fasterxml.jackson.databind.node.ObjectNode;
|
//import org.apache.http.client.methods.CloseableHttpResponse;
|
//import org.apache.http.client.methods.HttpPost;
|
//import org.apache.http.entity.StringEntity;
|
//import org.apache.http.impl.client.CloseableHttpClient;
|
//import org.apache.http.util.EntityUtils;
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.stereotype.Component;
|
//import org.springframework.stereotype.Service;
|
//
|
//import java.io.IOException;
|
//import java.math.BigDecimal;
|
//import java.nio.charset.StandardCharsets;
|
//import java.util.HashMap;
|
//import java.util.Map;
|
//
|
//@Component
|
//public class WxAppPayService {
|
//
|
// private static final Logger log = LoggerFactory.getLogger(WxAppPayService.class);
|
//
|
// private final ObjectMapper objectMapper; // 用于JSON序列化和反序列化
|
// private final CloseableHttpClient wechatPayClient; // 注入通过工具类创建的HTTP客户端
|
//
|
// @Autowired
|
// public WxAppPayService(ObjectMapper objectMapper) throws IOException {
|
// this.objectMapper = objectMapper;
|
// // 在构造函数中初始化带有签名验证功能的HTTP客户端
|
// this.wechatPayClient = WXPaySignatureCertificateUtil.getWechatPayClient();
|
// log.info("微信支付V3 HTTP客户端初始化完成。");
|
// }
|
//
|
// /**
|
// * 创建APP支付预付单 (统一下单)
|
// *
|
// * @param description 商品描述
|
// * @param outTradeNo 商户订单号 (要求32个字符内，只能是数字、大小写字母_-|* 且在同一个商户号下唯一)
|
// * @param totalAmount 支付总金额 (单位：元)
|
// * @return 用于调起APP支付的参数 Map (appid, partnerid, prepayid, package, noncestr, timestamp, sign)
|
// * @throws IOException 网络或IO异常
|
// * @throws RuntimeException 支付请求失败或处理异常
|
// */
|
// public Map<String, String> createOrder(String description, String outTradeNo, BigDecimal totalAmount)
|
// throws IOException {
|
//
|
// // 1. 构建请求URL
|
// String url = WXPayConstants.DOMAIN_API + WXPayConstants.PAY_TRANSACTIONS_APP;
|
// HttpPost httpPost = new HttpPost(url);
|
// httpPost.addHeader("Accept", "application/json");
|
// httpPost.addHeader("Content-type", "application/json; charset=utf-8");
|
//
|
// // 2. 构建请求体 JSON
|
// ObjectNode rootNode = objectMapper.createObjectNode();
|
//// rootNode.put("appid", WxV3PayConfig.APP_ID);//服务商不需要该字段
|
//// rootNode.put("mchid", WxV3PayConfig.Mch_ID);//服务商不需要该字段
|
// rootNode.put("description", description);
|
// rootNode.put("out_trade_no", outTradeNo);
|
// rootNode.put("notify_url", WXPayConstants.WECHAT_PAY_NOTIFY_URL); // 使用常量中的回调地址
|
//
|
// ObjectNode amountNode = objectMapper.createObjectNode();
|
// // 微信支付金额单位为分，需要转换
|
// amountNode.put("total", totalAmount.multiply(new BigDecimal("100")).intValue());
|
// amountNode.put("currency", "CNY"); // 货币类型，默认人民币
|
// rootNode.set("amount", amountNode);
|
//
|
// // 如果你是服务商模式，需要添加子商户信息
|
// rootNode.put("sp_mchid", WxV3PayConfig.Mch_ID);
|
// rootNode.put("sub_mchid", "123");
|
// rootNode.put("sp_appid", "wx41d32f362ba0f911");
|
// // rootNode.put("sub_appid", "子商户AppID"); // 如果子商户需要用自己的AppID拉起支付
|
//
|
// String requestBody = rootNode.toString();
|
// log.info("微信APP支付下单请求体: {}", requestBody);
|
// httpPost.setEntity(new StringEntity(requestBody, StandardCharsets.UTF_8));
|
//
|
// // 3. 发送请求
|
// try (CloseableHttpResponse response = wechatPayClient.execute(httpPost)) {
|
// int statusCode = response.getStatusLine().getStatusCode();
|
// String responseBody = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
|
// log.info("微信APP支付下单响应状态码: {}, 响应体: {}", statusCode, responseBody);
|
//
|
// if (statusCode == 200) { // HTTP状态码 200 表示成功
|
// JsonNode responseNode = objectMapper.readTree(responseBody);
|
// String prepayId = responseNode.get("prepay_id").asText();
|
// log.info("成功获取预支付交易会话标识 (prepay_id): {}", prepayId);
|
//
|
// // 4. 生成调起支付所需的参数
|
// Map<String, String> payParams = WXPaySignatureCertificateUtil.buildAppPayParams(prepayId);
|
// log.info("生成APP支付参数: {}", payParams);
|
// return payParams;
|
//
|
// } else {
|
// // 处理错误情况
|
// log.error("微信APP支付下单失败，状态码: {}, 响应: {}", statusCode, responseBody);
|
// // 可以根据 responseBody 中的 code 和 message 进一步分析错误
|
// throw new RuntimeException("微信APP支付下单失败: " + responseBody);
|
// }
|
// } catch (Exception e) {
|
// log.error("微信APP支付下单请求执行异常", e);
|
// throw new IOException("微信APP支付下单请求执行异常", e);
|
// }
|
// }
|
//
|
// /**
|
// * 关闭订单 (根据商户订单号)
|
// *
|
// * @param outTradeNo 商户订单号
|
// * @return true 如果关闭成功或订单已关闭/不存在 (根据微信文档，成功是204 No Content)
|
// * @throws IOException 网络或IO异常
|
// * @throws RuntimeException 关闭请求失败或处理异常
|
// */
|
// public boolean closeOrder(String outTradeNo) throws IOException {
|
// // 1. 构建请求URL, 注意替换占位符
|
// String url = WXPayConstants.DOMAIN_API
|
// + WXPayConstants.PAY_TRANSACTIONS_OUT_TRADE_NO.replace("{}", outTradeNo);
|
//
|
// HttpPost httpPost = new HttpPost(url);
|
// httpPost.addHeader("Accept", "application/json");
|
// httpPost.addHeader("Content-type", "application/json; charset=utf-8");
|
//
|
// // 2. 构建请求体 JSON (只需要商户号)
|
// ObjectNode rootNode = objectMapper.createObjectNode();
|
// rootNode.put("mchid", WxV3PayConfig.Mch_ID);
|
// // 如果是服务商模式，则用 sp_mchid
|
// rootNode.put("sp_mchid", WxV3PayConfig.Mch_ID);
|
//
|
// String requestBody = rootNode.toString();
|
// log.info("微信关单请求 URL: {}, 请求体: {}", url, requestBody);
|
// httpPost.setEntity(new StringEntity(requestBody, StandardCharsets.UTF_8));
|
//
|
// // 3. 发送请求
|
// try (CloseableHttpResponse response = wechatPayClient.execute(httpPost)) {
|
// int statusCode = response.getStatusLine().getStatusCode();
|
// // 关单成功时，微信返回 HTTP 状态码 204 No Content
|
// log.info("微信关单响应状态码: {}", statusCode);
|
// if (statusCode == 204) {
|
// log.info("订单 {} 关闭成功。", outTradeNo);
|
// return true;
|
// } else {
|
// String responseBody = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
|
// log.error("微信关单失败，商户订单号: {}, 状态码: {}, 响应: {}", outTradeNo, statusCode, responseBody);
|
// // 根据需要可以解析responseBody获取错误详情
|
// return false; // 或者抛出异常，根据业务决定
|
// }
|
// } catch (Exception e) {
|
// log.error("微信关单请求执行异常, 商户订单号: {}", outTradeNo, e);
|
// throw new IOException("微信关单请求执行异常", e);
|
// }
|
// }
|
//
|
//
|
// // --- 退款相关方法 (可选) ---
|
//
|
// /**
|
// * 申请退款
|
// *
|
// * @param outTradeNo 原商户订单号
|
// * @param outRefundNo 商户退款单号 (商户系统内部的退款单号，要求唯一)
|
// * @param reason 退款原因 (可选)
|
// * @param refundAmount 退款金额 (单位：元)
|
// * @param totalAmount 原订单总金额 (单位：元)
|
// * @return 退款处理结果，可以返回微信返回的JSON节点或自定义对象
|
// * @throws IOException 网络或IO异常
|
// * @throws RuntimeException 退款请求失败或处理异常
|
// */
|
// public JsonNode createRefund(String outTradeNo, String outRefundNo, String reason,
|
// BigDecimal refundAmount, BigDecimal totalAmount) throws IOException {
|
//
|
// String url = WXPayConstants.DOMAIN_API + WXPayConstants.REFUND_DOMESTIC_REFUNDS;
|
// HttpPost httpPost = new HttpPost(url);
|
// httpPost.addHeader("Accept", "application/json");
|
// httpPost.addHeader("Content-type", "application/json; charset=utf-8");
|
//
|
// ObjectNode rootNode = objectMapper.createObjectNode();
|
// // 如果是服务商模式，需要添加子商户号
|
// // rootNode.put("sub_mchid", "子商户号");
|
// rootNode.put("out_trade_no", outTradeNo);
|
// rootNode.put("out_refund_no", outRefundNo);
|
// if (reason != null && !reason.isEmpty()) {
|
// rootNode.put("reason", reason);
|
// }
|
// // 设置退款回调地址
|
// rootNode.put("notify_url", WXPayConstants.WECHAT_REFUNDS_NOTIFY_URL);
|
//
|
// ObjectNode amountNode = objectMapper.createObjectNode();
|
// amountNode.put("refund", refundAmount.multiply(new BigDecimal("100")).intValue()); // 退款金额，分
|
// amountNode.put("total", totalAmount.multiply(new BigDecimal("100")).intValue()); // 原订单金额，分
|
// amountNode.put("currency", "CNY");
|
// rootNode.set("amount", amountNode);
|
//
|
// String requestBody = rootNode.toString();
|
// log.info("微信申请退款请求体: {}", requestBody);
|
// httpPost.setEntity(new StringEntity(requestBody, StandardCharsets.UTF_8));
|
//
|
// try (CloseableHttpResponse response = wechatPayClient.execute(httpPost)) {
|
// int statusCode = response.getStatusLine().getStatusCode();
|
// String responseBody = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
|
// log.info("微信申请退款响应状态码: {}, 响应体: {}", statusCode, responseBody);
|
//
|
// if (statusCode == 200) { // 成功受理
|
// log.info("微信退款申请成功受理。");
|
// return objectMapper.readTree(responseBody);
|
// } else {
|
// log.error("微信申请退款失败，状态码: {}, 响应: {}", statusCode, responseBody);
|
// throw new RuntimeException("微信申请退款失败: " + responseBody);
|
// }
|
// } catch (Exception e) {
|
// log.error("微信申请退款请求执行异常", e);
|
// throw new IOException("微信申请退款请求执行异常", e);
|
// }
|
// }
|
//
|
//}
|
