Sales Order SPK & Automated Provisioning Lifecycle

// Service Order SPK & Automated Provisioning Service di NestJS
@Injectable()
export class ServiceOrderProvisioningService {
  constructor(
    @InjectDataSource() private readonly dataSource: DataSource,
    private readonly redisService: RedisService,
    private readonly radiusClient: RadiusClientService,
  ) {}

  async createServiceOrder(dto: CreateOrderSpkDto): Promise<ServiceOrderResponse> {
    const queryRunner = this.dataSource.createQueryRunner();
    await queryRunner.connect();
    await queryRunner.startTransaction('SERIALIZABLE');

    try {
      // 1. Verifikasi ketersediaan port ODP dengan pessimistic write lock
      const odp = await queryRunner.manager.createQueryBuilder(OdpNode, 'odp')
        .setLock('pessimistic_write')
        .where('odp.id = :id', { id: dto.odpId })
        .getOne();

      if (!odp || odp.usedPorts >= odp.totalPorts) {
        throw new ConflictException('Port splitter ODP telah penuh.');
      }

      // 2. Lock port ODP di Redis (TTL 24 Jam)
      const lockKey = `lock:odp:${odp.id}:port:${odp.usedPorts + 1}`;
      const locked = await this.redisService.set(lockKey, dto.customerNik, 'EX', 86400, 'NX');
      if (!locked) {
        throw new ConflictException('Port sedang dalam reservasi aktif SPK lain.');
      }

      // 3. Terbitkan record SPK bernomor urut resmi
      const spkNumber = `SPK-${new Date().getFullYear()}-${dto.branchCode}-${Math.floor(1000 + Math.random() * 9000)}`;
      const order = queryRunner.manager.create(ServiceOrder, {
        spkNumber,
        customerName: dto.customerName,
        customerNik: dto.customerNik,
        customerPhone: dto.customerPhone,
        packageCode: dto.packageCode,
        odpId: odp.id,
        portIndex: odp.usedPorts + 1,
        status: 'SPK_ISSUED',
        createdAt: new Date(),
      });
      await queryRunner.manager.save(order);

      // Increment port used count
      await queryRunner.manager.update(OdpNode, odp.id, {
        usedPorts: odp.usedPorts + 1,
      });

      await queryRunner.commitTransaction();

      // 4. Pre-provision akun PPPoE di FreeRADIUS
      await this.radiusClient.createSubscriberAccount({
        username: `user_${dto.customerPhone.slice(-6)}`,
        profileSpeed: dto.packageCode,
        nasIp: odp.nasIp,
      });

      return { spkNumber, status: 'SPK_ISSUED', reservedPort: odp.usedPorts + 1 };
    } catch (err) {
      await queryRunner.rollbackTransaction();
      throw err;
    } finally {
      await queryRunner.release();
    }
  }
}