后端增加发放好客权益券的接口

server/dukang-api/src/modules/ops/admin-benefit.service.ts

@@ -4,11 +4,16 @@ import { PrismaService } from '../../common/prisma/prisma.module';
 import { serializeBigInt } from '../../common/decorators/current-user.decorator';
 import { buildBenefitLedgerEvent, benefitLedgerWhere } from '../../common/event/event.helpers';
 import { mapBenefitLedgerCompat } from '../../common/compat/v31-compat';
+import { BenefitService } from '../benefit/benefit.service';
 import type { AdminBenefitCouponsQueryDto, AdminBenefitLedgersQueryDto } from './dto/admin-query.dto';
+import type { AdminBenefitGrantDto } from './dto/admin-mutate.dto';
 
 @Injectable()
 export class AdminBenefitService {
-  constructor(private readonly prisma: PrismaService) {}
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly benefitService: BenefitService,
+  ) {}
 
   async listCoupons(query: AdminBenefitCouponsQueryDto) {
     const page = query.page ?? 1;
@@ -80,6 +85,32 @@ export class AdminBenefitService {
     return serializeBigInt(updated);
   }
 
+  async grantCoupon(dto: AdminBenefitGrantDto) {
+    const phone = dto.phone.trim();
+    if (!/^1[3-9]\d{9}$/.test(phone)) {
+      throw new BadRequestException('请输入正确的用户手机号');
+    }
+
+    const user = await this.prisma.user.findFirst({
+      where: { phone, status: 1, mergedIntoUserId: null },
+      select: { id: true, userNo: true, phone: true, nickname: true },
+    });
+    if (!user) {
+      throw new NotFoundException('未找到该手机号对应的用户');
+    }
+
+    const coupon = await this.benefitService.grantManual({
+      userId: user.id,
+      amount: dto.amount,
+      remark: dto.remark,
+    });
+
+    return serializeBigInt({
+      ...coupon,
+      user,
+    });
+  }
+
   async listLedgers(query: AdminBenefitLedgersQueryDto) {
     const page = query.page ?? 1;
     const pageSize = query.pageSize ?? 20;