From 235ef24e4bbfc9c17db95d06dbaded4892ca3816 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Tue, 14 Apr 2026 10:48:20 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E4=BF=AE=E5=A4=8D=E3=80=91=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D=E6=B4=BE=E5=B7=A5=E5=8D=95=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E7=8A=B6=E6=80=81=E5=88=A4=E6=96=AD=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gongfu/task/DispatchScheduledTasks.java | 34 ++++++++++++------- 1 file changed, 22 insertions(+), 12 deletions(-) diff --git a/nflg-mobilebroken-gongfu/src/main/java/com/nflg/mobilebroken/gongfu/task/DispatchScheduledTasks.java b/nflg-mobilebroken-gongfu/src/main/java/com/nflg/mobilebroken/gongfu/task/DispatchScheduledTasks.java index c35b868c..1b795b5f 100644 --- a/nflg-mobilebroken-gongfu/src/main/java/com/nflg/mobilebroken/gongfu/task/DispatchScheduledTasks.java +++ b/nflg-mobilebroken-gongfu/src/main/java/com/nflg/mobilebroken/gongfu/task/DispatchScheduledTasks.java @@ -1,9 +1,12 @@ package com.nflg.mobilebroken.gongfu.task; +import com.nflg.mobilebroken.common.constant.Constant; import com.nflg.mobilebroken.common.util.DateTimeUtil; +import com.nflg.mobilebroken.common.util.IdUtil; import com.nflg.mobilebroken.repository.entity.GongfuDispatch; import com.nflg.mobilebroken.repository.service.IGongfuDispatchService; import lombok.extern.slf4j.Slf4j; +import org.slf4j.MDC; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -24,17 +27,24 @@ public class DispatchScheduledTasks { */ @Scheduled(cron = "0 0 0 * * ?") public void setState() { - List datas = dispatchService.lambdaQuery().eq(GongfuDispatch::getState, 0).list(); - log.info("共{}条记录", datas.size()); - String now = DateTimeUtil.format(LocalDate.now(), "yyyy-MM-dd"); - datas.forEach(data -> { - log.info("开始处理{}:{}", data.getId(), data.getTitle()); - if (data.getPlanStartDate().compareTo(now) >= 0) { - log.info("设置为处理中"); - data.setState(1); - dispatchService.updateById(data); - } - log.info("处理完成"); - }); + try { + MDC.put(Constant.TRACE_ID, IdUtil.getIdStr()); + List datas = dispatchService.lambdaQuery().eq(GongfuDispatch::getState, 0).list(); + log.info("共{}条记录", datas.size()); + String now = DateTimeUtil.format(LocalDate.now(), "yyyy-MM-dd"); + datas.forEach(data -> { + log.info("开始处理{}:{}", data.getId(), data.getTitle()); + if (now.compareTo(data.getPlanStartDate()) >= 0) { + log.info("设置为处理中"); + data.setState(1); + dispatchService.updateById(data); + } + log.info("处理完成"); + }); + } catch (Exception e) { + log.error("设置状态失败", e); + } finally { + MDC.remove(Constant.TRACE_ID); + } } }