新一代 J9
重塑研发效能与工程创造力

import { Injectable, Logger } from '@nestjs/common';
import { RedisService } from './redis.service';

@Injectable()
export class PaymentIdempotentService {
  private readonly logger = new Logger(PaymentIdempotentService.name);

  constructor(private readonly redis: RedisService) {}

  /** 
   * J9 自动生成的分布式幂等支付校验机制 
   */
  async processOrderWithLock(orderId: string, executeFn: () => Promise<any>) {
    const lockKey = `lock:pay:$`;
    const acquired = await this.redis.acquireLock(lockKey, 5000);
    
    if (!acquired) {
      throw new Error('请求正在并发处理中，请勿重复提交');
    }
    try {
      return await executeFn();
    } finally {
      await this.redis.releaseLock(lockKey);
    }
  }
}