1
String outTradeNo = paramsMap.get("out_trade_no");
2
String totalAmount = paramsMap.get("total_amount");
3
BigDecimal callbackAmount = new BigDecimal(totalAmount);
4
String appId = paramsMap.get("app_id");
5
String tradeStatus = paramsMap.get("trade_status");

1
if (!"TRADE_SUCCESS".equals(tradeStatus)) {
2
    return "failure";
3
}
4

5
if (!csmallAlipayConfig.getAppId().equals(appId)) {
6
    return "failure";
7
}

1
LambdaQueryWrapper<PaymentInfo> queryWrapper = new LambdaQueryWrapper<>();
2
queryWrapper.eq(PaymentInfo::getOutTradeNo, outTradeNo)
3
        .eq(PaymentInfo::getPaymentType, payTypeName);
4

5
PaymentInfo paymentInfo = paymentInfoMapper.selectOne(queryWrapper);
6
if (paymentInfo != null) {
7
    return paymentInfoConverter.convertPaymentInfoToDTO(paymentInfo);
8
}
9
return null;

1
PaymentInfoDTO paymentInfoDTO =
2
        payService.queryPaymentInfoByOutTradeNoAndPaymentType(
3
                outTradeNo, PaymentType.ALIPAY.name());
4

5
if (paymentInfoDTO == null) {
6
    return "failure";
7
}
8

9
BigDecimal localTotalAmount = paymentInfoDTO.getTotalAmount();
10
if (localTotalAmount.doubleValue() != callbackAmount.doubleValue()) {
11
    return "failure";
12
}

1
// 改进示例，不是当前实现
2
if (localTotalAmount.compareTo(callbackAmount) != 0) {
3
    return "failure";
4
}

1
key   = pay:callback:notifyid:{notify_id}
2
value = out_trade_no
3
write = RBucket.trySet(value)
4
TTL   = 当前调用没有设置

1
String notifyId = paramsMap.get("notify_id");
2
String key = RedisConst.PAY_CALL_BACK_VERFY_PREFIX + notifyId;
3
RBucket<Object> bucket = redissonClient.getBucket(key);
4

5
boolean firstHandle = bucket.trySet(outTradeNo);
6

7
if (!firstHandle) {
8
    return "success";
9
}

1
Boolean flag = payService.successPay(
2
        outTradeNo, PaymentType.ALIPAY.name(), paramsMap);
3

4
if (!flag) {
5
    bucket.delete();
6
    return "failure";
7
}
8

9
return "success";

1
PaymentInfoDTO paymentInfoDTO =
2
        queryPaymentInfoByOutTradeNoAndPaymentType(outTradeNo, name);
3

4
PaymentInfo paymentInfo = new PaymentInfo();
5
paymentInfo.setId(paymentInfoDTO.getId());
6
paymentInfo.setPaymentStatus(PaymentStatus.PAID.name());
7
paymentInfo.setTradeNo(paramsMap.get("trade_no"));
8
paymentInfo.setCallbackTime(new Date());
9
paymentInfo.setCallbackContent(JSON.toJSONString(paramsMap));
10

11
int affectedRows = paymentInfoMapper.updateById(paymentInfo);
12
if (affectedRows < 1) {
13
    throw new RuntimeException("修改支付表的状态失败");
14
}

1
Result result =
2
        orderApiClient.successPay(paymentInfoDTO.getOrderId());
3

4
if (!ResultCodeEnum.SUCCESS.getCode().equals(result.getCode())) {
5
    throw new RuntimeException("远程调用订单失败");
6
}
7

8
return true;

1
@PostMapping("/api/order/inner/success/{orderId}")
2
public Result successPay(@PathVariable("orderId") Long orderId) {
3
    orderService.successPay(orderId);
4
    return Result.ok();
5
}

1
OrderInfo orderInfo = new OrderInfo();
2
orderInfo.setId(orderId);
3
orderInfo.setOrderStatus(OrderStatus.PAID.name());
4
orderInfo.setUpdateTime(new Date());
5
orderInfoMapper.updateById(orderInfo);
6

7
wareApiClient.decreaseStock(orderId);

1
支付回调
2
  -> payment_info = PAID
3
  -> Feign 通知 order-service
4
  -> order_info = PAID
5
  -> Feign 调用 ware-service
6
  -> 创建库存任务并锁定库存

1
POST /pay/notify/url
2
Content-Type: application/x-www-form-urlencoded
3

4
out_trade_no=<本地交易号>
5
&total_amount=<本地金额>
6
&app_id=<当前应用>
7
&trade_status=TRADE_SUCCESS
8
&notify_id=<通知唯一标识>
9
&trade_no=<第三方交易号>
10
&sign=<支付宝签名>

1
-- 改进示例，不是当前 Mapper
2
UPDATE payment_info
3
SET payment_status = 'PAID',
4
    trade_no = ?,
5
    callback_time = ?,
6
    callback_content = ?
7
WHERE id = ?
8
  AND payment_status = 'UNPAID';

1
支付宝回调
2
  -> 本地事务更新 payment_info
3
  -> 同一事务写 payment_success_event/outbox
4
  -> 后台可靠投递
5
  -> order-service 幂等消费
6
  -> ware-service 使用订单号或工作单唯一键防重