From 44f5008fd16f6eacc76df6b2906dfd122cb9cd33 Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Thu, 1 Jan 2026 19:55:33 +0800 Subject: [PATCH] =?UTF-8?q?refactor(task):=20=E4=BC=98=E5=8C=96=E9=87=8D?= =?UTF-8?q?=E5=A4=8D=E4=BB=BB=E5=8A=A1=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 移除旧任务更新逻辑,简化重复任务处理流程 - 替换视频查询方法调用,使用新的存储库方法 - 保持任务缓存清除功能 - 简化日志输出信息 --- .../basic/service/task/impl/TaskTaskServiceImpl.java | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) 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 0c839ea0..c2183611 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 @@ -440,19 +440,11 @@ public class TaskTaskServiceImpl implements TaskService { memberVideoEntity.setTaskId(taskEntity.getId()); } else { TaskRespVO existingTask = list.getFirst(); - log.info("重复task,更新旧任务! faceId:{},templateId:{},taskId:{}", faceId, templateId, existingTask.getId()); - // 更新旧任务:重置status为0,更新taskParams - TaskEntity taskUpdate = new TaskEntity(); - taskUpdate.setId(existingTask.getId()); - taskUpdate.setStatus(0); - taskUpdate.setTaskParams(JacksonUtil.toJSONString(sourcesMap)); - taskMapper.update(taskUpdate); - // 显式清除workerId(update方法的动态SQL会跳过null值) - taskMapper.deassign(existingTask.getId()); + log.info("重复task! faceId:{},templateId:{},taskId:{}", faceId, templateId, existingTask.getId()); videoTaskRepository.clearTaskCache(existingTask.getId()); memberVideoEntity.setTaskId(existingTask.getId()); - VideoEntity video = videoMapper.findByTaskId(existingTask.getId()); + VideoEntity video = videoRepository.getVideoByTaskId(existingTask.getId()); if (video != null) { IsBuyRespVO isBuy = orderBiz.isBuy(existingTask.getScenicId(), face.getMemberId(), face.getId(), 0, video.getId()); if (isBuy.isBuy()) {