first commit

WangHan

2024-09-12 d5855a4926926698b740bc6c7ba489de47adb68b

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package tech.powerjob.official.processors;
 
import tech.powerjob.common.model.LogConfig;
import tech.powerjob.worker.core.processor.TaskContext;
import tech.powerjob.worker.core.processor.WorkflowContext;
import tech.powerjob.worker.log.impl.OmsLocalLogger;
 
import java.util.concurrent.ThreadLocalRandom;
 
/**
 * TestUtils
 *
 * @author tjq
 * @since 2021/1/30
 */
public class TestUtils {
 
    public static TaskContext genTaskContext(String jobParams) {
 
        long jobId = ThreadLocalRandom.current().nextLong();
 
        TaskContext taskContext = new TaskContext();
        taskContext.setJobId(jobId);
        taskContext.setInstanceId(jobId);
        taskContext.setJobParams(jobParams);
        taskContext.setTaskId("0.0");
        taskContext.setTaskName("TEST_TASK");
        taskContext.setOmsLogger(new OmsLocalLogger(new LogConfig()));
        taskContext.setWorkflowContext(new WorkflowContext(null, null));
        return taskContext;
    }
}