feat(sj_1.1.0-beta2): 透传配置的工作流上下文至批次中

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/dto/WorkflowPartitionTaskDTO.java

@@ -53,4 +53,9 @@ public class WorkflowPartitionTaskDTO extends PartitionTask {
      */
     private String flowInfo;
 
+    /**
+     * 工作流上下文
+     */
+    private String wfContext;
+
 }

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/dto/WorkflowTaskPrepareDTO.java

@@ -73,4 +73,9 @@ public class WorkflowTaskPrepareDTO {
      * 仅做超时检测
      */
     private boolean onlyTimeoutCheck;
+
+    /**
+     * 工作流上下文
+     */
+    private String wfContext;
 }

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/ScanWorkflowTaskActor.java

@@ -134,7 +134,7 @@ public class ScanWorkflowTaskActor extends AbstractActor {
                 new LambdaQueryWrapper<Workflow>()
                         .select(Workflow::getId, Workflow::getGroupName, Workflow::getNextTriggerAt, Workflow::getTriggerType,
                                 Workflow::getTriggerInterval, Workflow::getExecutorTimeout, Workflow::getNamespaceId,
-                                Workflow::getFlowInfo, Workflow::getBlockStrategy)
+                                Workflow::getFlowInfo, Workflow::getBlockStrategy, Workflow::getWfContext)
                         .eq(Workflow::getWorkflowStatus, StatusEnum.YES.getStatus())
                         .eq(Workflow::getDeleted, StatusEnum.NO.getStatus())
                         .in(Workflow::getBucketIndex, scanTask.getBuckets())

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/WorkflowTaskPrepareActor.java

@@ -55,6 +55,7 @@ public class WorkflowTaskPrepareActor extends AbstractActor {
                 // 终态任务
                 if (workflowPrePareHandler.matches(null)) {
                     workflowPrePareHandler.handler(workflowTaskPrepareDTO);
+                    break;
                 }
             }
         } else {

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/generator/batch/WorkflowBatchGenerator.java

@@ -34,6 +34,7 @@ public class WorkflowBatchGenerator {
         WorkflowTaskBatch workflowTaskBatch = WorkflowTaskConverter.INSTANCE.toWorkflowTaskBatch(context);
         workflowTaskBatch.setTaskBatchStatus(Optional.ofNullable(context.getTaskBatchStatus()).orElse(JobTaskBatchStatusEnum.WAITING.getStatus()));
         workflowTaskBatch.setOperationReason(context.getOperationReason());
+        workflowTaskBatch.setWfContext(context.getWfContext());
 
         Assert.isTrue(1 == workflowTaskBatchMapper.insert(workflowTaskBatch), () -> new SnailJobServerException("新增调度任务失败. [{}]", context.getWorkflowId()));
 

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/generator/batch/WorkflowTaskBatchGeneratorContext.java

@@ -47,5 +47,10 @@ public class WorkflowTaskBatchGeneratorContext {
      */
     private String flowInfo;
 
+    /**
+     * 工作流上下文
+     */
+    private String wfContext;
+
 
 }