wuzhen处理部分内存泄露问题

This commit is contained in:
wuzhen committed 2025-08-18 16:20:44 +08:00
1 parent a600627f4c
commit 30e4c65a91
2 files changed
+6 -89

No files matched your search

@@ -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("🏁 事件监听器处理完成");
}
}
@@ -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;
}
}
}