From 30e4c65a9164c89573afd3d537e561c8aeff95d8 Mon Sep 17 00:00:00 2001 From: wuzhen <52326163@qq.com> Date: Mon, 18 Aug 2025 16:20:44 +0800 Subject: [PATCH] =?UTF-8?q?wuzhen=E5=A4=84=E7=90=86=E9=83=A8=E5=88=86?= =?UTF-8?q?=E5=86=85=E5=AD=98=E6=B3=84=E9=9C=B2=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ApprovalProcessEventListener.java | 12 +-- .../jcbt/task/WorkStudyPositionTask.java | 83 ------------------- 2 files changed, 6 insertions(+), 89 deletions(-) delete mode 100644 backend/ruoyi-modules/ruoyi-jcbt/src/main/java/org/dromara/jcbt/task/WorkStudyPositionTask.java diff --git a/backend/ruoyi-modules/ruoyi-cw/src/main/java/org/dromara/cw/listener/ApprovalProcessEventListener.java b/backend/ruoyi-modules/ruoyi-cw/src/main/java/org/dromara/cw/listener/ApprovalProcessEventListener.java index a33d5230..59d58e87 100644 --- a/backend/ruoyi-modules/ruoyi-cw/src/main/java/org/dromara/cw/listener/ApprovalProcessEventListener.java +++ b/backend/ruoyi-modules/ruoyi-cw/src/main/java/org/dromara/cw/listener/ApprovalProcessEventListener.java @@ -25,15 +25,15 @@ public class ApprovalProcessEventListener { * 处理审批流程创建事件(异步处理,不阻塞主流程) */ @Async("approvalTaskExecutor") - @EventListener + /*@EventListener*/ public void handleApprovalProcessCreated(ApprovalProcessCreatedEvent event) { log.info("🎧 事件监听器被触发:ApprovalProcessCreatedEvent"); - log.info("📋 事件详情:applicationId={}, applicationNo={}, source={}", + log.info("📋 事件详情:applicationId={}, applicationNo={}, source={}", event.getApplicationId(), event.getApplicationNo(), event.getSource().getClass().getSimpleName()); - log.info("👤 用户上下文:userId={}, userName={}, deptId={}, tenantId={}", - event.getCurrentUserId(), event.getCurrentUserName(), + log.info("👤 用户上下文:userId={}, userName={}, deptId={}, tenantId={}", + event.getCurrentUserId(), event.getCurrentUserName(), event.getCurrentDeptId(), event.getCurrentTenantId()); - + try { log.info("🚀 开始处理审批流程创建事件:applicationId={}, applicationNo={}", event.getApplicationId(), event.getApplicationNo()); @@ -61,7 +61,7 @@ public class ApprovalProcessEventListener { log.error("💥 异常堆栈信息:", e); // 事件处理异常,但不影响主业务流程 } - + log.info("🏁 事件监听器处理完成"); } } diff --git a/backend/ruoyi-modules/ruoyi-jcbt/src/main/java/org/dromara/jcbt/task/WorkStudyPositionTask.java b/backend/ruoyi-modules/ruoyi-jcbt/src/main/java/org/dromara/jcbt/task/WorkStudyPositionTask.java deleted file mode 100644 index dda0f358..00000000 --- a/backend/ruoyi-modules/ruoyi-jcbt/src/main/java/org/dromara/jcbt/task/WorkStudyPositionTask.java +++ /dev/null @@ -1,83 +0,0 @@ -package org.dromara.jcbt.task; - -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.dromara.jcbt.service.IJcbtWorkStudyPositionService; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; - -/** - * 勤工俭学岗位定时任务 - * - * @author ruoyi - * @date 2025-01-03 - */ -@Slf4j -@Component -@RequiredArgsConstructor -public class WorkStudyPositionTask { - - private final IJcbtWorkStudyPositionService workStudyPositionService; - - /** - * 自动更新过期岗位状态 - * 每天凌晨1点执行 - */ - @Scheduled(cron = "0 0 1 * * ?") - public void updateExpiredPositions() { - log.info("开始执行过期岗位状态更新任务"); - try { - int count = workStudyPositionService.updateExpiredPositions(); - log.info("过期岗位状态更新任务完成,更新了 {} 个岗位", count); - } catch (Exception e) { - log.error("过期岗位状态更新任务执行失败", e); - } - } - - /** - * 自动更新满员岗位状态 - * 每天凌晨1点30分执行 - */ - @Scheduled(cron = "0 30 1 * * ?") - public void updateFullPositions() { - log.info("开始执行满员岗位状态更新任务"); - try { - int count = workStudyPositionService.updateFullPositions(); - log.info("满员岗位状态更新任务完成,更新了 {} 个岗位", count); - } catch (Exception e) { - log.error("满员岗位状态更新任务执行失败", e); - } - } - - /** - * 手动触发过期岗位状态更新 - * 提供给管理员手动执行的接口 - */ - public int manualUpdateExpiredPositions() { - log.info("手动触发过期岗位状态更新任务"); - try { - int count = workStudyPositionService.updateExpiredPositions(); - log.info("手动过期岗位状态更新完成,更新了 {} 个岗位", count); - return count; - } catch (Exception e) { - log.error("手动过期岗位状态更新失败", e); - throw e; - } - } - - /** - * 手动触发满员岗位状态更新 - * 提供给管理员手动执行的接口 - */ - public int manualUpdateFullPositions() { - log.info("手动触发满员岗位状态更新任务"); - try { - int count = workStudyPositionService.updateFullPositions(); - log.info("手动满员岗位状态更新完成,更新了 {} 个岗位", count); - return count; - } catch (Exception e) { - log.error("手动满员岗位状态更新失败", e); - throw e; - } - } -}