diff --git a/backend/services/planting-service/src/infrastructure/persistence/repositories/contract-signing-task.repository.impl.ts b/backend/services/planting-service/src/infrastructure/persistence/repositories/contract-signing-task.repository.impl.ts index bc092cee..ca138357 100644 --- a/backend/services/planting-service/src/infrastructure/persistence/repositories/contract-signing-task.repository.impl.ts +++ b/backend/services/planting-service/src/infrastructure/persistence/repositories/contract-signing-task.repository.impl.ts @@ -41,9 +41,11 @@ export class ContractSigningTaskRepositoryImpl implements IContractSigningTaskRe }); return this.mapToDomain(updated); } else { - // 创建 - const created = await this.prisma.contractSigningTask.create({ - data: { + // 创建 - 使用 upsert 处理并发幂等性 + // 如果 orderNo 已存在,则只返回现有记录(不更新) + const result = await this.prisma.contractSigningTask.upsert({ + where: { orderNo: task.orderNo }, + create: { orderNo: task.orderNo, userId: task.userId, accountSequence: task.accountSequence, @@ -62,8 +64,10 @@ export class ContractSigningTaskRepositoryImpl implements IContractSigningTaskRe status: task.status, expiresAt: task.expiresAt, }, + // 如果已存在,不更新任何字段,只返回现有记录 + update: {}, }); - return this.mapToDomain(created); + return this.mapToDomain(result); } }