@RestController
@RequestMapping("/api/pay")
@Tag(name = "支付中心", description = "統(tǒng)一支付接口")
public class PayController {

    private final PayService payService;
    private final RedissonPropertiesConfig redissonPropertiesConfig;
    private final Redisson redisson;

    @Autowired
    public PayController(RedissonPropertiesConfig redissonPropertiesConfig,
                         Redisson redisson,
                         PayService payService) {
        this.redissonPropertiesConfig = redissonPropertiesConfig;
        this.redisson = redisson;
        this.payService = payService;
    }

    @PostMapping("/pay")
    @Operation(summary = "統(tǒng)一支付入口")
    @PermitAll
    public CommonResult<PaymentVO> corePay(@RequestBody @Valid PayVO payParam) throws Exception {
        log.info("【訂單 {}】發(fā)起支付請(qǐng)求，參數(shù)：{}", payParam.getOrderId(), JSON.toJSONString(payParam));

        String lockKey = RedisConstant.PAYMENT_LOCK.concat(payParam.getOrderId().toString());
        RLock lock = redisson.getLock(lockKey);
        PaymentVO r = null;
        try {
            lock.lock(redissonPropertiesConfig.getAutomaticReleaseTimeValue(), TimeUnit.SECONDS);

            // 執(zhí)行支付
            r = payService.corePay(payParam);

        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }

        return CommonResult.success(result);
    }
}

@Service
public class PayServiceImpl implements PayService {

    @Resource
    private ApplicationContext applicationContext;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public PaymentVO corePay(PayVO payParam) throws Exception {
        // todo 1. 查詢支付方式配置
        PayTypeDO payType = ...
        // todo 2. 金額預(yù)檢
        validateAmount(payParam.getAmount());

        // todo 3. 檢查訂單狀態(tài)（是否已支付、是否存在）

        // 4. 動(dòng)態(tài)獲取支付實(shí)現(xiàn)類
        CorePayService corePayService = applicationContext.getBean(payType.getServiceName(), CorePayService.class);
        
        // 5. 執(zhí)行支付
        return corePayService.pay(payParam);
    }
}

public interface CorePayService {
    /**
     * 執(zhí)行支付
     * @param payParam 支付參數(shù)
     * @return 支付結(jié)果（如：二維碼鏈接、跳轉(zhuǎn) URL 等）
     */
    PaymentVO pay(PayVO payParam) throws Exception;
}

@Service("AliPayQRCodeServiceImpl")
@Slf4j
public class AliPayQRCodeServiceImpl implements CorePayService {
    @Resource
    private AlipayConfig alipayConfig;
    @Resource
    private AliPayPropertiesConfig aliPayPropertiesConfig;
    @Resource
    private PayLogMapper logMapper;
    @Resource
    private OrderRefundApi orderRefundApi;
    @Resource
    private PayLogMapper payLogMapper;
    @Resource
    private OrderPayLogApi orderPayLogApi;
    @Resource
    private StringRedisTemplate stringRedisTemplate;


    @Override
    public PaymentVO pay(PayVO payParam) throws Exception {
        // 支付日志
        log.info("【{}】訂單支付場(chǎng)景信息 => {}", payLog.getOrderId(), JSONUtil.toJsonStr(build));

        // 支付場(chǎng)景信息保存到redis中，避免傳入的數(shù)據(jù)字節(jié)數(shù)太大導(dǎo)致接口調(diào)用失敗
        stringRedisTemplate.opsForValue().set(PAYMENT_INFO.concat(payLog.getPayPaylog()), JSONUtil.toJsonStr(build), 12, TimeUnit.HOURS);

        // 初始化SDK
        AlipayClient alipayClient = new DefaultAlipayClient(alipayConfig);

        // 構(gòu)造請(qǐng)求參數(shù)以調(diào)用接口
        AlipayTradePrecreateRequest request = new AlipayTradePrecreateRequest();
        AlipayTradePrecreateModel model = new AlipayTradePrecreateModel();

        // 設(shè)置商戶訂單號(hào)
        model.setOutTradeNo(...);

        // 設(shè)置訂單總金額(小數(shù)點(diǎn)后兩位)
        model.setTotalAmount(...);

        // 設(shè)置訂單標(biāo)題
        model.setSubject(...);

        // 設(shè)置產(chǎn)品碼
        model.setProductCode("QR_CODE_OFFLINE");

        // 設(shè)置訂單附加信息
        model.setBody(JSON.toJSONString(payParam.getScenarios()));

        log.info("訂單【{}】申請(qǐng)支付寶QR付款(v3)參數(shù) => {}", payParam.getOrderId(), JSONUtil.toJsonStr(model));

        request.setBizModel(model);

        request.setNotifyUrl(...);

        AlipayTradePrecreateResponse response = alipayClient.execute(request);

        JSONObject entries = JSONUtil.parseObj(response.getBody());

        if (!response.isSuccess()) {
            log.error("訂單【{}】申請(qǐng)支付寶QR付款(v3)失敗響應(yīng) => {}", payParam.getOrderId(), entries);
            throw exception(PayErrorCode.ZFB_QR_PAY_ERR);
        }

        log.info("訂單【{}】申請(qǐng)支付寶QR付款(v3)成功響應(yīng) => {}", payParam.getOrderId(), entries);

        JSONObject resp = entries.getJSONObject("alipay_trade_precreate_response");
        String qrCode = resp.getStr("qr_code");

        return PaymentVO.builder()
                .payType(Integer.valueOf(payParam.getPayTypeNo()))
                .inTradeNo(payParam.getPayLog())
                .param(qrCode)
                .build();
    }