gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix(sj_1.1.0-beta2): 优化事务问题

Browse Source
This commit is contained in:
opensnail 2024-07-04 13:33:16 +08:00
parent 3a4382a9ab
commit fa635db300
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/JobExecutorActor.java
View File

@ -152,7 +152,7 @@ public class JobExecutorActor extends AbstractActor {
// 事务提交以后再执行任务 // 事务提交以后再执行任务
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override @Override
public void afterCompletion(final int status) { public void afterCommit() {
// 获取工作流的上下文 // 获取工作流的上下文
WorkflowTaskBatch workflowTaskBatch = null; WorkflowTaskBatch workflowTaskBatch = null;
Long workflowTaskBatchId = taskExecute.getWorkflowTaskBatchId(); Long workflowTaskBatchId = taskExecute.getWorkflowTaskBatchId();

7
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/executor/job/AbstractJobExecutor.java
View File

@ -1,5 +1,7 @@
package com.aizuda.snailjob.server.job.task.support.executor.job; package com.aizuda.snailjob.server.job.task.support.executor.job;
import cn.hutool.core.collection.CollUtil;
import com.aizuda.snailjob.common.log.SnailJobLog;
import com.aizuda.snailjob.server.job.task.support.JobExecutor; import com.aizuda.snailjob.server.job.task.support.JobExecutor;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -12,8 +14,11 @@ import org.springframework.transaction.annotation.Transactional;
public abstract class AbstractJobExecutor implements JobExecutor, InitializingBean { public abstract class AbstractJobExecutor implements JobExecutor, InitializingBean {
@Override @Override
@Transactional
public void execute(JobExecutorContext context) { public void execute(JobExecutorContext context) {
if (CollUtil.isEmpty(context.getTaskList())) {
SnailJobLog.LOCAL.warn("待执行的任务列表为空. taskBatchId:[{}]", context.getTaskBatchId());
return;
}
doExecute(context); doExecute(context);
} }