third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: optimize initialization of workflow context

Browse Source
This commit is contained in:
Echo009 2021-03-01 20:02:38 +08:00
parent da6eb3705b
commit 44ae97d6d8
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/WorkflowContext.java
View File

@ -5,6 +5,7 @@ import com.github.kfcfans.powerjob.common.utils.JsonUtils;
import com.google.common.collect.Maps;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import java.util.Map;
@ -34,11 +35,14 @@ public class WorkflowContext {
@SuppressWarnings({"rawtypes", "unchecked"})
public WorkflowContext(Long instanceId, String data) {
this.instanceId = instanceId;
if (StringUtils.isBlank(data)) {
return;
}
try {
Map originMap = JsonUtils.parseObject(data, Map.class);
originMap.forEach((k, v) -> this.data.put(String.valueOf(k), v == null ? null : String.valueOf(v)));
} catch (Exception exception) {
log.warn("[WorkflowContext-{}] parse workflow context failed, {}", instanceId, exception);
log.warn("[WorkflowContext-{}] parse workflow context failed, {}", instanceId, exception.getMessage());
}
}