package com.dsh.activity.util.wx;
|
|
import com.dsh.activity.util.wx.WXPaySignatureCertificateUtil;
|
import com.dsh.activity.util.wx.WxPayAesUtil;
|
import com.dsh.activity.util.wx.WxV3PayConfig;
|
import com.fasterxml.jackson.databind.JsonNode;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.nio.charset.StandardCharsets;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@RestController
|
@RequestMapping("/api/appPayment") // 路径前缀，与常量中配置的回调URL匹配
|
public class WxPayNotifyController {
|
|
private static final Logger log = LoggerFactory.getLogger(WxPayNotifyController.class);
|
|
private final ObjectMapper objectMapper;
|
|
@Autowired
|
public WxPayNotifyController(ObjectMapper objectMapper) {
|
this.objectMapper = objectMapper;
|
}
|
|
/**
|
* 接收微信支付结果通知
|
* URL需要与 WXPayConstants.WECHAT_PAY_NOTIFY_URL 匹配
|
*/
|
@PostMapping("/weChatPayNotify")
|
public ResponseEntity<Map<String, String>> handleWeChatPayNotify(HttpServletRequest request, @RequestBody String requestBody) {
|
|
Map<String, String> responseMap = new HashMap<>();
|
try {
|
// 1. 验证签名 (使用工具类，它会处理证书)
|
boolean verifyResult = WXPaySignatureCertificateUtil.verifyNotify(request, requestBody);
|
if (!verifyResult) {
|
log.error("微信支付通知验签失败！");
|
responseMap.put("code", "FAIL");
|
responseMap.put("message", "验签失败");
|
return new ResponseEntity<>(responseMap, HttpStatus.BAD_REQUEST); // 返回错误状态码
|
}
|
log.info("微信支付通知验签成功。");
|
|
// 2. 解析通知体
|
JsonNode notifyData = objectMapper.readTree(requestBody);
|
String eventType = notifyData.get("event_type").asText();
|
|
// 只处理支付成功的通知类型
|
if ("TRANSACTION.SUCCESS".equals(eventType)) {
|
log.info("处理支付成功通知...");
|
JsonNode resourceNode = notifyData.get("resource");
|
String associatedData = resourceNode.get("associated_data").asText();
|
String nonce = resourceNode.get("nonce").asText();
|
String ciphertext = resourceNode.get("ciphertext").asText();
|
|
// 3. 解密关键信息
|
String decryptedDataJson = WxPayAesUtil.decrypt(WxV3PayConfig.apiV3Key, associatedData, nonce, ciphertext);
|
log.info("解密后的支付通知信息: {}", decryptedDataJson);
|
JsonNode decryptedData = objectMapper.readTree(decryptedDataJson);
|
|
// 4. 处理业务逻辑
|
String outTradeNo = decryptedData.get("out_trade_no").asText();
|
String transactionId = decryptedData.get("transaction_id").asText();
|
String tradeState = decryptedData.get("trade_state").asText();
|
// ... 获取其他需要的信息，例如支付金额、用户openid等
|
|
// TODO: 在这里实现你的业务逻辑：
|
// 1. 根据 outTradeNo 查询你的数据库订单状态。
|
// 2. 判断订单是否已经处理过（防止重复处理通知）。
|
// 3. 如果订单未处理且 tradeState 为 SUCCESS，则更新订单状态为支付成功。
|
// 4. 记录 transactionId (微信支付订单号)。
|
// 5. 执行后续业务流程（如发货、增加积分等）。
|
// 6. 如果处理失败，可以考虑记录日志并后续重试，但仍需返回成功给微信，避免微信重复通知。
|
|
log.info("业务逻辑处理完成，商户订单号: {}, 微信订单号: {}", outTradeNo, transactionId);
|
|
} else {
|
log.warn("收到非支付成功类型的通知: {}", eventType);
|
// 其他类型的通知，根据需要处理或忽略
|
}
|
|
// 5. 返回成功响应给微信平台
|
responseMap.put("code", "SUCCESS");
|
responseMap.put("message", "成功");
|
return new ResponseEntity<>(responseMap, HttpStatus.OK);
|
|
} catch (Exception e) {
|
log.error("处理微信支付通知异常", e);
|
responseMap.put("code", "FAIL");
|
responseMap.put("message", "处理失败");
|
// 即使处理失败，也尽量返回成功给微信，避免重复通知轰炸，然后在后台处理异常。
|
// 但如果验签失败，可以返回错误状态码。
|
return new ResponseEntity<>(responseMap, HttpStatus.INTERNAL_SERVER_ERROR); // 或者返回OK，根据策略定
|
}
|
}
|
|
|
/**
|
* 接收微信退款结果通知
|
* URL需要与 WXPayConstants.WECHAT_REFUNDS_NOTIFY_URL 匹配
|
*/
|
@PostMapping("/weChatPayRefundsNotify")
|
public ResponseEntity<Map<String, String>> handleWeChatRefundsNotify(HttpServletRequest request, @RequestBody String requestBody) {
|
|
Map<String, String> responseMap = new HashMap<>();
|
try {
|
// 1. 验证签名
|
boolean verifyResult = WXPaySignatureCertificateUtil.verifyNotify(request, requestBody);
|
if (!verifyResult) {
|
log.error("微信退款通知验签失败！");
|
responseMap.put("code", "FAIL");
|
responseMap.put("message", "验签失败");
|
return new ResponseEntity<>(responseMap, HttpStatus.BAD_REQUEST);
|
}
|
log.info("微信退款通知验签成功。");
|
|
// 2. 解析通知体
|
JsonNode notifyData = objectMapper.readTree(requestBody);
|
String eventType = notifyData.get("event_type").asText();
|
|
// 处理退款成功或异常的通知
|
if ("REFUND.SUCCESS".equals(eventType) || "REFUND.ABNORMAL".equals(eventType) || "REFUND.CLOSED".equals(eventType)) {
|
log.info("处理退款通知，类型: {}", eventType);
|
JsonNode resourceNode = notifyData.get("resource");
|
String associatedData = resourceNode.get("associated_data").asText();
|
String nonce = resourceNode.get("nonce").asText();
|
String ciphertext = resourceNode.get("ciphertext").asText();
|
|
// 3. 解密关键信息
|
String decryptedDataJson = WxPayAesUtil.decrypt(WxV3PayConfig.apiV3Key, associatedData, nonce, ciphertext);
|
log.info("解密后的退款通知信息: {}", decryptedDataJson);
|
JsonNode decryptedData = objectMapper.readTree(decryptedDataJson);
|
|
// 4. 处理业务逻辑
|
String outTradeNo = decryptedData.get("out_trade_no").asText();
|
String outRefundNo = decryptedData.get("out_refund_no").asText();
|
String refundStatus = decryptedData.get("refund_status").asText(); // SUCCESS, CLOSED, ABNORMAL
|
// ... 获取其他需要的信息，例如退款金额、微信退款单号 refund_id 等
|
|
// TODO: 在这里实现你的退款业务逻辑：
|
// 1. 根据 outRefundNo 查询你的数据库退款单状态。
|
// 2. 判断退款单是否已经处理过。
|
// 3. 根据 refundStatus 更新退款单状态。
|
// 4. 如果退款成功 (SUCCESS)，可能需要执行一些操作，如返还库存、通知用户等。
|
// 5. 如果退款关闭或异常，也需要记录状态。
|
|
log.info("退款业务逻辑处理完成，商户订单号: {}, 商户退款单号: {}, 退款状态: {}", outTradeNo, outRefundNo, refundStatus);
|
|
} else {
|
log.warn("收到非退款类型的通知: {}", eventType);
|
}
|
|
// 5. 返回成功响应给微信平台
|
responseMap.put("code", "SUCCESS");
|
responseMap.put("message", "成功");
|
return new ResponseEntity<>(responseMap, HttpStatus.OK);
|
|
} catch (Exception e) {
|
log.error("处理微信退款通知异常", e);
|
responseMap.put("code", "FAIL");
|
responseMap.put("message", "处理失败");
|
return new ResponseEntity<>(responseMap, HttpStatus.INTERNAL_SERVER_ERROR);
|
}
|
}
|
|
}
|
