From d286ecb4da97fdefb5ec56ec19c38a45f06b1c33 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Fri, 6 Feb 2026 21:25:51 +0800
Subject: [PATCH] =?UTF-8?q?fix(task):=20=E8=A7=A3=E5=86=B3=E5=8E=9F?=
 =?UTF-8?q?=E4=BD=8D=E6=9B=BF=E6=8D=A2=E6=A8=A1=E5=BC=8F=E4=B8=8B=E6=97=A7?=
 =?UTF-8?q?=E6=98=A0=E5=B0=84=E6=AE=8B=E7=95=99=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 在插入新映射前先删除已存在的旧映射记录
- 添加日志记录以便追踪旧映射删除操作
- 确保轮询服务能够正确处理最新的任务渲染作业映射关系
---
 .../ycwl/basic/service/task/impl/TaskTaskServiceImpl.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java
index 06400328..9a64d6c0 100644
--- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java
+++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java
@@ -722,6 +722,12 @@ public class TaskTaskServiceImpl implements TaskService {
 
                 // 写入mapping表，供轮询服务处理
                 try {
+                    // 原位替换模式下可能已有旧映射，先删除再插入
+                    TaskRenderJobMappingEntity existingMapping = taskRenderJobMappingMapper.selectByTaskId(taskId);
+                    if (existingMapping != null) {
+                        taskRenderJobMappingMapper.deleteById(existingMapping.getId());
+                        log.info("[灰度测试] 已删除旧mapping, taskId: {}, oldRenderJobId: {}", taskId, existingMapping.getRenderJobId());
+                    }
                     TaskRenderJobMappingEntity mapping = new TaskRenderJobMappingEntity();
                     mapping.setTaskId(taskId);
                     mapping.setRenderJobId(response.getJobId());